chore: test

ubq-testing · Sep 11, 2024 · 5f4ab81 · 5f4ab81
1 parent a1bb81f
commit 5f4ab81
Showing 1 changed file with 24 additions and 17 deletions.
diff --git a/src/bot/mtproto-api/workrooms.ts b/src/bot/mtproto-api/workrooms.ts
@@ -133,7 +133,7 @@ export async function closeChat(context: Context<"issues.closed", SupportedEvent
                 return participant.userId;
             });
 
-            await chats.userSnapshot(chat.chatId, userIDs.map((id) => id.toJSNumber()));
+            // await chats.userSnapshot(chat.chatId, userIDs.map((id) => id.toJSNumber()));
 
             for (let i = 0; i < userIDs.length; i++) {
                 if (userIDs[i].toJSNumber() === context.config.botId) {
@@ -221,26 +221,33 @@ export async function reopenChat(context: Context<"issues.reopened", SupportedEv
 
     await chats.updateChatStatus("reopened", payload.issue.node_id);
 
-    const users = await chats.getChatUsers(chat.chatId);
+    try {
+        const users = await chats.getChatUsers(chat.chatId);
 
-    if (!users) {
-        throw new Error("Failed to get chat users");
-    }
+        if (!users) {
+            throw new Error("Failed to get chat users");
+        }
 
-    const { userIds } = users;
+        const { userIds } = users;
 
-    for (let i = 0; i < userIds.length; i++) {
-        if (userIds[i] === context.config.botId) {
-            continue;
+        console.log("userIds", userIds);
+
+        for (let i = 0; i < userIds.length; i++) {
+            if (userIds[i] === context.config.botId) {
+                continue;
+            }
+            await mtProto.client.invoke(
+                new mtProto.api.messages.AddChatUser({
+                    chatId: chat.chatId,
+                    userId: userIds[i].userId,
+                    fwdLimit: 50,
+                })
+            );
         }
-        await mtProto.client.invoke(
-            new mtProto.api.messages.AddChatUser({
-                chatId: chat.chatId,
-                userId: userIds[i].userId,
-                fwdLimit: 50,
-            })
-        );
-    }
 
+    } catch (er) {
+        logger.error("Failed to add chat users", { er });
+        throw new Error("Failed to add chat users");
+    }
     return { status: 200, reason: "chat_reopened" };
 }