mackuba.eu
A Ruby gem for streaming data from the Bluesky/ATProto firehose
parse labels eagerly in LabelsMessage
so they can be printed in the inspect output
+8
-2
lib/skyfall/firehose/labels_message.rb
+8
-2
lib/skyfall/firehose/labels_message.rb
···
3
3
4
4
module Skyfall
5
5
class Firehose::LabelsMessage < Firehose::Message
6
-
def labels
7
-
@labels ||= @data_object['labels'].map { |x| Label.new(x) }
6
+
7
+
attr_reader :labels
8
+
9
+
def initialize(type_object, data_object)
10
+
super
11
+
raise DecodeError.new("Missing event details") unless @data_object['labels'].is_a?(Array)
12
+
13
+
@labels = @data_object['labels'].map { |x| Label.new(x) }
8
14
end
9
15
10
16
protected