Read a context field.

Resolve the active locale from the Flask request object. Order of precedence: ``?lang=`` query param → ``X-MiroShark-Locale`` header → ``Acce

Look up a prompt template and substitute placeholders. ``key`` is ``<module>.<name>``. The lookup tries the requested locale first, then Engl

Get a logger (create one if it doesn't exist) Args: name: Logger name Returns: Logger instance

Write a fake simulation folder under ``root`` with the minimum files ``compute_project_stats`` reads.

Convert to dictionary

Return the locale set for the current execution context.

Write a fake simulation folder under ``root`` with the minimum files ``build_distribution`` reads. ``final_belief`` is the per-stance percent

Get simulation state

Set one or more context fields (simulation_id, round_num, agent_id, agent_name, platform, trace_id, run_id, sim_phase, prompt_type).

Build a minimum sim folder under ``root``. Snapshots defaults to a one-round bullish trajectory so the signal pipeline yields a non-null dire

Shorthand for a stance-split row matching the peak-round projection.

Wonderwall reddit-shape profile with the manager-default fields.

r"""If, in addition to the trace, the operation function also records time in other tables of the database, use the time of entering t

Decide whether ``payload`` should be dispatched under ``events``. Returns ``(passes, trace)``. ``trace`` is a small dict captured for the log

Assemble the same dict the embed-summary endpoint returns. Extracted so the share-card renderer can reuse the data pipeline without going bac

Trim trailing zeros so ``120.0`` serialises as ``120`` — keeps the SVG body small and bytewise stable across float repr quirks.

Create a sim directory with a minimal state.json.

Normalise a free-form locale string to one of ``SUPPORTED``.

Validate that a simulation_id is safe for use in filesystem paths. Rejects any value containing path separators, parent-directory refere

Return the platform-wide outcome distribution for every public, completed simulation under ``sim_root``. Result shape:: {

Run a search and return normalized result dicts. Each result has keys: url, title, content, engine, score, publishedDate (all present

Render a single ``@misc{…}`` BibTeX entry for a published sim. Keyword args: simulation_id: The canonical sim id (``sim_…``). Drives the

Return per-project aggregate statistics for ``project_id`` under ``sim_root``. Result shape:: { "schema_version": "1",

Derive the trading-signal payload from an embed-summary dict. Returns ``None`` when the summary is missing the data required to produce a mea

Write a fake simulation folder under ``root`` with the minimum files ``compute_platform_stats`` reads.

Write a minimum ``state.json`` for one sim under ``root``.

Render a flat Shields.io-style status badge as an SVG string. Returns a complete SVG 1.1 document — XML declaration, namespace, ``viewBox``,

Execute a function with retry on Neo4j transient errors. Replaces 3 different retry patterns from the Zep codebase.

Get run state

A signal-shaped dict — matches the keys ``signal_service`` emits.

Build the full signed-result envelope. Parameters ---------- signal: The dict returned by ``signal_service.compute_signal`` — eve

r"""Update the recommendation system and perform the actions. Args: actions(dict[SocialAgent, Union[ManualAction, LLMAction,

Minimal embed-summary-shaped dict for the signal derivation.

Remove all context fields.

HTML-attribute escape — quotes are critical here since values land inside ``content="..."``.

Derive the Polymarket-shaped prediction payload from an embed summary. Returns ``None`` when: * ``summary`` is not a dict. * The simulat

HTML attribute escape — quotes are critical here since values land inside ``content="..."``.

Create a sim subdir with a minimal ``state.json`` so the layout matches what the route handler would have produced.

Save simulation state to file

Drop a state.json with the manager-shaped defaults + overrides.

Filter + sort + truncate the gallery cards used to render a feed. Mirrors the exact selection ``GET /api/simulation/public`` performs so a su

Mirror the shape ``_build_gallery_card_payload`` returns.

Write a minimum ``state.json`` for one sim under ``root``.

Record a log entry Args: action: Action type, e.g. 'start', 'tool_call', 'llm_response', 'section_complete', etc.

Start background worker thread

Update task status Args: task_id: Task ID status: New status progress: Progress mess

Mirror the shape ``_build_gallery_card_payload`` returns.

Minimal embed-summary-shaped dict for the polymarket derivation.

Make an API call, return parsed JSON. Fail on HTTP errors.

Get simulation config

Log round end

Clear the set. Test-only convenience.

Send a chat request and return JSON Args: messages: List of messages temperature: Temperature parameter

Verify the document round-trips through ElementTree.

Assemble the full transcript payload from the embed summary + on-disk artifacts. The ``summary`` arg is the same dict ``_build_embed_summary_

Escape ``<`` / ``>`` / ``&`` for Telegram HTML parse mode. Telegram rejects the whole message with HTTP 400 if any HTML tag fails to parse —

Assemble the webhook JSON payload for one simulation. Reads ``simulation_config.json``, ``quality.json``, ``trajectory.json``, ``resolution.j

Factory: returns ClaudeCodeClient when LLM_PROVIDER=claude-code, otherwise returns the standard LLMClient.

Get entity type (exclude default Entity label)

Render the trajectory chart for a sim directory. Returns ``None`` when the trajectory is empty so the route handler can emit a clean 404 — be

Resolve a relative path (``/api/simulation/sim_x/share-card.png``) against the deployment base URL. Returns ``None`` when the input is falsy s

Get report folder path

Single trajectory snapshot in the shape agent_sparklines_service reads.