···

       
35
       
 
       
])

     

       
36
       
 
       


     

       
37
       
 
       
async def bsky_activity():

     

       
38
       
-
       
    relay_url = 'ws://localhost:6008/subscribe'

     

       
39
       
 
       


     

       
40
       
 
       
    sys.stdout.write(f'opening websocket connection to {relay_url}\n')

     

       
41
       
 
       
    sys.stdout.flush()

     

···

       
35
       
 
       
])

     

       
36
       
 
       


     

       
37
       
 
       
async def bsky_activity():

     

       
38
       
+
       
    relay_url = 'wss://jetstream1.us-west.bsky.network/subscribe'

     

       
39
       
 
       


     

       
40
       
 
       
    sys.stdout.write(f'opening websocket connection to {relay_url}\n')

     

       
41
       
 
       
    sys.stdout.flush()

     

···

       
10
       
 
       
	"github.com/gorilla/websocket"

     

       
11
       
 
       
)

     

       
12
       
 
       


     

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

     

       
14
       
 
       


     

       
15
       
 
       
func main() {

     

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

     

···

       
10
       
 
       
	"github.com/gorilla/websocket"

     

       
11
       
 
       
)

     

       
12
       
 
       


     

       
13
       
+
       
const JetstreamUrl = `wss://jetstream1.us-west.bsky.network/subscribe?wantedCollections=app.bsky.feed.post`

     

       
14
       
 
       


     

       
15
       
 
       
func main() {

     

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

     

···

       
39
       
 
       
	"chat.bsky.actor.declaration": true,

     

       
40
       
 
       
}

     

       
41
       
 
       


     

       
42
       
-
       
// const JetstreamUrl = `wss://jetstream1.us-west.bsky.network/subscribe`

     

       
43
       
-
       


     

       
44
       
-
       
const JetstreamUrl = `ws://localhost:6008/subscribe` // TODO(ejd): attach a reconnect cursor

     

       
45
       
 
       


     

       
46
       
 
       
const userTimestampUpdate = `insert into users (did, ts) values (?, ?) on conflict (did) do update set ts = ?`

     

       
47
       
 
       


     

···

       
39
       
 
       
	"chat.bsky.actor.declaration": true,

     

       
40
       
 
       
}

     

       
41
       
 
       


     

       
42
       
+
       
const JetstreamUrl = `wss://jetstream1.us-west.bsky.network/subscribe` // TODO(ejd): attach a reconnect cursor

     

       
0
       
 
       

     

       
0
       
 
       

     

       
43
       
 
       


     

       
44
       
 
       
const userTimestampUpdate = `insert into users (did, ts) values (?, ?) on conflict (did) do update set ts = ?`

     

       
45