Add PreserveTypes to the pipeline to handle key symbolization.

- use PreserveTypes transformation with the same types config standard JSONClient uses
- make PreserveTypes run before RefundToReturnEventMapper to allow it to symbolize old keys because old key names are stored in metadata PreserveTypes uses
- run RefundToReturnEventMapper and transform payload using already symbolized keys

Author: dysk

infra/lib/infra/event_store.rb

@@ -4,8 +4,11 @@ def self.main
       require_relative "../../../rails_application/lib/transformations/refund_to_return_event_mapper" rescue nil
 
       begin
+        preserve_types = create_standard_preserve_types
+
         mapper = RubyEventStore::Mappers::PipelineMapper.new(
           RubyEventStore::Mappers::Pipeline.new(
+            preserve_types,
             Transformations::RefundToReturnEventMapper.new(
               'Ordering::DraftRefundCreated' => 'Ordering::DraftReturnCreated',
               'Ordering::ItemAddedToRefund' => 'Ordering::ItemAddedToReturn',
@@ -52,5 +55,55 @@ def link_event_to_stream(event, stream, expected_version: :any)
       )
     end
 
+    private
+
+    def self.create_standard_preserve_types
+      preserve_types = RubyEventStore::Mappers::Transformation::PreserveTypes.new
+
+      types_config = {
+        Symbol => {
+          serializer: ->(v) { v.to_s },
+          deserializer: ->(v) { v.to_sym }
+        },
+        Time => {
+          serializer: ->(v) { v.iso8601(RubyEventStore::TIMESTAMP_PRECISION) },
+          deserializer: ->(v) { Time.iso8601(v) }
+        },
+        Date => {
+          serializer: ->(v) { v.iso8601 },
+          deserializer: ->(v) { Date.iso8601(v) }
+        },
+        DateTime => {
+          serializer: ->(v) { v.iso8601 },
+          deserializer: ->(v) { DateTime.iso8601(v) }
+        },
+        BigDecimal => {
+          serializer: ->(v) { v.to_s },
+          deserializer: ->(v) { BigDecimal(v) }
+        }
+      }
+
+      if defined?(ActiveSupport::TimeWithZone)
+        types_config[ActiveSupport::TimeWithZone] = {
+          serializer: ->(v) { v.iso8601(RubyEventStore::TIMESTAMP_PRECISION) },
+          deserializer: ->(v) { Time.iso8601(v).in_time_zone },
+          stored_type: ->(*) { "ActiveSupport::TimeWithZone" }
+        }
+      end
+
+      if defined?(OpenStruct)
+        types_config[OpenStruct] = {
+          serializer: ->(v) { v.to_h },
+          deserializer: ->(v) { OpenStruct.new(v) }
+        }
+      end
+
+      types_config.each do |type, config|
+        preserve_types.register(type, **config)
+      end
+
+      preserve_types
+    end
+
   end
 end

rails_application/lib/transformations/refund_to_return_event_mapper.rb

@@ -32,10 +32,10 @@ def load(record)
     def transform_payload(data, old_class_name)
       case old_class_name
       when 'Ordering::DraftRefundCreated'
-        data = transform_refund_to_return_payload(data, "refund_id", "return_id")
-        transform_refund_to_return_payload(data, "refundable_products", "returnable_products")
+        data = transform_refund_to_return_payload(data, :refund_id, :return_id)
+        transform_refund_to_return_payload(data, :refundable_products, :returnable_products)
       when 'Ordering::ItemAddedToRefund', 'Ordering::ItemRemovedFromRefund'
-        transform_refund_to_return_payload(data, "refund_id", "return_id")
+        transform_refund_to_return_payload(data, :refund_id, :return_id)
       else
         data
       end