mackuba.eu
A Ruby gem for streaming data from the Bluesky/ATProto firehose
added example script
+2
README.md
+2
README.md
+27
example/firehose.rb
+27
example/firehose.rb
···
1
+
#!/usr/bin/env ruby
2
+
3
+
lib = File.expand_path('../../lib', __FILE__)
4
+
$LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)
5
+
6
+
require 'skyfall'
7
+
8
+
sky = Skyfall::Stream.new('bsky.social', :subscribe_repos)
9
+
10
+
sky.on_message do |m|
11
+
next if m.type != :commit
12
+
13
+
m.operations.each do |op|
14
+
next unless op.action == :create && op.type == :bsky_post
15
+
16
+
puts "#{op.repo}:"
17
+
puts op.raw_record['text']
18
+
puts
19
+
end
20
+
end
21
+
22
+
sky.on_connect { puts "Connected" }
23
+
sky.on_disconnect { puts "Disconnected" }
24
+
sky.on_error { |e| puts "ERROR: #{e}" }
25
+
26
+
sky.connect
27
+
sleep