\n \n

\n\n\n\n\n",[60],"4820f447-5950-42db-92c2-0aa4f976aff0","index.html","006a8192-84a5-11f1-9543-1607ee4eb77e",11,["D",1784670391353],5,"\n\n\n\n\nVapi Platform Knowledge Base\n\n\n\n

\n \n

\n\n

\n \n

\n\n\n\n\n\n",[67],"84d23682-4313-4237-948e-82b7e5dbec0a","flow-outbound.html","747ecd56-854d-11f1-a638-1607ee4eb77e",["D",1784670313854],"\n\n\n\n\nPOST /call — Outbound Call E2E Flow\n\n\n\n\n\nCALLS · FLOWCHART\n

POST /call — Outbound Call E2E Flow

Full lifecycle of an outbound phone call: HTTP entry → initialization → transport routing (two paths) → carrier dial → callWorker pipeline → call end. Latency-bearing steps are flagged.

\n\n\n

01HTTP Entryapps/api

\n call.controller.ts:91 — CallController.create()\n

\n • Auth + CASL scope check (ACTION_AUTH.CREATE, SUBJECT_AUTH.CALL)\n • If dto.type === 'outboundPhoneCall' → fires async Dodgeball fraud tracking event\n • If dto.transport.provider === 'websocket' → diverges to callService.websocketCallCreate()\n • Otherwise → callService.createPhoneCall()\n

↓

\n call.service.ts:201 — createPhoneCall()\n

\n • dto.customers (batch) → callBatch() → different path (fan-out)\n • dto.schedulePlan → callSchedule() (writes scheduled row, no immediate dial)\n • Otherwise → callOutbound() ← the normal path\n

\n\n

callOutbound()↓

\n\n\n

02Call InitializationphoneCallFunctions.ts:276

\n 1\n

Pre-load org + feature flags db read

callOrgGet() / featureFlagGet(). Validates billing (concurrency limits, subscription). Returns 400 here if over limit — no DB write yet.

\n 2\n

Resolve assistant version db read

assistantVersionForCallDispatch(). Handles assistantId, inline assistant, squadId/squad, workflowId/workflow, or pinned assistantVersionId. Error → 400 before any call row is written.

\n 3\n

Write call row to DB db write

callInitialize(). Inserts call with status: 'queued'. From this point a call record exists.

\n 4\n

Fetch resources multiple db reads

callResourcesGet(): full assistant (tools, credentials), phone number, customer record, all credentials. Missing → callEndOnError() + error.

\n 5\n

Guard checks each failure marks call ended

\n • Free Vapi number → international → call.start.error-vapi-number-international\n • Dodgeball fraud check (ENABLE_OUTBOUND_CALL_FRAUD_CHECK + Vapi number)\n • Daily outbound limit (resets if outboundCallsCounterNextResetAt passed)\n

\n\n

↓

\n\n\n

03Transport Routingtwo paths

Branch

ENABLE_OUTBOUND_CALL_QUEUING feature flag?

Path A · Queuing ON

\n pendingOutboundCallEnqueue() pushes the call into a Redis/Valkey pending queue. API returns immediately with the queued call. A separate callScheduler worker dequeues and calls callOutboundTransportAndQueue() when capacity is available.

Backpressure valve — prevents thundering-herd on carrier APIs.\n

Path B · Direct (flag off)

\n callOutboundTransportAndQueue() is called inline from the API request, adding its latency directly to the HTTP response. Also taken when phoneCallProviderBypassEnabled.

This is why POST /call sometimes takes >5s — the carrier API is hit synchronously.\n

\n\n

both converge on callOutboundTransportAndQueue()↓

\n\n\n

04Transport + QueuephoneCallFunctions.ts:132

\n callTransportGet() — carrier dial latency 1–5s+\n

Contacts Twilio / Telnyx / Vonage to actually dial the phone — creates the PSTN leg. TwiML/SIP URI streams audio back to Vapi's WebSocket server. Primary latency source on Path B.
• Error → callTransportErrorHandle() + Kafka callOutboundInitiatedEventEmit(status: 'failure')

