Debug transformations.

Author: dysk

.github/workflows/rails_application.yml

@@ -184,6 +184,7 @@ jobs:
         working-directory: ${{ env.WORKING_DIRECTORY }}
         env:
           NUM_GROUPS_FROM_CI: ${{ needs.determine_run_parameters.outputs.num_groups }}
+          DEBUG_TRANSFORMATIONS: true
         run: |
           echo "Waiting for PostgreSQL to be ready..."
           until pg_isready -h localhost -p 5432 -U "postgres" -d "cqrs-es-sample-with-res_test"; do
@@ -193,7 +194,7 @@ jobs:
 
           RAILS_ENV=test bundle exec rails db:prepare
 
-          SUBJECT_LIST_OUTPUT=$(RAILS_ENV=test bundle exec mutant environment subject list)
+          SUBJECT_LIST_OUTPUT=$(RAILS_ENV=test DEBUG_TRANSFORMATIONS=true bundle exec mutant environment subject list)
           mapfile -t subjects_array < <( \
             echo "$SUBJECT_LIST_OUTPUT" | \
             awk 'NR == 1 {next} /Run options:/ {exit} {print}' | \

infra/lib/infra/event_store.rb

@@ -1,23 +1,27 @@
 module Infra
   class EventStore < SimpleDelegator
     def self.main
-      require_relative "../../../rails_application/lib/transformations/refund_to_return_event_mapper" rescue nil
+      if ENV['DISABLE_EVENT_TRANSFORMATIONS'] == 'true'
+        mapper = default_mapper
+      else
+        require_relative "../../../rails_application/lib/transformations/refund_to_return_event_mapper" rescue nil
 
-      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,
-            RubyEventStore::Mappers::Transformation::PreserveTypes.new
+        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,
+              RubyEventStore::Mappers::Transformation::PreserveTypes.new
+            )
           )
-        )
-      else
-        mapper = default_mapper
+        else
+          mapper = default_mapper
+        end
       end
 
       new(RailsEventStore::JSONClient.new(mapper: mapper))

rails_application/lib/transformations/refund_to_return_event_mapper.rb

@@ -5,23 +5,46 @@ def initialize(class_map)
     end
 
     def dump(record)
+      if ENV['DEBUG_TRANSFORMATIONS'] == 'true'
+        puts "[TRANSFORM] dump() called with event_type: #{record.event_type}"
+        puts "[TRANSFORM] record class: #{record.class.name}"
+        puts "[TRANSFORM] record timestamp: #{record.timestamp.inspect}"
+        puts "[TRANSFORM] record valid_at: #{record.valid_at.inspect}"
+      end
       record
     end
 
     def load(record)
+      if ENV['DEBUG_TRANSFORMATIONS'] == 'true'
+        puts "[TRANSFORM] load() called with event_type: #{record.event_type}"
+        puts "[TRANSFORM] record class: #{record.class.name}"
+        puts "[TRANSFORM] record timestamp: #{record.timestamp.inspect}"
+        puts "[TRANSFORM] record valid_at: #{record.valid_at.inspect}"
+      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
+        if ENV['DEBUG_TRANSFORMATIONS'] == 'true'
+          puts "[TRANSFORM] Transforming: #{old_class_name} -> #{new_class_name}"
+        end
+
         transformed_data = transform_payload(record.data, old_class_name)
-        record.class.new(
+        new_record = 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
         )
+
+        if ENV['DEBUG_TRANSFORMATIONS'] == 'true'
+          puts "[TRANSFORM] Created new record with timestamp: #{new_record.timestamp.inspect}"
+        end
+
+        new_record
       else
         record
       end