From 21c8d6601a274262074e39845be24d8020d2e5aa Mon Sep 17 00:00:00 2001 From: Julien Dessaux Date: Tue, 28 Jan 2025 00:30:30 +0100 Subject: feat(webui): bootstrap state version page --- pkg/database/versions.go | 32 ++++++++++++++++++++++++++++++++ 1 file changed, 32 insertions(+) (limited to 'pkg/database/versions.go') 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 -- cgit v1.2.3