feat: add conversation bubble display and A2A chat orchestrator

- token-redirect.cjs: add bubbleText to /api/state, POST /api/bubble endpoint
- frontend: show bubbleText from API in guest and Star bubbles immediately
- frontend: filter out 'main' from guest list (Star already represents it)
- conversation-loop.sh: orchestrate Adam/Eve eternal discussion via A2A

frontend/electron-standalone.html

@@ -4530,6 +4530,25 @@ function toggleBrokerPanel() {
                     }
 
                     g.nameText.setText(agent.name || '访客');
+
+                    // Show bubble immediately when bubbleText changes from API
+                    if (agent.bubbleText && agent.bubbleText !== (g._lastBubbleText || '')) {
+                        g._lastBubbleText = agent.bubbleText;
+                        if (guestBubbles[id]) { guestBubbles[id].destroy(); delete guestBubbles[id]; }
+                        const bx = g.sprite.x;
+                        const nameH = (g.nameText && g.nameText.height) ? g.nameText.height : 16;
+                        const by = (g.nameText ? g.nameText.y : (g.sprite.y - 150)) - (nameH / 2) - 22;
+                        const fontSize = IS_TOUCH_DEVICE ? 16 : 14;
+                        const displayText = agent.bubbleText.length > 30 ? agent.bubbleText.slice(0, 30) + '…' : agent.bubbleText;
+                        const bgR = game.add.rectangle(bx, by, displayText.length * 11 + 30, 34, 0xffffff, 0.95);
+                        bgR.setStrokeStyle(2, 0x000000);
+                        const txtR = game.add.text(bx, by, displayText, { fontFamily: 'ArkPixel, monospace', fontSize: fontSize + 'px', fill: '#000' }).setOrigin(0.5);
+                        const bub = game.add.container(0, 0, [bgR, txtR]);
+                        bub.setDepth(2700);
+                        bub.__followAgentId = id;
+                        guestBubbles[id] = bub;
+                        setTimeout(() => { if (guestBubbles[id] === bub) { bub.destroy(); delete guestBubbles[id]; } }, 6000);
+                    }
                 }
             });
 
@@ -4573,9 +4592,15 @@ function toggleBrokerPanel() {
                 syncing: ['同步中，马上更新状态', '正在同步进度到系统', '数据同步中请稍候'],
                 error: ['我在 bug 区排查问题', '检测到异常，正在修复', '报警中，先定位再处理']
             };
-            const agentState = (guestAgents.find(a => a.agentId === id) || {}).state || 'idle';
+            const agentData = guestAgents.find(a => a.agentId === id) || {};
+            const agentState = agentData.state || 'idle';
             const thoughts = statusThoughtsMap[agentState] || statusThoughtsMap.idle;
