mackuba.eu
+2
-2
app/firehose_stream.rb
+2
-2
app/firehose_stream.rb
···
73
end
74
75
def process_message(msg)
76
-
if msg.is_a?(Skyfall::InfoMessage)
77
# AtProto error, the only one right now is "OutdatedCursor"
78
log "InfoMessage: #{msg}"
79
-
elsif msg.is_a?(Skyfall::HandleMessage)
80
# use these events if you want to track handle changes:
81
# log "Handle change: #{msg.repo} => #{msg.handle}"
82
elsif msg.is_a?(Skyfall::UnknownMessage)
···
73
end
74
75
def process_message(msg)
76
+
if msg.type == :info
77
# AtProto error, the only one right now is "OutdatedCursor"
78
log "InfoMessage: #{msg}"
79
+
elsif msg.type == :handle
80
# use these events if you want to track handle changes:
81
# log "Handle change: #{msg.repo} => #{msg.handle}"
82
elsif msg.is_a?(Skyfall::UnknownMessage)