···

       
21
       
21
       
 
       
	BskyModLabelEndpoint = `wss://mod.bsky.app/xrpc/com.atproto.label.subscribeLabels`

     

       
22
       
22
       
 
       


     

       
23
       
23
       
 
       
	ActionsConfig = `bskymodactions:config`

     

       
24
       
24
       
-
       
	ActionsLabels = `bskymodactions:labels`

     

       
24
       
24
       
+
       
	LabelsAdded   = `bskymodactions:added`

     

       
25
       
25
       
+
       
	LabelsRemoved = `bskymodactions:removed`

     

       
25
       
26
       
 
       
)

     

       
26
       
27
       
 
       


     

       
27
       
28
       
 
       
func main() {

     
···

       
85
       
86
       
 
       
						continue

     

       
86
       
87
       
 
       
					}

     

       
87
       
88
       
 
       


     

       
88
       
88
       
-
       
					var neg bool

     

       
89
       
89
       
-
       
					if label.Neg != nil {

     

       
90
       
90
       
-
       
						neg = *label.Neg

     

       
89
       
89
       
+
       
					key := LabelsAdded

     

       
90
       
90
       
+
       
					if label.Neg != nil && *label.Neg {

     

       
91
       
91
       
+
       
						key = LabelsRemoved

     

       
91
       
92
       
 
       
					}

     

       
92
       
92
       
-
       
					key := fmt.Sprintf("%s:%t", label.Val, neg)

     

       
93
       
93
       
 
       


     

       
94
       
94
       
-
       
					if err := rdb.ZIncrBy(ctx, ActionsLabels, 1, key).Err(); err != nil {

     

       
94
       
94
       
+
       
					if err := rdb.ZIncrBy(ctx, key, 1, label.Val).Err(); err != nil {

     

       
95
       
95
       
 
       
						slog.Error("error incrementing key", "key", key)

     

       
96
       
96
       
 
       
					}

     

       
97
       
97
       
 
       
				}