commit cafcb5e20b3ff352b0d915730955ce6151f97e85 · mackuba.eu/lycan

app/firehose_client.rb

··· 151 end 152 end 153 end 154 end 155 156 def process_account_event(msg) ··· 166 return unless @current_user 167 168 if op.action == :create 169 @current_user.likes.import_from_record(op.uri, op.raw_record, queue: :firehose) 170 elsif op.action == :delete 171 @current_user.likes.where(rkey: op.rkey).delete_all ··· 176 return unless @current_user 177 178 if op.action == :create 179 @current_user.reposts.import_from_record(op.uri, op.raw_record, queue: :firehose) 180 elsif op.action == :delete 181 @current_user.reposts.where(rkey: op.rkey).delete_all ··· 184 185 def process_post(msg, op) 186 if op.action == :create 187 if @current_user 188 @current_user.quotes.import_from_record(op.uri, op.raw_record, queue: :firehose) 189 @current_user.pins.import_from_record(op.uri, op.raw_record, queue: :firehose)

··· 151 end 152 end 153 end 154 + rescue CBOR::UnpackError 155 + # ignore invalid records 156 end 157 158 def process_account_event(msg) ··· 168 return unless @current_user 169 170 if op.action == :create 171 + return if op.raw_record.nil? 172 @current_user.likes.import_from_record(op.uri, op.raw_record, queue: :firehose) 173 elsif op.action == :delete 174 @current_user.likes.where(rkey: op.rkey).delete_all ··· 179 return unless @current_user 180 181 if op.action == :create 182 + return if op.raw_record.nil? 183 @current_user.reposts.import_from_record(op.uri, op.raw_record, queue: :firehose) 184 elsif op.action == :delete 185 @current_user.reposts.where(rkey: op.rkey).delete_all ··· 188 189 def process_post(msg, op) 190 if op.action == :create 191 + return if op.raw_record.nil? 192 + 193 if @current_user 194 @current_user.quotes.import_from_record(op.uri, op.raw_record, queue: :firehose) 195 @current_user.pins.import_from_record(op.uri, op.raw_record, queue: :firehose)