···

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

     

       
39
       
39
       
 
       
    sys.stdout.flush()

     

       
40
       
40
       
 
       


     

       
41
       
41
       
-
       
    async with websockets.connect(relay_url) as firehose:

     

       
41
       
41
       
+
       
    async with websockets.connect(relay_url, ping_timeout=60) as firehose:

     

       
42
       
42
       
 
       
        while True:

     

       
43
       
43
       
 
       
            frame = BytesIO(await firehose.recv())

     

       
44
       
44
       
 
       
            header = dag_cbor.decode(frame, allow_concat=True)