Monorepo for Tangled
Something went wrong. Try again.
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113package db
import ( "context" "path/filepath" "testing"
"github.com/bluesky-social/indigo/atproto/syntax" "tangled.org/core/appview/models")
func TestRemoveReposByKnotCascadesEntities(t *testing.T) { d := newTestDB(t)
knot := "kelp.example" repo := seedRepo(t, d, "did:plc:akshay", knot, "anemone", "anemone", "did:plc:anemone")
starNotif := &models.Notification{ RecipientDid: "did:plc:akshay", ActorDid: "did:plc:boltless", Type: models.NotificationTypeRepoStarred, EntityType: "repo", EntityId: repo.RepoAt().String(), RepoId: &repo.Id, } if err := CreateNotification(d, starNotif); err != nil { t.Fatalf("CreateNotification repo: %v", err) }
tx, err := d.Begin() if err != nil { t.Fatalf("Begin: %v", err) } issue := &models.Issue{ Did: "did:plc:akshay", Rkey: "issue1", RepoDid: syntax.DID(repo.RepoDid), Title: "title", Body: "body", Open: true, } if err := PutIssue(tx, issue); err != nil { t.Fatalf("PutIssue: %v", err) } if err := tx.Commit(); err != nil { t.Fatalf("Commit: %v", err) }
issueNotif := &models.Notification{ RecipientDid: "did:plc:akshay", ActorDid: "did:plc:boltless", Type: models.NotificationTypeIssueCommented, EntityType: "issue", EntityId: issue.AtUri().String(), IssueId: &issue.Id, } if err := CreateNotification(d, issueNotif); err != nil { t.Fatalf("CreateNotification issue: %v", err) }
if err := RemoveReposByKnot(d, knot); err != nil { t.Fatalf("RemoveReposByKnot: %v", err) }
if got := countRows(t, d, "select count(*) from repos where knot = ?", knot); got != 0 { t.Errorf("repos remaining: got %d, want 0", got) } if got := countRows(t, d, "select count(*) from issues where repo_did = ?", repo.RepoDid); got != 0 { t.Errorf("issues remaining: got %d, want 0", got) } if got := countRows(t, d, "select count(*) from notifications"); got != 0 { t.Errorf("notifications remaining: got %d, want 0", got) }}
func TestMakeReopenPreservesOrphanData(t *testing.T) { path := filepath.Join(t.TempDir(), "reopen.db")
d, err := Make(context.Background(), path) if err != nil { t.Fatalf("first Make: %v", err) }
repo := seedRepo(t, d, "did:plc:akshay", "ghost.example", "anemone", "anemone", "did:plc:anemone") notif := &models.Notification{ RecipientDid: "did:plc:akshay", ActorDid: "did:plc:boltless", Type: models.NotificationTypeRepoStarred, EntityType: "repo", EntityId: repo.RepoAt().String(), RepoId: &repo.Id, } if err := CreateNotification(d, notif); err != nil { t.Fatalf("CreateNotification: %v", err) } if err := d.Close(); err != nil { t.Fatalf("Close: %v", err) }
d2, err := Make(context.Background(), path) if err != nil { t.Fatalf("second Make: %v", err) } t.Cleanup(func() { d2.Close() })
if got := countRows(t, d2, "select count(*) from repos where knot = ?", "ghost.example"); got != 1 { t.Errorf("orphan repo lost across reopen: got %d, want 1", got) } if got := countRows(t, d2, "select count(*) from notifications"); got != 1 { t.Errorf("notification lost across reopen: got %d, want 1", got) }}