this repo has no description
resolve more build issues
+3
-6
+3
-3
bgs/bgs.go
+3
-3
bgs/bgs.go
···
1005
1005
if errors.Is(err, carstore.ErrRepoBaseMismatch) || ipld.IsNotFound(err) {
1006
1006
ai, lerr := bgs.Index.LookupUser(ctx, u.ID)
1007
1007
if lerr != nil {
1008
-
log.Warn("failed handling event, no user", "err", err, "pdsHost", host.Host, "seq", evt.Seq, "repo", u.Did, "prev", stringLink(evt.Prev), "commit", evt.Commit.String())
1008
+
log.Warn("failed handling event, no user", "err", err, "pdsHost", host.Host, "seq", evt.Seq, "repo", u.Did, "commit", evt.Commit.String())
1009
1009
repoCommitsResultCounter.WithLabelValues(host.Host, "nou4").Inc()
1010
1010
return fmt.Errorf("failed to look up user %s (%d) (err case: %s): %w", u.Did, u.ID, err, lerr)
1011
1011
}
1012
1012
1013
1013
span.SetAttributes(attribute.Bool("catchup_queue", true))
1014
1014
1015
-
log.Info("failed handling event, catchup", "err", err, "pdsHost", host.Host, "seq", evt.Seq, "repo", u.Did, "prev", stringLink(evt.Prev), "commit", evt.Commit.String())
1015
+
log.Info("failed handling event, catchup", "err", err, "pdsHost", host.Host, "seq", evt.Seq, "repo", u.Did, "commit", evt.Commit.String())
1016
1016
repoCommitsResultCounter.WithLabelValues(host.Host, "catchup2").Inc()
1017
1017
return bgs.Index.Crawler.AddToCatchupQueue(ctx, host, ai, evt)
1018
1018
}
1019
1019
1020
-
log.Warn("failed handling event", "err", err, "pdsHost", host.Host, "seq", evt.Seq, "repo", u.Did, "prev", stringLink(evt.Prev), "commit", evt.Commit.String())
1020
+
log.Warn("failed handling event", "err", err, "pdsHost", host.Host, "seq", evt.Seq, "repo", u.Did, "commit", evt.Commit.String())
1021
1021
repoCommitsResultCounter.WithLabelValues(host.Host, "err").Inc()
1022
1022
return fmt.Errorf("handle user event failed: %w", err)
1023
1023
}
-1
cmd/supercollider/main.go
-1
cmd/supercollider/main.go
···
599
599
if err := s.Events.AddEvent(ctx, &events.XRPCStreamEvent{
600
600
RepoCommit: &comatproto.SyncSubscribeRepos_Commit{
601
601
Repo: s.Dids[evt.User-1],
602
-
Prev: (*lexutil.LexLink)(evt.OldRoot),
603
602
Blocks: evt.RepoSlice,
604
603
Commit: lexutil.LexLink(evt.NewRoot),
605
604
Time: time.Now().Format(util.ISO8601),
-1
indexer/indexer.go
-1
indexer/indexer.go