diff --git a/events/diskpersist/diskpersist.go b/events/diskpersist/diskpersist.go index 9236c312..04695d1d 100644 --- a/events/diskpersist/diskpersist.go +++ b/events/diskpersist/diskpersist.go @@ -278,8 +278,8 @@ func scanForLastSeq(fi *os.File, end int64) (int64, error) { const ( evtKindCommit = 1 - evtKindHandle = 2 - evtKindTombstone = 3 + evtKindHandle = 2 // DEPRECATED + evtKindTombstone = 3 // DEPRECATED evtKindIdentity = 4 evtKindAccount = 5 evtKindSync = 6 diff --git a/events/persist.go b/events/persist.go index 274d9787..494dd3dd 100644 --- a/events/persist.go +++ b/events/persist.go @@ -42,6 +42,8 @@ func (mp *MemPersister) Persist(ctx context.Context, e *XRPCStreamEvent) error { switch { case e.RepoCommit != nil: e.RepoCommit.Seq = mp.seq + case e.RepoSync != nil: + e.RepoSync.Seq = mp.seq case e.RepoIdentity != nil: e.RepoIdentity.Seq = mp.seq case e.RepoAccount != nil: