diff options
author | Julien Dessaux | 2025-01-27 22:00:51 +0100 |
---|---|---|
committer | Julien Dessaux | 2025-01-27 22:00:51 +0100 |
commit | 26e10a9399bd6185741d0912ffa54c807ffef671 (patch) | |
tree | 0cf9e81c6880b07d9c029e3abd6ee03b6a2acdb1 /pkg/database/versions.go | |
parent | chore(webui): remove redundant set of the Cache-Control header in state get h... (diff) | |
download | tfstated-26e10a9399bd6185741d0912ffa54c807ffef671.tar.gz tfstated-26e10a9399bd6185741d0912ffa54c807ffef671.tar.bz2 tfstated-26e10a9399bd6185741d0912ffa54c807ffef671.zip |
feat(webui): implement state versions list
Diffstat (limited to '')
-rw-r--r-- | pkg/database/versions.go | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/pkg/database/versions.go b/pkg/database/versions.go new file mode 100644 index 0000000..5a6f11f --- /dev/null +++ b/pkg/database/versions.go @@ -0,0 +1,35 @@ +package database + +import ( + "fmt" + "time" + + "git.adyxax.org/adyxax/tfstated/pkg/model" +) + +func (db *DB) LoadVersionsByState(state *model.State) ([]model.Version, error) { + rows, err := db.Query( + `SELECT account_id, created, data, id, lock + FROM versions + WHERE state_id = ? + ORDER BY id DESC;`, state.Id) + if err != nil { + return nil, fmt.Errorf("failed to load versions from database: %w", err) + } + defer rows.Close() + versions := make([]model.Version, 0) + for rows.Next() { + var version model.Version + var created int64 + err = rows.Scan(&version.AccountId, &created, &version.Data, &version.Id, &version.Lock) + if err != nil { + return nil, fmt.Errorf("failed to load version from row: %w", err) + } + version.Created = time.Unix(created, 0) + versions = append(versions, version) + } + if err := rows.Err(); err != nil { + return nil, fmt.Errorf("failed to load versions from rows: %w", err) + } + return versions, nil +} |