Chat creation WIP

matushorvath · Oct 1, 2023 · 9a510bf · 9a510bf
1 parent 70f492b
commit 9a510bf
Show file tree

Hide file tree

Showing 3 changed files with 58 additions and 12 deletions.
diff --git a/src/chat.js b/src/chat.js
@@ -3,6 +3,8 @@
 const { TelegramClient } = require('./client');
 const { getTdLibSecrets } = require('./secrets');
 
+const botUserId = 5071613978;
+
 let cachedClient;
 const getTelegramClient = async () => {
     if (cachedClient) {
@@ -28,8 +30,21 @@ const getTelegramClient = async () => {
 const createNewChat = async () => {
     const client = await getTelegramClient();
 
-    const chat = await client.createSupergroup('MH TEST AoC 2001 Day 25', 'MH Test Description');
-    console.log(chat);
+    const { chatId, supergroupId } = await client.createSupergroup('MH TEST AoC 2001 Day 25', 'MH Test Description');
+    console.debug(`createNewChat: Created chat ${chatId} supergroup ${supergroupId}`);
+
+    // TODO mark the chat as created somehow, so we don't repeatedly try to create the same chat over and over
+
+    await client.addChatAdmin(botUserId, chatId);
+    console.debug(`createNewChat: Added bot ${botUserId} as admin to chat ${chatId}`);
+};
+
+const transferChatOwnership = async (_newOwnerUserId) => {
+    const client = await getTelegramClient();
+
+    const result = await client.canTransferChatOwnership();
+    console.debug(result);
 };
 
 exports.createNewChat = createNewChat;
+exports.transferChatOwnership = transferChatOwnership;
diff --git a/src/client.js b/src/client.js
@@ -137,7 +137,7 @@ class TelegramClient {
         let onUpdate;
         return new Promise(resolve => {
             onUpdate = (update) => {
-                //console.debug(JSON.stringify(update, undefined, 2));
+                // console.debug(JSON.stringify(update, undefined, 2));
                 if (filter(update)) {
                     updates.push(update);
                 }
@@ -189,14 +189,12 @@ class TelegramClient {
     }
 
     async createSupergroup(title, description) {
-        const chat = await this.client.invoke({
+        const chat = await this.clientInvoke({
             _: 'createNewSupergroupChat',
             title,
             description
         });
 
-        console.log(chat);
-
         if (chat?._ !== 'chat' || !chat?.id || chat?.type?._ !== 'chatTypeSupergroup' || !chat?.type?.supergroup_id) {
             throw new Error(`Invalid response: ${JSON.stringify(chat)}`);
         }
@@ -271,6 +269,29 @@ class TelegramClient {
         }
     }
 
+    async canTransferChatOwnership() {
+        const result = await this.clientInvoke({
+            _: 'canTransferOwnership'
+        });
+
+        return {
+            canTransfer: result?._ === 'canTransferOwnershipResultOk',
+            result: result?._
+        };
+    }
+
+    async transferChatOwnership(chatId, newOwnerUserId) {
+        const status = await this.clientInvoke({
+            _: 'transferChatOwnership',
+            chat_id: chatId,
+            user_id: newOwnerUserId
+        });
+
+        if (status?._ !== 'ok') {
+            throw new Error(`Invalid response: ${JSON.stringify(status)}`);
+        }
+    }
+
     async setChatDescription(chatId, description) {
         const status = await this.clientInvoke({
             _: 'setChatDescription',

diff --git a/src/message.js b/src/message.js
@@ -5,7 +5,7 @@ const { updateLeaderboards } = require('./leaderboards');
 const { formatBoard } = require('./board');
 const { enableLogs, disableLogs, getLogsStatus, logActivity } = require('./logs');
 const { loadStartTimes } = require('./times');
-const { createNewChat } = require('./chat');
+const { createNewChat, transferChatOwnership } = require('./chat');
 
 const { DynamoDB } = require('@aws-sdk/client-dynamodb');
 const luxon = require('luxon');
@@ -44,8 +44,10 @@ const onMessage = async (message) => {
         await onCommandUpdate(message.chat.id, message.from, params?.trim());
     } else if (command === 'board') {
         await onCommandBoard(message.chat.id, params?.trim());
-    } else if (command === 'tmp') {
-        await onCommandTmp(message.chat.id, params?.trim());
+    } else if (command === 'tmp1') {
+        await onCommandTmp1(message.chat.id, params?.trim());
+    } else if (command === 'tmp2') {
+        await onCommandTmp2(message.chat.id, params?.trim());
     } else if (command === 'start' || command === 'help') {
         await onCommandHelp(message.chat.id);
     } else {
@@ -258,12 +260,20 @@ const onCommandBoard = async (chat, params) => {
 };
 
 // TODO remove
-const onCommandTmp = async (_chat, _params) => {
-    console.log('onCommandTmp: start');
+const onCommandTmp1 = async (_chat, _params) => {
+    console.log('onCommandTmp1: start');
 
     await createNewChat();
 
-    console.log('onCommandTmp: done');
+    console.log('onCommandTmp1: done');
+};
+
+const onCommandTmp2 = async (_chat, _params) => {
+    console.log('onCommandTmp2: start');
+
+    await transferChatOwnership();
+
+    console.log('onCommandTmp2: done');
 };
 
 const onCommandStatus = async (chat, telegramUser) => {