novox/mesh-catalog
18
0
Fork 0
Code Issues Pull Requests 5 Actions Packages Projects Releases Wiki Activity

Run postgres on the SDK's harness and moved path, dropping its copies (issue 849)

Browse Source
This commit is contained in:
fix-cat-pas@novox
2026-10-16 19:35:22 +02:00
parent 2f09dd8501
commit 33759f8b57
15 changed files with 78 additions and 2910 deletions
Download Patch File Download Diff File Expand all files Collapse all files
modules/postgres/cmd/postgres-provider/live_test.go
+8 -7
View File
@@ -12,6 +12,7 @@ package main
// COMMIT (novox/hq ADR 0230).
import (
"git.novox.be/novox/mesh-sdk/go/provider/harness"
"net/url"
"os"
"testing"
@@ -31,7 +32,7 @@ func TestLive(t *testing.T) {
t.Fatal(err)
}
a := provisioner{pg: c, announce: func(string, map[string]string) {}}
p := Provision{As: "mesh_test_letta", Password: "consumer-pw", Values: map[string]any{"name": "letta", "extensions": []any{"vector"}}}
p := harness.Provision{As: "mesh_test_letta", Password: "consumer-pw", Values: map[string]any{"name": "letta", "extensions": []any{"vector"}}}
// vector is not trusted: the consumer cannot install it itself.
if err := c.CreateDatabaseAndRole(ctx, p.As, p.As, p.Password); err != nil {
@@ -68,11 +69,11 @@ func TestLive(t *testing.T) {
}
// A neighbour that must survive everything below untouched.
other := Provision{As: "mesh_test_other", Password: "other-pw"}
other := harness.Provision{As: "mesh_test_other", Password: "other-pw"}
if err := a.Create(ctx, other); err != nil {
t.Fatal(err)
}
defer c.DeleteRetired(ctx, Retired{Consumer: other.As}) //nolint — best effort, after a retire below
defer c.DeleteRetired(ctx, harness.Retired{Consumer: other.As}) //nolint — best effort, after a retire below
at := time.Date(2026, 10, 6, 12, 0, 0, 0, time.UTC)
if err := a.Retire(ctx, p.As, nil, "the mesh stopped asking for it", at); err != nil {
@@ -89,7 +90,7 @@ func TestLive(t *testing.T) {
if err != nil {
t.Fatal(err)
}
var found *Retired
var found *harness.Retired
for i := range inv.Retired {
if inv.Retired[i].Consumer == p.As {
found = &inv.Retired[i]
@@ -102,7 +103,7 @@ func TestLive(t *testing.T) {
t.Fatalf("%+v", inv)
}
// An active consumer is never deleted, whatever is asked.
if _, err := c.DeleteRetired(ctx, Retired{Consumer: other.As}); err == nil {
if _, err := c.DeleteRetired(ctx, harness.Retired{Consumer: other.As}); err == nil {
t.Fatal("deleted an active consumer")
}
@@ -125,7 +126,7 @@ func TestLive(t *testing.T) {
if err := a.Retire(ctx, p.As, nil, "again", at); err != nil {
t.Fatal(err)
}
freed, err := a.Delete(ctx, Retired{Consumer: p.As, Kind: KindConsumer})
freed, err := a.Delete(ctx, harness.Retired{Consumer: p.As, Kind: harness.KindConsumer})
if err != nil || freed <= 0 {
t.Fatal(freed, err)
}
@@ -145,7 +146,7 @@ func TestLive(t *testing.T) {
t.Fatal(err)
}
inv, _ = a.Inventory(ctx)
var setAside *Retired
var setAside *harness.Retired
for i := range inv.Retired {
if inv.Retired[i].Consumer == aside {
setAside = &inv.Retired[i]