[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22},"handle","prudhvinakkina","name","vapi-knowledge-base","path","flow-outbound.html","project",{"_23":45,"_11":12,"_34":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":33,"_60":-5,"_61":-5,"_62":37,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_23":24,"_11":14,"_25":26,"_27":-5,"_28":29,"_30":31,"_32":33,"_34":35,"_36":37,"_38":17,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/prudhvinakkina/vapi-knowledge-base/code/flow-outbound.html","extension","html","id","84d23682-4313-4237-948e-82b7e5dbec0a","fileId","747ecd56-854d-11f1-a638-1607ee4eb77e","parentId","branchId","51319357-762a-49a7-b659-2d021fe3500c","branchVersion",5,"latest",true,"createdAt",["D",1784670313854],"version",0,"fileType","content","\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","deleted",false,"label",[14],"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","b47707a6-84a4-11f1-bf51-1607ee4eb77e","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",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_36":88,"_11":89,"_23":29,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",11,"main","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","ctx",{"_81":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":33,"_149":-5,"_150":-7,"_151":-7,"_152":37,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":89,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]