Something went wrong. Try again.
cloudflare-native port of the tangled knot server
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245package appview
import ( "encoding/json" "log/slog" "path/filepath" "strings" "testing" "time"
jmodels "github.com/bluesky-social/jetstream/pkg/models" "tangled.org/core/api/tangled" "tangled.org/core/appview/db" "tangled.org/core/appview/models" "tangled.org/core/orm")
func newStringIngester(t *testing.T) *Ingester { t.Helper() path := filepath.Join(t.TempDir(), "test.db") d, err := db.Make(t.Context(), path) if err != nil { t.Fatalf("db.Make: %v", err) } t.Cleanup(func() { d.Close() }) return &Ingester{ Db: d, Logger: slog.New(slog.DiscardHandler), }}
func makeStringEvent(t *testing.T, op, did, rkey string, record tangled.String) *jmodels.Event { t.Helper() raw, err := json.Marshal(record) if err != nil { t.Fatalf("marshal record: %v", err) } return &jmodels.Event{ Did: did, Kind: jmodels.EventKindCommit, Commit: &jmodels.Commit{ Operation: op, Collection: tangled.StringNSID, RKey: rkey, Record: raw, }, }}
func loadString(t *testing.T, ing *Ingester, did, rkey string) (models.String, bool) { t.Helper() rows, err := db.GetStrings(ing.Db, 0, orm.FilterEq("did", did), orm.FilterEq("rkey", rkey), ) if err != nil { t.Fatalf("GetStrings: %v", err) } if len(rows) == 0 { return models.String{}, false } if len(rows) > 1 { t.Fatalf("expected at most one row for (%s,%s), got %d", did, rkey, len(rows)) } return rows[0], true}
func TestIngestString_CreateRoundTrip(t *testing.T) { ing := newStringIngester(t) created := time.Date(2025, 9, 14, 10, 30, 0, 0, time.UTC)
e := makeStringEvent(t, jmodels.CommitOperationCreate, "did:plc:boltless", "rk1", tangled.String{ Filename: "hello.txt", Description: "a greeting", Contents: "hello world\n", CreatedAt: created.Format(time.RFC3339), })
if err := ing.ingestString(e, ing.Logger); err != nil { t.Fatalf("ingestString: %v", err) }
s, ok := loadString(t, ing, "did:plc:boltless", "rk1") if !ok { t.Fatal("row not inserted") } if s.Filename != "hello.txt" { t.Errorf("filename = %q, want hello.txt", s.Filename) } if s.Description != "a greeting" { t.Errorf("description = %q", s.Description) } if s.Contents != "hello world\n" { t.Errorf("contents = %q", s.Contents) } if !s.Created.Equal(created) { t.Errorf("created = %v, want %v (record CreatedAt must round-trip)", s.Created, created) } if s.Edited != nil { t.Errorf("edited = %v, want nil on create", s.Edited) }}
func TestIngestString_UpdateBumpsEditedOnContentChange(t *testing.T) { ing := newStringIngester(t) created := time.Date(2025, 9, 14, 10, 30, 0, 0, time.UTC) base := tangled.String{ Filename: "hello.txt", Description: "a greeting", Contents: "hello world\n", CreatedAt: created.Format(time.RFC3339), }
if err := ing.ingestString(makeStringEvent(t, jmodels.CommitOperationCreate, "did:plc:boltless", "rk1", base), ing.Logger); err != nil { t.Fatalf("ingestString create: %v", err) }
updated := base updated.Contents = "hello, world!\n" if err := ing.ingestString(makeStringEvent(t, jmodels.CommitOperationUpdate, "did:plc:boltless", "rk1", updated), ing.Logger); err != nil { t.Fatalf("ingestString update: %v", err) }
s, ok := loadString(t, ing, "did:plc:boltless", "rk1") if !ok { t.Fatal("row missing after update") } if s.Contents != "hello, world!\n" { t.Errorf("contents = %q, want updated value", s.Contents) } if !s.Created.Equal(created) { t.Errorf("update overwrote created: got %v, want %v", s.Created, created) } if s.Edited == nil { t.Fatal("edited not set after content change") }}
func TestIngestString_UpdateNoChangeKeepsEditedNil(t *testing.T) { ing := newStringIngester(t) rec := tangled.String{ Filename: "hello.txt", Description: "a greeting", Contents: "hello world\n", CreatedAt: time.Date(2025, 9, 14, 10, 30, 0, 0, time.UTC).Format(time.RFC3339), }
if err := ing.ingestString(makeStringEvent(t, jmodels.CommitOperationCreate, "did:plc:akshay", "rk2", rec), ing.Logger); err != nil { t.Fatalf("create: %v", err) } if err := ing.ingestString(makeStringEvent(t, jmodels.CommitOperationUpdate, "did:plc:akshay", "rk2", rec), ing.Logger); err != nil { t.Fatalf("update: %v", err) }
s, _ := loadString(t, ing, "did:plc:akshay", "rk2") if s.Edited != nil { t.Errorf("edited = %v, want nil when no field changed", s.Edited) }}
func TestIngestString_DeleteRemovesRow(t *testing.T) { ing := newStringIngester(t) rec := tangled.String{ Filename: "hello.txt", Contents: "x", CreatedAt: time.Now().UTC().Format(time.RFC3339), } if err := ing.ingestString(makeStringEvent(t, jmodels.CommitOperationCreate, "did:plc:boltless", "rk1", rec), ing.Logger); err != nil { t.Fatalf("create: %v", err) }
del := &jmodels.Event{ Did: "did:plc:boltless", Kind: jmodels.EventKindCommit, Commit: &jmodels.Commit{ Operation: jmodels.CommitOperationDelete, Collection: tangled.StringNSID, RKey: "rk1", }, } if err := ing.ingestString(del, ing.Logger); err != nil { t.Fatalf("delete: %v", err) }
if _, ok := loadString(t, ing, "did:plc:boltless", "rk1"); ok { t.Fatal("row still present after delete") }}
func TestIngestString_ValidatorRejects(t *testing.T) { ing := newStringIngester(t) now := time.Now().UTC().Format(time.RFC3339)
cases := []struct { name string rec tangled.String }{ {"empty contents", tangled.String{Filename: "x", Contents: "", CreatedAt: now}}, {"long filename", tangled.String{Filename: strings.Repeat("a", 141), Contents: "x", CreatedAt: now}}, {"long description", tangled.String{Filename: "x", Description: strings.Repeat("d", 281), Contents: "x", CreatedAt: now}}, }
for _, tc := range cases { t.Run(tc.name, func(t *testing.T) { e := makeStringEvent(t, jmodels.CommitOperationCreate, "did:plc:akshay", "bad", tc.rec) if err := ing.ingestString(e, ing.Logger); err == nil { t.Fatal("expected validator error, got nil") } if _, ok := loadString(t, ing, "did:plc:akshay", "bad"); ok { t.Fatal("row inserted despite validator failure") } }) }}
func TestIngestString_ColdReplayPreservesCreated(t *testing.T) { created := time.Date(2024, 1, 2, 3, 4, 5, 0, time.UTC) rec := tangled.String{ Filename: "snippet.go", Description: "first cut", Contents: "package main\n", CreatedAt: created.Format(time.RFC3339), } event := makeStringEvent(t, jmodels.CommitOperationCreate, "did:plc:boltless", "rkcold", rec)
first := newStringIngester(t) if err := first.ingestString(event, first.Logger); err != nil { t.Fatalf("first ingest: %v", err) } live, _ := loadString(t, first, "did:plc:boltless", "rkcold")
second := newStringIngester(t) if err := second.ingestString(event, second.Logger); err != nil { t.Fatalf("replay ingest: %v", err) } replayed, _ := loadString(t, second, "did:plc:boltless", "rkcold")
if !live.Created.Equal(replayed.Created) { t.Fatalf("cold replay drifted: live=%v replayed=%v", live.Created, replayed.Created) } if !replayed.Created.Equal(created) { t.Fatalf("replay lost record CreatedAt: got %v, want %v", replayed.Created, created) }}