···

       
17
       
17
       
 
       
)

     

       
18
       
18
       
 
       
logging.getLogger('').setLevel(logging.WARNING)

     

       
19
       
19
       
 
       
logging.getLogger('feeds').setLevel(logging.DEBUG)

     

       
20
       
20
       
+
       
logging.getLogger('firehose').setLevel(logging.DEBUG)

     

       
20
       
21
       
 
       


     

       
21
       
22
       
 
       
async def firehose_events(firehose_manager):

     

       
22
       
23
       
 
       
    relay_url = 'wss://bsky.network/xrpc/com.atproto.sync.subscribeRepos'

     

···

       
9
       
9
       
 
       
        with self.db_cnx:

     

       
10
       
10
       
 
       
            self.db_cnx.execute("create table if not exists firehose(key text unique, value text)")

     

       
11
       
11
       
 
       


     

       
12
       
12
       
-
       
        self.logger = logging.getLogger('feeds.firehose')

     

       
12
       
12
       
+
       
        self.logger = logging.getLogger('firehose.manager')

     

       
13
       
13
       
 
       


     

       
14
       
14
       
 
       
    def get_sequence_number(self):

     

       
15
       
15
       
 
       
        row = self.db_cnx.execute("select * from firehose where key = 'seq'").fetchone()