New custom slack sink, slack_sink_preview

docs/configuration/sinks/slack.rst

@@ -181,3 +181,174 @@ your own. This is not recommended for most companies due to the added complexity
 
     When using a custom Slack app, callback buttons are not supported due to complexities in how Slack handles incoming
     messages. :ref:`Contact us if you need assistance. <Getting Support>`
+Message Templating
+-------------------------------------------------------------------
+
+Slack messages can be customized using Jinja2 templates. Robusta includes default templates that match the standard format, but you can override them for custom formatting.
+
+To use custom templates, add them to the ``custom_templates`` parameter:
+
+.. code-block:: yaml
+
+   sinksConfig:
+   - slack_sink:
+       name: main_slack_sink
+       slack_channel: "#alerts"
+       api_key: xoxb-112...
+       custom_templates:
+         header.j2: |
+           {
+             "type": "section",
+             "text": {
+               "type": "mrkdwn",
+               "text": "{{ status_emoji }} *CUSTOM ALERT: {{ title }}*"
+             }
+           }
+
+           {
+             "type": "context",
+             "elements": [
+               {
+                 "type": "mrkdwn", 
+                 "text": ":bell: {{ alert_type }} on cluster {{ cluster_name }}"
+               },
+               {
+                 "type": "mrkdwn",
+                 "text": "{{ severity_emoji }} {{ severity }}"
+               }
+             ]
+           }
+
+Templates use Slack's Block Kit format and must generate valid JSON. Each template block is separated by double newlines (``\n\n``).
+
+Available template variables:
+
++-----------------------------+-------------------------------------------------------------+
+| Variable                    | Description                                                 |
++=============================+=============================================================+
+| ``title``                   | The alert title                                             |
++-----------------------------+-------------------------------------------------------------+
+| ``status_text``             | "Firing" or "Resolved"                                      |
++-----------------------------+-------------------------------------------------------------+
+| ``status_emoji``            | "⚠️" (for firing) or "✅" (for resolved)                    |
++-----------------------------+-------------------------------------------------------------+
+| ``severity``                | Alert severity (e.g., "Warning", "Critical")                |
++-----------------------------+-------------------------------------------------------------+
+| ``severity_emoji``          | Emoji for the severity level                                |
++-----------------------------+-------------------------------------------------------------+
+| ``alert_type``              | "Alert", "K8s Event", or "Notification"                     |
++-----------------------------+-------------------------------------------------------------+
+| ``cluster_name``            | The name of the cluster                                     |
++-----------------------------+-------------------------------------------------------------+
+| ``platform_enabled``        | Boolean indicating if Robusta platform is enabled           |
++-----------------------------+-------------------------------------------------------------+
+| ``include_investigate_link``| Boolean for including investigate link                      |
++-----------------------------+-------------------------------------------------------------+
+| ``investigate_uri``         | URI for investigation                                       |
++-----------------------------+-------------------------------------------------------------+
+| ``resource_text``           | Resource identifier (e.g., "Pod/namespace/name")            |
++-----------------------------+-------------------------------------------------------------+
+| ``resource_emoji``          | Emoji for the resource type                                 |
++-----------------------------+-------------------------------------------------------------+
+| ``finding``                 | The complete finding object as JSON                         |
++-----------------------------+-------------------------------------------------------------+
+
+Currently available templates:
+
+* ``header.j2`` - The header section of alert notificationsTemplate Styles and Customization
+-------------------------------------------------------------------
+
+Slack messages in Robusta can be customized using different template styles and Jinja2 templates.
+
+Template Styles
+~~~~~~~~~~~~~~
+
+Robusta supports two built-in template styles:
+
+1. **default** - Modern JIRA-style formatting (default)
+2. **legacy** - Classic formatting matching Robusta's original style
+
+To select a template style:
+
+.. code-block:: yaml
+
+   sinksConfig:
+   - slack_sink:
+       name: main_slack_sink
+       slack_channel: "#alerts"
+       api_key: xoxb-112...
+       template_style: "legacy"  # Use "default" or "legacy"
+
+Custom Templates
+~~~~~~~~~~~~~~~
+
+For complete control over message formatting, you can provide custom Jinja2 templates:
+
+.. code-block:: yaml
+
+   sinksConfig:
+   - slack_sink:
+       name: main_slack_sink
+       slack_channel: "#alerts"
+       api_key: xoxb-112...
+       custom_templates:
+         header.j2: |
+           {
+             "type": "section",
+             "text": {
+               "type": "mrkdwn",
+               "text": "{{ status_emoji }} *CUSTOM ALERT: {{ title }}*"
+             }
+           }
+
+           {
+             "type": "context",
+             "elements": [
+               {
+                 "type": "mrkdwn", 
+                 "text": ":bell: {{ alert_type }} on cluster {{ cluster_name }}"
+               },
+               {
+                 "type": "mrkdwn",
+                 "text": "{{ severity_emoji }} {{ severity }}"
+               }
+             ]
+           }
+
+Templates use Slack's Block Kit format and must generate valid JSON. Each template block is separated by double newlines (``\n\n``).
+
+Available template variables:
+
++-----------------------------+-------------------------------------------------------------+
+| Variable                    | Description                                                 |
++=============================+=============================================================+
+| ``title``                   | The alert title                                             |
++-----------------------------+-------------------------------------------------------------+
+| ``status_text``             | "Firing" or "Resolved"                                      |
++-----------------------------+-------------------------------------------------------------+
+| ``status_emoji``            | "⚠️" (for firing) or "✅" (for resolved)                    |
++-----------------------------+-------------------------------------------------------------+
+| ``severity``                | Alert severity (e.g., "Warning", "Critical")                |
++-----------------------------+-------------------------------------------------------------+
+| ``severity_emoji``          | Emoji for the severity level                                |
++-----------------------------+-------------------------------------------------------------+
+| ``alert_type``              | "Alert", "K8s Event", or "Notification"                     |
++-----------------------------+-------------------------------------------------------------+
+| ``cluster_name``            | The name of the cluster                                     |
++-----------------------------+-------------------------------------------------------------+
+| ``platform_enabled``        | Boolean indicating if Robusta platform is enabled           |
++-----------------------------+-------------------------------------------------------------+
+| ``include_investigate_link``| Boolean for including investigate link                      |
++-----------------------------+-------------------------------------------------------------+
+| ``investigate_uri``         | URI for investigation                                       |
++-----------------------------+-------------------------------------------------------------+
+| ``resource_text``           | Resource identifier (e.g., "Pod/namespace/name")            |
++-----------------------------+-------------------------------------------------------------+
+| ``resource_emoji``          | Emoji for the resource type                                 |
++-----------------------------+-------------------------------------------------------------+
+| ``finding``                 | The complete finding object with all alert data             |
++-----------------------------+-------------------------------------------------------------+
+
+Currently available templates:
+
+* ``header.j2`` - The header section of alert notifications

