···

       
13
       
13
       
 
       
	_ "github.com/mattn/go-sqlite3"

     

       
14
       
14
       
 
       
)

     

       
15
       
15
       
 
       


     

       
16
       
16
       
-
       
// const JetstreamUrl = `wss://jetstream1.us-west.bsky.network/subscribe?wantedCollections=app.bsky.feed.post&wantedCollections=app.bsky.feed.like&cursor=1728846514000000`

     

       
17
       
17
       
-
       
const JetstreamUrl = `ws://localhost:6008/subscribe?wantedCollections=app.bsky.feed.post&wantedCollections=app.bsky.feed.like`

     

       
16
       
16
       
+
       
const JetstreamUrl = `wss://jetstream2.us-west.bsky.network/subscribe?wantedCollections=app.bsky.feed.post&wantedCollections=app.bsky.feed.like`

     

       
18
       
17
       
 
       


     

       
19
       
18
       
 
       
func main() {

     

       
20
       
19
       
 
       
	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGINT, syscall.SIGTERM)