feat: Implement Alarms System backend (#267)

packages/db/src/drizzle/notifications.ts

@@ -0,0 +1,22 @@
+import { alarms } from "@databuddy/db/schema";
+import { eq, and } from "drizzle-orm";
+
+export const sendNotification = async (db: any, websiteId: string, status: string) => {
+  const siteAlarms = await db
+    .select()
+    .from(alarms)
+    .where(
+      and(
+        eq(alarms.websiteId, websiteId),
+        // Условие: проверяем статус внутри JSON triggerConditions
+        eq(alarms.triggerConditions, { status: status }) 
+      )
+    );
+
+  for (const alarm of siteAlarms) {
+    // В консоль для логов сервера
+    console.log(`[Alarm] Site ${websiteId} is ${status}. Notifying: ${alarm.channels.join(", ")}`);
+
+    // Интеграция с провайдерами (Slack/Discord) будет добавлена в следующих итерациях
+  }
+};

packages/db/src/drizzle/schema.ts

@@ -1116,3 +1116,12 @@ export type Feedback = typeof feedback.$inferSelect;
 export type FeedbackInsert = typeof feedback.$inferInsert;
 export type FeedbackRedemption = typeof feedbackRedemptions.$inferSelect;
 export type FeedbackRedemptionInsert = typeof feedbackRedemptions.$inferInsert;
+// --- ALARMS SYSTEM ---
+export const alarms = pgTable("alarms", {
+  id: text("id").primaryKey(), // ID аларма (обычно генерируется через createId)
+  websiteId: text("website_id").notNullable(), // Привязка к сайту
+  channels: jsonb("channels").$type<string[]>().notNullable().default([]), // ['slack', 'discord', 'email']
+  triggerConditions: jsonb("trigger_conditions").notNullable(), // Условия срабатывания
+  createdAt: timestamp("created_at").defaultNow().notNullable(),
+  updatedAt: timestamp("updated_at").defaultNow().notNullable(),
+});

packages/rpc/src/routers/alarms.ts

@@ -0,0 +1,87 @@
+import { z } from "zod";
+import { eq } from "drizzle-orm";
+import { protectedProcedure, router } from "../trpc";
+import { alarms } from "@databuddy/db/schema";
+import { createId } from "@paralleldrive/cuid2";
+
+export const createAlarmSchema = z.object({
+  websiteId: z.string().min(1),
+  channels: z.array(z.enum(["slack", "discord", "email"])).min(1),
+  triggerConditions: z.object({
+    status: z.enum(["down", "up", "degraded"]),
+    durationMinutes: z.number().int().min(1).default(5),
+  }),
+});
+
+export const updateAlarmSchema = z.object({
+  id: z.string().min(1),
+  data: createAlarmSchema.partial(),
+});
+
+export const alarmsRouter = router({
+  list: protectedProcedure
+    .input(z.object({ websiteId: z.string() }))
+    .query(async ({ ctx, input }) => {
+      return await ctx.db
+        .select()
+        .from(alarms)
+        .where(eq(alarms.websiteId, input.websiteId));
+    }),
+
+  get: protectedProcedure
+    .input(z.object({ id: z.string() }))
+    .query(async ({ ctx, input }) => {
+      const result = await ctx.db
+        .select()
+        .from(alarms)
+        .where(eq(alarms.id, input.id))
+        .limit(1);
+
+      if (!result.length) throw new Error("Alarm not found");
+      return result[0];
+    }),
+
+  create: protectedProcedure
+    .input(createAlarmSchema)
+    .mutation(async ({ ctx, input }) => {
+      const newAlarm = await ctx.db
+        .insert(alarms)
+        .values({
+          id: createId(),
+          websiteId: input.websiteId,
+          channels: input.channels,
+          triggerConditions: input.triggerConditions,
+        })
+        .returning();
+
+      return newAlarm[0];
+    }),
+
+  update: protectedProcedure
+    .input(updateAlarmSchema)
+    .mutation(async ({ ctx, input }) => {
+      const updatedAlarm = await ctx.db
+        .update(alarms)
+        .set({
+          ...input.data,
+          updatedAt: new Date(),
+        })
+        .where(eq(alarms.id, input.id))
+        .returning();
+
+      if (!updatedAlarm.length) throw new Error("Alarm not found");
+      return updatedAlarm[0];
+    }),
+
+  delete: protectedProcedure
+    .input(z.object({ id: z.string() }))
+    .mutation(async ({ ctx, input }) => {
+      const deletedAlarm = await ctx.db
+        .delete(alarms)
+        .where(eq(alarms.id, input.id))
+        .returning();
+
+      if (!deletedAlarm.length) throw new Error("Alarm not found");
+      return deletedAlarm[0];
+    }),
+});

packages/rpc/src/routers/uptime.ts

@@ -6,6 +6,7 @@ import { z } from "zod";
 import { rpcError } from "../errors";
 import { protectedProcedure } from "../orpc";
 import { withWorkspace } from "../procedures/with-workspace";
+import { sendNotification } from "../../../db/src/drizzle/notifications";
 
 const client = new Client({ token: process.env.UPSTASH_QSTASH_TOKEN });
 
@@ -406,6 +407,10 @@ export const uptimeRouter = {
 						.set({ isPaused: input.pause, updatedAt: new Date() })
 						.where(eq(uptimeSchedules.id, input.scheduleId)),
 				]);
+
+                // ВЫЗОВ УВЕДОМЛЕНИЯ ПРИ СМЕНЕ СТАТУСА (ПАУЗА/РЕЗЮМЕ)
+                await sendNotification(db, schedule.websiteId ?? "", input.pause ? "paused" : "active");
+
 			} catch (error) {
 				logger.error(
 					{ scheduleId: input.scheduleId, error },
@@ -447,6 +452,9 @@ export const uptimeRouter = {
 						.set({ isPaused: true, updatedAt: new Date() })
 						.where(eq(uptimeSchedules.id, input.scheduleId)),
 				]);
+
+                await sendNotification(db, schedule.websiteId ?? "", "paused");
+
 			} catch (error) {
 				logger.error(
 					{ scheduleId: input.scheduleId, error },
@@ -484,6 +492,9 @@ export const uptimeRouter = {
 						.set({ isPaused: false, updatedAt: new Date() })
 						.where(eq(uptimeSchedules.id, input.scheduleId)),
 				]);
+
+                await sendNotification(db, schedule.websiteId ?? "", "active");
+
 			} catch (error) {
 				logger.error(
 					{ scheduleId: input.scheduleId, error },