chore

RSS3-Network · Dec 26, 2024 · 97f7231 · 97f7231
1 parent 942c098
commit 97f7231
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/engine/protocol/atproto/data_source.go b/internal/engine/protocol/atproto/data_source.go
@@ -71,8 +71,10 @@ func (s *dataSource) Start(ctx context.Context, tasksChan chan<- *engine.Tasks,
 func (s *dataSource) pollSubscribeRepos(ctx context.Context, tasksChan chan<- *engine.Tasks) error {
 	uri := bluesky.BskySubscribeURI
 
-	if lo.IsEmpty(s.state.SubscribeCursor) {
+	if lo.IsNotEmpty(s.state.SubscribeCursor) {
 		uri = fmt.Sprintf("%s?cursor=%d", uri, s.state.SubscribeCursor)
+	} else {
+		uri = fmt.Sprintf("%s?cursor=1", uri)
 	}
 
 	conn, _, err := websocket.DefaultDialer.Dial(uri, nil)