fix: dedupe streamed annual llm signals

Author: jiwenxu025-boop

frontend/app.js

@@ -141,6 +141,7 @@ function mergeAnnualSignals(year, signals){
     if (chart.annual_scans[si].year === year){
       if (!chart.annual_scans[si].events) chart.annual_scans[si].events = [];
       for (let sj = 0; sj < signals.length; sj++){
+        if (_isDuplicateLlmSignal(chart.annual_scans[si].events, signals[sj])) continue;
         chart.annual_scans[si].events.push(signals[sj]);
       }
       break;
@@ -150,6 +151,25 @@ function mergeAnnualSignals(year, signals){
   return chart;
 }
 
+function _isDuplicateLlmSignal(existingSignals, candidate){
+  if (!candidate || candidate.source !== 'llm') return false;
+  let candidateKey = _annualSignalKey(candidate);
+  for (let i = 0; i < existingSignals.length; i++){
+    let signal = existingSignals[i];
+    if (signal && signal.source === 'llm' && _annualSignalKey(signal) === candidateKey) return true;
+  }
+  return false;
+}
+
+function _annualSignalKey(signal){
+  let triggers = Array.isArray(signal.triggers) ? signal.triggers.join('\u001f') : '';
+  let notes = Array.isArray(signal.notes) ? signal.notes.join('\u001f') : '';
+  return [
+    signal.category || '', signal.direction || '', signal.strength || 0,
+    signal.prediction || '', triggers, notes,
+  ].join('\u0001');
+}
+
 function setDayunInterpretations(items){
   let chart = getChartData();
   if (!chart) return null;

scripts/tests/test_frontend_personality_ui.py

@@ -1385,7 +1385,10 @@ class Element {{
         const chart = {{
           id: 'fresh-chart',
           current_context: {{ current_dayun: {{ ganzhi: 'bingwu' }} }},
-          annual_scans: [{{ year: 2026, events: [{{ category: 'base', strength: 2 }}] }}],
+          annual_scans: [{{ year: 2026, events: [
+            {{ category: 'base', strength: 2 }},
+            {{ category: 'stream', direction: 'positive', strength: 3, prediction: 'same', triggers: ['trigger'], notes: ['note'], source: 'llm' }}
+          ] }}],
           dayun: {{ interpretations: [] }}
         }};
 
@@ -1395,9 +1398,11 @@ class Element {{
         if (!vm.runInContext('CHAT.chartData === getChartData()', sandbox)) throw new Error('legacy chat chart was not synchronized');
         if (sandbox.window._calChart !== chart) throw new Error('legacy calendar chart was not synchronized');
 
-        sandbox.mergeAnnualSignals(2026, [{{ category: 'stream', strength: 3 }}]);
+        sandbox.mergeAnnualSignals(2026, [{{ category: 'stream', direction: 'positive', strength: 3, prediction: 'same', triggers: ['trigger'], notes: ['note'], source: 'llm' }}]);
         if (chart.current_context.current_dayun.ganzhi !== 'bingwu') throw new Error('current_context changed during annual merge');
-        if (chart.annual_scans[0].events.length !== 2) throw new Error('annual stream signal was not merged');
+        if (chart.annual_scans[0].events.length !== 2) throw new Error('duplicate LLM stream signal was appended');
+        sandbox.mergeAnnualSignals(2026, [{{ category: 'stream', direction: 'positive', strength: 3, prediction: 'different', triggers: ['trigger'], notes: ['note'], source: 'llm' }}]);
+        if (chart.annual_scans[0].events.length !== 3) throw new Error('distinct LLM stream signal was not merged');
 
         sandbox.setDayunInterpretations([{{ index: 0, text: 'ok' }}]);
         if (chart.current_context.current_dayun.ganzhi !== 'bingwu') throw new Error('current_context changed during dayun merge');