Описание изменений
This commit is contained in:
@@ -206,6 +206,46 @@ class AuthService {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Получает все идентификаторы пользователя
|
||||
* @param {number} userId - ID пользователя
|
||||
* @returns {Promise<Array>} - Список идентификаторов
|
||||
*/
|
||||
async getAllUserIdentities(userId) {
|
||||
try {
|
||||
const result = await db.query(`
|
||||
SELECT identity_type, identity_value, verified, created_at
|
||||
FROM user_identities
|
||||
WHERE user_id = $1
|
||||
`, [userId]);
|
||||
|
||||
return result.rows;
|
||||
} catch (error) {
|
||||
logger.error(`Error getting user identities: ${error.message}`);
|
||||
return [];
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Проверяет, является ли пользователь администратором
|
||||
* @param {number} userId - ID пользователя
|
||||
* @returns {Promise<boolean>} - Является ли пользователь администратором
|
||||
*/
|
||||
async isAdmin(userId) {
|
||||
try {
|
||||
const result = await db.query('SELECT is_admin FROM users WHERE id = $1', [userId]);
|
||||
|
||||
if (result.rows.length === 0) {
|
||||
return false;
|
||||
}
|
||||
|
||||
return result.rows[0].is_admin;
|
||||
} catch (error) {
|
||||
logger.error(`Error checking admin status: ${error.message}`);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = new AuthService();
|
||||
@@ -3,6 +3,11 @@ const nodemailer = require('nodemailer');
|
||||
const Imap = require('imap');
|
||||
const simpleParser = require('mailparser').simpleParser;
|
||||
const { processMessage } = require('./ai-assistant');
|
||||
const { inspect } = require('util');
|
||||
const logger = require('../utils/logger');
|
||||
|
||||
// Хранилище кодов подтверждения
|
||||
const verificationCodes = new Map(); // { email: { code, token, expires } }
|
||||
|
||||
// Конфигурация для отправки писем
|
||||
const transporter = nodemailer.createTransport({
|
||||
@@ -13,6 +18,9 @@ const transporter = nodemailer.createTransport({
|
||||
user: process.env.EMAIL_USER,
|
||||
pass: process.env.EMAIL_PASSWORD,
|
||||
},
|
||||
tls: {
|
||||
rejectUnauthorized: false // Отключение проверки сертификата
|
||||
}
|
||||
});
|
||||
|
||||
// Конфигурация для получения писем
|
||||
@@ -25,222 +33,307 @@ const imapConfig = {
|
||||
tlsOptions: { rejectUnauthorized: false },
|
||||
};
|
||||
|
||||
/**
|
||||
* Инициализация сервиса электронной почты
|
||||
*/
|
||||
function initEmailBot() {
|
||||
if (!process.env.EMAIL_USER || !process.env.EMAIL_PASSWORD) {
|
||||
console.warn('EMAIL_USER or EMAIL_PASSWORD not set, Email integration disabled');
|
||||
return null;
|
||||
class EmailBotService {
|
||||
constructor(user, password) {
|
||||
this.user = user;
|
||||
this.password = password;
|
||||
this.transporter = null;
|
||||
this.imap = null;
|
||||
this.initialize();
|
||||
this.listenForReplies();
|
||||
}
|
||||
|
||||
console.log('Email bot initialized');
|
||||
|
||||
// Запуск проверки почты каждые 5 минут
|
||||
const checkInterval = 5 * 60 * 1000; // 5 минут
|
||||
setInterval(checkEmails, checkInterval);
|
||||
|
||||
// Первая проверка при запуске
|
||||
checkEmails();
|
||||
|
||||
return {
|
||||
sendEmail,
|
||||
checkEmails,
|
||||
};
|
||||
}
|
||||
|
||||
/**
|
||||
* Проверка новых писем
|
||||
*/
|
||||
function checkEmails() {
|
||||
const imap = new Imap(imapConfig);
|
||||
|
||||
imap.once('ready', () => {
|
||||
imap.openBox('INBOX', false, (err, box) => {
|
||||
if (err) {
|
||||
console.error('Error opening inbox:', err);
|
||||
return;
|
||||
initialize() {
|
||||
// Настройка транспорта
|
||||
this.transporter = nodemailer.createTransport({
|
||||
host: process.env.EMAIL_SMTP_HOST,
|
||||
port: process.env.EMAIL_SMTP_PORT,
|
||||
secure: true,
|
||||
auth: {
|
||||
user: this.user,
|
||||
pass: this.password
|
||||
}
|
||||
});
|
||||
|
||||
// Поиск непрочитанных писем
|
||||
imap.search(['UNSEEN'], (err, results) => {
|
||||
if (err) {
|
||||
console.error('Error searching emails:', err);
|
||||
return;
|
||||
// Настройка IMAP для чтения входящих писем
|
||||
this.imap = new Imap({
|
||||
user: this.user,
|
||||
password: this.password,
|
||||
host: process.env.EMAIL_IMAP_HOST,
|
||||
port: process.env.EMAIL_IMAP_PORT,
|
||||
tls: true,
|
||||
tlsOptions: { rejectUnauthorized: false }
|
||||
});
|
||||
|
||||
this.imap.once('error', (err) => {
|
||||
logger.error(`IMAP connection error: ${err.message}`);
|
||||
});
|
||||
}
|
||||
|
||||
async sendVerificationCode(toEmail, token) {
|
||||
try {
|
||||
// Генерируем код подтверждения
|
||||
const verificationCode = Math.floor(100000 + Math.random() * 900000).toString();
|
||||
|
||||
// Сохраняем код в хранилище
|
||||
verificationCodes.set(toEmail.toLowerCase(), {
|
||||
code: verificationCode,
|
||||
token: token,
|
||||
expires: Date.now() + 15 * 60 * 1000 // 15 минут
|
||||
});
|
||||
|
||||
// Отправляем письмо с кодом
|
||||
const mailOptions = {
|
||||
from: this.user,
|
||||
to: toEmail,
|
||||
subject: 'Код подтверждения для DApp for Business',
|
||||
text: `Ваш код подтверждения: ${verificationCode}\n\nДля завершения аутентификации, пожалуйста, ответьте на это письмо, указав только полученный код.\n\nКод действителен в течение 15 минут.`,
|
||||
html: `
|
||||
<div style="font-family: Arial, sans-serif; max-width: 600px; margin: 0 auto; padding: 20px; border: 1px solid #ddd; border-radius: 5px;">
|
||||
<h2 style="color: #333;">Код подтверждения для DApp for Business</h2>
|
||||
<p>Ваш код подтверждения:</p>
|
||||
<div style="font-size: 24px; font-weight: bold; padding: 15px; background-color: #f5f5f5; border-radius: 5px; text-align: center; margin: 20px 0;">
|
||||
${verificationCode}
|
||||
</div>
|
||||
<p>Для завершения аутентификации, пожалуйста, ответьте на это письмо, указав только полученный код.</p>
|
||||
<p>Код действителен в течение 15 минут.</p>
|
||||
<hr style="margin: 20px 0; border: none; border-top: 1px solid #ddd;">
|
||||
<p style="font-size: 12px; color: #777;">Это автоматическое сообщение, пожалуйста, не отвечайте на него.</p>
|
||||
</div>
|
||||
`
|
||||
};
|
||||
|
||||
const info = await this.transporter.sendMail(mailOptions);
|
||||
logger.info(`Email sent: ${info.messageId}`);
|
||||
|
||||
return { success: true, code: verificationCode }; // Код для отладки
|
||||
} catch (error) {
|
||||
logger.error(`Error sending email: ${error}`);
|
||||
return { success: false, error: error.message };
|
||||
}
|
||||
}
|
||||
|
||||
listenForReplies() {
|
||||
// Запускаем проверку почты каждые 30 секунд
|
||||
setInterval(() => {
|
||||
this.checkEmails();
|
||||
}, 30000);
|
||||
}
|
||||
|
||||
checkEmails() {
|
||||
try {
|
||||
// Добавляем обработчики ошибок
|
||||
this.imap.once('error', (err) => {
|
||||
logger.error(`IMAP connection error during check: ${err.message}`);
|
||||
// Пытаемся закрыть соединение при ошибке
|
||||
try {
|
||||
this.imap.end();
|
||||
} catch (e) {
|
||||
// Игнорируем ошибки при закрытии
|
||||
}
|
||||
});
|
||||
|
||||
if (results.length === 0) {
|
||||
console.log('No new emails');
|
||||
imap.end();
|
||||
return;
|
||||
}
|
||||
|
||||
console.log(`Found ${results.length} new emails`);
|
||||
|
||||
const f = imap.fetch(results, { bodies: '' });
|
||||
|
||||
f.on('message', (msg, seqno) => {
|
||||
msg.on('body', (stream, info) => {
|
||||
simpleParser(stream, async (err, parsed) => {
|
||||
if (err) {
|
||||
console.error('Error parsing email:', err);
|
||||
return;
|
||||
}
|
||||
|
||||
try {
|
||||
// Обработка письма
|
||||
await processEmail(parsed);
|
||||
|
||||
// Пометить как прочитанное
|
||||
imap.setFlags(results, ['\\Seen'], (err) => {
|
||||
if (err) {
|
||||
console.error('Error marking email as read:', err);
|
||||
}
|
||||
this.imap.once('ready', () => {
|
||||
this.imap.openBox('INBOX', false, (err, box) => {
|
||||
if (err) {
|
||||
logger.error(`Error opening inbox: ${err}`);
|
||||
this.imap.end();
|
||||
return;
|
||||
}
|
||||
|
||||
// Ищем непрочитанные письма
|
||||
this.imap.search(['UNSEEN'], (err, results) => {
|
||||
if (err) {
|
||||
logger.error(`Error searching messages: ${err}`);
|
||||
this.imap.end();
|
||||
return;
|
||||
}
|
||||
|
||||
if (!results || results.length === 0) {
|
||||
logger.info('No new messages found');
|
||||
this.imap.end();
|
||||
return;
|
||||
}
|
||||
|
||||
// Защищаемся от пустых результатов
|
||||
try {
|
||||
const f = this.imap.fetch(results, { bodies: '' });
|
||||
|
||||
f.on('message', (msg, seqno) => {
|
||||
msg.on('body', (stream, info) => {
|
||||
simpleParser(stream, async (err, parsed) => {
|
||||
if (err) {
|
||||
logger.error(`Error parsing message: ${err}`);
|
||||
return;
|
||||
}
|
||||
|
||||
// Обработка входящего письма
|
||||
try {
|
||||
await this.processEmail(parsed);
|
||||
} catch (e) {
|
||||
logger.error(`Error processing email: ${e.message}`);
|
||||
}
|
||||
});
|
||||
});
|
||||
} catch (error) {
|
||||
console.error('Error processing email:', error);
|
||||
});
|
||||
|
||||
f.once('error', (err) => {
|
||||
logger.error(`Fetch error: ${err}`);
|
||||
});
|
||||
|
||||
f.once('end', () => {
|
||||
try {
|
||||
this.imap.end();
|
||||
} catch (e) {
|
||||
logger.error(`Error ending IMAP connection: ${e.message}`);
|
||||
}
|
||||
});
|
||||
} catch (e) {
|
||||
logger.error(`Error fetching messages: ${e.message}`);
|
||||
try {
|
||||
this.imap.end();
|
||||
} catch (e) {
|
||||
// Игнорируем ошибки при закрытии
|
||||
}
|
||||
});
|
||||
}
|
||||
});
|
||||
});
|
||||
|
||||
f.once('error', (err) => {
|
||||
console.error('Fetch error:', err);
|
||||
});
|
||||
|
||||
f.once('end', () => {
|
||||
imap.end();
|
||||
});
|
||||
});
|
||||
});
|
||||
});
|
||||
|
||||
imap.once('error', (err) => {
|
||||
console.error('IMAP error:', err);
|
||||
});
|
||||
|
||||
imap.connect();
|
||||
}
|
||||
|
||||
/**
|
||||
* Обработка полученного письма
|
||||
* @param {Object} email - Распарсенное письмо
|
||||
*/
|
||||
async function processEmail(email) {
|
||||
try {
|
||||
const from = email.from.value[0].address;
|
||||
const subject = email.subject;
|
||||
const text = email.text || '';
|
||||
|
||||
console.log(`Processing email from ${from}, subject: ${subject}`);
|
||||
|
||||
// Поиск пользователя по email
|
||||
const userResult = await pool.query(
|
||||
`SELECT u.* FROM users u
|
||||
JOIN user_identities ui ON u.id = ui.user_id
|
||||
WHERE ui.identity_type = 'email' AND ui.identity_value = $1 AND ui.verified = TRUE`,
|
||||
[from]
|
||||
);
|
||||
|
||||
if (userResult.rows.length === 0) {
|
||||
console.log(`No verified user found for email ${from}`);
|
||||
// Отправка ответа о необходимости регистрации
|
||||
await sendEmail(
|
||||
from,
|
||||
'Регистрация в системе',
|
||||
'Для использования ИИ-ассистента через email, пожалуйста, зарегистрируйтесь на нашем сайте и подтвердите свой email.'
|
||||
);
|
||||
return;
|
||||
|
||||
this.imap.connect();
|
||||
} catch (error) {
|
||||
logger.error(`Global error checking emails: ${error.message}`);
|
||||
// Обеспечиваем корректное завершение IMAP сессии
|
||||
try {
|
||||
this.imap.end();
|
||||
} catch (e) {
|
||||
// Игнорируем ошибки при закрытии
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
const user = userResult.rows[0];
|
||||
async processEmail(email) {
|
||||
try {
|
||||
const fromEmail = email.from.value[0].address.toLowerCase();
|
||||
const subject = email.subject;
|
||||
const text = email.text;
|
||||
|
||||
// Получение или создание диалога
|
||||
const conversationResult = await pool.query(
|
||||
`SELECT * FROM conversations
|
||||
WHERE user_id = $1
|
||||
ORDER BY updated_at DESC
|
||||
LIMIT 1`,
|
||||
[user.id]
|
||||
);
|
||||
|
||||
let conversationId;
|
||||
|
||||
if (conversationResult.rows.length === 0) {
|
||||
// Создание нового диалога
|
||||
const newConversationResult = await pool.query(
|
||||
`INSERT INTO conversations (user_id, title)
|
||||
VALUES ($1, $2)
|
||||
RETURNING id`,
|
||||
[user.id, subject || 'Email диалог']
|
||||
);
|
||||
|
||||
conversationId = newConversationResult.rows[0].id;
|
||||
} else {
|
||||
conversationId = conversationResult.rows[0].id;
|
||||
// Ищем код в тексте письма
|
||||
const codeMatch = text.match(/\b\d{6}\b/);
|
||||
if (!codeMatch) return;
|
||||
|
||||
const code = codeMatch[0];
|
||||
|
||||
// Проверяем, есть ли код для этого email
|
||||
const verificationData = verificationCodes.get(fromEmail);
|
||||
|
||||
if (verificationData && verificationData.code === code) {
|
||||
// Проверяем срок действия
|
||||
if (Date.now() > verificationData.expires) {
|
||||
// Код истек
|
||||
this.transporter.sendMail({
|
||||
from: this.user,
|
||||
to: fromEmail,
|
||||
subject: 'Срок действия кода истек',
|
||||
text: 'Срок действия кода подтверждения истек. Пожалуйста, запросите новый код.'
|
||||
});
|
||||
verificationCodes.delete(fromEmail);
|
||||
return;
|
||||
}
|
||||
|
||||
// Код верный и актуальный
|
||||
const { pool } = require('../db');
|
||||
const token = verificationData.token;
|
||||
|
||||
// Связываем email с пользователем
|
||||
const tokenResult = await pool.query(
|
||||
'SELECT user_id FROM email_auth_tokens WHERE token = $1',
|
||||
[token]
|
||||
);
|
||||
|
||||
if (tokenResult.rows.length > 0) {
|
||||
const userId = tokenResult.rows[0].user_id;
|
||||
|
||||
// Добавляем идентификатор email для пользователя
|
||||
await pool.query(
|
||||
'INSERT INTO user_identities (user_id, identity_type, identity_value, verified, created_at) ' +
|
||||
'VALUES ($1, $2, $3, true, NOW()) ' +
|
||||
'ON CONFLICT (identity_type, identity_value) ' +
|
||||
'DO UPDATE SET user_id = $1, verified = true',
|
||||
[userId, 'email', fromEmail]
|
||||
);
|
||||
|
||||
// Отмечаем токен как использованный
|
||||
await pool.query(
|
||||
'UPDATE email_auth_tokens SET used = true WHERE token = $1',
|
||||
[token]
|
||||
);
|
||||
|
||||
// Отправляем подтверждение
|
||||
this.transporter.sendMail({
|
||||
from: this.user,
|
||||
to: fromEmail,
|
||||
subject: 'Аутентификация успешна',
|
||||
text: 'Ваш email успешно связан с аккаунтом DApp for Business.'
|
||||
});
|
||||
|
||||
verificationCodes.delete(fromEmail);
|
||||
}
|
||||
}
|
||||
} catch (error) {
|
||||
logger.error(`Error processing email: ${error}`);
|
||||
}
|
||||
}
|
||||
|
||||
// Сохранение сообщения пользователя
|
||||
await pool.query(
|
||||
`INSERT INTO messages (conversation_id, sender_type, sender_id, content, channel)
|
||||
VALUES ($1, $2, $3, $4, $5)`,
|
||||
[conversationId, 'user', user.id, text, 'email']
|
||||
);
|
||||
// Оставляем существующие методы
|
||||
async sendEmail(to, subject, text) {
|
||||
try {
|
||||
const mailOptions = {
|
||||
from: this.user,
|
||||
to,
|
||||
subject,
|
||||
text
|
||||
};
|
||||
|
||||
// Обработка сообщения ИИ-ассистентом
|
||||
const aiResponse = await processMessage(user.id, text, user.language || 'ru');
|
||||
const info = await this.transporter.sendMail(mailOptions);
|
||||
logger.info(`Email sent: ${info.messageId}`);
|
||||
return true;
|
||||
} catch (error) {
|
||||
logger.error(`Error sending email: ${error}`);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
// Сохранение ответа ИИ
|
||||
await pool.query(
|
||||
`INSERT INTO messages (conversation_id, sender_type, sender_id, content, channel)
|
||||
VALUES ($1, $2, $3, $4, $5)`,
|
||||
[conversationId, 'ai', null, aiResponse, 'email']
|
||||
);
|
||||
|
||||
// Обновление времени последнего обновления диалога
|
||||
await pool.query(
|
||||
`UPDATE conversations
|
||||
SET updated_at = NOW()
|
||||
WHERE id = $1`,
|
||||
[conversationId]
|
||||
);
|
||||
|
||||
// Отправка ответа пользователю
|
||||
await sendEmail(from, `Re: ${subject}`, aiResponse);
|
||||
|
||||
console.log(`Sent response to ${from}`);
|
||||
} catch (error) {
|
||||
console.error('Error processing email:', error);
|
||||
throw error;
|
||||
// Метод для проверки кода без IMAP
|
||||
verifyCode(email, code) {
|
||||
email = email.toLowerCase();
|
||||
const data = verificationCodes.get(email);
|
||||
|
||||
if (!data) {
|
||||
return { success: false, error: 'Код не найден' };
|
||||
}
|
||||
|
||||
if (Date.now() > data.expires) {
|
||||
verificationCodes.delete(email);
|
||||
return { success: false, error: 'Срок действия кода истек' };
|
||||
}
|
||||
|
||||
if (data.code !== code) {
|
||||
return { success: false, error: 'Неверный код' };
|
||||
}
|
||||
|
||||
return {
|
||||
success: true,
|
||||
token: data.token
|
||||
};
|
||||
}
|
||||
|
||||
// Метод для удаления кода после проверки
|
||||
removeCode(email) {
|
||||
verificationCodes.delete(email.toLowerCase());
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Отправка email
|
||||
* @param {string} to - Адрес получателя
|
||||
* @param {string} subject - Тема письма
|
||||
* @param {string} text - Текст письма
|
||||
* @returns {Promise<Object>} - Результат отправки
|
||||
*/
|
||||
async function sendEmail(to, subject, text) {
|
||||
try {
|
||||
const info = await transporter.sendMail({
|
||||
from: process.env.EMAIL_USER,
|
||||
to,
|
||||
subject,
|
||||
text,
|
||||
});
|
||||
|
||||
console.log('Email sent:', info.messageId);
|
||||
return info;
|
||||
} catch (error) {
|
||||
console.error('Error sending email:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = {
|
||||
initEmailBot,
|
||||
sendEmail,
|
||||
checkEmails,
|
||||
};
|
||||
// Экспортируем класс и хранилище кодов
|
||||
module.exports = EmailBotService;
|
||||
module.exports.verificationCodes = verificationCodes;
|
||||
|
||||
@@ -1,262 +0,0 @@
|
||||
const TelegramBot = require('node-telegram-bot-api');
|
||||
const { pool } = require('../db');
|
||||
const { processMessage } = require('./ai-assistant');
|
||||
|
||||
// Инициализация бота
|
||||
const token = process.env.TELEGRAM_BOT_TOKEN;
|
||||
let bot = null;
|
||||
|
||||
if (token) {
|
||||
bot = new TelegramBot(token, { polling: true });
|
||||
console.log('Telegram bot initialized');
|
||||
} else {
|
||||
console.warn('TELEGRAM_BOT_TOKEN not set, Telegram integration disabled');
|
||||
}
|
||||
|
||||
/**
|
||||
* Инициализация Telegram бота
|
||||
*/
|
||||
function initTelegramBot() {
|
||||
if (!bot) return;
|
||||
|
||||
// Обработка команды /start
|
||||
bot.onText(/\/start/, async (msg) => {
|
||||
const chatId = msg.chat.id;
|
||||
const userId = msg.from.id;
|
||||
const username =
|
||||
msg.from.username || `${msg.from.first_name} ${msg.from.last_name || ''}`.trim();
|
||||
|
||||
try {
|
||||
// Проверка существования пользователя
|
||||
const user = await findOrCreateUser(userId, username, chatId);
|
||||
|
||||
// Приветственное сообщение
|
||||
bot.sendMessage(chatId, `Привет, ${username}! Я ИИ-ассистент. Чем могу помочь?`);
|
||||
} catch (error) {
|
||||
console.error('Error handling /start command:', error);
|
||||
bot.sendMessage(
|
||||
chatId,
|
||||
'Произошла ошибка при обработке команды. Пожалуйста, попробуйте позже.'
|
||||
);
|
||||
}
|
||||
});
|
||||
|
||||
// Обработка текстовых сообщений
|
||||
bot.on('message', async (msg) => {
|
||||
if (!msg.text || msg.text.startsWith('/')) return;
|
||||
|
||||
const chatId = msg.chat.id;
|
||||
const userId = msg.from.id;
|
||||
const username =
|
||||
msg.from.username || `${msg.from.first_name} ${msg.from.last_name || ''}`.trim();
|
||||
|
||||
try {
|
||||
// Проверка существования пользователя
|
||||
const user = await findOrCreateUser(userId, username, chatId);
|
||||
|
||||
// Получение или создание диалога
|
||||
const conversation = await getOrCreateConversation(user.id);
|
||||
|
||||
// Сохранение сообщения пользователя
|
||||
await saveMessage(conversation.id, 'user', user.id, msg.text, 'telegram');
|
||||
|
||||
// Обработка сообщения ИИ-ассистентом
|
||||
const aiResponse = await processMessage(user.id, msg.text, user.language || 'ru');
|
||||
|
||||
// Сохранение ответа ИИ
|
||||
await saveMessage(conversation.id, 'ai', null, aiResponse, 'telegram');
|
||||
|
||||
// Отправка ответа
|
||||
bot.sendMessage(chatId, aiResponse);
|
||||
} catch (error) {
|
||||
console.error('Error processing message:', error);
|
||||
bot.sendMessage(
|
||||
chatId,
|
||||
'Произошла ошибка при обработке сообщения. Пожалуйста, попробуйте позже.'
|
||||
);
|
||||
}
|
||||
});
|
||||
|
||||
console.log('Telegram bot handlers registered');
|
||||
}
|
||||
|
||||
/**
|
||||
* Поиск или создание пользователя по Telegram ID
|
||||
* @param {number} telegramId - Telegram ID пользователя
|
||||
* @param {string} username - Имя пользователя
|
||||
* @param {number} chatId - ID чата
|
||||
* @returns {Promise<Object>} - Информация о пользователе
|
||||
*/
|
||||
async function findOrCreateUser(telegramId, username, chatId) {
|
||||
try {
|
||||
// Поиск пользователя по Telegram ID
|
||||
const userIdResult = await pool.query(
|
||||
`SELECT user_id FROM user_identities
|
||||
WHERE identity_type = 'telegram' AND identity_value = $1`,
|
||||
[telegramId.toString()]
|
||||
);
|
||||
|
||||
if (userIdResult.rows.length > 0) {
|
||||
// Пользователь найден
|
||||
const userId = userIdResult.rows[0].user_id;
|
||||
|
||||
// Получение информации о пользователе
|
||||
const userResult = await pool.query('SELECT * FROM users WHERE id = $1', [userId]);
|
||||
|
||||
return userResult.rows[0];
|
||||
} else {
|
||||
// Создание нового пользователя
|
||||
const userResult = await pool.query(
|
||||
`INSERT INTO users (
|
||||
username,
|
||||
role_id,
|
||||
is_admin,
|
||||
language,
|
||||
address
|
||||
) VALUES (
|
||||
$1,
|
||||
(SELECT id FROM roles WHERE name = 'user'),
|
||||
FALSE,
|
||||
'ru',
|
||||
'0x' || encode(gen_random_bytes(20), 'hex')
|
||||
) RETURNING *`,
|
||||
[username]
|
||||
);
|
||||
|
||||
const newUser = userResult.rows[0];
|
||||
|
||||
// Добавление идентификатора Telegram
|
||||
await pool.query(
|
||||
`INSERT INTO user_identities (
|
||||
user_id,
|
||||
identity_type,
|
||||
identity_value,
|
||||
verified
|
||||
) VALUES ($1, 'telegram', $2, TRUE)`,
|
||||
[newUser.id, telegramId.toString()]
|
||||
);
|
||||
|
||||
// Сохранение метаданных Telegram
|
||||
await pool.query(
|
||||
`INSERT INTO user_preferences (
|
||||
user_id,
|
||||
preference_key,
|
||||
preference_value
|
||||
) VALUES ($1, 'telegram_chat_id', $2)`,
|
||||
[newUser.id, chatId.toString()]
|
||||
);
|
||||
|
||||
return newUser;
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('Error finding or creating user:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Получение или создание диалога для пользователя
|
||||
* @param {number} userId - ID пользователя
|
||||
* @returns {Promise<Object>} - Информация о диалоге
|
||||
*/
|
||||
async function getOrCreateConversation(userId) {
|
||||
try {
|
||||
// Поиск активного диалога
|
||||
const conversationResult = await pool.query(
|
||||
`SELECT * FROM conversations
|
||||
WHERE user_id = $1
|
||||
ORDER BY updated_at DESC
|
||||
LIMIT 1`,
|
||||
[userId]
|
||||
);
|
||||
|
||||
if (conversationResult.rows.length > 0) {
|
||||
// Обновление времени последней активности
|
||||
await pool.query('UPDATE conversations SET updated_at = NOW() WHERE id = $1', [
|
||||
conversationResult.rows[0].id,
|
||||
]);
|
||||
|
||||
return conversationResult.rows[0];
|
||||
} else {
|
||||
// Создание нового диалога
|
||||
const newConversationResult = await pool.query(
|
||||
`INSERT INTO conversations (user_id, title)
|
||||
VALUES ($1, $2)
|
||||
RETURNING *`,
|
||||
[userId, 'Диалог в Telegram']
|
||||
);
|
||||
|
||||
return newConversationResult.rows[0];
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('Error getting or creating conversation:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Сохранение сообщения
|
||||
* @param {number} conversationId - ID диалога
|
||||
* @param {string} senderType - Тип отправителя ('user', 'ai')
|
||||
* @param {number|null} senderId - ID отправителя
|
||||
* @param {string} content - Текст сообщения
|
||||
* @param {string} channel - Канал ('telegram')
|
||||
* @returns {Promise<Object>} - Информация о сообщении
|
||||
*/
|
||||
async function saveMessage(conversationId, senderType, senderId, content, channel) {
|
||||
try {
|
||||
const messageResult = await pool.query(
|
||||
`INSERT INTO messages (
|
||||
conversation_id,
|
||||
sender_type,
|
||||
sender_id,
|
||||
content,
|
||||
channel
|
||||
) VALUES ($1, $2, $3, $4, $5)
|
||||
RETURNING *`,
|
||||
[conversationId, senderType, senderId, content, channel]
|
||||
);
|
||||
|
||||
return messageResult.rows[0];
|
||||
} catch (error) {
|
||||
console.error('Error saving message:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Отправка сообщения пользователю через Telegram
|
||||
* @param {number} userId - ID пользователя
|
||||
* @param {string} message - Текст сообщения
|
||||
* @returns {Promise<boolean>} - Успешность отправки
|
||||
*/
|
||||
async function sendMessageToUser(userId, message) {
|
||||
if (!bot) return false;
|
||||
|
||||
try {
|
||||
// Получение Telegram chat ID пользователя
|
||||
const chatIdResult = await pool.query(
|
||||
`SELECT preference_value FROM user_preferences
|
||||
WHERE user_id = $1 AND preference_key = 'telegram_chat_id'`,
|
||||
[userId]
|
||||
);
|
||||
|
||||
if (chatIdResult.rows.length === 0) {
|
||||
return false;
|
||||
}
|
||||
|
||||
const chatId = chatIdResult.rows[0].preference_value;
|
||||
|
||||
// Отправка сообщения
|
||||
await bot.sendMessage(chatId, message);
|
||||
return true;
|
||||
} catch (error) {
|
||||
console.error('Error sending message to user:', error);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = {
|
||||
initTelegramBot,
|
||||
sendMessageToUser,
|
||||
};
|
||||
273
backend/services/telegramBot.js
Normal file
273
backend/services/telegramBot.js
Normal file
@@ -0,0 +1,273 @@
|
||||
const TelegramBot = require('node-telegram-bot-api');
|
||||
const logger = require('../utils/logger');
|
||||
|
||||
// Создаем бота
|
||||
const token = process.env.TELEGRAM_BOT_TOKEN;
|
||||
let bot = null;
|
||||
|
||||
// Добавим хранилище для кодов подтверждения
|
||||
const verificationCodes = new Map(); // Формат: { telegramId: { code: '123456', token: 'auth_token', expires: timestamp } }
|
||||
|
||||
/**
|
||||
* Инициализация Telegram бота
|
||||
* @returns {Object|null} - Объект с методами для работы с ботом или null, если инициализация не удалась
|
||||
*/
|
||||
function initTelegramBot() {
|
||||
if (!token) {
|
||||
console.warn('TELEGRAM_BOT_TOKEN not set, Telegram integration disabled');
|
||||
return null;
|
||||
}
|
||||
|
||||
try {
|
||||
// Создаем бота с опцией polling
|
||||
bot = new TelegramBot(token, { polling: true });
|
||||
console.log('Telegram bot initialized');
|
||||
|
||||
// Регистрируем обработчики событий
|
||||
registerHandlers();
|
||||
|
||||
return {
|
||||
bot,
|
||||
sendMessage: (chatId, text) => bot.sendMessage(chatId, text)
|
||||
};
|
||||
} catch (error) {
|
||||
console.error('Error initializing Telegram bot:', error);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Регистрация обработчиков событий для бота
|
||||
*/
|
||||
function registerHandlers() {
|
||||
// Обработчик /start
|
||||
bot.onText(/\/start(.*)/, async (msg, match) => {
|
||||
const chatId = msg.chat.id;
|
||||
const param = match[1] ? match[1].trim() : '';
|
||||
|
||||
console.log(`Получена команда /start с параметром: "${param}" от пользователя ${chatId}`);
|
||||
|
||||
if (param.startsWith('auth_')) {
|
||||
// Это токен авторизации через deep link
|
||||
const authToken = param.replace('auth_', '');
|
||||
console.log(`Обработка токена авторизации: ${authToken}`);
|
||||
|
||||
try {
|
||||
// Проверяем, существует ли токен
|
||||
const { pool } = require('../db');
|
||||
const tokenResult = await pool.query(
|
||||
'SELECT user_id, expires_at FROM telegram_auth_tokens WHERE token = $1',
|
||||
[authToken]
|
||||
);
|
||||
|
||||
if (tokenResult.rows.length === 0 || new Date(tokenResult.rows[0].expires_at) < new Date()) {
|
||||
bot.sendMessage(chatId, '❌ Недействительный или истекший токен авторизации.');
|
||||
return;
|
||||
}
|
||||
|
||||
// Генерируем код подтверждения
|
||||
const verificationCode = Math.floor(100000 + Math.random() * 900000).toString(); // 6-значный код
|
||||
|
||||
// Сохраняем в хранилище
|
||||
verificationCodes.set(chatId.toString(), {
|
||||
code: verificationCode,
|
||||
token: authToken,
|
||||
expires: Date.now() + 5 * 60 * 1000 // Срок действия 5 минут
|
||||
});
|
||||
|
||||
// Отправляем код пользователю
|
||||
bot.sendMessage(chatId,
|
||||
'🔐 Для завершения связывания аккаунта, пожалуйста, введите этот код:\n\n' +
|
||||
`<code>${verificationCode}</code>\n\n` +
|
||||
'Код действителен в течение 5 минут.',
|
||||
{ parse_mode: 'HTML' }
|
||||
);
|
||||
} catch (error) {
|
||||
console.error('Error processing auth token:', error);
|
||||
bot.sendMessage(chatId, '❌ Произошла ошибка при обработке запроса авторизации.');
|
||||
}
|
||||
} else {
|
||||
// Получаем последний активный токен для этого чата, если есть
|
||||
const { pool } = require('../db');
|
||||
try {
|
||||
const lastTokenResult = await pool.query(`
|
||||
SELECT token FROM telegram_auth_tokens
|
||||
WHERE expires_at > NOW() AND used = FALSE
|
||||
ORDER BY created_at DESC LIMIT 1
|
||||
`);
|
||||
|
||||
if (lastTokenResult.rows.length > 0) {
|
||||
const authToken = lastTokenResult.rows[0].token;
|
||||
|
||||
// Генерируем код подтверждения
|
||||
const verificationCode = Math.floor(100000 + Math.random() * 900000).toString(); // 6-значный код
|
||||
|
||||
// Сохраняем в хранилище
|
||||
verificationCodes.set(chatId.toString(), {
|
||||
code: verificationCode,
|
||||
token: authToken,
|
||||
expires: Date.now() + 5 * 60 * 1000 // Срок действия 5 минут
|
||||
});
|
||||
|
||||
// Отправляем код пользователю
|
||||
bot.sendMessage(chatId,
|
||||
'🔐 Для завершения связывания аккаунта, пожалуйста, введите этот код:\n\n' +
|
||||
`<code>${verificationCode}</code>\n\n` +
|
||||
'Код действителен в течение 5 минут.',
|
||||
{ parse_mode: 'HTML' }
|
||||
);
|
||||
return;
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('Error checking last token:', error);
|
||||
}
|
||||
|
||||
// Если нет активного токена, отправляем стандартное сообщение
|
||||
bot.sendMessage(chatId,
|
||||
'Привет! Я бот для аутентификации в DApp for Business.\n\n' +
|
||||
'Для связи с вашим аккаунтом используйте кнопку на сайте.'
|
||||
);
|
||||
}
|
||||
});
|
||||
|
||||
// Обработчик для проверки кода подтверждения
|
||||
bot.on('message', async (msg) => {
|
||||
const chatId = msg.chat.id;
|
||||
const text = msg.text;
|
||||
|
||||
// Игнорируем команды
|
||||
if (text && text.startsWith('/')) return;
|
||||
|
||||
// Проверяем, есть ли ожидающая верификация для этого чата
|
||||
const verificationData = verificationCodes.get(chatId.toString());
|
||||
|
||||
if (verificationData && text === verificationData.code) {
|
||||
// Код верный, проверяем срок действия
|
||||
if (Date.now() > verificationData.expires) {
|
||||
bot.sendMessage(chatId, '❌ Срок действия кода истек. Пожалуйста, начните процесс заново.');
|
||||
verificationCodes.delete(chatId.toString());
|
||||
return;
|
||||
}
|
||||
|
||||
// Код верный и актуальный, завершаем аутентификацию
|
||||
try {
|
||||
const result = await linkTelegramAccount(chatId.toString(), verificationData.token);
|
||||
|
||||
if (result.success) {
|
||||
bot.sendMessage(chatId,
|
||||
'✅ Аутентификация успешна!\n\n' +
|
||||
'Ваш Telegram аккаунт связан с DApp for Business.\n' +
|
||||
'Теперь вы можете использовать бота для общения с системой.'
|
||||
);
|
||||
} else {
|
||||
bot.sendMessage(chatId,
|
||||
'❌ Ошибка аутентификации: ' + (result.error || 'неизвестная ошибка')
|
||||
);
|
||||
}
|
||||
|
||||
// Удаляем данные верификации
|
||||
verificationCodes.delete(chatId.toString());
|
||||
} catch (error) {
|
||||
console.error('Error completing authentication:', error);
|
||||
bot.sendMessage(chatId, '❌ Произошла ошибка при завершении аутентификации.');
|
||||
}
|
||||
} else if (verificationData) {
|
||||
// Есть ожидающая верификация, но код неверный
|
||||
bot.sendMessage(chatId, '❌ Неверный код. Пожалуйста, попробуйте еще раз.');
|
||||
} else {
|
||||
// Нет ожидающей верификации
|
||||
bot.sendMessage(chatId, 'Я могу помочь с аутентификацией. Используйте кнопку на сайте для начала процесса.');
|
||||
}
|
||||
});
|
||||
|
||||
// Добавить обработку прямых команд аутентификации
|
||||
bot.onText(/\/auth (.+)/, async (msg, match) => {
|
||||
const chatId = msg.chat.id;
|
||||
const authToken = match[1].trim();
|
||||
|
||||
console.log(`Получена прямая команда авторизации с токеном: ${authToken}`);
|
||||
|
||||
try {
|
||||
// Связываем Telegram ID с аккаунтом по токену
|
||||
const result = await linkTelegramAccount(chatId.toString(), authToken);
|
||||
console.log(`Результат связывания: ${JSON.stringify(result)}`);
|
||||
|
||||
if (result.success) {
|
||||
bot.sendMessage(chatId,
|
||||
'✅ Аутентификация успешна!\n\n' +
|
||||
'Ваш Telegram аккаунт связан с DApp for Business.\n' +
|
||||
'Теперь вы можете использовать бота для общения с системой.'
|
||||
);
|
||||
} else {
|
||||
bot.sendMessage(chatId,
|
||||
'❌ Ошибка аутентификации: ' + (result.error || 'неизвестная ошибка')
|
||||
);
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('Error linking telegram account:', error);
|
||||
bot.sendMessage(chatId, '❌ Произошла ошибка при связывании аккаунта.');
|
||||
}
|
||||
});
|
||||
|
||||
// Обработка ошибок
|
||||
bot.on('polling_error', (error) => {
|
||||
logger.error(`[polling_error] ${JSON.stringify(error)}`);
|
||||
});
|
||||
|
||||
console.log('Telegram bot handlers registered');
|
||||
}
|
||||
|
||||
/**
|
||||
* Связывание Telegram ID с аккаунтом пользователя
|
||||
* @param {string} telegramId - ID пользователя в Telegram
|
||||
* @param {string} authToken - Токен авторизации
|
||||
* @returns {Promise<Object>} - Результат операции
|
||||
*/
|
||||
async function linkTelegramAccount(telegramId, authToken) {
|
||||
try {
|
||||
console.log(`Попытка связать Telegram ID ${telegramId} с токеном ${authToken}`);
|
||||
|
||||
// Здесь должен быть код для связывания через API или напрямую с БД
|
||||
const { pool } = require('../db');
|
||||
|
||||
// Проверяем токен авторизации
|
||||
const tokenResult = await pool.query(
|
||||
'SELECT user_id, expires_at FROM telegram_auth_tokens WHERE token = $1',
|
||||
[authToken]
|
||||
);
|
||||
|
||||
console.log(`Результат запроса токена: ${JSON.stringify(tokenResult.rows)}`);
|
||||
|
||||
if (tokenResult.rows.length === 0 || new Date(tokenResult.rows[0].expires_at) < new Date()) {
|
||||
console.log('Токен не найден или истек');
|
||||
return { success: false, error: 'Недействительный или истекший токен' };
|
||||
}
|
||||
|
||||
const userId = tokenResult.rows[0].user_id;
|
||||
console.log(`Найден пользователь с ID: ${userId}`);
|
||||
|
||||
// Добавляем идентификатор Telegram для пользователя
|
||||
await pool.query(
|
||||
'INSERT INTO user_identities (user_id, identity_type, identity_value, verified, created_at) ' +
|
||||
'VALUES ($1, $2, $3, true, NOW()) ' +
|
||||
'ON CONFLICT (identity_type, identity_value) ' +
|
||||
'DO UPDATE SET user_id = $1, verified = true',
|
||||
[userId, 'telegram', telegramId]
|
||||
);
|
||||
|
||||
// Отмечаем токен как использованный
|
||||
await pool.query(
|
||||
'UPDATE telegram_auth_tokens SET used = true WHERE token = $1',
|
||||
[authToken]
|
||||
);
|
||||
|
||||
return { success: true };
|
||||
} catch (error) {
|
||||
console.error('Error in linkTelegramAccount:', error);
|
||||
return { success: false, error: 'Внутренняя ошибка сервера' };
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = {
|
||||
initTelegramBot
|
||||
};
|
||||
Reference in New Issue
Block a user