···

       
3
       
3
       
 
       
import (

     

       
4
       
4
       
 
       
	"context"

     

       
5
       
5
       
 
       
	"fmt"

     

       
6
       
6
       
+
       
	"log/slog"

     

       
6
       
7
       
 
       
	"net/http"

     

       
7
       
8
       
 
       


     

       
8
       
9
       
 
       
	"github.com/gorilla/websocket"

     
···

       
16
       
17
       
 
       
		url += fmt.Sprintf("?cursor=%d", curs)

     

       
17
       
18
       
 
       
	}

     

       
18
       
19
       
 
       


     

       
20
       
20
       
+
       
	slog.Info("connecting to firehose", "url", url)

     

       
19
       
21
       
 
       
	conn, _, err := websocket.DefaultDialer.DialContext(ctx, url, http.Header{

     

       
20
       
22
       
 
       
		"User-Agent": []string{"backfiller/0.1 (@edavis.dev)"},

     

       
21
       
23
       
 
       
	})