Don't use transformations for in-memory RES. Only apply for read old events to provide backward compatibility.

Author: dysk

infra/lib/infra/event_store.rb

@@ -32,26 +32,9 @@ def self.in_memory
     end
 
     def self.in_memory_rails
-      if defined?(Transformations::RefundToReturnEventMapper)
-        mapper = RubyEventStore::Mappers::PipelineMapper.new(
-          RubyEventStore::Mappers::Pipeline.new(
-            Transformations::RefundToReturnEventMapper.new(
-              'Ordering::DraftRefundCreated' => 'Ordering::DraftReturnCreated',
-              'Ordering::ItemAddedToRefund' => 'Ordering::ItemAddedToReturn',
-              'Ordering::ItemRemovedFromRefund' => 'Ordering::ItemRemovedFromReturn'
-            ),
-            RubyEventStore::Mappers::Transformation::DomainEvent.new,
-            RubyEventStore::Mappers::Transformation::SymbolizeMetadataKeys.new
-          )
-        )
-      else
-        mapper = default_mapper
-      end
-      
       new(
         RailsEventStore::Client.new(
-          repository: RubyEventStore::InMemoryRepository.new,
-          mapper: mapper
+          repository: RubyEventStore::InMemoryRepository.new
         )
       )
     end

rails_application/lib/transformations/refund_to_return_event_mapper.rb

@@ -9,19 +9,21 @@ def dump(record)
     end
 
     def load(record)
+      return record unless record.respond_to?(:timestamp) && record.timestamp
+
       old_class_name = record.event_type
       new_class_name = @class_map.fetch(old_class_name, old_class_name)
 
       if old_class_name != new_class_name
         transformed_data = transform_payload(record.data, old_class_name)
 
-        RubyEventStore::Record.new(
+        record.class.new(
           event_id: record.event_id,
           event_type: new_class_name,
           data: transformed_data,
           metadata: record.metadata,
-          timestamp: record.timestamp || Time.now.utc,
-          valid_at: record.valid_at || Time.now.utc
+          timestamp: record.timestamp,
+          valid_at: record.valid_at
         )
       else
         record