diff --git a/cmd/bsky-activity/main.go b/cmd/bsky-activity/main.go index 344b973..d05c50f 100644 --- a/cmd/bsky-activity/main.go +++ b/cmd/bsky-activity/main.go @@ -6,6 +6,7 @@ import ( "log" "os" "os/signal" + "strings" "sync" "syscall" "time" @@ -156,6 +157,18 @@ func handler(ctx context.Context, queue *Queue) { log.Printf("failed incrementing collection: %v\n", err) } + var appCount string + if collection == "app.bsky.feed.like" { + appCount = "bskyactivity:appgroup:bskylikes" + } else if strings.HasPrefix(collection, "app.bsky.") || strings.HasPrefix(collection, "chat.bsky.") { + appCount = `bskyactivity:appgroup:bskyrest` + } else { + appCount = `bskyactivity:appgroup:nonbsky` + } + if err := pipe.Incr(ctx, appCount).Err(); err != nil { + log.Printf("failed incrementing appgroup ops: %v\n", err) + } + if err := pipe.Incr(ctx, `dev.edavis.muninsky.ops`).Err(); err != nil { log.Printf("failed incrementing ops: %v\n", err) }