tenseleyflow/shithub / 75713ce

+// SPDX-License-Identifier: AGPL-3.0-or-later

+

+package meta_test

+

+import (

+	"context"

+	"testing"

+

+	metadb "github.com/tenseleyFlow/shithub/internal/meta/sqlc"

+	"github.com/tenseleyFlow/shithub/internal/testing/dbtest"

+)

+

+// TestMetaRoundtrip exercises the dbtest harness end-to-end: clone-from-template,

+// migrations applied, sqlc-generated queries against the meta table.

+func TestMetaRoundtrip(t *testing.T) {

+	t.Parallel()

+	pool := dbtest.NewTestDB(t)

+	q := metadb.New()

+	ctx := context.Background()

+

+	// Migrations populate the schema_version + app rows.

+	got, err := q.GetMeta(ctx, pool, "schema_version")

+	if err != nil {

+		t.Fatalf("GetMeta(schema_version): %v", err)

+	}

+	if string(got.Value) != `"0001"` {

+		t.Errorf("schema_version: got %s, want %q", got.Value, `"0001"`)

+	}

+

+	// Set a new key and read it back.

+	if err := q.SetMeta(ctx, pool, metadb.SetMetaParams{Key: "test_key", Value: []byte(`"hello"`)}); err != nil {

+		t.Fatalf("SetMeta: %v", err)

+	}

+	got2, err := q.GetMeta(ctx, pool, "test_key")

+	if err != nil {

+		t.Fatalf("GetMeta(test_key): %v", err)

+	}

+	if string(got2.Value) != `"hello"` {

+		t.Errorf("test_key: got %s, want %q", got2.Value, `"hello"`)

+	}

+

+	// updated_at trigger: re-set with a new value, updated_at advances.

+	first := got2.UpdatedAt

+	if err := q.SetMeta(ctx, pool, metadb.SetMetaParams{Key: "test_key", Value: []byte(`"world"`)}); err != nil {

+		t.Fatalf("SetMeta upsert: %v", err)

+	}

+	got3, err := q.GetMeta(ctx, pool, "test_key")

+	if err != nil {

+		t.Fatalf("GetMeta upsert: %v", err)

+	}

+	if !got3.UpdatedAt.Time.After(first.Time) {

+		t.Errorf("updated_at trigger did not advance: first=%v, after=%v", first.Time, got3.UpdatedAt.Time)

+	}

+

+	// List + delete.

+	rows, err := q.ListMeta(ctx, pool)

+	if err != nil {

+		t.Fatalf("ListMeta: %v", err)

+	}

+	if len(rows) < 3 { // schema_version, app, test_key

+		t.Errorf("ListMeta: got %d rows, want >= 3", len(rows))

+	}

+	if err := q.DeleteMeta(ctx, pool, "test_key"); err != nil {

+		t.Fatalf("DeleteMeta: %v", err)

+	}

+}

+

+// TestMetaParallelism asserts dbtest gives each parallel test its own DB.

+// If two parallel tests shared a database, the writes here would race.

+func TestMetaParallelism(t *testing.T) {

+	t.Parallel()

+	for i := 0; i < 4; i++ {

+		i := i

+		t.Run("worker", func(t *testing.T) {

+			t.Parallel()

+			pool := dbtest.NewTestDB(t)

+			q := metadb.New()

+			key := "parallel_key"

+			val := []byte(`"worker"`)

+			if err := q.SetMeta(context.Background(), pool, metadb.SetMetaParams{Key: key, Value: val}); err != nil {

+				t.Fatalf("SetMeta worker %d: %v", i, err)

+			}

+		})

+	}

+}

+-- SPDX-License-Identifier: AGPL-3.0-or-later

+

+-- name: GetMeta :one

+SELECT key, value, updated_at

+FROM meta

+WHERE key = $1;

+

+-- name: SetMeta :exec

+INSERT INTO meta (key, value)

+VALUES ($1, $2)

+ON CONFLICT (key) DO UPDATE

+    SET value = EXCLUDED.value;

+

+-- name: ListMeta :many

+SELECT key, value, updated_at

+FROM meta

+ORDER BY key;

+

+-- name: DeleteMeta :exec

+DELETE FROM meta WHERE key = $1;

+// Code generated by sqlc. DO NOT EDIT.

+// versions:

+//   sqlc v1.31.1

+

+package metadb

+

+import (

+	"context"

+

+	"github.com/jackc/pgx/v5"

+	"github.com/jackc/pgx/v5/pgconn"

+)

