diff --git a/cmd/sonar/docker-compose.yml b/cmd/sonar/docker-compose.yml --- a/cmd/sonar/docker-compose.yml +++ b/cmd/sonar/docker-compose.yml @@ -8,17 +8,3 @@ restart: always ports: - "8345:8345" - sonar-sandbox: - build: - context: ../../ - dockerfile: cmd/sonar/Dockerfile - image: atproto-sonar - restart: always - ports: - - "8346:8345" - command: - [ - "./sonar", - "--ws-url", - "wss://bgs.bsky-sandbox.dev/xrpc/com.atproto.sync.subscribeRepos", - ] diff --git a/cmd/sonar/main.go b/cmd/sonar/main.go --- a/cmd/sonar/main.go +++ b/cmd/sonar/main.go @@ -14,7 +14,7 @@ "time" "github.com/bluesky-social/indigo/events" - "github.com/bluesky-social/indigo/events/schedulers/autoscaling" + "github.com/bluesky-social/indigo/events/schedulers/sequential" "github.com/bluesky-social/indigo/sonar" "github.com/gorilla/websocket" "github.com/prometheus/client_golang/prometheus/promhttp" @@ -35,7 +35,7 @@ &cli.StringFlag{ Name: "ws-url", Usage: "full websocket path to the ATProto SubscribeRepos XRPC endpoint", - Value: "wss://bsky.social/xrpc/com.atproto.sync.subscribeRepos", + Value: "wss://bsky.network/xrpc/com.atproto.sync.subscribeRepos", }, &cli.StringFlag{ Name: "log-level", @@ -46,11 +46,6 @@ Name: "port", Usage: "listen port for metrics server", Value: 8345, - }, - &cli.IntFlag{ - Name: "worker-count", - Usage: "number of workers to process events", - Value: 10, }, &cli.IntFlag{ Name: "max-queue-size", @@ -102,11 +97,7 @@ wg := sync.WaitGroup{} - scalingSettings := autoscaling.DefaultAutoscaleSettings() - scalingSettings.MaxConcurrency = cctx.Int("worker-count") - scalingSettings.AutoscaleFrequency = time.Second - - pool := autoscaling.NewScheduler(scalingSettings, u.Host, s.HandleStreamEvent) + pool := sequential.NewScheduler(u.Host, s.HandleStreamEvent) // Start a goroutine to manage the cursor file, saving the current cursor every 5 seconds. go func() {