Something went wrong. Try again.
Monorepo for Tangled tangled.org
Something went wrong. Try again.
1234567891011121314151617181920212223242526272829303132package db
import ( "fmt" "testing" "time"
"github.com/bluesky-social/indigo/atproto/syntax")
func TestDuePullEventsReadsOnlyALimitOldestFirst(t *testing.T) { d := newTestDB(t) repo := syntax.DID("did:plc:a") if err := d.AddPullTicket(repo, "t1", PullTicket{Author: "did:plc:bob", State: "open", Version: "v0"}); err != nil { t.Fatal(err) } for i := 1; i <= 5; i++ { ev := PullEvent{RepoDid: repo, Ticket: "t1", Event: "closed", Pull: []byte("{}")} if err := d.AdvancePullTicket(repo, "t1", fmt.Sprintf("v%d", i-1), fmt.Sprintf("v%d", i), "closed", &ev); err != nil { t.Fatal(err) } }
due, err := d.DuePullEvents(repo, time.Now().Add(time.Hour), 3) if err != nil || len(due) != 3 { t.Fatalf("read %d events, %v, want the limit of 3", len(due), err) } if due[0].ID >= due[1].ID || due[1].ID >= due[2].ID { t.Fatalf("ids %d %d %d, want oldest first", due[0].ID, due[1].ID, due[2].ID) }}