File tree Expand file tree Collapse file tree 7 files changed +29
-4
lines changed
Expand file tree Collapse file tree 7 files changed +29
-4
lines changed Original file line number Diff line number Diff line change 11PATH
22 remote: .
33 specs:
4- journaled (6.2.3 )
4+ journaled (6.2.4 )
55 activejob
66 activerecord
77 activesupport
Original file line number Diff line number Diff line change 11PATH
22 remote: ..
33 specs:
4- journaled (6.2.3 )
4+ journaled (6.2.4 )
55 activejob
66 activerecord
77 activesupport
Original file line number Diff line number Diff line change 11PATH
22 remote: ..
33 specs:
4- journaled (6.2.3 )
4+ journaled (6.2.4 )
55 activejob
66 activerecord
77 activesupport
Original file line number Diff line number Diff line change @@ -21,6 +21,8 @@ class TableNotFoundError < StandardError; end
2121 # @param ** [Hash] Additional options (ignored, for interface compatibility)
2222 # @return [void]
2323 def self . deliver ( events :, **)
24+ return unless Journaled . enabled?
25+
2426 check_table_exists!
2527
2628 records = events . map do |event |
Original file line number Diff line number Diff line change 11# frozen_string_literal: true
22
33module Journaled
4- VERSION = "6.2.3 "
4+ VERSION = "6.2.4 "
55end
Original file line number Diff line number Diff line change 8181 end
8282
8383 describe '.deliver' do
84+ context 'when Journaled is disabled' do
85+ before do
86+ allow ( Journaled ) . to receive ( :enabled? ) . and_return ( false )
87+ end
88+
89+ it 'does not persist any events' do
90+ expect {
91+ described_class . deliver ( events :, enqueue_opts :)
92+ } . not_to change { Journaled ::Outbox ::Event . count }
93+ end
94+
95+ it 'does not check for table existence' do
96+ expect ( described_class ) . not_to receive ( :check_table_exists! )
97+ described_class . deliver ( events :, enqueue_opts :)
98+ end
99+ end
100+
84101 context 'when tables exist' do
102+ before do
103+ allow ( Journaled ) . to receive ( :enabled? ) . and_return ( true )
104+ end
105+
85106 it 'creates database event records' do
86107 expect {
87108 described_class . deliver ( events :, enqueue_opts :)
119140
120141 context 'when tables do not exist' do
121142 before do
143+ allow ( Journaled ) . to receive ( :enabled? ) . and_return ( true )
122144 allow ( Journaled ::Outbox ::Event ) . to receive ( :table_exists? ) . and_return ( false )
123145 end
124146
Original file line number Diff line number Diff line change @@ -503,6 +503,7 @@ def fake_event(num)
503503 context 'with Outbox::Adapter' do
504504 before do
505505 skip "Outbox tests require PostgreSQL" unless ActiveRecord ::Base . connection . adapter_name == 'PostgreSQL'
506+ allow ( Journaled ) . to receive ( :enabled? ) . and_return ( true )
506507 end
507508
508509 around do |example |
You can’t perform that action at this time.
0 commit comments