diff --git a/cmd/bsky-modactions/main.go b/cmd/bsky-modactions/main.go index c0f2602..3bf8d3f 100644 --- a/cmd/bsky-modactions/main.go +++ b/cmd/bsky-modactions/main.go @@ -21,7 +21,8 @@ const ( BskyModLabelEndpoint = `wss://mod.bsky.app/xrpc/com.atproto.label.subscribeLabels` ActionsConfig = `bskymodactions:config` - ActionsLabels = `bskymodactions:labels` + LabelsAdded = `bskymodactions:added` + LabelsRemoved = `bskymodactions:removed` ) func main() { @@ -85,13 +86,12 @@ func main() { continue } - var neg bool - if label.Neg != nil { - neg = *label.Neg + key := LabelsAdded + if label.Neg != nil && *label.Neg { + key = LabelsRemoved } - key := fmt.Sprintf("%s:%t", label.Val, neg) - if err := rdb.ZIncrBy(ctx, ActionsLabels, 1, key).Err(); err != nil { + if err := rdb.ZIncrBy(ctx, key, 1, label.Val).Err(); err != nil { slog.Error("error incrementing key", "key", key) } }