↓

\n liveCallRequired()\n

Constructs the LiveCall object, stamping all resolved resources (org, assistant, phone number, customer, credentials, feature flags) onto the call.

↓

\n callStoreAndQueue()\n

Updates the call row (transport info, phone provider ID, increments concurrency counter) and enqueues a BullMQ job to the CALL queue for the callWorker.

↓

\n Kafka + API response\n

• Kafka callOutboundInitiatedEventEmit(status: 'success')• API returns the call object (status: queued) — the call.status === 'queued' webhook fires here.

\n\n

BullMQ CALL queue↓

\n\n\n

05callWorker — Live Pipelineapps/callWorker

\n streamBundleConstruct.ts → streamBundleConnectPipes.ts\n

BullMQ picks up the job and creates the LiveCallPipeline. The stream pipeline is constructed, then wired:

Carrier WebSocket audio in ↓

VadStreamvoice activity detection

DenoiserStreamoptional

BackgroundSpeechFilteroptional

CombinedAudioBufferrecording mix

SttStreamDeepgram / AssemblyAI / …

ConversationBuffermessage history

EndpointingBufferend-of-turn detection

LlmStreamOpenAI / Anthropic / …

TtsStreamElevenLabs / Cartesia / …

SampleRateConverter

TurnTakingBuffer

VolumeControlBufferbot speaking state, audio mixing

TransportStream→ carrier WebSocket audio out

↓

\n callStart()\n

All streams start corked (buffering). callStart() uncorks them, fires the assistant-request → assistant-response webhook sequence (server-URL-based configs), then fires status-update: in-progress.

\n\n

on end condition: silence / maxDuration / endCall / hangup↓

\n\n\n

06Call Endmanager.end()

manager.end()

Waits ~2.5s for final STT transcripts to drain.

Cost collection (bottom-up)

STT (per min per channel), LLM (per token), TTS (per character). BYOK credentials (org provides key) → marked user-fault, not billed to subscription.

streamBundleArtifacts()

Uploads recording WAV + transcript JSON to S3.

callComplete()

Writes final DB state: endedAt, endedReason, costs, artifact URLs, analysis (structuredData + successEvaluation + summary from the analysis plan).

end-of-call-report webhook

Delivered to your server URL.

\n\n\n

Key latency sources on POST /call

\n \n \n \n \n \n \n \n \n \n \n

Source	When it hits
callOrgGet + featureFlagGet	always DB reads
assistantVersionForCallDispatch	always DB read
callInitialize	always DB write
callResourcesGet	always multiple DB reads (assistant + phone number + credentials)
Dodgeball fraud check	conditional Vapi numbers only, flag-gated
callTransportGet (carrier API)	path B only biggest variable, 1–5s+ (queuing flag off)

\n If queuing (ENABLE_OUTBOUND_CALL_QUEUING) is on for your org, the carrier dial is deferred and the API returns fast. On the standard path it's all synchronous — which explains the >5s responses seen in the earlier investigation.\n

