hallgren · August 29, 2015 14:13 · Jan 13, 2015 · Jan 12, 2015 · Jan 12, 2015 · Jan 12, 2015
diff --git a/proposal.rb b/proposal.rb
@@ -1,11 +1,12 @@
 # = Example Sandthorn setup
 
 Sandthorn.config do |sand|
-  sand.snapshot_store = SnapshotStore.new
+  snapshot_store = SnapshotStore.new
   sand.event_stores = {
-    default:      SequelStore.new(url: "sqlite://my_db", snapshot_store: sand.snapshot_store)
-    alternative:  MongoStore.new(url: "some_url", snapshot_store: sand.snapshot_store)
-    aux:          InMemoryStore.new
+    default:       EventStore.new(event_driver: SequelDriver.new(url: "sqlite://my_db"), snapshot_driver: snapshot_store)
+    mongo:         EventStore.new(event_driver: MongoDBDriver.new(), snapshot_driver: snapshot_store)
+    alternative:   ObjectStore.new(object_driver: InMemoryDriver.new)
+    aux:           InMemoryStore.new
   }
   # This maps aggregates to event stores.
   # Aggregates that aren't exlicitly mapped will be stored in the default store.
@@ -19,7 +20,7 @@
 # Example aggregate
 
 class MyAggregate
-  include AggregateRoot
+  include EventStore::AggregateRoot
 
   attr_reader :name
 
@@ -49,7 +50,7 @@ def name_changed
 
 # Here's an incomplete implementation of AggregateRoot
 
-module Sandthorn
+module EventStore
   module AggregateRoot
 
     attr_reader :unsaved_events

diff --git a/proposal.rb b/proposal.rb
@@ -54,7 +54,11 @@ module AggregateRoot
 
     attr_reader :unsaved_events
 
-    class << self
+    def self.included(base)
+      base.extend(ClassMethods)
+    end
+
+    module ClassMethods
       def event_store
         Sandthorn.event_store_for(self)
       end

diff --git a/proposal.rb b/proposal.rb
@@ -45,7 +45,7 @@ def name_changed
 # Saving means finding the appropriate event store for the aggregate type, and then calling `save_events` on the event store with any unsaved events.
 # Example:
 #   1. my_aggregate.save calls Sandthorn.event_store_for(my_aggregate) and gets an event_store
-#   2. Call event_store.save_events(my_aggregate, )
+#   2. Call event_store.save_events(my_aggregate, my_aggregate.unsaved_events)
 
 # Here's an incomplete implementation of AggregateRoot
 

diff --git a/proposal.rb b/proposal.rb
@@ -0,0 +1,80 @@
+# = Example Sandthorn setup
+
+Sandthorn.config do |sand|
+  sand.snapshot_store = SnapshotStore.new
+  sand.event_stores = {
+    default:      SequelStore.new(url: "sqlite://my_db", snapshot_store: sand.snapshot_store)
+    alternative:  MongoStore.new(url: "some_url", snapshot_store: sand.snapshot_store)
+    aux:          InMemoryStore.new
+  }
+  # This maps aggregates to event stores.
+  # Aggregates that aren't exlicitly mapped will be stored in the default store.
+  # I see the need to be able to define either concrete classes or patterns.
+  sand.aggregate_mappings = {
+    alternative: [StoreAggregates::Foo, StoreAggregates::Bar]
+    aux: /LogAggregates/
+  }
+end
+
+# Example aggregate
+
+class MyAggregate
+  include AggregateRoot
+
+  attr_reader :name
+
+  def initialize(name: nil)
+    @name = name
+  end
+
+  def change_name(name)
+    @name = name
+    name_changed
+  end
+
+  def name_changed
+    commit
+  end
+end
+
+# = Committing
+# When commit is called, we just construct the appropriate event and save it in the aggregate.
+# The events should be in the agreed-upon event format.
+
+# = Saving an aggregate
+# Saving means finding the appropriate event store for the aggregate type, and then calling `save_events` on the event store with any unsaved events.
+# Example:
+#   1. my_aggregate.save calls Sandthorn.event_store_for(my_aggregate) and gets an event_store
+#   2. Call event_store.save_events(my_aggregate, )
+
+# Here's an incomplete implementation of AggregateRoot
+
+module Sandthorn
+  module AggregateRoot
+
+    attr_reader :unsaved_events
+
+    class << self
+      def event_store
+        Sandthorn.event_store_for(self)
+      end
+    end
+
+    def save
+      if unsaved_events.any?
+        save_events(unsaved_events)
+      end
+    end
+
+    private
+
+    def save_events(events)
+      event_store.save_events(self, events)
+    end
+
+    def event_store
+      self.class.event_store
+    end
+
+  end
+end
No results found