Persist store_id in TimePromotions read model to filter it later.

Author: andrzejkrzywda

rails_application/app/read_models/time_promotions/assign_store_to_time_promotion.rb

@@ -0,0 +1,7 @@
+module TimePromotions
+  class AssignStoreToTimePromotion
+    def call(event)
+      TimePromotion.find(event.data.fetch(:time_promotion_id)).update!(store_id: event.data.fetch(:store_id))
+    end
+  end
+end

rails_application/app/read_models/time_promotions/configuration.rb

@@ -5,9 +5,20 @@ class TimePromotion < ApplicationRecord
     scope :current, -> { where("start_time < ? AND end_time > ?", Time.current, Time.current) }
   end
 
+  private_constant :TimePromotion
+
+  def self.time_promotions_for_store(store_id)
+    TimePromotion.where(store_id: store_id)
+  end
+
+  def self.current_time_promotions_for_store(store_id)
+    TimePromotion.where(store_id: store_id).current
+  end
+
   class Configuration
     def call(event_store)
       event_store.subscribe(CreateTimePromotion, to: [Pricing::TimePromotionCreated])
+      event_store.subscribe(AssignStoreToTimePromotion.new, to: [Stores::TimePromotionRegistered])
     end
   end
 end

rails_application/db/migrate/20251206153816_add_store_id_to_time_promotions.rb

@@ -0,0 +1,5 @@
+class AddStoreIdToTimePromotions < ActiveRecord::Migration[8.0]
+  def change
+    add_column :time_promotions, :store_id, :uuid
+  end
+end

rails_application/db/schema.rb

@@ -10,7 +10,7 @@
 #
 # It's strongly recommended that you check this file into your version control system.
 
-ActiveRecord::Schema[8.0].define(version: 2025_11_01_151254) do
+ActiveRecord::Schema[8.0].define(version: 2025_12_06_153816) do
   # These are extensions that must be enabled in order to support this database
   enable_extension "pg_catalog.plpgsql"
   enable_extension "pgcrypto"
@@ -27,6 +27,15 @@
     t.datetime "updated_at", null: false
   end
 
+  create_table "authorizations", force: :cascade do |t|
+    t.uuid "resource_id"
+    t.uuid "store_id"
+    t.datetime "created_at", null: false
+    t.datetime "updated_at", null: false
+    t.index ["resource_id", "store_id"], name: "index_authorizations_on_resource_id_and_store_id"
+    t.index ["store_id"], name: "index_authorizations_on_store_id"
+  end
+
   create_table "availability_products", force: :cascade do |t|
     t.uuid "uid"
     t.integer "available"
@@ -263,6 +272,7 @@
     t.datetime "created_at", null: false
     t.datetime "updated_at", null: false
     t.boolean "active", default: false
+    t.uuid "store_id"
   end
 
   add_foreign_key "event_store_events_in_streams", "event_store_events", column: "event_id", primary_key: "event_id"

rails_application/test/time_promotions/assign_store_to_time_promotion_test.rb

@@ -0,0 +1,67 @@
+require "test_helper"
+
+module TimePromotions
+  class AssignStoreToTimePromotionTest < InMemoryTestCase
+    cover "TimePromotions*"
+
+    def test_store_id_is_set_when_time_promotion_registered_in_store
+      event_store.publish(time_promotion_created)
+      event_store.publish(time_promotion_registered_in_store)
+
+      assert_equal(store_id, TimePromotion.find(time_promotion_id).store_id)
+    end
+
+    def test_store_id_is_nil_when_time_promotion_not_registered_in_store
+      event_store.publish(time_promotion_created)
+
+      assert_nil(TimePromotion.find(time_promotion_id).store_id)
+    end
+
+    def test_store_id_is_updated_when_time_promotion_registered_in_different_store
+      store_2_id = SecureRandom.uuid
+
+      event_store.publish(time_promotion_created)
+      event_store.publish(time_promotion_registered_in_store)
+
+      assert_equal(store_id, TimePromotion.find(time_promotion_id).store_id)
+
+      event_store.publish(time_promotion_registered_in_different_store(store_2_id))
+
+      assert_equal(store_2_id, TimePromotion.find(time_promotion_id).store_id)
+    end
+
+    private
+
+    def event_store
+      Rails.configuration.event_store
+    end
+
+    def time_promotion_id
+      @time_promotion_id ||= SecureRandom.uuid
+    end
+
+    def store_id
+      @store_id ||= SecureRandom.uuid
+    end
+
+    def time_promotion_created
+      Pricing::TimePromotionCreated.new(
+        data: {
+          time_promotion_id: time_promotion_id,
+          discount: 10,
+          start_time: Time.current - 1.hour,
+          end_time: Time.current + 1.hour,
+          label: "Test Promotion"
+        }
+      )
+    end
+
+    def time_promotion_registered_in_store
+      Stores::TimePromotionRegistered.new(data: { time_promotion_id: time_promotion_id, store_id: store_id })
+    end
+
+    def time_promotion_registered_in_different_store(different_store_id)
+      Stores::TimePromotionRegistered.new(data: { time_promotion_id: time_promotion_id, store_id: different_store_id })
+    end
+  end
+end