version update

Author: dacoburn

pyproject.toml

@@ -6,7 +6,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "socketsecurity"
-version = "2.0.43"
+version = "2.0.44"
 requires-python = ">= 3.10"
 license = {"file" = "LICENSE"}
 dependencies = [

socketsecurity/__init__.py

@@ -1,2 +1,2 @@
 __author__ = 'socket.dev'
-__version__ = '2.0.43'
+__version__ = '2.0.44'

socketsecurity/plugins/__init__.py

@@ -0,0 +1,6 @@
+class Plugin:
+    def __init__(self, config):
+        self.config = config
+
+    def send(self, message, level):
+        raise NotImplementedError("Plugin must implement send()")

socketsecurity/plugins/base.py

@@ -0,0 +1,30 @@
+from .base import Plugin
+import requests
+import base64
+
+class JiraPlugin(Plugin):
+    def send(self, message, level):
+        if not self.config.get("enabled", False):
+            return
+        if level not in self.config.get("levels", ["block", "warn"]):
+            return
+
+        url = self.config["url"]
+        project = self.config["project"]
+        auth = base64.b64encode(f"{self.config['email']}:{self.config['api_token']}".encode()).decode()
+
+        payload = {
+            "fields": {
+                "project": {"key": project},
+                "summary": message.get("title", "No title"),
+                "description": message.get("description", ""),
+                "issuetype": {"name": "Task"}
+            }
+        }
+
+        headers = {
+            "Authorization": f"Basic {auth}",
+            "Content-Type": "application/json"
+        }
+
+        requests.post(f"{url}/rest/api/3/issue", json=payload, headers=headers)

socketsecurity/plugins/jira.py

@@ -0,0 +1,21 @@
+from . import jira, webhook, slack, teams
+
+PLUGIN_CLASSES = {
+    "jira": jira.JiraPlugin,
+    "slack": slack.SlackPlugin,
+    "webhook": webhook.WebhookPlugin,
+    "teams": teams.TeamsPlugin,
+}
+
+class PluginManager:
+    def __init__(self, config):
+        self.plugins = []
+        for name, conf in config.items():
+            if conf.get("enabled"):
+                plugin_cls = PLUGIN_CLASSES.get(name)
+                if plugin_cls:
+                    self.plugins.append(plugin_cls(conf))
+
+    def send(self, message, level):
+        for plugin in self.plugins:
+            plugin.send(message, level)

socketsecurity/plugins/manager.py

@@ -0,0 +1,12 @@
+from .base import Plugin
+import requests
+
+class SlackPlugin(Plugin):
+    def send(self, message, level):
+        if not self.config.get("enabled", False):
+            return
+        if level not in self.config.get("levels", ["block", "warn"]):
+            return
+
+        payload = {"text": message.get("title", "No title")}
+        requests.post(self.config["webhook_url"], json=payload)

socketsecurity/plugins/slack.py

@@ -0,0 +1,12 @@
+from .base import Plugin
+import requests
+
+class TeamsPlugin(Plugin):
+    def send(self, message, level):
+        if not self.config.get("enabled", False):
+            return
+        if level not in self.config.get("levels", ["block", "warn"]):
+            return
+
+        payload = {"text": message.get("title", "No title")}
+        requests.post(self.config["webhook_url"], json=payload)

socketsecurity/plugins/teams.py

@@ -0,0 +1,13 @@
+from .base import Plugin
+import requests
+
+class WebhookPlugin(Plugin):
+    def send(self, message, level):
+        if not self.config.get("enabled", False):
+            return
+        if level not in self.config.get("levels", ["block", "warn"]):
+            return
+
+        url = self.config["url"]
+        headers = self.config.get("headers", {"Content-Type": "application/json"})
+        requests.post(url, json=message, headers=headers)