Module: Messaging::Message::Transform::MessageData

Defined in:
lib/messaging/message/transform.rb

Class Method Summary collapse

Class Method Details

.read(message_data) ⇒ Object 



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'lib/messaging/message/transform.rb', line 35

def self.read(message_data)
  data = message_data.to_h

  unless data[:metadata].nil?
    data[:metadata] = data[:metadata].clone
  else
    data[:metadata] = {}
  end

  metadata = data[:metadata]

  metadata[:stream_name] = data[:stream_name]
  metadata[:position] = data[:position]

  metadata[:global_position] = data[:global_position]
  metadata[:time] = data[:time]

  data
end

.write(message) ⇒ Object 



19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/messaging/message/transform.rb', line 19

def self.write(message)
  message_data = MessageStore::MessageData::Write.build

  message_data.id = message.id
  message_data.type = message.message_type

  message_data.data = message.to_h

  metadata = message.metadata.to_h
  metadata.delete_if { |k, v| v.nil? }

  message_data.metadata = metadata

  message_data
end