cleanup

docker-compose.yml

···
     depends_on:
       - qdrant
       - retina
-    environment:
-      - RETINA_HOST=http://retina:8080
-      - WEBSOCKET_HOST=wss://bsky.network
-      - QDRANT_HOST=qdrant
-      - QDRANT_PORT=6334
-      - QDRANT_COLLECTION=profile_blobs
-      - MAX_SEARCH_TIME=24h
-      - MAX_LIMIT=20
-      - SEEN_THRESHOLD=5
-      - MAX_HAMMING_DISTANCE=31
     command:
-      - --retina-host=${RETINA_HOST}
-      - --websocket-host=${WEBSOCKET_HOST}
-      - --qdrant-host=${QDRANT_HOST}
-      - --qdrant-port=${QDRANT_PORT}
-      - --qdrant-collection=${QDRANT_COLLECTION}
-      - --max-search-time=${MAX_SEARCH_TIME}
-      - --max-limit=${MAX_LIMIT}
-      - --seen-threshold=${SEEN_THRESHOLD}
-      - --max-hamming-distance=${MAX_HAMMING_DISTANCE}
+      - --retina-host=http://retina:8080
+      - --websocket-host=wss://bsky.network
+      - --qdrant-host=qdrant
+      - --qdrant-port=6334
+      - --qdrant-collection=profile_blobs
+      - --max-search-time=24h
+      - --max-limit=20
+      - --seen-threshold=5
+      - --max-hamming-distance=31
     restart: unless-stopped
 
 volumes:

server/handleprofile.go

···
 	var bannerHash string
 	getHashResult := func(kind, cid string) {
 		logger := logger.With("kind", kind, "cid", cid)
-		hashResult, err := s.getImageHash(searchCtx, did, avatarCid)
+		hashResult, err := s.getImageHash(searchCtx, did, cid)
 		if err != nil {
 			logger.Error("failed to get hash result", "err", err)
 			return
···
 			}
 		})
 	}
+
+	wg.Wait()
 
 	// inserts can happen in a different goroutine so we don't block returning these results
 	go func() {

server/server.go

···
 			return nil, fmt.Errorf("failed to create flagged image collection timestamp index: %w", err)
 		}
 
-		args.Logger.Info("Successfully created flagged image vector collection in Milvus")
+		args.Logger.Info("Successfully created flagged image vector collection in Qdrant")
 
 	} else {
 		args.Logger.Info("collection already exists", "collection", args.QdrantColletion)
···
 	logger := s.logger.With("name", "Run")
 
 	wsDialer := websocket.DefaultDialer
-	u, err := url.Parse(s.websocketHost)
+	u, err := url.Parse(s.websocketHost + "/xrpc/com.atproto.sync.subscribeRepos")
 	if err != nil {
 		return fmt.Errorf("failed to parse websocket host: %w", err)
 	}