297600e3c8
* New file with all configuration parameters. * Remove all env var usage and use new config.
31 lines
937 B
JavaScript
31 lines
937 B
JavaScript
const telegramPoller = require('./telegramPoller');
|
|
const { User } = require('../models');
|
|
const config = require('../config/config');
|
|
|
|
async function initializeTelegramPolling() {
|
|
if (config.environment === 'test' || config.disableTelegram) {
|
|
return;
|
|
}
|
|
|
|
try {
|
|
// Find users with configured Telegram tokens
|
|
const usersWithTelegram = await User.findAll({
|
|
where: {
|
|
telegram_bot_token: {
|
|
[require('sequelize').Op.ne]: null,
|
|
},
|
|
},
|
|
});
|
|
|
|
if (usersWithTelegram.length > 0) {
|
|
// Add each user to the polling list
|
|
for (const user of usersWithTelegram) {
|
|
await telegramPoller.addUser(user);
|
|
}
|
|
}
|
|
} catch (error) {
|
|
// Telegram polling will be initialized later when the database is available
|
|
}
|
|
}
|
|
|
|
module.exports = { initializeTelegramPolling };
|