diff options
author | Julien Dessaux | 2025-01-28 00:30:30 +0100 |
---|---|---|
committer | Julien Dessaux | 2025-01-28 00:30:30 +0100 |
commit | 21c8d6601a274262074e39845be24d8020d2e5aa (patch) | |
tree | cad793b4984574c0763e148fb2ac6008a11951a6 /pkg/database/versions.go | |
parent | feat(webui): implement state versions list (diff) | |
download | tfstated-21c8d6601a274262074e39845be24d8020d2e5aa.tar.gz tfstated-21c8d6601a274262074e39845be24d8020d2e5aa.tar.bz2 tfstated-21c8d6601a274262074e39845be24d8020d2e5aa.zip |
feat(webui): bootstrap state version page
Diffstat (limited to 'pkg/database/versions.go')
-rw-r--r-- | pkg/database/versions.go | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/pkg/database/versions.go b/pkg/database/versions.go index 5a6f11f..f05d230 100644 --- a/pkg/database/versions.go +++ b/pkg/database/versions.go @@ -1,12 +1,44 @@ package database import ( + "database/sql" + "errors" "fmt" "time" "git.adyxax.org/adyxax/tfstated/pkg/model" ) +func (db *DB) LoadVersionById(id int) (*model.Version, error) { + version := model.Version{ + Id: id, + } + var ( + created int64 + encryptedData []byte + ) + err := db.QueryRow( + `SELECT account_id, state_id, data, lock, created FROM versions WHERE id = ?;`, + id).Scan( + &version.AccountId, + &version.StateId, + &encryptedData, + &version.Lock, + &created) + if err != nil { + if errors.Is(err, sql.ErrNoRows) { + return nil, nil + } + return nil, fmt.Errorf("failed to load version id %d from database: %w", id, err) + } + version.Created = time.Unix(created, 0) + version.Data, err = db.dataEncryptionKey.DecryptAES256(encryptedData) + if err != nil { + return nil, fmt.Errorf("failed to decrypt version %d data: %w", id, err) + } + return &version, nil +} + func (db *DB) LoadVersionsByState(state *model.State) ([]model.Version, error) { rows, err := db.Query( `SELECT account_id, created, data, id, lock |