Append a feedback event to the buffer with timestamp and current node.

* Add a node of the given type. * * `type` is a spec name (e.g., "startCall", "agentNode"). Remaining * properties are validated agains

Close Redis connection

Get the backend endpoint URLs for external access (webhooks, callbacks, WebSocket connections). Priority: 1. BACKEND_API_ENDPOINT en

Fetch a workflow by id, scoped to a tenant. Scoping is mandatory: pass ``organization_id`` (preferred) or ``user_id``. A fully unscop

Create or update a draft version for this workflow. If a draft already exists, it is updated in place. If no draft exists, a new one

Get workflow run by ID without user filtering - for background tasks

Helper to build a minimal workflow definition dict.

Deep-merge workflow model_overrides onto global user config. - If model_overrides is None or empty, returns a copy of user_config unchanged.

Parse JSON from LLM output, handling common formatting issues. Handles the following common LLM mistakes: 1. JSON wrapped in markdown code bl

Run a pipeline worker through the v1.3 worker runner lifecycle.

Simplified set_node implementation according to v2 PRD.

Helper to build a QA node.

Return a masked representation of *real_key*. Example: >>> mask_key("sk-1234567890abcdef") '****************cdef'

Check if ICE candidate contains a private IP address or CGNAT IP Address. Parses the candidate string to extract the IP address and checks if it'

Return a copy of *workflow_definition* with node secret fields masked.

Look up a registered provider by name.

Resolve the authenticated Dograh user for an MCP tool invocation. Accepts either `X-API-Key: <key>` or `Authorization: Bearer <key>`, reusing

Centralized method to end the call with disposition mapping

Verify the signature of an inbound webhook for security. Each provider extracts its own signature/timestamp/nonce headers. R

Validate a service configuration and return any error statuses.

Create and return appropriate TTS service based on user configuration Args: user_config: User configuration containing TTS settings

Update campaign with arbitrary fields

Create and return appropriate STT service based on user configuration Args: user_config: User configuration containing STT settings

Resolve the provider for a given workflow run. Prefers ``initial_context.telephony_configuration_id`` — stamped at run creation by ``/initiat

Fetch a workflow by id WITHOUT tenant scoping. Explicit unscoped variant of ``get_workflow``. Only for system/runtime contexts that l

Get headers for MPS API requests. Args: organization_id: Organization ID for authenticated mode created_by:

Fire a PostHog event. Silently no-ops if PostHog is not configured.

Create an LLM service from explicit provider/model/api_key. Also used by create_llm_service which extracts these from user_config.

Get or create Redis connection

Main service with two concurrent tasks.

Connect, initialize, and cache the tool list. Never raises on a connect failure — a dead/unreachable MCP server leaves the session ma

List versions for a workflow, newest first. When `limit` is provided, returns at most `limit` rows starting from `offset` — used by t

Set the pipeline task. This allows setting the task after the engine has been created, which is useful when the task needs to be crea

Process status updates from telephony providers. Idempotent: handles repeated callbacks (e.g. from both webhook and CDR).

Get single campaign by ID, ensuring organization access

Fetch custom tools and convert them to function schemas. Args: tool_uuids: List of tool UUIDs to fetch mcp_tool_filte

Preserve real node secret fields when the incoming value is masked.

Normalize a telephony address into a canonical form for storage/lookup. `country_hint` is an ISO-2 country code used to disambiguate non-E.164

Promote the current draft to published. - Draft → published - Previous published → archived - Updates released_definition_id

Stop all connections and clean up.

Factory fixture that creates test clients for specific users. This allows tests to create custom users and test clients on demand. Usage

All registered specs, sorted by name for stable output.

Return cached FunctionSchemas, optionally filtered by raw MCP tool name. ``allowed_raw_names=None`` returns all schemas. An empty set returns

Get campaign by ID without organization check (for internal use)

Mask secret fields inside workflow-level model overrides for API responses.

Record a call outcome, and if the breaker trips, pause the campaign. This is the main entry point called from telephony status callbacks.

Pull the context variables out of a pre-call fetch response. The canonical key is ``initial_context``. The legacy ``dynamic_variables`` key i

Authorize a workflow run before any billable call/text runtime starts. The workflow organization is the billing subject for hosted v2. The workfl

Build authentication header based on credential type. Supports the following credential types: - bearer_token: Authorization: Bearer <token>

Execute an HTTP API tool. Args: tool: ToolModel instance arguments: Arguments passed by the LLM (parameter name -> value)

Get or create the global call transfer manager instance.

Create a FunctionSchema definition that can later be transformed into the provider-specific format (OpenAI, Gemini, etc.). The helper keeps t

Parse LLM-authored TS back into a workflow JSON. Returns the raw validator response — `{"ok": True, "workflow": {...}}` on success, `{"ok": F

Yield the base streamable-HTTP URL of a live mock MCP server.

Restrict user-configured service URLs in hosted deployments. OSS deployments commonly point model services at localhost or private LAN hosts.