Introduce product and order archivization.

- producs and orders can be archived wich make them disappear from the UI.

Author: dysk

ecommerce/fulfillment/lib/fulfillment.rb

@@ -2,12 +2,15 @@
 require_relative "fulfillment/events/order_registered"
 require_relative "fulfillment/events/order_confirmed"
 require_relative "fulfillment/events/order_cancelled"
+require_relative "fulfillment/events/order_archived"
 require_relative "fulfillment/commands/register_order"
 require_relative "fulfillment/commands/confirm_order"
 require_relative "fulfillment/commands/cancel_order"
+require_relative "fulfillment/commands/archive_order"
 require_relative "fulfillment/on_register_order"
 require_relative "fulfillment/on_cancel_order"
 require_relative "fulfillment/on_confirm_order"
+require_relative "fulfillment/on_archive_order"
 require_relative "fulfillment/order"
 require_relative "fulfillment/number_generator"
 require_relative "fulfillment/fake_number_generator"
@@ -22,6 +25,7 @@ def call(event_store, command_bus)
       command_bus.register(RegisterOrder, OnRegisterOrder.new(event_store, @number_generator.call))
       command_bus.register(ConfirmOrder, OnConfirmOrder.new(event_store))
       command_bus.register(CancelOrder, OnCancelOrder.new(event_store))
+      command_bus.register(ArchiveOrder, OnArchiveOrder.new(event_store))
     end
   end
 end

ecommerce/fulfillment/lib/fulfillment/commands/archive_order.rb

@@ -0,0 +1,9 @@
+# frozen_string_literal: true
+
+module Fulfillment
+  class ArchiveOrder < Infra::Command
+    attribute :order_id, Infra::Types::UUID
+
+    alias aggregate_id order_id
+  end
+end

ecommerce/fulfillment/lib/fulfillment/events/order_archived.rb

@@ -0,0 +1,7 @@
+# frozen_string_literal: true
+
+module Fulfillment
+  class OrderArchived < Infra::Event
+    attribute :order_id, Infra::Types::UUID
+  end
+end

ecommerce/fulfillment/lib/fulfillment/on_archive_order.rb

@@ -0,0 +1,15 @@
+# frozen_string_literal: true
+
+module Fulfillment
+  class OnArchiveOrder
+    def initialize(event_store)
+      @repository = Infra::AggregateRootRepository.new(event_store)
+    end
+
+    def call(command)
+      @repository.with_aggregate(Order, command.aggregate_id) do |order|
+        order.archive
+      end
+    end
+  end
+end

ecommerce/fulfillment/lib/fulfillment/order.rb

@@ -25,6 +25,10 @@ def cancel
       apply OrderCancelled.new(data: { order_id: @id })
     end
 
+    def archive
+      apply OrderArchived.new(data: { order_id: @id })
+    end
+
     on OrderRegistered do |event|
       @state = :new
     end
@@ -36,5 +40,9 @@ def cancel
     on OrderCancelled do |event|
       @state = :cancelled
     end
+
+    on OrderArchived do |event|
+      @state = :archived
+    end
   end
 end

ecommerce/fulfillment/test/archive_order_test.rb

@@ -0,0 +1,46 @@
+require_relative "test_helper"
+
+module Fulfillment
+  class ArchiveOrderTest < Test
+    cover "Fulfillment::OnArchiveOrder*"
+
+    def test_order_can_be_archived
+      aggregate_id = SecureRandom.uuid
+      stream = "Fulfillment::Order$#{aggregate_id}"
+
+      arrange(
+        RegisterOrder.new(order_id: aggregate_id)
+      )
+
+      assert_events(
+        stream,
+        OrderArchived.new(data: { order_id: aggregate_id })
+      ) { act(ArchiveOrder.new(order_id: aggregate_id)) }
+    end
+
+    def test_not_registered_order_can_be_archived
+      aggregate_id = SecureRandom.uuid
+      stream = "Fulfillment::Order$#{aggregate_id}"
+
+      assert_events(
+        stream,
+        OrderArchived.new(data: { order_id: aggregate_id })
+      ) { act(ArchiveOrder.new(order_id: aggregate_id)) }
+    end
+
+    def test_confirmed_order_can_be_archived
+      aggregate_id = SecureRandom.uuid
+      stream = "Fulfillment::Order$#{aggregate_id}"
+
+      arrange(
+        RegisterOrder.new(order_id: aggregate_id),
+        ConfirmOrder.new(order_id: aggregate_id)
+      )
+
+      assert_events(
+        stream,
+        OrderArchived.new(data: { order_id: aggregate_id })
+      ) { act(ArchiveOrder.new(order_id: aggregate_id)) }
+    end
+  end
+end

ecommerce/product_catalog/lib/product_catalog.rb

@@ -3,13 +3,15 @@
 require_relative "product_catalog/events"
 require_relative "product_catalog/registration"
 require_relative "product_catalog/naming"
+require_relative "product_catalog/archivization"
 
 module ProductCatalog
 
   class Configuration
     def call(event_store, command_bus)
       command_bus.register(RegisterProduct, Registration.new(event_store))
       command_bus.register(NameProduct, Naming.new(event_store))
+      command_bus.register(ArchiveProduct, Archivization.new(event_store))
     end
   end
 end

ecommerce/product_catalog/lib/product_catalog/archivization.rb

@@ -0,0 +1,16 @@
+module ProductCatalog
+  class Archivization
+    def initialize(event_store)
+      @event_store = event_store
+    end
+
+    def call(command)
+      @event_store.publish(
+        ProductArchived.new(
+          data: { product_id: command.product_id }
+        ),
+        stream_name: "ProductCatalog$#{command.product_id}"
+      )
+    end
+  end
+end

ecommerce/product_catalog/lib/product_catalog/commands.rb

@@ -7,4 +7,8 @@ class NameProduct < Infra::Command
     attribute :product_id, Infra::Types::UUID
     attribute :name, Infra::Types::String
   end
+
+  class ArchiveProduct < Infra::Command
+    attribute :product_id, Infra::Types::UUID
+  end
 end

ecommerce/product_catalog/lib/product_catalog/events.rb

@@ -8,4 +8,8 @@ class ProductNamed < Infra::Event
     attribute :product_id, Infra::Types::String
   end
 
+  class ProductArchived < Infra::Event
+    attribute :product_id, Infra::Types::UUID
+  end
+
 end