t.me/c/1234567890/8 → Thread ID = 8",
+ parse_mode="HTML"
+ )
+ return
+
+ message = f"📋 Threads Disponibles ({len(topics)})\n\n"
+ for topic in topics:
+ name = topic.get('name', f'Thread {topic["id"]}')
+ thread_id = topic['id']
+ message += f"• {self.escape_html(name)} → Thread ID: {thread_id}\n"
+
+ await update.message.reply_text(message, parse_mode="HTML")
+ except Exception as e:
+ self.logger.error(f"Error en comando /threads: {e}")
+ await update.message.reply_text(
+ "❌ Error obteniendo threads. Usa el método manual:\n\n"
+ "1. Haz clic derecho en el tema\n"
+ "2. Copia el enlace del tema\n"
+ "3. El número al final es el Thread ID"
+ )
+
async def handle_favs_command(self, update: telegram.Update, context: telegram.ext.ContextTypes.DEFAULT_TYPE):
"""Maneja el comando /favs para mostrar los favoritos"""
if not self._article_cache:
@@ -326,7 +400,7 @@ class TelegramManager:
]
]
else:
- keyboard = [
+ keyboard = [
[
InlineKeyboardButton("⭐ Añadir a favoritos", callback_data=f"fav_{platform}_{article_id}_Unknown")
]
diff --git a/wallamonitor.py b/wallamonitor.py
index fbc1025..be9c175 100644
--- a/wallamonitor.py
+++ b/wallamonitor.py
@@ -91,15 +91,9 @@ def load_cache_config():
with open(config_path, 'r') as f:
config = yaml.safe_load(f)
cache_config = config.get('cache', {})
- cache_type = cache_config.get('type', 'memory')
+ cache_type = cache_config.get('type', 'redis')
- if cache_type == 'memory':
- memory_config = cache_config.get('memory', {})
- return {
- 'cache_type': 'memory',
- 'limit': memory_config.get('limit', 300)
- }
- elif cache_type == 'redis':
+ if cache_type == 'redis':
redis_config = cache_config.get('redis', {})
return {
'cache_type': 'redis',
@@ -109,16 +103,22 @@ def load_cache_config():
'redis_password': redis_config.get('password')
}
else:
- logger.warning(f"Tipo de cache desconocido: {cache_type}, usando 'memory'")
+ logger.warning(f"Tipo de cache desconocido: {cache_type}, usando 'redis' por defecto")
return {
- 'cache_type': 'memory',
- 'limit': 300
+ 'cache_type': 'redis',
+ 'redis_host': 'localhost',
+ 'redis_port': 6379,
+ 'redis_db': 0,
+ 'redis_password': None
}
except Exception as e:
- logger.warning(f"Error cargando configuración de cache, usando valores por defecto (memory): {e}")
+ logger.warning(f"Error cargando configuración de cache, usando valores por defecto (redis): {e}")
return {
- 'cache_type': 'memory',
- 'limit': 300
+ 'cache_type': 'redis',
+ 'redis_host': 'localhost',
+ 'redis_port': 6379,
+ 'redis_db': 0,
+ 'redis_password': None
}
class WorkerManager:
diff --git a/web/backend/server.js b/web/backend/server.js
index 9594fd2..34549e7 100644
--- a/web/backend/server.js
+++ b/web/backend/server.js
@@ -327,6 +327,51 @@ app.delete('/api/favorites/:platform/:id', async (req, res) => {
}
});
+// Limpiar toda la caché de Redis
+app.delete('/api/cache', async (req, res) => {
+ try {
+ if (!redisClient) {
+ return res.status(500).json({ error: 'Redis no está disponible' });
+ }
+
+ // Obtener todas las claves que empiezan con 'notified:'
+ const keys = await redisClient.keys('notified:*');
+
+ if (!keys || keys.length === 0) {
+ return res.json({
+ success: true,
+ message: 'Cache ya está vacío',
+ count: 0
+ });
+ }
+
+ // Eliminar todas las claves
+ const count = keys.length;
+ for (const key of keys) {
+ await redisClient.del(key);
+ }
+
+ // Notificar a los clientes WebSocket
+ broadcast({
+ type: 'cache_cleared',
+ data: { count, timestamp: Date.now() }
+ });
+
+ // También actualizar favoritos (debería estar vacío ahora)
+ const favorites = await getFavorites();
+ broadcast({ type: 'favorites_updated', data: favorites });
+
+ res.json({
+ success: true,
+ message: `Cache limpiado: ${count} artículos eliminados`,
+ count
+ });
+ } catch (error) {
+ console.error('Error limpiando cache de Redis:', error);
+ res.status(500).json({ error: error.message });
+ }
+});
+
// Obtener artículos notificados
app.get('/api/articles', async (req, res) => {
try {
@@ -454,6 +499,64 @@ app.get('/api/config', (req, res) => {
}
});
+// Obtener threads/topics de Telegram
+app.get('/api/telegram/threads', async (req, res) => {
+ try {
+ if (!config) {
+ config = yaml.parse(readFileSync(CONFIG_PATH, 'utf8'));
+ }
+
+ const token = config?.telegram_token;
+ const channel = config?.telegram_channel;
+
+ if (!token || !channel) {
+ return res.status(400).json({ error: 'Token o canal de Telegram no configurados' });
+ }
+
+ // Convertir el canal a chat_id si es necesario
+ let chatId = channel;
+ if (channel.startsWith('@')) {
+ // Para canales con @, necesitamos obtener el chat_id primero
+ const getChatUrl = `https://api.telegram.org/bot${token}/getChat?chat_id=${encodeURIComponent(channel)}`;
+ const chatResponse = await fetch(getChatUrl);
+ const chatData = await chatResponse.json();
+
+ if (!chatData.ok) {
+ return res.status(400).json({ error: `Error obteniendo chat: ${chatData.description || 'Chat no encontrado'}` });
+ }
+
+ chatId = chatData.result.id;
+ }
+
+ // Intentar obtener forum topics
+ const forumTopicsUrl = `https://api.telegram.org/bot${token}/getForumTopics?chat_id=${chatId}&limit=100`;
+ const topicsResponse = await fetch(forumTopicsUrl);
+ const topicsData = await topicsResponse.json();
+
+ if (topicsData.ok && topicsData.result?.topics) {
+ const threads = topicsData.result.topics.map(topic => ({
+ id: topic.message_thread_id,
+ name: topic.name || `Thread ${topic.message_thread_id}`,
+ icon_color: topic.icon_color,
+ icon_custom_emoji_id: topic.icon_custom_emoji_id,
+ }));
+
+ return res.json({ threads, success: true });
+ } else {
+ // Si no hay forum topics, devolver un mensaje informativo
+ return res.json({
+ threads: [],
+ success: false,
+ message: 'El chat no tiene forum topics habilitados o no se pudieron obtener. Puedes obtener el Thread ID manualmente copiando el enlace del tema.',
+ info: 'Para obtener el Thread ID manualmente: 1. Haz clic derecho en el tema/hilo en Telegram 2. Selecciona "Copiar enlace del tema" 3. El número al final de la URL es el Thread ID (ej: t.me/c/1234567890/8 → Thread ID = 8)'
+ });
+ }
+ } catch (error) {
+ console.error('Error obteniendo threads de Telegram:', error.message);
+ res.status(500).json({ error: error.message });
+ }
+});
+
// WebSocket connection
wss.on('connection', (ws) => {
console.log('Cliente WebSocket conectado');
diff --git a/web/frontend/src/services/api.js b/web/frontend/src/services/api.js
index f04139f..1853173 100644
--- a/web/frontend/src/services/api.js
+++ b/web/frontend/src/services/api.js
@@ -69,5 +69,17 @@ export default {
const response = await api.get('/config');
return response.data;
},
+
+ // Telegram
+ async getTelegramThreads() {
+ const response = await api.get('/telegram/threads');
+ return response.data;
+ },
+
+ // Cache
+ async clearCache() {
+ const response = await api.delete('/cache');
+ return response.data;
+ },
};
diff --git a/web/frontend/src/views/Workers.vue b/web/frontend/src/views/Workers.vue
index c4f038a..cc0230e 100644
--- a/web/frontend/src/views/Workers.vue
+++ b/web/frontend/src/views/Workers.vue
@@ -6,6 +6,9 @@
+
@@ -226,8 +229,47 @@
Opcional: ID del hilo donde enviar notificaciones
+ + +Threads disponibles:
+{{ threadsMessage }}
+{{ threadsInfo }}
+