+2 -2

indexer/indexer.go

reviewed

··· 56 56 return fmt.Errorf("failed to catch up on user repo changes, processing events off base: %w", err) 57 57 } 58 58 59 59 - fmt.Println("Handling Event!") 59 59 + fmt.Println("Handling Repo Event!") 60 60 var relpds []uint 61 61 var repoOps []*events.RepoOp 62 62 for _, op := range evt.Ops { ··· 85 85 return err 86 86 } 87 87 88 88 - fmt.Println("Sending event: ", relpds) 88 88 + fmt.Println("Sending event: ", relpds, len(repoOps)) 89 89 if err := ix.events.AddEvent(&events.Event{ 90 90 Kind: events.EvtKindRepoChange, 91 91 CarSlice: evt.RepoSlice,

+3 -1

repomgr/repomgr.go

reviewed

··· 492 492 return fmt.Errorf("opening external user repo: %w", err) 493 493 } 494 494 495 495 + fmt.Println("external event: ", ops) 496 496 + 495 497 var evtops []RepoOp 496 498 for _, op := range ops { 497 499 switch op.Kind { ··· 508 510 Record: rec, 509 511 RecCid: recid, 510 512 }) 511 511 - return nil 512 513 default: 513 514 return fmt.Errorf("unrecognized external user event kind: %q", kind) 514 515 } ··· 525 526 } 526 527 527 528 if rm.events != nil { 529 529 + fmt.Println("calling out to events handler...") 528 530 rm.events(ctx, &RepoEvent{ 529 531 User: uid, 530 532 //OldRoot: head,

+2 -1

server/federation_test.go

reviewed

··· 305 305 bob.Follow(t, laura.did) 306 306 307 307 bp1 := bob.Post(t, "hello world") 308 308 + 309 309 + fmt.Println("LAURA POST!!!!") 308 310 lp1 := laura.Post(t, "hello bob") 309 311 time.Sleep(time.Millisecond * 50) 310 312 311 311 - select {} 312 313 f := bob.GetFeed(t) 313 314 assert.Equal(f[0].Post.Uri, bp1.Uri) 314 315 assert.Equal(f[1].Post.Uri, lp1.Uri)