diff --git a/salt/elastalert/files/modules/so/thehive.py b/salt/elastalert/files/modules/so/thehive.py deleted file mode 100644 index af18b412e..000000000 --- a/salt/elastalert/files/modules/so/thehive.py +++ /dev/null @@ -1,107 +0,0 @@ -# -*- coding: utf-8 -*- -# HiveAlerter modified from original at: https://raw.githubusercontent.com/Nclose-ZA/elastalert_hive_alerter/master/elastalert_hive_alerter/hive_alerter.py - -import uuid - -from elastalert.alerts import Alerter -from thehive4py.api import TheHiveApi -from thehive4py.models import Alert, AlertArtifact, CustomFieldHelper - - -class TheHiveAlerter(Alerter): - """ - Use matched data to create alerts containing observables in an instance of TheHive - """ - - required_options = set(['hive_connection', 'hive_alert_config']) - - def get_aggregation_summary_text(self, matches): - text = super(TheHiveAlerter, self).get_aggregation_summary_text(matches) - if text: - text = '```\n{0}```\n'.format(text) - return text - - def create_artifacts(self, match): - artifacts = [] - context = {'rule': self.rule, 'match': match} - for mapping in self.rule.get('hive_observable_data_mapping', []): - for observable_type, match_data_key in mapping.items(): - try: - artifacts.append(AlertArtifact(dataType=observable_type, data=match_data_key.format(**context))) - except KeyError as e: - print(('format string {} fail cause no key {} in {}'.format(e, match_data_key, context))) - return artifacts - - def create_alert_config(self, match): - context = {'rule': self.rule, 'match': match} - alert_config = { - 'artifacts': self.create_artifacts(match), - 'sourceRef': str(uuid.uuid4())[0:6], - 'title': '{rule[name]}'.format(**context) - } - - alert_config.update(self.rule.get('hive_alert_config', {})) - - for alert_config_field, alert_config_value in alert_config.items(): - if alert_config_field == 'customFields': - custom_fields = CustomFieldHelper() - for cf_key, cf_value in alert_config_value.items(): - try: - func = getattr(custom_fields, 'add_{}'.format(cf_value['type'])) - except AttributeError: - raise Exception('unsupported custom field type {}'.format(cf_value['type'])) - value = cf_value['value'].format(**context) - func(cf_key, value) - alert_config[alert_config_field] = custom_fields.build() - elif isinstance(alert_config_value, str): - alert_config[alert_config_field] = alert_config_value.format(**context) - elif isinstance(alert_config_value, (list, tuple)): - formatted_list = [] - for element in alert_config_value: - try: - formatted_list.append(element.format(**context)) - except (AttributeError, KeyError, IndexError): - formatted_list.append(element) - alert_config[alert_config_field] = formatted_list - - return alert_config - - def send_to_thehive(self, alert_config): - connection_details = self.rule['hive_connection'] - api = TheHiveApi( - connection_details.get('hive_host', ''), - connection_details.get('hive_apikey', ''), - proxies=connection_details.get('hive_proxies', {'http': '', 'https': ''}), - cert=connection_details.get('hive_verify', False)) - - alert = Alert(**alert_config) - response = api.create_alert(alert) - - if response.status_code != 201: - raise Exception('alert not successfully created in TheHive\n{}'.format(response.text)) - - def alert(self, matches): - if self.rule.get('hive_alert_config_type', 'custom') != 'classic': - for match in matches: - alert_config = self.create_alert_config(match) - self.send_to_thehive(alert_config) - else: - alert_config = self.create_alert_config(matches[0]) - artifacts = [] - for match in matches: - artifacts += self.create_artifacts(match) - if 'related_events' in match: - for related_event in match['related_events']: - artifacts += self.create_artifacts(related_event) - - alert_config['artifacts'] = artifacts - alert_config['title'] = self.create_title(matches) - alert_config['description'] = self.create_alert_body(matches) - self.send_to_thehive(alert_config) - - def get_info(self): - - return { - 'type': 'hivealerter', - 'hive_host': self.rule.get('hive_connection', {}).get('hive_host', '') - } diff --git a/salt/elastalert/files/rules/so/nids2hive.yaml b/salt/elastalert/files/rules/so/nids2hive.yaml index 7408a34ce..b7593b1d2 100644 --- a/salt/elastalert/files/rules/so/nids2hive.yaml +++ b/salt/elastalert/files/rules/so/nids2hive.yaml @@ -26,7 +26,8 @@ filter: alert: modules.so.thehive.TheHiveAlerter hive_connection: - hive_host: https://{{hivehost}}/thehive/ + hive_host: http://{{hivehost}} + hive_port: 9000 hive_apikey: {{hivekey}} hive_proxies: diff --git a/salt/elastalert/init.sls b/salt/elastalert/init.sls index 0952689e2..83e7b5655 100644 --- a/salt/elastalert/init.sls +++ b/salt/elastalert/init.sls @@ -55,35 +55,35 @@ elastalogdir: file.directory: - name: /opt/so/log/elastalert - user: 933 - - group: 939 + - group: 933 - makedirs: True elastarules: file.directory: - name: /opt/so/rules/elastalert - user: 933 - - group: 939 + - group: 933 - makedirs: True elastaconfdir: file.directory: - name: /opt/so/conf/elastalert - user: 933 - - group: 939 + - group: 933 - makedirs: True elastasomodulesdir: file.directory: - name: /opt/so/conf/elastalert/modules/so - user: 933 - - group: 939 + - group: 933 - makedirs: True elastacustmodulesdir: file.directory: - name: /opt/so/conf/elastalert/modules/custom - user: 933 - - group: 939 + - group: 933 - makedirs: True elastasomodulesync: @@ -91,7 +91,7 @@ elastasomodulesync: - name: /opt/so/conf/elastalert/modules/so - source: salt://elastalert/files/modules/so - user: 933 - - group: 939 + - group: 933 - makedirs: True elastarulesync: @@ -99,7 +99,7 @@ elastarulesync: - name: /opt/so/rules/elastalert - source: salt://elastalert/files/rules/so - user: 933 - - group: 939 + - group: 933 - template: jinja elastaconf: @@ -107,7 +107,7 @@ elastaconf: - name: /opt/so/conf/elastalert/elastalert_config.yaml - source: salt://elastalert/files/elastalert_config.yaml - user: 933 - - group: 939 + - group: 933 - template: jinja so-elastalert: @@ -118,16 +118,9 @@ so-elastalert: - user: elastalert - detach: True - binds: - - /opt/so/rules/elastalert:/etc/elastalert/rules/:ro + - /opt/so/rules/elastalert:/opt/rules/:ro - /opt/so/log/elastalert:/var/log/elastalert:rw - /opt/so/conf/elastalert/modules/:/opt/elastalert/modules/:ro - - /opt/so/conf/elastalert/elastalert_config.yaml:/etc/elastalert/conf/elastalert_config.yaml:ro - - environment: - - ELASTICSEARCH_HOST: {{ esip }} - - ELASTICSEARCH_PORT: {{ esport }} - - ELASTALERT_CONFIG: /etc/elastalert/conf/elastalert_config.yaml - - ELASTALERT_SUPERVISOR_CONF: /etc/elastalert/conf/elastalert_supervisord.conf - - RULES_DIRECTORY: /etc/elastalert/rules/ - - LOG_DIR: /var/log/elastalert + - /opt/so/conf/elastalert/elastalert_config.yaml:/opt/config/elastalert_config.yaml:ro {% endif %}