*kiS`ddlZddlZddlZddlZddlmZej jdeee jjdddl m Z mZmZmZmZmZmZmZmZmZmZmZmZddlmZdededdfd Zdefd Zd d Ze d k(rejBeyy)N)Path) PlannedToolCallSearchProductsArgs_derive_home_thread_state_extract_catalog_query _build_surface_direct_tool_calls_execute_tool_call$_home_requires_hard_direct_execution"_normalize_home_planned_tool_calls_normalize_sql_readonly_query_normalize_text_search_products_should_prefer_planner_for_home_timeclock_period_from_message)get_tenant_store conditiondetailreturnc|s t|y)N)AssertionError)rrs 7apps/backend-hub/scripts/check_assistant_regressions.py_assertrs V$$ cZtjddj}|r|Sttjdd}t j |5}|j ddj}ddd tdt|dS#1swY$xYw) NASSISTANT_REGRESSION_TENANT_IDTENANCY_REGISTRY_DATABASEz/data/platform_registry.sqlite3z%SELECT id FROM tenants WHERE slug = ?)ritualzDTenant 'ritual' non trovato. Imposta ASSISTANT_REGRESSION_TENANT_ID.r) osgetenvstriprsqlite3connectexecutefetchone RuntimeErrorstr) configured registry_path connectionrows r_resolve_regression_tenant_idr- s;R@FFHJ#>@abcM  'b:  !H+V__ab {abb s1v; bbs !B!!B*c Kt}|jt}| tdd}t |}t d|gi}t |xr|djdk(d|dt t||gg|d d }t t|d k(d d }t t|d k(dt d|gi}t |xr|djdk(dt d|gi}t |xr|djdk(dt d t|djjdxsdjvxr;dt|djjdxsdjvd|djtddddg} t|| } t | djjddk(dt!d} t d| vdt#|t%dd } | jd!gD cgc] } t| jd"xsd"}} t |d#gk(d$|d%}t d|gi}t |xr|djd&k(d'||dj}t |jd(d)k(xr*|jd*d+k(xr|jd,d-k(d.|t|td/d-d+d0g}t |xrX|djd&k(xrD|djjd(d)k(xr!|djjd*d+k(d1|t'||dg2d{}|jd3ijd4g}t t)|d+k(d5t)|d6}t d|gd7d&d&d8}t |xr|djd&k(xr|djjddk(xrg|djjd(d)k(xrD|djjd*d9k(xr!|djjd,d-k(d:|t|td/d;d-d+d<g}t |xr{|djd&k(xrg|djjddk(xrD|djjd(d)k(xr!|djjd*d9k(d=|d>}t d|gi}t |xr{|djd&k(xrg|djjdd?k(xrD|djjd(d)k(xr!|djjd*d+k(d@|t|td/d?d-d+d<g}t |xr{|djd&k(xrg|djjdd?k(xrD|djjd(d)k(xr!|djjd*d+k(dA|dB}t d|gi}t t+|t ||dCdD}t d|gi}t |xr|djdEk(dFt t|t |gg| dGdH}t d|gi} t | xrt| djdEk(xr`| djjdIxr@| djjdJxr | djjd*dudK| t|tdEdLdMdNddOg}!t |!xr|!djdEk(xr|!djjdPdQk(xr`|!djjdIxr@|!djjdJxr |!djjd*dudR|!dSD]^}"t |"}#t-|"|#\}$}%}&}'t t/|%xst/|&xr t/|'xs|$dTk(dU|"dV|$|%|&|'f`dW}(t d|(gi})t |)xr|)djdEk(dX|)dj}*t |*jdPdQk(xr*|*jdIdYk(xr|*jdJdZk(d[|*t1i||dEd\d]d^d_d`daidbgdcgd}+t ddedf|dgdhdidgg|+},t |,xr|,djdEk(dj|,|,dj}-t |-jdk|k(dlt |-jdIdYk(xr|-jdJdZk(dm|-t ddedfd dgdhdndgdf|dgdhdidgdfdedgdhdodggdpdqdqd8}.t |.xr|.djdEk(drt |.djjdk|k(ds|.djt ddtdf|(dgdhdudgdfdvdgdhdidggdE|(dwdxdy}/t |/xr|/djdzk(d{|/t tdtt dtgg|/ d|t1dE|(d}dt|/gdcgd}0t |0jd~dzk(d|0t dddf|(dgdhdudgdfdtdgdhddgg|0}1t |1xr|1djdzk(d|1t dddf|(dgdhdudgdfdtdgdhdidggdE|(dwd}2t |2xr|2djdzk(d|2t dddf|dgdhdidgdfddgdhddggddqdqd8}3t t3d|3D d|3t'||dg2d{}4|4jd3ijdg}5|5D6cgc]1}6t5|6t6st|6jdxsd3}7}6t |7d#gk(d|7t'||dg2d{}8|8jd3ijdg}9|9D6cgc]1}6t5|6t6st|6jdxsd3}:}6t |:d#gk(d|:t9dycc} w7 7cc}6w7cc}6ww)NzBSessione di servizio non disponibile per il tenant di regressione.z4Trovi rum Gosling nel catalogo dei nostri fornitori?homerrun_tenant_queryz7I cataloghi fornitori devono usare il query layer, non .)contextual_tool_callsdirect_tool_callsz4Le letture catalogo devono preferire il planner LLM.z*Trovi del gosling nei cataloghi fornitori?goslingz;La query catalogo non deve includere la preposizione 'nei'.z0Trovi Gosling nel catalogo di qualche fornitore?z[La query catalogo non deve diventare 'qualche' quando l'utente dice 'di qualche fornitore'.zJLa richiesta 'cataloghi fornitori' non deve finire nello storico acquisti.zbLa richiesta 'catalogo di qualche fornitore' deve interrogare i cataloghi, non rispondere a vuoto.sqlrqualchez6La SQL cataloghi deve cercare Gosling, non 'qualche': search_productsrum )querylimit)tool argumentsr:z rum goslingz@Il normalizzatore deve reinserire il termine distintivo Gosling.zPSELECT * FROM supplier_catalog_items WHERE lower(product_name) LIKE '%gosling%';zlower(source_name)z9Le query supplier_catalog_items devono usare source_name.iitems product_namez GOSLING 1Lz!Atteso solo GOSLING 1L, trovati: z!Mostrami il primo ordine del 2025get_purchase_batchesz9'Primo ordine' deve usare get_purchase_batches, trovati: sort_orderearliestr;ryearizF'Primo ordine del 2025' deve essere earliest/limit 1/year 2025, args: get_purchase_history)rCr;zIIl normalizzatore non deve trasformare 'primo ordine' in lista completa: )prior_tool_resultsresultbatcheszA'Primo ordine del 2025' deve restituire un solo ordine, trovati: z#Mostrami il secondo ordine del 2025 timbrature)purchase_query purchase_view last_toolzZ'Secondo ordine del 2025' non deve ereditare query sporche e deve usare earliest/limit 2: secondo)r:rCr;zRIl normalizzatore deve correggere 'secondo ordine' in secondo ordine cronologico: z+mostrami il primo ordine di laconi del 2025laconiz<'Primo ordine di laconi' deve mantenere il filtro prodotto: z-Il normalizzatore non deve perdere 'laconi': zzmain..sii "99iszDUn follow-up acquisti non deve ereditare il vecchio contesto turni: rows display_namez]Il fallback diretto sui cataloghi deve trovare solo GOSLING 1L dal catalogo locale, trovati: zKLa frase 'catalogo di qualche fornitore' deve trovare GOSLING 1L, trovati: zassistant regressions: ok)rbuild_service_sessionr-r'rr rr<rrr(r=getlowerrr r rrr lenr rboolrany isinstancedictprint);storesessioncatalog_messagenormalized_catalog_messagecatalog_direct_callsplural_supplier_catalog_messagesupplier_any_catalog_messageplural_supplier_catalog_callssupplier_any_catalog_callsplanned_searchnormalized_searchnormalized_sql search_resultitem product_namesfirst_order_messagefirst_order_callsfirst_order_argsplanner_first_order_callsfirst_order_resultfirst_order_batchessecond_order_messagesecond_order_callsplanner_second_order_callsfirst_laconi_messagefirst_laconi_callsplanner_first_laconi_callsreservation_messagereservation_direct_callstimeclock_messagetimeclock_direct_callsteam_month_timeclock_messageteam_month_timeclock_callsplanner_team_month_callstemporal_messagenormalized_temporal_messagerUrVrPrQtimeclock_year_messagetimeclock_year_callstimeclock_year_argstimeclock_statetimeclock_followup_callstimeclock_followup_argsdirty_timeclock_followup_calls!reservation_after_timeclock_callsreservation_statereservation_followup_calls dirty_reservation_followup_callsnewer_purchase_followup_calls direct_result direct_rowsr, direct_namessupplier_any_resultsupplier_any_rowssupplier_any_namess; rmainr-s  E))*G*IJG_``LO!0!A;FOUWY[\ S!5a!8!=!=AS!S ABVAWWXY '  & "$2   ? 'S# >?9LE$V  ;< Ie%EVMlnprt$u! %e*G*J*O*OSe*eT"B&Jfhjln!o "_'A!'D'I'IM_'_l S3A6@@DDUKQrRXXZZ c S!;A!>!H!H!L!LU!S!YWYZ``b b @A[\]A^AhAh@ij &+BB9bQ   A% KCPcLdKefA9 ':P_uv    @ q ! & &*@ @ @ q ! + + / / 8B > @ q ! + + / / = K @ q ! + + / / 8A =  @ q ! + + / / 74 ? dewdxy"D 4)]alm@n op" " F &q ) . .2H H F &q ) 3 3 7 7 @B F F 'q ) 3 3 7 7 E S F 'q ) 3 3 7 7 @A E \]w\xy I9&BVXZ\^_  > q ! & &*@ @ > q ! + + / / 8H D > q ! + + / / = K > q ! + + / / 8A = FGYFZ[ "D 4(\`kl@m no" " F &q ) . .2H H F &q ) 3 3 7 7 @H L F 'q ) 3 3 7 7 E S F 'q ) 3 3 7 7 @A E 78R7ST Y?H[]_acd ,  / 0 $ @ 9=fFWY[]_` \#9!#<#A#AE\#\K +  - . "$4    L $S !A&Jfhjln!o " M &q ) . .2I I M &q ) 3 3 7 7 E M 'q ) 3 3 7 7 C M 'q ) 3 3 7 7 @ L ]^x]yz  B$ ,)2WUalpq      K $Q ' , ,0G G K $Q ' 1 1 5 5g >% G K %Q ' 1 1 5 5l C K %Q ' 1 1 5 5j A  K %Q ' 1 1 5 5g >d J hjBiC D   '66F&G#3QRbd4A0{J   [$z"2"EtH~ [%S[J[ABRASSVX]_jlvyAXBWC D   G;FDZ\^`bc X!5a!8!=!=AX!XS/q1;; (E1 @  # #L 1\ A @  # #J /< ? VWjVkl  0!20##- ,$)!3 &   %O( @!(9 : -L M     `%=a%@%E%EI`%` FG_F`a7q9CC ##L15FFQ ##L1\A D # ' ' 3| C EF]E^_ &F!(T U -W X(9 : -L M(A B -a b  );Raxy &" &l+I!+L+Q+QUl+lV &q)3377 EIZZ =>\]^>_>i>i=jk)I((> ? -c d 2 -L M  1$:&%1  )%  )v.OPQ.R.W.W[v.v VWxVyz + , < = "$?    e 20$: 1=  k*.II MN_M`a"B(> ? -c d(H I -V W   " "h'A!'D'I'IMh'h DE_D`a(H(> ? -c d(H I -L M  1$:& ($ (t-Ma-P-U-UYt-t VWwVxy%E(9 : -L M(M N -X Y  '9P_vw %! iKhi ii NOlNmn -W6STU6VkmnnM##Hb155fbAKBMg3Q[\_aeQfC/526gLg & ghtguv!37:%t'Dt,a?t>t/*t>t2 t2<)t>%t7&*t>t9& t9't>/t>2t>9t>__main__)rN)"asyncior r#syspathlibrpathinsertr(__file__resolveparents*app.services.operational_assistant_servicerrrrr r r r r rrrrapp.services.tenant_storerr{rr-r__name__runrrrs  3tH~--/77:;<7%t%S%T% s P'f  zGKKr