tangled
alpha
login
or
join now
edavis.dev
/
recordcollector
18
fork
atom
this repo has no description
18
fork
atom
overview
issues
2
pulls
pipelines
feat: bit less chatty
Eric Davis
1 month ago
7b803c37
9ba87717
+2
-5
1 changed file
expand all
collapse all
unified
split
cmd
recordcollector
main.go
+2
-5
cmd/recordcollector/main.go
···
221
221
},
222
222
}
223
223
224
224
-
view, err := toolsozone.ModerationEmitEvent(ctx, h.client, input)
224
224
+
_, err = toolsozone.ModerationEmitEvent(ctx, h.client, input)
225
225
if err != nil {
226
226
h.logger.Error("failed to add label", "err", err)
227
227
return fmt.Errorf("failed to add label: %w", err)
228
228
}
229
229
-
h.logger.Info("added label", "view", view)
229
229
+
h.logger.Info("emitting label", "did", did, "label", label)
230
230
231
231
// Set key with 24h TTL after successful emission
232
232
if err := h.redis.Set(ctx, key, "1", 24*time.Hour).Err(); err != nil {
···
268
268
}
269
269
}
270
270
271
271
-
h.logger.Info("potential label", "did", event.Did, "collection", collection)
272
272
-
273
271
for prefix, label := range labelPrefixes {
274
272
if strings.HasPrefix(collection, prefix) {
275
275
-
h.logger.Info("label exists for collection, adding")
276
273
if err := h.addLabel(ctx, event.Did, label); err != nil {
277
274
return fmt.Errorf("error adding label: %w", err)
278
275
}