Xj܅ < UddlmZddlZddlZddlZddlmZmZddlm Z m Z ddl m Z m Z ddl mZmZddlmZddlmZmZmZmZmZdd lmZmZmZdd lmZmZdd lm Z dd l!m"Z"dd l#m$Z$m%Z%ddl&m'Z'm(Z(m)Z)ddl*m+Z+m,Z,ddl-m.Z.m/Z/m0Z0m1Z1m2Z2ddl3m4Z4ddl5m6Z6m7Z7m8Z8m9Z9ddl:m;Z;ddlm?Z?ddl@mAZAddlBmCZCejDdZEe"ejFGdZHeIejFGddZJe ejFGddZKe'ejFGdd ZLejMNejMOePd!d"ZQe%ZRe;ejFGd#d$ZSeAZTd%e=eSeReT&iZUejFGd'd(d)kre?eSeT&eUd*<dd-ZVe Gd.d/ZWGd0d1eZXGd2d3eZYGd4d5eZZGd6d7eZ[iZ\d8e]d9<dd>Z^d?Z_e+e,d@dAe^e_dBZ`dCZae/ejFGdDdEZbe.e0e1ebdFe^e_eaZcdGdGdHdIZddJZedKZfdLZgddMZhddNZidOZjdPZkeddSZledTdUelVZmemne6ddYZodd\ZpemGd]d^Zqemrd_ddbZsemGdcddZtemrdcdefddiZuemvdjdkfddmZwemGdndoZxemGdpddqZyemGdrddtZzemrduddvZ{emrdwdxfddzZ|emGd{dd|Z}emrd{dd~Z~emGdddZemGddddZemGddddZemGddddZemGdddZemGdddZemGdddZ dddZ dddZddZdZddZiZdZemrddedGfddZemrdddZemrdddZemrdddZGddeZGddeZemrdddZemrdddZemdddZdS)) annotationsN)asynccontextmanagersuppress) dataclassfield)datetimetimezone)AnyLiteral)uuid4)FastAPIHeader HTTPException WebSocketWebSocketDisconnect) FileResponseRedirectResponse JSONResponse) BaseModelField)DeviceCredentialStore)SystemCollector)PiSessionEventPiSessionRegistry) TargetStorenormalize_target split_target) VoiceManagerconfigured_stt) SpeechManagerSpeechPreferencesconfigured_tts HaihubSummaryMODES) quick_catalog) ControlErrorInputProjectSettings)ProjectRegistry) PiAdapter) CodexAdapter)ApprovalRegistry)PiApprovalServerzuvicorn.error.device_gatewayGATEWAY_SERVER_NAME)hostnameGATEWAY_SNAPSHOT_INTERVAL2DEVICE_CREDENTIALS_FILEz*~/.config/esp32-device-gateway/device.jsonGATEWAY_STATE_FILEz+~/.config/esp32-device-gateway/targets.jsonstaticz admin.htmlGATEWAY_PROJECTS_FILEz,~/.config/esp32-device-gateway/projects.jsonpi) approvalsGATEWAY_CODEX_ENABLED01codexreturnrc>tjtjSN)rnowr utcW/home/lighthouse/esp32-dev/.cache/network-resilience-0.5.1/server/device_gateway/app.pyutc_nowrE7s < % %%rCc`eZdZUded<ded<ded<ded<edZded <d Zd ed <eeZd ed<dZ ded<ee j dZ ded<eddZ ded<dZded<dZded<eeZded<ee j dZded<d#d"ZdS)$Devicestr device_idboardfirmwarezWebSocket | None websocketc(tjSr?)r hexrBrCrDzDevice.As uww{rC)default_factory connection_idTboolonliner last_seenNzdict[str, Any] | None last_eventF)rPreprz asyncio.Lock settings_lock)defaultrVzasyncio.Task | None settings_taskz str | None settings_idlast_agent_statezset[str] capabilities send_lockr=dict[str, Any]c|j|j|j|jt |j|j|jdS)N)rIrJrKrSr]rTrU) rIrJrKrSsortedr]rT isoformatrU)selfs rDpublicz Device.publicLsIZ k"4#4551133/   rCr=r_)__name__ __module__ __qualname____annotations__rrQrSrErTrUasyncioLockrWrYrZr\setr]r^rdrBrCrDrGrG;sXNNNJJJMMM/B/BCCCMCCCCF%888I8888(,J,,,,"'% 5"Q"Q"QMQQQQ).t%)H)H)HMHHHH"K"""""U3777L7777#eGLuMMMIMMMM       rCrGceZdZUded<dS)ApprovalDecisionzLiteral['approve', 'reject']decisionNrfrgrhrirBrCrDrnrnXs******rCrncXeZdZUeddZded<eddZded<dS) DisplayMessageP min_length max_lengthrHtitleibodyN)rfrgrhrrxriryrBrCrDrrrr\sR!333E3333s333D333333rCrrc2eZdZUedZded<dS)TargetSelectionz;^(server|(?:agent:(?:pi|codex)|pi):[A-Za-z0-9._:-]{1,160})$)patternrHtargetNrfrgrhrr}rirBrCrDr{r{as1% ^___F______rCr{ceZdZUded<dS)NotificationTestzLiteral['done', 'failed']kindNrprBrCrDrres######rCrzdict[str, Device]devicesdevicepayloadr_NonecK|jr|jtd|j4d{Vt j|j|dd{Vdddd{VdS#1d{VswxYwYdS)Ndevice is offline)rSrL RuntimeErrorr^rjwait_for send_json)rrs rDsend_to_devicerlsJ =0F,4.///GGGGGGGGv/99'BBAFFFFFFFFFGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGs4A44 A>A>cdt|j|uo|jo|jduSr?)rgetrIrSrL)rs rDcurrent_devicerts1 ;;v' ( (F 2 ev} eIYaeIeerCc6t|Sr? target_storerdids rDrOrOxsL4D4DS4I4IrCc t|Sr?) adapter_foragents rDrOrOxsYdejYkYkrCcNttSr?)rRr8 list_pendingrBrCrDrOrOysD1G1G1I1I,J,JrCctj|j}t t pt |o|jdvS)N) RECORDING TRANSCRIBINGAWAITING_CONFIRMATIONSENDING)voicesrequestsrrQrRr8rstate)rvoices rDspeech_blockedr|sd O   4 5 5E  &&(( ) ) NT%3MEKLM=M.N.NNrCGATEWAY_SPEECH_FILEz*~/.config/esp32-device-gateway/speech.jsonc6t|Sr?rrs rDrOrOs   %%rCr[namelatest_activityc ttD]"}t|||||||#dSr?)listrvaluesspeechesterminal)r session_idr final_textrrrs rDon_agent_terminalrsTw~~''((__&%UJo^^^^__rCc(trdttD]=}t |t|d|_>| dSr?) r8rrrrrcancelrrZrl)changedrs rDapprovals_changedrsw&7>>++,, & &F OOF # # # MM& ! ! !!%F   KKMMMMMrCcK|ddkr'|j|dkrd|_dS|j4d{Vt||d{Vdddd{VdS#1d{VswxYwYdS)Ntypesettings_cancel request_id)rZrrW_device_settings)revents rDdevice_settingsrs% V})))  .validstf%%V&*<*CV HXHXY_YiHjHjntHtV~G~T~T~V~VzV VrCsettings_applysettings) still_validc*g|]}|j |jSrB)model).0ss rD z$_device_settings..s8,A,A,Axyx,AAG,A,A,ArCc|jSr?) updated_at)rs rDrOz"_device_settings..s YZYerCT)keyreversesettings_updatedsettings_state)rrr}rz UPDATE FAILEDrB)r isinstancerHlenrZrrIrrr8rrr get_sessionupdate_settingsr)model_validate get_settings list_sessionsproject_registry project_idr%radictr Exceptionr&detail) rrparsedrrsidadaptersessionrrecentexcrr}s ` @@rDrrs ))L ! !C c3  qCHH':':':':':':':': V})))   $ $!%F    f. / /F & ! !F V-=3Yl%m%mnnnnnnnnn~f'='= V}&&   s " "eii&9&9V&C&CVVVVVVV] se$$++C00000000uww =, , ,$44S(:QRWR[R[\fhjRkRk:l:lz4AAAAAAAAHH$11#66666666Huww,,-=-A-A'BT-U-UVVVVVVVV ,A,AVFPePeos=t=t=t,A,A,ABB 577 J *NvXhIhIh3E3En~vGL*N*NDL*N*NOO O O O O O O OV}...T0B0B0B J J/. ]]] 577 ] 1As(23 (E(EZ#**?*\*\]] ] ] ] ] ] ] ] ] ] ] ] ] ] ] ] ] ] ] ]]s'&9J!A6JB8J K2!AK--K2cxKttD]}|jr|j t ||d{V*#t $rt|ddt|ddd|_ |jrMtt 5|j dd{Vdddn #1swxYwYd|_d|_t|_td|jY wxYwdS)NFTnotifyforgetcodez4device %s disconnected while pushing server_snapshot)rrrrSrLrrrrrrZrcloserErTloggerwarningrI)rrs rDbroadcast_server_snapshotrs~w~~''((ee}  0 8  e 11 1 1 1 1 1 1 1 1 e e e OOF5O > > > MM&tM < < >>>>>>>> """""""""m5666666666 7rCc KttD]Z}|j}|jr|js!t j|d9 t j |}t |}|rP| |j dkrCt|d||r|j nddd{Vt j|d|t jvrt }|r|d}t|t|d|_|jt j|<t%jt|t |dd{V#t*$rt j|dt|dd t|dd d|_d|_|jrMt-t*5|jd d{Vdddn #1swxYwYd|_YXwxYwtt0jD]}t5|jd{VdS) NPENDINGapproval_cancelled CANCELLED)r approval_idrrrFTrrr)rrrrQrSrLr8 presentationspoprrrrrrrrZrrjrwirerrr pi_sessionssessionspush_selected_pi_sessionr)r connection current_idcurrentpendingapprovalrs rDsynchronize_approvalsr s7w~~''(($$) } F$4   # ' ' D 9 9 9  $"044Z@@JmmJ//G >w'-92L2L$V6J[e.5FW]];.H.HIIIIIIIII'++J===!888#0022`&qzHOOF+++MM&))))-F&:B:NI+J7!*>&)..QYBZBZ+[+[]^_________ $ $ $  # ' ' D 9 9 9 OOF5O > > > MM&tM < < "I, J,I0 0J3I0 4 JJcK |d{V|td{VCr?)waitclearr rs rDapproval_deliveryr s[&llnn #%%%%%%%%%&rC_r c .Ktjfdt_dtvr.t td_ttd_ttt}| d{Vtj td}tj td} dWVtt d{Vt"d{V|d{VtjdtDd{Vt)d{Vdt_||fD]O}|t-tj5|d{Vdddn #1swxYwYPdS#tt d{Vt"d{V|d{VtjdtDd{Vt)d{Vdt_||fD]O}|t-tj5|d{Vdddn #1swxYwYPwxYw)Nc"tSr?)rrsrDrOzlifespan..s"3G"<"<rCr<zapproval-delivery)rzsystem-monitorc3>K|]}|VdSr?)r)rrs rD zlifespan..#s*PP7w}}PPPPPPrC)rjEventr8 on_changeadaptersqueue_codex_activity on_activityr on_terminalr.rstart create_taskrrrrrgatherrr rrCancelledError)rapproval_server delivery_task monitor_tasktaskrs @rDlifespanr$smooG<<<NOOOL  nnllnn##%%%%%%%%%nPPhoo>O>OPPPQQQQQQQQ#%%%%%%%%%" !=1  D KKMMM'011                     nnllnn##%%%%%%%%%nPPhoo>O>OPPPQQQQQQQQ#%%%%%%%%%" !=1  D KKMMM'011                   sCG8 G**G. 1G. 8C:L2 L ; LL LL LzDevice Lab Gateway0.5.0)rxversionr$rr&c@Kt|jd|jiS)Nr) status_codecontent)rstatusr)requestrs rDcontrol_error_handlerr,/s" CJ3:8N O O OOrCrrHcN|tvrtddt|S)Nzagent adapter not enabled)rr&rs rDrr4s( H6<<< E?rCz/api/approvalscLKdtDS)Nc:g|]}|dS)json)mode)r)rr s rDrz"list_approvals..<s) V V VH  V  , , V V VrC)r8rrBrCrDlist_approvalsr3:s& V VY=S=S=U=U V V VVrCz%/api/approvals/{approval_id}/decisionrvaluecKt||jstddd|t|jdS)Nz'approval is missing or already resolvedr(rT)acceptedrr)r8resolverorrr)rr4s rDdecide_approvalr:?sU   [%. 9 9_4]^^^^[9==Q\C]C]Cc d ddrCz /api/projectsc8KtSr?)rrrBrCrD list_projectsr<Fs  " ""rCr(projectr(c:Kt|Sr?)radd)r?s rD add_projectrBKs    ( ((rCz/api/projects/{project_id}rc>Kt|dSr?)rdelete)rs rDdelete_projectrFPs J'''''rCz /api/agentsc(KdtDS)Ncg|] }|gdd S))rresume_session send_inputr list_modelsr)rr]rB)rrs rDrzlist_agents..WsM g g gVZd-P-P-P Q Q g g grC)rrBrCrD list_agentsrLUs1 g g^f g g ggrCz#/api/projects/{project_id}/sessionscKt|gi}}tjfdtDddid{V}t t|D]Q\}}t|tr"t|tr|j nd||<<| |R||dS)Nc3BK|]}|VdSr?)r)rrr?s rDrz#project_sessions..^s1$e$eW%:%:7%C%C$e$e$e$e$e$erCreturn_exceptionsTzagent catalog unavailable)rerrors) rrrjrrrziprrr&rextend)rrrPresultsrresultr?s @rDproject_sessionsrUZs"":..G2fHN$e$e$e$eS[SbSbSdSd$e$e$e~y}~~~~~~~~GHg..$$ f fi ( ( $,6v|,L,Lm6==RmF4LL OOF # # # # F 3 33rCz)/api/agents/{agent}/sessions/{session_id}rcVKt||d{VSr?)rrrrs rDget_agent_sessionrXgs4U##// ;; ; ; ; ; ; ;;rCz0/api/agents/{agent}/sessions/{session_id}/resumecdKt||d{V}d|||dS)NT)r8rrresumed)rrI)rrrZs rDresume_agent_sessionr[lsF&&55jAAAAAAAAGuJSZ [ [[rCz//api/agents/{agent}/sessions/{session_id}/inputr'cbKt|||jd{VSr?)rrJtextrrr4s rD agent_inputr`rs8U##..z5:FF F F F F F FFrCz2/api/agents/{agent}/sessions/{session_id}/settingscVKt||d{VSr?)rrrWs rDrrws4U##00<< < < < < < <.s%MqMq[\ahMqMqMqMqMqMqrC)r*control_versiononline_devices)sumrrrBrCrDhealthrjs:w#MqMq`g`n`n`p`pMqMqMqJqJq r rrrC/F)include_in_schemarc(KtddS)N/admini3r>)rrBrCrDrootros H# 6 6 66rCrnrc2KttdS)Nz text/html media_type)radmin_page_pathrBrCrD admin_pagerts K @ @ @@rCz /api/admin.jscKttjtjt ddS)Nzadmin.jsztext/javascriptrq)rospathjoindirnamersrBrCrD admin_scriptrzs8  RW___%E%EzRR_p q q qqrCz/servercxKtjpt}|Sr?)rlatestrrrs rD server_statusr}s2&D*:*B*B*D*DH     rCz/deviceslist[dict[str, Any]]cXKg}ttdD]{}|}t|j|d<tj|j|d|d<| |||S)Nc|jSr?)rI)rfs rDrOzlist_devices..srC)rr} speech_mode) rarrrdrrrIr preferencesappend)rTritems rD list_devicesrs F))/D/DEEE}}%))&*:;;X&266v7GhXX] d MrCz /api/statuscrKtjpt}t}|D]K}t d|d}|r&d|d<|djdz|djz|d<L| td{V|dS) Nr7rWAITING_APPROVALrr: waiting_reason)serverrr) rr|rrrdr8rrxrrr)rrrr s rD admin_statusrs&D*:*B*B*D*DH!!##HTT((w|/DEE  T1GG (/ (84(?'!*BS(SG$ %%%''%''''''  rC notification Literal['done', 'failed'] | Nonec .t|}|ddd|||ddddd Sddd|d|d }td|}|r&d |d <|djd z|djz|d<|||d<|S)N agent_stater7 agent:pi:r[OFFLINEr) rrr}rrcwdrelapsed_secondsr)rrr}T)include_historyrrrrr)rrrdr8rrxr)rrrrr s rDpi_target_payloadrsooj))G!D.*..$ "   *j** ... . .G $$T:66GP-$+AJ$4t$;gaj>O$O !". NrCcKtd|d{V}|||d<ttD]}t|jd|kr* t||d{VB#t$rt |ddt |ddd|_ |j rMtt5|j dd{Vdddn #1swxYwYd|_d|_ t#|_YwxYwdS)NrrFTrrr)agent_target_payloadrrrrrrIrrrrrrZrLrrrSrErT)rrrrs rDrrs))AZ)A)ABBBBBBBBG<!8w~~''(( ) )   F, - -1IZ1I1I I I  ) 11 1 1 1 1 1 1 1 1 ) ) ) OOF5O > > > MM&tM < < > > MM&tM < < !>!E!Eg!N!Nuvv!V!]!]^env!]!w!w  D==[__S11=gl= NN,S11 2 2 2 YYY D==[__S11=$S)) ) ) )$.>v.F.Fubey1TSWYY Y Y YYsD,E 9F#F#"F#cKi}ttD]}t|j}t |}t|r |r |r |||fkrM ||vrt|d{V||<||}t|j|kst|s|rrt|td||d|d|d|dd|ddd{Vnnt|}|dd kr0|j d vr'|d d vr|d  |d <|d |_ t||d{V#t$rtdYwxYwdS)Nrrrsrrr[r)rr}rrrrrr<)RUNNINGrr)DONEFAILEDrzAgent target delivery failed)rrrrrrIrrrrrr\lowerrrr) rrrcacherr}rroutgoings rDrrs\ Ew~~''((;;!!&"233f%%f%% V  &UTWLBXBX  ;U"":Nv:V:V4V4V4V4V4V4VE&MFmG 011V;;>RXCYCY;[c 7$VT7Gv]cde]frxyzr{")++o">"> TefhHiHi ' M" = =.?.?.?@@@@@@@@@@ ==!9''F,CGe,e,ejqryjzPkPkP/6w/?/E/E/G/GH^,*1'*:'$VX666666666 ; ; ; NN9 : : : : : ;);;s9AF4C"F44$GGc|fd}tvr,t|t<dSdS)NcK tjdd{Vtdd{Vtddd{VtddS#tdwxYw)Ng333333?r<T)r)rjrr_codex_push_tasksr)rsrDdeliverz%queue_codex_activity..deliver;s --$$ $ $ $ $ $ $ $$Wc22 2 2 2 2 2 2 2$WcDAAA A A A A A A A  ! !#t , , , , ,  ! !#t , , , ,s AA**B)rrspawn)rmethodrs` rDrr9sU----- ###!'ggii!8!8#$#rCz/integrations/pi/events)rXx_device_lab_pi_tokencKt|stddt|}|jdvr t d|j|jdkr5|j r.td|j|j |j |j |j|jdkrt|d{Vn t!|j|j d{Vd |d S) Nizinvalid Pi integration tokenr7)session_shutdown agent_endr7rrrT)r8r)credential_storeauthenticate_pirrapplyrr8cancel_sessionrpending_notificationrrrrrrrrd)rrrs rDpi_eventrFs(  + +,A B BT4RSSSS&&G {777  u'7888 {k!!g&B!$ 2GM7CU&|W=T V V V V {j  '..........&w'97;WXXXXXXXXX)9)9 : ::rCz/devices/{device_id}/targetrI selectioncK|tvrtddt|j}t |}|rM|\}}|dkrt |s(t||d{Vt|}t||krBt |t |d|_ d|_t||d}t!|r; t#|d{V}t||krSt%||d{V|dd|_t|d{Vd}n#t($rt |dd t |dd d|_ |jrMt-t(5|jd d{Vdddn #1swxYwYd|_d|_YnwxYw|||d S) Nr.device not foundr7r7r[FrTrrr)rIr} delivered)rrrr}rrrrrrrrrrZr\rlrrrrrrLrrrS) rIrr}rrrrrrs rD select_targetrZs4FGGGG i. / /F & ! !F 6 s +//#"6"6 e$$0055 5 5 5 5 5 5 5 Y F ""f,, f!"$Y'''If$ $088888888G **f44$VW555555555*1++gr*B*B'''/////////  $ $ $ OOF5O > > > MM&tM < < eZdZUeddZded<ded<dS) SpeechSelectionrsrurHr}z6Literal['OFF', 'MANUAL', 'AUTO_REPLY', 'AUTO_SUMMARY']r2Nr~rBrCrDrrs>%1555F5555@@@@@@rCrc<eZdZUeddZded<ddiZdS) SpeechTestrsrrurHr}extraforbidN)rfrgrhrr}ri model_configrBrCrDrrs:%1555F5555X&LLLrCrz/api/devices/{device_id}/speechcKt|}|stddt|t |jkrtddt |t j ||j|j t |d{V|j t |jdS)Nr.Device not foundr6 Target changed; refresh settings)r2r}) rrrrrr}rrrrlr2rrIr4rs rDset_speech_moders [[ # #F 5C!3444 ""&6u|&D&DDDC!CDDD OOF Y ejAAA   F # ########J*:5<*H*H I IIrCz$/api/devices/{device_id}/speech-testc>Kt|}|stddt|t |jkrtddt |ddstdddd iS) Nr.rr6rscreenu语音播放测试成功。zASpeech unavailable, device busy or firmware lacks speech_playbackr8T)rrrrrr}rrrs rD test_speechrs [[ # #F 5C!3444 ""&6u|&D&DDDC!CDDD >>&(,I J JfC!deee  rCz /device/wsrLrc  K|d{Vd} |d{V t tr ddkr|ddd{V |ft |ddt|ddd|_ tj |j d|t|j|urt |ddt|ddd|_ |jrMt#t$5|jd d{Vdddn #1swxYwYd|_d|_t)|_t,d |jdSdSdSd }t1 fd |Dr|ddd{V |ft |ddt|ddd|_ tj |j d|t|j|urt |ddt|ddd|_ |jrMt#t$5|jd d{Vdddn #1swxYwYd|_d|_t)|_t,d |jdSdSdS d}t2| dst,d||ddd{V |ft |ddt|ddd|_ tj |j d|t|j|urt |ddt|ddd|_ |jrMt#t$5|jd d{Vdddn #1swxYwYd|_d|_t)|_t,d |jdSdSdSt|}|c|j\t |ddt|dd|jddd{Vt9| d d|t dt:r d dgDn t=}|t|<t?|ddid{Vt@j!pt@"}t?||#d{VtH|}tK|d{V}t?||d{V|dd|_&t '|d{Vt(t,d|j|j)|j* |d{V}t|tr(t|dtVs!t,d|jyt)|_|d,dr d|din||_-|d,d r#t .||d{Vnr|d,d!rI|dd"krt |t.||d{Vn|dd#vr|dd$krt ||dd%krt_||d{Vn|j0|j01r/t2t_|||_0nkt?|d&|d'd(d)d{Vn<|dd*krqt|j|urO|jrHt3|d+|d,|j -n|dd.krKt,d/|j|d0d1|d2d1nh|dd3kr5t,4d4|j|d5n't,d6|j|di#tj$rYn)t$$rt,6d7YnwxYw|ft |ddt|ddd|_ tj |j d|t|j|urt |ddt|ddd|_ |jrMt#t$5|jd d{Vdddn #1swxYwYd|_d|_t)|_t,d |jdSdSdS#|ft |ddt|ddd|_ tj |j d|t|j|urt |ddt|ddd|_ |jrMt#t$5|jd d{Vdddn #1swxYwYd|_d|_t)|_t,d |jwwwxYw)8Nrhelloizfirst message must be hello)rreasonFTrrrzdevice %s offline)rI device_tokenrJrKc3|K|]6}t|t p| V7dSr?)rrrH)rrrs rDrz#device_websocket..sEYY:eiinnc222D%*nYYYYYYrCz invalid hellorIrzrejected unauthorized device %szunauthorized deviceizreplaced by a new connectionrJrKr]c<h|]}t|t|SrB)rrH)rvs rD z#device_websocket..s)YYYjQRTWFXFXY!YYYrC)rIrJrKrLr] hello_ackrr[z%device %s online board=%s firmware=%szdevice %s sent invalid event)voice_ settings_speech_rr voice_start)rrrrrrrzSettings request busyrapproval_responserro)device_connection button_eventz,device %s button clicked button=%s action=%sbuttonunknownaction heartbeatzdevice %s heartbeat uptime=%suptimezdevice %s event type=%szdevice websocket failed)7accept receive_jsonrrrrrrrrZr8rrrQrrIrLrrrSrErTrranyr authenticaterrGrrlrrr|rrrrr\rrrJrKrH startswithrUhandlerrYdonerr9debugr exception) rLrrequiredrIpreviousrr}rrrs @rDdevice_websocketrs      Fd?,,........%&& %))F*;*;w*F*F//t4Q/RR R R R R R R R d   OOF5O > > > MM&tM < < "?"?6"I"I OOF5O > > > MM&tM < < > > > >  "I"IkF YYYYPXYYY Y Y //tO/DD D D D D D D D Z   OOF5O > > > MM&tM < < "?"?6"I"I OOF5O > > > MM&tM < < > > > >  "I"Ia+& ,,Yn8MNN  NN > > MM&tM < < "?"?6"I"I OOF5O > > > MM&tM < < > > > >  "I"IW;;y))  H$6$B OOHU4O @ @ @ MM(5M > > >$**=[*\\ \ \ \ \ \ \ \.:&eii77>>JYYUYY~r%B%BYYYYDGEE    $ Vfk%:;;;;;;;;;#*H.>.F.F.H.HVX%8%8%:%:;;;;;;;;;!!),,,V44444444VW---------")++gr":":''''''''' 3V5Ev|U[Ud   $ X#0022222222EeT** *UYYv=N=NPS2T2T =v?OPPP&yyF ;@=;S;STv;w;w!Cv 7 7~CF V}'' 22 Xoofe4444444444v))(33 X=M118??63J3J3JmmFE2222222222v"WWW=N22HOOF4K4K4K=$555)&%8888888888+3v7K7P7P7R7R3/5||OFTY&> *@U@U8>8L&NNNv.00 B$IIh 22IIh 22  v+-- NPUPYPYZbPcPcdddd 5v7GvWWWI$ XJ      4442333334   OOF5O > > > MM&tM < < "?"?6"I"I OOF5O > > > MM&tM < < > > > >  "I"I   OOF5O > > > MM&tM < < "?"?6"I"I OOF5O > > > MM&tM < < > > > "IsA&k-/"FF!$F!/;k-"MMMA"k-"T  TTVk-- l7r 9#lr lr "p77p;>p; C(w.1"v w.v# #w.&v# 'Aw.)r=r)rrGrr_r=r)rr_r=r)r=r)rr )rr&)rrH)rrHr4rn)r?r()rrH)rrHrrH)rrHrrHr4r')rrHrrHr4r)re)r=r)r=r)r=r~r?)rrHrrr=r_)rrHrrr=r)rrr=r)NNF)rrrrHr=r_)rIrHrr{r=r_)rIrHrrrr=r_)rIrHr+rr=r_)rIrHr4r)rIrHr4r)rLrr=r) __future__rrjloggingrv contextlibrr dataclassesrrrr typingr r uuidr fastapir rrrrfastapi.responsesrrrpydanticrrdevice_gateway.authr device_gateway.collectors.systemrdevice_gateway.integrations.pirrdevice_gateway.staterrrdevice_gateway.voicerrdevice_gateway.speechr r!r"r#r$device_gateway.control.settingsr%device_gateway.control.modelsr&r'r(r)device_gateway.control.projectsr*device_gateway.control.pir+device_gateway.control.codexr, device_gateway.control.approvalsr-"device_gateway.control.pi_approvalr. getLoggerrenvironrrfloatrrrrwrxry__file__rsrrr8rrErGrnrrr{rrrirrrrspeech_preferencesrrrrrrrr rr$appexception_handlerr,rr3postr:r<rBrErFrLrUrXr[r`rrrjrortrzr}rrrrrrrrrrrrrrrrrrLrrBrCrDrs """"""" 44444444((((((((''''''''RRRRRRRRRRRRRRJJJJJJJJJJ%%%%%%%%555555<<<<<<LLLLLLLLLLLLLLLLLL========hhhhhhhhhhhhhh999999PPPPPPPPPPPP;;;;;;//////555555======??????  9 : :"?BJNN;P,Q,QRRR!E"*..1Lc"R"RSS((JNN!4 {JNN5 ',,rwx88(LQQ!! "?2:>>2IKy#z#z{{     )),kYOOO P:>>)3//366$ %5KKKHW&&&&          8+++++y+++44444Y444 `````i```$$$$$y$$$ GGGGfff nn&&(I(IKkKkN$J$J L LNNN '&rz~~6KMy'z'z{{ =))==??=\  ;MMGGGNMG =>>===?>= >??GGG@?Gssss&&777'&7U++AAA,+AE22rrr32r!!!!      GK<GK)))))*))))@YYY*;;;;4 9 9 9 #u=="(!3!3!3;;;;>=;& '((!N!N!N)(!NH ())FFF*)F$ 233 H H H43 H AAAAAiAAA ''''''''  +,, J J J-, J 01121|g?g?g?g?g?g?rC