From 04f1d94685cb31fae2e7fb7cbbc195fe3f7419df Mon Sep 17 00:00:00 2001
From: Jaz Volpert <ericvolp12@gmail.com>
Date: Sat, 23 Mar 2024 00:36:55 +0000
Subject: [PATCH] Update sonar a little bit

---
 cmd/sonar/docker-compose.yml | 14 --------------
 cmd/sonar/main.go | 15 +++------------
 2 file(s) changed, 3 insertion(s)(+), 26 deletion(s)(-)

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() {

--
tangled.sh