mackuba.eu
+10
-4
app/firehose_stream.rb
+10
-4
app/firehose_stream.rb
···
65
65
log "Disconnected."
66
66
}
67
67
68
-
@sky.on_timeout { log "Trying to reconnect..." }
69
-
@sky.on_reconnect { log "Connection lost, reconnecting..." }
68
+
@sky.on_reconnect {
69
+
log "Connection lost, reconnecting..."
70
+
}
71
+
72
+
@sky.on_timeout {
73
+
log "Trying to reconnect..."
74
+
}
75
+
70
76
@sky.on_error { |e| log "ERROR: #{e.class} #{e.message}" }
71
77
end
72
78
···
96
102
97
103
def process_message(msg)
98
104
if msg.type == :info
99
-
# AtProto error, the only one right now is "OutdatedCursor"
105
+
# ATProto error, the only one right now is "OutdatedCursor"
100
106
log "InfoMessage: #{msg}"
101
107
102
108
elsif msg.type == :identity
···
107
113
# tracking account status changes, e.g. suspensions, deactivations and deletes
108
114
process_account_message(msg)
109
115
110
-
elsif msg.is_a?(Skyfall::Firehose::UnknownMessage)
116
+
elsif msg.unknown?
111
117
log "Unknown message type: #{msg.type} (#{msg.seq})"
112
118
end
113
119