Add a transformation to ensure payload keys being transformed to symbols.

Author: dysk

infra/lib/infra/event_store.rb

@@ -2,6 +2,7 @@ module Infra
   class EventStore < SimpleDelegator
     def self.main
       require_relative "../../../rails_application/lib/transformations/refund_to_return_event_mapper" rescue nil
+      require_relative "../../../rails_application/lib/transformations/symbolize_data_keys" rescue nil
 
       begin
         mapper = RubyEventStore::Mappers::PipelineMapper.new(
@@ -11,8 +12,8 @@ def self.main
               'Ordering::ItemAddedToRefund' => 'Ordering::ItemAddedToReturn',
               'Ordering::ItemRemovedFromRefund' => 'Ordering::ItemRemovedFromReturn'
             ),
-            RubyEventStore::Mappers::Transformation::SymbolizeMetadataKeys.new,
-            RubyEventStore::Mappers::Transformation::PreserveTypes.new
+            Transformations::SymbolizeDataKeys.new,
+            RubyEventStore::Mappers::Transformation::SymbolizeMetadataKeys.new
           )
         )
         client = RailsEventStore::JSONClient.new(mapper: mapper)

rails_application/lib/transformations/symbolize_data_keys.rb

@@ -0,0 +1,34 @@
+module Transformations
+  class SymbolizeDataKeys
+    def dump(record)
+      record
+    end
+
+    def load(record)
+      return record unless record.respond_to?(:data)
+
+      symbolized_data = symbolize_keys(record.data)
+
+      if record.respond_to?(:dup)
+        new_record = record.dup
+        new_record.instance_variable_set(:@data, symbolized_data) if new_record.instance_variable_defined?(:@data)
+        new_record
+      else
+        record
+      end
+    end
+
+    private
+
+    def symbolize_keys(hash)
+      case hash
+      when Hash
+        hash.transform_keys(&:to_sym).transform_values { |v| symbolize_keys(v) }
+      when Array
+        hash.map { |v| symbolize_keys(v) }
+      else
+        hash
+      end
+    end
+  end
+end