+ ${body} +
+ + ${rideInfoHtml} + + ${data.reason ? `${t('RIDE_CANCELLED_REASON')}
` : ''} + + ${ctaHtml} ++ ${config.appName} +
++ Ricevi questa email perché hai attivato le notifiche. + Gestisci preferenze +
+${err.stack || err.message}`;
- for (const id of ADMIN_GROUP_IDS) {
- await sendMessage(id, msg);
- }
-});
-
-module.exports = { reportError };
diff --git a/src/telegram/handlers/friendsHandler.js b/src/telegram/handlers/friendsHandler.js
deleted file mode 100644
index ffb366a..0000000
--- a/src/telegram/handlers/friendsHandler.js
+++ /dev/null
@@ -1,61 +0,0 @@
-// telegram/handlers/friendsHandler.js
-const shared_consts = require('../../tools/shared_nodejs');
-const tools = require('../../tools/general');
-const { User } = require('../../models/user');
-const printf = require('util').format;
-const { handleRegistration, InlineConferma } = require('./registrationHandler');
-
-async function handleFriends({ bot, cl, idapp, msg, data, user, userDest, username_action }) {
- let notifyText = '';
-
- // SI -> amicizia
- if (data.action === InlineConferma.RISPOSTA_SI + shared_consts.CallFunz.RICHIESTA_AMICIZIA) {
- if (userDest) {
- const req = tools.getReqByPar(idapp, username_action);
- const already = await User.isMyFriend(idapp, data.username, data.userDest);
- if (!already) await User.setFriendsCmd(req, idapp, data.username, data.userDest, shared_consts.FRIENDSCMD.SETFRIEND);
- await cl.sendMsg(msg.chat.id, '🤝 Amicizia confermata!');
- notifyText = 'Amicizia OK';
- }
- return notifyText;
- }
-
- // NO -> amicizia (rimuovi/nega)
- if (data.action === InlineConferma.RISPOSTA_NO + shared_consts.CallFunz.RICHIESTA_AMICIZIA) {
- if (userDest) {
- const req = tools.getReqByPar(idapp, username_action);
- const ris = await User.setFriendsCmd(req, idapp, data.username, data.userDest, shared_consts.FRIENDSCMD.REMOVE_FROM_MYFRIENDS);
- if (ris) {
- const msgDest = printf(tools.gettranslate('MSG_FRIENDS_NOT_ACCEPTED_CONFIRMED', user.lang), data.username);
- await localSendMsgByUsername(idapp, data.userDest, msgDest);
- }
- await cl.sendMsg(msg.chat.id, '🚫 Amicizia rifiutata.');
- notifyText = 'Rifiutata';
- }
- return notifyText;
- }
-
- // SI -> handshake
- if (data.action === InlineConferma.RISPOSTA_SI + shared_consts.CallFunz.RICHIESTA_HANDSHAKE) {
- if (userDest) {
- const req = tools.getReqByPar(idapp, username_action);
- const already = await User.isMyHandShake(idapp, data.userDest, data.username);
- if (!already) await User.setFriendsCmd(req, idapp, data.userDest, data.username, shared_consts.FRIENDSCMD.SETHANDSHAKE);
- await cl.sendMsg(msg.chat.id, '🤝 Handshake confermato!');
- notifyText = 'Handshake OK';
- }
- return notifyText;
- }
-
- return 'OK';
-}
-
-// helper locale (equivalente del tuo local_sendMsgTelegram)
-async function localSendMsgByUsername(idapp, username, text) {
- const teleg_id = await User.TelegIdByUsername(idapp, username);
- const cl = require('../telegram.bot.init').getclTelegByidapp(idapp);
- if (cl && teleg_id) return await cl.sendMsg(teleg_id, text);
- return null;
-}
-
-module.exports = { handleFriends };
diff --git a/src/telegram/handlers/groupHandler.js b/src/telegram/handlers/groupHandler.js
deleted file mode 100644
index e30655d..0000000
--- a/src/telegram/handlers/groupHandler.js
+++ /dev/null
@@ -1,70 +0,0 @@
-// telegram/handlers/groupHandler.js
-const shared_consts = require('../../tools/shared_nodejs');
-const tools = require('../../tools/general');
-const { User } = require('../../models/user');
-
-const InlineConferma = { RISPOSTA_SI: 'SI_', RISPOSTA_NO: 'NO_' };
-
-/**
- * Gestisce conferma/rifiuto a richieste di GRUPPO
- * Payload data:
- * - action
- * - username (mittente originale)
- * - userDest (destinatario/utente da aggiungere)
- * - groupId (id o path del gruppo)
- * - groupname (nome del gruppo)
- */
-async function handleGroup({ bot, cl, idapp, msg, data, user, userDest, username_action }) {
- let notifyText = '';
-
- // SI → accetta richiesta d'ingresso nel gruppo
- if (data.action === InlineConferma.RISPOSTA_SI + shared_consts.CallFunz.RICHIESTA_GRUPPO) {
- // Se l’app ha funzioni di persistenza specifiche, usale se esistono
- // (non assumo nomi rigidi per non rompere il deploy)
- if (typeof User.setGroupCmd === 'function') {
- try {
- await User.setGroupCmd(idapp, data.userDest || data.username, data.groupId, shared_consts.GROUPCMD.ADDUSERTOGROUP, 1, username_action, { groupname: data.groupname });
- } catch (e) {
- console.warn('handleGroup:setGroupCmd non eseguito:', e.message);
- }
- }
-
- // Messaggi di conferma
- await cl.sendMsg(msg.chat.id, `✅ ${data.userDest || data.username} è stato aggiunto al gruppo ${data.groupname || data.groupId}.`);
- // Notifica anche l’utente interessato
- const targetUsername = data.userDest || data.username;
- const teleg_id = await User.TelegIdByUsername(idapp, targetUsername);
- if (teleg_id) {
- await cl.sendMsg(teleg_id, `👥 Sei stato aggiunto al gruppo: ${data.groupname || data.groupId}`);
- }
-
- notifyText = 'Gruppo: aggiunta OK';
- return notifyText;
- }
-
- // NO → rifiuta/annulla richiesta
- if (data.action === InlineConferma.RISPOSTA_NO + shared_consts.CallFunz.RICHIESTA_GRUPPO) {
- if (typeof User.setGroupCmd === 'function') {
- try {
- await User.setGroupCmd(idapp, data.userDest || data.username, data.groupId, shared_consts.GROUPCMD.REMOVEUSERFROMGROUP, 0, username_action, { groupname: data.groupname });
- } catch (e) {
- console.warn('handleGroup:setGroupCmd non eseguito:', e.message);
- }
- }
-
- await cl.sendMsg(msg.chat.id, '🚫 Richiesta gruppo rifiutata.');
- // Avvisa il richiedente
- const targetUsername = data.userDest || data.username;
- const teleg_id = await User.TelegIdByUsername(idapp, targetUsername);
- if (teleg_id) {
- await cl.sendMsg(teleg_id, `❌ La tua richiesta per il gruppo ${data.groupname || data.groupId} è stata rifiutata.`);
- }
-
- notifyText = 'Gruppo: rifiutata';
- return notifyText;
- }
-
- return 'OK';
-}
-
-module.exports = { handleGroup };
diff --git a/src/telegram/handlers/multiAppHandler.js b/src/telegram/handlers/multiAppHandler.js
deleted file mode 100644
index ef19d49..0000000
--- a/src/telegram/handlers/multiAppHandler.js
+++ /dev/null
@@ -1,47 +0,0 @@
-const { sendMessage } = require('../api');
-const { safeExec, eachSeries } = require('../helpers');
-const tools = require('../../tools/general');
-const {
- getAdminTelegramUsers,
- getManagersTelegramUsers,
- getAllTelegramUsersByApp,
-} = require('./userQuery');
-
-const sendMsgTelegramToTheAdminAllSites = safeExec(async (text, alsoGroups = false) => {
- const apps = await tools.getApps(); // deve restituire {idapp,...}
- await eachSeries(apps, async (app) => {
- const admins = await getAdminTelegramUsers(app.idapp);
- await eachSeries(admins, async (u) => sendMessage(u.telegram_id, text));
- if (alsoGroups && app?.telegram_admin_group_id) {
- await sendMessage(app.telegram_admin_group_id, text);
- }
- });
-});
-
-const sendMsgTelegramByIdApp = safeExec(async (idapp, text) => {
- const users = await getAllTelegramUsersByApp(idapp);
- await eachSeries(users, async (u) => sendMessage(u.telegram_id, text));
-});
-
-const sendMsgTelegramToTheManagers = safeExec(async (idapp, text) => {
- const managers = await getManagersTelegramUsers(idapp);
- await eachSeries(managers, async (u) => sendMessage(u.telegram_id, text));
-});
-
-const sendMsgTelegramToTheAdmin = safeExec(async (idapp, text) => {
- const admins = await getAdminTelegramUsers(idapp);
- await eachSeries(admins, async (u) => sendMessage(u.telegram_id, text));
-});
-
-const sendMsgTelegramToTheGroup = safeExec(async (chatId, text) => {
- if (!chatId) return null;
- return sendMessage(chatId, text);
-});
-
-module.exports = {
- sendMsgTelegramToTheAdminAllSites,
- sendMsgTelegramByIdApp,
- sendMsgTelegramToTheManagers,
- sendMsgTelegramToTheAdmin,
- sendMsgTelegramToTheGroup,
-};
diff --git a/src/telegram/handlers/notificationHandler.js b/src/telegram/handlers/notificationHandler.js
deleted file mode 100644
index 03290c8..0000000
--- a/src/telegram/handlers/notificationHandler.js
+++ /dev/null
@@ -1,9 +0,0 @@
-const { sendMessage } = require('../api');
-const { safeExec } = require('../helpers');
-
-const sendNotification = safeExec(async (chatId, title, body) => {
- const msg = `🔔 ${title}\n${body}`;
- await sendMessage(chatId, msg);
-});
-
-module.exports = { sendNotification };
diff --git a/src/telegram/handlers/passwordHandler.js b/src/telegram/handlers/passwordHandler.js
deleted file mode 100644
index 097c2be..0000000
--- a/src/telegram/handlers/passwordHandler.js
+++ /dev/null
@@ -1,35 +0,0 @@
-// telegram/handlers/passwordHandler.js
-const shared_consts = require('../../tools/shared_nodejs');
-const tools = require('../../tools/general');
-
-const InlineConferma = { RISPOSTA_SI: 'SI_', RISPOSTA_NO: 'NO_' };
-
-async function handlePassword({ bot, cl, idapp, msg, data, user, userDest, username_action }) {
- let notifyText = '';
-
- if (data.action === InlineConferma.RISPOSTA_SI + shared_consts.CallFunz.RESET_PWD) {
- // Nel tuo codice usavi anche tools.sendNotificationToUser ecc.
- await tools.sendNotificationToUser(
- user?._id || msg.chat.id,
- '🔑 Reset Password',
- `La password di ${data.username} è stata resettata.`,
- '/',
- '',
- 'server',
- []
- );
- await cl.sendMsg(msg.chat.id, '✅ Password resettata.');
- notifyText = 'Reset OK';
- return notifyText;
- }
-
- if (data.action === InlineConferma.RISPOSTA_NO + shared_consts.CallFunz.RESET_PWD) {
- await cl.sendMsg(msg.chat.id, '❌ Reset password annullato.');
- notifyText = 'Annullato';
- return notifyText;
- }
-
- return 'OK';
-}
-
-module.exports = { handlePassword };
diff --git a/src/telegram/handlers/phaseHandler.js b/src/telegram/handlers/phaseHandler.js
deleted file mode 100644
index 6b5d0b9..0000000
--- a/src/telegram/handlers/phaseHandler.js
+++ /dev/null
@@ -1,65 +0,0 @@
-const messages = require('../messages');
-const { phase } = require('../constants');
-const { safeExec } = require('../helpers');
-const { sendMessage } = require('../api');
-const {
- getAdminTelegramUsers,
- getManagersTelegramUsers,
-} = require('./userQuery');
-
-// locals: { idapp, username, nomeapp, text, ... }
-const notifyToTelegram = safeExec(async (ph, locals = {}) => {
- const idapp = String(locals.idapp || '');
- let text = '';
-
- const templ = messages.byPhase[ph] || messages.byPhase.GENERIC;
- text = templ(locals);
-
- // router di default: manda agli admin dell'app
- const admins = await getAdminTelegramUsers(idapp);
- for (const a of admins) {
- if (a.telegram_id) await sendMessage(a.telegram_id, text);
- }
-});
-
-const askConfirmationUser = safeExec(async (idapp, phaseCode, user) => {
- const txt = messages.askConfirmationUser({
- idapp,
- username: user?.username,
- nomeapp: user?.nomeapp,
- });
- if (user?.telegram_id) await sendMessage(user.telegram_id, txt);
-});
-
-// helper semplici
-const sendNotifToAdmin = safeExec(async (idapp, title, body = '') => {
- const admins = await getAdminTelegramUsers(String(idapp));
- const txt = `📣 ${title}\n${body}`;
- for (const a of admins) {
- if (a.telegram_id) await sendMessage(a.telegram_id, txt);
- }
-});
-
-const sendNotifToManager = safeExec(async (idapp, title, body = '') => {
- const managers = await getManagersTelegramUsers(String(idapp));
- const txt = `📣 ${title}\n${body}`;
- for (const m of managers) {
- if (m.telegram_id) await sendMessage(m.telegram_id, txt);
- }
-});
-
-const sendNotifToAdminOrManager = safeExec(async (idapp, title, body = '', preferManagers = false) => {
- if (preferManagers) {
- return sendNotifToManager(idapp, title, body);
- }
- return sendNotifToAdmin(idapp, title, body);
-});
-
-module.exports = {
- notifyToTelegram,
- askConfirmationUser,
- sendNotifToAdmin,
- sendNotifToManager,
- sendNotifToAdminOrManager,
- phase, // re-export utile
-};
diff --git a/src/telegram/handlers/registrationHandler.js b/src/telegram/handlers/registrationHandler.js
deleted file mode 100644
index 502a702..0000000
--- a/src/telegram/handlers/registrationHandler.js
+++ /dev/null
@@ -1,50 +0,0 @@
-// telegram/handlers/registrationHandler.js
-const shared_consts = require('../../tools/shared_nodejs');
-const { User } = require('../../models/user');
-const telegrambot = require('../telegram.bot.init'); // per sendMsgTelegramToTheAdminAllSites
-const printf = require('util').format;
-
-const InlineConferma = {
- RISPOSTA_SI: 'SI_',
- RISPOSTA_NO: 'NO_',
-};
-
-async function handleRegistration({ bot, cl, idapp, msg, data, user, userDest, username_action }) {
- let notifyText = '';
-
- // NO alla registrazione
- if (data.action === InlineConferma.RISPOSTA_NO + shared_consts.CallFunz.REGISTRATION) {
- await cl.sendMsg(msg.chat.id, '❌ Registrazione annullata.');
- notifyText = 'Annullata';
- return notifyText;
- }
-
- // SI alla registrazione standard
- if (data.action === InlineConferma.RISPOSTA_SI + shared_consts.CallFunz.REGISTRATION) {
- // set verified (come da tuo codice)
- await User.setVerifiedReg(idapp, data.username, data.userDest);
- await cl.sendMsg(msg.chat.id, '✅ Registrazione confermata.');
- await telegrambot.sendMsgTelegramToTheAdminAllSites(`🆕 Nuova registrazione confermata: ${data.userDest}`);
- notifyText = 'Registrazione OK';
- return notifyText;
- }
-
- // SI/NO alla REGISTRATION_FRIEND
- if (data.action === InlineConferma.RISPOSTA_SI + shared_consts.CallFunz.REGISTRATION_FRIEND) {
- await User.setVerifiedReg(idapp, data.username, data.userDest);
- await cl.sendMsg(msg.chat.id, '🤝 Conferma amicizia completata!');
- notifyText = 'Amicizia OK';
- return notifyText;
- }
-
- if (data.action === InlineConferma.RISPOSTA_NO + shared_consts.CallFunz.REGISTRATION_FRIEND) {
- await cl.sendMsg(msg.chat.id, '🚫 Invito amicizia rifiutato.');
- notifyText = 'Rifiutata';
- return notifyText;
- }
-
- // deleghe future (es. REGISTRATION_TOZOOM gestita in zoomHandler)
- return 'OK';
-}
-
-module.exports = { handleRegistration, InlineConferma };
diff --git a/src/telegram/handlers/userHandler.js b/src/telegram/handlers/userHandler.js
deleted file mode 100644
index 43f2d4a..0000000
--- a/src/telegram/handlers/userHandler.js
+++ /dev/null
@@ -1,15 +0,0 @@
-const { sendMessage, sendPhoto } = require('../api');
-const { formatUser, safeExec } = require('../helpers');
-
-const notifyUser = safeExec(async (user, text) => {
- if (!user?.telegram_id) return;
- const msg = `👋 Ciao ${formatUser(user)}\n${text}`;
- await sendMessage(user.telegram_id, msg);
-});
-
-const sendUserPhoto = safeExec(async (user, photoUrl, caption) => {
- if (!user?.telegram_id) return;
- await sendPhoto(user.telegram_id, photoUrl, caption);
-});
-
-module.exports = { notifyUser, sendUserPhoto };
diff --git a/src/telegram/handlers/userQuery.js b/src/telegram/handlers/userQuery.js
deleted file mode 100644
index e7bdf59..0000000
--- a/src/telegram/handlers/userQuery.js
+++ /dev/null
@@ -1,32 +0,0 @@
-const { User } = require('../../models/user');
-
-async function getTelegramUsersByQuery(query = {}) {
- return User.find({
- ...query,
- telegram_id: { $exists: true, $ne: null },
- }).lean();
-}
-
-async function getAdminTelegramUsers(idapp) {
- return getTelegramUsersByQuery({ idapp, isAdmin: true });
-}
-
-async function getManagersTelegramUsers(idapp) {
- return getTelegramUsersByQuery({ idapp, isManager: true });
-}
-
-async function getFacilitatoriTelegramUsers(idapp) {
- return getTelegramUsersByQuery({ idapp, isFacilitatore: true });
-}
-
-async function getAllTelegramUsersByApp(idapp) {
- return getTelegramUsersByQuery({ idapp });
-}
-
-module.exports = {
- getTelegramUsersByQuery,
- getAdminTelegramUsers,
- getManagersTelegramUsers,
- getFacilitatoriTelegramUsers,
- getAllTelegramUsersByApp,
-};
diff --git a/src/telegram/handlers/zoomHandler.js b/src/telegram/handlers/zoomHandler.js
deleted file mode 100644
index 4f56fd2..0000000
--- a/src/telegram/handlers/zoomHandler.js
+++ /dev/null
@@ -1,27 +0,0 @@
-// telegram/handlers/zoomHandler.js
-const shared_consts = require('../../tools/shared_nodejs');
-const { User } = require('../../models/user');
-
-const InlineConferma = { RISPOSTA_SI: 'SI_', RISPOSTA_NO: 'NO_' };
-
-async function handleZoom({ bot, cl, idapp, msg, data, user, userDest, username_action }) {
- let notifyText = '';
-
- if (data.action === InlineConferma.RISPOSTA_SI + shared_consts.CallFunz.REGISTRATION_TOZOOM) {
- // nelle tue callback originale: conferma registrazione + messaggio
- await User.setVerifiedReg(idapp, data.username, data.userDest);
- await cl.sendMsg(msg.chat.id, '🟢 Accesso Zoom confermato!');
- notifyText = 'Zoom OK';
- return notifyText;
- }
-
- if (data.action === InlineConferma.RISPOSTA_NO + shared_consts.CallFunz.REGISTRATION_TOZOOM) {
- await cl.sendMsg(msg.chat.id, '🚫 Accesso Zoom rifiutato.');
- notifyText = 'Rifiutato';
- return notifyText;
- }
-
- return 'OK';
-}
-
-module.exports = { handleZoom };
diff --git a/src/telegram/helpers.js b/src/telegram/helpers.js
deleted file mode 100644
index 0d5e01a..0000000
--- a/src/telegram/helpers.js
+++ /dev/null
@@ -1,31 +0,0 @@
-function formatUser(user) {
- const u = user || {};
- const username = u.username || (u.profile && u.profile.username_telegram) || 'no_username';
- return `${u.name || ''} ${u.surname || ''} (@${username})`.trim();
-}
-
-function safeExec(fn) {
- return async (...args) => {
- try {
- return await fn(...args);
- } catch (e) {
- console.error('Telegram helper error:', e);
- return null;
- }
- };
-}
-
-function ensureArray(x) {
- if (!x) return [];
- return Array.isArray(x) ? x : [x];
-}
-
-// utility semplice per evitare flood (se ti serve rate-limit: usa bottleneck)
-async function eachSeries(arr, fn) {
- for (const item of arr) {
- // eslint-disable-next-line no-await-in-loop
- await fn(item);
- }
-}
-
-module.exports = { formatUser, safeExec, ensureArray, eachSeries };
diff --git a/src/telegram/index_new_check.js b/src/telegram/index_new_check.js
deleted file mode 100644
index 40d86fc..0000000
--- a/src/telegram/index_new_check.js
+++ /dev/null
@@ -1,66 +0,0 @@
-const messages = require('./messages');
-
-// base api/handlers già creati in precedenza
-const { sendMessage, sendPhoto } = require('./api');
-const { sendToAdmins } = require('./handlers/adminHandler');
-const { notifyUser, sendUserPhoto } = require('./handlers/userHandler');
-const { sendNotification } = require('./handlers/notificationHandler');
-const { reportError } = require('./handlers/errorHandler');
-
-// NUOVI HANDLER aggiunti ora
-const {
- sendMsgTelegram,
- sendMsgTelegramByIdTelegram,
- sendPhotoTelegram,
-} = require('./handlers/directHandler');
-
-const {
- sendMsgTelegramToTheAdminAllSites,
- sendMsgTelegramByIdApp,
- sendMsgTelegramToTheManagers,
- sendMsgTelegramToTheAdmin,
- sendMsgTelegramToTheGroup,
-} = require('./handlers/multiAppHandler');
-
-const {
- notifyToTelegram,
- askConfirmationUser,
- sendNotifToAdmin,
- sendNotifToManager,
- sendNotifToAdminOrManager,
- phase,
-} = require('./handlers/phaseHandler');
-
-module.exports = {
- // messaggi/template
- messages,
- phase,
-
- // API raw
- sendMessage,
- sendPhoto,
-
- // generico
- sendToAdmins,
- notifyUser,
- sendUserPhoto,
- sendNotification,
- reportError,
-
- // EQUIVALENTI del vecchio file
- sendMsgTelegram, // (user, text)
- sendMsgTelegramByIdTelegram, // (telegramId, text)
- sendPhotoTelegram, // (chatIdOrUser, photoUrl, caption)
-
- sendMsgTelegramToTheAdminAllSites, // (text, alsoGroups?)
- sendMsgTelegramByIdApp, // (idapp, text)
- sendMsgTelegramToTheManagers, // (idapp, text)
- sendMsgTelegramToTheAdmin, // (idapp, text)
- sendMsgTelegramToTheGroup, // (chatId, text)
-
- notifyToTelegram, // (phase, locals)
- askConfirmationUser, // (idapp, phase, user)
- sendNotifToAdmin, // (idapp, title, body)
- sendNotifToManager, // (idapp, title, body)
- sendNotifToAdminOrManager, // (idapp, title, body, preferManagers?)
-};
diff --git a/src/telegram/messages.js b/src/telegram/messages.js
deleted file mode 100644
index fda2701..0000000
--- a/src/telegram/messages.js
+++ /dev/null
@@ -1,25 +0,0 @@
-module.exports = {
- // messaggi generici
- serverStarted: (dbName) => `🚀 Il server ${dbName} è stato avviato con successo.`,
- userUnlocked: (user) => `⚠️ L'utente ${user.username} (${user.name} ${user.surname}) è stato sbloccato.`,
- errorOccurred: (context, err) =>
- `❌ Errore in ${context}\n${(err && err.message) || err}`,
- notifyAdmin: (msg) => `📢 Notifica Admin:\n${msg}`,
-
- // fasi logiche
- byPhase: {
- REGISTRATION: (locals = {}) =>
- `🆕 Nuova registrazione su ${locals.nomeapp || 'App'}\nUtente: ${locals.username}`,
- REGISTRATION_CONFIRMED: (locals = {}) =>
- `✅ Registrazione confermata su ${locals.nomeapp || 'App'} da ${locals.username}`,
- RESET_PWD: (locals = {}) =>
- `🔁 Reset password richiesto per ${locals.username}`,
- NOTIFICATION: (locals = {}) =>
- `🔔 Notifica: ${locals.text || ''}`,
- GENERIC: (locals = {}) =>
- `${locals.text || ''}`,
- },
-
- askConfirmationUser: (locals = {}) =>
- `👋 Ciao ${locals.username}!\nConfermi l'operazione su ${locals.nomeapp || 'App'}?`,
-};
diff --git a/src/telegram/prova.txt b/src/telegram/prova.txt
deleted file mode 100644
index 3939fbf..0000000
--- a/src/telegram/prova.txt
+++ /dev/null
@@ -1 +0,0 @@
-http://localhost:8084/signup/paoloar77/SuryaArena/5356627050
diff --git a/src/telegram/telegram.bot.init.js b/src/telegram/telegram.bot.init.js
deleted file mode 100644
index df4346e..0000000
--- a/src/telegram/telegram.bot.init.js
+++ /dev/null
@@ -1,488 +0,0 @@
-/**
- * ======================================================
- * TELEGRAM BOT INIT (derived from telegrambot_OLD.js)
- * ======================================================
- * - Gestione multi-bot per app (arrTelegram)
- * - Classe Telegram con funzioni core
- * - Invio messaggi, immagini, notifiche
- * - Callback Query, menu e inline keyboard
- * - API pubbliche per admin, manager, utenti
- * - Compatibile con tools, User, Circuit, ecc.
- * ======================================================
- */
-
-const TelegramBot = require('node-telegram-bot-api');
-const fs = require('fs');
-const path = require('path');
-const axios = require('axios');
-const sharp = require('sharp');
-
-const tools = require('../tools/general');
-const shared_consts = require('../tools/shared_nodejs');
-const server_constants = require('../tools/server_constants');
-const { Site } = require('../models/site');
-
-const { handleCallback } = require('./handlers/callbackHandler');
-
-
-// -----------------------------------------------------------------------------
-// 🔹 COSTANTI, ENUM, EMOJI E TEXT
-// -----------------------------------------------------------------------------
-const emo = {
- JOY: '😂',
- JOY2: '🤣',
- DANCER: '💃',
- STARS: '✨',
- FIRE: '🔥',
- SUN: '☀️',
- TV: '📺',
- NEWSPAPER: '🗞',
- KISS: '😘',
- PENCIL: '✏️',
- DREAM: '🏖',
- EYES: '😜',
- DIZZY: '💫',
- ONE_HUNDRED: '💯',
- SMILE_STAR: '🤩', // Star-struck
- LEFT_FACING_FIST: '🤛', // Left-facing fist
- CHECK_VERDE: '✅', // White check mark (verde)
- CHECK_GRIGIA: '☑️', // Ballot box with check (grigia)
- CROSS_ROSSA: '❌', // X (rossa)
- ENVELOPE: '✉️', // Envelope
- EXCLAMATION_MARK: '❗', // Exclamation mark
- QUESTION_MARK: '❓', // Question mark
- ARROW_RIGHT: '➡️', // Arrow pointing to the right
- INVITATI: '',
- HEART: '❤️',
- BLUE_HEART: '💙',
- GREEN_HEART: '💚',
- YELLOW_HEART: '💛',
- PURPLE_HEART: '💜',
- GIFT_HEART: '💝',
- GIFT: '🎁',
- ROBOT_FACE: '🤖',
- ADMIN: '💁',
- MALE: '💁♂️',
- FEMALE: '👩🦱',
- INNOCENT: '😇',
- CREDIT_CARD: '💳',
- PERSON: '🧑',
-};
-
-MsgBot = {
- OK: ['si', 'ok'],
- CUORE: ['❤️', '💚️', '💜'],
- CIAO: ['ciao', 'ciaoo', 'hola', 'holaa', 'hey', 'salve', 'buongiorno', 'buondi', 'ciao ❤️'],
- CI_SEI: ['ci sei', "c'è qualcuno", "c'è nessuno"],
- CHI_SONO_IO: ['chi sono io', 'chi sono'],
- COME_STAI: ['tutto bene', 'come stai', 'come stai', 'come va', 'come butta', 'come va oggi'],
- COME_TI_CHIAMI: [
- 'chi sei',
- 'come ti chiami',
- "qual'è il tuo nome",
- "qual'e' il tuo nome",
- 'che lavoro fai',
- 'di cosa ti occupi',
- ],
- COSA_FAI: ['cosa fai', 'cosa combini', 'che fai'],
- QUANTI_ANNI_HAI: ['quanti anni hai', 'che età hai'],
- SEI_LIBERO_STASERA: [
- 'sei libera stasera',
- 'sei libero stasera',
- 'usciamo insieme',
- "fare l'amore con me",
- 'fare sesso',
- 'vuoi scopare',
- 'vuoi trombare',
- ],
- MI_TROVI_UN_MOROSO: [
- 'trovi un moroso',
- 'una morosa',
- 'fidanzato',
- 'fidanzata',
- 'trovi un marito',
- 'trovi una moglie',
- ],
- CHAT_EMPOWER: ['chat empower'],
- MASCHIO_FEMMINA: ['sei uomo o donna', 'sei maschio o femmina', 'sei ragazzo o ragazza', 'che sesso hai'],
- DAMMI_UN_BACIO: ['dammi un bacio', 'baciami'],
- HAHA: ['hahaha', 'ahah', '😂'],
- MI_AMI: ['mi ami'],
- TI_AMO: ['ti amo', 'ti adoro', 'ti lovvo'],
- PREGO: ['prego', 'Prego ! 💋💋💋'],
- GRAZIE: ['grazie ainy', 'grazie', 'grazie mille', 'graziee', 'grazie ❤', 'grazie️❤', 'grazie 😘', 'grazie😘'],
- PRINCIPE_AZZURRO: ['principe azzurro'],
- START_INV: ['/start inv'],
- COSE_COVID: ["cos'è il covid", 'cosa è il covid'],
- COVID: ['covid'],
- SPOSAMI: ['sposami', 'vuoi sposar', 'sei sposat', 'ci sposiamo', 'ti sposo', 'sei sposat', 'mi sposi'],
- CHE_TEMPO_FA: ['che tempo'],
- NON_TROO_INVITATI: ['non trovo invitati', 'non riesco a trovare invitati'],
- TROVAMI_UN_UOMO_DONNA: ['trovami un uomo', 'trovami una donna', 'esiste una donna per me', 'esiste un uomo per me'],
- PAROLACCE: ['stronz', 'fanculo', 'fottiti', 'cagare', 'ammazzat', 'muori', 'cretino', 'stupido'],
- COME_SI_CHIAMA: ['come si chiama'],
- PROSSIMO_ZOOM: ['prossimo zoom', 'fare lo zoom', 'gli zoom', 'conferenz', 'zoom'],
- LAVAGNA: ['lavagna', 'Lavagna', 'LAVAGNA'],
- SEI_LIBERO_DI_RESPIRARE: ['sei libero di respirare'],
- SEI_LIBERO: ['sei liber', 'sei sposat', 'sei fidanzat', 'sei single'],
- AIUTO: [
- 'help',
- 'aiuto',
- 'ho bisogno di',
- 'ho problemi',
- 'non riesco',
- 'mi puoi aiutare',
- 'mi aiuti',
- 'aiutami',
- 'posso chiederti',
- 'puoi aiutarmi',
- ],
- UOMO: ['uomo', 'maschio'],
- SORPRESA: ['noo', 'davvero', 'sii', 'facciamo festa', 'è qui la festa', 'festa'],
- UGUALE: ['👍🏻', '✨', '❤🏻', '⭐', '❤', '❤❤', '🤩'],
- SI: ['si', 'yes'],
- NO: ['no', 'noo'],
- DONNA: ['donna', 'femmina'],
- FARE_DOMANDA: ['fare una domanda', 'posso farti una domanda'],
- DIVENTERO_RICCA: ['diventerò ricc'],
- DOVE_VUOI_VIVERE: ['dove vuoi vivere'],
- MA_ALLORA: ['ma allora'],
-};
-
-const MsgRisp = {
- CHAT_EMPOWER:
- 'Entra nella Chat EMPOWER !!!\n' +
- 'https://t.me/joinchat/C741mkx5QYXu-kyYCYvA8g ' +
- emo.PURPLE_HEART +
- emo.GIFT_HEART +
- emo.BLUE_HEART,
-};
-
-function getemojibynumber(number) {
- if (number === 0) {
- return '0️⃣'; // zero
- } else if (number === 1) {
- return '1️⃣'; // one
- } else if (number === 2) {
- return '2️⃣'; // two
- } else if (number === 3) {
- return '3️⃣'; // three
- } else if (number === 4) {
- return '4️⃣'; // four
- } else if (number === 5) {
- return '5️⃣'; // five
- } else if (number === 6) {
- return '6️⃣'; // six
- } else if (number === 7) {
- return '7️⃣'; // seven
- } else if (number === 8) {
- return '8️⃣'; // eight
- } else if (number === 9) {
- return '9️⃣'; // nine
- } else {
- return number;
- }
-}
-
-const Menu = {
- LANG_IT: '🇮🇹 Italiano', // Bandiera italiana
- LANG_EN: '🇬🇧 English', // Bandiera del Regno Unito
- LANG_ES: '🇪🇸 Español', // Bandiera spagnola
- LANG_FR: '🇫🇷 Français', // Bandiera francese
- LANG_SI: '🇸🇮 Slovenski', // Bandiera slovena
- LANG_PT: '🇵🇹 Português', // Bandiera portoghese
- LANG: '🌐 Language', // Globo con meridiani
- CHAT_PERSONALE: '👩💼💻', // Donna impiegata + computer
- EXIT_TELEGRAM: 'exittotelegram',
- MSG_TO_USER: 'sendmsgto',
- ADMIN: '💁♀️ Admin', // Persona al banco informazioni
- AIUTO: '🔮 Help', // Cristallo magico
- ALTRO: '📰 Altro', // Giornale
- SETPICPROFILE: '🖼 SetPicProfile', // Cornice con foto
- RESETPWD: '🔑 SetResetPwd', // Chiave
- MSG_SI_INVITATI_NO_7REQ_INVITATI: '📩Inv e NO 7 Req', // Busta
- MSGSTAFF: '📩 Invia a STAFF', // Busta
- MSGAPPARTIENE_CIRCUITI_RIS: 'Invia a Utenti dei Circuiti RIS',
- MSGPAOLO: '📩 Invia a SURYA', // Busta
- RESTART_SRV: '📩Restart-NodeJs', // Busta
- REBOOT_SRV: '📩Reboot-VPS!', // Busta
- EXECSH: '📩ExecSH', // Busta
- LOG_SRV: '🖥Logserver.sh', // Monitor
- MSGATUTTI: '📩 Invia a TUTTI', // Busta
- it: {
- ACCEDI: '👤 Accedi', // Persona
- LAVAGNA: '🕉 Lavagna', // Simbolo Om
- LINK_CONDIVIDERE: '🔗 Link da condividere', // Link
- ZOOM: 'ℹ️ Zoom (Conferenze)', // Informazione
- INFO: 'ℹ️ Informazioni', // Informazione
- ASSISTENZA: '👐 Le Chat', // Mani aperte
- INDIETRO: '🔙 Indietro', // Freccia indietro
- SI: '👍 SI', // Pollice su
- NO: '👎 NO', // Pollice giù
- ESCI_DA_CHAT: '📩 Esci dalla Conversazione', // Busta
- NUOVOSITO: '',
- },
- es: {
- ACCEDI: '👤 Entra',
- LAVAGNA: '🕉 Tablero',
- LINK_CONDIVIDERE: '🔗 Enlaces para compartir',
- ZOOM: 'ℹ️ Zoom (Conferencias)',
- INFO: 'ℹ️ Información',
- ASSISTENZA: '👐 Chats',
- INDIETRO: '🔙 Volver',
- SI: '👍 SÍ',
- NO: '👎 NO',
- ESCI_DA_CHAT: '📩 Salir de la conversación',
- },
- fr: {
- ACCEDI: '👤 Entrez',
- LAVAGNA: '🕉 Tableau de bord',
- LINK_CONDIVIDERE: '🔗 Liens à partager',
- ZOOM: 'ℹ️ Zoom (Conférences)',
- INFO: 'ℹ️ Informations',
- ASSISTENZA: '👐 Les chats',
- INDIETRO: '🔙 Retour',
- SI: '👍 OUI',
- NO: '👎 NON',
- ESCI_DA_CHAT: '📩 Quitter la conversation',
- },
- si: {
- ACCEDI: '👤 Prijava',
- LAVAGNA: '🕉 Tabla',
- LINK_CONDIVIDERE: '🔗 Link za vpis oseb',
- ZOOM: 'ℹ️ Zoom (Konference)',
- INFO: 'ℹ️ Informacije',
- ASSISTENZA: '👐 jev klepet',
- INDIETRO: '🔙 Nazaj',
- SI: '👍 DA',
- NO: '👎 NE',
- ESCI_DA_CHAT: '📩 Zaprite pogovor',
- },
- pt: {
- ACCEDI: '👤 Entre',
- LAVAGNA: '🕉 Tablero',
- LINK_CONDIVIDERE: '🔗 Links para compartilhar',
- ZOOM: 'ℹ️ Zoom (Conferências)',
- INFO: 'ℹ️ Informações',
- ASSISTENZA: '👐 Chats',
- INDIETRO: '🔙 Voltar',
- SI: '👍 SIM',
- NO: '👎 NÃO',
- ESCI_DA_CHAT: '📩 Sair da Conversa',
- },
- enUs: {
- ACCEDI: '👤 Enter',
- LAVAGNA: '🕉 DashBoard',
- LINK_CONDIVIDERE: '🔗 Link to Share',
- ZOOM: 'ℹ️ Zoom (Conference)',
- INFO: 'ℹ️ Info',
- ASSISTENZA: '👐 Chats',
- INDIETRO: '🔙 Back',
- SI: '👍 YES',
- NO: '👎 NO',
- ESCI_DA_CHAT: '📩 Exit to the Conversation',
- },
-};
-
-const CONTA_SOLO = 'contasolo';
-const RICEVI_EMAIL = 'riceviemail';
-const NOME_COGNOME = 'nomecognome';
-const CHEDI_SE_IMBARCARTI = 'chiedi_se_imbarcarti';
-
-const phase = {
- REGISTRATION: 'REGISTRATION',
- REGISTRATION_CONFIRMED: 'REGISTRATION_CONFIRMED',
- RESET_PWD: 'RESET_PWD',
- NOTIFICATION: 'NOTIFICATION',
-};
-
-const roles = {
- ADMIN: 'ADMIN',
- MANAGER: 'MANAGER',
- FACILITATORE: 'FACILITATORE',
- EDITOR: 'EDITOR',
- SOCIO: 'SOCIO',
-};
-
-// -----------------------------------------------------------------------------
-// 🔹 REGISTRY MULTI-BOT (arrTelegram)
-// -----------------------------------------------------------------------------
-const arrTelegram = [];
-
-function getclTelegByidapp(idapp) {
- const rec = arrTelegram.find((r) => String(r.idapp) === String(idapp));
- return rec ? rec.cl : null;
-}
-function getclTelegBytoken(token) {
- const rec = arrTelegram.find((r) => r.cl?.token === token);
- return rec ? rec.cl : null;
-}
-
-// -----------------------------------------------------------------------------
-// 🔹 FUNZIONI LOCALI
-// -----------------------------------------------------------------------------
-async function local_sendMsgTelegram(idapp, username, text) {
- const teleg_id = await User.TelegIdByUsername(idapp, username);
- const cl = getclTelegByidapp(idapp);
- if (cl && teleg_id) return await cl.sendMsg(teleg_id, text);
- return null;
-}
-
-async function local_sendMsgTelegramToTheManagers(idapp, text, msg, username_bo) {
- const managers = await User.getusersManagers(idapp);
- const username = username_bo || msg?.chat?.username;
- const fullmsg = `${emo.ROBOT_FACE}: Da ${tools.getNomeCognomeTelegram(msg)} (${username})\n${text}`;
- if (managers)
- for (const m of managers) {
- const cl = getclTelegByidapp(idapp);
- if (cl && m.profile?.teleg_id)
- await cl.sendMsg(m.profile.teleg_id, fullmsg, undefined, undefined, undefined, undefined, true);
- }
- return true;
-}
-
-// -----------------------------------------------------------------------------
-// 🔹 CLASSE TELEGRAM
-// -----------------------------------------------------------------------------
-class Telegram {
- constructor(idapp, bot) {
- this.idapp = idapp;
- this.bot = bot;
- this.token = bot.token;
- this.arrUsers = [];
- this.lastid = 0;
- }
-
- // Invia un messaggio base
- async sendMsg(chatId, text, parseMode = 'HTML', MyForm = null, message_id, chat_id, ripr_menuPrec, img) {
- if (!chatId) return;
- try {
- await this.bot.sendMessage(chatId, text, { parse_mode: parseMode });
- } catch (err) {
- console.error('❌ sendMsg error:', err.message);
- }
- }
-
- // Invia immagine con fallback
- async sendImageToTelegram(chatId, imgPath, caption = '') {
- if (!chatId || !imgPath) return;
- try {
- const buffer = fs.readFileSync(imgPath);
- const sharped = await sharp(buffer).resize({ width: 1280 }).toBuffer();
- await this.bot.sendPhoto(chatId, sharped, { caption });
- } catch (err) {
- console.error('⚠️ sendImageToTelegram fallback:', err.message);
- try {
- await this.bot.sendDocument(chatId, imgPath, { caption });
- } catch (e) {
- console.error('❌ sendDocument fallback:', e.message);
- }
- }
- }
-
- // Placeholder per ricezione messaggi
- async receiveMsg(msg) {
- console.log('💬', this.idapp, msg.text);
- }
-
- // Placeholder per start
- async start(msg) {
- await this.sendMsg(msg.chat.id, `${emo.ROBOT_FACE} Benvenuto nel bot ${tools.getNomeAppByIdApp(this.idapp)}!`);
- }
-
- // Inline keyboard esempio
- getInlineKeyboard(buttons) {
- return { reply_markup: { inline_keyboard: buttons } };
- }
-}
-
-// -----------------------------------------------------------------------------
-// 🔹 API PUBBLICHE
-// -----------------------------------------------------------------------------
-async function sendMsgTelegramToTheAdminAllSites(text, senzaintestazione) {
- const apps = await tools.getApps();
- for (const app of apps) {
- const filled = text.replace('{appname}', tools.getNomeAppByIdApp(app.idapp));
- await sendMsgTelegramToTheAdmin(app.idapp, filled, senzaintestazione);
- }
-}
-
-async function sendMsgTelegramToTheAdmin(idapp, text, senzaintestazione) {
- const usersadmin = await User.getusersAdmin(idapp);
- let head = emo.ROBOT_FACE + '[BOT-ADMIN]' + emo.ADMIN + ': ';
- if (senzaintestazione) head = '';
- if (usersadmin)
- for (const rec of usersadmin) {
- if (User.isAdmin(rec.perm)) {
- await sendMsgTelegramByIdTelegram(idapp, rec.profile.teleg_id, head + text);
- await tools.snooze(300);
- }
- }
- return true;
-}
-
-async function sendMsgTelegramByIdTelegram(idapp, idtelegram, text, message_id, chat_id, ripr_menuPrec, MyForm = null, img = '') {
- if (!idtelegram) return;
- const cl = getclTelegByidapp(idapp);
- if (cl) return await cl.sendMsg(idtelegram, text, null, MyForm, message_id, chat_id, ripr_menuPrec, img, { idapp });
-}
-
-async function sendMsgTelegramToTheManagers(idapp, text) {
- const managers = await User.getusersManagers(idapp);
- if (managers)
- for (const rec of managers) {
- await sendMsgTelegramByIdTelegram(idapp, rec.profile.teleg_id, text);
- await tools.snooze(300);
- }
- return true;
-}
-
-// -----------------------------------------------------------------------------
-// 🔹 CALLBACK QUERY HANDLER (semplificata ma compatibile)
-// -----------------------------------------------------------------------------
-function setupCallback(bot, cl) {
- bot.on('callback_query', async (callbackQuery) => {
- await handleCallback(bot, cl, callbackQuery);
- });
-}
-
-// -----------------------------------------------------------------------------
-// 🔹 INIZIALIZZAZIONE BOT MULTI-APP
-// -----------------------------------------------------------------------------
-async function initTelegramBots() {
- const arrApps = await tools.getApps();
- for (const app of arrApps) {
- const idapp = app.idapp;
- const token = tools.getTelegramKeyByIdApp(idapp);
- const nomebot = tools.getTelegramBotNameByIdApp(idapp);
- if (!token) continue;
-
- console.log(`🤖 Avvio BOT: ${nomebot} (${idapp})`);
- const bot = new TelegramBot(token, { polling: true });
- const cl = new Telegram(idapp, bot);
- arrTelegram.push({ idapp, cl });
-
- bot.onText(/\/start/, (msg) => cl.start(msg));
- bot.on('message', async (msg) => cl.receiveMsg(msg));
- setupCallback(bot, cl);
- }
-}
-
-// -----------------------------------------------------------------------------
-// 🔹 ESPORTAZIONI PUBBLICHE
-// -----------------------------------------------------------------------------
-module.exports = {
- Telegram,
- initTelegramBots,
- getclTelegByidapp,
- getclTelegBytoken,
- sendMsgTelegramToTheAdminAllSites,
- sendMsgTelegramToTheAdmin,
- sendMsgTelegramByIdTelegram,
- sendMsgTelegramToTheManagers,
- local_sendMsgTelegram,
- local_sendMsgTelegramToTheManagers,
- phase,
- roles,
- emo,
-};
diff --git a/src/tools/shared_nodejs.js b/src/tools/shared_nodejs.js
index cdc35ec..548a7e0 100755
--- a/src/tools/shared_nodejs.js
+++ b/src/tools/shared_nodejs.js
@@ -1330,5 +1330,6 @@ module.exports = {
JOB_TO_EXECUTE: {
MIGRATION_SECTORS_DIC25: 'Migration_Sectors_Dic_2025',
+ MIGRATION_TELEGRAM_30DIC25: 'Migration_Telegram_30Dic_2025',
},
};