lib/aggro/subscription.rb in aggro-0.0.3 vs lib/aggro/subscription.rb in aggro-0.0.4

@@ -1,8 +1,10 @@
 module Aggro
   # Private: Handles invoking events on a subscriber object.
   class Subscription
+    attr_reader :caught_up
+
     def initialize(topic, subscriber, namespace, filters, at_version)
       @topic = topic
       @subscriber = subscriber
       @namespace = namespace
       @filters = filters
@@ -19,18 +21,30 @@
       return if @canceled
 
       invoke(event) if handles_event?(event) && matches_filter?(event)
     end
 
+    def notify_subscription_caught_up
+      @caught_up = true
+
+      return unless @subscriber.handles_event? :caught_up, @namespace
+
+      @subscriber.send "#{@namespace}_caught_up"
+    end
+
     private
 
+    def expand_event(event)
+      event.details.merge now: event.occured_at, today: event.occured_at.to_date
+    end
+
     def handles_event?(event)
       @subscriber.handles_event? event.name, @namespace
     end
 
     def invoke(event)
-      Invokr.invoke method: "#{@namespace}_#{event.name}",
-                    using: event.details, on: @subscriber
+      Invokr.invoke method: "#{@namespace}_#{event.name}", on: @subscriber,
+                    using: expand_event(event)
     end
 
     def matches_filter?(event)
       @filters.all? do |filter_key, filter_value|
         event.details[filter_key] == filter_value