Recursively merge embedded ``i18n[locale]`` blocks into a JSON payload. Looks for an ``i18n`` mapping on each dict node — when present and the

Return platform-level aggregate statistics for every public, completed simulation under ``sim_root``. Result shape:: { "sc

Return ``sha256=<hex>`` for ``payload_bytes`` under ``secret``. ``secret`` defaults to the ``WEBHOOK_SECRET`` env var. A blank / missing secr

Get project Args: project_id: Project ID Returns: Project object, or None if not found

Parse malformed/truncated LLM JSON, recovering as much as possible. Two tiers, each best-effort: 1. Re-close anything a ``max_tokens`` cut-o

Hybrid search — returns results matching the scope. Args: as_of: ISO-8601 timestamp. If set, returns only edges that wer

Pick a translation for ``locale``, falling back to the English source. ``en`` is the canonical source string. ``zh`` (kept positional for the

Get simulation data directory

Quote-safe, single-line YAML scalar for the front-matter block. Wraps strings in double quotes (escaping internal double quotes + backslashes

Save run state to file

Chat with Report Agent In conversation, Agent can autonomously call retrieval tools to answer questions Args: m

Flask application factory function

Render the public-gallery cards as an Atom 1.0 XML feed. ``feed_path`` is the request path that produced this feed (e.g. ``/api/feed.atom?ver

Stable hash of the inputs that affect the rendered GIF. Two summaries with the same hash produce byte-identical GIFs (as long as the renderer

Return ``None`` if the URL is acceptable, else an error message. Empty string is valid (treated as "disable webhook").

Assemble the minimal card-friendly payload for the public gallery. Cheap reads only — no DB joins, no LLM calls. Walks the on-disk artifacts

Reset the four DKG_* config attributes back to the unset shape. The notifications probe reads DKG state via ``dkg_publisher.is_configured()``

Escape a Turtle string literal. Turtle backslash + quote escaping per https://www.w3.org/TR/turtle/#sec-escapes. We use the triple-double

Extract and validate simulation_id from POST body. Returns (simulation_id, None) on success or (None, error_response) on failure.

Read ``<sim_dir>/outcome.json`` if it exists. Returns the parsed dict (with the public fields the gallery + embed surfaces care about) or ``N

Coerce ``value`` to a non-negative int with a default fallback. Belief: every numeric field in the export is non-negative — agent count, roun

Coerce ``value`` to a stripped string.

Measure pixel width — uses textbbox (Pillow 10+) which is accurate for both TTF and the bitmap fallback.

Render the flat platform-stats badge as an SVG string. Returns a complete SVG 1.1 document with the same dimensions, rounded clip path, font

Read sim_dir on-disk artifacts and return the analyst row list. Reads ``trajectory.json`` (required — empty list when missing) and ``quality.

Assemble the GET /api/mcp/status response body. Splitting this from the request handler keeps the unit tests Flask-free.

Get complete action history for all platforms (no pagination limit) Args: simulation_id: Simulation ID platf

Log a single action

Log round start

Record actions from one platform for a round. Call this after each platform steps, BEFORE the next platform steps, so that subsequent

Send response

Update report generation progress Frontend can get real-time progress by reading progress.json

Constant-time verification helper for recipients. Returns ``True`` iff ``header_value`` is the signature this MiroShark instance would emit f

Convert a counts dict into a ``{key, key_pct}``-flavoured dict. Percentages are rounded to one decimal and ``0.0`` when ``total == 0``. Same

Bucket a continuous belief position into bullish/neutral/bearish. Mirrors the ±0.2 threshold used elsewhere — keeps the transcript's per-agen

Reset SMTP_* env vars so the email channel reads as unconfigured.

Reset TELEGRAM_* env vars so the channel reads as unconfigured.

Reset ``WAYBACKCLAW_AGENT_TOKEN`` so the channel reads as unconfigured. ``is_configured()`` returns True iff the agent token is set, so this

Same proxy-aware base URL the share / watch routes use. Honours ``X-Forwarded-Proto`` + ``X-Forwarded-Host`` for deployments behind a TLS-ter

Synthesise a Polymarket-shaped market title from the sim scenario. Polymarket titles start with ``"Will "`` and end with a single ``"?"``. We

Assemble the full tweet-thread payload for a finished simulation. Returns ``{"tweets": [...], "total": N, "inflections_recorded": M, "truncat

Send a chat request Args: messages: List of messages temperature: Temperature parameter max_toke

Build a short ETag from the cheap inputs. ``total_analyzed`` + the year-month prefix of ``newest_completed_at`` detects material change witho

Fetch a URL and return its readable content. Uses Firecrawl (MIROSHARK_FIRECRAWL_BASE_URL) when configured, falling back to the web-sear

Filter and extract nodes with meaningful entity types. Filtering logic: - If a node's labels only include "Entity", it has n

Inject belief state into an agent's system message. Follows the same pattern as ``inject_cross_platform_context``: appends (or replaces) a ma

Read ``<sim_dir>/counterfactual_injection.json`` or return None.

Send an action through the channel to the platform.

Render the feed in the requested format. Returns ``(body_bytes, mime_type)``. ``fmt`` accepts ``"atom"`` (the default) or ``"rss"`` — anythin

Save trajectory to JSON for the report agent.

Stable hash of the inputs that affect the rendered card. Two cards with the same hash are guaranteed byte-identical (as long as the renderer c

Convert belief state to natural language for LLM prompt injection.

GIF signature is GIF87a or GIF89a in the first 6 bytes.

Format ``epoch_seconds`` (UTC) as the naive-local shape ``simulation_runner`` writes into ``state.json``.

Locale-aware lookup that falls back to module-level English constants. Lets us add Chinese variants in the registry without moving the sizabl

Map a percentage (0–100) into a pixel y-coordinate. SVG y-axis is inverted — 0 is at the top. We invert the percentage so 100% maps to ``PAD_

Drop raw embedding vectors from a result payload — they're noise for LLMs.

Three realistic surfaces with distinct, easy-to-verify content.

Bucket per-agent belief positions into bullish/neutral/bearish %. ``belief_positions`` is the snapshot field: ``{agent_id: {topic: float}}``.

Factory for intelligence-sensitive workflows (reports, ontology, graph reasoning). Uses SMART_* config when set, otherwise falls back to the

Pull per-round belief percentages out of the embed-summary payload. Returns a list of ``{round, bullish, neutral, bearish}`` dicts in round o

Render the transcript payload as Markdown. Layout: - YAML front-matter so Notion / Obsidian / Bear pick up the scenario, sim_id, a

Send response

Send response

Check if the simulation has been prepared Conditions checked: 1. state.json exists and status is "ready" 2. Required files exist: re

Strip per-post fields that don't carry signal for agent decisions. CAMEL's ChatAgent accumulates env dumps across rounds, so each post's wire

Compute agent influence scores from simulation action JSONL logs. Reads twitter/actions.jsonl, reddit/actions.jsonl, and polymarket/actions.

Shape a daemon failure into the structured response. ``payload`` is whatever the daemon (or transport) returned. Trim long bodies so the resp

Count frames by reading the GIF with Pillow. Avoids hand-parsing the GCT / image descriptor blocks — Pillow's iterator already knows how to w

The PNG signature is fixed at 8 bytes: 89 50 4e 47 0d 0a 1a 0a.

Load simulation state from file

Load openapi.yaml as a dict — pyyaml is in the unit-test workflow.

Tiny Flask app with one view gated by ``require_admin_token``. We can't import the full ``create_app`` factory here because it boots Neo4j an

Return only the last 4 characters of an API key.

Attach cache_control to the first system message (Anthropic-style). Leaves the input list untouched; returns a shallow copy with the system

Integer Unix timestamp — single source for current-time arithmetic. Pulled into a helper so the test suite can monkey-patch one symbol rather

Open a ZIP from in-memory bytes for inspection.

Read action log file Args: log_path: Log file path position: Last read position state: Run state