mackuba.eu
+1
-4
app/firehose_stream.rb
+1
-4
app/firehose_stream.rb
···
114
114
@replaying = false
115
115
end
116
116
117
-
if msg.seq % 10 == 0
118
-
save_cursor(msg.seq)
119
-
end
120
-
121
117
msg.operations.each do |op|
122
118
case op.type
123
119
when :bsky_post
···
223
219
# wait until we have 100 posts and then save them all in one insert, if possible
224
220
if @post_queue.length >= POSTS_BATCH_SIZE
225
221
save_queued_posts
222
+
save_cursor(@sky.cursor)
226
223
end
227
224
228
225
print '.' if @show_progress && @log_posts != :all