src/robusta/core/reporting/base.py

@@ -149,6 +149,14 @@ def __init__(
 
     def __str__(self):
         return f"annotations: {self.annotations} Enrichment: {self.blocks} "
+
+    def to_dict(self):
+        return {
+            "blocks": [block.dict() for block in self.blocks],
+            "annotations": self.annotations,
+            "enrichment_type": self.enrichment_type,
+            "title": self.title,
+        }
 
 
 class FilterableScopeMatcher(BaseScopeMatcher):
@@ -404,3 +412,31 @@ def __calculate_fingerprint(subject: FindingSubject, source: FindingSource, aggr
         # if not, generate with logic similar to alertmanager
         s = f"{subject.subject_type},{subject.name},{subject.namespace},{subject.node},{source.value}{aggregation_key}"
         return hashlib.sha256(s.encode()).hexdigest()
+
+    def to_json(self):
+        return {
+            "title": self.title,
+            "aggregation_key": self.aggregation_key,
+            "severity": self.severity.name,
+            "source": self.source.name,
+            "description": self.description,
+            "subject": {
+                "name": self.subject.name,
+                "subject_type": self.subject.subject_type.value,
+                "namespace": self.subject.namespace,
+                "node": self.subject.node,
+                "container": self.subject.container,
+                "labels": self.subject.labels,
+                "annotations": self.subject.annotations,
+            },
+            "finding_type": self.finding_type.name,
+            "failure": self.failure,
+            "creation_date": self.creation_date,
+            "fingerprint": self.fingerprint,
+            "starts_at": self.starts_at,
+            "ends_at": self.ends_at,
+            "add_silence_url": self.add_silence_url,
+            "silence_labels": self.silence_labels,
+            "enrichments": [enrichment.to_dict() for enrichment in self.enrichments],
+            "links": [link.dict() for link in self.links],
+        }

src/robusta/core/sinks/slack/slack_sink_params.py

@@ -1,18 +1,47 @@
 from robusta.core.sinks.sink_base_params import SinkBaseParams
 from robusta.core.sinks.sink_config import SinkConfigBase
 from robusta.core.sinks.common import ChannelTransformer
-
-from typing import Optional
+from enum import Enum
+from typing import Optional, Dict, Literal
 from pydantic import validator
 
 
+class SlackTemplateStyle(str, Enum):
+    DEFAULT = "default"
+    LEGACY = "legacy"
+
+
 class SlackSinkParams(SinkBaseParams):
     slack_channel: str
     api_key: str
     channel_override: Optional[str] = None
     max_log_file_limit_kb: int = 1000
     investigate_link: bool = True
 
+    template_style: SlackTemplateStyle = SlackTemplateStyle.DEFAULT  # Use "legacy" for old-style formatting
+    slack_custom_templates: Optional[Dict[str, str]] = None  # Template name -> custom template content
+    template_name: Optional[str] = None
+
+    def get_effective_template_name(self) -> str:
+        """
+        Returns the template name to use for this sink. If template_name is set, use it.
+        Otherwise, use 'legacy.j2' if template_style is legacy, else 'header.j2'.
+        """
+        if self.template_name:
+            return self.template_name
+        if self.template_style == SlackTemplateStyle.LEGACY:
+            return "legacy.j2"
+        return "header.j2"
+
+    def get_custom_template(self) -> Optional[str]:
+        """
+        Returns the custom template string for the effective template name, if it exists.
+        """
+        template_name = self.get_effective_template_name()
+        if self.slack_custom_templates and template_name in self.slack_custom_templates:
+            return self.slack_custom_templates[template_name]
+        return None
+
     @classmethod
     def _supports_grouping(cls):
         return True
@@ -30,4 +59,4 @@ class SlackSinkConfigWrapper(SinkConfigBase):
     slack_sink: SlackSinkParams
 
     def get_params(self) -> SinkBaseParams:
-        return self.slack_sink
+        return self.slack_sink

src/robusta/core/sinks/slack/templates/README.md

@@ -0,0 +1,73 @@
+# Slack Message Templates
+
+This directory contains the Jinja2 templates used to render Slack messages.
+
+## How Templates Work
+
+Slack messages are rendered using [Jinja2](https://jinja.palletsprojects.com/) templates. Each template produces one or more Slack Block Kit blocks in JSON format.
+
+Templates are separated by double newlines (`\n\n`) to indicate separate blocks. Each block must be valid JSON that conforms to the [Slack Block Kit](https://api.slack.com/block-kit) format.
+
+## Available Templates
+
+- `header.j2`: The header section of alert notifications, including title and metadata
+
+## Customizing Templates
+
+Users can customize templates in the Robusta configuration by providing their own template content:
+
+```yaml
+sinks:
+  slack:
+    slack_sink:
+      name: slack
+      slack_channel: "#alerts"
+      api_key: "${SLACK_TOKEN}"
+      custom_templates:
+        header.j2: |
+          {
+            "type": "section",
+            "text": {
+              "type": "mrkdwn",
+              "text": "{{ status_emoji }} *CUSTOM ALERT: {{ title }}*"
+            }
+          }
+
+          {
+            "type": "context",
+            "elements": [
+              {
+                "type": "mrkdwn", 
+                "text": ":bell: {{ alert_type }} on cluster {{ cluster_name }}"
+              },
+              {
+                "type": "mrkdwn",
+                "text": "{{ severity_emoji }} {{ severity }}"
+              }
+            ]
+          }
+```
+
+## Template Variables
+
+Each template has access to different variables. Here are the variables available in the `header.j2` template:
+
+| Variable | Description |
+|----------|-------------|
+| `title` | The alert title |
+| `status_text` | "Firing" or "Resolved" |
+| `status_emoji` | "⚠️" (for firing) or "✅" (for resolved) |
+| `severity` | Alert severity (e.g., "Warning", "Critical") |
+| `severity_emoji` | Emoji for the severity level |
+| `alert_type` | "Alert", "K8s Event", or "Notification" |
+| `cluster_name` | The name of the cluster |
+| `platform_enabled` | Boolean indicating if Robusta platform is enabled |
+| `include_investigate_link` | Boolean indicating if investigate link should be included |
+| `investigate_uri` | URI for investigation |
+| `resource_text` | Resource identifier (e.g., "Pod/namespace/name") |
+| `resource_emoji` | Emoji for the resource type |
+| `finding` | The complete finding object as JSON |
+
+## Fallback Behavior
+
+If Jinja2 is not available, a built-in fallback implementation will be used that produces the same output as the default template.

src/robusta/core/sinks/slack/templates/__init__.py

@@ -0,0 +1 @@
+# Slack message templates package

src/robusta/core/sinks/slack/templates/header.j2

@@ -0,0 +1,36 @@
+{# Default template for Slack message headers #}
+{# This creates a JIRA-style header with title and context blocks #}
+
+{# First create the title block with status #}
+{
+  "type": "section",
+  "text": {
+    "type": "mrkdwn",
+    "text": "{{ status_emoji }} *[{{ status_text }}] {% if platform_enabled and include_investigate_link %}<{{ investigate_uri }}|{{ title }}>{% else %}{{ title }}{% endif %}*"
+  }
+}
+
+{# Then create the context block with metadata #}
+{
+  "type": "context",
+  "elements": [
+    {
+      "type": "mrkdwn", 
+      "text": ":bell: Type: {{ alert_type }}"
+    },
+    {
+      "type": "mrkdwn",
+      "text": "{{ severity_emoji }} Severity: {{ severity }}"
+    },
+    {
+      "type": "mrkdwn",
+      "text": ":globe_with_meridians: Cluster: {{ cluster_name }}"
+    }
+    {% if resource_text %}
+    ,{
+      "type": "mrkdwn",
+      "text": "{{ resource_emoji }} Resource: {{ resource_text }}"
+    }
+    {% endif %}
+  ]
+}