spec/models/concerns/publishable_spec.rb in reactor-0.18.0 vs spec/models/concerns/publishable_spec.rb in reactor-0.19.0

@@ -1,9 +1,9 @@
 require 'spec_helper'
 require 'sidekiq/testing'
 
-class Publisher < ActiveRecord::Base
+class Publisher < ApplicationRecord
   belongs_to :pet
 
   def ring_timeout
     start_at + 30.seconds
   end
@@ -18,25 +18,14 @@
   publishes :conditional_event_on_save, at: :start_at, enqueue_if: -> { we_want_it }
   publishes :conditional_event_on_publish, at: :start_at, if: -> { we_want_it }
   publishes :woof, actor: :pet, target: :self
 end
 
-class TestSubscriber < Reactor::Subscriber
-  @@called = false
-
-  on_fire do
-    @@called = true
-  end
-end
-
 describe Reactor::Publishable do
-  before do
-    TestSubscriber.destroy_all
-    TestSubscriber.class_variable_set(:@@called, false)
-  end
+  before { allow(Reactor::Event).to receive(:perform_at).and_call_original }
 
-  describe 'publish' do
+  describe 'publishes' do
     let(:pet) { Pet.create! }
     let(:publisher) { Publisher.create!(pet: pet, start_at: Time.current + 1.day, we_want_it: false) }
 
     it 'publishes an event with actor_id and actor_type set as self' do
       publisher
@@ -90,11 +79,11 @@
 
     context 'conditional firing at publish time' do
       before do
         Sidekiq::Testing.fake!
         Sidekiq::Worker.clear_all
-        TestSubscriber.create! event_name: :conditional_event_on_publish
+        # TestSubscriber.create! event_name: :conditional_event_on_publish
         publisher
         job = Reactor::Event.jobs.detect do |job|
           job['class'] == 'Reactor::Event' && job['args'].first == 'conditional_event_on_publish'
         end
         @job_args = job['args']
@@ -151,11 +140,10 @@
 
     context 'conditional firing on save' do
       before do
         Sidekiq::Testing.fake!
         Sidekiq::Worker.clear_all
-        TestSubscriber.create! event_name: :conditional_event_on_save
         publisher
         job = Reactor::Event.jobs.detect do |job|
           job['class'] == 'Reactor::Event' && job['args'].first == 'conditional_event_on_save'
         end
         @job_args = job ? job['args'] : []
@@ -201,29 +189,30 @@
       end
     end
 
 
     it 'supports immediate events (on create) that get fired once' do
-      Reactor.with_subscriber_enabled(Reactor::Subscriber) do
-        TestSubscriber.create! event_name: :bell
-        publisher
-        expect(TestSubscriber.class_variable_get(:@@called)).to be_truthy
-        TestSubscriber.class_variable_set(:@@called, false)
-        publisher.start_at = 1.day.from_now
-        publisher.save
-        expect(TestSubscriber.class_variable_get(:@@called)).to be_falsey
-      end
+      expect(Reactor::Event).to receive(:perform_async).
+        with(:woof, hash_including(actor_type: 'Pet'))
+      expect(Reactor::Event).to receive(:perform_async).
+          with(:bell, hash_including(actor_type: 'Publisher'))
+
+      publisher
+
+      # and dont get fired on update
+      publisher.start_at = 1.day.from_now
+      expect(Reactor::Event).to_not receive(:perform_async).with(:bell)
+      expect(Reactor::Event).to_not receive(:perform_async).with(:woof)
+      publisher.save
+
     end
 
     it 'does publish an event scheduled for the future' do
-      Reactor.enable_test_mode_subscriber Reactor::Subscriber
-      Reactor.enable_test_mode_subscriber Publisher
-      TestSubscriber.create! event_name: :begin
-      Publisher.create!(pet: pet, start_at: Time.current + 1.week)
+      future = Time.now.utc + 1.week
 
-      expect(TestSubscriber.class_variable_get(:@@called)).to be_truthy
+      expect(Reactor::Event).to receive(:perform_at).
+          with(future, :begin, hash_including('additional_info' => 'curtis was here'))
 
-      Reactor.disable_test_mode_subscriber Reactor::Subscriber
-      Reactor.disable_test_mode_subscriber Publisher
+      Publisher.create!(pet: pet, start_at: future)
     end
   end
 end