+1

events/diskpersist.go

reviewed

··· 540 540 if err != nil { 541 541 return fmt.Errorf("failed while skipping event (seq: %d, fn: %q): %w", h.Seq, fn, err) 542 542 } 543 543 + continue 543 544 } 544 545 545 546 switch h.Kind {

+19 -6

events/diskpersist_test.go

reviewed

··· 375 375 userCount := 10 376 376 users := make([]*models.ActorInfo, userCount) 377 377 for i := models.Uid(1); i <= models.Uid(userCount); i++ { 378 378 + did := fmt.Sprintf("did:example:%d", i) 379 379 + handle := fmt.Sprintf("user%d", i) 378 380 users[i-1] = &models.ActorInfo{ 379 379 - Uid: i, 380 380 - Did: fmt.Sprintf("did:example:%d", i), 381 381 + Uid: i, 382 382 + Did: did, 383 383 + Handle: handle, 384 384 + } 385 385 + if err := db.Create(&users[i-1]).Error; err != nil { 386 386 + t.Fatal(err) 381 387 } 382 382 - db.Create(users[i-1]) 383 388 384 384 - err := mgr.InitNewActor(ctx, i, fmt.Sprintf("user%d", i), users[i-1].Did, fmt.Sprintf("User%d", i), "", "") 389 389 + err := mgr.InitNewActor(ctx, i, handle, did, fmt.Sprintf("User%d", i), "", "") 385 390 if err != nil { 386 391 t.Fatal(err) 387 392 } ··· 443 448 444 449 // Verify that the events of the user have been removed from the event stream 445 450 var evtsCount int 446 446 - p.Playback(ctx, 0, func(evt *events.XRPCStreamEvent) error { 451 451 + if err := p.Playback(ctx, 0, func(evt *events.XRPCStreamEvent) error { 452 452 + evtsCount++ 447 453 if evt.RepoCommit.Repo == takeDownUser.Did { 448 454 t.Fatalf("found event for user %d after takedown", takeDownUser.Uid) 449 455 } 450 456 return nil 451 451 - }) 457 457 + }); err != nil { 458 458 + t.Fatal(err) 459 459 + } 460 460 + 461 461 + exp := testSize * (userCount - 1) 462 462 + if evtsCount != exp { 463 463 + t.Fatalf("wrong number of events out: %d != %d", evtsCount, exp) 464 464 + } 452 465 }