Try to coerce a JSON value to a string. Returns None if already a string.

Collect all top-level child ids declared in a scope (group body or * root). Starts at `start` (0-based line index) and walks until the * matching

Collect the full declaration header that may span multiple lines. Starting from `after_type` (which begins with `(`), collects lines until all parens

Variant that also collects multi-line config body when the header has an unclosed `{`. Only called from the top-level declaration path; inline express

Parse a group body: everything between `{` and `}`. Contains child nodes, connections, nested groups, and comments. The first contiguous block of `#`

Build a CompletionContext for tracked AI calls. Prefer `tracked_ai_context()` for most use cases. This lower-level method is available when you need

Count running infra deployments (replicas > 0) across all namespaces.

Count running infra deployments (replicas > 0) for a specific user.

Call `POST /sandboxes` with exponential backoff on 429 Too Many Requests, then parse the three fields we need. If the HTTP succeeds but the body is mi

Delete all K8s resources for an instance by label selector. Deletes Deployments, Services, and PVCs matching the instance label. Waits for all resourc

Derive input and output ports from a node's config.fields using form field specs. Mirrors the frontend's deriveInputsFromFields / deriveOutputsFromFie

Global per-replica concurrency gate for E2B sandbox creation. Enforced across all concurrent ExecPython executions in a single node-runner process. Si

Emit an Expand output port: split the array value into N child-lane pulses. Null is treated as [null] (one child lane with null data) so downstream Ga

Ensure a K8s namespace exists for a user. Creates it with ResourceQuota, LimitRange, and NetworkPolicy if it doesn't exist yet. Namespace format: `wm

Execute collected dispatch work items. Does NOT hold the per-execution mutex. All dispatch setup (instance lookup, infra endpoints) runs concurrently

Expand Group nodes into Passthrough pairs for validation. * Mirrors the backend compiler's flatten logic: * - Group → {id}__in Passthrough + {id}_

Expand a one-liner or bare node declaration into multi-line form. This is * a pure source transformation: the parsed semantics are unchanged, but *

Input preprocessing: mutate the pulse table in-place so that all Pending pulses on a node end up at compatible lane depths before readiness checking.

* Extract all loom code blocks from an LLM response. Accepts both 4-backtick * (canonical) and 3-backtick (regression-friendly) fences, and tolerates

* Extract content from a WhatsApp message. * Returns { content, audio, messageType } where content and audio are * mutually exclusive (one is always

Extract port names from a -> (...) text fragment.

Extract port names from a post-config -> (...) block, if present.

Extract the infrastructure sub-graph from this project. Walks backwards from every infrastructure node, collecting all upstream dependencies (Text no

Hoist `from X import *` lines from module scope (column 0) to the top of the generated script, because Python 3 disallows them inside functions and we

Filter a `{ nodeId: { port: value } }` outputs blob through a deployment's `visitor_access.outputs` allowlist. Mirrors the function of the same name i

* Find a raw WAMessage by its messageId across all chats. * Used by the /media/:messageId endpoint to look up media for download.

Find a connection line using the parser.

Find the position of the `}` that matches the opening `{` at the start * of `s`. Respects string literals so `{`/`}` inside quotes don't break * m

Find a node by ID (possibly scoped like "grp.worker") using the parser.

Find the position of the `}` that matches the opening `{` at the start of `s`. Respects string literals so that `{` or `}` inside quotes don't break m

Find ready groups for a node. Pulses on Gather input ports that haven't been gathered yet (still at child-lane depth) are excluded. Only the parent-la

True if the first `{` in `s` is followed by real config content on the * same line (not just whitespace or a trailing `#` comment). Mirrors the *

Flush immediately (e.g. on shutdown).

Form field specs for hasFormSchema nodes. Each spec maps a field type to the input/output ports it contributes. Used by enrichment to derive ports fro

Generate a unique instance ID for this process

* Get all chatIds that have stored messages.

* Get the set of connected input port names for a node.

* Get the last `count` raw WAMessages for a chat, oldest first.

Get a user's current credit balance. Returns 0.0 if user has no credits row.

Get execution base cost for a user. Priority: subscription custom_execution_base_cost > tier execution_base_cost > default. Panics if an enterprise us

Get all pending actions for triggers belonging to a project.

Compute port Y position for expanded groups (side ports)

Derive a GroupLocation from a ParsedGroup and the lines array. * Parser line numbers are 1-based, editor uses 0-based.