diff --git a/patching/210-bgs-since-empty-fix.patch b/patching/210-bgs-since-empty-fix.patch new file mode 100644 index 0000000..763005d --- /dev/null +++ b/patching/210-bgs-since-empty-fix.patch @@ -0,0 +1,26 @@ +diff --git a/indexer/indexer.go b/indexer/indexer.go +index abc1234..def5678 100644 +--- a/indexer/indexer.go ++++ b/indexer/indexer.go +@@ -104,13 +104,19 @@ func (ix *Indexer) HandleRepoEvent(ctx context.Context, evt *repomgr.RepoEvent) + toobig = true + } + ++ // Normalize empty string to nil for since field ++ // Empty string fails TID validation on consumers ++ var since *string ++ if evt.Since != nil && *evt.Since != "" { ++ since = evt.Since ++ } ++ + ix.log.Debug("Sending event", "did", did) + if err := ix.events.AddEvent(ctx, &events.XRPCStreamEvent{ + RepoCommit: &comatproto.SyncSubscribeRepos_Commit{ + Repo: did, + Blocks: slice, + Rev: evt.Rev, +- Since: evt.Since, ++ Since: since, + Commit: lexutil.LexLink(evt.NewRoot), + Time: time.Now().Format(util.ISO8601), + Ops: outops,