Parse the body of a quoted-label expression. Strips surrounding quotes * if present, then unescapes the interior. Mirrors backend try_extract_label.

Report a service usage cost to the usage tracking API. This is the standard way for nodes to report costs. All HTTP plumbing (internal API key, endpo

Compute target expected wire type (mirrors backend target_expected_wire_type)

Check if a type contains any TypeVar references

A dotted ref is 2+ identifier segments joined by `.`, no quotes, no * whitespace, no digits-only segments (so `3.14` is NOT a dotted ref). * Used

Check if a string value looks like the start of an inline node expression. * Accepted forms (after stripping leading whitespace): * Type ( ... )

Resolve the weft/loom/layout sources for the deployment. The dashboard sends an explicit payload so it can strip sensitive field values at publish tim

Dynamically resolve port types based on current port definitions. Called at compile time when the node has TypeVar or dynamic ports. Returns overrides

Runtime type check for a port value, accounting for Expand/Gather lane modes. For **Single** ports, the value must match the declared type directly.

Parse an inline expression from `lines[startLine]` starting at `startCol`. * Appends the child node + connection to `inlineScope` and returns the in

Authenticate a file request. Returns the user_id. In local mode: no auth needed, returns "local". Otherwise: requires internal API key (backend nodes)

Try to bind a TypeVar name to a concrete type. If already bound, check consistency.

Build an OAuth 1.0a Authorization header for a request with no query params. The request body is JSON (not form-encoded), so only oauth_* params are s

Clear the pending action for a trigger.

Count structural parens in a line, ignoring parens inside `@require_one_of(...)`. This prevents directive-internal parens from polluting the port-list

Encrypt sensitive data (e.g., credentials JSON). Returns base64-encoded ciphertext with prepended nonce.

Check the request's internal API key. Constant-time, reads from state (no per-request env access).

A config key must be a bare identifier (no dots, no spaces).

Check for remaining MustOverride ports that have connections (they should have been overridden).

Apply a connection-line literal to a target node's config. If the target * exists, the value is inserted (overwriting any prior value for the same

Write a connection-line literal into the target node's config map. Later writes override earlier ones for the same key. If the target node isn't found

Build node outputs from NodeExecution records. For failed executions, synthesizes an `{"_error": "..."}` output so errors are visible.

Check if a WeftType contains any TypeVar references (at any depth).

Emit null on all output ports of a node. Used when a node is skipped or fails at dispatch time. Routes through postprocess_output so null correctly fl

* Find `needle` in `haystack`. Returns offset and length in haystack, or null. * Tries exact match first, then with trailing-whitespace-trimmed needl

Get an optional string from the config. Returns `None` if missing or empty.

Get a specific trigger by ID

Get an optional u64 from the config (handles both number and string values).

Parse an input value as `Vec<String>`, accepting either a JSON array of strings or a single comma-separated string. Returns empty vec if the key is mi

Check if a JSON-like string has balanced brackets/braces.

True if a source/target id refers to something local to the current * scope. Local means: it IS a declared child, OR it's an anon inline id * `{lo

Check if a source/target identifier refers to something local to the current group scope. A reference is local if: - it IS one of the declared child i

Check if a string value looks like the start of an inline node expression. Returns true if it starts with an uppercase identifier followed by `(`, `{`

Infer media category ("image", "video", "audio", "document") from a MIME type.

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

Parse an inline expression starting at lines[start_line][start_col..]. Generates an anon child node, emits a connection from the child's output to par

Resolve the caller's user id from request headers. In cloud mode: cloud-api's auth middleware decodes the JWT and injects `x-user-id` before forwardi

Aggregate usage_events into usage_daily for a specific date. Uses UPSERT so it can be called multiple times safely (idempotent).

Bind a TypeVar, checking for conflicts

Build node statuses from NodeExecution records. Falls back to "pending" for nodes that haven't been dispatched yet.

Collect ready nodes and prepare dispatch work. Skip propagation happens synchronously (modifies pulses). Actual dispatches are collected as work items

Collect a multi-line triple-backtick heredoc value starting after the opening `` ``` ``. `initial_after_bt` is whatever text appeared on the same line

Collect a multi-line JSON value (object or array) with brace-depth tracking. `initial_value` is the first chunk (e.g. `[` or `{"key":`). Lines are rea

Compute active edge IDs from pulse data. An edge is active when the target node has a Pending pulse on the target port.

Get the output value for an execution, synthesizing `{"_error": "..."}` for failures.