···

       
23
       
23
       
 
       
        while True:

     

       
24
       
24
       
 
       
            message = BytesIO(await firehose.recv())

     

       
25
       
25
       
 
       
            header = dag_cbor.decode(message, allow_concat=True)

     

       
26
       
26
       
-
       
            if header['op'] != 1 or header['t'] == '#info':

     

       
26
       
26
       
+
       
            if header['op'] != 1:

     

       
27
       
27
       
 
       
                continue

     

       
28
       
28
       
 
       


     

       
29
       
29
       
 
       
            redis_cnx.publish('bsky-tools:firehose:stream', message.getvalue())