this repo has no description
hepa: handle #identity event stream event (#587)
+16
-4
+16
-4
cmd/hepa/consumer.go
+16
-4
cmd/hepa/consumer.go
···
65
65
}
66
66
return nil
67
67
},
68
-
RepoMigrate: func(evt *comatproto.SyncSubscribeRepos_Migrate) error {
68
+
Identity: func(evt *comatproto.SyncSubscribeRepos_Identity) error {
69
69
atomic.StoreInt64(&s.lastSeq, evt.Seq)
70
70
did, err := syntax.ParseDID(evt.Did)
71
71
if err != nil {
72
-
s.logger.Error("bad DID in RepoMigrate event", "did", evt.Did, "seq", evt.Seq, "err", err)
72
+
s.logger.Error("bad DID in RepoIdentity event", "did", evt.Did, "seq", evt.Seq, "err", err)
73
73
return nil
74
74
}
75
-
if err := s.engine.ProcessIdentityEvent(ctx, "migrate", did); err != nil {
76
-
s.logger.Error("processing repo migrate failed", "did", evt.Did, "seq", evt.Seq, "err", err)
75
+
if err := s.engine.ProcessIdentityEvent(ctx, "identity", did); err != nil {
76
+
s.logger.Error("processing repo identity failed", "did", evt.Did, "seq", evt.Seq, "err", err)
77
+
}
78
+
return nil
79
+
},
80
+
RepoTombstone: func(evt *comatproto.SyncSubscribeRepos_Tombstone) error {
81
+
atomic.StoreInt64(&s.lastSeq, evt.Seq)
82
+
did, err := syntax.ParseDID(evt.Did)
83
+
if err != nil {
84
+
s.logger.Error("bad DID in RepoTombstone event", "did", evt.Did, "seq", evt.Seq, "err", err)
85
+
return nil
86
+
}
87
+
if err := s.engine.ProcessIdentityEvent(ctx, "tombstone", did); err != nil {
88
+
s.logger.Error("processing repo tombstone failed", "did", evt.Did, "seq", evt.Seq, "err", err)
77
89
}
78
90
return nil
79
91
},