config to control the behavior of the CallsMonitoring job

introduces new configuration options in yeti_web.yml to control
the behavior of the CallsMonitoring job when dealing with
disabled customer
authentication and termination gateways:

- calls_monitoring.teardown_on_disabled_customer_auth
- calls_monitoring.teardown_on_disabled_term_gw

The CallsMonitoring class has been updated to use
these configurations in the
relevant methods. If the configs are not present,
the current behavior (terminating
calls for disabled customer auth and termination
gateways) is maintained.

The calls_monitoring_spec.rb file has been updated
with new test cases for the
introduced configurations.

app/jobs/jobs/calls_monitoring.rb

@@ -276,6 +276,8 @@ def detect_vendors_calls_to_reject
  # drop calls where `customer_auth_id`
  # is linked to `CustomersAuth#reject_calls = true`
  def detect_customers_auth_calls_to_reject
+ return unless CallsMonitoring.teardown_on_disabled_customer_auth?
+
  flatten_calls.each do |call|
  customers_auth_id = call[:customer_auth_id]
  customers_auth = active_customers_auths_reject_calls[customers_auth_id]
@@ -286,10 +288,21 @@ def detect_customers_auth_calls_to_reject
  end
  end
 
+ def self.teardown_on_disabled_customer_auth?
+ YetiConfig.calls_monitoring.teardown_on_disabled_customer_auth.nil? || YetiConfig.calls_monitoring.teardown_on_disabled_customer_auth
+ end
+
+ def self.teardown_on_disabled_term_gw?
+ YetiConfig.calls_monitoring.teardown_on_disabled_term_gw.nil? || YetiConfig.calls_monitoring.teardown_on_disabled_term_gw
+ end
+
  # detect gateway is disabled by orig_gw_id and term_gw_id
  def detect_gateway_calls_to_reject
  flatten_calls.each do |call|
- if disabled_orig_gw_active_calls.key?(call[:orig_gw_id]) || disabled_term_gw_active_calls.key?(call[:term_gw_id])
+ if disabled_orig_gw_active_calls.key?(call[:orig_gw_id])
+ local_tag = call[:local_tag]
+ @terminate_calls[local_tag] = call
+ elsif CallsMonitoring.teardown_on_disabled_term_gw? && disabled_term_gw_active_calls.key?(call[:term_gw_id])
  local_tag = call[:local_tag]
  @terminate_calls[local_tag] = call
  end

config/yeti_web.yml.ci

@@ -3,6 +3,8 @@ site_title_image: "yeti.png"
 calls_monitoring:
  write_account_stats: true
  write_gateway_stats: true
+ teardown_on_disabled_customer_auth: false
+ teardown_on_disabled_term_gw: false
 api:
  token_lifetime: 600 # jwt token lifetime in seconds, empty string means permanent tokens
 cdr_export:

config/yeti_web.yml.development

@@ -3,6 +3,8 @@ site_title_image: "yeti.png"
 calls_monitoring:
  write_account_stats: true
  write_gateway_stats: true
+ teardown_on_disabled_customer_auth: false
+ teardown_on_disabled_term_gw: false
 api:
  token_lifetime: 600 # jwt token lifetime in seconds, empty string means permanent tokens
 cdr_export:

config/yeti_web.yml.distr

@@ -3,6 +3,8 @@ site_title_image: "yeti.png"
 calls_monitoring:
  write_account_stats: true
  write_gateway_stats: true
+ teardown_on_disabled_customer_auth: false
+ teardown_on_disabled_term_gw: false
 api:
  token_lifetime: 600 # jwt token lifetime in seconds, empty string means permanent tokens
 cdr_export:

spec/jobs/jobs/calls_monitoring_spec.rb

@@ -289,6 +289,10 @@
  end
  end
 
+ context 'when YetiConfig.calls_monitoring.teardown_on_disabled_customer_auth' do
+
+ end
+
  context 'when YetiConfig.calls_monitoring.write_gateway_stats=false' do
  before do
  expect(YetiConfig.calls_monitoring).to receive(:write_gateway_stats).and_return(false)