···

       
51
       
 
       
feed_manager.register(HomeRunsTeamFeed)

     

       
52
       
 
       
feed_manager.register(NoraZoneInteresting)

     

       
53
       
 
       
feed_manager.register(SevenDirtyWordsFeed)

     

       
54
       
-
       
# feed_manager.register(MostLikedFeed)

     

       
55
       
 
       
feed_manager.register(PopularQuotePostsFeed)

     

···

       
51
       
 
       
feed_manager.register(HomeRunsTeamFeed)

     

       
52
       
 
       
feed_manager.register(NoraZoneInteresting)

     

       
53
       
 
       
feed_manager.register(SevenDirtyWordsFeed)

     

       
54
       
+
       
feed_manager.register(MostLikedFeed)

     

       
55
       
 
       
feed_manager.register(PopularQuotePostsFeed)

     

···

       
36
       
 
       
        self.logger = logging.getLogger('feeds.mostliked')

     

       
37
       
 
       


     

       
38
       
 
       
    def process_commit(self, commit):

     

       
39
       
-
       
        if commit['opType'] != 'c':

     

       
40
       
-
       
            return

     

       
41
       
-
       


     

       
42
       
-
       
        if commit['collection'] != 'app.bsky.feed.like':

     

       
43
       
-
       
            return

     

       
44
       
-
       


     

       
45
       
-
       
        record = commit.get('record')

     

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

     

       
47
       
-
       
        try:

     

       
48
       
-
       
            uri = record['subject']['uri']

     

       
49
       
-
       
        except KeyError:

     

       
50
       
-
       
            return

     

       
51
       
-
       


     

       
52
       
-
       
        self.transaction_begin(self.db_cnx)

     

       
53
       
-
       


     

       
54
       
-
       
        self.db_cnx.execute("""

     

       
55
       
-
       
        insert into posts (uri, create_ts, likes)

     

       
56
       
-
       
        values (:uri, :ts, 1)

     

       
57
       
-
       
        on conflict(uri)

     

       
58
       
-
       
        do update set

     

       
59
       
-
       
          likes = likes + 1

     

       
60
       
-
       
        """, dict(uri=uri, ts=ts))

     

       
61
       
 
       


     

       
62
       
 
       
    def delete_old_posts(self):

     

       
63
       
 
       
        self.db_cnx.execute(self.DELETE_OLD_POSTS_QUERY)

     
···

       
70
       
 
       
        self.wal_checkpoint(self.db_cnx, 'RESTART')

     

       
71
       
 
       


     

       
72
       
 
       
    def serve_feed(self, limit, offset, langs):

     

       
73
       
-
       
        cur = self.db_cnx.execute(self.SERVE_FEED_QUERY, dict(limit=limit, offset=offset))

     

       
74
       
-
       
        return [row[0] for row in cur]

     

       
0
       
 
       

     

       
75
       
 
       


     

       
76
       
 
       
    def serve_feed_debug(self, limit, offset, langs):

     

       
77
       
-
       
        bindings = dict(limit=limit, offset=offset)

     

       
78
       
-
       
        return apsw.ext.format_query_table(

     

       
79
       
-
       
            self.db_cnx, self.SERVE_FEED_QUERY, bindings,

     

       
80
       
-
       
            string_sanitize=2, text_width=9999, use_unicode=True

     

       
81
       
-
       
        )

     

···

       
36
       
 
       
        self.logger = logging.getLogger('feeds.mostliked')

     

       
37
       
 
       


     

       
38
       
 
       
    def process_commit(self, commit):

     

       
39
       
+
       
        return

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
40
       
 
       


     

       
41
       
 
       
    def delete_old_posts(self):

     

       
42
       
 
       
        self.db_cnx.execute(self.DELETE_OLD_POSTS_QUERY)

     
···

       
49
       
 
       
        self.wal_checkpoint(self.db_cnx, 'RESTART')

     

       
50
       
 
       


     

       
51
       
 
       
    def serve_feed(self, limit, offset, langs):

     

       
52
       
+
       
        return [

     

       
53
       
+
       
            'at://did:plc:4nsduwlpivpuur4mqkbfvm6a/app.bsky.feed.post/3l3cgg5vbc72i'

     

       
54
       
+
       
        ]

     

       
55
       
 
       


     

       
56
       
 
       
    def serve_feed_debug(self, limit, offset, langs):

     

       
57
       
+
       
        pass

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0