+

+type DBTX interface {

+	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)

+	Query(context.Context, string, ...interface{}) (pgx.Rows, error)

+	QueryRow(context.Context, string, ...interface{}) pgx.Row

+}

+

+func New() *Queries {

+	return &Queries{}

+}

+

+type Queries struct {

+}

+// Code generated by sqlc. DO NOT EDIT.

+// versions:

+//   sqlc v1.31.1

+

+package metadb

+

+import (

+	"github.com/jackc/pgx/v5/pgtype"

+)

+

+type Meta struct {

+	Key       string

+	Value     []byte

+	UpdatedAt pgtype.Timestamptz

+}

+// Code generated by sqlc. DO NOT EDIT.

+// versions:

+//   sqlc v1.31.1

+

+package metadb

+

+import (

+	"context"

+)

+

+type Querier interface {

+	DeleteMeta(ctx context.Context, db DBTX, key string) error

+	// SPDX-License-Identifier: AGPL-3.0-or-later

+	GetMeta(ctx context.Context, db DBTX, key string) (Meta, error)

+	ListMeta(ctx context.Context, db DBTX) ([]Meta, error)

+	SetMeta(ctx context.Context, db DBTX, arg SetMetaParams) error

+}

+

+var _ Querier = (*Queries)(nil)

+// Code generated by sqlc. DO NOT EDIT.

+// versions:

+//   sqlc v1.31.1

+// source: queries.sql

+

+package metadb

+

+import (

+	"context"

+)

+

+const deleteMeta = `-- name: DeleteMeta :exec

+DELETE FROM meta WHERE key = $1

+`

+

+func (q *Queries) DeleteMeta(ctx context.Context, db DBTX, key string) error {

+	_, err := db.Exec(ctx, deleteMeta, key)

+	return err

+}

+

+const getMeta = `-- name: GetMeta :one

+

+SELECT key, value, updated_at

+FROM meta

+WHERE key = $1

+`

+

+// SPDX-License-Identifier: AGPL-3.0-or-later

+func (q *Queries) GetMeta(ctx context.Context, db DBTX, key string) (Meta, error) {

+	row := db.QueryRow(ctx, getMeta, key)

+	var i Meta

+	err := row.Scan(&i.Key, &i.Value, &i.UpdatedAt)

+	return i, err

+}

+

+const listMeta = `-- name: ListMeta :many

+SELECT key, value, updated_at

+FROM meta

+ORDER BY key

+`

+

+func (q *Queries) ListMeta(ctx context.Context, db DBTX) ([]Meta, error) {

+	rows, err := db.Query(ctx, listMeta)

+	if err != nil {

+		return nil, err

+	}

+	defer rows.Close()

+	items := []Meta{}

+	for rows.Next() {

+		var i Meta

+		if err := rows.Scan(&i.Key, &i.Value, &i.UpdatedAt); err != nil {

+			return nil, err

+		}

+		items = append(items, i)

+	}

+	if err := rows.Err(); err != nil {

+		return nil, err

+	}

+	return items, nil

+}

+

+const setMeta = `-- name: SetMeta :exec

+INSERT INTO meta (key, value)

+VALUES ($1, $2)

+ON CONFLICT (key) DO UPDATE

+    SET value = EXCLUDED.value

+`

+

+type SetMetaParams struct {

+	Key   string

+	Value []byte

+}

+

+func (q *Queries) SetMeta(ctx context.Context, db DBTX, arg SetMetaParams) error {

+	_, err := db.Exec(ctx, setMeta, arg.Key, arg.Value)

+	return err

+}

+# Seed SQL files dropped here are loaded in lex order by `shithubd seed`.

+# Numbered prefixes recommended (e.g. 010_users.sql, 020_repos.sql).

+# Domain seeds will land in their owning sprints (S05+).

+version: "2"

+sql:

+  - engine: postgresql

+    schema: internal/migrationsfs/migrations

+    queries: internal/meta/queries

+    gen:

+      go:

+        package: metadb

+        out: internal/meta/sqlc

+        sql_package: pgx/v5

+        emit_json_tags: false

+        emit_pointers_for_null_types: false

+        emit_prepared_queries: false

+        emit_interface: true

+        emit_exact_table_names: false

+        emit_empty_slices: true

+        emit_methods_with_db_argument: true

+        rename:

+          tg_set_updated_at: TgSetUpdatedAt