|0bj?dZddlmZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z m Z ddl mZedZedZed Zd Zd Zd Zhd ZddZddZddZddZddZddZddZedk(reyy)aJDeterministic, local AI-review resolver. This is the versioned implementation of the Codex review policy. It uses no model API, Graphiti, OpenRouter or LLM. It reads the original Obsidian source, records two independent rule passes, and applies only terminal routing states. It never creates TruthItems and never writes Neo4j. ) annotationsN)Counter defaultdict)datetimetimezone)Pathz?/opt/struktur/obsidian-knowledge-pipeline/knowledge_pipeline.dbz7/opt/struktur/knowledge-curator/minimal-human-review.dbz/opt/obsidian-vaultzai-review-resolver/1.0.0zai-rulebook/1.0.0 chatgpt_codex> duplicatefast_index_onlyinvalid_fragmentobsolete_extractionsensitive_quarantineai_recorded_unverifiedai_structured_acceptedexcluded_non_knowledgegenerated_summary_onlyhistorical_report_onlyinsufficient_authoritytechnical_context_onlyexploratory_source_onlyconflict_observed_no_action#insufficient_evidence_no_escalationcdtjtjj S)N)rnowrutc isoformat5/opt/struktur/knowledge-curator/ai_review_resolver.pyrr&s << % / / 11rct|tr|jd}tj|j S)Nutf-8) isinstancestrencodehashlibsha256 hexdigest)values rshar)*s1%u||G'>% * * ,,rc|jdDchc]}|d }}dddddjD]!\}}||vs |jd|d|#|jdDchc]}|d }}ddddjD]$\}}|s ||vs|jd |d|&|jd ycc}wcc}w) NzPRAGMA table_info(review_items)TEXT)ai_review_statusai_review_versionai_reviewed_atai_decision_idz$ALTER TABLE review_items ADD COLUMN  z PRAGMA table_info(routing_items))terminal_status resolved_atresolver_versionz%ALTER TABLE routing_items ADD COLUMN al CREATE TABLE IF NOT EXISTS ai_review_runs( run_id TEXT PRIMARY KEY, resolver_version TEXT NOT NULL, rule_version TEXT NOT NULL, actor TEXT NOT NULL, started_at TEXT NOT NULL, completed_at TEXT, group_count INTEGER NOT NULL, candidate_count INTEGER NOT NULL, agreement_count INTEGER NOT NULL, conservative_count INTEGER NOT NULL, status TEXT NOT NULL, no_external_model INTEGER NOT NULL, no_neo4j_write INTEGER NOT NULL ); CREATE TABLE IF NOT EXISTS ai_group_decisions( decision_id TEXT PRIMARY KEY, run_id TEXT NOT NULL, group_id TEXT NOT NULL, group_status TEXT NOT NULL, member_count INTEGER NOT NULL, member_statuses_json TEXT NOT NULL, pass_a_json TEXT NOT NULL, pass_b_json TEXT NOT NULL, agreement INTEGER NOT NULL, split_required INTEGER NOT NULL, sources_json TEXT NOT NULL, evidence_hashes_json TEXT NOT NULL, exceptions_json TEXT NOT NULL, rule_id TEXT NOT NULL, rule_version TEXT NOT NULL, confidence_class TEXT NOT NULL, rollback_reference TEXT NOT NULL, decided_at TEXT NOT NULL, decided_by TEXT NOT NULL ); CREATE TABLE IF NOT EXISTS ai_review_decisions( decision_id TEXT PRIMARY KEY, run_id TEXT NOT NULL, group_id TEXT NOT NULL, candidate_id TEXT NOT NULL, target_status TEXT NOT NULL, reason TEXT NOT NULL, pass_a TEXT NOT NULL, pass_b TEXT NOT NULL, agreement INTEGER NOT NULL, source_path TEXT NOT NULL, source_file_sha256 TEXT, source_chunk_key TEXT, evidence_hash TEXT, evidence_length INTEGER NOT NULL, candidate_json TEXT NOT NULL, exceptions_json TEXT NOT NULL, rule_id TEXT NOT NULL, rule_version TEXT NOT NULL, confidence_class TEXT NOT NULL, decided_at TEXT NOT NULL, decided_by TEXT NOT NULL, rollback_reference TEXT NOT NULL ); CREATE TABLE IF NOT EXISTS ai_review_audit( audit_id TEXT PRIMARY KEY, run_id TEXT NOT NULL, candidate_id TEXT, group_id TEXT, phase TEXT NOT NULL, old_status TEXT, new_status TEXT, details_json TEXT NOT NULL, created_at TEXT NOT NULL ); )executeitems executescript)pcmcrcolsnametyprcolss r ensure_schemar?/s**%FG HQAaD HD H!v& eg] c t RZZ*NtfTUVYUZ([\ ] ::&HI JaQqT JE J(.VW]^ddfM c T& JJ>tfAcUK LM##  I Ks C . Cc|dz|zdztj|dzj}|jdryt j d|}|s|jds|dvry |jd s|jd s d |vsd |vsd|vry|jdry|jds|dvry|jdryy)z2Return target status, pass-A, pass-B, and rule id. F ensure_asciizYouTube-Research/)rzNThe source contains a reported rule or recommendation in a transcript/summary.zZThe source is external and non-authoritative; no current or verified claim may be created.ai.source.exploratory.v1zapi[- ]?key|token|passwort|password|secret|credentials|zugang|berecht|oauth|zahlung|konto|kredit|rechtlich|sicherheit|irrevers|medizin|personenbezogenz Email-Agent/>CODEX_HANDOVER_PLAN.mdSESSION_NOTES.md)rzJThe source describes an operational, access, security, or sensitive topic.zWAuthority and safe operational effect are not sufficient for automatic truth or action.zai.sensitive.quarantine.v1zADR/rFzARC-zStatus-z Status-nach-)rzBThe source records a historical decision, event, or system status.zEHistorical context must not be promoted to current or verified truth.zai.historical.report-only.v1zSystem/AI-Skills/)rz>The source is instructional or third-party reference material.zAIt is not an authoritative statement about the productive system.rDzSystemstruktur/>CODEX_TOOL_PROMPT.mdSYSTEM-ARCHITEKTUR.md)rzHThe source provides architecture, diagnostic, or implementation context.zFIt is not sufficient authority for an automatic truth-layer assertion.zai.technical.context-only.v1z Solutions/)rz=The source is a design analysis or implementation comparison.zCRecommendations and design notes are not verified production facts.zai.design.context-only.v1)r zNThe source is useful project or background information and remains searchable.zWIt has no sufficient authority or operational need for automatic truth-layer promotion.zai.low-impact.fast-index.v1)jsondumpscasefold startswithresearch)path candidateevidencelow sensitives rclassifyrT`s $; !D (4::ie+T T ^ ^ `C *+,  tvyzIDOON3t@8.  v$//2D"ESW[dhl[lp~CGqG0 *+, ()T5f-f0 |$- +rct|z }|jsdddddS|j}dt|t ||j dddS)NF)existsr&sizetextTr!replace)errors)VAULTrW read_bytesr)lendecode)rOfraws r source_inforbsT  A 88:$VXYY ,,.Cc#hC#**U\en*Jo pprctjt}tj|_tjt }tj|_t |||j|jg}|jdD]6}g}|jd|dfD]}|jd|dfj}|s+tj|d}|jdxsi} t| jdxs|jd xsd } t|d || \} } } }t|d }g}|d s|j!d d} | jdr|j!d|j!||| | | | |||| d |j!||d9t#}dt%j"t&j(j+dz}g}g}t-}d}d}|D][}|d}t-d|D}|r|j/dddnd}t1|dkD}|r|dz }t3d|Dr|dz }t5|Dchc] }|dd  c}}t5|Dchc]&}|djdxst7|d(c}}t5|Dchc]}|dD]}|c}}} |dd}!d|zdz|!z}"|j!id |"d!|d"|!d#|d$t1|d%t9|d&d't1|d(d)d*d+d,d)d-| d.|d/|d0|d| d1d2d3d4d5d6|zd7|d8t:i|D]}|d}|d9}#d:|zdz|#z}$|j!id |$d!|d"|!d9|#d;|d<d=|d&d>z|d*zd&|d&d*|d*d-t=| d?|d d@|dAdBdC|djdCd|djdxst7|ddDt1|dd|dd|dd1|dEt>d4|t:d6|zdF||d<xxdz cc<^id!|dGt@dHt>dIt:dJt1|dKt1|dLt9|dM|dN|dO|dP|rdn t1|dQ|rdn t1|dRddSddTddUddVt5tB}%|s"|jE|jE|%S||fD]}&|&jdW |jdX|t@t>t:||t1|t1|||dYddf |D]}'|jdZ|'d ||'d"|'d#|'d$tjF|'d%d[\tjF|'d&d[\tjF|'d*d[\t=|'d-t=|'d.tjF|'d/d[\tjF|'d0d[\tjF|'dd[\|'d1t>d4|'d5|t:f|D]}(|jd]|(d ||(d"|(d9|(d;|(d=|(d&|(d*|(d-|(d?|(d@|(dC|(d|(dD|(dtjF|(dd[\|(d1t>|(d3|t:|(d5f|jd^|(d9fj})|)r|)dd_vr|jd`|(d;|(d;|(d1t>|||(d;t@||(d |(d9f |jda|db|(d9dc|)d|(d;tjF|(d |(d1ddddded[\|f|jdfdg|(d z||(d9|(d"dc|)d|(d;tjF|(d1dddhd[\|f di|jdjD*chc]}*|*d c}*vr |jdk|(d;|t@|(d9fnd|jdl|j|j |jE|jE|%Scc}wcc}wcc}}wcc}*w#tH$r"|jK|jKwxYw#|jE|jEwxYw)mNzWSELECT * FROM decision_units WHERE status='pending_human_group_review' ORDER BY unit_idzTSELECT candidate_id FROM decision_unit_members WHERE unit_id=? ORDER BY candidate_idunit_idz/SELECT * FROM review_items WHERE candidate_id=?rcandidate_json provenance evidence_textobjectrVrOrWsource_missingrevidence_truncated) rowrPrQstatuspass_apass_brulesource exceptionsprov)unitmembersz ai-review-z%Y%m%dT%H%M%S%fZrtc3&K|] }|d yw)rlNr.0ms r zresolve..s.Lqq{.Lsr+c34K|]}|dxr|dyw)rmrnNrrvs rryzresolve..s X))!,Q/2Di (mAo ,!#, b 3+b /b J0b: bAbb+cc"c(cTtj}|jdd|jdd|j}|j|j k(r|j dttjt|j ddy) Nz --dry-run store_true)actionz--applyz)genau eine Option: --dry-run oder --applyF)rCindent) argparseArgumentParser add_argument parse_argsdry_runrerrorprintrIrJr)aprs rmainrs B"//+\/"RTVTcTcdmvBTcUCmmoAyyAGGRXX&QR $**WQWW%5 BCr__main__)returnr#)r(z bytes | strrr#)r8sqlite3.Connectionr9rrNone)rOr#rPrrQr#rztuple[str, str, str, str])rOr#rr)rboolrr)rr)__doc__ __future__rrr%rIrMr collectionsrrrrpathlibrrrr\rrrrrr)r?rTrbrr__name__rrrrs# ,' MN DE "# $"  2- . b++\qGTD z46r