feat: keep.join function for workflows

keep/functions/__init__.py

@@ -175,6 +175,17 @@ def slice(str_to_slice: str, start: int = 0, end: int = 0) -> str:
     return str_to_slice[int(start) : int(end)]
 
 
+def join(iterable: list | dict | str, delimiter: str = ",") -> str:
+    if isinstance(iterable, str):
+        try:
+            iterable = json.loads(iterable)
+        except json.JSONDecodeError:
+            iterable = json.loads(iterable.replace("'", '"'))
+    if isinstance(iterable, dict):
+        return delimiter.join([f"{k}={v}" for k, v in iterable.items()])
+    return delimiter.join([str(item) for item in iterable])
+
+
 def dict_pop(data: str | dict, *args) -> dict:
     if isinstance(data, str):
         data = json.loads(data)

keep/iohandler/iohandler.py

@@ -520,18 +520,9 @@ def __get_short_urls(self, urls: list) -> dict:
 if __name__ == "__main__":
     # debug & test
     context_manager = ContextManager("keep")
-    context_manager.event_context = {
-        "ticket_id": "1234",
-        "severity": "high",
-        "ticket_created_at": "2021-09-01T00:00:00Z",
-    }
+    context_manager.event_context = {"tags": {"k1": "v1", "k2": "v2"}}
     iohandler = IOHandler(context_manager)
-    res = iohandler.render(
-        iohandler.quote(
-            "not '{{ alert.ticket_id }}' or (('{{ alert.ticket_status }}' in ['Resolved', 'Closed', 'Canceled']) and ('{{ alert.severity }}' == 'critical' or keep.datetime_compare(keep.utcnow(), keep.to_utc('{{ alert.ticket_created_at }}')) > 168))"
-        ),
-        safe=False,
-    )
+    res = iohandler.render('https://www.keephq.dev?keep.join("{{alert.tags}}", "&")')
     from asteval import Interpreter
 
     aeval = Interpreter()

keep/providers/cloudwatch_provider/cloudwatch_provider.py

@@ -257,6 +257,7 @@ def validate_scopes(self):
 
         # 4. validate start query
         logs_client = self.__generate_client("logs")
+        query = False
         try:
             query = logs_client.start_query(
                 logGroupName="keepTest",
@@ -277,6 +278,8 @@ def validate_scopes(self):
             else:
                 self.logger.info("Error validating AWS logs:StartQuery scope")
                 scopes["logs:StartQuery"] = str(e)
+
+        query_id = False
         if query:
             try:
                 query_id = logs_client.describe_queries().get("queries")[0]["queryId"]