jk8XdZddlZddlZddlZddlZddlmZmZmZm Z m Z m Z ddl m Z mZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd l m!Z!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-ej\e/Z0eddgZ1ejde3jijjjjdz dz Z6ejde3jijjjjdz dz Z7ejde3jijjjjdz dz Z8GddeZ9GddeZ:de;de;de;ddfd Ze?d@ZLe1jdAe?dBZMe1j}dCdDe:fdEZNe1jdFdGZOe1j}dHed#eded$ed#fde;dIe;dJe?dKe fdLZPe1jdMdNe;de;fdOZQe1jdPdNe;de;fdQZRe1jdPdNe;de;fdRZSy)Wz:The merchant-facing surface for the product pairing graph.N) APIRouterFileForm HTTPExceptionResponse UploadFile) FileResponse HTMLResponse) BaseModel)OperationalError build_catalog) import_csv)CsvFormatError)jobs)QuotaExceededError pair_tenant)delete_all_productsdelete_product)disconnect_all_sources)record) get_product list_anchorslist_categories list_pairings list_products pairings_forz/catalogcatalog)prefixtagsstaticzcatalog_admin.htmlsample_products.csvz chat_ui.htmlcDeZdZUeed<eed<eed<eed<dZeed<y) DecisionIn anchor_key neighbor_key pair_typedecisionN decided_by)__name__ __module__ __qualname__str__annotations__r*./var/www/html/strategist-ai/app/api/catalog.pyr%r%%s!ONMJr1r%c(eZdZUeed<eeed<y)DecideIn tenant_id decisionsN)r+r,r-r.r/listr%r0r1r2r4r4-sNJr1r4job_idr5kindreturnc<Kfd tjjfdd{}tj|d{y7$7#t $rV}t jd||jtj|jd{7Yd}~yd}~wt$rV}t jd|d tjt|jd{7Yd}~yd}~wwxYww) zFRuns a blocking job off the event loop, reporting progress as it goes.c4tj||yN)rtick)percentstepr8s r2progressz_run..progress4s &'4(r1cS)N)rAr0)fnrAr5sr2z_run..=sBy84r1N)resultz"%s job stopped by quota for %s: %serrorz%s job failed for %sTexc_info) anyio to_threadrun_syncrfinishrloggerinfomessage ExceptionrGtyper+)r8r5r9rCrEexrAs`` ` @r2_runrT2s) ;// 466kk&00060 4  8$ 2::Vkk& 333 ; +T9t Lkk&R(9(9:::;s|D'AAAAADAA D&AB7,B/-B72D7 DAD D  DDDDc K tj||d{} tjt|||||S7(#tj$rt$rB}tj d||dt dddt|jd d}~wwxYw#t$r;tj d ||dtj|d d{7wxYww) aTakes the lock and schedules the work, or releases the lock trying. The window between create() and create_task() is small but real: an exception in it once left a tenant locked out of enrichment with no job running and nothing to release it until the TTL expired. Nz,Job store unavailable starting %s job for %sTrHjob_store_unavailablez5Could not reach the job store. Try again in a moment.rGrPcause status_codedetailz Could not schedule %s job for %sSchedulingFailedrF)rcreateJobAlreadyRunning DbUnavailablerNrGrrRr+asyncio create_taskrTrQrM)r5r9rCr8rSs r2 start_jobrcJs){{9d33DD"=> M-4  ! !  )  CT9"  $,N"X&&5() ) )  7y"  $kk&(:;;; sUC0AAA!B)C0AB&$=B!!B&&C0).runssVheDDr1cSr=r0)rjr5sr2rDz build_endpoint..xs #i.r1rZzBuild failed for %sTrHbuildalready_runningrGr8queuedr8statusr=)rJrKrLrrrPrQrNrGrRr+rcrr_r8r[)r5rdrerfrSr8runningrjs`` @r2build_endpointrwksE  K112HII IC GS99 H 11J! DC C C K LL. DL ICR8I8IJ J K :  ! !C&'..5BC CCsx D&AAADC C  C  DA C'A>> C 8CCD C C>C99C>>Dz/paircK|r+ tjjfdd{S tdtd{}d |_|d d S7*#t$r=}tj ddt dt|jd}~wwxYw7[#tj$r}t dd |jd d}~wwxYww)NctSr=rr5sr2rDzpair_endpoint..s +i:Pr1zPairing failed for %sTrHrmrZpairrorprqrrrsrt)rJrKrLrQrNrGrrRr+rcrrr_r8r[)r5rerfrSr8rvs` r2 pair_endpointr|s  K112PQQ Q C FK@@ H 11R K LL0)dL KCR8I8IJ J K A  ! !C&'..5BC CCslC%AAACB$B"B$ CA B"8BBC"B$$C7CCCz/jobs/{job_id}c K tj|d{}| t d d |S7#t$rA}tj d|dt dddt |jdd}~wwxYww) Nz$Job store unavailable reading job %sTrHrVrWz,Could not reach the job store. Keep polling.rXrZz Job not found)rgetr`rNrGrrRr+)r8staterSs r2job_status_endpointrs )hhv&& }ODD L' )  ;Vd S,E"X&&5() ) )s0B424B4 A>>Bz/jobslimitcJKtj||d{S7wr=)rrecent)r5rs r2recent_jobs_endpointrsY. .. .s #!#z /categoriescdKtjjfdd{S7w)NctSr=)rrzsr2rDz%categories_endpoint..s /)2Lr1rJrKrLrzs`r2categories_endpointrs#))*LM MM Ms &0.0z /productscategoryoffsetcpKtjjfdd{S7w)Nc"tS)N)rrr)r)rrrr5sr2rDz#products_endpoint..s i(%PVWr1r)r5rrrs````r2products_endpointrs1))WY YY Ys )646chKfd}tjj|d{S7w)aZWipes every product, pairing, and embedding for a tenant, and disconnects every source it had connected -- a source left connected would just get silently re-crawled on the next build, repopulating exactly what this just deleted. Reconnecting a source (POST /sources/website, etc.) is what makes the next build add anything again.c:t}t|d<|S)Nsources_disconnected)rr)countsr5s r2_wipez+delete_all_products_endpoint.._wipes"$Y/)? )J%& r1Nr)r5rs` r2delete_all_products_endpointrs)))%0 00 0s (202z/pairings/anchorsruscorecK tjjfdd{S7#t$r}t dt |d}~wwxYww)a"Products with matches, and how many of each state they hold. Backs a review screen that shows one product at a time -- a merchant thinks in products, so a flat list of every pair across the catalogue is not something they can work through. status pending | approved | rejected | auto | all score high | medium | low category a product category to narrow to Every anchor carries the full breakdown regardless of the filter, so a screen can show "4 pending, 2 approved" without asking again per product. c$tS)N)rrurr)r)rrrrur5sr2rDz"anchors_endpoint..sL%*2%Ar1NrZrJrKrL ValueErrorrr.)r5rurrrrSs````` r2anchors_endpointrsY"=__-- ABB BB =CG<<=s1A )979A 9 AAAA z /pairingsr&cK tjjfdd{S7#t$r}t dt |d}~wwxYww)zThe matches themselves, filtered the same way as the anchor list. Pass anchor_key for one product's review screen; leave it off for the whole catalogue. c&tS)N)rr&rurr)r)r&rrrrur5sr2rDz#pairings_endpoint..sM)5Z)/(%Qr1NrrZr)r5r&rurrrrSs`````` r2pairings_endpointrs_=__-- Q QRR RR =CG<<=s1A"*;9;A"; AAAA"z/admin)response_classcK ttjS#t$r*tj dtdt ddwxYww)Nz#Could not read the admin page at %sTrHzadmin page unavailablerZ)r ADMIN_PAGE read_textOSErrorrNrGrr0r1r2 admin_pagersWNJ00233 N :J"  $4LMMNA!A3AAz/democK ttjS#t$r*tj dtdt ddwxYww)Nz"Could not read the demo page at %sTrHrzdemo page unavailablerZ)r DEMO_PAGErrrNrGrr0r1r2 demo_pager sWMI//122 M 99"  $4KLLMrz/pairings/decidepayloadcKjDcgc]}|jc} tjj fdd{}d|iScc}w7 #t $r}t dt|d}~wwxYww)Nc0tjSr=)rr5)r6rsr2rDz!decide_endpoint..sF7,,i8r1rrZrecorded)r6 model_dumprJrKrLrrr.)rdrrSr6s` @r2decide_endpointrs{)0):):;A;I=11 8::  !! <: =CG<<=sDB AB &A$A"A$ B "A$$ B-BBB z /sample.csvc.KttddSw)Nztext/csvr#) media_typefilename)r SAMPLE_CSVr0r1r2sample_csv_endpointr$s  z!6 88sz /import/csvcurrencydry_runfilecKjd{}|jdd tjj fdd{S7F7#t $r}t dt|d}~wt$r}t d|jd}~wt$r=}tjdd t d t|jd}~wwxYww) Nzutf-8replace)errorsc8tjS)N)r)rr)rrrr5textsr2rDz%import_csv_endpoint..3sJy$ xQXYr1rrZrlzCSV import failed for %sTrHrm)readdecoderJrKrLrrr.rrPrQrNrGrRr+)r5rrrbodyrSrs```` @r2import_csv_endpointr+s D ;;wy; 1D G__-- Y[[ [ [ =CG<< @BJJ?? G /T JDH4E4EFFGs\C4A"C4)A&A$A&!C4$A&& C1/B C1B(( C148C,,C11C4z%/products/{product_key:path}/pairings product_keychKtjjfdd{S7w)NctSr=)rrr5sr2rDz+product_pairings_endpoint..Ds,y+2Vr1rrs``r2product_pairings_endpointrBs#))*VW WW Ws '202z/products/{product_key:path}cKtjjfdd{}| tdd|S7w)NctSr=)rrsr2rDz"product_endpoint..Is[K5Xr1r~Product not foundrZrJrKrLr)rr5products`` r2product_endpointrGs=OO,,-XYYG4GHH NZs'AAAcKtjjfdd{}|s tddddS7w)NctSr=)rrsr2rDz)delete_product_endpoint..Qs^I{5[r1r~rrZdeleted)rrur)rr5removeds`` r2delete_product_endpointrOsAOO,,-[\\G 4GHH&) <<]s'AAA))N2r)pendingNNr)NrNNd)T__doc__raloggingpathlibrJfastapirrrrrrfastapi.responsesr r pydanticr psycopg2r r`app.services.catalog.buildrapp.services.catalog.csv_importrapp.services.catalog.csv_sourcerapp.services.infrarapp.services.infra.quotasrapp.services.pairing.jobrapp.services.catalog.productsrrapp.services.catalog.sourcesrapp.services.pairing.decisionsrapp.services.pairing.queriesrrrrrr getLoggerr+rNrouterPath__file__resolveparentrrrr%r4r.rTrcpostboolrwr|rrintrrrdeleterrrrrrrrrrrr0r1r2rs@ NN8646:#80M?1   8 $ *I; 7W\\( # + + - 4 4 ; ;h FI] ] W\\( # + + - 4 4 ; ;h FI^ ^ GLL " * * , 3 3 : :X E V  y ;s;s;#;d;0s#cBX*.s)4;&*5k2C2D2#2=E22:W)-ce-1232$2"*22, c&G/#/c//MNNNKOQ+,YsYcYY%(YY { 1# 1 1  9B>B(*=c=3=%(=8;="%=!=2K>BEI