Turned 3 more Orders event handlers tests into event-driven

This helps with changes at the domain/process level, where we don't need to change the tests.

Author: andrzejkrzywda

rails_application/test/orders/item_added_to_refund_test.rb

@@ -27,30 +27,52 @@ def test_add_item_to_refund
 
     private
 
+    def event_store
+      Rails.configuration.event_store
+    end
+
     def prepare_product(product_id, price)
-      run_command(
-        ProductCatalog::RegisterProduct.new(
-          product_id: product_id,
-          )
+      event_store.publish(
+        ProductCatalog::ProductRegistered.new(
+          data: { product_id: product_id }
+        )
       )
-      run_command(
-        ProductCatalog::NameProduct.new(
-          product_id: product_id,
-          name: "Async Remote"
+      event_store.publish(
+        ProductCatalog::ProductNamed.new(
+          data: { product_id: product_id, name: "Async Remote" }
         )
       )
-      run_command(Pricing::SetPrice.new(product_id: product_id, price: price))
+      event_store.publish(Pricing::PriceSet.new(data: { product_id: product_id, price: price }))
     end
 
     def place_order(order_id, product_id, price)
-      run_command(Pricing::AddPriceItem.new(order_id:, product_id:, price:))
-      run_command(Pricing::AcceptOffer.new(order_id:))
+      event_store.publish(
+        Pricing::PriceItemAdded.new(
+          data: {
+            order_id: order_id,
+            product_id: product_id,
+            base_price: price,
+            price: price,
+            base_total_value: price,
+            total_value: price
+          }
+        )
+      )
+      event_store.publish(
+        Pricing::OfferAccepted.new(
+          data: {
+            order_id: order_id,
+            order_lines: [{ product_id: product_id, quantity: 1 }]
+          }
+        )
+      )
     end
 
     def create_draft_refund(refund_id, order_id)
-      run_command(
-        Ordering::CreateDraftRefund.new(refund_id: refund_id, order_id: order_id)
+      draft_refund_created = Ordering::DraftRefundCreated.new(
+        data: { refund_id: refund_id, order_id: order_id, refundable_products: [] }
       )
+      CreateDraftRefund.new.call(draft_refund_created)
     end
 
     def item_added_to_refund(refund_id, order_id, product_id)

rails_application/test/orders/order_paid_test.rb

@@ -12,11 +12,29 @@ def test_order_confirmed
       product_id = SecureRandom.uuid
 
       create_product(product_id, "Async Remote", 10)
-      run_command(Crm::RegisterCustomer.new(customer_id: customer_id, name: "John Doe"))
-      run_command(Pricing::AddPriceItem.new(order_id: order_id, product_id: product_id, price: 10))
-      run_command(Pricing::AcceptOffer.new(order_id: order_id))
-      run_command(
-        Crm::AssignCustomerToOrder.new(customer_id: customer_id, order_id: order_id)
+      event_store.publish(Crm::CustomerRegistered.new(data: { customer_id: customer_id, name: "John Doe" }))
+      event_store.publish(
+        Pricing::PriceItemAdded.new(
+          data: {
+            order_id: order_id,
+            product_id: product_id,
+            base_price: 10,
+            price: 10,
+            base_total_value: 10,
+            total_value: 10
+          }
+        )
+      )
+      event_store.publish(
+        Pricing::OfferAccepted.new(
+          data: {
+            order_id: order_id,
+            order_lines: [{ product_id: product_id, quantity: 1 }]
+          }
+        )
+      )
+      event_store.publish(
+        Crm::CustomerAssignedToOrder.new(data: { customer_id: customer_id, order_id: order_id })
       )
 
       event_store.publish(Processes::TotalOrderValueUpdated.new(data: { order_id: order_id, discounted_amount: 0, total_amount: 10 }))
@@ -38,9 +56,13 @@ def test_order_confirmed
     private
 
     def create_product(product_id, name, price)
-      run_command(ProductCatalog::RegisterProduct.new(product_id: product_id))
-      run_command(ProductCatalog::NameProduct.new(product_id: product_id, name: name))
-      run_command(Pricing::SetPrice.new(product_id: product_id, price: price))
+      event_store.publish(ProductCatalog::ProductRegistered.new(data: { product_id: product_id }))
+      event_store.publish(ProductCatalog::ProductNamed.new(data: { product_id: product_id, name: name }))
+      event_store.publish(Pricing::PriceSet.new(data: { product_id: product_id, price: price }))
+    end
+
+    def event_store
+      Rails.configuration.event_store
     end
   end
 end

rails_application/test/orders/product_price_changed_test.rb

@@ -8,7 +8,7 @@ def test_reflects_change
       product_id = prepare_product
       unchanged_product_id = prepare_product
 
-      run_command(Pricing::SetPrice.new(product_id: product_id, price: 100))
+      event_store.publish(Pricing::PriceSet.new(data: { product_id: product_id, price: 100 }))
 
       assert_equal 100, Product.find_by_uid(product_id).price
       assert_equal 50, Product.find_by_uid(unchanged_product_id).price
@@ -24,18 +24,17 @@ def event_store
 
     def prepare_product
       product_id = SecureRandom.uuid
-      run_command(
-        ProductCatalog::RegisterProduct.new(
-          product_id: product_id,
-          )
+      event_store.publish(
+        ProductCatalog::ProductRegistered.new(
+          data: { product_id: product_id }
+        )
       )
-      run_command(
-        ProductCatalog::NameProduct.new(
-          product_id: product_id,
-          name: "test"
+      event_store.publish(
+        ProductCatalog::ProductNamed.new(
+          data: { product_id: product_id, name: "test" }
         )
       )
-      run_command(Pricing::SetPrice.new(product_id: product_id, price: 50))
+      event_store.publish(Pricing::PriceSet.new(data: { product_id: product_id, price: 50 }))
 
       product_id
     end