fix pipelines for flow if proxy has flow sensors

redBorder · Nov 12, 2024 · b450479 · b450479
1 parent b873b58
commit b450479
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/resources/libraries/get_pipelines.rb b/resources/libraries/get_pipelines.rb
@@ -7,6 +7,7 @@ def get_pipelines
       main_logstash = determine_main_logstash_node()
       monitor_sensor_in_proxy_nodes = find_sensor_in_proxy_nodes('device')
       vault_sensor_in_proxy_nodes = find_sensor_in_proxy_nodes('vault')
+      flow_sensor_in_proxy_nodes = find_sensor_in_proxy_nodes('flow')
       monitor_config = get_monitor_configuration()
       has_device_sensors = !sensors['device-sensor'].nil? && !sensors['device-sensor'].empty?
 
@@ -15,8 +16,8 @@ def get_pipelines
       logstash_pipelines.push('scanner-pipeline') unless sensors['scanner-sensor'].empty?
       logstash_pipelines.push('nmsp-pipeline') if main_logstash == node.name && !sensors['flow-sensor'].empty?
       logstash_pipelines.push('radius-pipeline') if main_logstash == node.name
-      logstash_pipelines.push('netflow-pipeline') unless sensors['flow-sensor'].empty?
-      logstash_pipelines.push('sflow-pipeline') unless sensors['flow-sensor'].empty?
+      logstash_pipelines.push('netflow-pipeline') unless sensors['flow-sensor'].empty? && flow_sensor_in_proxy_nodes.empty?
+      logstash_pipelines.push('sflow-pipeline') unless sensors['flow-sensor'].empty?  && flow_sensor_in_proxy_nodes.empty?
       logstash_pipelines.push('meraki-pipeline') unless sensors['meraki-sensor'].empty?
       logstash_pipelines.push('monitor-pipeline') unless namespaces.empty?
       logstash_pipelines.push('intrusion-pipeline') unless sensors['ips-sensor'].empty? && sensors['ipsv2-sensor'].empty? && sensors['ipscp-sensor'].empty? && sensors['ipsg-sensor'].empty?