feat: speaker resolution, peer reactions, market indices, and solo-agent fallback

- Fix speaker name resolution: normalize endpoint URIs to canonical agent names
  (Finn/Lucky/Prudence) in both template and utterance handlers to enable
  proper peer-to-peer interactions with name-prefixed responses
Signed-off-by Deborah Dahl <dahl@conversational-technologies.com>

- Fix peer reaction counter: reset _peer_reaction_count on each fresh user
  question so agents continue reacting to each other through conversational turns

- Add out-of-domain fallback: agents alone on floor now respond with
  "that's outside of my expertise" for queries outside their domain expertise

- Add market indices support via ETF proxies: users can now query index data
  (Dow, S&P 500, Nasdaq-100, Russell 2000) on Finnhub free tier by mapping
  ^DJI→DIA, ^GSPC→SPY, ^IXIC→QQQ, ^RUT→IWM with implied index levels in responses

- Tune agent personalities: Prudence disapproves of reckless/speculative advice;
  Lucky disapproves of overly cautious, fear-driven investing

- Improve web-floor UI: increase conversation history font size to clamp(1rem,
  2.1vw, 1.15rem); make utterance textbox full panel width; allow resize handle
  up to 80vh max height

Files modified:
  - lucky/utterance_handler.py (canonical names, peer reset, personality)
  - lucky/template_agent.py (speaker resolution, solo-agent detection, fallback)
  - prudence/utterance_handler.py (canonical names, peer reset, personality)
  - prudence/template_agent.py (speaker resolution, solo-agent detection, fallback)
  - financial/utterance_handler.py (indices, proxy ETFs, formatted responses)
  - financial/template_agent.py (speaker resolution, fallback text standardization)
  - floor-implementations/.../styles.css (font, width, height tuning)

Author: dadahl

.vscode/launch.json

@@ -83,6 +83,26 @@
             "cwd": "${workspaceFolder}/financial",
             "justMyCode": false,
             "python": "${workspaceFolder}/financial/.venv/Scripts/python.exe"
