Client panel: Inbox without hardcoded messages

- temporarily call read model directly from the process
- it's antipattern, but step towards proper process, while being green and without making too many changes at once
- so far disabled mutant, driven by integration test

Author: andrzejkrzywda

ecommerce/processes/.mutant.yml

@@ -16,4 +16,5 @@ matcher:
     - Processes::OrderItemInvoicingProcess#fetch_id
     - Processes::SyncShipmentFromPricing*
     - Processes::SyncInventoryFromOrdering*
-    - Processes::NotifyPaymentsAboutOrderValue*
+    - Processes::NotifyPaymentsAboutOrderValue*
+    - Processes::WelcomeMessageProcess*

ecommerce/processes/lib/processes.rb

@@ -17,6 +17,7 @@
 require_relative 'processes/sync_shipment_from_pricing'
 require_relative 'processes/three_plus_one_free'
 require_relative 'processes/reservation_process'
+require_relative 'processes/welcome_message_process'
 
 module Processes
   class Configuration
@@ -39,6 +40,7 @@ def call(event_store, command_bus)
       enable_shipment_process(event_store, command_bus)
       enable_order_item_invoicing_process(event_store, command_bus)
       enable_reservation_process(event_store, command_bus)
+      enable_welcome_message_process(event_store, command_bus)
     end
 
     private
@@ -137,5 +139,12 @@ def enable_coupon_discount_process(event_store, command_bus)
                     .call(Pricing::CouponUsed, [:order_id, :discount],
                           Pricing::SetPercentageDiscount, [:order_id, :amount])
     end
+
+    def enable_welcome_message_process(event_store, command_bus)
+      event_store.subscribe(
+        WelcomeMessageProcess.new(event_store, command_bus),
+        to: [Crm::CustomerRegistered]
+      )
+    end
   end
 end

ecommerce/processes/lib/processes/welcome_message_process.rb

@@ -0,0 +1,15 @@
+module Processes
+  class WelcomeMessageProcess
+    def initialize(event_store, command_bus)
+      @event_store = event_store
+      @command_bus = command_bus
+    end
+
+    def call(event)
+      case event
+      when Crm::CustomerRegistered
+        ClientInbox::Message.create(client_uid: event.data.fetch(:customer_id), title: "Welcome to our platform!")
+      end
+    end
+  end
+end

rails_application/app/read_models/client_inbox/rendering/inbox_list.rb

@@ -6,16 +6,7 @@ class InboxList < Arbre::Component
       include Rails.application.routes.url_helpers
 
       def self.build(view_context, client_id)
-        messages = inbox_messages(client_id)
-        if messages.empty?
-          messages << OpenStruct.new(
-            id: SecureRandom.uuid,
-            title: "Welcome to our platform!",
-            created_at: 2.days.ago,
-            read: false
-          )
-        end
-        new(Arbre::Context.new(nil, view_context)).build(messages)
+        new(Arbre::Context.new(nil, view_context)).build(inbox_messages(client_id))
       end
 
       def build(messages, attributes = {})

rails_application/test/integration/client_inbox_test.rb

@@ -9,7 +9,7 @@ def test_customer_sees_inbox_messages
     assert_response :success
     assert_select "h1", "Your Inbox"
 
-    assert_message("Welcome to our platform!", /\d+ days? ago/)
+    assert_message("Welcome to our platform!", /minute ago/)
   end
 
   private