)j) <dZddlZddlmcmZddlZddlZddl m Z ddl m Z ddl Z ddlmZddlmZddlmZddlmZmZdd lmZGd d ejZd Zd dddddZe jdgddZ dZ!dZ"dZ#e$dkrddl%Z%iZ&dD]]Z'e j()5Z*eee'e*\Z+Z,dddn #1swxYwYde+e,de&e-e'<^e j()5Z*eede*dd\Z+Z,dddn #1swxYwYde+e,de&d<e e%j.d/ej0e&d !d"zd#Z1d$Z2d%Z3dS)&zDeterministic application backpressure at the real Starlette ASGI boundary. No socket/ESP32 equivalence is assumed; the one-slot queue is an explicit model. N)Path)SimpleNamespace) WebSocket)app)speech) SpeechManager CHUNK_BYTES) SpeechTracec.eZdZfdZdZfdZxZS) VirtualLoopcVd|_tdS)NgY@)nowsuper__init__self __class__s a/home/lighthouse/esp32-dev/.cache/wifi-fallback-speech-ab-0.5.1/server/tests/test_speech_trace.pyrzVirtualLoop.__init__s& c|jSN)r)rs rtimezVirtualLoop.times xrc|js1|jr*t|j|jdj|_t dS)Nr)_ready _scheduledmaxr_whenr _run_oncers rrzVirtualLoop._run_oncesQ{ ?t ?48T_Q%7%=>>DH r)__name__ __module__ __qualname__rrr __classcell__)rs@rr r s`rr ct} |||S#|wxYwr)r run_until_completeclose)coroloops r virtual_runr("sB ==D&&t,,  s 9ATF)frames competitorsburstproduction_cyclec Ktjggc}tdj|j}|t d||td|tjdd}fd} tdd i|| } | d{Vt j d d d | d hfd} tt| dddt jdd} fd} fd}fd}tj| }| dd|r.receive1s+,,rcK|ddkr5tj|dd{VdSdS)Nr6zwebsocket.sendtext)putjsonloads)messagequeues r asgi_sendzexperiment..asgi_send3sW 6?. . .))DJwv7788 8 8 8 8 8 8 8 8 8 / .rr6 websocketzdiagnostic-devicetestz0.5.1speech_playback) capabilitiesc(KdtdzzzS)Ns)r )_r*s r synthesizezexperiment..synthesize9s+*V344r)rHcdS)Nserverr7rGs rzexperiment..<shrcdS)NTr7rKs rrLzexperiment..<sRVrcdS)NFr7rKs rrLzexperiment..<sbgrcjK d{V}|d|dfr|ddkrdndn}tj|dz d{V)NTr6sequencer3r)getappendrasynciosleep task_done)payloaddelayr,delay_msr'r?receiveds rconsumezexperiment..consume=s !IIKK''''''G OOTYY[['&/7;;z;R;RS T T TEJXW[[4499TTqqPXE- -- - - - - - - - OO     rcKtdD]9}tj|d{Vtjd|id{V:dS)Nr6)rangerUrVgatewaysend_to_device)kindintervalrGdevices rperiodiczexperiment..periodicEsxq A AA-)) ) ) ) ) ) ) )(&$@@ @ @ @ @ @ @ @ @ A ArcKtdD]V}tjddid{Vtjddid{Vtjdd{VWdS)Nr6server_snapshot agent_staterF)r_r`rarUrV)rGrds rsystem_monitor_cyclez(experiment..system_monitor_cycleIsq # #A(&:K1LMM M M M M M M M(&-1HII I I I I I I I-"" " " " " " " " " # #rscreenzFixed public test.rhg{Gz?rigQ?return_exceptions)rUget_running_loopr rrTsetattrr` speech_moduleQueueracceptDevicerrra create_taskstartgatherlisttasksjoincancelr%)rZ monkeypatchr*r+r,r-recordstracer8r@wsrHmanagerr\rerjconsumer backgroundrdr'r?r[s` ` ` @@@@r experimentr*s  # % %DBGX DIGN C C CE777 ~u=== M! $ $ $E---99999 FK('9 = =B ))++ ^/"TeSf g g gF55555OzBBBD$..0FXgXgiiGAAAAA##### "7799--H MM&($8999IT]7&xx0A3'G'GHH&xx s'C'CDDFFZ\G'-.B.B.D.DEEFFF . ;$w}-- ; ; ; ;;;;;;;; **,, OO .T : : :::::::: --// H rrY)rdi,rRrQc tt||\}}d|D}d|D}d|D}d}t|}t|} || k} | s"t jd| fd|| ft j|dtjvst j trt jtnddtjvst j trt jtndt j|t j|t j| d z} d d | iz} tt j | dx}x} x}x}} d |D} t| }|sd dtjvst j trt jtndt j| t j|dz}tt j |dx} }d|D}d}t|}t|} || k} | s"t jd| fd|| ft j|dtjvst j trt jtnddtjvst j trt jtndt j|t j|t j| d z} d d | iz} tt j | dx}x} x}x}} d|D} t| }d}||k}|st jd|fd||fdtjvst j trt jtndt j| t j|t j|dz}dd|iz}tt j |dx} x}x}}dt||ddD} t| }|sd dtjvst j trt jtndt j| t j|dz}tt j |dx} }|dkrd|D} t| }d}||k}|st jd|fd||fdtjvst j trt jtndt j| t j|t j|dz}dd|iz}tt j |dx} x}x}}|dkrd|D} t| }d}||k}|st jd|fd||fdtjvst j trt jtndt j| t j|t j|dz}dd|iz}tt j |dx} x}x}}d |D} t| }d}||k}|st jd|fd||fdtjvst j trt jtndt j| t j|t j|dz}dd|iz}tt j |dx} x}x}}d!|D}g} t!|}d}||k}|}|r|dd"}|}|sVt jd|fd#||fd$tjvst j t rt jt nd$d%tjvst j |rt j|nd%t j|t j|d&z}d'd(|iz} | | |r.d)d*t j|iz}| |t j| diz}d+d,|iz}tt j |dx}x} x}x}x}}dS)-Nc*g|]}|ddk|S)eventsendr7.0rs r zDtest_continuous_speech_with_constrained_receiver..`s& 8 8 811W:#7#7Q#7#7#7rc*g|]}|ddk|S message_type speech_chunkr7rs rrzDtest_continuous_speech_with_constrained_receiver..as' F F FA!N"3~"E"Ea"E"E"Ercg|] }|d S)rPr7rs rrzDtest_continuous_speech_with_constrained_receiver..bs * * *aAjM * * *rr)==)zP%(py1)s == %(py10)s {%(py10)s = %(py3)s(%(py8)s {%(py8)s = %(py4)s(%(py6)s) }) }rwr_)py1py3py4py6py8py10zassert %(py12)spy12c3*K|]}|dduVdS)errorNr7rs r zCtest_continuous_speech_with_constrained_receiver..cs+11aqzT!111111r,assert %(py4)s {%(py4)s = %(py0)s(%(py2)s) }allpy0py2rc&g|]\}}}|dk |S)rr7)rrGtss rrzDtest_continuous_speech_with_constrained_receiver..ds( = = ='!Qn)<).e-99WQ1qL 999999rr3z0%(py4)s {%(py4)s = %(py0)s(%(py2)s) } == %(py7)ssumrrrpy7assert %(py9)spy9c3FK|]\}}|d|dz dkVdSsend_attempt_mssend_complete_msgZd;C@Nr7rabs rrzCtest_continuous_speech_with_constrained_receiver..fsP441a"#a(:&;;vE444444rrc3&K|] }|dV dSdevice_lock_wait_msNr7rs rrzCtest_continuous_speech_with_constrained_receiver..is(;;1*+;;;;;;rrrRc3&K|] }|dV dSrr7rs rrzCtest_continuous_speech_with_constrained_receiver..ks(<<1*+<<<<<z/%(py4)s {%(py4)s = %(py0)s(%(py2)s) } > %(py7)sc3>K|]}|ddk|dVdS)rrhrNr7rs rrzCtest_continuous_speech_with_constrained_receiver..ls8eea>OSd>d>d1*+>d>d>d>deerc*g|]}|ddk|S)rsummaryr7rs rrzDtest_continuous_speech_with_constrained_receiver..ns&???qqzY'>'>'>'>'>rspeech_end_sent)z0%(py5)s {%(py5)s = %(py2)s(%(py3)s) } == %(py8)slen summaries)rrpy5rz%(py10)srz%(py13)spy13zassert %(py16)spy16)r(rr_rw @pytest_ar_call_reprcompare _saferepr @py_builtinslocals_should_repr_global_nameAssertionError_format_explanationrrziprrrT_format_boolop)rYr{r|r[sendschunks @py_assert0 @py_assert5 @py_assert7 @py_assert9 @py_assert2 @py_format11 @py_format13 @py_assert1 @py_assert3 @py_format5 @py_assert6 @py_format8 @py_format10r @py_assert4 @py_assert12 @py_format9 @py_format14 @py_format15 @py_format17s r0test_continuous_speech_with_constrained_receiverr]s2 #Juk$B$BCCGX 8 8 8 8 8E F F F F FF * *6 * * *==599=d9oo= *o ========== *o===== *===========d=====d=============5=====5==========9====o===============================115111131 1 11 111111111111311111311111111111 11111111111111111111 = =X = = =PBPeBiiPiP = PPPPPPPPPP =PPPPP =PPPPPPPPPPPPPPPPPPPPPPPPPPPPPePPPPPePPPPPPBPPPPiPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPP99999>39 9 9>Q> 9Q >>>>>>>>>> 9Q>>>>>>>>>>>>3>>>>>3>>>>>>9>>>> 9>>>>Q>>>>>>>>>>>>>>>>>>>>>>>>>>>>>44vvabbz22444434 4 44 44444-3444443 4444*3 44444*34444*3 444444444 34444444444 zz;;U;;;@s;;;@q@;q@@@@@@@@@@;q@@@@@@@@@@@@s@@@@@s@@@@@@;@@@@;@@@@q@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ }}<>BQB>Q BBBBB9Q<0A#BB#BBBBBBBBBB>QBBBBBBBBBBBB3BBBBB3BBBBBBBBBBBBByBBBBByBBBBBB>BBBBQBBBBBBBBBBBBBBBBBBBBBBBBB#BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBrcttd|dd\}}d|D}d|D}t|}d}||k}|stjd|fd ||fd t jvstjtrtjtnd tj|tj|tj|d z}d d |iz} ttj | dx}x}x}}|dd} d}| |k} | sltjd| fd| |ftj| tj|dz} dd| iz} ttj | dx} x} }dt||ddD}t|}|sddt jvstjtrtjtndtj|tj|dz} ttj | dx}}dS)NrFT)r+r,cDg|]}|ddk|SrrSrs rrz@test_two_second_stall_drifts_without_catchup..t. L L LAAEE.$9$9^$K$Ka$K$K$Krc3&K|] }|dV dSwebsocket_send_msNr7rs rrz?test_two_second_stall_drifts_without_catchup..us(66!q$%666666rirrrrrrdrift_from_nominal_ms)z%(py1)s > %(py4)srrassert %(py6)src3FK|]\}}|d|dz dkVdSrr7rs rrz?test_two_second_stall_drifts_without_catchup..ws<hh1q"#A&8$99VChhhhhhrr3rrr) r(rrrrrrrrrrrr)r{r|rGrrrrrrrrrr @py_format7s r,test_two_second_stall_drifts_without_catchuprrsZ;EQUVVVWWJGQ L L L L LF66v666=36 6 6== 6 ========== 6============3=====3======6==== 6================================= ":- .55 . 5555555555 .55555 .5555555555555555555555555555555hhPSTZ\bcdcece\fPgPghhhh3h h hh hhhhhhhhhhhh3hhhhh3hhhhhhhhhhh hhhhhhhhhhhhhhhhhhhhhhrc:d}t|dS)Nc^ Ktj}gtd|jj}d}t jdddt|}||dd d dd d d d}tj t5| ||d dd{Vdddn #1swxYwYdd}d}||k}|sltjd|fd||ftj|tj|dz}dd|iz} t!tj| dx}x}}|j} | j}|} | } | sddt)jvstj|rtj|ndtj| tj|tj| dz} t!tj| dx} x}x} } |jd{Vtj| ||}tjdd{V|tj|dd{Vdd}d}||k}|sltjd|fd||ftj|tj|dz}dd|iz} t!tj| dx}x}}dd}d}||u}|sltjd|fd ||ftj|tj|dz}dd|iz} t!tj| dx}x}}dd!}d"}||k}|sltjd|fd||ftj|tj|dz}dd|iz} t!tj| dx}x}}|j||dfd#d$D} t=| }|sd%d&t)jvstjt<rtjt<nd&tj| tj|d'z}t!tj|dx} }dS)(NTr/c>Ktjdd{VdS)N rUrVrKs rblockedz\test_timeout_and_cancel_release_lock_without_leaking_payload..check..blockeds.-## # # # # # # # # #rdrv send_jsonrrkrr PRIVATE_PCMSECRET)r6 speech_idrPaudiotokenrF)scheduled_elapsed_ms raw_pcm_bytesrri rz%(py1)s == %(py4)srrrdassert not %(py6)s {%(py6)s = %(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.send_lock }.locked }() }rrrrrlriis)z%(py1)s is %(py4)srCancelledErrorc3DK|]}|tjvVdSr)r<dumps)rxr|s rrz^test_timeout_and_cancel_release_lock_without_leaking_payload..check..s2eeA1DJw///eeeeeer)rrrrrrr)rUrnr rrTr`rsrbeginpytestraises TimeoutErrorrrrrrr send_locklockedrrracquirertrVrzrvreleasefinishr)r'r}rrrXrrrrrrrrrtaskr|s @rcheckzKtest_timeout_and_cancel_release_lock_without_leaking_payload..check{sD'))D GGG $ $ $ N3S/G*L*L*L M M AsH%%%)Ubmuvv ]< ( ( R R**Qaq*QQ Q Q Q Q Q Q Q R R R R R R R R R R R R R R Rr{./747/47777777777/477777/77774777777777777777777777777777;';%'%%''''''''''''''''''1'''''1'''''';''''%''''''''''''''''''''''''''''k!!#########"5::a#9#9::mA nTT::::::::::r{019T91T99999999991T9999919999T999999999999999999999999999r{./747/47777777777/477777/77774777777777777777777777777777r{7#7'77#'77777777777#'777777#7777'7777777777777777777777777777  Qeeee9deeeeseeeeeeeeeeeeeeeeseeeeeseeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeees CCCr()rs r.check..fasts rrrrrrrkrr)r6rrPr)r r)z0%(py3)s {%(py3)s = %(py0)s(%(py1)s) } == %(py6)srr|)rrrrzassert %(py8)sr)zM%(py5)s {%(py5)s = %(py0)s(%(py3)s {%(py3)s = %(py1)s.records }) } == %(py8)scaplog)rrrrrzassert %(py10)srr3wire_payload_bytesz4{"type":"speech_chunk","speech_id":"s","sequence":0})z0%(py1)s == %(py7)s {%(py7)s = %(py3)s(%(py5)s) })rrrrrr)r rUrnrrTr`rsrrr_rrrrrrrrrrr|)r|r}r"rirrrrrrrrrrrr%s rrz,test_default_off_and_sampling..checks(D(@(B(B(Ggn]]] N3S/D*I*I*I J J AsH%%%r s sA**QcWX Y Ypq*rr r r r r r r r r7||!r!|r!!!!!!!!!!|r!!!!!!!!!!!!s!!!!!s!!!!!!!!!!!!!7!!!!!7!!!!!!|!!!!r!!!!!!!!!!!!!!!!!!!!!!!!!!!>'s>""'a'"a''''''''''"a''''''''''''s'''''s'''''''''''''6'''''6''''''>''''"''''a'''''''''''''''''''''''''''''qz./n7mn37m3n3nn/3nnnnnnnnnnn/3nnnnnn/nnnnnnnnnnn3nnnnn3nnnnnn7mnnnn3nnnnnnnnnnnnnnnnnnnnnnnnnnnnnnnnrINFO) delenvr from_envenabledrrrrrrrat_levelr()r{r%rrrrrrs ` rtest_default_off_and_samplingr-s-u===#-##%%-%--- -- ------------{-----{------#----%---------------------------- o o o o o  EEGGsD**D.1D.__main__z4one-slot ASGI queue; periodic snapshot + agent_state)modelr}r8rQr+r-z2one-slot ASGI queue; snapshot -> agent -> sleep 2sproduction_cycle_2000r3rF)indent c@fd}t|dS)Nc Ktj}ggc}td|j|j}t d|d}fd}t jdddt|| }t d |j |i| |d d t j d did{Vg}|j }| }|} |r|j } d} | | u} | } | r ddig} | k}|} | sddtjvst!j|rt!j|ndt!j|dz}|||r+t!jd| fd| | fdtjvst!j|rt!j|ndt!j| t!j| dz}dd|iz}||| rt!jd|fd| fdtjvst!jrt!jndt!j| dz}dd|iz}||t!j|diz}d d!|iz}t+t!j|dx} x}x}x}x} x} x} x}} |d"d#} d$}| |k}|slt!jd|fd%| |ft!j| t!j|d&z}d'd(|iz}t+t!j|dx} x}}|j}|j}|}| }|sd)dtjvst!j|rt!j|ndt!j|t!j|t!j|d*z}t+t!j|dx}x}x}}dS)+NTr/r2c>Ktjdd{VdS)NrgrrKs rrzCtest_snapshot_timeout_closes_device..check..blockeds.-"" " " " " " " " " "rc6K|dSrrT)kwargsclosess rr%zAtest_snapshot_timeout_closes_device..check..closes MM& ! ! ! ! !rz isolated-testrr)rr%devices syntheticrkr6rhcodeiz'not %(py4)s {%(py4)s = %(py2)s.online }r)rrr )z2%(py9)s {%(py9)s = %(py7)s.websocket } is %(py12)s)rrrz%(py14)spy14r)z%(py16)s == %(py19)sr:)rpy19z%(py21)spy21rzassert %(py24)spy24rrrrrrrrr)rUrnr rrTror`rsr device_idrbroadcast_server_snapshotonlinerArrrrrrrrrrr)r'r|r}rr%rrrrr @py_assert8 @py_assert11 @py_assert10 @py_assert18 @py_assert17 @py_format6rr @py_format20 @py_format22 @py_format23 @py_format25rrrrrr:r{s @rrz2test_snapshot_timeout_closes_device..checks '))bD GGGG^U;;; # # # " " " " " N?CoPW_d6e6e6e f fGYa0@AAA A{H---/9J0KLLLLLLLLLRR18R8|R|R|R RtR t 3RRRRRFD>BRRBR8RRRRRRRRRRRRRRRR1RRRRR1RRRRRR8RRRRRRRRRRRRR|RRRRRRR tRRRRRRRRRRRRRRRRRRRRRRR RRRRtRRRRRRRRRRRRRRRRRRRRRRRRRRRBRRRRRRRRRRRRRRRRRRRRRRRRBRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRr{7#5~5#~5555555555#~55555#5555~555555555555555555555555555;';%'%%''''''''''''''''''1'''''1'''''';''''%''''''''''''''''''''''''''''''rrr{rs` r#test_snapshot_timeout_closes_devicerPs8((((( rcttd|dd\}}d|D}d|D}d|D}t|}d}||k}|stjd |fd ||fd t jvstjtrtjtnd tj|tj|tj|d z} d d| iz} ttj | dx}x}x}}d|D}t|}d}||k}|stjd|fd||fd t jvstjtrtjtnd tj|tj|tj|d z} d d| iz} ttj | dx}x}x}}d|D} d| D}t|}d}||k}|stjd|fd||fd t jvstjtrtjtnd tj|tj|tj|d z} d d| iz} ttj | dx}x}x}}d|D}t|}|sddt jvstjtrtjtndtj|tj|dz} ttj | dx}}dS)NrQFTr0cDg|]}|ddk|Srrrs rrzGtest_actual_sequential_system_monitor_also_contends..rrcDg|]}|ddk|S)rrhrrs rrzGtest_actual_sequential_system_monitor_also_contends..s/RRRqquu^'<'<@Q'Q'Q'Q'Q'Qrc3&K|] }|dV dSrr7rs rrzFtest_actual_sequential_system_monitor_also_contends..(88Aq&'888888rrRrrrrrrc3&K|] }|dV dSrr7rs rrzFtest_actual_sequential_system_monitor_also_contends..s(99!q$%999999rrrcDg|]}|ddk|S)rrirrs rrzGtest_actual_sequential_system_monitor_also_contends..s. K K KAAEE.$9$9]$J$Ja$J$J$Jrc3&K|] }|dV dSrr7rs rrzFtest_actual_sequential_system_monitor_also_contends..rUrc3*K|]\}}}|dkVdSrr7rs rrzFtest_actual_sequential_system_monitor_also_contends..rrranyr) r(rrrrrrrrrrrZ) r{r|r[r snapshotsrrrrrragentsrs r3test_actual_sequential_system_monitor_also_contendsr]sH#Jt[efj$k$k$kllGX L L L L LFRRGRRRI88888?38 8 8?4? 84 ?????????? 84????????????3?????3??????8???? 8????4?????????????????????????????99y999A39 9 9ATA 9T AAAAAAAAAA 9TAAAAAAAAAAAA3AAAAA3AAAAAA9AAAA 9AAAATAAAAAAAAAAAAAAAAAAAAAAAAAAAAA K K K K KF88888@38 8 8@D@ 8D @@@@@@@@@@ 8D@@@@@@@@@@@@3@@@@@3@@@@@@8@@@@ 8@@@@D@@@@@@@@@@@@@@@@@@@@@@@@@@@@@99999939 9 99 999999999999399999399999999999 9999999999999999999999rc@fd}t|dS)NcKgfd}tjdddt|}tdd}||d d d }d |d dd}|||d{Vg}d}||u}|}|r |j} | } | }|s9tj d|fd||ftj |dtj vstj |rtj |nddz} dd| iz} || |rlddtj vstj |rtj |ndtj | dz} || tj|diz}dd|iz}t!tj|dx}x}x}x}x} } dS)Nc6K|dSrr8)rXobserveds rrzMtest_disabled_trace_does_not_serialize_or_mutate..check..sends!9!9!9!9!9rrrrrFc*tjdS)Nzdisabled trace emittedrfailrKs rrLzQtest_disabled_trace_does_not_serialize_or_mutate..check..s&+>V2W2Wr)r1rrkc.tjddS)Nzdisabled trace serializedrc)rG__s r forbiddenzRtest_disabled_trace_does_not_serialize_or_mutate..check..forbiddens-H!I!I!I!I!Irz&device_gateway.speech_trace.json.dumpsr unchanged)r6rrr )z%(py3)s is %(py5)srX)rrz%(py7)srz*not %(py11)s {%(py11)s = %(py9)s.streams }r})rpy11zassert %(py15)spy15)r`rsrr rrorstreamsrrrrrrrTrrr)rrr}rgrXrrrrrGrrJrrr @py_format16rar{s @rrz?test_disabled_trace_does_not_serialize_or_mutate..checksy99999 N3S/D*I*I*I J JE(W(WXXX AsH%%%IIIDiPPP)K@@jjG$$$$$$$$$;;x{;{g%;;;;;em;m*;;*;;;;;;;;;;{g;;;;;{;;;;;;;;;;;g;;;;;g;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;e;;;;;e;;;;;;m;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;rrrOs` r0test_disabled_trace_does_not_serialize_or_mutaterms8 < < < < <r)4__doc__builtinsr_pytest.assertion.rewrite assertionrewriterrUr<pathlibrtypesrrstarlette.websocketsrdevice_gatewayrr`rrpdevice_gateway.speechrr device_gateway.speech_tracer SelectorEventLoopr r(rmark parametrizerrrr-rsysresultsrY MonkeyPatchcontextpatchr|r[strargv write_textrrPr]rmr7rrrs !!!!!! ******))))))222222<<<<<<<<333333     '+    79dRWjo00000f";";";<<CC=<C(iii8$ zJJJG*FF   ' ' ) ) FU + JJue,D,D E E GX F F F F F F F F F F F F F F F(^(/HFFE    # # % %k'K 4Edh(i(i(ijjkkkkkkkkkkkkkkk1e07H(N(NG #$D!  GA!>!>!>!EFFF(:::     s$?C$$C( +C( EE E