feat: refactor Discord notification handling and remove unused files

- Consolidated notification logic by replacing `createMessageFromWebhook` and `sendDiscordNotification` with a single `sendNotifications` function that utilizes multiple providers.
- Removed unused `discord.ts` and `embed-factory.ts` files to clean up the codebase.
- Introduced a new provider registry to manage notification providers more effectively.
- Added a comprehensive formatter for Discord embeds to enhance message formatting based on webhook events.

Author: kWAYTV

apps/web/src/app/api/hook/route.ts

@@ -2,10 +2,7 @@ import { after } from "next/server";
 import { ZodError } from "zod/v4";
 
 import HttpStatusCode from "@/enums/http-status-codes";
-import {
-  createMessageFromWebhook,
-  sendDiscordNotification,
-} from "@/lib/notify";
+import { sendNotifications } from "@/lib/notify";
 import { checkRateLimit, getClientIp } from "@/lib/ratelimit";
 import { verifySignature } from "@/lib/verify";
 import { webhookSchema } from "@/schemas/vercel";
@@ -36,8 +33,7 @@ export async function POST(req: Request) {
     const payload = JSON.parse(rawBody) as unknown;
     const webhook = webhookSchema.parse(payload);
 
-    const embed = createMessageFromWebhook(webhook);
-    after(() => sendDiscordNotification(embed));
+    after(() => sendNotifications(webhook));
 
     return Response.json({ success: true, message: "Webhook processed" });
   } catch (error) {

apps/web/src/consts/discord.ts

@@ -1,13 +1,6 @@
-import type { Embed } from "@vermaysha/discord-webhook";
-
-import { createEmbedFromWebhook } from "@/discord/embed-factory";
-import { sendWebhook } from "@/discord/webhook-sender";
+import { providers } from "@/providers/registry";
 import type { VercelWebhook } from "@/schemas/vercel";
 
-export function createMessageFromWebhook(webhook: VercelWebhook): Embed {
-  return createEmbedFromWebhook(webhook);
-}
-
-export function sendDiscordNotification(embed: Embed): Promise<void> {
-  return sendWebhook(embed);
+export async function sendNotifications(webhook: VercelWebhook): Promise<void> {
+  await Promise.all(providers.map((provider) => provider.send(webhook)));
 }

apps/web/src/discord/embed-factory.ts

@@ -1,31 +1,26 @@
 import { type Embed, Webhook } from "@vermaysha/discord-webhook";
 
-import { DEFAULT_AVATAR_URL } from "@/consts/discord";
 import { env } from "@/env";
-
-const WEBHOOK_CONFIG = {
-  username: env.DISCORD_WEBHOOK_USERNAME || "Vercord",
-  avatarUrl: env.DISCORD_WEBHOOK_AVATAR_URL || DEFAULT_AVATAR_URL,
-} as const;
+import { DEFAULT_AVATAR_URL } from "./consts";
 
 const RETRY_CONFIG = {
   maxRetries: 3,
   rateLimitDelay: 5000,
   backoffMultiplier: 1000,
 } as const;
 
-export async function sendWebhook(embed: Embed): Promise<void> {
+export async function sendEmbed(embed: Embed): Promise<void> {
   const hook = new Webhook(env.DISCORD_WEBHOOK_URL);
-  hook.setUsername(WEBHOOK_CONFIG.username);
-  hook.setAvatarUrl(WEBHOOK_CONFIG.avatarUrl);
+  hook.setUsername(env.DISCORD_WEBHOOK_USERNAME || "Vercord");
+  hook.setAvatarUrl(env.DISCORD_WEBHOOK_AVATAR_URL || DEFAULT_AVATAR_URL);
   hook.addEmbed(embed);
 
   await sendWithRetry(hook);
 }
 
 async function sendWithRetry(hook: Webhook, attempt = 0): Promise<void> {
   if (attempt >= RETRY_CONFIG.maxRetries) {
-    throw new Error("Maximum retry attempts reached");
+    throw new Error("Discord: maximum retry attempts reached");
   }
 
   try {

apps/web/src/lib/notify.ts

@@ -0,0 +1,113 @@
+import type { WebhookType } from "@/schemas/vercel";
+import type { StateProperty } from "./types";
+
+export const DEFAULT_AVATAR_URL =
+  "https://assets.vercel.com/image/upload/front/favicon/vercel/180x180.png" as const;
+
+export const COLORS = {
+  PROMOTED: 0xd9_98_e3,
+  SUCCESS: 0x2e_cc_71,
+  ERROR: 0xe7_4c_3c,
+  CANCELED: 0x95_a5_a6,
+  INFO: 0x34_98_db,
+  PENDING: 0xf1_c4_0f,
+  WARNING: 0xff_98_00,
+  REFUNDED: 0x60_7d_8b,
+  PAID: 0x4c_af_50,
+  CONNECTED: 0x21_96_f3,
+  DISCONNECTED: 0xf4_43_36,
+  CREATED: 0x8b_c3_4a,
+  REMOVED: 0xff_57_22,
+  UPGRADED: 0x9c_27_b0,
+  CONFIRMED: 0x00_bc_d4,
+} as const;
+
+export const EMOJIS = {
+  PROMOTED: "🔗",
+  SUCCESS: "✅",
+  ERROR: "❌",
+  CANCELED: "🚫",
+  PENDING: "⏳",
+  BRANCH: "🌿",
+  COMMIT: "📝",
+  PROJECT: "📦",
+  DEPLOY: "🚀",
+  REFRESH: "🔄",
+  CLEANUP: "🧹",
+  DOMAIN: "🌐",
+  UPGRADE: "🔼",
+  DISCONNECT: "🔌",
+  CONFIRM: "✅",
+  CONNECT: "🔗",
+  UNLOCK: "🔓",
+  INVOICE: "📝",
+  WARNING: "⚠️",
+  PAYMENT: "💵",
+  MONEY: "💸",
+  NEW: "🆕",
+  TRASH: "🗑️",
+  ENV: "🔗",
+  URL: "🌐",
+  MESSAGE: "💬",
+} as const;
+
+const STATE_MAPPINGS = {
+  color: {
+    "deployment.created": COLORS.PENDING,
+    "deployment.succeeded": COLORS.SUCCESS,
+    "deployment.ready": COLORS.SUCCESS,
+    "deployment.promoted": COLORS.PROMOTED,
+    "deployment.error": COLORS.ERROR,
+    "deployment.canceled": COLORS.CANCELED,
+    "deployment.check-rerequested": COLORS.INFO,
+    "deployment.integration.action.start": COLORS.PENDING,
+    "deployment.integration.action.cancel": COLORS.CANCELED,
+    "deployment.integration.action.cleanup": COLORS.INFO,
+    "domain.created": COLORS.SUCCESS,
+    "integration-configuration.permission-upgraded": COLORS.UPGRADED,
+    "integration-configuration.removed": COLORS.ERROR,
+    "integration-configuration.scope-change-confirmed": COLORS.CONFIRMED,
+    "integration-resource.project-connected": COLORS.CONNECTED,
+    "integration-resource.project-disconnected": COLORS.DISCONNECTED,
+    "marketplace.invoice.created": COLORS.INFO,
+    "marketplace.invoice.notpaid": COLORS.WARNING,
+    "marketplace.invoice.paid": COLORS.PAID,
+    "marketplace.invoice.refunded": COLORS.REFUNDED,
+    "project.created": COLORS.CREATED,
+    "project.removed": COLORS.REMOVED,
+    default: COLORS.INFO,
+  },
+  emoji: {
+    "deployment.created": EMOJIS.PENDING,
+    "deployment.succeeded": EMOJIS.SUCCESS,
+    "deployment.ready": EMOJIS.SUCCESS,
+    "deployment.promoted": EMOJIS.PROMOTED,
+    "deployment.error": EMOJIS.ERROR,
+    "deployment.canceled": EMOJIS.CANCELED,
+    "deployment.check-rerequested": EMOJIS.REFRESH,
+    "deployment.integration.action.start": EMOJIS.PENDING,
+    "deployment.integration.action.cancel": EMOJIS.CANCELED,
+    "deployment.integration.action.cleanup": EMOJIS.CLEANUP,
+    "domain.created": EMOJIS.DOMAIN,
+    "integration-configuration.permission-upgraded": EMOJIS.UPGRADE,
+    "integration-configuration.removed": EMOJIS.DISCONNECT,
+    "integration-configuration.scope-change-confirmed": EMOJIS.CONFIRM,
+    "integration-resource.project-connected": EMOJIS.CONNECT,
+    "integration-resource.project-disconnected": EMOJIS.UNLOCK,
+    "marketplace.invoice.created": EMOJIS.INVOICE,
+    "marketplace.invoice.notpaid": EMOJIS.WARNING,
+    "marketplace.invoice.paid": EMOJIS.PAYMENT,
+    "marketplace.invoice.refunded": EMOJIS.MONEY,
+    "project.created": EMOJIS.NEW,
+    "project.removed": EMOJIS.TRASH,
+    default: EMOJIS.DEPLOY,
+  },
+} as const;
+
+export function getStateProperty(
+  type: WebhookType,
+  property: StateProperty
+): number | string {
+  const mapping = STATE_MAPPINGS[property];
+  return mapping[type as keyof typeof mapping] ?? mapping.default;
+}