Crea un bot de picks para Telegram con cuotas de Pinnacle en vivo
Este bot vigila los precios de Pinnacle en el WebSocket de PinnFeed y publica un mensaje en un canal de Telegram cada vez que un mercado hace steam, es decir, cuando su cuota baja un 5% o más en dos minutos en un mercado con una apuesta máxima razonable. Es un solo archivo de unas 70 líneas, sin librería de Telegram: llama directamente a la Bot API.
Paso 1 — Crea el bot#
- En Telegram, abre @BotFather, envía
/newboty sigue las instrucciones. Copia el token. - Crea un canal y añade el bot como administrador con permiso para publicar.
- Usa el nombre público del canal (
@mychannel) como chat id, o el id numérico para un chat privado.
Paso 2 — Configura el entorno#
export PINNFEED_KEY="pf_live_..." # plan Builder (WebSocket)
export TELEGRAM_TOKEN="123456:ABC..." # de @BotFather
export TELEGRAM_CHAT="@mychannel"
npm install ws
Si dejas TELEGRAM_TOKEN sin definir, el bot funciona en modo de prueba: imprime los mensajes en vez de enviarlos.
Paso 3 — El bot#
Guárdalo como telegram-picks-bot.mjs:
// telegram-picks-bot.mjs: publica los movimientos steam de Pinnacle en un canal de Telegram como "picks".
// npm install ws Node 18+ (global fetch)
// entorno: PINNFEED_KEY, TELEGRAM_TOKEN (de @BotFather), TELEGRAM_CHAT (p. ej. @mychannel o un id de chat)
import WebSocket from 'ws';
const WS_URL = process.env.PINNFEED_WS || 'wss://pinnfeed.io/v1/stream';
const { PINNFEED_KEY, TELEGRAM_TOKEN, TELEGRAM_CHAT } = process.env;
const MIN_DROP = Number(process.env.MIN_DROP || 0.05); // bajada del 5%...
const WINDOW_MS = Number(process.env.WINDOW_MS || 120000); // ...en menos de 2 minutos
const SIDES = new Set(['home', 'away', 'draw', 'over', 'under']);
const events = new Map();
const highs = new Map(); // "marketId|outcome" -> [{t, p}]
const sent = new Map(); // "marketId|outcome" -> hora de la última alerta
async function post(text) {
if (!TELEGRAM_TOKEN) return console.log('[dry run]', text);
const r = await fetch(`https://api.telegram.org/bot${TELEGRAM_TOKEN}/sendMessage`, {
method: 'POST', headers: { 'content-type': 'application/json' },
body: JSON.stringify({ chat_id: TELEGRAM_CHAT, text, disable_web_page_preview: true }),
});
if (!r.ok) console.error('telegram', r.status, await r.text());
}
function check(m) {
const ev = events.get(m.eventId);
if (!ev || (m.maxStake ?? 0) < 500) return;
const now = Date.now();
for (const o of m.outcomes) {
if (!SIDES.has(o.name)) continue;
const k = `${m.id}|${o.name}`;
const h = (highs.get(k) || []).filter((x) => now - x.t < WINDOW_MS);
h.push({ t: now, p: o.decimal });
highs.set(k, h);
const high = Math.max(...h.map((x) => x.p));
const drop = 1 - o.decimal / high;
if (drop < MIN_DROP || now - (sent.get(k) || 0) < WINDOW_MS) continue;
sent.set(k, now);
const pick = o.name === 'home' ? ev.home : o.name === 'away' ? ev.away : o.name;
const line = o.points == null ? '' : m.type === 'total' ? ` ${o.points}` : ` ${o.points > 0 ? '+' : ''}${o.points}`;
post(`📉 ${ev.sport.toUpperCase()} · ${ev.league?.name ?? ''}\n${ev.home} v ${ev.away}\n` +
`Pick: ${pick} (${m.type}${line})\nPinnacle ${high.toFixed(2)} → ${o.decimal.toFixed(2)} (−${(drop * 100).toFixed(1)}%)\n` +
`Fair now ${o.fair.toFixed(2)} · max stake ${m.maxStake}`);
}
}
function connect(delay = 1000) {
const ws = new WebSocket(WS_URL, { headers: { 'x-api-key': PINNFEED_KEY }, perMessageDeflate: true });
ws.on('open', () => {
delay = 1000;
ws.send(JSON.stringify({ type: 'subscribe', sports: ['soccer', 'tennis', 'basketball'], markets: ['moneyline', 'spread', 'total'], main: true, specials: false }));
});
ws.on('message', (raw) => {
const msg = JSON.parse(raw);
if (msg.type === 'ping') return ws.send('{"type":"pong"}');
if (msg.type === 'snapshot') msg.events.forEach((e) => events.set(e.id, e));
if (msg.type === 'delta') for (const c of msg.changes) {
if (c.kind === 'event') c.op === 'upsert' ? events.set(c.event.id, c.event) : events.delete(c.id);
if (c.kind === 'market' && c.op === 'upsert') check(c.market);
}
});
ws.on('close', () => setTimeout(() => connect(Math.min(delay * 2, 30000)), delay));
ws.on('error', (e) => console.error('ws error:', e.message));
}
connect();
Paso 4 — Ejecútalo y pruébalo#
node telegram-picks-bot.mjs
Un mensaje tiene este aspecto:
📉 SOCCER · Italy - Serie A
Udinese v Fiorentina
Pick: Udinese (spread +0.25)
Pinnacle 1.88 → 1.70 (−9.5%)
Fair now 1.83 · max stake 500
Ajusta el volumen con MIN_DROP y WINDOW_MS; por ejemplo, MIN_DROP=0.08 para menos alertas y más fuertes.
Paso 5 — Mantenlo en marcha#
- Ejecútalo con
systemd,pm2o un contenedor que se reinicie si falla; el bot se reconecta solo al WebSocket. - Telegram permite unos 20 mensajes por minuto por grupo o canal. Sube
MIN_DROPsi recibes respuestas429. - Publica tu historial con honestidad: registra cada pick y mídelo con el valor de la línea de cierre.
Preguntas frecuentes#
¿Qué plan de PinnFeed necesita el bot?#
Builder (99 €/mes) o superior, porque usa el WebSocket. Para un bot más lento en Free o Hobby, haz polling a /v1/drops cada minuto.
¿Puedo publicar los picks en Discord?#
Sí. Sustituye la función post por un POST a la URL de un webhook de Discord con el cuerpo {"content": text}.
¿Es legal publicar picks?#
Las normas sobre pronósticos y publicidad de apuestas cambian según el país (en España, por ejemplo, la publicidad del juego está regulada). Revisa las normas de donde estés tú y tu audiencia, dirígete solo a mayores de 18 años y nunca presentes los picks como seguros.