4jp#@ddlZddlZddlZddlZddlZddlmZddlmZm Z ddl m Z ddl m Z mZmZedZefdZddZd Zdd ZGd d ZGd dZGddZefdZdZedk(r*eZedde ddej;yy)N)Path)parse_qsurlparse) make_server)AGENTSevaluate_ratings readinessz%/root/workspace/shorts_data/shorts.dbct|}|jjddtj|5}|j ddddy#1swYyxYw)NT)parentsexist_oka CREATE TABLE IF NOT EXISTS settings (key TEXT PRIMARY KEY, value TEXT NOT NULL); CREATE TABLE IF NOT EXISTS candidates ( id INTEGER PRIMARY KEY AUTOINCREMENT, source_url TEXT, title TEXT NOT NULL, clip_path TEXT, status TEXT NOT NULL DEFAULT 'pending', score REAL, ratings_json TEXT NOT NULL DEFAULT '[]', warnings_json TEXT NOT NULL DEFAULT '[]', created_at INTEGER NOT NULL, published_at INTEGER ); INSERT OR IGNORE INTO settings(key,value) VALUES ('threshold','85'); INSERT OR IGNORE INTO settings(key,value) VALUES ('publishing_enabled','0'); INSERT OR IGNORE INTO settings(key,value) VALUES ('source_url',''); )rparentmkdirsqlite3connect executescript)pathdbs #/root/workspace/shorts_dashboard.pyinit_dbrsW :Dt{{(((E    "       s AA"c|Dcgc] }t|}}|sy||dn t|}t|t|z |k\xr>t|t|dz|dz k\xr|dk\xrtd|Ddk\Scc}w)NFZc3&K|] }|dk\ yw)PN).0ss r z"score_candidate.."s0XLM@AEG@GXs)floatsumlensorted)scores threshold safety_scorersafetys rscore_candidater*s & '1eAh 'F ' %'/VBZU<5HF v;V $ 1 ]fVnS[RS^6TXadeXe6e ]jptvjv ]{~XQWX|X\]|]](sBcX|jdDcic]\}}|| c}}Scc}}w)NzSELECT key,value FROM settings)execute)rkvs r _settingsr/$s(::&FG HCAaAaC HH Hs &c tj||nij}|ddddj||dddt t |fg|gS)N200 OKz 201 Createdz 404 Not Found)z Error) Content-Typezapplication/jsonContent-Length)jsondumpsencodegetstrr$)startstatusbodydatas r_jsonr@'s ::d.dB 7 > > @D xMo > B B6fXU[K\ ]aDFVWZ[^_c[dWeEf`gh 6MceZdZdZdZy)Responsec ||_||_yN) status_code_body)selfr=r>s r__init__zResponse.__init__-svd&6$tzrAc@tj|jSrE)r7loadsrGrHs rget_jsonzResponse.get_json.stzz$**55rAN)__name__ __module__ __qualname__rIrMrrArrCrC,sN5rArCceZdZdZdZy) TestClientc||_yrE)app)rHrTs rrIzTestClient.__init__1scTXrAcggdj|jjd|ddfd}tt dj d|S)NrAGET)REQUEST_METHOD PATH_INFO wsgi.inputcHj|j|fSrE)appendextend)rhheadersresults rz TestClient.get..4s>ouo|o|}~oBIBPBPQRBSoTrAr)joinrT_wsgirCintsplit)rHrr>r^r_s @@rr:zTestClient.get2s^27 XXdhhnnu[_%`cTUVF1IOO-a01488rAN)rNrOrPrIr:rrArrRrR0s )9rArRc*eZdZdZdZdZdZdZy)Appc2t||_d|_y)NF)rrtesting)rHrs rrIz App.__init__8sDHDG5dlrAct|SrE)rRrLs r test_clientzApp.test_client9s *T"22rAc |jdd}tj|j5}|j dr|j d|j dddfj}|r|dst|dd d icdddSt|dj}|jtd r|jst|dd d icdddS|j}|d d dtt|fg|gcdddS|dk(rt|ddicdddS|dk(rt|t!cdddS|dk(r0t|t"D cgc] \}} || d c} }cdddS|dk(rt%|} t'|j d} t|t)| d| ddk(| d| | jdd| jd| jd| jd d!t+j,| jd"d#d$ cdddS|d%k(r|j d&D cgc]} t't/gd'| } } | D]P} t+j,| j1d(| d(<t+j,| j1d)| d)<Rt|| cdddS|d*k(r|jd+d,k(rt3|jd-xsd}t+j,|d.j5|xsd/}d0D]'}||vs|j d1|t||f)d|vr|j d1d|drdnd2f|j7t|ddicdddS|d%k(r|jd+d,k(ryt3|jd-xsd}t+j,|d.j5|xsd/}|jd(g}|r2t9|t)t%|d|jd)gnd}|r |j:nd}|r|j<rd3nd4}|j d5|jdd!|jd6d7|jd8d!||t+j>|t+j>|jd)gt3tAj@f|j7t|d9d||d:;cdddS|dk(r|jC||cdddS dddt|dd dz/api/readinessz /api/agents)idmissionz /api/summaryz6SELECT status,count(*) FROM candidates GROUP BY statusr'publishing_enabled1 source_url worker_statusunknown scan_started last_scan last_error last_resultz{}) r'rrrtcountsrurwrxryr{z/api/candidateszSELECT id,source_url,title,clip_path,status,score,ratings_json,warnings_json,created_at FROM candidates ORDER BY created_at DESC) rprttitle clip_pathr=scoreratingswarnings created_atrrz /api/settingsrWPOSTCONTENT_LENGTHrYs{})r'rtz7INSERT OR REPLACE INTO settings(key,value) VALUES (?,?)0approvedpendingz~INSERT INTO candidates(source_url,title,clip_path,status,score,ratings_json,warnings_json,created_at) VALUES (?,?,?,?,?,?,?,?)r}Untitledr~r3)ror=r)r=r>z not found)"r:rrr startswithr,rsplitfetchoner@rresolveis_relative_tois_file read_bytesr;r$r rr/dictr"r7rKzippoprcreadcommitraveragerr8time_page)rHenvironr<rrrowtargetr?keyrqrr|rrowslengthpayloadr-prgaterr=s rrbz App._wsgi:sC [[S ) __TWW % 9/jj!NQUQ\Q\]`abQcdfQgPijssu#a&uS',AW1X 9 9c!f--/,,T2U-VW_e_m_m_ox}DEHJQR^I_y` 9 9 ((*h <>NsSVW[S\~=^_`v 9 9}$U5T{-K 9 9''e)+0N 9 9}$U5tz?{dpdgipsW^@_?{-| 9 9~%B-RZZ8p-q(rUeAkN6Kabcwaxz}a}LMNZL[ek|}|A|ABQR[|\lmlqlqr@lANONSNST_N`nonsnst@ACnDSWS]S]^_^c^cdqrv^wSx*yz 9 9((HJHRHRSUHVWCDd3yz{|}WWuADJJquuY7G,Hq|X\XbXbcdchchisctXu!J-uU.% 9 9&&7;;7G+H&+P7;;'78=A> SZ[gShSmSmntSuS~y~H3AG|RZZ0iklmpqxyzq{m|j}%~'72BJJ?x{OW^_sWtPSz}z~5 E%tDk$B1 9 92((W[[9I-JF-R7;;'78=A>$**WUaMbMgMghnMoMxsxByi+IP2B7ER[\^R_`kRlLmopototuACpD3EVZT&*dll%)dmmz \^_^c^cdpqs^tuvuzuz{BCMuNOPOTOTU`acOdeklqrvr|r|}DrEFJFPFPQRQVQVWabdQeFfgjkoktktkvgw]xy E%V\ejBk$l? 9 9@s{4::eR#8A 9 9@A 9BU3 455-@| W! 9 9srAV4AV451V40V4 V40V4V)V4%B6V4%V4=V/A#V4A+V44AV4F V41V4) V44V=ct|}|ddgtdjjdt j |djdt j |dj gS)Nr1)r5ztext/html; charset=utf-8z/root/workspace/shorts_ui.html __THRESHOLD__r' __SOURCE__rt)r/r read_textreplacehtmlescaper9)rHr<rr?s rrz App._page^s r]E(,W+XY56@@BJJ?[_[f[fgklwgx[yzCCDPQUQ\Q\]abn]oQpqxxz{ {rAc&|j||SrE)rb)rHrr<s r__call__z App.__call__asTZZ-F&FrAN)rNrOrPrIrjrbrrrrArrfrf7s@2#6H{GrArfc.t|t|SrE)rrf)rs r create_apprcsGBKBrAu{Shorts Control

Shorts Control

ECC-inspired scoring dashboard. Public publishing is disabled until platform OAuth and source rights are configured.

Source and gate



Pipeline status

Loading…

Candidate clips

Loading…
__main__z,shorts dashboard listening on 127.0.0.1:8790T)flushz 127.0.0.1iV")UN)r2N)rr7r threadingrpathlibr urllib.parserrwsgiref.simple_serverrshorts_pipelinerrr DB_PATHrr*r/r@rCrRrfrPAGErNrTprint serve_foreverrrArrs  +-?? 6 7 ] I 6699*G*GX7G" Z CeJRVW D%335rA