Fix problem with keys not being symbolized for TotalOrderValueUpdated event by defining event attributes. When attributes were not defined DomainEvent transformation was not able to symbolize existing keys.

Author: dysk

infra/lib/infra/event_store.rb

@@ -2,7 +2,6 @@ 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(
@@ -12,8 +11,8 @@ def self.main
               'Ordering::ItemAddedToRefund' => 'Ordering::ItemAddedToReturn',
               'Ordering::ItemRemovedFromRefund' => 'Ordering::ItemRemovedFromReturn'
             ),
-            Transformations::SymbolizeDataKeys.new,
-            RubyEventStore::Mappers::Transformation::SymbolizeMetadataKeys.new
+            RubyEventStore::Mappers::Transformation::SymbolizeMetadataKeys.new,
+            to_domain_event: RubyEventStore::Mappers::Transformation::DomainEvent.new
           )
         )
         client = RailsEventStore::JSONClient.new(mapper: mapper)

rails_application/app/processes/processes/invoices/money_splitter.rb

@@ -2,7 +2,7 @@ module Processes
   module Invoices
     class MoneySplitter
       def initialize(amount, quantity)
-        @amount = BigDecimal(amount.to_s)
+        @amount = amount
         @weights = Array.new(quantity, 1)
       end
 

rails_application/app/processes/processes/total_order_value_updated.rb

@@ -1,4 +1,12 @@
 module Processes
   class TotalOrderValueUpdated < Infra::Event
+    attribute :order_id, Infra::Types::UUID
+    attribute :total_amount, Infra::Types::Price
+    attribute :discounted_amount, Infra::Types::Price
+    attribute? :items, Infra::Types::Array do
+      attribute :product_id, Infra::Types::UUID
+      attribute :quantity, Infra::Types::Quantity
+      attribute :amount, Infra::Types::Price
+    end
   end
 end

rails_application/lib/transformations/refund_to_return_event_mapper.rb

@@ -14,20 +14,14 @@ def load(record)
 
       if old_class_name != new_class_name
         transformed_data = transform_payload(record.data, old_class_name)
-        begin
-          metadata_json = record.metadata.respond_to?(:to_json) ? record.metadata.to_json : record.metadata.to_h.to_json
-          RubyEventStore::SerializedRecord.new(
-            event_id: record.event_id,
-            event_type: new_class_name,
-            data: transformed_data.to_json,
-            metadata: metadata_json,
-            timestamp: record.timestamp,
-            valid_at: record.valid_at
-          )
-        rescue => e
-          puts "Mapper error: #{e.message}, falling back to original record"
-          record
-        end
+        RubyEventStore::Record.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
+        )
       else
         record
       end
@@ -38,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