A tool for measuring the coverage of Bluesky/ATProto relays
changed output of worker results
+6
-6
+6
-6
run_test.rb
+6
-6
run_test.rb
···
73
73
sky.connect
74
74
puts "[#{Time.now}] #{host}: Finished."
75
75
76
-
output.puts(JSON.generate([events, users.size, connected]))
76
+
output.puts(JSON.generate({ events: events, users: users.size, connected: connected }))
77
77
end
78
78
79
79
output.close
···
93
93
94
94
line = worker.pipe.gets
95
95
next if line.nil?
96
-
puts "#{worker.host}: #{line}" if verbose
97
96
98
-
events, users, connected = JSON.parse(line)
97
+
result = JSON.parse(line)
98
+
puts "#{worker.host}: #{result.inspect}" if verbose
99
99
100
100
Report.create!(
101
101
start_time: test_start_time,
102
102
duration: duration,
103
103
host: worker.host,
104
104
source_type: worker.type,
105
-
users: users,
106
-
events: events,
107
-
connected: connected
105
+
users: result['users'],
106
+
events: result['events'],
107
+
connected: result['connected']
108
108
)
109
109
end
110
110
rescue Interrupt