\n\n\n\n\n\n",[75],{"_36":74,"_13":75,"_39":76,"_41":-5,"_42":43,"_44":71,"_46":47,"_48":94,"_17":63,"_51":24,"_53":78,"_55":56,"_57":-5,"_85":95,"_18":96},{"_36":66,"_13":67,"_39":68,"_41":-5,"_42":43,"_44":69,"_46":47,"_48":91,"_17":71,"_51":24,"_53":72,"_55":56,"_57":-5,"_85":92,"_18":93},{"_36":59,"_13":60,"_39":61,"_41":-5,"_42":43,"_44":50,"_46":47,"_48":88,"_17":63,"_51":24,"_53":64,"_55":56,"_57":-5,"_85":89,"_18":90},{"_36":37,"_13":38,"_39":40,"_41":-5,"_42":43,"_44":45,"_46":47,"_48":84,"_17":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_85":86,"_18":87},["D",1784670333265],"children",[],[38],["D",1784597859612],[],[60],["D",1784670391353],[],[67],["D",1784670313854],[],[75],"e9627797-35b4-470a-a957-8eeef849cbac",["D",1784597836214],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Collaborative Vapi platform reference","imageUrl","userId","28056148-fc13-432f-be05-37a4ce07f9db","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019e511e-6214-7719-8b29-0af034f4b069","tursoName","e962779735b4470aa9578eeef849cbac","tursoHostname","e962779735b4470aa9578eeef849cbac-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789474853273],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_154":150},"org",{"_11":12,"_147":148,"_149":150,"_107":108,"_151":152,"_153":56},"branch",{"_17":69,"_13":16,"_36":43,"_139":97,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":14,"_146":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Prudhvi Nakkina","avatar","https://lh3.googleusercontent.com/a/ACg8ocJhop25jm0wt-QSQjfGck498ZYGdD4MCM_ARgX-IyZCNlNiRl8=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_36":97,"_13":14,"_48":203,"_99":-5,"_100":56,"_101":102,"_103":102,"_104":105,"_106":-5,"_107":108,"_109":40,"_110":47,"_111":-5,"_112":-5,"_113":63,"_114":115,"_116":117,"_118":119,"_120":204,"_122":-5,"_123":124,"_125":124,"_126":127,"_128":127,"_129":127,"_130":124,"_131":124,"_132":205,"_134":206,"_136":207,"_138":56},[191,192,193,194],"files",[191,192,193,194],"counts",{"_181":63,"_182":183,"_184":63,"_31":185,"_186":187},[173,174,175,176],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_36":74,"_13":75,"_39":76,"_41":-5,"_42":43,"_44":71,"_46":47,"_48":77,"_17":63,"_51":24,"_53":78,"_55":56,"_57":-5,"_18":180},{"_36":66,"_13":67,"_39":68,"_41":-5,"_42":43,"_44":69,"_46":47,"_48":70,"_17":71,"_51":24,"_53":72,"_55":56,"_57":-5,"_18":179},{"_36":59,"_13":60,"_39":61,"_41":-5,"_42":43,"_44":50,"_46":47,"_48":62,"_17":63,"_51":24,"_53":64,"_55":56,"_57":-5,"_18":178},{"_36":37,"_13":38,"_39":40,"_41":-5,"_42":43,"_44":45,"_46":47,"_48":49,"_17":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_18":177},[38],[60],[67],[75],"pulls","branches",1,"forks",{"_188":183,"_190":63},"connections",{"_188":63,"_189":63},"count","unfilledCount","emptyCount",{"_36":74,"_13":75,"_39":76,"_41":-5,"_42":43,"_44":71,"_46":47,"_48":94,"_17":63,"_51":24,"_53":78,"_55":56,"_57":-5,"_85":201,"_18":202},{"_36":66,"_13":67,"_39":68,"_41":-5,"_42":43,"_44":69,"_46":47,"_48":91,"_17":71,"_51":24,"_53":72,"_55":56,"_57":-5,"_85":199,"_18":200},{"_36":59,"_13":60,"_39":61,"_41":-5,"_42":43,"_44":50,"_46":47,"_48":88,"_17":63,"_51":24,"_53":64,"_55":56,"_57":-5,"_85":197,"_18":198},{"_36":37,"_13":38,"_39":40,"_41":-5,"_42":43,"_44":45,"_46":47,"_48":84,"_17":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_85":195,"_18":196},[],[38],[],[60],[],[67],[],[75],["D",1784597836214],["D",1789474853273],{"_11":12,"_154":150},{"_11":12,"_147":148,"_149":150,"_107":108,"_151":152,"_153":56},{"_17":69,"_13":16,"_36":43,"_139":97,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":14,"_146":12},"ctx",{"_132":-5,"_170":241,"_242":243,"_244":245,"_246":56,"_247":56,"_248":56,"_249":47,"_250":-5,"_251":-7,"_252":-7,"_253":63,"_254":56,"_255":56,"_256":-5,"_257":56,"_258":56,"_259":56,"_260":-5},"ENV",{"_212":213,"_214":215,"_216":16,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Add knowledge

POST /call — Outbound Call E2E Flow

Code