summaryrefslogtreecommitdiff
path: root/pkg/database/versions.go
diff options
context:
space:
mode:
Diffstat (limited to 'pkg/database/versions.go')
-rw-r--r--pkg/database/versions.go32
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