def send_alarm()

in elkserver/docker/redelk-base/redelkinstalldata/scripts/modules/slack/module.py [0:0]

• 45 lines of code
• 9 McCabe index (conditional complexity)

    def send_alarm(self, alarm):
        """Send the alarm notification"""
        description = alarm["info"]["description"]
        if len(alarm["groupby"]) > 0:
            description += f'\n _Please note that the items below have been grouped by: {alarm["groupby"]}_'

        blocks = [
            {
                "type": "section",
                "text": {
                    "type": "mrkdwn",
                    "text": f'*[{config.project_name}] Alarm from {alarm["info"]["name"]} [{alarm["hits"]["total"]} hits]*\n{description}',
                },
            },
            {"type": "divider"},
        ]

        try:
            for hit in alarm["hits"]["hits"]:
                i = 0
                title = hit["_id"]
                while i < len(alarm["groupby"]):
                    val = get_value(f'_source.{alarm["groupby"][i]}', hit)
                    if i == 0:
                        title = val
                    else:
                        title = f"{title} / {val}"
                    i += 1

                text = f"*Alarm on item: {title.strip()}*\n\t"
                for field in alarm["fields"]:
                    val = get_value(f"_source.{field}", hit)

                    # Add a tab to every line of values, this makes it easier to read
                    pretty_val = "".join(
                        [f"{line}\n\t" for line in pprint(val).split("\n")]
                    )
                    text += f"*{field}*: {pretty_val}"

                blocks.append(
                    {"type": "section", "text": {"type": "mrkdwn", "text": text}}
                )
                blocks.append({"type": "divider"})
            # pylint: disable=broad-except
        except Exception as error:
            self.logger.exception(error)

        webhook = WebhookClient(config.notifications["slack"]["webhook_url"])
        res = webhook.send(text="", blocks=blocks)

        if not 200 <= res.status_code <= 299:
            self.logger.error(
                "Informing slack failed: %s %s", res.status_code, res.body
            )
            self.logger.error(alarm)