Richer Globe Research Popups is implemented

assets/globe.css

@@ -143,13 +143,173 @@
 }
 
 .globe-marker-popup-empty,
-.globe-marker-popup-hint {
+.globe-marker-popup-hint,
+.globe-marker-popup-waiting,
+.globe-marker-popup-incomplete,
+.globe-marker-popup-preview,
+.globe-marker-popup-activity {
   margin: 0;
   font-size: 0.82rem;
   line-height: 1.4;
   color: #9ca3af;
 }
 
+.globe-marker-popup-status {
+  margin: 0 0 6px;
+  font-size: 0.72rem;
+  font-weight: 600;
+  letter-spacing: 0.05em;
+  text-transform: uppercase;
+  color: #60a5fa;
+}
+
+.globe-marker-popup--researching .globe-marker-popup-status {
+  color: #60a5fa;
+}
+
+.globe-marker-popup--complete .globe-marker-popup-status {
+  color: #34d399;
+}
+
+.globe-marker-popup-activity {
+  margin-bottom: 8px;
+  color: #e5e7eb;
+}
+
+.globe-marker-popup-preview {
+  margin-bottom: 10px;
+  color: #e5e7eb;
+}
+
+.globe-marker-popup-activities {
+  margin: 0 0 10px;
+  padding-left: 1rem;
+  font-size: 0.78rem;
+  color: #cbd5e1;
+}
+
+.globe-marker-popup-view-details {
+  display: inline-flex;
+  align-items: center;
+  justify-content: center;
+  margin: 0 0 10px;
+  padding: 8px 12px;
+  border: 1px solid rgba(245, 158, 11, 0.45);
+  border-radius: 999px;
+  background: rgba(245, 158, 11, 0.12);
+  color: #fbbf24;
+  font-size: 0.82rem;
+  font-weight: 600;
+  cursor: pointer;
+  transition: background 0.15s ease, border-color 0.15s ease;
+}
+
+.globe-marker-popup-view-details:hover {
+  background: rgba(245, 158, 11, 0.22);
+  border-color: rgba(251, 191, 36, 0.75);
+}
+
+.globe-detail-backdrop {
+  position: fixed;
+  inset: 0;
+  z-index: 10000;
+  display: flex;
+  align-items: center;
+  justify-content: center;
+  padding: 24px;
+  background: rgba(2, 6, 23, 0.72);
+  backdrop-filter: blur(6px);
+}
+
+.globe-detail-backdrop[hidden] {
+  display: none;
+}
+
+.globe-detail-dialog {
+  width: min(720px, calc(100vw - 32px));
+  max-height: min(82vh, 760px);
+  display: flex;
+  flex-direction: column;
+  border: 1px solid rgba(245, 158, 11, 0.28);
+  border-radius: 16px;
+  background: #0f172a;
+  box-shadow: 0 24px 64px rgba(0, 0, 0, 0.55);
+  overflow: hidden;
+}
+
+.globe-detail-dialog-header {
+  display: flex;
+  align-items: flex-start;
+  justify-content: space-between;
+  gap: 12px;
+  padding: 18px 20px 14px;
+  border-bottom: 1px solid rgba(148, 163, 184, 0.18);
+}
+
+.globe-detail-dialog-heading {
+  min-width: 0;
+}
+
+.globe-detail-dialog-title {
+  margin: 0;
+  font-size: 1.2rem;
+  line-height: 1.3;
+  color: #f9fafb;
+}
+
+.globe-detail-dialog-pathway {
+  margin: 6px 0 0;
+  color: #fbbf24;
+  font-size: 0.92rem;
+  line-height: 1.35;
+}
+
+.globe-detail-dialog-close {
+  flex: 0 0 auto;
+  width: 36px;
+  height: 36px;
+  border: 0;
+  border-radius: 999px;
+  background: rgba(148, 163, 184, 0.12);
+  color: #e5e7eb;
+  font-size: 1.4rem;
+  line-height: 1;
+  cursor: pointer;
+}
+
+.globe-detail-dialog-close:hover {
+  background: rgba(148, 163, 184, 0.22);
+}
+
+.globe-detail-dialog-body {
+  padding: 16px 20px 20px;
+  overflow-y: auto;
+  color: #e5e7eb;
+  font-size: 0.9rem;
+  line-height: 1.55;
+}
+
+.globe-detail-dialog-body h3 {
+  margin: 1.1em 0 0.45em;
+  font-size: 0.95rem;
+  color: #fbbf24;
+}
+
+.globe-detail-dialog-body h3:first-child {
+  margin-top: 0;
+}
+
+.globe-detail-dialog-body p,
+.globe-detail-dialog-body ul,
+.globe-detail-dialog-body ol {
+  margin: 0.45em 0;
+}
+
+.globe-detail-dialog-body a {
+  color: #fbbf24;
+  word-break: break-word;
+}
+
 .globe-marker-popup-hint {
   margin-top: 10px;
   font-size: 0.75rem;

assets/globe.js

@@ -1,8 +1,5 @@
 /* assets/globe.js */
-import {
-  plainTextSummary,
-  renderMarkdownHtml,
-} from "/assets/markdown.js?v=1";
+import { renderMarkdownHtml } from "/assets/markdown.js?v=1";
 
 const MAPLIBRE_VERSION = "5.24.0";
 const MAPLIBRE_BASE = `https://unpkg.com/maplibre-gl@${MAPLIBRE_VERSION}/dist`;
@@ -122,6 +119,15 @@ function mergeGlobeOptions(...sources) {
 const HIGHLIGHT_SOURCE = "borderless-highlights";
 const HIGHLIGHT_LAYER = "borderless-highlight-circles";
 
+const DETAIL_SECTIONS = [
+  ["why_recommended", "Why This Country Is Recommended"],
+  ["feasible_methods", "Feasible Migration Methods"],
+  ["procedure", "Step-by-Step Procedure"],
+  ["requirements", "Requirements And Documents"],
+  ["duration_costs_risks", "Duration, Costs, And Risks"],
+  ["official_sources", "Official Sources"],
+];
+
 window.BorderlessGlobe = {
   map: null,
   markers: [],
@@ -131,6 +137,10 @@ window.BorderlessGlobe = {
   pendingState: null,
   rootElement: null,
   countryDetails: {},
+  detailModalBackdrop: null,
+  detailModalTitle: null,
+  detailModalPathway: null,
+  detailModalBody: null,
 
   shell() {
     return this.rootElement?.querySelector(".globe-shell") ?? null;
@@ -160,78 +170,204 @@ window.BorderlessGlobe = {
     }
   },
 
+  resolveMarkerDetail(marker) {
+    if (marker.detail) return marker.detail;
+    if (marker.iso2 && this.countryDetails[marker.iso2]) {
+      return this.countryDetails[marker.iso2];
+    }
+    if (marker.name && this.countryDetails[marker.name]) {
+      return this.countryDetails[marker.name];
+    }
+    return null;
+  },
+
+  ensureDetailModal() {
+    if (this.detailModalBackdrop) return;
+
+    const backdrop = document.createElement("div");
+    backdrop.className = "globe-detail-backdrop";
+    backdrop.hidden = true;
+
+    const dialog = document.createElement("div");
+    dialog.className = "globe-detail-dialog";
+    dialog.setAttribute("role", "dialog");
+    dialog.setAttribute("aria-modal", "true");
+
+    const header = document.createElement("div");
+    header.className = "globe-detail-dialog-header";
+
+    const titleWrap = document.createElement("div");
+    titleWrap.className = "globe-detail-dialog-heading";
+
+    const titleEl = document.createElement("h2");
+    titleEl.className = "globe-detail-dialog-title";
+
+    const pathwayEl = document.createElement("p");
+    pathwayEl.className = "globe-detail-dialog-pathway";
+
+    titleWrap.appendChild(titleEl);
+    titleWrap.appendChild(pathwayEl);
+
+    const closeBtn = document.createElement("button");
+    closeBtn.type = "button";
+    closeBtn.className = "globe-detail-dialog-close";
+    closeBtn.setAttribute("aria-label", "Close country details");
+    closeBtn.textContent = "×";
+    closeBtn.addEventListener("click", () => this.closeCountryDetailModal());
+
+    header.appendChild(titleWrap);
+    header.appendChild(closeBtn);
+
+    const body = document.createElement("div");
+    body.className = "globe-detail-dialog-body markdown-body";
+
+    dialog.appendChild(header);
+    dialog.appendChild(body);
+    backdrop.appendChild(dialog);
+
+    backdrop.addEventListener("click", (event) => {
+      if (event.target === backdrop) {
+        this.closeCountryDetailModal();
+      }
+    });
+
+    this._detailModalKeyHandler = (event) => {
+      if (event.key === "Escape" && !backdrop.hidden) {
+        this.closeCountryDetailModal();
+      }
+    };
+    document.addEventListener("keydown", this._detailModalKeyHandler);
+
+    document.body.appendChild(backdrop);
+    this.detailModalBackdrop = backdrop;
+    this.detailModalTitle = titleEl;
+    this.detailModalPathway = pathwayEl;
+    this.detailModalBody = body;
+  },
+
+  async openCountryDetailModal(detail) {
+    if (!detail?.sections) return;
+    this.ensureDetailModal();
+
+    this.detailModalTitle.textContent = detail.country || "Country details";
+    this.detailModalPathway.textContent = detail.pathway || "";
+    this.detailModalPathway.hidden = !detail.pathway;
+
+    const parts = [];
+    for (const [key, heading] of DETAIL_SECTIONS) {
+      const content = detail.sections[key];
+      if (content) {
+        parts.push(`### ${heading}\n\n${content}`);
+      }
+    }
+
+    const markdown = parts.join("\n\n");
+    this.detailModalBody.innerHTML = await renderMarkdownHtml(markdown);
+    for (const link of this.detailModalBody.querySelectorAll("a")) {
+      link.target = "_blank";
+      link.rel = "noopener noreferrer";
+    }
+
+    this.detailModalBackdrop.hidden = false;
+  },
+
+  closeCountryDetailModal() {
+    if (this.detailModalBackdrop) {
+      this.detailModalBackdrop.hidden = true;
+    }
+  },
+
   buildPopupElement(marker) {
-    const detail = marker.detail || this.countryDetails[marker.iso2] || null;
+    const detail = this.resolveMarkerDetail(marker);
+    const status = detail?.status || "pending";
     const container = document.createElement("div");
-    container.className = "globe-marker-popup";
+    container.className = `globe-marker-popup globe-marker-popup--${status}`;
 
     const title = document.createElement("h4");
     title.className = "globe-marker-popup-title";
     title.textContent = detail?.country || marker.name || marker.iso2 || "Country";
     container.appendChild(title);
 
-    const pathway = detail?.pathway || marker.label;
-    if (pathway) {
+    if (detail?.pathway) {
       const pathwayEl = document.createElement("p");
       pathwayEl.className = "globe-marker-popup-pathway";
-      pathwayEl.textContent = pathway;
+      pathwayEl.textContent = detail.pathway;
       container.appendChild(pathwayEl);
     }
 
-    if (detail?.summary) {
-      const body = document.createElement("div");
-      body.className = "globe-marker-popup-body markdown-body";
-      body.dataset.markdown = detail.summary;
-      body.textContent = plainTextSummary(detail.summary, 420);
-      container.appendChild(body);
-    } else if (marker.label) {
-      const fallback = document.createElement("p");
-      fallback.className = "globe-marker-popup-empty";
-      fallback.textContent = marker.label;
-      container.appendChild(fallback);
-    }
+    if (status === "researching") {
+      const statusBadge = document.createElement("p");
+      statusBadge.className = "globe-marker-popup-status";
+      statusBadge.textContent = "Research in progress";
+      container.appendChild(statusBadge);
+
+      const activity = document.createElement("p");
+      activity.className = "globe-marker-popup-activity";
+      activity.textContent = `Researching: ${
+        detail?.current_activity || "Gathering official immigration sources…"
+      }`;
+      container.appendChild(activity);
+
+      if (detail?.activities?.length > 1) {
+        const list = document.createElement("ul");
+        list.className = "globe-marker-popup-activities";
+        for (const item of detail.activities.slice(-3)) {
+          const listItem = document.createElement("li");
+          listItem.textContent = item;
+          list.appendChild(listItem);
+        }
+        container.appendChild(list);
+      }
+    } else if (status === "complete") {
+      if (detail?.preview) {
+        const preview = document.createElement("p");
+        preview.className = "globe-marker-popup-preview";
+        preview.textContent = detail.preview;
+        container.appendChild(preview);
+      }
 
-    if (detail?.sources?.length) {
-      const sources = document.createElement("div");
-      sources.className = "globe-marker-popup-sources";
-      const heading = document.createElement("strong");
-      heading.textContent = "Official sources";
-      sources.appendChild(heading);
-      const list = document.createElement("ul");
-      for (const url of detail.sources.slice(0, 4)) {
-        const item = document.createElement("li");
-        const link = document.createElement("a");
-        link.href = url;
-        link.target = "_blank";
-        link.rel = "noopener noreferrer";
-        link.textContent = url.replace(/^https?:\/\//, "").slice(0, 72);
-        item.appendChild(link);
-        list.appendChild(item);
+      if (detail?.sections && Object.keys(detail.sections).length) {
+        const viewBtn = document.createElement("button");
+        viewBtn.type = "button";
+        viewBtn.className = "globe-marker-popup-view-details";
+        viewBtn.textContent = "View details";
+        viewBtn.addEventListener("click", (event) => {
+          event.preventDefault();
+          event.stopPropagation();
+          void this.openCountryDetailModal(detail);
+        });
+        container.appendChild(viewBtn);
       }
-      sources.appendChild(list);
-      container.appendChild(sources);
+    } else if (status === "incomplete") {
+      const incomplete = document.createElement("p");
+      incomplete.className = "globe-marker-popup-incomplete";
+      incomplete.textContent =
+        detail?.preview ||
+        "Research did not produce verified findings for this country.";
+      container.appendChild(incomplete);
+    } else {
+      const waiting = document.createElement("p");
+      waiting.className = "globe-marker-popup-waiting";
+      waiting.textContent = "Waiting for research to start…";
+      container.appendChild(waiting);
     }
 
     const hint = document.createElement("p");
     hint.className = "globe-marker-popup-hint";
-    hint.textContent = "Research summary — verify on official immigration sites.";
+    if (status === "researching") {
+      hint.textContent = "Live tool activity from the country researcher.";
+    } else if (status === "complete") {
+      hint.textContent = "Verify key requirements on official immigration sites.";
+    } else if (status === "incomplete") {
+      hint.textContent = "Open the parallel research panel in chat for tool logs.";
+    } else {
+      hint.textContent = "Details appear as each country research completes.";
+    }
     container.appendChild(hint);
 
     return container;
   },
 
-  async hydratePopupMarkdown(popup) {
-    const body = popup?.getElement()?.querySelector("[data-markdown]");
-    if (!body) return;
-    const markdown = body.dataset.markdown;
-    if (!markdown) return;
-    body.innerHTML = await renderMarkdownHtml(markdown);
-    for (const link of body.querySelectorAll("a")) {
-      link.target = "_blank";
-      link.rel = "noopener noreferrer";
-    }
-  },
-
   createMarkerPopup(marker) {
     const popupNode = this.buildPopupElement(marker);
     const popup = new maplibregl.Popup({
@@ -242,9 +378,6 @@ window.BorderlessGlobe = {
       className: "borderless-country-popup",
     }).setDOMContent(popupNode);
 
-    popup.on("open", () => {
-      this.hydratePopupMarkdown(popup);
-    });
     return popup;
   },
 
@@ -274,10 +407,7 @@ window.BorderlessGlobe = {
     for (const record of this.markerRecords) {
       const mergedMarker = {
         ...record.marker,
-        detail:
-          record.marker.detail ||
-          this.countryDetails[record.marker.iso2] ||
-          null,
+        detail: this.resolveMarkerDetail(record.marker),
       };
       record.marker = mergedMarker;
       const popupNode = this.buildPopupElement(mergedMarker);

ui/agent/graph/respond.py

@@ -8,7 +8,7 @@ import gradio as gr
 from gradio import ChatMessage
 
 from ui.globe_commands import apply_update_globe
-from ui.globe_details import attach_finding_to_globe
+from ui.globe_details import attach_finding_to_globe, attach_research_progress_to_globe
 
 from ..messages import history_to_api_messages, multimodal_input_to_api_content
 from ..respond import (
@@ -36,6 +36,22 @@ class _UiState:
         self.globe_state = globe_state
         self._pending_by_id: dict[str, int] = {}
 
+    def _attach_research_progress(self, event: dict[str, Any]) -> None:
+        research_task = event.get("research_task")
+        if not research_task:
+            return
+        todo_title = str(research_task.get("title") or "").strip()
+        if not todo_title:
+            return
+        log = event.get("log") or {}
+        self.globe_state = attach_research_progress_to_globe(
+            self.globe_state,
+            todo_title=todo_title,
+            tool_name=str(log.get("tool") or ""),
+            args=dict(log.get("arguments") or {}),
+            message=str(event.get("message") or ""),
+        )
+
     def handle(self, event: dict[str, Any]) -> bool:
         kind = event.get("type")
         if kind == "thinking":
@@ -124,6 +140,7 @@ class _UiState:
                 )
             )
             self._pending_by_id[str(event.get("id"))] = len(self.ui_messages) - 1
+            self._attach_research_progress(event)
             return True
 
         if kind == "tool_end":
@@ -143,6 +160,7 @@ class _UiState:
                 self.ui_messages[index] = message
             else:
                 self.ui_messages.append(message)
+            self._attach_research_progress(event)
             return True
 
         if kind == "finding":

ui/agent/synthesis.py

@@ -99,6 +99,65 @@ def _needs_verification(value: str | None, *, fallback: str) -> str:
     return f"{fallback} *(Needs verification on official immigration sources.)*"
 
 
+def build_country_report_sections(
+    summary: str,
+    *,
+    country: str,
+    pathway: str,
+) -> dict[str, str]:
+    """Structured sections for a single country report."""
+    pathway_text = _extract_section(summary, "pathway") or pathway
+    timeline = _extract_section(summary, "timeline")
+    costs = _extract_section(summary, "costs")
+    risks = _extract_section(summary, "risks")
+    urls = _extract_urls(summary)
+
+    duration_parts = []
+    if timeline:
+        duration_parts.append(f"**Timeline:** {timeline}")
+    if costs:
+        duration_parts.append(f"**Costs:** {costs}")
+    if risks:
+        duration_parts.append(f"**Risks:** {risks}")
+    duration_block = "\n\n".join(duration_parts) if duration_parts else ""
+
+    sources_block = "\n".join(f"- {url}" for url in urls[:8]) if urls else ""
+
+    return {
+        "why_recommended": _needs_verification(
+            _extract_section(summary, "eligibility"),
+            fallback=f"Potential fit for skilled migration to {country} via {pathway}.",
+        ),
+        "feasible_methods": _needs_verification(
+            pathway_text,
+            fallback=pathway,
+        ),
+        "procedure": _needs_verification(
+            _extract_steps(summary),
+            fallback=(
+                f"Confirm the official application sequence on the immigration "
+                f"authority website for {country}."
+            ),
+        ),
+        "requirements": _needs_verification(
+            _extract_section(summary, "documents"),
+            fallback=(
+                "Passport, education credentials, employment records, language "
+                f"test results (if required), and proof of funds — verify exact "
+                f"list for {pathway}."
+            ),
+        ),
+        "duration_costs_risks": _needs_verification(
+            duration_block or None,
+            fallback="Typical processing time, fees, and risks not verified in research.",
+        ),
+        "official_sources": _needs_verification(
+            sources_block or None,
+            fallback="Check the country's official immigration authority website.",
+        ),
+    }
+
+
 def build_structured_final_answer(
     *,
     profile_summary: str,

ui/globe_details.py

@@ -2,10 +2,13 @@
 from __future__ import annotations
 
 import re
+import time
 from typing import Any
 
 from apis.rest_countries import lookup_country
 
+from ui.agent.synthesis import build_country_report_sections
+
 _COUNTRY_NAME_TO_ISO2 = {
     "canada": "CA",
     "germany": "DE",
@@ -21,6 +24,18 @@ _COUNTRY_NAME_TO_ISO2 = {
     "usa": "US",
 }
 
+_INCOMPLETE_SUMMARIES = {
+    "no findings could be produced for this to-do.",
+    "no detailed findings were captured for this country yet.",
+}
+
+_TOOL_ACTIVITY_LABELS = {
+    "search_immigration_info": "Searching immigration sources",
+    "get_country_profile": "Loading country profile",
+    "scrape_web_page": "Reading official page",
+    "crawl_web_site": "Crawling official site",
+}
+
 _URL_PATTERN = re.compile(r"https?://[^\s\)\]>\"']+")
 
 
@@ -34,6 +49,13 @@ def split_country_title(title: str) -> tuple[str, str]:
     return title.strip(), "Skilled migration pathway"
 
 
+def is_incomplete_summary(summary: str) -> bool:
+    text = summary.strip().lower()
+    if not text:
+        return True
+    return text in _INCOMPLETE_SUMMARIES
+
+
 def _extract_urls(text: str) -> list[str]:
     seen: set[str] = set()
     urls: list[str] = []
@@ -65,38 +87,73 @@ def iso2_from_todo_title(title: str, marker_isos: set[str] | None = None) -> str
     return iso2_from_country_name(country, marker_isos)
 
 
-def build_country_detail(todo_title: str, summary: str) -> dict[str, Any]:
+def _preview_text(text: str, limit: int = 220) -> str:
+    cleaned = re.sub(r"[#>*`_\-[\]()]", " ", text)
+    cleaned = re.sub(r"\s+", " ", cleaned).strip()
+    if len(cleaned) <= limit:
+        return cleaned
+    return f"{cleaned[: limit - 1]}…"
+
+
+def _activity_from_tool(tool_name: str, args: dict[str, Any], message: str) -> str:
+    label = _TOOL_ACTIVITY_LABELS.get(tool_name, f"Running {tool_name}")
+    if tool_name == "search_immigration_info":
+        query = str(args.get("query") or "").strip()
+        if query:
+            return f"{label}: {query[:160]}"
+    if tool_name == "scrape_web_page":
+        url = str(args.get("url") or "").strip()
+        if url:
+            return f"{label}: {url[:120]}"
+    if tool_name == "crawl_web_site":
+        url = str(args.get("url") or "").strip()
+        if url:
+            return f"{label}: {url[:120]}"
+    if message.strip():
+        return message.strip()[:220]
+    return label
+
+
+def _base_detail(todo_title: str) -> dict[str, Any]:
     country, pathway = split_country_title(todo_title)
     return {
         "country": country,
         "title": todo_title,
         "pathway": pathway,
-        "summary": summary.strip(),
-        "sources": _extract_urls(summary),
+        "summary": "",
+        "preview": "",
+        "sources": [],
+        "activities": [],
+        "current_activity": "",
+        "sections": {},
+        "updated_at": int(time.time()),
     }
 
 
-def attach_finding_to_globe(
-    state: dict[str, Any],
-    *,
+def _enrich_detail_with_iso2(
+    detail: dict[str, Any],
     todo_title: str,
-    summary: str,
-) -> dict[str, Any]:
-    """Merge researcher findings into globe_state for marker popups."""
-    marker_isos = {str(marker.get("iso2", "")).upper() for marker in state.get("markers", [])}
-    marker_isos.discard("")
-
+    marker_isos: set[str],
+) -> tuple[str | None, dict[str, Any]]:
     iso2 = iso2_from_todo_title(todo_title, marker_isos or None)
-    detail = build_country_detail(todo_title, summary)
     if iso2:
         detail["iso2"] = iso2
         info = lookup_country(iso2)
         if info:
             detail["country"] = str(info.get("name") or detail["country"])
+    key = iso2 or str(detail["country"])
+    return iso2, detail if iso2 else detail | {"iso2": None, "key": key}
 
+
+def _merge_detail_into_state(
+    state: dict[str, Any],
+    *,
+    iso2: str | None,
+    country_key: str,
+    detail: dict[str, Any],
+) -> dict[str, Any]:
     country_details = dict(state.get("country_details") or {})
-    key = iso2 or detail["country"]
-    country_details[key] = detail
+    country_details[country_key] = detail
 
     markers = []
     for marker in state.get("markers", []):
@@ -111,3 +168,116 @@ def attach_finding_to_globe(
         "country_details": country_details,
         "details_version": int(state.get("details_version", 0)) + 1,
     }
+
+
+def build_research_progress_detail(
+    todo_title: str,
+    *,
+    tool_name: str,
+    args: dict[str, Any],
+    message: str,
+    existing: dict[str, Any] | None = None,
+) -> dict[str, Any]:
+    detail = dict(existing or _base_detail(todo_title))
+    activity = _activity_from_tool(tool_name, args, message)
+    activities = list(detail.get("activities") or [])
+    if activity and (not activities or activities[-1] != activity):
+        activities.append(activity)
+        activities = activities[-6:]
+
+    detail.update(
+        {
+            "status": "researching",
+            "current_activity": activity,
+            "activities": activities,
+            "preview": activity,
+            "updated_at": int(time.time()),
+        }
+    )
+    return detail
+
+
+def build_country_detail(todo_title: str, summary: str) -> dict[str, Any]:
+    country, pathway = split_country_title(todo_title)
+    detail = _base_detail(todo_title)
+
+    if is_incomplete_summary(summary):
+        detail.update(
+            {
+                "status": "incomplete",
+                "preview": (
+                    "Research could not produce verified findings for this country. "
+                    "Check the parallel research panel for tool activity."
+                ),
+                "sections": build_country_report_sections("", country=country, pathway=pathway),
+            }
+        )
+        return detail
+
+    sections = build_country_report_sections(summary, country=country, pathway=pathway)
+    detail.update(
+        {
+            "status": "complete",
+            "summary": summary.strip(),
+            "preview": _preview_text(summary),
+            "sources": _extract_urls(summary),
+            "sections": sections,
+            "current_activity": "Research complete",
+        }
+    )
+    return detail
+
+
+def attach_research_progress_to_globe(
+    state: dict[str, Any],
+    *,
+    todo_title: str,
+    tool_name: str,
+    args: dict[str, Any],
+    message: str,
+) -> dict[str, Any]:
+    marker_isos = {str(marker.get("iso2", "")).upper() for marker in state.get("markers", [])}
+    marker_isos.discard("")
+
+    country_details = dict(state.get("country_details") or {})
+    iso2 = iso2_from_todo_title(todo_title, marker_isos or None)
+    country, _ = split_country_title(todo_title)
+    key = iso2 or country
+    existing = country_details.get(key)
+    if existing and existing.get("status") == "complete":
+        return state
+
+    detail = build_research_progress_detail(
+        todo_title,
+        tool_name=tool_name,
+        args=args,
+        message=message,
+        existing=existing,
+    )
+    iso2, detail = _enrich_detail_with_iso2(detail, todo_title, marker_isos)
+    return _merge_detail_into_state(
+        state,
+        iso2=iso2,
+        country_key=iso2 or detail["country"],
+        detail=detail,
+    )
+
+
+def attach_finding_to_globe(
+    state: dict[str, Any],
+    *,
+    todo_title: str,
+    summary: str,
+) -> dict[str, Any]:
+    """Merge researcher findings into globe_state for marker popups."""
+    marker_isos = {str(marker.get("iso2", "")).upper() for marker in state.get("markers", [])}
+    marker_isos.discard("")
+
+    detail = build_country_detail(todo_title, summary)
+    iso2, detail = _enrich_detail_with_iso2(detail, todo_title, marker_isos)
+    return _merge_detail_into_state(
+        state,
+        iso2=iso2,
+        country_key=iso2 or detail["country"],
+        detail=detail,
+    )