summaryrefslogtreecommitdiff
path: root/pkg/database/states.go
diff options
context:
space:
mode:
authorJulien Dessaux2024-11-13 21:08:48 +0100
committerJulien Dessaux2024-11-13 21:08:48 +0100
commit4020344eda4d2a988f11dc60ac7c55a97aa39774 (patch)
treec5a6da4f1ddfea23642e0598f9623e18ac4f1659 /pkg/database/states.go
parentchore(deps): update dependencies (diff)
downloadtfstated-4020344eda4d2a988f11dc60ac7c55a97aa39774.tar.gz
tfstated-4020344eda4d2a988f11dc60ac7c55a97aa39774.tar.bz2
tfstated-4020344eda4d2a988f11dc60ac7c55a97aa39774.zip
chore(tfstated): rename state "name" to "path" for consistency
Diffstat (limited to 'pkg/database/states.go')
-rw-r--r--pkg/database/states.go22
1 files changed, 11 insertions, 11 deletions
diff --git a/pkg/database/states.go b/pkg/database/states.go
index 5536533..d1e9c7d 100644
--- a/pkg/database/states.go
+++ b/pkg/database/states.go
@@ -8,8 +8,8 @@ import (
)
// returns true in case of successful deletion
-func (db *DB) DeleteState(name string) (bool, error) {
- result, err := db.Exec(`DELETE FROM states WHERE name = ?;`, name)
+func (db *DB) DeleteState(path string) (bool, error) {
+ result, err := db.Exec(`DELETE FROM states WHERE path = ?;`, path)
if err != nil {
return false, err
}
@@ -20,16 +20,16 @@ func (db *DB) DeleteState(name string) (bool, error) {
return n == 1, nil
}
-func (db *DB) GetState(name string) ([]byte, error) {
+func (db *DB) GetState(path string) ([]byte, error) {
var encryptedData []byte
err := db.QueryRow(
`SELECT versions.data
FROM versions
JOIN states ON states.id = versions.state_id
- WHERE states.name = ?
+ WHERE states.path = ?
ORDER BY versions.id DESC
LIMIT 1;`,
- name).Scan(&encryptedData)
+ path).Scan(&encryptedData)
if err != nil {
if errors.Is(err, sql.ErrNoRows) {
return []byte{}, nil
@@ -43,7 +43,7 @@ func (db *DB) GetState(name string) ([]byte, error) {
}
// returns true in case of id mismatch
-func (db *DB) SetState(name string, data []byte, lockID string) (bool, error) {
+func (db *DB) SetState(path string, data []byte, lockID string) (bool, error) {
encryptedData, err := db.dataEncryptionKey.EncryptAES256(data)
if err != nil {
return false, err
@@ -61,10 +61,10 @@ func (db *DB) SetState(name string, data []byte, lockID string) (bool, error) {
stateID int64
lockData []byte
)
- if err = tx.QueryRowContext(db.ctx, `SELECT id, lock->>'ID' FROM states WHERE name = ?;`, name).Scan(&stateID, &lockData); err != nil {
+ if err = tx.QueryRowContext(db.ctx, `SELECT id, lock->>'ID' FROM states WHERE path = ?;`, path).Scan(&stateID, &lockData); err != nil {
if errors.Is(err, sql.ErrNoRows) {
var result sql.Result
- result, err = tx.ExecContext(db.ctx, `INSERT INTO states(name) VALUES (?)`, name)
+ result, err = tx.ExecContext(db.ctx, `INSERT INTO states(path) VALUES (?)`, path)
if err != nil {
return false, err
}
@@ -95,16 +95,16 @@ func (db *DB) SetState(name string, data []byte, lockID string) (bool, error) {
`DELETE FROM versions
WHERE state_id = (SELECT id
FROM states
- WHERE name = :name)
+ WHERE path = :path)
AND id < (SELECT MIN(id)
FROM(SELECT versions.id
FROM versions
JOIN states ON states.id = versions.state_id
- WHERE states.name = :name
+ WHERE states.path = :path
ORDER BY versions.id DESC
LIMIT :limit));`,
sql.Named("limit", db.versionsHistoryLimit),
- sql.Named("name", name),
+ sql.Named("path", path),
)
if err != nil {
return false, err