Class: CycloneLariat::Outbox::Mappers::Messages

Inherits:
Repo::Mappers::Base show all
Defined in:
lib/cyclone_lariat/plugins/outbox/mappers/messages.rb

Class Method Summary collapse

Class Method Details

.from_row(row) ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
 
# File 'lib/cyclone_lariat/plugins/outbox/mappers/messages.rb', line 10

def from_row(row)
  return if row.nil?

  attrs = hash_from_json_column(row[:serialized_message]).symbolize_keys
  attrs[:uuid]             = row[:uuid]
  attrs[:deduplication_id] = row[:deduplication_id]
  attrs[:group_id]         = row[:group_id]
  attrs[:sending_error]    = row[:sending_error]

  attrs
end

.to_row(input) ⇒ Object 



22
23
24
25
26
27
28
29
30
 
# File 'lib/cyclone_lariat/plugins/outbox/mappers/messages.rb', line 22

def to_row(input)
  {}.tap do |row|
    row[:uuid] = input.uuid if input.uuid
    row[:deduplication_id] = input.deduplication_id
    row[:group_id] = input.group_id
    row[:serialized_message] = input.to_json
    row[:sending_error] = input.sending_error
  end
end