mackuba.eu
A Ruby gem for streaming data from the Bluesky/ATProto firehose
some other tweaks in the examples
+12
-8
example/block_tracker.rb
+12
-8
example/block_tracker.rb
···
1
1
#!/usr/bin/env ruby
2
2
3
-
# Example: monitor the network for people blocking your account or adding you to mute lists.
3
+
# Example: monitor the network for people blocking your account or adding you to lists.
4
4
5
5
# load skyfall from a local folder - you normally won't need this
6
6
$LOAD_PATH.unshift(File.expand_path('../lib', __dir__))
···
21
21
22
22
sky = Skyfall::Firehose.new('bsky.network', :subscribe_repos)
23
23
24
-
sky.on_connect { puts "Connected, monitoring #{$monitored_did}" }
25
-
sky.on_disconnect { puts "Disconnected" }
26
-
sky.on_reconnect { puts "Reconnecting..." }
27
-
sky.on_error { |e| puts "ERROR: #{e}" }
24
+
sky.on_connect { log "Connected, monitoring #{$monitored_did}" }
25
+
sky.on_disconnect { log "Disconnected" }
26
+
sky.on_reconnect { log "Reconnecting..." }
27
+
sky.on_error { |e| log "ERROR: #{e}" }
28
28
29
29
sky.on_message do |msg|
30
30
# we're only interested in repo commit messages
···
41
41
process_list_item(msg, op)
42
42
end
43
43
rescue StandardError => e
44
-
puts "Error: #{e}"
44
+
log "Error: #{e}"
45
45
end
46
46
end
47
47
end
48
48
49
+
def log(msg)
50
+
puts "[#{Time.now}] #{msg}"
51
+
end
52
+
49
53
def process_block(msg, op)
50
54
if op.raw_record['subject'] == $monitored_did
51
55
owner_handle = get_user_handle(op.repo)
52
-
puts "@#{owner_handle} has blocked you! (#{msg.time.getlocal})"
56
+
log "@#{owner_handle} has blocked you! (#{msg.time.getlocal})"
53
57
end
54
58
end
55
59
···
60
64
list_uri = op.raw_record['list']
61
65
list_name = get_list_name(list_uri)
62
66
63
-
puts "@#{owner_handle} has added you to list \"#{list_name}\" (#{msg.time.getlocal})"
67
+
log "@#{owner_handle} has added you to list \"#{list_name}\" (#{msg.time.getlocal})"
64
68
end
65
69
end
66
70
+5
-2
example/print_all_posts.rb
+5
-2
example/print_all_posts.rb
···
1
1
#!/usr/bin/env ruby
2
2
3
3
# Example: print the date and text of every new post made on the network as they appear.
4
+
# Pass a hostname of a single PDS as the argument to only stream new posts from that PDS.
4
5
5
6
# load skyfall from a local folder - you normally won't need this
6
7
$LOAD_PATH.unshift(File.expand_path('../lib', __dir__))
7
8
8
9
require 'skyfall'
9
10
10
-
sky = Skyfall::Firehose.new('bsky.network', :subscribe_repos)
11
+
firehose_host = ARGV[0] || 'bsky.network'
12
+
13
+
sky = Skyfall::Firehose.new(firehose_host, :subscribe_repos)
11
14
12
15
sky.on_message do |msg|
13
16
# we're only interested in repo commit messages
···
23
26
end
24
27
end
25
28
26
-
sky.on_connect { puts "Connected" }
29
+
sky.on_connect { puts "Connected to #{firehose_host}" }
27
30
sky.on_disconnect { puts "Disconnected" }
28
31
sky.on_reconnect { puts "Reconnecting..." }
29
32
sky.on_error { |e| puts "ERROR: #{e}" }