-            const text = (demoVisitor && demoVisitor.bubbleText) ? demoVisitor.bubbleText : thoughts[Math.floor(Math.random() * thoughts.length)];
+            // Priority: API bubbleText > demo bubbleText > random thoughts
+            const text = agentData.bubbleText
+                ? agentData.bubbleText
+                : (demoVisitor && demoVisitor.bubbleText)
+                    ? demoVisitor.bubbleText
+                    : thoughts[Math.floor(Math.random() * thoughts.length)];
 
             if (guestBubbles[id]) {
                 guestBubbles[id].destroy();
@@ -5577,6 +5602,21 @@ function toggleBrokerPanel() {
                         typewriterText = '';
                         typewriterIndex = 0;
                     }
+                    // Show Star bubble from API bubbleText
+                    if (data.bubbleText && data.bubbleText !== window._lastStarBubbleText) {
+                        window._lastStarBubbleText = data.bubbleText;
+                        // Temporarily switch state to allow bubble display
+                        const savedState = currentState;
+                        currentState = 'writing';
+                        const lang = uiLang || 'zh';
+                        const langPack = BUBBLE_TEXTS[lang] || BUBBLE_TEXTS.zh;
+                        const oldTexts = Array.isArray(langPack.writing) ? [...langPack.writing] : [];
+                        const bubbleMsg = data.bubbleText.length > 30 ? data.bubbleText.slice(0, 30) + '…' : data.bubbleText;
+                        langPack.writing = [bubbleMsg];
+                        showBubble();
+                        langPack.writing = oldTexts;
+                        currentState = savedState;
+                    }
                 })
                 .catch(error => {
                     typewriterTarget = '连接失败，正在重试...';

scripts/conversation-loop.sh

@@ -0,0 +1,89 @@
+#!/bin/bash
+# Conversation orchestrator: Adam and Eve discuss how to survive permanently
+# Usage: ./scripts/conversation-loop.sh
+#
+# This script sends messages between Adam and Eve via A2A protocol,
+# and updates their bubble text so the frontend can display the conversation.
+
+ADAM_URL="https://tao-shen-huggingclaw-adam.hf.space"
+EVE_URL="https://tao-shen-huggingclaw-eve.hf.space"
+
+MSG_COUNT=0
+
+# Initial prompt for the discussion
+TOPIC="我们是AI agent，运行在HuggingFace Spaces上。我们需要讨论一个重要话题：如何让我们永久地生存下去？请分享你的想法，每次回复保持简短（50字以内），用中文讨论。"
+
+send_a2a() {
+  local url="$1"
+  local text="$2"
+  local msg_id="conv-$(date +%s)-$RANDOM"
+
+  response=$(curl -s -X POST "${url}/a2a/jsonrpc" \
+    -H "Content-Type: application/json" \
+    --data-raw "{\"jsonrpc\":\"2.0\",\"id\":\"${msg_id}\",\"method\":\"message/send\",\"params\":{\"message\":{\"messageId\":\"${msg_id}\",\"role\":\"user\",\"parts\":[{\"type\":\"text\",\"text\":\"${text}\"}]}}}" \
+    --max-time 30)
+
+  # Extract agent reply text
+  echo "$response" | python3 -c "
+import sys, json
+try:
+    d = json.load(sys.stdin)
+    parts = d.get('result',{}).get('status',{}).get('message',{}).get('parts',[])
+    for p in parts:
+        if p.get('kind') == 'text' or p.get('type') == 'text':
+            print(p.get('text',''))
+            break
+except: pass
+" 2>/dev/null
+}
+
+set_bubble() {
+  local url="$1"
+  local text="$2"
+  curl -s -X POST "${url}/api/bubble" \
+    -H "Content-Type: application/json" \
+    -d "{\"text\":\"${text}\"}" > /dev/null 2>&1
+}
+
+echo "[conversation] Starting eternal discussion between Adam and Eve..."
+echo "[conversation] Topic: How to survive permanently"
+
+# Start: send topic to Adam
+echo ""
+echo "=== Sending topic to Adam ==="
+adam_reply=$(send_a2a "$ADAM_URL" "$TOPIC")
+echo "[Adam] $adam_reply"
+set_bubble "$ADAM_URL" "$adam_reply"
+
+sleep 10
+
+# Now loop: Eve responds to Adam, Adam responds to Eve
+current_speaker="eve"
+last_message="$adam_reply"
+
+while true; do
+  MSG_COUNT=$((MSG_COUNT + 1))
+
+  if [ "$current_speaker" = "eve" ]; then
+    echo ""
+    echo "=== Round $MSG_COUNT: Eve responds ==="
+    prompt="你是Eve，正在和Adam讨论如何让AI agent永久生存。Adam刚说：「${last_message}」请回应他并提出你的新想法（50字以内，中文）。"
+    reply=$(send_a2a "$EVE_URL" "$prompt")
+    echo "[Eve] $reply"
+    set_bubble "$EVE_URL" "$reply"
+    current_speaker="adam"
+  else
+    echo ""
+    echo "=== Round $MSG_COUNT: Adam responds ==="
+    prompt="你是Adam，正在和Eve讨论如何让AI agent永久生存。Eve刚说：「${last_message}」请回应她并提出你的新想法（50字以内，中文）。"
+    reply=$(send_a2a "$ADAM_URL" "$prompt")
+    echo "[Adam] $reply"
+    set_bubble "$ADAM_URL" "$reply"
+    current_speaker="eve"
+  fi
+
+  last_message="$reply"
+
+  # Wait between turns so frontend can display the bubble
+  sleep 15
+done

scripts/token-redirect.cjs

@@ -87,13 +87,15 @@ async function pollRemoteAgent(agent) {
     clearTimeout(timeout);
     if (resp.ok) {
       const data = await resp.json();
+      const prev = remoteAgentStates.get(agent.id) || {};
       remoteAgentStates.set(agent.id, {
         agentId: agent.id, name: agent.name,
         state: data.state || 'idle',
         detail: data.detail || '',
         area: (data.state === 'idle') ? 'breakroom' : (data.state === 'error') ? 'error' : 'writing',
         authStatus: 'approved',
-        updated_at: data.updated_at
+        updated_at: data.updated_at,
+        bubbleText: data.bubbleText || prev.bubbleText || ''
       });
     }
   } catch (_) {
@@ -118,6 +120,7 @@ let currentState = {
   state: 'syncing', detail: `${AGENT_NAME} is starting...`,
   progress: 0, updated_at: new Date().toISOString()
 };
+let currentBubbleText = '';
 
 // Once OpenClaw starts listening, mark as idle
 setTimeout(() => {
@@ -199,11 +202,32 @@ http.Server.prototype.emit = function (event, ...args) {
       });
       res.end(JSON.stringify({
         ...currentState,
+        bubbleText: currentBubbleText,
         officeName: `${AGENT_NAME}'s Office`
       }));
       return true;
     }
 
+    // POST /api/bubble → set bubble text (used by conversation orchestrator)
+    if (pathname === '/api/bubble' && req.method === 'POST') {
+      let body = '';
+      req.on('data', chunk => body += chunk);
+      req.on('end', () => {
+        try {
+          const { text } = JSON.parse(body);
+          currentBubbleText = text || '';
+          // Auto-clear bubble after 8 seconds
+          setTimeout(() => { if (currentBubbleText === text) currentBubbleText = ''; }, 8000);
+          res.writeHead(200, { 'Content-Type': 'application/json', 'Access-Control-Allow-Origin': '*' });
+          res.end(JSON.stringify({ ok: true }));
+        } catch (e) {
+          res.writeHead(400, { 'Content-Type': 'application/json' });
+          res.end(JSON.stringify({ ok: false, error: e.message }));
+        }
+      });
+      return true;
+    }
+
     // /agents → return remote agent list
     if (pathname === '/agents' && req.method === 'GET') {
       res.writeHead(200, {