this repo has no description
automod: give each event a separate ctx (#934)
This didn't fix the problem we were seeing at the time, but might still
be the best practice here?
+5
-5
+4
-4
automod/consumer/firehose.go
+4
-4
automod/consumer/firehose.go
···
80
80
},
81
81
RepoIdentity: func(evt *comatproto.SyncSubscribeRepos_Identity) error {
82
82
atomic.StoreInt64(&fc.lastSeq, evt.Seq)
83
-
if err := fc.Engine.ProcessIdentityEvent(ctx, *evt); err != nil {
83
+
if err := fc.Engine.ProcessIdentityEvent(context.Background(), *evt); err != nil {
84
84
fc.Logger.Error("processing repo identity failed", "did", evt.Did, "seq", evt.Seq, "err", err)
85
85
}
86
86
return nil
87
87
},
88
88
RepoAccount: func(evt *comatproto.SyncSubscribeRepos_Account) error {
89
89
atomic.StoreInt64(&fc.lastSeq, evt.Seq)
90
-
if err := fc.Engine.ProcessAccountEvent(ctx, *evt); err != nil {
90
+
if err := fc.Engine.ProcessAccountEvent(context.Background(), *evt); err != nil {
91
91
fc.Logger.Error("processing repo account failed", "did", evt.Did, "seq", evt.Seq, "err", err)
92
92
}
93
93
return nil
···
182
182
CID: &recCID,
183
183
RecordCBOR: *recCBOR,
184
184
}
185
-
err = fc.Engine.ProcessRecordOp(ctx, op)
185
+
err = fc.Engine.ProcessRecordOp(context.Background(), op)
186
186
if err != nil {
187
187
logger.Error("engine failed to process record", "err", err)
188
188
continue
···
196
196
CID: nil,
197
197
RecordCBOR: nil,
198
198
}
199
-
err = fc.Engine.ProcessRecordOp(ctx, op)
199
+
err = fc.Engine.ProcessRecordOp(context.Background(), op)
200
200
if err != nil {
201
201
logger.Error("engine failed to process record", "err", err)
202
202
continue
+1
-1
automod/consumer/ozone.go
+1
-1
automod/consumer/ozone.go
···
118
118
119
119
oc.Logger.Debug("received ozone event", "eventID", eventView.Id, "createdAt", eventView.CreatedAt)
120
120
121
-
if err := oc.Engine.ProcessOzoneEvent(ctx, eventView); err != nil {
121
+
if err := oc.Engine.ProcessOzoneEvent(context.Background(), eventView); err != nil {
122
122
oc.Logger.Error("engine failed to process ozone event", "err", err)
123
123
}
124
124
return nil