dashboard.js 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352
  1. // News MCP Dashboard — pure JS + Chart.js
  2. // Clusters are ALWAYS ordered by date descending (freshest first)
  3. var API = '/api/v1';
  4. var _charts = {};
  5. var _clustersData = [];
  6. var _entitiesData = [];
  7. var _healthLoaded = false;
  8. function switchView(name) {
  9. var views = ['health','clusters','sentiment','entities','detail'];
  10. if (views.indexOf(name) === -1) return;
  11. document.querySelectorAll('.view').forEach(function(v) { v.classList.toggle('active', v.id === 'view-' + name); });
  12. document.querySelectorAll('.nav-links a').forEach(function(a) { a.classList.toggle('active', a.dataset.view === name); });
  13. if (name === 'health') loadHealth();
  14. if (name === 'clusters') reloadClusters();
  15. if (name === 'sentiment') reloadSentiment();
  16. if (name === 'entities') loadEntities();
  17. }
  18. function $(id) {
  19. if (!id) return null;
  20. return document.getElementById(id) || document.querySelector('#' + id);
  21. }
  22. function esc(s) {
  23. if (s == null || s === undefined) return '';
  24. return String(s).replace(/&/g,'&amp;').replace(/</g,'&lt;').replace(/>/g,'&gt;').replace(/"/g,'&quot;');
  25. }
  26. function topicChip(topic) {
  27. var t = (topic || 'other').toString().replace(/[^a-z0-9]/g,'');
  28. return '<span class="chip topic-' + t + '">' + esc(topic) + '</span>';
  29. }
  30. function sentimentClass(s) {
  31. if (s === 'positive') return 'sentiment-pos';
  32. if (s === 'negative') return 'sentiment-neg';
  33. return 'sentiment-neu';
  34. }
  35. // ── Health ──────────────────────────────────────────────
  36. async function loadHealth() {
  37. try {
  38. var res = await fetch(API + '/health');
  39. var d = await res.json();
  40. var sc = $('stat-clusters'); if (sc) sc.textContent = d.total_clusters;
  41. var se = $('stat-entities'); if (se) se.textContent = d.total_entities;
  42. var sce = $('stat-cluster-entities'); if (sce) sce.textContent = d.cluster_entities;
  43. var sf = $('stat-fresh');
  44. if (sf) {
  45. if (d.data_fresh) { sf.textContent = 'Fresh'; sf.className = 'value green'; }
  46. else { sf.textContent = 'Stale'; sf.className = 'value red'; }
  47. }
  48. var sr = $('stat-refresh'); if (sr) sr.textContent = d.last_refresh_at ? new Date(d.last_refresh_at).toLocaleString() : 'never';
  49. var nm = $('nav-meta'); if (nm) nm.textContent = 'Refresh: ' + (d.last_refresh_at ? new Date(d.last_refresh_at).toLocaleTimeString() : 'never');
  50. renderTopicPie(d.clusters_by_topic || {});
  51. await renderSentimentOverview();
  52. renderFeedStatus(d.feeds || {});
  53. _healthLoaded = true;
  54. } catch(e) {
  55. console.error('Health load error:', e);
  56. var hs = $('health-stats');
  57. if (hs) hs.innerHTML = '<div class="loading" style="color:var(--red)">Error: ' + esc(e.message) + '</div>';
  58. }
  59. }
  60. function renderTopicPie(topics) {
  61. var el = $('chart-topic-dist'); if (!el) return;
  62. var ctx = el.getContext('2d');
  63. var colors = { crypto:'#f59e0b', macro:'#8b5cf6', regulation:'#3b82f6', ai:'#10b981', other:'#6b7280' };
  64. var labels = Object.keys(topics);
  65. if (_charts.topicDist) _charts.topicDist.destroy();
  66. _charts.topicDist = new Chart(ctx, {
  67. type: 'doughnut',
  68. data: { labels: labels, datasets: [{ data: labels.map(function(l){return topics[l]}), backgroundColor: labels.map(function(l){return colors[l]||'#555'}), borderWidth: 0 }] },
  69. options: { responsive:true, maintainAspectRatio:false, plugins:{legend:{position:'bottom',labels:{color:'#8a8f9b',font:{size:11},padding:12}}} }
  70. });
  71. }
  72. async function renderSentimentOverview() {
  73. try {
  74. var res = await fetch(API + '/sentiment-series?hours=24&bucket_hours=4');
  75. var d = await res.json();
  76. renderSentimentChart(d.series || [], 'chart-sentiment-overview', false);
  77. } catch(e) { console.error('Sentiment overview error:', e); }
  78. }
  79. function renderFeedStatus(feeds) {
  80. var el = $('feed-status');
  81. if (!el) return;
  82. if (!feeds || !Object.keys(feeds).length) {
  83. el.innerHTML = '<p class="muted" style="font-size:.82rem;padding:.5rem 0">No feed state yet.</p>';
  84. return;
  85. }
  86. var html = '';
  87. for (var k in feeds) {
  88. var v = feeds[k];
  89. var label = k.replace(/^https?:\/\//, '').replace(/\/$/, '');
  90. var count = (v.last_item_count == null) ? 'n/a' : String(v.last_item_count);
  91. html += '<div class="feed-item"><span>' + esc(label) + '</span><span class="badge">' + esc(count) + ' items</span></div>';
  92. }
  93. el.innerHTML = html;
  94. }
  95. // ── Clusters (ALWAYS date descending) ──────────────────────
  96. async function reloadClusters() {
  97. var topic = $('cluster-topic').value;
  98. var hours = $('cluster-hours').value;
  99. try {
  100. var res = await fetch(API + '/clusters?topic=' + encodeURIComponent(topic) + '&hours=' + hours + '&limit=50');
  101. var d = await res.json();
  102. if (d.error) throw new Error(d.error);
  103. _clustersData = d.clusters || [];
  104. // Data is already sorted by server (date DESC). Force-sort client-side as safety net.
  105. _clustersData.sort(function(a,b) {
  106. var ta = new Date(a.timestamp || 0).getTime();
  107. var tb = new Date(b.timestamp || 0).getTime();
  108. return tb - ta; // newest first
  109. });
  110. var ct = $('cluster-total'); if (ct) ct.textContent = _clustersData.length + ' / ' + d.total;
  111. renderClusterTable(_clustersData);
  112. } catch(e) {
  113. console.error('Clusters error:', e);
  114. var ct2 = $('cluster-table');
  115. if (ct2) ct2.innerHTML = '<div class="loading" style="color:var(--red)">Error: ' + esc(e.message) + '</div>';
  116. }
  117. }
  118. function filterClusters() {
  119. var q = $('cluster-search').value.toLowerCase().trim();
  120. var data = _clustersData;
  121. if (q) {
  122. data = _clustersData.filter(function(c) {
  123. return (c.headline||'').toLowerCase().indexOf(q) !== -1 || (c.entities||[]).some(function(e) { return (e||'').toLowerCase().indexOf(q) !== -1; });
  124. });
  125. var ct = $('cluster-total'); if (ct) ct.textContent = data.length + ' / ' + _clustersData.length;
  126. }
  127. renderClusterTable(data);
  128. }
  129. function renderClusterTable(clusters) {
  130. var el = $('cluster-table');
  131. if (!el) return;
  132. if (!clusters || !clusters.length) {
  133. el.innerHTML = '<div class="loading" style="padding:2rem;text-align:center">No clusters in this window</div>';
  134. return;
  135. }
  136. // Sorted by date descending — newest first
  137. var html = '<thead><tr><th>\u23f1\ufe0f Time \u25bc</th><th>Headline</th><th>Topic</th><th>Sentiment</th><th>Imp.</th><th>Entities</th></tr></thead><tbody>';
  138. for (var i = 0; i < clusters.length; i++) {
  139. var c = clusters[i];
  140. var ts = c.timestamp ? new Date(c.timestamp).toLocaleString() : '';
  141. var sc = sentimentClass(c.sentiment || 'neutral');
  142. var imp = c.importance || 0;
  143. var chips = '';
  144. var ents = c.entities || [];
  145. for (var ei = 0; ei < Math.min(ents.length, 5); ei++) {
  146. chips += '<span class="chip" title="' + esc(ents[ei]) + '">' + esc(String(ents[ei]||'').substring(0,22)) + '</span>';
  147. }
  148. html += '<tr style="cursor:pointer" onclick="openClusterModal(\'' + esc(c.cluster_id) + '\')">';
  149. html += '<td style="white-space:nowrap;font-size:.78rem">' + ts + '</td>';
  150. html += '<td><a href="#" onclick="event.stopPropagation();openClusterModal(\'' + esc(c.cluster_id) + '\')">' + esc(c.headline) + '</a></td>';
  151. html += '<td>' + topicChip(c.topic) + '</td>';
  152. html += '<td class="' + sc + '" style="font-weight:600;font-size:.82rem">' + esc(c.sentiment) + ' <span style="opacity:.7">(' + esc(String(c.sentimentScore||'')) + ')</span></td>';
  153. html += '<td style="text-align:center"><span style="font-size:.75rem">' + imp + '</span></td>';
  154. html += '<td style="max-width:200px">' + (chips || '\u2014') + '</td></tr>';
  155. }
  156. html += '</tbody>';
  157. el.innerHTML = '<table>' + html + '</table>';
  158. }
  159. // ── Sentiment ─────────────────────────────────────────────
  160. async function reloadSentiment() {
  161. var topic = $('sentiment-topic').value;
  162. var hours = $('sentiment-hours').value;
  163. var bucket = $('sentiment-bucket').value;
  164. try {
  165. var res = await fetch(API + '/sentiment-series?topic=' + encodeURIComponent(topic) + '&hours=' + hours + '&bucket_hours=' + bucket);
  166. var d = await res.json();
  167. renderSentimentChart(d.series || [], 'chart-sentiment', true);
  168. renderSentimentStats(d.series || []);
  169. } catch(e) {
  170. console.error('Sentiment error:', e);
  171. var el = $('chart-sentiment');
  172. if (el) el.parentElement.innerHTML = '<div class="loading">Error: ' + esc(e.message) + '</div>';
  173. }
  174. }
  175. function renderSentimentChart(series, canvasId, showCount) {
  176. if (!series.length) {
  177. var el = $(canvasId);
  178. if (el) el.parentElement.innerHTML = '<div class="loading">No data</div>';
  179. return;
  180. }
  181. if (_charts.sentiment) { _charts.sentiment.destroy(); _charts.sentiment = null; }
  182. var ctx = $(canvasId).getContext('2d');
  183. var labels = series.map(function(s) { var d=new Date(s.time); return d.toLocaleDateString()+' '+d.toLocaleTimeString([],{hour:'2-digit',minute:'2-digit'}); });
  184. var datasets = [{ label:'Avg Sentiment', data:series.map(function(s){return s.avg_sentiment}), borderColor:'#5b8af5', backgroundColor:'rgba(91,138,245,0.15)', tension:0.3, yAxisID:'y', pointRadius:3 }];
  185. if (showCount) datasets.push({ label:'Count', data:series.map(function(s){return s.count}), borderColor:'#fbbf24', backgroundColor:'rgba(251,191,36,0.15)', yAxisID:'y1', pointRadius:2 });
  186. _charts.sentiment = new Chart(ctx, {
  187. type: 'line', data: { labels: labels, datasets: datasets },
  188. options: {
  189. responsive: true, maintainAspectRatio: false,
  190. interaction: { mode: 'index', intersect: false },
  191. scales: {
  192. y: { position:'left', title:{display:true,text:'Sentiment',color:'#8a8f9b'}, grid:{color:'rgba(42,46,58,.5)'}, ticks:{color:'#8a8f9b'} },
  193. y1: { position:'right', title:{display:true,text:'Count',color:'#8a8f9b'}, grid:{drawOnChartArea:false}, ticks:{color:'#8a8f9b'} },
  194. x: { ticks:{color:'#8a8f9b',maxRotation:45}, grid:{color:'rgba(42,46,58,.3)'} }
  195. },
  196. plugins: { legend: { labels: { color: '#8a8f9b' } } }
  197. }
  198. });
  199. }
  200. function renderSentimentStats(series) {
  201. var el = $('sentiment-stats'); if (!el) return;
  202. if (!series.length) { el.innerHTML = ''; return; }
  203. var avg = (series.reduce(function(s,v){return s+v.avg_sentiment},0)/series.length).toFixed(3);
  204. var max = Math.max.apply(null, series.map(function(s){return s.avg_sentiment})).toFixed(3);
  205. var min = Math.min.apply(null, series.map(function(s){return s.avg_sentiment})).toFixed(3);
  206. var total = series.reduce(function(s,v){return s+v.count},0);
  207. var pos = series.filter(function(s){return s.avg_sentiment>0.15}).length;
  208. var neg = series.filter(function(s){return s.avg_sentiment<-0.15}).length;
  209. el.innerHTML = '<span class="sentiment-stat">Avg: <b>'+avg+'</b></span>'
  210. +'<span class="sentiment-stat">Peak +: <b style="color:var(--green)">'+max+'</b></span>'
  211. +'<span class="sentiment-stat">Peak -: <b style="color:var(--red)">'+min+'</b></span>'
  212. +'<span class="sentiment-stat">Clusters: <b>'+total+'</b></span>'
  213. +'<span class="sentiment-stat">+ buckets: <b class="sentiment-pos">'+pos+'</b></span>'
  214. +'<span class="sentiment-stat">- buckets: <b class="sentiment-neg">'+neg+'</b></span>';
  215. }
  216. // ── Entities ─────────────────────────────────────────────
  217. async function loadEntities() {
  218. try {
  219. var res = await fetch(API + '/entities?hours=144&limit=30');
  220. var d = await res.json();
  221. _entitiesData = d.entities || [];
  222. renderEntityList();
  223. renderEntityChart();
  224. } catch(e) {
  225. console.error('Entities error:', e);
  226. var el = $('entity-list'); if (el) el.innerHTML = '<div class="loading">Error</div>';
  227. }
  228. }
  229. function renderEntityList() {
  230. var el = $('entity-list'); if (!el) return;
  231. if (!_entitiesData.length) { el.innerHTML = '<div class="loading">No entities</div>'; return; }
  232. var html = '';
  233. for (var i = 0; i < _entitiesData.length; i++) {
  234. var e = _entitiesData[i];
  235. html += '<div class="entity-row" onclick="showEntityDetail(\''+esc(e.label)+'\')" style="cursor:pointer"><span class="ent-label">' + esc(e.canonical_label||e.label) + '</span><span class="ent-count">' + e.count + 'x</span></div>';
  236. }
  237. el.innerHTML = html;
  238. }
  239. function renderEntityChart() {
  240. var top15 = _entitiesData.slice(0,15);
  241. if (!top15.length) return;
  242. if (_charts.entities) _charts.entities.destroy();
  243. _charts.entities = new Chart($('chart-entities').getContext('2d'), {
  244. type: 'bar',
  245. data: { labels: top15.map(function(e){return (e.canonical_label||e.label).substring(0,24)}), datasets: [{ label:'Mentions', data:top15.map(function(e){return e.count}), backgroundColor:'rgba(91,138,245,0.3)', borderColor:'#5b8af5', borderWidth:1 }] },
  246. options: { indexAxis:'y', responsive:true, plugins:{legend:{display:false}}, scales:{ x:{ticks:{color:'#8a8f9b'},grid:{color:'rgba(42,46,58,.5)'}}, y:{ticks:{color:'#8a8f9b'},grid:{display:false}} } }
  247. });
  248. }
  249. // Show clusters that mention this entity, sorted by date DESC
  250. async function showEntityDetail(label) {
  251. if (!label) return;
  252. var el = $('entity-detail'); if (!el) return;
  253. el.innerHTML = '<div class="loading">Fetching clusters mentioning ' + esc(label) + '...</div>';
  254. try {
  255. var res = await fetch(API + '/clusters?topic=all&hours=144&limit=100');
  256. var d = await res.json();
  257. var matched = (d.clusters || []).filter(function(c) {
  258. return (c.entities||[]).some(function(e) { return (e||'').toLowerCase() === label.toLowerCase(); });
  259. });
  260. // Sort by timestamp descending — newest first
  261. matched.sort(function(a,b) {
  262. var ta = new Date(a.timestamp || 0).getTime();
  263. var tb = new Date(b.timestamp || 0).getTime();
  264. return tb - ta;
  265. });
  266. if (!matched.length) { el.innerHTML = '<p class="muted">No clusters mention "' + esc(label) + '" in the current window.</p>'; return; }
  267. var html = '<h4 style="font-size:.85rem;margin-bottom:.5rem">Clusters mentioning ' + esc(label) + ' (' + matched.length + ')</h4>';
  268. for (var i = 0; i < matched.length; i++) {
  269. var c = matched[i];
  270. html += '<div style="margin-bottom:.6rem;padding:.6rem;background:var(--surface2);border-radius:6px;font-size:.82rem;cursor:pointer" onclick="openClusterModal(\''+esc(c.cluster_id)+'\')">'+
  271. '<b>'+esc(c.headline)+'</b><br><span class="muted">'+topicChip(c.topic)+' '+sentimentClass(c.sentiment)+' '+esc(String(c.sentimentScore||''))+' &middot; '+esc(String(c.timestamp||''))+'</span></div>';
  272. }
  273. el.innerHTML = html;
  274. } catch(e) {
  275. el.innerHTML = '<p class="muted">Error: ' + esc(e.message) + '</p>';
  276. }
  277. }
  278. // ── Detail modal ─────────────────────────────────────────
  279. function openClusterModal(clusterId) {
  280. if (!clusterId) return;
  281. $('cluster-modal').classList.add('open');
  282. $('modal-content').innerHTML = '<div class="loading">Loading...</div>';
  283. fetch(API + '/cluster/' + encodeURIComponent(clusterId))
  284. .then(function(r){ return r.json(); })
  285. .then(function(d) {
  286. var mc = $('modal-content');
  287. if (!mc) return;
  288. mc.innerHTML = d.error ? '<p class="muted">' + esc(d.error) + '</p>' : buildDetailHTML(d);
  289. })
  290. .catch(function() { var mc = $('modal-content'); if (mc) mc.innerHTML = '<p class="muted">Error loading detail.</p>'; });
  291. }
  292. function closeModal() { var m = $('cluster-modal'); if (m) m.classList.remove('open'); }
  293. function searchDetail() {
  294. var q = $('detail-search').value.trim();
  295. if (!q) return;
  296. var el = $('detail-content'); if (el) el.innerHTML = '<div class="loading">Searching...</div>';
  297. fetch(API + '/cluster/' + encodeURIComponent(q))
  298. .then(function(r) { if (r.status===404) { var el2=$('detail-content'); if(el2) el2.innerHTML='<p class="muted">Not found.</p>'; return null; } return r.json(); })
  299. .then(function(d) { if (d) { var el3=$('detail-content'); if(el3) el3.innerHTML = buildDetailHTML(d); } });
  300. }
  301. function buildDetailHTML(d) {
  302. var h = '<div class="detail-section"><h4>Headline</h4><div class="detail-content">' + esc(d.headline||'') + '</div></div>';
  303. h += '<div class="detail-section"><h4>Metadata</h4><div class="detail-content">';
  304. h += topicChip(d.topic) + ' <span class="' + sentimentClass(d.sentiment) + '" style="font-weight:600">' + esc(d.sentiment) + ' (' + esc(String(d.sentimentScore||'')) + ')</span>';
  305. h += ' <span style="color:var(--accent);margin-left:.5rem">Importance: ' + (d.importance||0) + '</span>';
  306. h += '<br><span class="muted">First: ' + (d.first_seen||'n/a') + ' &middot; Updated: ' + (d.last_updated||'n/a') + '</span></div></div>';
  307. if (d.summary_text) h += '<div class="detail-section"><h4>Summary</h4><div class="detail-content">' + esc(d.summary_text) + '</div></div>';
  308. if (d.summary) h += '<div class="detail-section"><h4>LLM Summary</h4><div class="detail-content">' + esc(d.summary) + '</div></div>';
  309. if (d.key_facts && d.key_facts.length) h += '<div class="detail-section"><h4>Key Facts</h4><div class="detail-content">' + d.key_facts.map(function(f){return '<div class="key-fact">&bull; ' + esc(f) + '</div>';}).join('') + '</div></div>';
  310. if (d.entities && d.entities.length) h += '<div class="detail-section"><h4>Entities ('+d.entities.length+')</h4><div class="detail-content">' + d.entities.map(function(e){return '<span class="chip">' + esc(e) + '</span>';}).join('') + '</div></div>';
  311. if (d.keywords && d.keywords.length) h += '<div class="detail-section"><h4>Keywords ('+d.keywords.length+')</h4><div class="detail-content">' + d.keywords.map(function(k){return '<span class="chip">' + esc(k) + '</span>';}).join('') + '</div></div>';
  312. if (d.articles && d.articles.length) {
  313. h += '<div class="detail-section"><h4>Articles ('+d.articles.length+')</h4>';
  314. for (var ai = 0; ai < Math.min(d.articles.length, 8); ai++) {
  315. var a = d.articles[ai];
  316. h += '<div style="margin-bottom:.5rem;padding:.5rem;background:var(--surface2);border-radius:6px;font-size:.82rem"><a href="' + esc(a.url||'#') + '" target="_blank" rel="noopener">' + esc(a.title||'Untitled') + '</a><br><span class="muted">' + esc(a.source||'') + ' &middot; ' + (a.timestamp||'') + '</span></div>';
  317. }
  318. h += '</div>';
  319. }
  320. return h;
  321. }
  322. setInterval(function() {
  323. fetch(API + '/health').then(function(r){return r.json()}).then(function(d) {
  324. var nm = $('nav-meta'); if (nm) nm.textContent = 'Last refresh: ' + (d.last_refresh_at ? new Date(d.last_refresh_at).toLocaleTimeString() : 'never');
  325. }).catch(function(){});
  326. }, 30000);
  327. document.addEventListener('DOMContentLoaded', loadHealth);