j! dZddlmZddlmZmZddlmZddlm Z m Z m Z m Z Gdde eZejdej dej"d ej$d iZd(d ZGd d e eZeddhZedGddZedGddZedGddZedGddZedGddZdZdZdZdZ d Z!d!Z" d)d"Z#d*d#Z$d+dd%d& d,d'Z%y$)-uEinzige Routinglogik des Aria-V3-Kerns. `route()` ist eine reine Funktion: Sie entscheidet, führt nichts aus und vergibt keine Freigabe. Ausführen kann nur ein Adapter mit gültiger HMAC-Clearance (siehe authorization.py, adapter_contract.py). Eingangsgrößen: Aufgabenklasse, Fähigkeiten, Datenschutzklasse (über die PrivacyMatrix), Qualität (inkl. Untergrenze), Verfügbarkeit, Budget, Kontextgröße und manuelle Modellwahl. Bei gleicher Eignung gewinnt Codex. ) annotations) dataclassfield)Enum) FrozenSetIterableMappingOptionalceZdZdZdZdZdZy) PrivacyTierpublicinternal confidentialunknownN)__name__ __module__ __qualname__PUBLICINTERNAL CONFIDENTIALUNKNOWN-/home/aria/aria-v3/python/aria_router/core.pyr r s FH!LGrr ctj}d}|D]}d}t|t|kDs|}|r|StjS)NFT)r rPRIVACY_SEVERITYr)tiersresultseentiers rmost_sensitiver$#sS   F D D !$4V$< <F62{222rceZdZdZdZdZy)ModeautocodexclaudeN)rrrAUTOCODEXCLAUDErrrr&r&-s D E Frr&r(r)T)frozenceZdZUded<ded<ej Zded<eeZ ded<e jZ d ed <d Z d ed <y) JobRequeststrjob_id task_classr privacy)default_factoryFrozenSet[str]required_capabilitiesr&moderint context_bytesN)rrr__annotations__r rr3r frozensetr6r&r*r7r9rrrr/r/6sD KO&..G[.,1),L>LD$M3rr/czeZdZUded<ded<ded<dZded<dZded <d Zd ed <d Zded<dZded<ddZ y )Backendr0namer5 capabilitiessupported_tasksTbool availablebudget_allowed2r8 quality_scoreNz Optional[int]max_context_bytesrztuple[tuple[str, int], ...] task_qualitycT|jD]\}}||k(s |cS|jSN)rGrE)selfr2taskscores r quality_forzBackend.quality_forNs6,, KD%z!  !!!r)r2r0returnr8) rrrr:rBrCrErFrGrMrrrr=r=AsN I  ##ItNDM3'+}+13L-2"rr=cPeZdZUdZded<d dZd dZed dZed dZ y) PrivacyMatrixzAWelche Datenschutzklasse an welches Backend darf (Konfiguration).z.tuple[tuple[str, FrozenSet[PrivacyTier]], ...]allowedcdt|tsy|jD]\}}||k(s ||vcSy)NF) isinstancer rQ)rJbackendr#r>r s rpermitszPrivacyMatrix.permits[s<$ ,<< %KD%wu}$ %rcP|jD]\}}||k(s |cStSrI)rQr;)rJrTr>r s r tiers_forzPrivacyMatrix.tiers_forcs/<< KD%w  {rc `|ttd|jDS)Nc3<K|]\}}|t|fywrI)r;).0r>r s r z-PrivacyMatrix.from_mapping..ks# )4uT9U# $ s)tuplesorteditems)clsmappings r from_mappingzPrivacyMatrix.from_mappingis05 8?      rcf|jtjhtjhdS)z=Altvertrag von route(): nur PUBLIC darf an irgendein Backend.)r(r))rar r)r_s rstrictzPrivacyMatrix.strictos4!(()"))*!   rN)rTr0r#r rNrA)rTr0rNzFrozenSet[PrivacyTier])r`z#Mapping[str, Iterable[PrivacyTier]]rN'PrivacyMatrix')rNrd) rrr__doc__r:rUrW classmethodrarcrrrrPrPUs=K ;;     rrPc6eZdZUded<ded<ded<ded<y ) CandidateEvaluationr0rTrAeligibleztuple[str, ...]reasonsr8qualityN)rrrr:rrrrhrhxs LN  Lrrhc|eZdZUded<ded<ded<ded<dZded <d Zd ed <d Zded<d Zded<dZded<y)RoutingDecisionr0r1z Optional[str]rTrArQreasoncoderztuple[CandidateEvaluation, ...] candidatesF tie_breakmanualN fallback_from) rrrr:rprqrrrsrtrrrrmrmsI K  M KD#N24J/4ItFD#'M='rrmSELECTEDMANUAL_SELECTEDCHECKED_FALLBACKPRIVACY_DENIEDNO_ELIGIBLE_BACKENDMANUAL_CHOICE_NOT_PERMITTEDcg}|jtvr|jd|j|j|js|jd|j s|jd|j s|jd|jj|js|jd|j|jvr|jd|j*|j|jkDr|jd|j|j}||kr|jdt|j| t!||S) NUNKNOWN_BACKENDPRIVACY_NOT_PERMITTED UNAVAILABLEBUDGET_EXHAUSTEDCAPABILITY_MISSINGTASK_UNSUPPORTEDCONTEXT_TOO_LARGEQUALITY_BELOW_MINIMUM)r>KNOWN_BACKENDSappendrUr3rBrCr6issubsetr?r2r@rFr9rMrhr\)jobrTmatrix min_qualityrjrks r _evaluaters$G||>)() >>',, 4./   }%  ! !)*  $ $ - -g.B.B C+, ~~W444)*  ,1B1BWE^E^1^*+!!#..1G./ w||[%.' RRrct|dS)NcP|j |jdk7|jfS)Nr()rkrT)es rz_rank..s#qyyj!))w:NPQPYPY-Zr)key)r]) evaluationss r_rankrs +#Z [[rNF)rmanual_fallbackc |tj}|Dcgc]}t||||}}t|}|Dcgc]}|js|} }|j t jurJ|j j} | Dcgc]}|j| k(s|} }| r$t|j| dd| dt|dS|D cgc]%}|j| k(s|jD]} | '} }} |rt| Dcgc]}|j| k7s|c}}|rW|d}t|j|jdd|jd| dd j| xsd d t |d| St|jdd d| dd j| xsd t"|dS| s]t%|xrt'd|D}|rt|jdd dt(|St|jdd dt*|St| }|d}t-|dkDxr|dj.|j.k(}t|j|jdd|jd|r|jdk(rdndzt0||Scc}wcc}wcc}wcc} }wcc}w)u Wählt ein Backend oder lehnt strukturiert ab. matrix=None bedeutet die strikte Altmatrix (nur PUBLIC). Das Gateway übergibt immer die konfigurierte Matrix. Manuelle Wahl überstimmt nie eine Prüfung. Ist das gewünschte Backend nicht zulässig, wird blockiert. Nur mit manual_fallback=True darf ein anderes Backend gewählt werden, und auch dann nur eines, das jede einzelne Prüfung (Datenschutz, Verfügbarkeit, Budget, Fähigkeiten, Kontextgröße, Qualität) selbst bestanden hat. NTz Selected z!: manual choice passed all checks)rsrz: checked fallback, z not permitted (z, znot configured))rsrtFzManual choice z not permitted: c38K|]}d|jvyw)r}N)rj)rZrs rr[zroute..s1 56 #qyy 01 sz2Privacy policy: execution denied for every backendzNo eligible backendrz: eligible backendr(z (tie-break codex)ro)rr)rPrcrr\rir7r&r*valuerTrmr1rvrjrjoinrwrzrAallrxrylenrkru)rbackendsrrrbrrqrriwantedchosenrwanted_reasons alternativesselected privacy_onlyrankedrrs rrouters~%%'CKLa9S!V[9LKL{#J&5a!**5H5 xxtyy %=f)\!Ms5J)J.J.J3%J3J8+J8J>#J>)r zIterable[PrivacyTier]rNr ) rr/rTr=rrPrr8rNrh)rlist[CandidateEvaluation]rNrrI) rr/rz list[Backend]rzOptional[PrivacyMatrix]rr8rrArNrm)&re __future__r dataclassesrrenumrtypingrrr r r0r rrrrrr$r&r;rr/r=rPrhrmrurvrwrxryrzrrrrrrrs #(99#t!a 33 GX./ $ $"""& $   D $ $ ( ( ( #%!+;SS#6S.\ B !5BB48BETBr