Get a node by its type identifier.

Check if the registry is empty.

Compile Weft source code into a flat ProjectDefinition. `project_id` must be the real DB project_id. The compiler can't derive it from source (the so

Get the number of registered node types.

Parse weft and return the first project (convenience).

Port template accepting any type, independent from sibling ports. See `T_Auto` marker handling in enrich.rs.

Enrich a compiled ProjectDefinition with metadata from the node registry. For each node: 1. Set features from the catalog. 2. Merge weft-declared por

Check edge type compatibility accounting for lane modes

Parse weft and expect no errors. Returns the project. * Filters out validation errors (e.g. "required input port not connected") * that aren't rel

* Ingest one raw Baileys WAMessage. * Safe to call multiple times with the same message (deduped by messageId).

Output postprocessing: after a node completes, process each output port independently based on its laneMode and emit downstream pulses. Each output p

Parse a port type string. Strict : no bare List/Dict/Any. Valid: "String", "List[String]", "Dict[String, Number]", "String | Number", "Media", "T", "

Find all ready groups across all nodes. Returns (node_id, ReadyGroup) pairs.

Build aggregated input for a normal (non-Gather) node from its local pulses.

Set a config field and record its source span in one step. Used at every * `config[key] = ...` call site in the parser so the editor has a single *

Combined TypeVar resolution + type narrowing in one pass. For each node: narrow input ports from source types, extract TypeVar bindings, apply binding

Validate stack depth: expand/gather must be balanced. Walks the graph topologically, tracking stack depth at each node. - Expand input: depth increase

Returns true for TypeVar or MustOverride : types not yet resolved to concrete

Sanitize mock output: keep only ports that exist on the node, fill missing ones with null. Prevents mock data with extra/wrong port names from breakin

Update trigger status

Collapse runs of 3+ blank lines into 2.

* How many messages are stored for a chat.

Spawn a trigger event loop. Handles all infrastructure plumbing: shutdown channel, TriggerHandle construction, and event wrapping. The closure receiv

Find a group by name using the parser.

Returns true if the type includes Null as a valid value. This means null is a legitimate data value, not a skip signal. Whether a port of this type sh

Push ports into target array, skipping duplicates, emitting errors for * malformed entries returned from parseInlinePortList.

Split a port-list-ish string on top-level separators. Both commas and * newlines act as separators at bracket depth 0, matching the backend's * sp

Check if a normal node should be skipped (required port has null data, or all ports in a oneOfRequired group are null/missing).

Get the actual measured port Y, falling back to computed position if DOM isn't available (e.g. during streaming).

Merge weft-declared ports with catalog ports. Rules: 1. Start with catalog ports as the base. 2. For each weft-declared port that matches a catalog p

Parse weft code and return the raw parse result for structural lookups.

Core logic for processing a node completion. Returns dispatch work and restate tasks for the caller to execute. Called both from the HTTP handler and

Get a required string from the config. Returns `TriggerError::Config` if missing or empty.

Execute the results of process_execution_callback: dispatch work + register tasks. Uses Box::pin to break the async type recursion cycle: dispatch_nod

Dedent: strip common leading whitespace from all non-empty lines.

Find matching ) for a ( at startIdx. Returns index of ), or -1.

Find matching ')' for a string starting with '('. Returns (inner_content, rest_after_paren).

Split `node.port` on the single dot. Both parts must be bare identifiers (letters, digits, underscores) with at least one character. Rejects any input

Parse a comma/newline-separated port list with optional @require_one_of directives.

Resolve an api_key field value into an actual key. - Empty or "__PLATFORM__": use the platform key from the env var for this provider. - Anything els

Validate a token and return the user_id if valid Also updates last_used_at