Monorepo for Tangled

appview,knotmirror: follow updated `git.refUpdate` event schema

Signed-off-by: Seongmin Lee <git@boltless.me>

boltless.me e796ecb6 5084c96d

verified
+16 -6
+5
appview/state/knotstream.go
··· 117 117 ownerDid := "" 118 118 if record.OwnerDid != nil { 119 119 ownerDid = *record.OwnerDid 120 + } else { 121 + // handle legacy event 122 + if record.RepoDid != nil { 123 + ownerDid = *record.RepoDid 124 + } 120 125 } 121 126 122 127 repo, lookupErr := resolveRepo(d, record.RepoDid, ownerDid, record.RepoName)
+11 -6
knotmirror/knotstream/slurper.go
··· 280 280 281 281 l := s.logger.With("src", source) 282 282 283 - repoDid := "" 284 - if evt.Event.RepoDid != nil { 285 - repoDid = *evt.Event.RepoDid 283 + ownerDid := "" 284 + if evt.Event.OwnerDid != nil { 285 + ownerDid = *evt.Event.OwnerDid 286 + } else { 287 + // handle legacy event 288 + if evt.Event.RepoDid != nil { 289 + ownerDid = *evt.Event.RepoDid 290 + } 286 291 } 287 - curr, err := db.GetRepoByName(ctx, s.db, syntax.DID(repoDid), evt.Event.RepoName) 292 + curr, err := db.GetRepoByName(ctx, s.db, syntax.DID(ownerDid), evt.Event.RepoName) 288 293 if err != nil { 289 - return fmt.Errorf("failed to get repo '%s': %w", repoDid+"/"+evt.Event.RepoName, err) 294 + return fmt.Errorf("failed to get repo '%s': %w", ownerDid+"/"+evt.Event.RepoName, err) 290 295 } 291 296 if curr == nil { 292 297 // if repo doesn't exist in DB, just ignore the event. That repo is unknown. ··· 296 301 // But we want to store that in did/rkey in knot-mirror. 297 302 // Therefore, we should ignore when the repository is unknown. 298 303 // Hopefully crawler will sync it later. 299 - l.Warn("skipping event from unknown repo", "did/name", repoDid+"/"+evt.Event.RepoName) 304 + l.Warn("skipping event from unknown repo", "did/name", ownerDid+"/"+evt.Event.RepoName) 300 305 knotstreamEventsSkipped.Inc() 301 306 return nil 302 307 }