v1
This commit is contained in:
@@ -1,19 +1,14 @@
|
||||
const util = require('util')
|
||||
const crypto = require('crypto')
|
||||
const EventEmitter = require('events')
|
||||
const fs = require('fs')
|
||||
const db = require('../include/db')
|
||||
|
||||
const { Api, TelegramClient } = require('telegram')
|
||||
const { StringSession } = require('telegram/sessions')
|
||||
const { NewMessage } = require('telegram/events')
|
||||
const { Button } = require('telegram/tl/custom/button')
|
||||
const { CustomFile } = require('telegram/client/uploads')
|
||||
|
||||
// const session = new StringSession('1AgAOMTQ5LjE1NC4xNjcuNTABuxdIxmjimA0hmWpdrlZ4Fo7uoIGU4Bu9+G5QprS6zdtyeMfcssWEZp0doLRX/20MomQyF4Opsos0El0Ifj5aiNgg01z8khMLMeT98jS+1U/sh32p3GxZfxyXSxX1bD0NLRaXnqVyNNswYqRZPhboT28NMjDqwlz0nrW9rge+QMJDL7jIkXgSs+cmJBINiqsEI8jWjXmc8TU/17gngtjUHRf5kRM4y5gsNC4O8cF5lcHRx0G/U5ZVihTID8ItQ6EdEHjz6e4XErbVOJ81PfYkqEoPXVvkEmRM0/VbvCzFfixfas4Vzczfn98OHLd8P2MXcgokZ2rppvIV3fQXOHxJbA0=')
|
||||
const session = new StringSession('')
|
||||
|
||||
let session
|
||||
let client
|
||||
let BOT_ID
|
||||
const BOT_NAME = 'ready_or_not_2025_bot'
|
||||
|
||||
function registerUser (telegramId) {
|
||||
db
|
||||
@@ -78,121 +73,125 @@ async function updateUserPhoto (userId, data) {
|
||||
db
|
||||
.prepare(`update users set photo_id = :photo_id, photo = :photo where id = :user_id`)
|
||||
.safeIntegers(true)
|
||||
.run({ user_id: userId, photo_id: photoId, photo: file.toString('base64') })
|
||||
.run({ user_id: userId, photo_id: photoId, photo: 'data:image/jpg;base64,' + file.toString('base64') })
|
||||
}
|
||||
|
||||
async function registerGroup (telegramId, isChannel) {
|
||||
db
|
||||
.prepare(`insert or ignore into groups (telegram_id, is_channel) values (:telegram_id, :is_channel)`)
|
||||
async function registerChat (telegramId, isChannel) {
|
||||
const chat = db
|
||||
.prepare(`select id, name, is_channel, access_hash from chats where telegram_id = :telegram_id`)
|
||||
.safeIntegers(true)
|
||||
.run({ telegram_id: telegramId, is_channel: +isChannel })
|
||||
.get({telegram_id: telegramId})
|
||||
|
||||
const row = db
|
||||
.prepare(`select id, name from groups where telegram_id = :telegram_id`)
|
||||
.safeIntegers(true)
|
||||
.get({telegram_id: telegramId})
|
||||
|
||||
if (!row?.name) {
|
||||
const entity = isChannel ? { channelId: telegramId } : { chatId: telegramId }
|
||||
const group = await client.getEntity(isChannel ? new Api.PeerChannel(entity) : new Api.PeerChat(entity))
|
||||
|
||||
db
|
||||
.prepare(`update groups set name = :name where id = :group_id`)
|
||||
.run({ group_id: row.id, name: group.title })
|
||||
}
|
||||
|
||||
return row.id
|
||||
}
|
||||
|
||||
async function attachGroup(groupId, isChannel, projectId) {
|
||||
const info = db
|
||||
.prepare(`update groups set project_id = :project_id where id = :group_id and coalesce(project_id, 1) = 1`)
|
||||
.run({ group_id: groupId, project_id: projectId })
|
||||
|
||||
if (info.changes == 1) {
|
||||
const inputPeer = isChannel ?
|
||||
new Api.InputPeerChannel({ channelId: tgGroupId }) :
|
||||
new Api.InputPeerChat({ chatlId: tgGroupId })
|
||||
|
||||
const query = `select (select name from customers where id = p.customer_id) || ' >> ' || p.name from projects p where id = :project_id`
|
||||
const message = db
|
||||
.prepare(query)
|
||||
.pluck(true)
|
||||
.get({project_id: projectId})
|
||||
if (message)
|
||||
await client.sendMessage(inputPeer, {message})
|
||||
}
|
||||
|
||||
return info.changes == 1
|
||||
}
|
||||
|
||||
async function onGroupAttach (tgGroupId, isChannel) {
|
||||
const projectId = db
|
||||
.prepare(`select project_id from groups where telegram_id = :telegram_id`)
|
||||
.safeIntegers(true)
|
||||
.pluck(true)
|
||||
.get({ telegram_id: tgGroupId })
|
||||
|
||||
const entity = isChannel ? { channelId: tgGroupId } : { chatId: tgGroupId }
|
||||
const inputPeer = await client.getEntity( isChannel ?
|
||||
if (chat && chat.access_hash && chat.is_channel == isChannel && chat.name)
|
||||
return chat.id
|
||||
|
||||
const entity = isChannel ? { channelId: telegramId } : { chatId: telegramId }
|
||||
const tgChat = await client.getEntity( isChannel ?
|
||||
new Api.InputPeerChannel(entity) :
|
||||
new Api.InputPeerChat(entity)
|
||||
)
|
||||
|
||||
const resultBtn = await client.sendMessage(inputPeer, {
|
||||
message: 'ReadyOrNot',
|
||||
buttons: client.buildReplyMarkup([[Button.url('Открыть проект', 'https://t.me/ready_or_not_2025_bot/userapp?startapp=user_' + projectId)]])
|
||||
|
||||
const chatId = db
|
||||
.prepare(`replace into chats (telegram_id, is_channel, access_hash, name) values (:telegram_id, :is_channel, :access_hash, :name) returning id`)
|
||||
.safeIntegers(true)
|
||||
.pluck(true)
|
||||
.get({
|
||||
telegram_id: telegramId,
|
||||
is_channel: +isChannel,
|
||||
access_hash: tgChat.accessHash.value,
|
||||
name: tgChat.title
|
||||
})
|
||||
|
||||
await updateChat(chatId)
|
||||
|
||||
return chatId
|
||||
}
|
||||
|
||||
async function updateChat (chatId) {
|
||||
const chat = db
|
||||
.prepare(`select id, telegram_id, access_hash, is_channel from chats where id = :id`)
|
||||
.safeIntegers(true)
|
||||
.get({id: chatId})
|
||||
|
||||
const peer = chat.is_channel ?
|
||||
new Api.InputPeerChannel({ channelId: chat.telegram_id, accessHash: chat.access_hash }) :
|
||||
new Api.InputPeerChat({ chatId: chat.telegram_id, accessHash: chat.access_hash })
|
||||
|
||||
const data = chat.is_channel ?
|
||||
await client.invoke(new Api.channels.GetFullChannel({ channel: peer })) :
|
||||
await client.invoke(new Api.messages.GetFullChat({ chatId: chat.telegram_id, accessHash: chat.access_hash }))
|
||||
|
||||
const file = data?.fullChat?.chatPhoto ? await client.downloadFile(new Api.InputPeerPhotoFileLocation({ peer, photoId: data.fullChat.chatPhoto?.id }, {})) : null
|
||||
logo = file ? 'data:image/jpg;base64,' + file.toString('base64') : null
|
||||
|
||||
db
|
||||
.prepare(`update chats set description = :description, logo = :logo, user_count = :user_count, last_update_time = :last_update_time where id = :id`)
|
||||
.safeIntegers(true)
|
||||
.run({
|
||||
id: chatId,
|
||||
description: data.fullChat.about,
|
||||
logo,
|
||||
user_count: data.fullChat.participantsCount - (data.users || []).filter(user => user.bot).length,
|
||||
last_update_time: Math.floor(Date.now() / 1000)
|
||||
})
|
||||
}
|
||||
|
||||
async function attachChat(chatId, projectId) {
|
||||
const chat = db
|
||||
.prepare(`update chats set project_id = :project_id where id = :chat_id returning telegram_id, access_hash, is_channel`)
|
||||
.safeIntegers(true)
|
||||
.get({ chat_id: chatId, project_id: projectId })
|
||||
|
||||
if (!chat.telegram_id)
|
||||
return console.error('Can\'t attach chat: ' + chatId + ' to project: ' + projectId)
|
||||
|
||||
const peer = chat.is_channel ?
|
||||
new Api.InputPeerChannel({ channelId: chat.telegram_id, accessHash: chat.access_hash }) :
|
||||
new Api.InputPeerChat({ chatId: chat.telegram_id, accessHash: chat.access_hash })
|
||||
|
||||
const message = db
|
||||
.prepare(`select (select name from customers where id = p.customer_id) || ' >> ' || p.name from projects p where id = :project_id`)
|
||||
.pluck(true)
|
||||
.get({project_id: projectId})
|
||||
|
||||
const resultBtn = await client.sendMessage(peer, {
|
||||
message,
|
||||
buttons: client.buildReplyMarkup([[Button.url('Открыть проект', `https://t.me/${BOT_NAME}/userapp?startapp=` + projectId)]])
|
||||
})
|
||||
|
||||
await client.invoke(new Api.messages.UpdatePinnedMessage({
|
||||
peer: inputPeer,
|
||||
peer,
|
||||
id: resultBtn.id,
|
||||
unpin: false
|
||||
}))
|
||||
|
||||
//fs.appendFileSync('./1.log', '\n>' + tgGroupId + ':' + isChannel + '<\n')
|
||||
}
|
||||
|
||||
async function reloadGroupUsers(groupId, onlyReset) {
|
||||
async function reloadChatUsers(chatId, onlyReset) {
|
||||
db
|
||||
.prepare(`delete from group_users where group_id = :group_id`)
|
||||
.run({ group_id: groupId })
|
||||
.prepare(`delete from chat_users where chat_id = :chat_id`)
|
||||
.run({ chat_id: chatId })
|
||||
|
||||
if (onlyReset)
|
||||
return
|
||||
|
||||
const group = db
|
||||
.prepare(`select telegram_id, is_channel, access_hash from groups where id = :group_id`)
|
||||
.get({ group_id: groupId})
|
||||
const chat = db
|
||||
.prepare(`select telegram_id, is_channel, access_hash from chats where id = :chat_id`)
|
||||
.get({ chat_id: chatId})
|
||||
|
||||
console.log (123, group)
|
||||
|
||||
if (!group)
|
||||
if (!chat)
|
||||
return
|
||||
|
||||
const tgGroupId = group.telegram_id
|
||||
const isChannel = group.is_channel
|
||||
let accessHash = group.access_hash
|
||||
|
||||
console.log ('HERE')
|
||||
|
||||
db
|
||||
.prepare(`update groups set access_hash = :access_hash where id = :group_id`)
|
||||
.safeIntegers(true)
|
||||
.run({
|
||||
group_id: groupId,
|
||||
access_hash: accessHash,
|
||||
})
|
||||
const tgChatId = chat.telegram_id
|
||||
const isChannel = chat.is_channel
|
||||
const accessHash = chat.access_hash
|
||||
|
||||
const result = isChannel ?
|
||||
await client.invoke(new Api.channels.GetParticipants({
|
||||
channel: new Api.PeerChannel({ channelId: tgGroupId }),
|
||||
channel: new Api.PeerChannel({ channelId: tgChatId, accessHash }),
|
||||
filter: new Api.ChannelParticipantsRecent(),
|
||||
limit: 999999,
|
||||
offset: 0
|
||||
})) : await client.invoke(new Api.messages.GetFullChat({
|
||||
chatId: tgGroupId,
|
||||
}))
|
||||
})) : await client.invoke(new Api.messages.GetFullChat({ chatId: tgChatId, accessHash }))
|
||||
|
||||
const users = result.users.filter(user => !user.bot)
|
||||
for (const user of users) {
|
||||
@@ -201,37 +200,42 @@ async function reloadGroupUsers(groupId, onlyReset) {
|
||||
if (updateUser(userId, user)) {
|
||||
await updateUserPhoto (userId, user)
|
||||
|
||||
const query = `insert or ignore into group_users (group_id, user_id) values (:group_id, :user_id)`
|
||||
db.prepare(query).run({ group_id: groupId, user_id: userId })
|
||||
db
|
||||
.prepare(`insert or ignore into chat_users (chat_id, user_id) values (:chat_id, :user_id)`)
|
||||
.run({ chat_id: chatId, user_id: userId })
|
||||
}
|
||||
}
|
||||
|
||||
db
|
||||
.prepare(`update chats set user_count = (select count(1) from chat_users where chat_id = :chat_id) where id = :chat_id`)
|
||||
.run({ chat_id: chatId})
|
||||
}
|
||||
|
||||
async function registerUpload(data) {
|
||||
if (!data.projectId || !data.media)
|
||||
return false
|
||||
return console.error ('registerUpload: ' + (data.projectId ? 'media' : 'project id') + ' is missing')
|
||||
|
||||
const uploadGroup = db
|
||||
.prepare(`
|
||||
select id, telegram_id, project_id, is_channel, access_hash
|
||||
from groups
|
||||
where id = (select upload_group_id
|
||||
from customers
|
||||
where id = (select customer_id from projects where id = :project_id limit 1)
|
||||
limit 1)
|
||||
limit 1
|
||||
`)
|
||||
.safeIntegers(true)
|
||||
const customer_id = db
|
||||
.prepare(`select customer_id from projects where project_id = :project_id`)
|
||||
.pluck(true)
|
||||
.get({project_id: data.projectId})
|
||||
|
||||
if (!uploadGroup || !uploadGroup.telegram_id || uploadGroup.id == data.originGroupId)
|
||||
return false
|
||||
if (!customer_id)
|
||||
return console.error ('registerUpload: The customer is not found for project: ' + data.projectId)
|
||||
|
||||
const tgUploadGroupId = uploadGroup.telegram_id
|
||||
const chat = db
|
||||
.prepare(
|
||||
`select id, telegram_id, project_id, is_channel, access_hash from chats
|
||||
where id = (select upload_chat_id from customers where id = :customer_id`)
|
||||
.safeIntegers(true)
|
||||
.get({ customer_id })
|
||||
|
||||
const peer = uploadGroup.is_channel ?
|
||||
new Api.PeerChannel({ channelId: tgUploadGroupId }) :
|
||||
new Api.PeerChat({ chatlId: tgUploadGroupId })
|
||||
if (!chat || !chat.telegram_id || chat.id == data.originchatId)
|
||||
return console.error ('registerUpload: The upload chat is not set for customer: ' + customer_id)
|
||||
|
||||
const peer = chat.is_channel ?
|
||||
new Api.PeerChannel({ channelId: chat.telegram_id, accessHash: chat.access_hash }) :
|
||||
new Api.PeerChat({ chatlId: chat.telegram_id, accessHash: chat.access_hash })
|
||||
|
||||
let resultId = 0
|
||||
|
||||
@@ -247,26 +251,26 @@ async function registerUpload(data) {
|
||||
const update = result.updates.find(u =>
|
||||
(u.className == 'UpdateNewMessage' || u.className == 'UpdateNewChannelMessage') &&
|
||||
u.message.className == 'Message' &&
|
||||
(u.message.peerId.channelId?.value == tgUploadGroupId || u.message.peerId.chatId?.value == tgUploadGroupId) &&
|
||||
(u.message.peerId.channelId?.value == chat.telegram_id || u.message.peerId.chatId?.value == chat.telegram_id) &&
|
||||
u.message.media)
|
||||
|
||||
const udoc = update?.message?.media?.document
|
||||
if (udoc) {
|
||||
resultId = db
|
||||
.prepare(`
|
||||
insert into documents (project_id, origin_group_id, origin_message_id, group_id, message_id,
|
||||
file_id, access_hash, filename, mime, caption, size, published_by, parent_type, parent_id)
|
||||
values (:project_id, :origin_group_id, :origin_message_id, :group_id, :message_id,
|
||||
:file_id, :access_hash, :filename, :mime, :caption, :size, :published_by, :parent_type, :parent_id)
|
||||
insert into files (project_id, origin_chat_id, origin_message_id, chat_id, message_id,
|
||||
file_id, access_hash, filename, mime, caption, size, published_by, published, parent_type, parent_id)
|
||||
values (:project_id, :origin_chat_id, :origin_message_id, :chat_id, :message_id,
|
||||
:file_id, :access_hash, :filename, :mime, :caption, :size, :published_by, :published, :parent_type, :parent_id)
|
||||
returning id
|
||||
`)
|
||||
.safeIntegers(true)
|
||||
.pluck(true)
|
||||
.get({
|
||||
project_id: data.projectId,
|
||||
origin_group_id: data.originGroupId,
|
||||
origin_chat_id: data.originchatId,
|
||||
origin_message_id: data.originMessageId,
|
||||
group_id: uploadGroup.id,
|
||||
chat_id: chat.id,
|
||||
message_id: update.message.id,
|
||||
file_id: udoc.id.value,
|
||||
filename: udoc.attributes.find(attr => attr.className == 'DocumentAttributeFilename')?.fileName,
|
||||
@@ -275,14 +279,15 @@ async function registerUpload(data) {
|
||||
caption: data.caption,
|
||||
size: udoc.size.value,
|
||||
published_by: data.publishedBy,
|
||||
published: data.published,
|
||||
parent_type: data.parentType,
|
||||
parent_id: data.parentId
|
||||
})
|
||||
}
|
||||
|
||||
} catch (err) {
|
||||
fs.appendFileSync('./1.log', '\n\nERR:' + err.message + ':' + JSON.stringify (err.stack)+'\n\n')
|
||||
console.error('Message.registerUpload: ' + err.message)
|
||||
//fs.appendFileSync('./1.log', '\n\nERR:' + err.message + ':' + JSON.stringify (err.stack)+'\n\n')
|
||||
console.error('registerUpload: ' + err.message)
|
||||
}
|
||||
|
||||
return resultId
|
||||
@@ -290,14 +295,14 @@ async function registerUpload(data) {
|
||||
|
||||
async function onNewServiceMessage (msg, isChannel) {
|
||||
const action = msg.action || {}
|
||||
const tgGroupId = isChannel ? msg.peerId?.channelId?.value : msg.peerId?.chatId?.value
|
||||
const groupId = await registerGroup(tgGroupId, isChannel)
|
||||
const tgChatId = isChannel ? msg.peerId?.channelId?.value : msg.peerId?.chatId?.value
|
||||
const chatId = await registerChat(tgChatId, isChannel)
|
||||
|
||||
// Group/Channel rename
|
||||
// Сhat rename
|
||||
if (action.className == 'MessageActionChatEditTitle') {
|
||||
const info = db
|
||||
.prepare(`
|
||||
update groups
|
||||
update chats
|
||||
set name = :name, is_channel = :is_channel, last_update_time = :last_update_time
|
||||
where telegram_id = :telegram_id
|
||||
`)
|
||||
@@ -306,15 +311,18 @@ async function onNewServiceMessage (msg, isChannel) {
|
||||
name: action.title,
|
||||
is_channel: +isChannel,
|
||||
last_update_time: Math.floor (Date.now() / 1000),
|
||||
telegram_id: tgGroupId
|
||||
telegram_id: tgChatId
|
||||
})
|
||||
|
||||
if (info.changes == 0)
|
||||
console.error('onNewServiceMessage: Can\'t update a chat title: ' + tgChatId)
|
||||
}
|
||||
|
||||
// Chat to Channel
|
||||
if (action.className == 'MessageActionChatMigrateTo') {
|
||||
const info = db
|
||||
.prepare(`
|
||||
update groups
|
||||
update chats
|
||||
set telegram_id = :new_telegram_id, name = :name, is_channel = 1, last_update_time = :last_update_time
|
||||
where telegram_id = :old_telegram_id
|
||||
`)
|
||||
@@ -322,9 +330,12 @@ async function onNewServiceMessage (msg, isChannel) {
|
||||
.run({
|
||||
name: action.title,
|
||||
last_update_time: Date.now() / 1000,
|
||||
old_telegram_id: tgGroupId,
|
||||
old_telegram_id: tgChatId,
|
||||
new_telegram_id: action.channelId.value
|
||||
})
|
||||
|
||||
if (info.changes == 0)
|
||||
console.error('onNewServiceMessage: Can\'t apply a chat migration to channel: ' + tgChatId)
|
||||
}
|
||||
|
||||
// User/s un/register
|
||||
@@ -335,7 +346,7 @@ async function onNewServiceMessage (msg, isChannel) {
|
||||
const tgUserIds = [action.user, action.users, action.userId].flat().filter(Boolean).map(e => BigInt(e.value))
|
||||
const isAdd = action.className == 'MessageActionChatAddUser' || action.className == 'MessageActionChannelAddUser'
|
||||
|
||||
if (tgUserIds.indexOf(bot.id) == -1) {
|
||||
if (tgUserIds.indexOf(BOT_ID) == -1) {
|
||||
// Add/remove non-bot users
|
||||
for (const tgUserId of tgUserIds) {
|
||||
const userId = registerUser(tgUserId)
|
||||
@@ -351,27 +362,29 @@ async function onNewServiceMessage (msg, isChannel) {
|
||||
}
|
||||
|
||||
const query = isAdd ?
|
||||
`insert or ignore into group_users (group_id, user_id) values (:group_id, :user_id)` :
|
||||
`delete from group_users where group_id = :group_id and user_id = :user_id`
|
||||
db.prepare(query).run({ group_id: groupId, user_id: userId })
|
||||
`insert or ignore into chat_users (chat_id, user_id) values (:chat_id, :user_id)` :
|
||||
`delete from chat_users where chat_id = :chat_id and user_id = :user_id`
|
||||
db
|
||||
.prepare(query)
|
||||
.run({ chat_id: chatId, user_id: userId })
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
async function onNewMessage (msg, isChannel) {
|
||||
const tgGroupId = isChannel ? msg.peerId?.channelId?.value : msg.peerId?.chatId?.value
|
||||
const groupId = await registerGroup(tgGroupId, isChannel)
|
||||
const tgChatId = isChannel ? msg.peerId?.channelId?.value : msg.peerId?.chatId?.value
|
||||
const chatId = await registerChat(tgChatId, isChannel)
|
||||
|
||||
// Document is detected
|
||||
if (msg.media?.document) {
|
||||
const doc = msg.media.document
|
||||
|
||||
const projectId = db
|
||||
.prepare(`select project_id from groups where telegram_id = :telegram_id`)
|
||||
.prepare(`select project_id from chats where telegram_id = :telegram_id`)
|
||||
.safeIntegers(true)
|
||||
.pluck(true)
|
||||
.get({telegram_id: tgGroupId})
|
||||
.get({telegram_id: tgChatId})
|
||||
|
||||
const media = new Api.InputMediaDocument({
|
||||
id: new Api.InputDocument({
|
||||
@@ -385,101 +398,55 @@ async function onNewMessage (msg, isChannel) {
|
||||
projectId,
|
||||
media,
|
||||
caption: msg.message,
|
||||
originGroupId: groupId,
|
||||
originchatId: chatId,
|
||||
originMessageId: msg.id,
|
||||
parentType: 0,
|
||||
publishedBy: registerUser (msg.fromId?.userId?.value)
|
||||
publishedBy: registerUser (msg.fromId?.userId?.value),
|
||||
published: msg.date
|
||||
})
|
||||
}
|
||||
|
||||
if (msg.message?.startsWith('KEY-')) {
|
||||
let projectName = db
|
||||
if (msg.message?.startsWith(`/start@${BOT_NAME} KEY-`) || msg.message?.startsWith('KEY-')) {
|
||||
const rows = db
|
||||
.prepare(`
|
||||
select name
|
||||
from projects
|
||||
where id in (
|
||||
select project_id from groups where id = :group_id
|
||||
union
|
||||
select id from projects where upload_group_id = :group_id)
|
||||
select 1 from chats where id = :chat_id and project_id is not null
|
||||
union all
|
||||
select 1 from customers where upload_chat_id = :chat_id
|
||||
`)
|
||||
.pluck(true)
|
||||
.get({ group_id: groupId })
|
||||
.all({ chat_id: chatId })
|
||||
|
||||
if (projectName)
|
||||
return await bot.sendMessage(groupId, 'Группа уже используется на проекте ' + projectName)
|
||||
if (rows.length)
|
||||
return await sendMessage(chatId, 'Чат уже используется')
|
||||
|
||||
const [_, time64, key] = msg.message.substr(3).split('-')
|
||||
const rawkey = msg.message.substr(msg.message?.indexOf('KEY-'))
|
||||
const [_, time64, key] = rawkey.split('-')
|
||||
const now = Math.floor(Date.now() / 1000)
|
||||
const time = Buffer.from(time64, 'base64')
|
||||
|
||||
if (now - 3600 >= time && time >= now)
|
||||
return await bot.sendMessage(groupId, 'Время действия ключа для привязки истекло')
|
||||
return await sendMessage(chatId, 'Время действия ключа для привязки истекло')
|
||||
|
||||
const projectId = db
|
||||
.prepare(`select id from projects where generate_key(id, :time) = :key`)
|
||||
.pluck(true)
|
||||
.get({ key: msg.message.trim(), time })
|
||||
|
||||
if (projectId) {
|
||||
await attachGroup(groupId, isChannel, projectId)
|
||||
await onGroupAttach(tgGroupId, isChannel)
|
||||
const row = db
|
||||
.prepare(`
|
||||
select (select id from projects where generate_key(id, :time) = :rawkey) project_id,
|
||||
(select id from customers where generate_key(-id, :time) = :rawkey) customer_id
|
||||
`)
|
||||
.get({ rawkey, time })
|
||||
|
||||
if (row.project_id) {
|
||||
await attachChat(chatId, row.project_id)
|
||||
await reloadChatUsers(chatId)
|
||||
}
|
||||
}
|
||||
|
||||
if (msg.message?.startsWith('/start')) {
|
||||
// Called by https://t.me/ready_or_not_2025_bot?startgroup=<customer_id/project_id>
|
||||
if (/start@ready_or_not_2025_bot (-|)([\d]+)$/g.test(msg.message)) {
|
||||
const tgUserId = msg.fromId?.userId?.value
|
||||
const param = +msg.message.split(' ')[1]
|
||||
|
||||
// Set upload group for customer
|
||||
if (param < 0) {
|
||||
const customerId = -param
|
||||
if (row.customer_id) {
|
||||
const info = db
|
||||
.prepare(`update customers set upload_chat_id = :chat_id where id = :customer_id`)
|
||||
.safeIntegers(true)
|
||||
.run({ customer_id: row.customer_id, chat_id: chatId })
|
||||
|
||||
db
|
||||
.prepare(`
|
||||
update customers
|
||||
set upload_group_id = :group_id
|
||||
where id = :customer_id and telegram_user_id = :telegram_user_id
|
||||
`)
|
||||
.safeIntegers(true)
|
||||
.run({
|
||||
group_id: groupId,
|
||||
customer_id: customerId,
|
||||
telegram_user_id: tgUserId
|
||||
})
|
||||
}
|
||||
|
||||
// Add group to project
|
||||
if (param > 0) {
|
||||
const projectId = param
|
||||
|
||||
const customerId = db
|
||||
.prepare(`select customer_id from projects where id = :project_id`)
|
||||
.pluck(true)
|
||||
.get({project_id: projectId})
|
||||
|
||||
db
|
||||
.prepare(`
|
||||
update groups
|
||||
set project_id = :project_id
|
||||
where id = :group_id and exists(
|
||||
select 1
|
||||
from customers
|
||||
where id = :customer_id and telegram_user_id = :telegram_user_id)
|
||||
`)
|
||||
.safeIntegers(true)
|
||||
.run({
|
||||
project_id: projectId,
|
||||
group_id: groupId,
|
||||
customer_id: customerId,
|
||||
telegram_user_id: tgUserId
|
||||
})
|
||||
|
||||
await reloadGroupUsers(groupId, false)
|
||||
await onGroupAttach(tgGroupId, isChannel)
|
||||
}
|
||||
}
|
||||
if (info.changes == 0)
|
||||
console.error('Can\'t set upload chat: ' + chatId + ' to customer: ' + row.customer_id)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -493,12 +460,19 @@ async function onNewUserMessage (msg) {
|
||||
updateUser(userId, user)
|
||||
await updateUserPhoto (userId, user)
|
||||
|
||||
const appButton = new Api.KeyboardButtonWebView({
|
||||
text: "Open Mini-App", // Текст на кнопке
|
||||
url: "https://h5sj0gpz-3000.euw.devtunnels.ms/", // URL вашего Mini-App (HTTPS!)
|
||||
});
|
||||
|
||||
|
||||
const inputPeer = new Api.InputPeerUser({userId: tgUserId, accessHash: user.accessHash.value})
|
||||
const resultBtn = await client.sendMessage(inputPeer, {
|
||||
await client.sendMessage(inputPeer, {
|
||||
message: 'Сообщение от бота',
|
||||
buttons: client.buildReplyMarkup([
|
||||
[Button.url('Админка', 'https://t.me/ready_or_not_2025_bot/userapp?startapp=admin')],
|
||||
[Button.url('Пользователь', 'https://t.me/ready_or_not_2025_bot/userapp?startapp=user')]
|
||||
[Button.url('Админка', `https://t.me/${BOT_NAME}/userapp?startapp=admin`)],
|
||||
[Button.url('Пользователь', `https://t.me/${BOT_NAME}/userapp?startapp=user`)],
|
||||
[appButton]
|
||||
])
|
||||
})
|
||||
} catch (err) {
|
||||
@@ -508,41 +482,125 @@ async function onNewUserMessage (msg) {
|
||||
}
|
||||
|
||||
async function onUpdatePaticipant (update, isChannel) {
|
||||
const tgGroupId = isChannel ? update.channelId?.value : update.chatlId?.value
|
||||
if (!tgGroupId || update.userId?.value != bot.id)
|
||||
const tgChatId = isChannel ? update.channelId?.value : update.chatlId?.value
|
||||
if (!tgChatId || update.userId?.value != BOT_ID)
|
||||
return
|
||||
|
||||
const groupId = await registerGroup (tgGroupId, isChannel)
|
||||
const chatId = await registerChat (tgChatId, isChannel)
|
||||
|
||||
const isBan = update.prevParticipant && !update.newParticipant
|
||||
const isAdd = (!update.prevParticipant || update.prevParticipant?.className == 'ChannelParticipantBanned') && update.newParticipant
|
||||
|
||||
if (isBan || isAdd)
|
||||
await reloadGroupUsers(groupId, isBan)
|
||||
await reloadChatUsers(chatId, isBan)
|
||||
|
||||
if (isBan) {
|
||||
db
|
||||
.prepare(`update groups set project_id = null where id = :group_id`)
|
||||
.run({group_id: groupId})
|
||||
.prepare(`update chats set project_id = null where id = :chat_id`)
|
||||
.run({chat_id: chatId})
|
||||
}
|
||||
|
||||
const botCanBan = update.newParticipant?.adminRights?.banUsers || 0
|
||||
db
|
||||
.prepare(`update groups set bot_can_ban = :bot_can_ban where id = :group_id`)
|
||||
.run({group_id: groupId, bot_can_ban: +botCanBan})
|
||||
.prepare(`update chats set bot_can_ban = :bot_can_ban where id = :chat_id`)
|
||||
.run({chat_id: chatId, bot_can_ban: +botCanBan})
|
||||
}
|
||||
|
||||
class Bot extends EventEmitter {
|
||||
|
||||
async start (apiId, apiHash, botAuthToken) {
|
||||
this.id = 7236504417n
|
||||
async function uploadFile(projectId, fileName, mime, data, parentType, parentId, publishedBy) {
|
||||
const file = await client.uploadFile({ file: new CustomFile(fileName, data.length, '', data), workers: 1 })
|
||||
|
||||
client = new TelegramClient(session, apiId, apiHash, {})
|
||||
const media = new Api.InputMediaUploadedDocument({
|
||||
file,
|
||||
mimeType: mime,
|
||||
attributes: [new Api.DocumentAttributeFilename({ fileName })]
|
||||
})
|
||||
|
||||
client.addEventHandler(async (update) => {
|
||||
if (update.className == 'UpdateConnectionState')
|
||||
return
|
||||
return await registerUpload({
|
||||
projectId,
|
||||
media,
|
||||
parentType,
|
||||
parentId,
|
||||
publishedBy,
|
||||
published: Math.floor(Date.now() / 1000)
|
||||
})
|
||||
}
|
||||
|
||||
async function downloadFile(projectId, fileId) {
|
||||
const file = db
|
||||
.prepare(`
|
||||
select file_id, access_hash, '' thumbSize, filename, mime
|
||||
from files where id = :id and project_id = :project_id
|
||||
`)
|
||||
.safeIntegers(true)
|
||||
.get({project_id: projectId, id: fileId})
|
||||
|
||||
if (!file)
|
||||
return false
|
||||
|
||||
const result = await client.downloadFile(new Api.InputDocumentFileLocation({
|
||||
id: file.file_id,
|
||||
accessHash: file.access_hash,
|
||||
fileReference: Buffer.from(file.filename),
|
||||
thumbSize: ''
|
||||
}, {}))
|
||||
|
||||
return {
|
||||
filename: file.filename,
|
||||
mime: file.mime,
|
||||
size: result.length,
|
||||
data: result
|
||||
}
|
||||
}
|
||||
|
||||
async function sendMessage (chatId, message) {
|
||||
const chat = db
|
||||
.prepare(`select telegram_id, is_channel from chats where id = :chat_id`)
|
||||
.get({ chat_id: chatId})
|
||||
|
||||
if (!chat)
|
||||
return
|
||||
|
||||
const entity = chat.is_channel ? { channelId: chat.telegram_id } : { chatId: chat.telegram_id }
|
||||
const inputPeer = await client.getEntity( chat.is_channel ?
|
||||
new Api.InputPeerChannel(entity) :
|
||||
new Api.InputPeerChat(entity)
|
||||
)
|
||||
|
||||
await client.sendMessage(inputPeer, {message})
|
||||
|
||||
const delay = ms => new Promise(resolve => setTimeout(resolve, ms))
|
||||
await delay(1000)
|
||||
}
|
||||
|
||||
async function leaveChat (chatId) {
|
||||
const chat = db
|
||||
.prepare(`select telegram_id, access_hash, is_channel from chats where id = :chat_id`)
|
||||
.get({ chat_id: chatId})
|
||||
|
||||
if (!chat)
|
||||
return
|
||||
|
||||
if (chat.is_channel) {
|
||||
const inputPeer = await client.getEntity(new Api.InputPeerChannel({ channelId: chat.telegram_id, accessHash: chat.access_hash }))
|
||||
await client.invoke(new Api.channels.LeaveChannel({ channel: inputPeer }))
|
||||
} else {
|
||||
await client.invoke(new Api.messages.DeleteChatUser({ chatId: chat.telegram_id, userId: this.id, accessHash: chat.access_hash }))
|
||||
}
|
||||
}
|
||||
|
||||
async function start (apiId, apiHash, botAuthToken, sid) {
|
||||
BOT_ID = BigInt(botAuthToken.split(':')[0])
|
||||
|
||||
session= new StringSession(sid || '')
|
||||
client = new TelegramClient(session, apiId, apiHash, {})
|
||||
|
||||
client.addEventHandler(async (update) => {
|
||||
if (update.className == 'UpdateConnectionState')
|
||||
return
|
||||
|
||||
try {
|
||||
// console.log(update)
|
||||
|
||||
if (update.className == 'UpdateNewMessage' || update.className == 'UpdateNewChannelMessage') {
|
||||
const msg = update?.message
|
||||
const isChannel = update.className == 'UpdateNewChannelMessage'
|
||||
@@ -557,98 +615,13 @@ class Bot extends EventEmitter {
|
||||
|
||||
if (update.className == 'UpdateChatParticipant' || update.className == 'UpdateChannelParticipant')
|
||||
await onUpdatePaticipant(update, update.className == 'UpdateChannelParticipant')
|
||||
})
|
||||
|
||||
await client.start({botAuthToken})
|
||||
}
|
||||
|
||||
async uploadDocument(projectId, fileName, mime, data, parentType, parentId, publishedBy) {
|
||||
const file = await client.uploadFile({ file: new CustomFile(fileName, data.length, '', data), workers: 1 })
|
||||
|
||||
const media = new Api.InputMediaUploadedDocument({
|
||||
file,
|
||||
mimeType: mime,
|
||||
attributes: [new Api.DocumentAttributeFilename({ fileName })]
|
||||
})
|
||||
|
||||
return await registerUpload({
|
||||
projectId,
|
||||
media,
|
||||
parentType,
|
||||
parentId,
|
||||
publishedBy
|
||||
})
|
||||
}
|
||||
|
||||
async downloadDocument(projectId, documentId) {
|
||||
const document = db
|
||||
.prepare(`
|
||||
select file_id, access_hash, '' thumbSize, filename, mime
|
||||
from documents where id = :document_id and project_id = :project_id
|
||||
`)
|
||||
.safeIntegers(true)
|
||||
.get({project_id: projectId, document_id: documentId})
|
||||
|
||||
if (!document)
|
||||
return false
|
||||
|
||||
const result = await client.downloadFile(new Api.InputDocumentFileLocation({
|
||||
id: document.file_id,
|
||||
accessHash: document.access_hash,
|
||||
fileReference: Buffer.from(document.filename),
|
||||
thumbSize: ''
|
||||
}, {}))
|
||||
|
||||
return {
|
||||
filename: document.filename,
|
||||
mime: document.mime,
|
||||
size: result.length,
|
||||
data: result
|
||||
} catch (err) {
|
||||
console.error(err)
|
||||
}
|
||||
}
|
||||
})
|
||||
|
||||
async reloadGroupUsers(groupId, onlyReset) {
|
||||
return reloadGroupUsers(groupId, onlyReset)
|
||||
}
|
||||
await client.start({botAuthToken})
|
||||
}
|
||||
|
||||
async sendMessage (groupId, message) {
|
||||
const group = db
|
||||
.prepare(`select telegram_id, is_channel from groups where id = :group_id`)
|
||||
.get({ group_id: groupId})
|
||||
|
||||
if (!group)
|
||||
return
|
||||
|
||||
const entity = group.is_channel ? { channelId: group.telegram_id } : { chatId: group.telegram_id }
|
||||
const inputPeer = await client.getEntity( group.is_channel ?
|
||||
new Api.InputPeerChannel(entity) :
|
||||
new Api.InputPeerChat(entity)
|
||||
)
|
||||
|
||||
await client.sendMessage(inputPeer, {message})
|
||||
|
||||
const delay = ms => new Promise(resolve => setTimeout(resolve, ms))
|
||||
await delay(1000)
|
||||
}
|
||||
|
||||
async leaveGroup (groupId) {
|
||||
const group = db
|
||||
.prepare(`select telegram_id, is_channel from groups where id = :group_id`)
|
||||
.get({ group_id: groupId})
|
||||
|
||||
if (!group)
|
||||
return
|
||||
|
||||
if (group.is_channel) {
|
||||
const inputPeer = await client.getEntity(new Api.InputPeerChannel({ channelId: group.telegram_id }))
|
||||
await client.invoke(new Api.channels.LeaveChannel({ channel: inputPeer }))
|
||||
} else {
|
||||
await client.invoke(new Api.messages.DeleteChatUser({ chatId: group.telegram_id, userId: this.id }))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
const bot = new Bot()
|
||||
|
||||
module.exports = bot
|
||||
module.exports = { start, uploadFile, downloadFile, reloadChatUsers, sendMessage }
|
||||
|
||||
|
||||
Reference in New Issue
Block a user