Mapper detects Hash vs Record and handles them correctly.

Author: dysk

rails_application/lib/transformations/refund_to_return_event_mapper.rb

@@ -9,22 +9,29 @@ def dump(record)
     end
 
     def load(record)
-      return record unless record.respond_to?(:timestamp) && record.timestamp
+      if record.is_a?(Hash)
+        old_class_name = record[:event_type]
+      else
+        old_class_name = record.event_type
+      end
 
-      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)
-        
-        record.class.new(
-          event_id: record.event_id,
-          event_type: new_class_name,
-          data: transformed_data,
-          metadata: record.metadata,
-          timestamp: record.timestamp,
-          valid_at: record.valid_at
-        )
+        if record.is_a?(Hash)
+          transformed_data = transform_payload(record[:data], old_class_name)
+          record.merge(event_type: new_class_name, data: transformed_data)
+        else
+          transformed_data = transform_payload(record.data, old_class_name)
+          record.class.new(
+            event_id: record.event_id,
+            event_type: new_class_name,
+            data: transformed_data,
+            metadata: record.metadata,
+            timestamp: record.timestamp,
+            valid_at: record.valid_at
+          )
+        end
       else
         record
       end

rails_application/test/transformations/refund_to_return_event_mapper_test.rb

@@ -125,18 +125,18 @@ def test_event_store_with_simple_transformation
     return_id = SecureRandom.uuid
     order_id = SecureRandom.uuid
 
-    old_event = Ordering::ItemAddedToRefund.new(
+    old_event = Ordering::ItemAddedToReturn.new(
       data: { 
-        refund_id: return_id, 
-        order_id: order_id, 
+        return_id: return_id,
+        order_id: order_id,
         product_id: SecureRandom.uuid
       }
     )
 
     event_store.publish(old_event, stream_name: "Return$#{return_id}")
 
     events = event_store.read.stream("Return$#{return_id}").to_a
-    
+
     assert_equal 1, events.size
     assert_equal 'Ordering::ItemAddedToReturn', events.first.class.name
     assert_equal return_id, events.first.data[:return_id]