mackuba.eu
+2
-2
app/firehose_stream.rb
+2
-2
app/firehose_stream.rb
···
34
34
@sky = sky = Skyfall::Stream.new(@service, :subscribe_repos, cursor)
35
35
36
36
@sky.on_message do |m|
37
-
handle_message(m)
37
+
process_message(m)
38
38
end
39
39
40
40
if @log_status
···
73
73
Subscription.where(service: @service).update_all(cursor: cursor)
74
74
end
75
75
76
-
def handle_message(msg)
76
+
def process_message(msg)
77
77
if msg.is_a?(Skyfall::InfoMessage)
78
78
# AtProto error, the only one right now is "OutdatedCursor"
79
79
puts "InfoMessage: #{msg}"