+
_&i? ^ RI t ^ RIt^ RIHt ^ RIHt ^ RIHtHtH t H
t
^ RI H t ^ RI
HtHt ^ RIHt ^ RIHt ^R IHt ^R
IHtHt ^ R IHtHt ^ R I H t H t H t ^ RI t R
R lt!R R lt"R R lt#R R lt$R R lt%R?R R llt&R@t'R R lt(R R lt)R R lt*R R lt+R! R" lt,R# R$ lt-R% R& lt.R' R( lt/R) R* lt0R+ R, lt1R- R. lt2R/ R0 lt3R1 R2 lt4R?R3 R4 llt5R5 R6 lt6R7 R8 lt7R9 R: lt8R; R< lt9 ! R= R>]Pt 4 t;R# )A N)uuid4) defaultdict)AnyDictListOptional) connections)statusviewsets)action)Response) AgentConfig)AgentConfigCreateSerializerAgentConfigSerializer)_q_ident ensure_business_cluster_tables) list_cloud_agent_deploymentsprepare_workdir_for_bot run_lk_agentc 0 V ^8 d QhR\ R\ /# vreturnr bool)formats "=E:\live-kit-agent\livekit_voicebot\backend\apps\agents\api.py __annotate__r s / /3 /4 / c V R9 # ) )r" T1trueTrue r s &r _truthy_colr( . ..r c < V ^8 d QhR\ R\ R\ /# )r r defaultr )r int)r s "r r r s! s s r c L \ V 4 # \ \ 3 d Tu # i ; iN)r, TypeError
ValueError)r r+ s &&r _safe_intr1 s) 1v
z " s
##c 0 V ^8 d QhR\ R\ /# r valr r list)r s "r r r s c d r c V f . # \ V \ 4 ' d V # \ V \ 4 ' d2 \ P ! V 4 p\ V\ 4 ' d V# . # . # \
d . u # i ; ir.
isinstancer6 strjsonloads Exception)r4 parseds & r _parse_transfer_destinationsr? q
{ #t
#s ZZ_F ' 5 56 =2 = I I -A( $A( (
A87A8c 0 V ^8 d QhR\ R\ /# r rowr dict)r s "r r r , s h hd ht hr c d \ V 4 pVP R4 p\ V\ 4 ' d \ P
! V4 VR& VP R4 p\ V\ 4 ' d \ P
! V4 VR& \ VP R4 \ 4 ' g R\ VP R4 4 RVP R4 ;' g
R;' g RRVP R 4 ;' g
R;' g RR
\ VP R 4 ^
4 R \ VP R
4 4 /VR& \ VP R4 \ 4 ' g R\ VP R4 4 RVP R4 ;' g
R;' g RRVP R4 ;' g
R;' g RR \ VP R4 4 /VR& \ VP R4 \ 4 ' g R\ VP R4 4 RVP R4 ;' g
R;' g RRVP R4 ;' g
R;' g RR \ VP R4 4 /VR& \ VP R4 \ 4 ' g R\ VP R4 4 RVP R4 ;' g
R;' g RRVP R4 ;' g
R;' g RR \ VP R4 4 /VR& VP R4 p\ V\ 4 ' d RpM Ve \ V4 P 4 MRp\ VP R4 4 pV' g \ R V// 4 p\ VP R4 \ 4 ' g R\ VP R 4 4 RVP R 4 ;' g
R;' g RRVP R 4 ;' g
R;' g RR VP R!4 ;' g
R";' g R"R#VR VR \ VP R$4 4 /VR& VP R%4 p\ V\ 4 ' d \ P
! V4 pM Vf / pM\ V\ 4 ' g / pVP R&4 pVe \ V4 P 4 VR'& M VP R'4 ' g RVR'& WqR%& VP R(4 p \ V \ 4 ' g T p
V
f R*p
R)V
/VR(& V# \ d EL? CGG$B CP IrPPb sww 89F?RFFB y)C!DbI #[9a1b%c #
cggk*D 1 1 {377;#78 CGG$; <I BIIr sww 12?8b??R #[9Z1[%\
K cgg 34d ; ; {377+@#AB CGG$; <I BIIr sww ;<IBIIr #[9d1e%f &
!" cgg /0$ 7 7 {377+<#=> CGG$A BO HbOOR sww 78E>BEE2 #[9`1a%b "
,-I)T"" .7.CC N((* /8O0PQL . /MrR cgg 23T : : {377+=#>? CGG$A BO HbOOR sww :;HArHHb )D!E \!P \ \U\ I L #[9c1d%e%
! ''%
&C#s **S/C
T
"
" " #B ~ b'--/J
WWZ
J "
WW'
(F fd # # ;C#*C. J{ @ C s5 U; 5V
;V ; V
V
V V
V/.V/c 0 V ^8 d QhR\ R\ /# rC rE )r s "r r r s r c \ \ V 4 4 pVP R4 pVe W!R& VP R4 ;' g VP R4 pVe W1R& V# )zKAlign cluster `{bid}_bots` rows with AgentConfig-shaped API (`id`, `name`).bot_ididbot_namename)r~ rF rr )rD ru bidr s & r _normalize_cluster_botr sZ
&tCy
1C
''(
C
D wwz"55cggfoH F Jr c t V ^8 d QhR\ R\ \ \ \ 3, , R\ /# )r request_data validatedr )rF r r r: r )r s "r r r s0 T htCQTH~>V bf r c F V ' d V P R 4 MR;' g& V' d T;' g / P R 4 MRp\ V\ 4 ' d \ P ! V4 p\ V\ 4 ' g / pV# \
d / p L)i ; i) voice_configNrr r9 r: r; r< r= rF )r r voice_cfgs && r _voice_config_from_requestr s 5A !!.1t 1: b n- )S!!
9-I i & & I s B
B B c ^ V ^8 d QhR\ R\ R\ \ \ 3, /# )r r bsr )rF r r: r )r s "r r r s, 4 DQTVYQYN r c Z \ VP R4 ;' g / 4 pT ;' g / P 4 F w r4WBV& K / p\ FS pW29 d K VP V4 pVf K" \ V\
4 ' d VP
4 R8X d KO WEV& KU V# )zZVoice tab controls stored under `platform_settings.voice` (subset of full `voice` column).rH rN )rF rr itemsVOICE_TAB_PLATFORM_KEYSr9 r: rs )r r mergedkr ru s && r )_voice_tab_settings_for_platform_settingsr s !"&&/"7"7R 8F b'')q * C
$ ? JJqM 9 a !'')r/ A % Jr c 0 V ^8 d QhR\ R\ /# r3 )r r: )r s "r r r s
c
c
r c V f R# \ V 4 P 4 P 4 P RR4 pVR9 d R# VR 9 d R# VR
9 d R# VR 9 d R# V# ) NrN _ri phone_dynamic_variablesip_urisip_uri_dynamic_variable)ri rj )r phone_number_dynamicphone_as_dynamic_variable)r )r sip_uri_dynamic)r: lowerrs replace)r4 ss & r $_normalize_transfer_destination_typer sd
{ C ((c2A %% [['L ;;) Hr c 0 V ^8 d QhR\ R\ /# )r rawr r5 )r s "r r r s # $ r c V f . # \ V \ 4 ' d V # \ V \ 4 ' d2 \ P ! V 4 p\ V\ 4 ' d V# . # . # \
d . u # i ; ir. r8 )r r> s & r _parse_destinations_listr r@ rA c < V ^8 d QhR\ R\ R\ /# )r tnfeaturesr rF r: )r s "r r r s! ( (4 (4 (C (r c . \ V P R4 ;' g VP R4 ;' g R4 P 4 pV' d
VR, # \ V P R4 4 pV' g \ VP R4 4 pV F p\ V\
4 ' g K \
VP R4 ;' g VP R4 4 pVR 8w d KW VP R4 ;' g VP R4 ;' g Rp\ V4 P 4 pV' g K VR, u # V' d V^ , p\ V\
4 ' d \
VP R4 ;' g VP R4 4 pVR 8X d_ VP R4 ;' g VP R4 ;' g Rp\ V4 P 4 pV' d
VR, # R# )
z
Resolve `transfer_to_number` VARCHAR from explicit fields or first phone-type destination row.
UI label "Phone Number" maps to destination type `phone`.
rj transfer_phone_numberrN :N@ Nrc rb rh typeri )r: rr rs r r9 rF r ) r r ri rc destdtprw firsts && r rt rt s
~ MM(,,/F"GMM2
eg
Sz+BFF>,BCL / =T0UV $%%
1 HH0 1 E ETXXf5E
= HH, - O O.1I O OR
V\\^
2c7N Q eT " "5 56KK%))F:KB W}II 56YY%))N:SYYWYV\\^ c7N
r c 0 V ^8 d QhR\ R\ /# r r )r s "r r r s L L L Lr c V R J ;' g9 V R8H ;' g, \ V \ 4 ;' d V P 4 R8H # NrN )r9 r: rs r' s &r _blankishr s9 9 K KR K KJq#$6$J$J1779?Kr c 0 V ^8 d QhR\ R\ /# )r r r rE )r s "r r r s
0
0d
0t
0r c V P R 4 pVf / # \ V\ 4 ' d2 \ P ! V4 p\ V\
4 ' d V# / # \ V\
4 ' d V# / # \ d / u # i ; i) bot_settings)rr r9 r: r; r< rF r= )r r r> s & r _parse_bot_settingsr s
>
*C
{ #s ZZ_F ' 5 56 =2 = S$''3/R/ I s -A9 A9 9
B B c R V ^8 d QhR\ R\ R\ \ , /# )r r r r )rF r )r s "r r r ' s% T (4. r c VP R 4 pVf V ' d V P R 4 p\ V\ 4 ' d \ P ! V4 p\ V\ 4 ' d V' d V# R# \
d R# i ; i)conversation_behaviorNr )r r r s && r _parse_conversation_behaviorr ' su
2
3C
{rff,-#s **S/C #t
s A> > B
B
c
T V ^8 d QhR\ R\ R\ R\ R\ /# )r r r vdr r r )r s "r r r 5 s4
#'
7;
r c ` \ W4 p/ pV' d WER& \ P ! V4 # )z
`platform_settings` keeps a compact `voice` object for Voice tab fields only.
Full merged voice (incl. voice_id) stays in the `voice` column; language in
`default_language`; features/prompts in dedicated columns.
rH )r r; dumps)r r r r voice_tabpayloads &&&& r %_build_platform_settings_column_valuer 5 s- :)HI G$ ::g r c 0 V ^8 d QhR\ R\ /# r r )r s "r r r E s / /s /t /r c V R9 # )T)Tr" r# r$ r% r& r' s &r _truthyr E r) r c @ V ^8 d QhR\ R\ R\ RR/# )r r
table_colsrD r NrF set)r s "r r r I s. F9 F9 F93 F9T F9d F9r c V ' g R# R pV F9 w rEW@9 g WQ9 d K \ V P V4 4 ' d ^M^ W%& K; RV9 d/ RV 9 d( \ V P R4 4 ' d ^M^ VR& R
pV FU w ruWQ9 g Wp9 d K V P V4 pVe* \ V4 P 4 R8w d \ V4 MRW%& KW R p V FU w ruWQ9 g Wp9 d K V P V4 pVe* \ V4 P 4 R8w d \ V4 MRW%& KW RV9 d0 RV 9 d) \ ^ \ V P R4 4 4 VR& RV9 dR RV 9 dK V P R4 pVe1 \ V4 P 4 R8w d \ V4 R, MRVR& RV9 dN RV 9 dG V P R4 p
V
e2 \ V
\ 4 ' g \ P ! V
4 MT
VR& R p V F9 w ruWQ9 g Wp9 d K \ V P V4 4 ' d ^M^ W%& K; R# \ \ 3 d
RTR& ELi ; i)
zEMap `platform_settings.features` into dedicated `{bid}_bots` columns.Nrd ra rN rR rh N Nrb ))rU rU )r] r] )rJ rJ )rY rY ))rW rW )r_ r_ )rP rP )rf rf )r[ r[ ))rV rV )r^ r^ )rM rM )re re )rZ rZ ))rX rX )r` r` )rT rT )rk rk )r\ r\ ) r rr r: rs maxr, r/ r0 r9 r; r ) r r rD bool_keysfeat_keycol long_textr{ r
short_texttdinterrupt_colss &&& r _apply_features_to_columnsr I sP I #
#s'< X 6771Q #
Z',@H,L'.x||AKBPSATAT4::b>Z\C' (N " B$6 R 0111q "' :& 3.2C* + 3s
'I I:9I:c
L V ^8 d QhR\ R\ R\ R\ RR/# )r r r r rD r Nr )r s "r r r s@ Ml Ml Ml MlRU Ml\` Mlei Mlr c V P R4 ;' g / pRV9 dK RV9 dD VP R4 pVe* \ V4 P 4 R8w d \ V4 MRVR& RV9 dK RV9 dD VP R4 pVe* \ V4 P 4 R8w d \ V4 MRVR& RV9 d0 RV9 d) \ ^ \ VP R 4 4 4 VR& R
V9 d/ R
V9 d( \ VP R 4 4 ' d ^M^ VR
& V P R 4 ;' g / pR
V9 dK R
V9 dD VP R4 pVe* \ V4 P 4 R8w d \ V4 MRVR
& RV9 dK RV9 dD VP R4 pVe* \ V4 P 4 R8w d \ V4 MRVR& RV9 dR RV9 dK VP R4 pVe1 \ V4 P 4 R8w d \ V4 R, MRVR& RV9 dN RV9 dG VP R4 pVe2 \ V\ 4 ' g \ P ! V4 MTVR& RV9 d/ RV9 d( \ VP R 4 4 ' d ^M^ VR& V P R4 ;' g / pRV9 dK RV9 dD VP R4 pVe* \ V4 P 4 R8w d \ V4 MRVR& RV9 dK RV9 dD VP R4 pVe* \ V4 P 4 R8w d \ V4 MRVR& RV9 d/ RV9 d( \ VP R 4 4 ' d ^M^ VR& V P R4 ;' g / p RV9 dK RV9 dD V P R4 pVe* \ V4 P 4 R8w d \ V4 MRVR& RV9 dK RV9 dD V P R4 pVe* \ V4 P 4 R8w d \ V4 MRVR& R V9 d/ R V9 d( \ V P R 4 4 ' d ^M^ VR & V P R 4 ;' g / p
R V9 dK R V9 dD V
P R4 pVe* \ V4 P 4 R8w d \ V4 MRVR & R V9 dK R V9 dD V
P R4 pVe* \ V4 P 4 R8w d \ V4 MRVR & R V9 d3 R V9 d* \ V
P R 4 4 ' d ^M^ VR & R# R# R# \
\ 3 d
RTR& ELi ; i)!z
Fill prompt/description/timeout/interrupt columns from top-level `bot_settings` sections
when those keys were not supplied via `platform_settings.features`.
rJ rP rO NrN rM rL rR rQ rT rS ra rf re rh rg r rb rc rk rY r[ rZ r\ rU rW rV rX r] r_ r^ r` ) rr r: rs r r, r/ r0 r r9 r; r ) r r r rD ecr r r vmstdls &&&& r '_apply_flat_bot_settings_detail_columnsr s-
" # ) )rB 05NR\5\ FF8 34=SV\\^WYEYQ_c %&%X5:X\f:f FF= !89
#a&,,.\^J^c!fdh *+!16PT^6^ 3.1!S 9J5K.LC* + 1@ 4
B=DRVVLcEd=e=ekl 45 $ % + +B"(27RV`7` FF8 56]s1v||~Y[G[3q6ae '($H49VZd9d FF= !78}Q []I]SVcg )*"(27RV`7` FF% &:;-CPQFLLN^`L`3q6#;fj '( h.3Jj3X
VVN
#
>AKBPSATAT4::b>Z\C' (2(B 6* D?FrvvNeGf?g?g!mn 67 % & , ,"B#838TXb8b FF8 67mA Z\H\CFbf () h.3Jj3X FF= !12 3q6<<>UWCWs1v]a #$38C 7: E@GOfHg@h@h1no 78 " "B).@J.N FF8 ,-Mc!fllnPR>R#a&X\ h.3Jj3X FF= !12 3q6<<>UWCWs1v]a #$(8=^bl=l6=bffE\>]6^6^de -. ! " ( (bB x/4LPZ4Z FF8 23-CFLLNVXDXA^b $%$H49VZd9d FF= !78}Q []I]SVcg )*/x? 3z Ah,N')vvi'8'8!a " "Bj [%@ "y 1 11qK % & , ,"B
*/DH/T*,&&*;*;Q !" ! " ( (bBJ&+ " .
?'*377>+B'C^$ '+zz$'7C# $'+C# $
bffWo## $B}}Z
j)--
";<!1
a "* zz"~G "$ 9 z*
/*.&'
/ z*
?'*ww~'>^$
?s$ "P P- P*)P*-%QQc 0 V ^8 d QhR\ R\ /# rC rE )r s "r r r 6 s ! !t ! !r c > \ V 4 pRV9 dI VR, p\ V4 ' d ^VR& M(\ V4 P 4 p \ V4 VR& R F8 pWA9 d K W, p\ V4 ' d RW& K* \ V4 W& K: RV9 dM VP R4 p\ V4 ' d RVR& V# \ V4 P 4 R, VR& V# \
d Y1R& Li ; i \ \
3 d RY& K i ; i)zc
Legacy `{bid}_bots` tables often use INT for mcube_gid; empty strings from JSON must not be sent.
mcube_gidNagent_idN N)ro )rF r r: rs r, r0 r/ rr )rD ru r r r s & r %_sanitize_cluster_bots_row_for_insertr 6 s s)Cc Q<< C A A
%#&q6K % > H Q<<CH
q6 % S GGJ Q<< "C
O J "!fllnT 2C
O J)
%#$K
% z*
s$
C.
D.D ?D D D c V ^8 d QhR\ R\ R\ R\ \ \
\ 3, , R\ /# )r r r r r r )rF r, r r r r: r )r s "r r r Z sB =; =;=; =;.1=;>FtCQTH~>V=; =;r c \ T;' g / p\ W4 p\ V 4 pR TRVP R4 ;' g V P R4 ;' g RP 4 ;' g RRV P R4 ;' g V P R4 RVP R4 ;' g V P R4 ;' g RP 4 ;' g RRVP R4 e VP R4 MV P R4 ;' g RR
VP R 4 e VP R 4 MV P R 4 ;' g RR \ WeW@4 R
RR^/ p\ W`4 pVe! RV9 d \ P ! V4 VR& RVP R4 e VP R4 MV P R4 RVP R4 e VP R4 MV P R4 RVP R4 e VP R4 MV P R4 RVP R4 e VP R4 MV P R4 RVP R4 e VP R4 MV P R4 RVP R4 e VP R4 MV P R4 RVP R4 e VP R4 MV P R4 R\ P ! V P R4 ;' g VP R4 ;' g . 4 R\ P ! V P R4 ;' g VP R4 ;' g . 4 R VR , /
p V P 4 F w rW9 g K
V f K WV
& K RV9 d VP R4 e VP R4 MV P R4 p V eC \ V 4 P 4 R8w d% \ V 4 P 4 R , VR& MR VR& \ WbWu4 VP 4 U
U u/ uF w rW9 g K
WbK p
p
p \ V
4 # u up p
i ) business_idr r rN Unnamed Botr agentId
agent_name llm_modelNrO
system_promptrI
voice_name is_activer stt_provider tts_provider llm_providermcube_exenumberr message_inboundfirst_message_inboundmessage_outboundfirst_message_outbound
guardrails system_toolsdefault_languager ) r r rr rs r r r; r r r: r r )r r r r r r r rD cb optional_mapr r dlangfiltereds &&&& r _build_cluster_bot_rowr
Z s
bB*< V P R4 pVR 9 d! \ V4 P 4 R, MRVR& V# RV 9 g RV 9 du RV9 d# \ / VRV P R4 /V 4 VR& RV9 dE RV 9 d> V P R4 pVR 9 d! \ V4 P 4 R, MRVR& V# \
d
YsT& EK i ; i) z1Map JSON/API fields to cluster columns for PATCH.r r r r r rO r r r r r r r r r r r r N:N Nr r r rI r r )Tr" r# r$ r )r r r: rs r, r0 r r r r r; r rr r )r r mappingupdatesapi_keyr r4 r r r tmpr r r vd_patchr s && r _cluster_update_valuesr s
Jl[,[ !2 "4[G G
"s'8 'C+%$'+A$Aqq J&=Fs^^s3x~~ / 5QU L(=Fs^^s3x~~ / 5QU # S>>#$GLC(A)'*1v # ' (* +<8I %
.*23JIIKDA
*"
;
> 5 C/3zz"~G+ ,& (8(89K(LM * ,+Px,G' ( +0Bl0R !!"45BBDJBV#b'--/#*>\`G& ' N
< '+= +M * ,+PI 2L4D4DEW4X Y[g,G' ( +0Bl0R !!"45BBDJBV#b'--/#*>\`G& ' NC & )'( )s
J&&J:9J:c 0 V ^8 d QhR\ R\ /# rC rE )r s "r r r s D T r c \ V 4 pVP R4 ;' g RVR& VP R4 ;' g RVR& VP R4 pV' d% \ V4 P R4 ' d W!R& V# )zPMatch `DocumentViewSet` cluster rows so `doc_name` appears as `name` for the UI.doc_namerN r doc_url file_pathweb_url)zhttp://zhttps://)rF rr r:
startswith)rD ru dus & r _shape_cluster_kb_documentr sr
s)C''*%++CKwwy)//RC B c"g !899I Jr c V ^8 d QhR\ R\ \ , R\ \ \ \ , 3, /# )r r bot_idsr )r, r r rF )r s "r r r s7 ' ' 'd3i 'DQTVZ[_V`Q`La 'r c V' g / # \ V 4 p\ V4 V R2p. p\ 4 pV F9 p \ V4 pYu9 g K TP T4 TP
T4 K; V' g / # RP R.\ V4 , 4 pR\ V4 RV R2p \ R, P 4 ;_uu_ 4 p
V
P W4 V
P U u. uF q^ , NK
p p V
P 4 p
RRR4 \ \ 4 pX
F\ p\# \% \' X V4 4 4 pVP) R 4 pVf K8 \ V4 pTT, P
T4 K^ \% V4 # \ \ 3 d EKz i ; iu up i + ' g i L; i \ \ 3 d K i ; i)
zSLoad `{business_id}_knowledgebase` rows grouped by `bot_id` (newest first per bot)._knowledgebase, %sSELECT * FROM z WHERE bot_id IN (z ) ORDER BY bot_id ASC, id DESCclusterNr )r, r r r/ r0 addappendjoinlenr r cursorexecuterL fetchallr r6 r rF ziprr )r r! r tableuniqseenxix placeholderssqlcurccolsraw_rowsby_botrdb_ids && r _knowledge_documents_by_bot_idr? s
k
C"3'e> "ED 5D
QB > HHRL KKO 99dVc$i /0L
% ));L> J' '
Y & & ( (C C !oo.o!o.<<>
) %0$5F
&tCaL'9 :uuX < t9D t A <7 :& /
) ( :& sA F F72F2F7' G
F/.F/2F77 G
G G c J V ^8 d QhR\ R\ \ , RR/# )r r botsr N)r, r rF )r s "r r r s* Q QS QT
Qt Qr c . pV FJ pVP R4 pVf VP R4 pVf K/ VP \ V4 4 KL \ W4 pV FV pVP R4 pVf VP R4 p Ve \ V4 MRpVe VP V. 4 M. VR& KX R# \ \ 3 d K i ; i \ \ 3 d Rp LNi ; i)zXMutate bot dicts in place: set `knowledge_documents` from cluster `{bid}_knowledgebase`.r Nr knowledge_documents)rr r) r, r/ r0 r? )r rA idsbr groupediks && r _attach_knowledge_documentsrH s C
eeHo ;%%+C ?
3s8$
-[>G
eeHo ;%%+C _S$B ;=.7;;r2#6b
z*
:& B s# B<
C<CCC*)C*c a a ] tR tRt oRt]P P 4 P R4 t R t
V 3R lt V 3R lt R t
R tV3R lV 3R
lltV 3R ltR t]! R
R.RR7 RR l4 tRtVtV ;t# )
BotViewSeti- z
Bot CRUD. With `business_id`, stores rows only in cluster DB `{business_id}_bots`.
Without `business_id`, uses legacy master `AgentConfig` (agents_agent_config).
r c < V P R 8X d \ # \ # )create)r r r )selfs &r get_serializer_class BotViewSet.get_serializer_class5 s ;;( ". .$$r c
< VP P R4 pV' d \ V4 p\ V4 V R2p\ R, P 4 ;_uu_ 4 pVP
R\ V4 R24 VP Uu. uF q^ , NK
p pVP 4 U
u. uF p
\ \ \ W4 4 4 NK" p p
\ W[4 RRR4 \ X 4 # \& S
V `P ! V.VO5/ VB # u upi u up
i + ' g i L9; i \ d3 p \ RRR \! T 4 /\" P$ R
7 u Rp ? # Rp ? ii ; i) z}
If business_id is provided, read bots from cluster `{business_id}_bots`.
Otherwise fall back to master DB AgentConfig list.
r _botsr' r& z ORDER BY bot_id DESCNmessagez!Failed to load bots from cluster.errorr
) query_paramsrr r, r r r, r- r rL r. r rF r/ rH r
r= r: r
HTTP_500_INTERNAL_SERVER_ERRORsuperr6 )rM requestargskwargsr r r0 r7 r8 r9 r< rowse __class__s &&*, r r6 BotViewSet.list: s9
**..}=
+&.s3 %u
+2244KK.% 0AAV WX*-//:/QaDD/D:PSP\P\P^_P^1 24D 3E FP^D_/: 5
~% w|G5d5f55 ;_ 54
CWcRSfU!@@
sS >D- $-DD"D6&D
D)D-
D D* %D- - E*8'E% E*%E*c
J < VP P R 4 pVP R4 pV' Ed Ve \ V4 p\ V4 V R2p\ R, P 4 ;_uu_ 4 pVP
R\ V4 R2V.4 VP 4 p V ' g( \ RR/\ P R 7 uuRRR4 # VP U
u. uF q^ , NK
p p
\ \ \ W4 4 4 p \! Wl.4 \ V 4 uuRRR4 # \( SV `T ! V.VO5/ VB # u up
i + ' g i L); i \" d3 p
\ R
R R \% T
4 /\ P& R 7 u Rp
?
# Rp
?
ii ; i)
r pkNrQ r' r& WHERE bot_id = %sdetail
Not found.rT rR z Failed to load bot from cluster.rS )rU rr r, r r r, r- r fetchoner
r
HTTP_404_NOT_FOUNDrL r rF r/ rH r= r: rV rW retrieve)rM rX rY rZ bid_rawr` r r0 r7 rD r8 r9 r r\ r] s &&*, r rf BotViewSet.retrieveR sa &&**=9
ZZ
7r~
'l.s3 %u
+2244KK.% 0AAS TWYVZ[ ,,.C '<(@IbIb c 54
+.//:/QaDD/D: 4T#d.5I JG/Y?#G, 54 w 9$9&99 ; 54
BGSQRVT!@@
sZ >E% :AE
E% E(E
95E.
E%
E E" E% "E% % F"0'F F" F"c 2 V P ! V.VO5R R/VB # )partialT_update_cluster_or_masterrM rX rY rZ s &&*,r partial_updateBotViewSet.partial_updatej s" --gUdUtUfUUr c 2 V P ! V.VO5R R/VB # )rj Frk rm s &&*,r updateBotViewSet.updatem s" --gVtVuVvVVr c < V ^8 d QhRS[ /# )r rj )r )r
__classdict__s "r r BotViewSet.__annotate__p s )8 )8$ )8r c
~ < VP P R 4 ;' g VP P R 4 pVP R4 pV' EdT VEeO \ V4 p\ V4 V R2p\
R, P
4 ;_uu_ 4 p V P R\ V4 R24 V P U
u0 uF q^ , kK
p p
\ VP V 4 p V ' g V P R\ V4 R2V.4 V P 4 p
V
' g( \ RR /\ P R
7 uuRRR4 # V P U
u. uF q^ , NK
pp
\ \! \# W4 4 4 p\% W.4 \ V4 uuRRR4 # R P' R V 4 4 p\) V P+ 4 4 pVP- V4 V P R
\ V4 RV R2V4 V P R\ V4 R2V.4 V P 4 p
V P U
u. uF q^ , NK
pp
\ \! \# W4 4 4 p\% W.4 \ V4 uuRRR4 # V' d \4 SV `l ! V.VO5/ VB # \4 SV `p ! V.VO5/ VB # u up
i u up
i u up
i + ' g i LO; i \. d3 p\ RRR\1 T4 /\ P2 R
7 u Rp?# Rp?ii ; i)r r` NrQ r' r& LIMIT 0ra rb rc rT r$ c 3 > " T F p\ V4 R 2x K R# 5i)z = %sNr ).0r s & r 7BotViewSet._update_cluster_or_master.. s )QAXa[M*?s zUPDATE z SET rR z Failed to update bot in cluster.rS ) datarr rU r, r r r, r- r rL r rd r
r
re r rF r/ rH r* r6 valuesr) r= r: rV rW rn rq )rM rX rj rY rZ rg r` r r0 r7 r8 r r rD r9 r set_partsvalsr\ r] s &&&*, r rl $BotViewSet._update_cluster_or_masterp s ,,""=1\\W5I5I5M5Mm5\
ZZ
7r~"
'l.s3 %u
+2244KK.% 0A JK03!@1A$$J!@ 4W\\: NG" nXe_4EEW$X[]Z^_ !lln "#+X|,DVMfMf#g 54 /2oo >o!o >"8c$n9M"N3CC ' 0 54 !% )Q)Q QI 01DKKOKK!(5/!2% {BTU KK.% 0AAS TWYVZ[ ,,.C*-//:/QaDD/D: 4T#d.5I JG/Y?#G,3 54> 7)'CDCFC Cw~g7777? "A ? ;- 544
BGSQRVT!@@
s >K? -K, K A4K,
K? K,)K":5K,/
K? :B"K, K'-5K,"
K? K,, K< 7K? <K? ? L<
'L71L<7L<c < VP P R 4 ;' g VP P R 4 pVP R4 pV' d Ve \ V4 p\ V4 V R2p\
R, P
4 ;_uu_ 4 pVP R\ V4 R2V.4 RRR4 \ \ P R7 # \ S
V `@ ! V.VO5/ VB # + ' g i L>; i \ d3 p \ RR R
\ T 4 /\ P R7 u Rp ? # Rp ? ii ; i) r r` NrQ r' z DELETE FROM ra rT rR z"Failed to delete bot from cluster.rS )rU rr r} r, r r r, r- r r
r
HTTP_204_NO_CONTENTr= r: rV rW destroy) rM rX rY rZ rg r` r r0 r7 r\ r] s &&*, r r BotViewSet.destroy s &&**=9\\W\\=M=Mm=\
ZZ
r~
'l.s3 %u
+2244KK,x.??Q RUWTXY 5 v'A'ABB ww8888 54
DgsSTvV!@@
s6 >D !C3=!D 3 D >D E'D>8E>Ec V P VP R7 pVP RR7 VP P R4 pVR19 Ed \ V4 p\ T4 T R 2p\ R
, P 4 ;_uu_ 4 pTP R \ T4 R 24 TP U u0 uF q^ , kK
p
p RRR4 \! \" P$ ! R
R4 4 P' 4 R29 p Rp Rp
\! TP( P R4 ;' g& TP P R4 ;' g R4 P+ 4 ;' g RpT ' Ed( \- T4 p\" P$ ! R4 p\" P$ ! R4 ;' g Rp\/ RTTT' d" \! T4 P+ 4 ' d TMR\ \" P$ ! RR4 4 RR7 p T P R4 p
T
' gu \! T P R4 ;' g R4 pRTP' 4 9 d< \1 4 pT' d
T^ , MR;' g \" P$ ! R4 p
\5 TP 4 pT
' d T
TR& TTR & \7 TTX
TP( 4 pT' g \ R R!/\ P8 R7 # \; TP= 4 4 pR"P? R#.\A T4 , 4 pR"P? R$ T 4 4 pR%\ T4 R&T R'T R(2p\ R
, P 4 ;_uu_ 4 pTP TT U u. uF p TT , NK up 4 TPB pTP R \ T4 R)2T.4 TPE 4 p TP U u. uF q^ , NK
p p RRR4 \G \5 \I X X 4 4 4 p \K TT .4 T e R \M T P R 4 4 R*T P R*4 R+T P R+4 RT P R4 R T P R 4 R,T P R,4 RT P R4 /T R-& T PO T 4 p \ T \ PP T R.7 # VPS 4 p \U V R/V/R07 P p V PO V 4 p \ V \ PP V R.7 # \
\ 3 d" \ RR./\ P R7 u # i ; iu up i + ' g i EL; i \2 d pR R R \! T4 /p Rp?EL#Rp?ii ; iu up i u up i + ' g i EL; i)3z
With business_id: insert only into cluster `{business_id}_bots` (livekitvoicebot_cluster).
Without business_id: legacy create on master AgentConfig.
)r} T)raise_exceptionr NrN zInvalid business_id.rT rQ r' r& rw !LIVEKIT_AUTO_DEPLOY_ON_BOT_CREATEfalser r LIVEKIT_AGENT_SECRETS_FILELIVEKIT_AGENT_REGIONzus-eastrL LIVEKIT_AGENT_CREATE_TIMEOUT_S1800)region secrets_file timeout_ssilentr stderrz maximum number of agents reachedLIVEKIT_FALLBACK_AGENT_IDokFrR r rb z+Cluster bots table has no writable columns.r$ r% c 3 8 " T F p\ V4 x K R # 5ir. ry )rz r8 s & r r{ $BotViewSet.create.. s :T Ts z INSERT INTO z (z
) VALUES ()ra exit_codecommandstdoutlivekit_deploy)r
headersrX )contextr )r# r$ yeson)+get_serializerr} is_validrr r, r/ r0 r
r
HTTP_400_BAD_REQUESTr r r, r- r rL r: osgetenvr validated_datars r r r r= rF r
rV r6 keysr* r+ lastrowidrd r r/ rH r get_success_headersHTTP_201_CREATEDsaver )!rM rX rY rZ
serializerbusiness_id_rawr r0 r7 r8 r auto_deploy deploy_infolivekit_agent_idr workdirr r r existingr\ request_for_rowrD r9 r5 col_sqlr6 bot_pkfetchedout_colsr r bots! &&*, r rL BotViewSet.create s
((gll(;
D1!,,**=9 * ,
/*
+3 /e5ME Y'..00C nXe_,=X FG,/OO K K)F". %5Ac,FWF]F]F_F_\ei"%bii0PRX&Y"Z #
#K (3z'B$+!$[__X%>%D%D"!E= O'C'EH?G T 0 0 VXV_V_ ;W , #7<< 0O .>
+,4OL )( #z:KdKdeC LM!@@
#D 99dVc$i%78Lii :T ::G % 1G9J|nTUVC Y'..00C C$!7$Q#a&&$!78 nXe_,==O PSYRZ[ ,,.*-//:/QaDD/: 1 -T#h2H-IJG 'gY 7&${t 45 != {y 9
; {y 9 kooh 7 kooh 7-() ..w7GGF,C,CWU U oo 'i5IJOO**73(?(?QQA z*
"%;$<=!66
= 100N ! C#' 3q6"BKC, "8 ; 100s U -V>VV=V* ?BV* ?V* V* W 'W9AW
WW /V
VV V' * W5W
W
W W- Tpostz
initiate-call)rb methodsurl_pathc VP ;' g / p\ VP R4 ;' g5 VP R4 ;' g VP R4 ;' g R4 P 4 pV' g \ RRRR/\
P R 7 # VP R
4 ;' g VP P R
4 p VR09 d \ V4 MR pR p Ve/ \ P P VR 7 P 4 MR p\ VP R
4 ;' g$ VP R4 ;' g \ 4 4 p\ \ P ! RR4 ;' g R4 P# R4 p \ \ P ! RR4 ;' g R4 P# R4 p
\ \ P ! RR4 ;' g R4 p \ \ P ! RR4 ;' g R4 P 4 p \ VP R4 ;' g R4 P 4 p
V
' g V ' d V V 2p
\ VP R4 ;' g R4 P 4 pV' g! V
' d V
V P# R4 RV 2p\ VP R4 ;' g R4 P 4 pV' g9 \ \% VRR4 ;' g R4 P 4 ;' g RpRVRVR
V/pV
' d V
VR& V' d VVR& Ve \ V4 VR& Ve VVR
& V' d \% VR R4 ' d' \ VP& 4 P 4 VR & \% VR R4 ' d1 \ VP( 4 P 4 ;' g R VR & \% VR!R4 ' d' \ VP* 4 P 4 VR"& \ P ! R#R$4 p\- \ P ! R%R&4 4 p \. P0 ! VR'7 ;_uu_ 4 pVP3 VVR(7 pVP4 ' d VP7 4 M/ pR R R 4 XP: R19 d. \ RRRR+R,TP: R-X/\
P8 R 7 # \ RR.RR/R
TR-X/\
P< R 7 # \ d R p ELgi ; i \ d R p ELDi ; i \ d
TTR& ELi ; i + ' g i L; i \ d5 p\ RRRR)R*\ T4 /\
P8 R 7 u R p?# R p?ii ; i)2z
Click-to-call entrypoint from the UI.
Expected body: { "customer_number": "...", "bot_id": "" }
Also accepts aliases used by other integrations: `to`, `custnumber`.
customer_number
custnumbertorN successFrR zcustomer_number is requiredrT r N)r call_idrefidMCUBE_PUBLIC_BASE_URL/MCUBE_PUBLIC_WS_URL_BASEMCUBE_WEBHOOK_PATHz/webhooks/mcubeMCUBE_WS_PATH_PREFIXz/ws callback_urlrefurlr r r+ r r exenumberr r# gidmcube_http_authorizationHTTP_AUTHORIZATIONMCUBE_OUTBOUND_CALL_URLz-http://127.0.0.1:8088/api/mcube/outbound-call MCUBE_OUTBOUND_CALL_TIMEOUT_S20)rQ )r; z$Failed to call outbound-call servicerS z'Outbound-call service returned an error http_statusresponseTzCall initiatedr ) ) r} r: rr rs r
r
r rU r, r= r objectsfilterr r r r rstripgetattrr r r floathttpxClientr contentr; HTTP_502_BAD_GATEWAY status_code HTTP_200_OK)rM rX r` r} r r business_id_intr r public_basepublic_ws_base webhook_pathws_path_prefixr r r r mcube_urlr clientresp resp_jsonr\ s &&& r
initiate_callBotViewSet.initiate_call s ||!!r *+]]txx /E]]RV ]][] ^ d d f E9.KL 22
hh}-XX1E1E1I1I-1X #2=Z2Oc+ .UYO
#' ?A~+%%,,,399;SWC dhhy)IITXXg->II%'J"))$;R@FFBGNNsS RYY'A2 F L L"MTTUXY299%9;LMbbQbc RYY'=u E N NOUUW488N399r:@@B )]<.9LTXXh'--2.446.&'(=(=c(B'C1WINF,/5526<<>
WS&" 5 ; ;<BBDQQ J
/ * w#
&2GN # &GH >
'$'G! &%4GM " s -r22'*3+>+>'?'E'E'G $sK,,!$S]]!3!9!9!;!B!Bss 6;;03C4P4P0Q0W0W0Y,-II 79hi "))$CTJK i00F {{97{;+/<<=U> V V V W )WWWr& r. )__name__
__module__ __qualname____firstlineno____doc__r r allorder_byquerysetrN r6 rf rn rq rl r rL r r __static_attributes____classdictcell__
__classcell__)r] rt s @@r rJ rJ - s
""&&(11&9H%
60:0VW)8 )8V9$lR\ 4&ODk
Ek
k
r rJ r. )text_normalisation_typeoptimize_streaming_latency streaming_latency_optimization pronunciation_dictionary_path stabilityspeed
similarity)r s # , , ! + , , K P ` ` / hV $
(VL
0
/F9RMl`Q&h!H=;@CL'TQ0Z
&& Z
r