Coupons are now per store

Enabled the Coupons read model for mutant.

Author: andrzejkrzywda

ecommerce/stores/lib/stores.rb

@@ -8,6 +8,7 @@
 require_relative "stores/customer_registration"
 require_relative "stores/offer_registration"
 require_relative "stores/time_promotion_registration"
+require_relative "stores/coupon_registration"
 
 module Stores
 
@@ -19,6 +20,7 @@ def call(event_store, command_bus)
       command_bus.register(RegisterCustomer, CustomerRegistration.new(event_store))
       command_bus.register(RegisterOffer, OfferRegistration.new(event_store))
       command_bus.register(RegisterTimePromotion, TimePromotionRegistration.new(event_store))
+      command_bus.register(RegisterCoupon, CouponRegistration.new(event_store))
     end
   end
 end

ecommerce/stores/lib/stores/commands.rb

@@ -27,4 +27,9 @@ class RegisterTimePromotion < Infra::Command
     attribute :store_id, Infra::Types::UUID
     attribute :time_promotion_id, Infra::Types::UUID
   end
+
+  class RegisterCoupon < Infra::Command
+    attribute :store_id, Infra::Types::UUID
+    attribute :coupon_id, Infra::Types::UUID
+  end
 end

ecommerce/stores/lib/stores/coupon_registration.rb

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

ecommerce/stores/lib/stores/events.rb

@@ -29,4 +29,9 @@ class TimePromotionRegistered < Infra::Event
     attribute :time_promotion_id, Infra::Types::UUID
   end
 
+  class CouponRegistered < Infra::Event
+    attribute :store_id, Infra::Types::UUID
+    attribute :coupon_id, Infra::Types::UUID
+  end
+
 end

ecommerce/stores/test/coupon_registration_test.rb

@@ -0,0 +1,27 @@
+require_relative 'test_helper'
+module Stores
+  class CouponRegistrationTest < Test
+    cover "Stores*"
+
+    def test_coupon_should_get_registered
+      store_id = SecureRandom.uuid
+      coupon_id = SecureRandom.uuid
+      assert register_coupon(store_id, coupon_id)
+    end
+
+    def test_should_publish_event
+      store_id = SecureRandom.uuid
+      coupon_id = SecureRandom.uuid
+      coupon_registered = Stores::CouponRegistered.new(data: { store_id: store_id, coupon_id: coupon_id })
+      assert_events("Stores::Store$#{store_id}", coupon_registered) do
+        register_coupon(store_id, coupon_id)
+      end
+    end
+
+    private
+
+    def register_coupon(store_id, coupon_id)
+      run_command(RegisterCoupon.new(store_id: store_id, coupon_id: coupon_id))
+    end
+  end
+end

rails_application/.mutant.yml

@@ -15,10 +15,12 @@ requires:
   - ./config/environment
 matcher:
   subjects:
+    - Coupons*
     - Orders*
     - ClientOrders*
     - Processes*
   ignore:
+    - Coupons::Configuration#call
     - Orders::Configuration#call
     - Orders::Broadcaster*
     - Orders::AddItemToOrder#broadcast_to_ui

rails_application/app/controllers/client/orders_controller.rb

@@ -62,7 +62,7 @@ def remove_item
     end
 
     def use_coupon
-      coupon = Coupons::Coupon.find_by!("lower(code) = ?", params[:coupon_code].downcase)
+      coupon = Coupons.find_by_code_for_store(params[:coupon_code], current_store_id)
       ActiveRecord::Base.transaction do
         command_bus.(use_coupon_cmd(params[:id], coupon.uid, coupon.discount))
       end

rails_application/app/controllers/coupons_controller.rb

@@ -1,14 +1,18 @@
 class CouponsController < ApplicationController
   def index
-    @coupons = Coupons::Coupon.all
+    @coupons = Coupons.coupons_for_store(current_store_id)
   end
 
   def new
     @coupon_id = SecureRandom.uuid
   end
 
   def create
-    create_coupon(params[:coupon_id], params[:name], params[:code], params[:discount])
+    coupon_id = params[:coupon_id]
+
+    ActiveRecord::Base.transaction do
+      create_coupon(coupon_id)
+    end
   rescue Pricing::Coupon::AlreadyRegistered
     flash[:notice] = "Coupon is already registered"
     render "new"
@@ -18,12 +22,21 @@ def create
 
   private
 
-  def create_coupon(coupon_id, name, code, discount)
-    command_bus.(create_coupon_cmd(coupon_id, name, code, discount))
-  end
-
-  def create_coupon_cmd(coupon_id, name, code, discount)
-    Pricing::RegisterCoupon.new(coupon_id: coupon_id, name: name, code: code, discount: discount)
+  def create_coupon(coupon_id)
+    command_bus.(
+      Pricing::RegisterCoupon.new(
+        coupon_id: coupon_id,
+        name: params[:name],
+        code: params[:code],
+        discount: params[:discount]
+      )
+    )
+    command_bus.(
+      Stores::RegisterCoupon.new(
+        coupon_id: coupon_id,
+        store_id: current_store_id
+      )
+    )
   end
 
 end

rails_application/app/read_models/coupons/assign_store_to_coupon.rb

@@ -0,0 +1,7 @@
+module Coupons
+  class AssignStoreToCoupon
+    def call(event)
+      Coupon.find_by!(uid: event.data.fetch(:coupon_id)).update!(store_id: event.data.fetch(:store_id))
+    end
+  end
+end

rails_application/app/read_models/coupons/configuration.rb

@@ -3,9 +3,20 @@ class Coupon < ApplicationRecord
     self.table_name = "coupons"
   end
 
+  private_constant :Coupon
+
+  def self.coupons_for_store(store_id)
+    Coupon.where(store_id: store_id)
+  end
+
+  def self.find_by_code_for_store(code, store_id)
+    Coupon.find_by!("lower(code) = ? AND store_id = ?", code.downcase, store_id)
+  end
+
   class Configuration
     def call(event_store)
       event_store.subscribe(RegisterCoupon.new, to: [Pricing::CouponRegistered])
+      event_store.subscribe(AssignStoreToCoupon.new, to: [Stores::CouponRegistered])
     end
   end
 end