Skip to content

Commit

Permalink
Use default_blacklisted_event_names for filtered_events
Browse files Browse the repository at this point in the history
  • Loading branch information
agrare committed Jan 28, 2025
1 parent 6518977 commit 170262a
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion app/models/manageiq/providers/base_manager.rb
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ def self.http_proxy
end

def self.default_blacklisted_event_names
Array(::Settings.ems["ems_#{provider_name.underscore}"].try(:blacklisted_event_names))
Array(::Settings.ems["ems_#{ems_type}"].try(:blacklisted_event_names))
end

# Returns a description of the options that are stored in "options" field.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ def after_initialize
do_exit("Unable to find instance for EMS ID [#{@cfg[:ems_id]}].", 1) if @ems.nil?
do_exit("EMS ID [#{@cfg[:ems_id]}] failed authentication check.", 1) unless @ems.authentication_check.first

@filtered_events = @ems.blacklisted_event_names
@filtered_events = @ems.class.default_blacklisted_event_names
_log.info("#{log_prefix} Event Catcher skipping the following events:\n#{@filtered_events.to_a.join("\n")}")

configure_event_flooding_prevention if worker_settings.try(:[], :flooding_monitor_enabled)
Expand Down Expand Up @@ -95,16 +95,16 @@ def before_exit(message, _exit_code)
def sync_blacklisted_events
return unless @ems

filters = @ems.blacklisted_event_names
filters = @ems.default_blacklisted_event_names

if @filtered_events.nil? || @filtered_events != filters
adds = filters - @filtered_events
deletes = @filtered_events - filters

@filtered_events = filters
_log.info("Synchronizing blacklisted events: #{filters}")
_log.info(" Blacklisted events added: #{adds}")
_log.info(" Blacklisted events deleted: #{deletes}")
_log.info("Synchronizing filtered events: #{filters}")
_log.info(" Filtered events added: #{adds}")
_log.info(" Filtered events deleted: #{deletes}")
end
end

Expand Down
2 changes: 1 addition & 1 deletion spec/models/manageiq/providers/base_manager_spec.rb
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
}
}
)
allow(described_class).to receive(:provider_name).and_return('SomeProvider')
allow(described_class).to receive(:ems_type).and_return(:some_provider)
expect(described_class.default_blacklisted_event_names).to eq(%w[ev1 ev2])
end
end
Expand Down

0 comments on commit 170262a

Please sign in to comment.