+5
app/firehose_stream.rb
+5
app/firehose_stream.rb
···
117
117
118
118
return unless op.action == :create
119
119
120
+
if op.raw_record.nil?
121
+
puts "Error: missing expected record data in operation: #{op.uri}"
122
+
return
123
+
end
124
+
120
125
# ignore posts with past date from Twitter etc. imported using some kind of tool
121
126
begin
122
127
post_time = Time.parse(op.raw_record['createdAt'])