Vat rates are now scoped per store

Author: andrzejkrzywda

ecommerce/stores/lib/stores.rb

@@ -11,6 +11,7 @@
 require_relative "stores/coupon_registration"
 require_relative "stores/invoice_registration"
 require_relative "stores/shipment_registration"
+require_relative "stores/vat_rate_registration"
 
 module Stores
 
@@ -25,6 +26,7 @@ def call(event_store, command_bus)
       command_bus.register(RegisterCoupon, CouponRegistration.new(event_store))
       command_bus.register(RegisterInvoice, InvoiceRegistration.new(event_store))
       command_bus.register(RegisterShipment, ShipmentRegistration.new(event_store))
+      command_bus.register(RegisterVatRate, VatRateRegistration.new(event_store))
     end
   end
 end

ecommerce/stores/lib/stores/commands.rb

@@ -42,4 +42,9 @@ class RegisterShipment < Infra::Command
     attribute :store_id, Infra::Types::UUID
     attribute :shipment_id, Infra::Types::UUID
   end
+
+  class RegisterVatRate < Infra::Command
+    attribute :store_id, Infra::Types::UUID
+    attribute :vat_rate_id, Infra::Types::UUID
+  end
 end

ecommerce/stores/lib/stores/events.rb

@@ -44,4 +44,9 @@ class ShipmentRegistered < Infra::Event
     attribute :shipment_id, Infra::Types::UUID
   end
 
+  class VatRateRegistered < Infra::Event
+    attribute :store_id, Infra::Types::UUID
+    attribute :vat_rate_id, Infra::Types::UUID
+  end
+
 end

ecommerce/stores/lib/stores/vat_rate_registration.rb

@@ -0,0 +1,26 @@
+module Stores
+  class VatRateRegistration
+    def initialize(event_store)
+      @event_store = event_store
+    end
+
+    def call(cmd)
+      @event_store.publish(vat_rate_registered_event(cmd), stream_name: stream_name(cmd))
+    end
+
+    private
+
+    def vat_rate_registered_event(cmd)
+      VatRateRegistered.new(
+        data: {
+          store_id: cmd.store_id,
+          vat_rate_id: cmd.vat_rate_id,
+        }
+      )
+    end
+
+    def stream_name(cmd)
+      "Stores::Store$#{cmd.store_id}"
+    end
+  end
+end

ecommerce/stores/test/vat_rate_registration_test.rb

@@ -0,0 +1,27 @@
+require_relative 'test_helper'
+module Stores
+  class VatRateRegistrationTest < Test
+    cover "Stores*"
+
+    def test_vat_rate_should_get_registered
+      store_id = SecureRandom.uuid
+      vat_rate_id = SecureRandom.uuid
+      assert register_vat_rate(store_id, vat_rate_id)
+    end
+
+    def test_should_publish_event
+      store_id = SecureRandom.uuid
+      vat_rate_id = SecureRandom.uuid
+      vat_rate_registered = Stores::VatRateRegistered.new(data: { store_id: store_id, vat_rate_id: vat_rate_id })
+      assert_events("Stores::Store$#{store_id}", vat_rate_registered) do
+        register_vat_rate(store_id, vat_rate_id)
+      end
+    end
+
+    private
+
+    def register_vat_rate(store_id, vat_rate_id)
+      run_command(RegisterVatRate.new(store_id: store_id, vat_rate_id: vat_rate_id))
+    end
+  end
+end

ecommerce/taxes/lib/taxes.rb

@@ -9,7 +9,7 @@ module Taxes
   class Configuration
     def call(event_store, command_bus)
       command_bus.register(SetVatRate, SetVatRateHandler.new(event_store))
-      command_bus.register(AddAvailableVatRate, AddAvailableVatRateHandler.new(event_store))
+      command_bus.register(AddAvailableVatRate, AddAvailableVatRateHandler.new(event_store, command_bus))
       command_bus.register(RemoveAvailableVatRate, RemoveAvailableVatRateHandler.new(event_store))
     end
   end

ecommerce/taxes/lib/taxes/commands.rb

@@ -7,6 +7,7 @@ class SetVatRate < Infra::Command
   class AddAvailableVatRate < Infra::Command
     attribute :available_vat_rate_id, Infra::Types::UUID
     attribute :vat_rate, Infra::Types::VatRate
+    attribute :store_id, Infra::Types::UUID
   end
 
   class RemoveAvailableVatRate < Infra::Command

ecommerce/taxes/lib/taxes/services.rb

@@ -20,8 +20,9 @@ def call(cmd)
   class AddAvailableVatRateHandler
     include Infra::Retry
 
-    def initialize(event_store)
+    def initialize(event_store, command_bus)
       @event_store = event_store
+      @command_bus = command_bus
     end
 
     def call(cmd)
@@ -31,12 +32,13 @@ def call(cmd)
 
         expected_version = event ? event_store.position_in_stream(event.event_id, stream_name(cmd)) : -1
         event_store.publish(available_vat_rate_added_event(cmd), stream_name: stream_name(cmd), expected_version: expected_version)
+        command_bus.call(Stores::RegisterVatRate.new(store_id: cmd.store_id, vat_rate_id: cmd.available_vat_rate_id))
       end
     end
 
     private
 
-    attr_reader :event_store
+    attr_reader :event_store, :command_bus
 
     def last_available_vat_rate_event(vat_rate_code)
       event_store

rails_application/.mutant.yml

@@ -21,6 +21,7 @@ matcher:
     - Processes*
     - Invoices*
     - Shipments*
+    - VatRates*
   ignore:
     - Coupons::Configuration#call
     - Orders::Configuration#call

rails_application/app/controllers/available_vat_rates_controller.rb

@@ -53,7 +53,8 @@ def add_available_vat_rate(code, rate, available_vat_rate_id)
   def add_available_vat_rate_cmd(code, rate, available_vat_rate_id)
     Taxes::AddAvailableVatRate.new(
       available_vat_rate_id: available_vat_rate_id,
-      vat_rate: Infra::Types::VatRate.new(code: code, rate: rate)
+      vat_rate: Infra::Types::VatRate.new(code: code, rate: rate),
+      store_id: current_store_id
     )
   end