Enhance notification system with webhook support

Author: Dobrunia

package.json

@@ -1,6 +1,6 @@
 {
   "name": "hawk.api",
-  "version": "1.4.6",
+  "version": "1.4.7",
   "main": "index.ts",
   "license": "BUSL-1.1",
   "scripts": {
@@ -42,7 +42,7 @@
     "@graphql-tools/schema": "^8.5.1",
     "@graphql-tools/utils": "^8.9.0",
     "@hawk.so/nodejs": "^3.3.1",
-    "@hawk.so/types": "^0.5.8",
+    "@hawk.so/types": "^0.5.9",
     "@n1ru4l/json-patch-plus": "^0.2.0",
     "@node-saml/node-saml": "^5.0.1",
     "@octokit/oauth-methods": "^4.0.0",

src/rabbitmq.ts

@@ -28,6 +28,7 @@ export enum Queues {
   Telegram = 'notify/telegram',
   Slack = 'notify/slack',
   Loop = 'notify/loop',
+  Webhook = 'sender/webhook',
   Limiter = 'cron-tasks/limiter',
 }
 
@@ -90,6 +91,14 @@ export const WorkerPaths: Record<string, WorkerPath> = {
     queue: Queues.Loop,
   },
 
+  /**
+   * Path to webhook worker
+   */
+  Webhook: {
+    exchange: Exchanges.Empty,
+    queue: Queues.Webhook,
+  },
+
   /**
    * Path to limiter worker
    */

src/typeDefs/notifications.ts

@@ -49,6 +49,11 @@ export default gql`
     """
     loop: NotificationsChannelSettings
 
+    """
+    Webhook channel
+    """
+    webhook: NotificationsChannelSettings
+
     """
     Webpush
     """

src/typeDefs/notificationsInput.ts

@@ -45,6 +45,11 @@ export default gql`
     """
     loop: NotificationsChannelSettingsInput
 
+    """
+    Webhook channel
+    """
+    webhook: NotificationsChannelSettingsInput
+
     """
     Web push
     """

src/utils/personalNotifications.ts

@@ -52,4 +52,14 @@ export default async function sendNotification(user: UserDBScheme, task: SenderW
       },
     });
   }
+
+  if (user.notifications.channels.webhook?.isEnabled) {
+    await enqueue(WorkerPaths.Webhook, {
+      type: task.type,
+      payload: {
+        ...task.payload,
+        endpoint: user.notifications.channels.webhook.endpoint,
+      },
+    });
+  }
 }