Class: EventStoreClient::Serializer::EventDeserializer

Inherits:
Object
  • Object
show all
Defined in:
lib/event_store_client/serializer/event_deserializer.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(serializer:) ⇒ EventDeserializer

Returns a new instance of EventDeserializer.

Parameters:

  • serializer (#serialize, #deserialize) 


21
22
23
 
# File 'lib/event_store_client/serializer/event_deserializer.rb', line 21

def initialize(serializer:)
  @serializer = serializer
end

Class Method Details

.call(raw_event, serializer: Serializer::Json) ⇒ EventStoreClient::DeserializedEvent

Parameters:

  • raw_event (EventStore::Client::Streams::ReadResp::ReadEvent::RecordedEvent, EventStore::Client::PersistentSubscriptions::ReadResp::ReadEvent::RecordedEvent)
  • serializer (#serialize, #deserialize) (defaults to: Serializer::Json)

Returns:



12
13
14
 
# File 'lib/event_store_client/serializer/event_deserializer.rb', line 12

def call(raw_event, serializer: Serializer::Json)
  new(serializer: serializer).call(raw_event)
end

Instance Method Details

#call(raw_event) ⇒ EventStoreClient::DeserializedEvent

Parameters:

  • raw_event (EventStore::Client::Streams::ReadResp::ReadEvent::RecordedEvent, EventStore::Client::PersistentSubscriptions::ReadResp::ReadEvent::RecordedEvent)

Returns:



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/event_store_client/serializer/event_deserializer.rb', line 27

def call(raw_event)
  data = serializer.deserialize(normalize_serialized(raw_event.data))
  custom_metadata = serializer.deserialize(normalize_serialized(raw_event.custom_metadata))
  metadata = custom_metadata.merge(raw_event.metadata.to_h)

  event_class(metadata['type']).new(
    skip_validation: true,
    id: raw_event.id.string,
    title: "#{raw_event.stream_revision}@#{raw_event.stream_identifier.stream_name}",
    type: metadata['type'],
    data: data,
    metadata: metadata,
    stream_revision: raw_event.stream_revision,
    commit_position: raw_event.commit_position,
    prepare_position: raw_event.prepare_position,
    stream_name: raw_event.stream_identifier.stream_name
  )
end