Extract repository

RailsEventStore · Nov 27, 2023 · 8983aed · 8983aed
1 parent 951989c
commit 8983aed
Show file tree

Hide file tree

Showing 3 changed files with 42 additions and 25 deletions.
diff --git a/examples/duck_typing/lib/project_management.rb b/examples/duck_typing/lib/project_management.rb
@@ -3,4 +3,5 @@
 require_relative "../../../shared/lib/project_management"
 require_relative "project_management/handler"
 require_relative "project_management/issue"
+require_relative "project_management/repository"
 require_relative "project_management/ui"
diff --git a/examples/duck_typing/lib/project_management/handler.rb b/examples/duck_typing/lib/project_management/handler.rb
@@ -1,7 +1,7 @@
 module ProjectManagement
   class Handler
     def initialize(event_store)
-      @event_store = event_store
+      @repository = Repository.new(event_store)
     end
 
     def call(cmd)
@@ -67,31 +67,10 @@ def resolve(id)
 
     private
 
-    def stream_name(id) = "Issue$#{id}"
-
     def load_issue(id)
-      issue =
-        @event_store
-          .read
-          .stream(stream_name(id))
-          .reduce(Issue.new) do |issue, event|
-            case event
-            when IssueOpened
-              issue.open
-            when IssueProgressStarted
-              issue.start
-            when IssueProgressStopped
-              issue.stop
-            when IssueResolved
-              issue.resolve
-            when IssueReopened
-              issue.reopen
-            when IssueClosed
-              issue.close
-            end
-          end
-
-      @event_store.append(yield(issue), stream_name: stream_name(id))
+      issue = @repository.load(id, Issue.new)
+      events = yield(issue)
+      @repository.store(id, events)
     end
   end
 end
diff --git a/examples/duck_typing/lib/project_management/repository.rb b/examples/duck_typing/lib/project_management/repository.rb
@@ -0,0 +1,37 @@
+module ProjectManagement
+  class Repository
+    def initialize(event_store)
+      @event_store = event_store
+    end
+
+    def load(id, initial_issue)
+      @event_store
+        .read
+        .stream(stream_name(id))
+        .reduce(initial_issue) do |issue, event|
+          case event
+          when IssueOpened
+            issue.open
+          when IssueProgressStarted
+            issue.start
+          when IssueProgressStopped
+            issue.stop
+          when IssueResolved
+            issue.resolve
+          when IssueReopened
+            issue.reopen
+          when IssueClosed
+            issue.close
+          end
+        end
+    end
+
+    def store(id, events)
+      @event_store.append(events, stream_name: stream_name(id))
+    end
+
+    private
+
+    def stream_name(id) = "Issue$#{id}"
+  end
+end