setChannel.ts

import * as TelegramBot from "node-telegram-bot-api";
import {groupSettings} from "../../../types";
import {setChannelID, setInviteURLChannel} from "../../db";
import langJson from "../assets/langNew.json";
const NodeCache = require( "node-cache" );
const myCache = new NodeCache( { stdTTL: 90, checkperiod: 120 } );
var myBot;
var myQueue;

myCache.on("expired",function(key,value){
    myQueue.add(async () => {try{await myBot.deleteMessage(value, key)}catch{}});
    });
/*
 * /setchannel [public channel name]
 */
const regexp = /\/setchannel/
const regexpFull = /\/setchannel (.+)/

const callback = async (queue: any, db: any, settings: groupSettings, bot: TelegramBot, botId: string, msg: any, match: string[], batchedSend: any) => {
    try {
        if (msg.chat.is_forum)
            return
        if (msg.text.substring(0,14) === "/setchannelfed")
            return
        if (!myBot)
            myBot = bot
        if (!myQueue)
            myQueue = queue
        const newmatch = msg.text.match(regexpFull);
        if (!newmatch || newmatch.length < 2){
            const resp = await queue.add(async () => {try{const val = await bot.sendMessage(msg.chat.id, `${langJson[settings.lang].notifications.set} [DM](https://t.me/${process.env.BOT_USERNAME}?start=helpnotifications) me : )`, {parse_mode: "Markdown", disable_web_page_preview: true})
            return val}catch{}});
            if(!resp)
            return
            myCache.set(resp.message_id, msg.chat.id)
            return; 
        }
        try{
            const channel = await queue.add(async () => {try{const val = await bot.getChat(newmatch[1])
                return val}catch{}});
                if(!channel)
                return
            if(channel.type !== "channel"){
                const resp = await queue.add(async () => {try{const val = await bot.sendMessage(msg.chat.id, langJson[settings.lang].notifications.invalid)
                return val}catch{}});
                if(!resp)
                return
                myCache.set(resp.message_id, msg.chat.id)
                return;
            }
        } catch(e){
            try{
                const resp = await queue.add(async () => {try{const val = await bot.sendMessage(msg.chat.id, `${newmatch[1]} ${langJson[settings.lang].notifications.invalid2}`)
                return val}catch{}});
                if(!resp)
                return
                myCache.set(resp.message_id, msg.chat.id)
            } catch(e){
                console.log(e)
            }
            return;
        }
        const channelUser = await queue.add(async () => {try{const val = await bot.getChatMember(newmatch[1], msg.from.id)
            return val}catch{}});
            if(!channelUser)
            return
        if(channelUser.status !== "administrator" && channelUser.status !== "creator"){
            const resp = await queue.add(async () => {try{const val = await bot.sendMessage(msg.chat.id, langJson[settings.lang].notifications.admin)
            return val}catch{}});
            if(!resp)
            return
            myCache.set(resp.message_id, msg.chat.id)
            return;
        }
        const channelUserSusie = await queue.add(async () => {try{const val = await bot.getChatMember(newmatch[1], Number(botId))
            return val}catch{}});
            if(!channelUserSusie)
            return
        if (channelUserSusie.status !== "administrator"){
            const resp = await queue.add(async () => {try{const val = await bot.sendVideo(msg.chat.id, 'https://cdn.kleros.link/ipfs/QmbnEeVzBjcAnnDKGYJrRo1Lx2FFnG62hYfqx4fLTqYKC7/guide.mp4', {caption: langJson[settings.lang].errorAdminRights})
            return val}catch{}});
            if(!resp)
            return
            myCache.set(resp.message_id, msg.chat.id)
            return;
        }
        if(!channelUserSusie.can_invite_users){
            const resp = await queue.add(async () => {try{const val = await bot.sendMessage(msg.chat.id, langJson[settings.lang].notifications.invite)
            return val}catch{}});
            if(!resp)
            return
            myCache.set(resp.message_id, msg.chat.id)
            return;
        }
        const invite_url_channel = await queue.add(async () => {try{const val = await bot.exportChatInviteLink(newmatch[1])
            return val}catch{}});
            if(!invite_url_channel)
            return
        setInviteURLChannel(db, 'telegram', String(msg.chat.id), invite_url_channel);
        setChannelID(db, 'telegram', String(msg.chat.id), newmatch[1]);
        queue.add(async () => {try{await bot.sendMessage(msg.chat.id, `${langJson[settings.lang].notifications.confirm1}(${invite_url_channel}).`, {parse_mode: "Markdown", disable_web_page_preview: true})}catch{}});
        queue.add(async () => {try{await bot.sendMessage(newmatch[1], `${langJson[settings.lang].notifications.confirm2} ${msg.chat.title}`, {parse_mode: "Markdown"})}catch{}});
    } catch (error) {
        console.log(error);
    }
}

export {regexp, callback};