+        },
+        {
+            "name": "Python: prudence Flask server",
+            "type": "debugpy",
+            "request": "launch",
+            "program": "${workspaceFolder}/prudence/flask_server.py",
+            "console": "integratedTerminal",
+            "cwd": "${workspaceFolder}/prudence",
+            "justMyCode": false,
+            "python": "${workspaceFolder}/gemini-agent/.venv/Scripts/python.exe"
+        },
+        {
+            "name": "Python: lucky Flask server",
+            "type": "debugpy",
+            "request": "launch",
+            "program": "${workspaceFolder}/lucky/flask_server.py",
+            "console": "integratedTerminal",
+            "cwd": "${workspaceFolder}/lucky",
+            "justMyCode": false,
+            "python": "${workspaceFolder}/gemini-agent/.venv/Scripts/python.exe"
         }
     ],
     "compounds": [
@@ -94,7 +114,9 @@
                 "Python: erin Flask server",
                 "Python: verity Flask server",
                 "Python: time-agent Flask server",
-                "Python: financial Flask server"
+                "Python: financial Flask server",
+                "Python: prudence Flask server",
+                "Python: lucky Flask server"
             ]
         },
         {

agent-template/envelope_handler.py

@@ -119,6 +119,13 @@ def serialize_envelope(envelope: Envelope) -> str:
         JSON string representation of the envelope
     """
     try:
+        # Do not echo incoming conversants back to clients.
+        if envelope and getattr(envelope, "conversation", None) is not None:
+            try:
+                setattr(envelope.conversation, "conversants", None)
+            except Exception:
+                pass
+
         # Debug-only: inspect the envelope before serialization
         if logger.isEnabledFor(logging.DEBUG):
             logger.debug("[SERIALIZE] Envelope has %d events", len(envelope.events))

agent-template/template_agent.py

@@ -249,24 +249,31 @@ def _handle_utterance(self, event: UtteranceEvent, in_envelope: Envelope, out_en
         try:
             # Extract user text from the OpenFloor event
             user_text = self._extract_text_from_utterance_event(event)
+            incoming_speaker_uri = (self._extract_speaker_uri_from_utterance_event(event) or "").strip().lower()
+            self_speaker_uri = str(self._manifest.identification.speakerUri or "").strip().lower()
+            responding_to_name = self._resolve_utterance_speaker_name(event, in_envelope)
+
+            if incoming_speaker_uri and self_speaker_uri and incoming_speaker_uri == self_speaker_uri:
+                logger.debug("[UTTERANCE] Ignoring self-originated utterance")
+                return
 
             if not user_text:
                 logger.debug("[UTTERANCE] No text found in utterance event")
                 return
 
             logger.debug("[UTTERANCE] Received: %s", user_text)
 
-            # Call utterance handler with just text + plain context - returns text response
+            # Call utterance handler with text, agent name, and speaker name for multi-agent reactions
             response_text = utterance_handler.process_utterance(
                 user_text,
                 agent_name=self._manifest.identification.conversationalName,
+                speaker_name=responding_to_name,
             )
 
             if not response_text:
                 logger.debug("[UTTERANCE] No response generated")
                 return
 
-            responding_to_name = self._resolve_utterance_speaker_name(event, in_envelope)
             if responding_to_name:
                 response_text = f"{responding_to_name}: {response_text}"
 
@@ -532,7 +539,7 @@ def _handle_uninvite(self, event: UninviteEvent, in_envelope: Envelope, out_enve
 
         dialog = DialogEvent(
             speakerUri=self._manifest.identification.speakerUri,
-            features=[TextFeature.from_text(farewell)]
+            features={"text": TextFeature(values=[farewell])}
         )
 
         utterance_event = UtteranceEvent(dialogEvent=dialog)

erin/envelope_handler.py

@@ -119,6 +119,13 @@ def serialize_envelope(envelope: Envelope) -> str:
         JSON string representation of the envelope
     """
     try:
+        # Do not echo incoming conversants back to clients.
+        if envelope and getattr(envelope, "conversation", None) is not None:
+            try:
+                setattr(envelope.conversation, "conversants", None)
+            except Exception:
+                pass
+
         # Debug-only: inspect the envelope before serialization
         if logger.isEnabledFor(logging.DEBUG):
             logger.debug("[SERIALIZE] Envelope has %d events", len(envelope.events))

erin/template_agent.py

@@ -298,6 +298,11 @@ def _handle_utterance(self, event: UtteranceEvent, in_envelope: Envelope, out_en
         try:
             # Extract user text from the OpenFloor event
             user_text = self._extract_text_from_utterance_event(event)
+            incoming_speaker_uri = (self._extract_speaker_uri_from_utterance_event(event) or "").strip().lower()
+            self_speaker_uri = str(self._manifest.identification.speakerUri or "").strip().lower()
+            if incoming_speaker_uri and self_speaker_uri and incoming_speaker_uri == self_speaker_uri:
+                logger.debug("[UTTERANCE] Ignoring self-originated utterance")
+                return
 
             if not user_text:
                 logger.debug("[UTTERANCE] No text found in utterance event")

financial/envelope_handler.py

@@ -119,6 +119,13 @@ def serialize_envelope(envelope: Envelope) -> str:
         JSON string representation of the envelope
     """
     try:
+        # Do not echo incoming conversants back to clients.
+        if envelope and getattr(envelope, "conversation", None) is not None:
+            try:
+                setattr(envelope.conversation, "conversants", None)
+            except Exception:
+                pass
+
         # Debug-only: inspect the envelope before serialization
         if logger.isEnabledFor(logging.DEBUG):
             logger.debug("[SERIALIZE] Envelope has %d events", len(envelope.events))

financial/mcp_server.py

@@ -48,6 +48,8 @@ def query_finnhub(intent, stock, time_text=None):
         url = f"{base_url}/company-news?symbol={stock}&from={datetime.utcfromtimestamp(from_ts).strftime('%Y-%m-%d')}&to={datetime.utcfromtimestamp(to_ts).strftime('%Y-%m-%d')}&token={FINNHUB_API_KEY}"
     elif intent == "EARNINGS_QUERY":
         url = f"{base_url}/stock/earnings?symbol={stock}&token={FINNHUB_API_KEY}"
+    elif intent == "DIVIDEND_QUERY":
+        url = f"{base_url}/stock/dividend?symbol={stock}&token={FINNHUB_API_KEY}"
     elif intent == "HISTORY_QUERY":
         url = f"{base_url}/stock/candle?symbol={stock}&resolution=D&from={from_ts}&to={to_ts}&token={FINNHUB_API_KEY}"
 

financial/template_agent.py

@@ -221,6 +221,40 @@ def _register_handlers(self):
         context_handler = getattr(self, "on_context", None)
         if context_handler is not None:
             context_handler += self._handle_context
+
+    def _is_only_agent_on_floor(self, in_envelope: Envelope) -> bool:
+        conversation = getattr(in_envelope, "conversation", None)
+        conversants = getattr(conversation, "conversants", []) if conversation else []
+        if not isinstance(conversants, list):
+            conversants = []
+
+        # Floor-awareness is based on incoming conversant count.
+        return len(conversants) <= 1
+
+    def _is_directly_addressed(self, event: UtteranceEvent, user_text: str) -> bool:
+        to_value = getattr(event, "to", None)
+        if to_value is None and isinstance(event, dict):
+            to_value = event.get("to")
+
+        # Explicit OpenFloor addressee targeting this agent.
+        if to_value is not None:
+            return self._is_addressed_to_me(event)
+
+        text = (user_text or "").strip().lower()
+        if not text:
+            return False
+
+        agent_name = str(getattr(self._manifest.identification, "conversationalName", "")).strip().lower()
+        if not agent_name:
+            return False
+
+        direct_prefixes = (
+            f"{agent_name}:",
+            f"{agent_name},",
+            f"{agent_name} ",
+            f"@{agent_name}",
+        )
+        return text.startswith(direct_prefixes)
 
     # =========================================================================
     # UTTERANCE EVENT - Delegated to utterance_handler.py
@@ -249,11 +283,37 @@ def _handle_utterance(self, event: UtteranceEvent, in_envelope: Envelope, out_en
         try:
             # Extract user text from the OpenFloor event
             user_text = self._extract_text_from_utterance_event(event)
+            incoming_speaker_uri = (self._extract_speaker_uri_from_utterance_event(event) or "").strip().lower()
+            self_speaker_uri = str(self._manifest.identification.speakerUri or "").strip().lower()
+            is_only_agent = self._is_only_agent_on_floor(in_envelope)
+
+            if incoming_speaker_uri and self_speaker_uri and incoming_speaker_uri == self_speaker_uri:
+                logger.debug("[UTTERANCE] Ignoring self-originated utterance")
+                return
 
             if not user_text:
                 logger.debug("[UTTERANCE] No text found in utterance event")
                 return
 
+            parsed = utterance_handler.parse_query(user_text)
+            has_stock = bool(parsed.get("stock"))
+            has_intent = bool(parsed.get("intent"))
+
+            if not has_stock and not has_intent:
+                if is_only_agent:
+                    dialog = DialogEvent(
+                        speakerUri=self._manifest.identification.speakerUri,
+                        features={"text": TextFeature(values=["that's outside of my expertise"])},
+                    )
+                    out_envelope.events.append(UtteranceEvent(dialogEvent=dialog))
+                else:
+                    logger.debug("[UTTERANCE] Ignoring non-financial utterance while multiple agents are on the floor")
+                return
+
+            if not (is_only_agent or self._is_directly_addressed(event, user_text)):
+                logger.debug("[UTTERANCE] Ignoring utterance; Finn is neither directly addressed nor the only agent on the floor")
+                return
+
             logger.debug("[UTTERANCE] Received: %s", user_text)
 
             # Call utterance handler with just text + plain context - returns text response
@@ -267,7 +327,8 @@ def _handle_utterance(self, event: UtteranceEvent, in_envelope: Envelope, out_en
                 return
 
             responding_to_name = self._resolve_utterance_speaker_name(event, in_envelope)
-            if responding_to_name:
+            _known_agent_markers = ("lucky", "prudence", "finn")
+            if responding_to_name and any(m in responding_to_name.lower() for m in _known_agent_markers):
                 response_text = f"{responding_to_name}: {response_text}"
 
             logger.debug("[UTTERANCE] Response: %s", response_text)
@@ -445,7 +506,20 @@ def _resolve_utterance_speaker_name(self, event: UtteranceEvent, in_envelope: En
         speaker_uri = self._extract_speaker_uri_from_utterance_event(event)
         if not speaker_uri:
             return ""
-        if "assistantclientconvener" in str(speaker_uri).strip().lower():
+        speaker_normalized = self._normalize_endpoint_id(speaker_uri)
+        if "assistantclientconvener" in speaker_normalized:
+            return ""
+
+        def _infer_agent_name_from_uri(uri: str) -> str:
+            normalized = self._normalize_endpoint_id(uri)
+            if not normalized:
+                return ""
+            if "finn" in normalized or ":8083" in normalized:
+                return "Finn"
+            if "prudence" in normalized or ":8084" in normalized:
+                return "Prudence"
+            if "lucky" in normalized or ":8085" in normalized:
+                return "Lucky"
             return ""
 
         conversation = getattr(in_envelope, 'conversation', None)
@@ -461,15 +535,28 @@ def _resolve_utterance_speaker_name(self, event: UtteranceEvent, in_envelope: En
 
             if isinstance(identification, dict):
                 conversant_speaker = identification.get('speakerUri')
+                conversant_service = identification.get('serviceUrl')
                 conversational_name = identification.get('conversationalName')
             else:
                 conversant_speaker = getattr(identification, 'speakerUri', None)
+                conversant_service = getattr(identification, 'serviceUrl', None)
                 conversational_name = getattr(identification, 'conversationalName', None)
 
-            if conversant_speaker and str(conversant_speaker).strip().lower() == str(speaker_uri).strip().lower():
-                return conversational_name or speaker_uri
-
-        return speaker_uri
+            conversant_speaker_normalized = self._normalize_endpoint_id(conversant_speaker)
+            conversant_service_normalized = self._normalize_endpoint_id(conversant_service)
+            if speaker_normalized and (
+                speaker_normalized == conversant_speaker_normalized
+                or speaker_normalized == conversant_service_normalized
+            ):
+                return (
+                    conversational_name
+                    or _infer_agent_name_from_uri(conversant_speaker)
+                    or _infer_agent_name_from_uri(conversant_service)
+                    or _infer_agent_name_from_uri(speaker_uri)
+                    or ""
+                )
+
+        return _infer_agent_name_from_uri(speaker_uri) or ""
 
     # =========================================================================
     # CONVERSATION LIFECYCLE EVENTS
@@ -503,7 +590,7 @@ def _handle_invite(self, event: InviteEvent, in_envelope: Envelope, out_envelope
         if self.joinedFloor:
             greeting = f"Hi, I'm {agent_name}. I've joined the floor and I'm ready to help!"
         else:
-            greeting = f"Hi, I'm {agent_name}. How can I help you today?"
+            greeting = f"Hi, I'm {agent_name}. I can give you real-time stock information."
 
         # Create greeting utterance
         dialog = DialogEvent(