* new projections will now be populated at the start of the projectio…

…nserver and not with the first incoming event

RAILS-DISCO_VERSION

@@ -1 +1 @@
-0.4.1
+0.4.2

active_domain/lib/active_domain/version.rb

@@ -1,7 +1,7 @@
 module ActiveDomain
   # Returns the version of the currently loaded ActiveDomain as a Gem::Version
   def self.version
-    Gem::Version.new '0.4.1'
+    Gem::Version.new '0.4.2'
   end
 
   module VERSION #:nodoc:

active_event/lib/active_event/version.rb

@@ -1,7 +1,7 @@
 module ActiveEvent
   # Returns the version of the currently loaded ActiveEvent as a Gem::Version
   def self.version
-    Gem::Version.new '0.4.1'
+    Gem::Version.new '0.4.2'
   end
 
   module VERSION #:nodoc:

active_projection/lib/active_projection/event_client.rb

@@ -11,13 +11,18 @@ def self.start(options)
 
     def start
       event_connection.start
+      sync_projections
       listen_for_events
       request_missing_events
       event_channel.work_pool.join
     rescue Interrupt
       puts 'Catching Interrupt'
     end
 
+    def sync_projections
+      ProjectionTypeRegistry.sync_projections
+    end
+
     def listen_for_events
       subscribe_to event_queue do |delivery_info, properties, body|
         event_received properties, body

active_projection/lib/active_projection/projection_type_registry.rb

@@ -20,6 +20,16 @@ def process(headers, event)
       end
     end
 
+    def self.sync_projections
+      instance.sync_projections
+    end
+
+    def sync_projections
+      projections.each do |projection|
+        ProjectionRepository.create_or_get(projection.class.name)
+      end
+    end
+
     private
 
     cattr_accessor :registry

active_projection/lib/active_projection/version.rb

@@ -1,7 +1,7 @@
 module ActiveProjection
   # Returns the version of the currently loaded ActiveProjection as a Gem::Version
   def self.version
-    Gem::Version.new '0.4.1'
+    Gem::Version.new '0.4.2'
   end
 
   module VERSION #:nodoc:

active_projection/spec/lib/projection_type_registry_spec.rb

@@ -20,4 +20,9 @@ class TestProjection
     expect_any_instance_of(TestProjection).to receive(:invoke).with(event, headers)
     ActiveProjection::ProjectionTypeRegistry.process(headers, event)
   end
+
+  it 'synchronizes the known projections with the db' do
+    expect(ActiveProjection::ProjectionRepository).to receive(:create_or_get).with('TestProjection')
+    ActiveProjection::ProjectionTypeRegistry.sync_projections
+  end
 end

drailties/lib/rails-disco/version.rb

@@ -2,7 +2,7 @@ module RailsDisco
   module VERSION
     MAJOR = 0
     MINOR = 4
-    TINY  = 1
+    TINY  = 2
     PRE   = nil
 
     STRING = [MAJOR, MINOR, TINY, PRE].compact.join(".")

version.rb

@@ -2,7 +2,7 @@ module RailsDisco
   module VERSION
     MAJOR = 0
     MINOR = 4
-    TINY  = 1
+    TINY  = 2
     PRE   = nil
 
     STRING = [MAJOR, MINOR, TINY, PRE].compact.join(".")