mackuba.eu
+4
-2
Gemfile.lock
+4
-2
Gemfile.lock
···
90
90
sinatra-activerecord (2.0.28)
91
91
activerecord (>= 4.1)
92
92
sinatra (>= 1.0)
93
-
skyfall (0.2.3)
93
+
skyfall (0.5.0)
94
94
base32 (~> 0.3, >= 0.3.4)
95
+
base64 (~> 0.1)
95
96
cbor (~> 0.5, >= 0.5.9.6)
96
-
faye-websocket (~> 0.11.2)
97
+
eventmachine (~> 1.2, >= 1.2.7)
98
+
faye-websocket (~> 0.11)
97
99
sqlite3 (2.6.0-arm64-darwin)
98
100
sqlite3 (2.6.0-x86_64-linux-gnu)
99
101
stringio (3.1.6)
+2
-2
app/firehose_stream.rb
+2
-2
app/firehose_stream.rb
···
31
31
last_cursor = load_or_init_cursor
32
32
cursor = @replay_events ? last_cursor : nil
33
33
34
-
@sky = sky = Skyfall::Stream.new(@service, :subscribe_repos, cursor)
34
+
@sky = sky = Skyfall::Firehose.new(@service, :subscribe_repos, cursor)
35
35
36
36
@sky.on_message do |m|
37
37
process_message(m)
···
79
79
elsif msg.type == :handle
80
80
# use these events if you want to track handle changes:
81
81
# log "Handle change: #{msg.repo} => #{msg.handle}"
82
-
elsif msg.is_a?(Skyfall::UnknownMessage)
82
+
elsif msg.is_a?(Skyfall::Firehose::UnknownMessage)
83
83
log "Unknown message type: #{msg.type} (#{msg.seq})"
84
84
end
85
85