A Ruby gem for streaming data from the Bluesky/ATProto firehose

added #operation to Jetstream Message, returning 1 op

+13 -1
+7 -1
lib/skyfall/jetstream/commit_message.rb
··· 9 super 10 end 11 12 def operations 13 - @operations ||= [Jetstream::Operation.new(self, json['commit'])] 14 end 15 end 16 end
··· 9 super 10 end 11 12 + def operation 13 + @operation ||= Jetstream::Operation.new(self, json['commit']) 14 + end 15 + 16 + alias op operation 17 + 18 def operations 19 + [operation] 20 end 21 end 22 end
+6
lib/skyfall/jetstream/message.rb
··· 43 self.is_a?(Jetstream::UnknownMessage) 44 end 45 46 def operations 47 [] 48 end
··· 43 self.is_a?(Jetstream::UnknownMessage) 44 end 45 46 + def operation 47 + nil 48 + end 49 + 50 + alias op operation 51 + 52 def operations 53 [] 54 end