Extract repository

examples/document_way/lib/project_management.rb

@@ -3,3 +3,4 @@
 require_relative "../../../shared/lib/project_management"
 require_relative "project_management/handler"
 require_relative "project_management/issue"
+require_relative "project_management/repository"

examples/document_way/lib/project_management/handler.rb

@@ -35,7 +35,7 @@ def stop(id) = with_aggregate(id) { |issue| issue.stop }
     def stream_name(id) = "Issue$#{id}"
 
     def with_aggregate(id)
-      repository = Issue::Repository.new(id)
+      repository = Repository.new(id)
       issue = Issue.new(repository.load)
 
       @event_store.append(yield(issue), stream_name: stream_name(id))

examples/document_way/lib/project_management/issue.rb

@@ -1,27 +1,5 @@
 module ProjectManagement
   class Issue
-    State = Struct.new(:id, :status)
-
-    class Repository
-      class Record < ActiveRecord::Base
-        self.table_name = :issues
-      end
-      private_constant :Record
-
-      def initialize(id)
-        @id = id
-      end
-
-      def store(state)
-        Record.where(uuid: @id).update_all(status: state.status)
-      end
-
-      def load
-        record = Record.find_or_create_by(uuid: @id)
-        State.new(record.uuid, record.status)
-      end
-    end
-
     InvalidTransition = Class.new(StandardError)
 
     attr_reader :state

examples/document_way/lib/project_management/repository.rb

@@ -0,0 +1,23 @@
+module ProjectManagement
+  class Repository
+    class Record < ActiveRecord::Base
+      self.table_name = :issues
+    end
+    private_constant :Record
+
+    State = Struct.new(:id, :status)
+
+    def initialize(id)
+      @id = id
+    end
+
+    def store(state)
+      Record.where(uuid: @id).update_all(status: state.status)
+    end
+
+    def load
+      record = Record.find_or_create_by(uuid: @id)
+      State.new(record.uuid, record.status)
+    end
+  end
+end