diff --git a/lib/alerts/telegram.mjs b/lib/alerts/telegram.mjs index 4288b02..36a06cf 100644 --- a/lib/alerts/telegram.mjs +++ b/lib/alerts/telegram.mjs @@ -271,7 +271,7 @@ export class TelegramAlerter { headline: `OSINT Surge: ${osintNew.length} New Urgent Posts`, reason: `${osintNew.length} new urgent OSINT signals detected. Elevated conflict reporting tempo.`, actionable: 'Review OSINT stream for pattern. Cross-check with satellite and ACLED data.', - signals: osintNew.map(s => (s.text || '').substring(0, 40)).slice(0, 3), + signals: osintNew.map(s => s.text || s.label || s.key).slice(0, 5), crossCorrelation: 'telegram OSINT', }; } @@ -728,7 +728,10 @@ Respond with ONLY valid JSON: } if (evaluation.signals?.length) { - lines.push('', `Signals: ${evaluation.signals.join(' · ')}`); + lines.push('', `*Signals:*`); + for (const sig of evaluation.signals) { + lines.push(`• ${sig}`); + } } lines.push('', `_${new Date().toISOString().replace('T', ' ').substring(0, 19)} UTC_`); diff --git a/lib/delta/engine.mjs b/lib/delta/engine.mjs index d42a958..e285473 100644 --- a/lib/delta/engine.mjs +++ b/lib/delta/engine.mjs @@ -161,7 +161,7 @@ export function computeDelta(current, previous, thresholdOverrides = {}) { if (hash && !prevHashes.has(hash)) { signals.new.push({ key: `tg_urgent:${hash}`, - text: post.text?.substring(0, 120), + text: post.text, item: post, reason: 'New urgent OSINT post', }); diff --git a/lib/delta/memory.mjs b/lib/delta/memory.mjs index 238c014..9d3c3b3 100644 --- a/lib/delta/memory.mjs +++ b/lib/delta/memory.mjs @@ -199,7 +199,7 @@ export class MemoryManager { bls: data.bls, treasury: data.treasury, gscpi: data.gscpi, - tg: { posts: data.tg?.posts, urgent: (data.tg?.urgent || []).map(p => ({ text: p.text?.substring(0, 80), date: p.date })) }, + tg: { posts: data.tg?.posts, urgent: (data.tg?.urgent || []).map(p => ({ text: p.text, date: p.date })) }, thermal: (data.thermal || []).map(t => ({ region: t.region, det: t.det, night: t.night, hc: t.hc })), air: (data.air || []).map(a => ({ region: a.region, total: a.total })), nuke: (data.nuke || []).map(n => ({ site: n.site, anom: n.anom, cpm: n.cpm })), diff --git a/lib/llm/ideas.mjs b/lib/llm/ideas.mjs index 08e6603..12a0fc1 100644 --- a/lib/llm/ideas.mjs +++ b/lib/llm/ideas.mjs @@ -91,7 +91,7 @@ function compactSweepForLLM(data, delta, previousIdeas) { // Geopolitical signals const urgentPosts = (data.tg?.urgent || []).slice(0, 5); if (urgentPosts.length) { - sections.push(`URGENT_OSINT:\n${urgentPosts.map(p => `- ${(p.text || '').substring(0, 120)}`).join('\n')}`); + sections.push(`URGENT_OSINT:\n${urgentPosts.map(p => `- ${p.text || ''}`).join('\n')}`); } // Thermal / fire detections