Return cached items list or ``None`` on miss (including TTL expiry).

Look up cached analysis by SHA256. Returns the ``pe_data`` dict (with *filepath* patched to the caller's current path) or ``

Send a log-level info message to the MCP client.

* Computes the minimum value of `array`. If `array` is empty or falsey, * `undefined` is returned. * * @static * @since 0.1.0 * @memberOf _ * @c

* Computes the maximum value of `array`. If `array` is empty or falsey, * `undefined` is returned. * * @static * @since 0.1.0 * @memberOf _ * @c

Smart Size Guard with dual-limit system. Primary: Soft character limit (_SOFT_LIMIT, default 8K chars) — prevents Claude Code CLI from t

Call an MCP tool, parse the response, and run standard assertions. If the server reports the tool is unknown or the required library is not i

Send a progress notification to the MCP client. Throttled by default; pass ``force=True`` for critical milestones (start / complete).

Connect to the Arkana server. Transport selection (ARKANA_TEST_TRANSPORT env var): "auto" — try streamable-http first, fall bac

Run an async coroutine using a shared event loop. Reuses a single event loop across all tests in the session to avoid the overhead of creatin

Helper to run async functions in tests.

Return a snapshot of cached param keys for *tool_name*.

Store *items* in the cache, evicting LRU if needed.

Raise a descriptive RuntimeError if no file has been loaded. Snapshots both ``pe_data`` and ``filepath`` in a single read to avoid a potentia

Thread-safe creation/replacement of a background task.

Thread-safe read of a background task.

Convert an integer to hex string, handling None.

Send JSONL command, read JSONL response. Execution commands (step/continue/run_until/step_over) include ``timeout_seconds`` in the pa

Like asyncio.to_thread() but uses the dashboard's dedicated thread pool. Resilient to a shut-down executor: raises ``DashboardShutdownError``

Check if request is authenticated via cookie, query param, or Bearer header.

Explicitly set the ``AnalyzerState`` for the current context.

Thread-safe partial update of a background task's fields.

Remove all cache entries. Returns summary dict.

Parse an address string (hex or decimal) to int.

Create an empty project (no binaries yet). *name* may be None for auto-naming later via ``promote_scratch``.

Build a synthetic feature dict matching extract_function_features() output.

Raise RuntimeError if the path is outside all allowed directories.

Read an environment variable as int with fallback to *default*. Resolution order: 1. Environment variable (key) 2. User config file (

Convert an ``{"error": "..."}`` dict return into a RuntimeError. Many inner synchronous helpers return error dicts instead of raising. Callin

Helper to safely update progress in the global registry. If a :class:`~arkana.mcp._progress_bridge.ProgressBridge` is provided, also push the

Return a consistent snapshot of (project, cfg).

Resolve by ID first, then by name.

Raise a descriptive RuntimeError if angr is unavailable or still initializing. Provides actionable guidance to the MCP client. Args:

Return a sanitized JSON error response — logs full details, returns generic message. Promotes ``DashboardShutdownError`` to a 503 with a brief me

Parse a sandbox report into the unified schema.

Build complete PE mock with customizable sections.

Ensure angr project and CFG are initialized. Uses a module-level lock to prevent concurrent callers from both creating separate ``angr.Projec

Thread-safe note creation. Returns the new note dict. For hypothesis notes, extra fields are attached: - confidence (float 0.0-1.0, d

Escape a string for use inside a Python repr/string literal.

Attempt to decode bytes as UTF-8 text, falling back to latin-1. When *max_len* > 0 the input is truncated **before** decoding so we never all

Return the most relevant AnalyzerState for dashboard reads. In stdio mode the MCP SDK still creates a session, so tools write to a per-sessio

Helper to run async functions in tests.

Build a structured behavioral digest from decompiled pseudocode lines.

Slice a list and return ``(page, pagination_dict)``. Lightweight helper for adding pagination metadata to individual fields within a larger r

Acquire the lock. Same API as ``threading.Lock.acquire``.

Thread-safe filtered read of notes. Returns copies.

Return user-assigned function name or fall back to default.

Helper to run async functions in tests.

Get a session by ID, or the most recent one if ID is None.

Write config dict to ~/.arkana/config.json, creating the directory if needed. Uses atomic write (temp file + rename) to prevent partial writes fr

Store a binary and its function features into the DB. Returns the binary_id. If the SHA256 already exists, the old entry is replaced (DELETE

Execute a pipeline on a single data blob. Returns (result_bytes, step_log).

Return a short format string from the first 4 bytes of a file. Returns one of: ``'pe'``, ``'elf'``, ``'macho'``, or ``'unknown'``.

Thread-safe artifact registration. Returns the new artifact dict. Schema fields: id, path, sha256, md5, size, source_tool, descri

Release the lock. Silently ignored if generation changed (stale).

Get or create the debug session manager for the current state.

Helper to run a blocking function in a thread and update the registry. Parameters ---------- task_id : str Unique identifier for