feat: leave chat endpoint

Author: lorenzocorallo

package.json

@@ -1,6 +1,6 @@
 {
   "name": "backend",
-  "version": "0.15.16",
+  "version": "0.15.17",
   "description": "PoliNetwork backend server",
   "private": true,
   "keywords": [],

package/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@polinetwork/backend",
-  "version": "0.15.16",
+  "version": "0.15.17",
   "description": "Utils to interact with the backend.",
   "repository": {
     "type": "git",

src/routers/tg/groups.ts

@@ -2,6 +2,7 @@ import { and, eq, ilike, ne, not, or, sql } from "drizzle-orm"
 import { z } from "zod"
 import { DB, SCHEMA } from "@/db"
 import { logger } from "@/logger"
+import { WSS } from "@/server"
 import { createTRPCRouter, publicProcedure } from "@/trpc"
 
 const GROUPS = SCHEMA.TG.groups
@@ -142,4 +143,21 @@ export default createTRPCRouter({
 
       return rows.length === 1
     }),
+
+  leaveChat: publicProcedure
+    .input(
+      z.object({
+        chatId: z.number(),
+        performerId: z.number(),
+      })
+    )
+    .mutation(async ({ input }) => {
+      const left = await WSS.leaveChat(input.chatId)
+      if (!left) return { error: "BOT_ERROR" }
+
+      const rows = await DB.delete(GROUPS).where(eq(GROUPS.telegramId, input.chatId)).returning()
+      if (rows.length === 0) return { error: "NOT_FOUND" }
+
+      return { error: null }
+    }),
 })

src/websocket/index.ts

@@ -97,4 +97,24 @@ export class WebSocketServer {
       })
     })
   }
+
+  async leaveChat(chatId: number, performerId: number) {
+    const sockets = await this.io.fetchSockets()
+    const tgSocket = sockets.find((s) => s.data.type === "telegram")
+    if (!tgSocket) {
+      logger.error("[WS] There is no bot websocket connected, cannot perform logGrantInterrupt")
+      return false
+    }
+
+    return new Promise<boolean>((res) => {
+      tgSocket.emit("leaveChat", { chatId, performerId }, (ok) => {
+        if (!ok) {
+          logger.error({ chatId }, "[WS] Cannot leave the chat")
+          res(false)
+        } else {
+          res(true)
+        }
+      })
+    })
+  }
 }

src/websocket/telegram.ts

@@ -22,6 +22,7 @@ export interface ToClient {
     cb: (error: string | null) => void
   ) => void
   logGrantInterrupt: (data: { userId: number; adminId: number }, cb: (error: string | null) => void) => void
+  leaveChat: (data: { chatId: number; performerId: number }, cb: (ok: boolean) => void) => void
 }
 
 // the telegram bot answers the backend