this repo has no description
edavis.dev
1import logging
2
3import apsw
4import apsw.ext
5
6from . import BaseFeed
7
8class MostLikedFeed(BaseFeed):
9 FEED_URI = 'at://did:plc:4nsduwlpivpuur4mqkbfvm6a/app.bsky.feed.generator/most-liked'
10 SERVE_FEED_QUERY = """
11 select uri, create_ts, unixepoch('now', '-24 hours'), create_ts - unixepoch('now', '-24 hours'), likes
12 from posts
13 where create_ts >= unixepoch('now', '-24 hours')
14 order by likes desc, create_ts asc
15 limit :limit offset :offset
16 """
17 DELETE_OLD_POSTS_QUERY = """
18 delete from posts
19 where create_ts < unixepoch('now', '-24 hours')
20 """
21
22 def __init__(self):
23 self.db_cnx = apsw.Connection('db/mostliked.db')
24 self.db_cnx.pragma('journal_mode', 'WAL')
25 self.db_cnx.pragma('wal_autocheckpoint', '0')
26
27 with self.db_cnx:
28 self.db_cnx.execute("""
29 create table if not exists posts (
30 uri text, create_ts timestamp, likes int
31 );
32 create unique index if not exists uri_idx on posts(uri);
33 create index if not exists create_ts_idx on posts(create_ts);
34 """)
35
36 self.logger = logging.getLogger('feeds.mostliked')
37
38 def process_commit(self, commit):
39 return
40
41 def delete_old_posts(self):
42 self.db_cnx.execute(self.DELETE_OLD_POSTS_QUERY)
43 self.logger.debug('deleted {} old posts'.format(self.db_cnx.changes()))
44
45 def commit_changes(self):
46 self.delete_old_posts()
47 self.logger.debug('committing changes')
48 self.transaction_commit(self.db_cnx)
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