commit c9eafff6898a3aaa3fa7af46db9ceb5e5ce0e7b5 · edavis.dev/bsky-tools

+4 -1

feeds/__init__.py

···

       41
        
               return datetime.now(timezone.utc)

     

       42
        
       

     

       43
        
           def safe_timestamp(self, timestamp):

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       44
        
               parsed = self.parse_timestamp(timestamp)

     

       45
       -
               utc_now = datetime.now(timezone.utc)

     

       46
        
               if parsed.timestamp() <= 0:

     

       47
        
                   return utc_now

     

       48
        
               elif parsed - timedelta(minutes=2) < utc_now:

···

       41
        
               return datetime.now(timezone.utc)

     

       42
        
       

     

       43
        
           def safe_timestamp(self, timestamp):

     

       44
       +
               utc_now = datetime.now(timezone.utc)

     

       45
       +
               if timestamp is None:

     

       46
       +
                   return utc_now

     

       47
       +
       

     

       48
        
               parsed = self.parse_timestamp(timestamp)

     

       0
        
       
     

       49
        
               if parsed.timestamp() <= 0:

     

       50
        
                   return utc_now

     

       51
        
               elif parsed - timedelta(minutes=2) < utc_now:

+1 -1

feeds/battle.py

···

       44
        
               path = op['path']

     

       45
        
               post_uri = f'at://{repo}/{path}'

     

       46
        
               length = grapheme.length(record.get('text', ''))

     

       47
       -
               ts = self.safe_timestamp(record.get('createdAt', '')).timestamp()

     

       48
        
       

     

       49
        
               self.transaction_begin(self.db_cnx)

     

       50

···

       44
        
               path = op['path']

     

       45
        
               post_uri = f'at://{repo}/{path}'

     

       46
        
               length = grapheme.length(record.get('text', ''))

     

       47
       +
               ts = self.safe_timestamp(record.get('createdAt')).timestamp()

     

       48
        
       

     

       49
        
               self.transaction_begin(self.db_cnx)

     

       50

+1 -1

feeds/popular.py

···

       34
        
               if record is None:

     

       35
        
                   return

     

       36
        
       

     

       37
       -
               ts = self.safe_timestamp(record['createdAt']).timestamp()

     

       38
        
               like_subject_uri = op['record']['subject']['uri']

     

       39
        
       

     

       40
        
               self.transaction_begin(self.db_cnx)

···

       34
        
               if record is None:

     

       35
        
                   return

     

       36
        
       

     

       37
       +
               ts = self.safe_timestamp(record.get('createdAt')).timestamp()

     

       38
        
               like_subject_uri = op['record']['subject']['uri']

     

       39
        
       

     

       40
        
               self.transaction_begin(self.db_cnx)

+1 -1

feeds/rapidfire.py

···

       46
        
                   repo = commit['repo']

     

       47
        
                   path = op['path']

     

       48
        
                   post_uri = f'at://{repo}/{path}'

     

       49
       -
                   ts = self.safe_timestamp(record.get('createdAt', '')).timestamp()

     

       50
        
       

     

       51
        
                   self.transaction_begin(self.db_cnx)

     

       52

···

       46
        
                   repo = commit['repo']

     

       47
        
                   path = op['path']

     

       48
        
                   post_uri = f'at://{repo}/{path}'

     

       49
       +
                   ts = self.safe_timestamp(record.get('createdAt')).timestamp()

     

       50
        
       

     

       51
        
                   self.transaction_begin(self.db_cnx)

     

       52