···

       
28
       
28
       
 
       
    logger = logging.getLogger('feeds.events')

     

       
29
       
29
       
 
       
    logger.info(f'opening websocket connection to {relay_url}')

     

       
30
       
30
       
 
       


     

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

     

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

     

       
32
       
32
       
 
       
        while True:

     

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

     

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