edavis.dev
+6
bsky-activity.py
+6
bsky-activity.py
···
81
81
{'did': repo_did, 'ts': repo_update_time.timestamp()}
82
82
)
83
83
84
+
if collection == 'app.bsky.feed.post':
85
+
embed = payload['record'].get('embed')
86
+
if embed is not None and embed.get('$type', ''):
87
+
embed_type = embed['$type']
88
+
redis_pipe.incr(f'app.bsky.feed.post:embed:{embed_type}')
89
+
84
90
redis_pipe \
85
91
.incr(collection) \
86
92
.incr('dev.edavis.muninsky.ops')