iaIUdZddlZddlZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z ddl Z e jjddddlmZmZej&j)dd Zeed <eej&j)d d Zeed <ej&j)dej&j)dZe eed<ej&j)ddj7dvZeed<dZeed<e dZe ed<e hdZ!e ed<e"ddZ#e"ed<Gdde$Z%Gd d!Z&y)"u; KingRegistry — Kinan directive store. Manages the King's (Kinan's) directives with priority ordering. AIVA RLM Nexus — Story 2.03 + 2.05 — Track A File: core/registry/king_registry.py Schema (002_king_queen_tables.sql): kinan_directives ( directive_id UUID PK, directive_text TEXT NOT NULL, priority INTEGER CHECK (1-5), source VARCHAR CHECK (voice/text/inferred), status VARCHAR CHECK (active/fulfilled/cancelled), captured_at TIMESTAMP, related_entities JSONB DEFAULT '[]' ) RULE COMPLIANCE: - Rule 7: No SQLite — uses Elestio PostgreSQL via ConnectionFactory - Rule 6: E: drive only — lives at /mnt/e/genesis-system/core/registry/ - Rule 14: RegistryError wraps all DB exceptions for clean caller surface N)datetimetimezone)Path)Optionalz/mnt/e/genesis-system)ConnectionFactory connections QDRANT_HOSTz"qdrant-b3knu-u50607.vm.elestio.app _QDRANT_HOST QDRANT_PORT6333 _QDRANT_PORTQDRANT_API_KEYGENESIS_QDRANT_API_KEY_QDRANT_API_KEY QDRANT_HTTPStrue)1ryes _QDRANT_HTTPSkinan_directives_QDRANT_COLLECTIONz(/mnt/e/genesis-system/data/observability _EVENTS_DIR>textvoiceinferred VALID_SOURCESVALID_PRIORITIESceZdZdZy) RegistryErrorz@Raised on unrecoverable KingRegistry failures (DB errors, etc.).N)__name__ __module__ __qualname____doc__4/mnt/e/genesis-system/core/registry/king_registry.pyr!r!CsJr'r!c eZdZdZddeeddfdZdedededefd Z dd ede fd Z dede fd Z d edededede f dZddedede fdZdededdfdZdede fdZdede de fdZd ede fdZy) KingRegistrya7 Kinan directive store. Provides add / read / fulfil lifecycle for King directives backed by Elestio PostgreSQL (kinan_directives table). Args: connection_factory: Optional ConnectionFactory override for testing. Defaults to the module-level singleton. Nconnection_factoryreturnc.|||_yt|_yN)r_cf)selfr+s r(__init__zKingRegistry.__init__Ws);)G%[r'rprioritysourcec|tvrtd||tvrtdttd|t t j }tjtj} |jj}|j}|jd|||||f|j|j! |j)|||d|S#t"$rM} |jjj%n#t"$rYnwxYwt'd||d}~wwxYw#t"$rY|SwxYw)u Insert a new Kinan directive and return its UUID. Args: text: Directive content (stored in directive_text column). priority: Integer 1-5 (5 = highest urgency). source: Origin channel — "voice", "text", or "inferred". Returns: directive_id as a UUID string. Raises: ValueError: priority not in 1-5, or source not in VALID_SOURCES. RegistryError: Any database-level failure. upriority must be 1–5, got zsource must be one of z, got z INSERT INTO kinan_directives (directive_id, directive_text, priority, source, status, captured_at) VALUES (%s, %s, %s, %s, 'active', %s) zadd_directive failed: Nactive)r ValueErrorrsortedstruuiduuid4rnowrutcr/ get_postgrescursorexecutecommitclose Exceptionrollbackr!_write_to_qdrant) r0rr2r3 directive_id captured_atconncurexcs r( add_directivezKingRegistry.add_directive^s`, + +.xl;   &( )>(?vfZP 4::<( ll8<<0  I88((*D++-C KK tXv{C  KKM IIK   ! !,h I I %%'002  "8 >?S H  I   sI>A!C6 E6 E (D)(E) D52E4D55EE  EEtop_nc  |jj}|j}|jd|f|j }|j g}|D]T}|d}|jt|d|d|dt|dr|jn t|d V|S#t $r}td||d}~wwxYw) a$ Return the top-N active directives ordered by priority DESC, then captured_at ASC (oldest high-priority first). Args: top_n: Maximum number of records to return (default 5). Returns: List of dicts: { "directive_id": str, "text": str, "priority": int, "captured_at": str (ISO-8601) } Raises: RegistryError: Any database-level failure. a SELECT directive_id, directive_text, priority, captured_at FROM kinan_directives WHERE status = 'active' ORDER BY priority DESC, captured_at ASC LIMIT %s zget_active_directives failed: Nrr isoformat)rErr2rF) r/r=r>r?fetchallrArBr!appendr8hasattrrO) r0rKrGrHrowsrIresultrowcaptureds r(get_active_directivesz"KingRegistry.get_active_directivess( Q88((*D++-C KK <<>D IIK C1vH MM$'AK$'F$'F#8[9!**, ]    % Q"@ FGS P QsAB<< CCCc tj|jj}d}t j |t |z }||zd|}td|dDcgc]!}tjd|||dzd#}}td|Dxsd}t j|r|dk(rd}|dd D cgc]} | |z  c} Scc}wcc} w) u Deterministic 768-dim embedding derived from the SHA-256 hash of text. This is a placeholder for a real embedding model. It is deterministic (same text → same vector) and normalised to [-1, 1]. The real model will be swapped in later without changing the caller interface. Args: text: Directive text to embed. Returns: List of 768 floats in [-1, 1]. i Nrfc32K|]}t|ywr.)abs).0vs r( z2KingRegistry._text_to_embedding..s-c!f-sg?g) hashlibsha256encodedigestmathceillenrangestructunpackmaxisfinite) r0rh needed_bytes repeat_countextendedivaluesmax_valr^s r(_text_to_embeddingzKingRegistry._text_to_embeddings NN4;;= ) 0 0 2 yyA!67  $m|4FKA|]^F_`&--Xa!a%%89!<``-f--4}}W%CG%+DS\2G 22 a 3s ,&C C!rEstatusc  ddlm}ddlm}m}m}|t ttt} | jjD cgc]} | j} } t| vr)| jt|d|j|j!|} ||| ||||d } | j#t| g y cc} w#t$$r%}|j'|t)|Yd }~y d }~wwxYw)ux Embed directive text and upsert to Qdrant ``kinan_directives`` collection. Qdrant is a secondary index — Postgres is the source of truth. Failure here is non-fatal; callers must catch and suppress exceptions OR use the bare ``try/except: pass`` pattern. Args: directive_id: UUID string — used as Qdrant point ID. text: Directive text to embed and store. priority: Integer 1-5, stored in payload. status: Current status string, stored in payload. Returns: True on success, False on failure. r QdrantClient)Distance PointStruct VectorParamshostportapi_keyhttpsr`)sizedistance)collection_namevectors_config)rErr2ru)idvectorpayload)rpointsTNF) qdrant_clientrxqdrant_client.modelsryrzr{r r rrget_collections collectionsnamercreate_collectionCOSINErtupsertrB_log_qdrant_warningr8)r0rErr2rurxryrzr{clientcexistingrpointrIs r(rDzKingRegistry._write_to_qdrants.#  2 P P!!!'# F)/(>(>(@(L(LM1MHM!1(($6#/S8??#S) ,,T2F$0 ($  E MM*r?rowcountr@rArBrCr!)r0rE fulfilled_atrGrHupdatedrIs r(mark_fulfilledzKingRegistry.mark_fulfilleds ||HLL1  J88((*D++-C KK llQ&G KKM IIKN J %%'002  "9# ?@c I  Js6A-B C)(CC$ CC$CC$$C)r.))rM)r"r#r$r%rrr1r8intrJlistrWrtboolrDrrdictrrrr&r'r(r*r*Ks& Y84E+FYRVY>>> > >H535t5v3s3t34::: :  :  :x/s/3/t/b 3 s t &1t11fc:'J3'J4'Jr'r*)'r%rarreosrir9rrpathlibrtypingrsyspathinsertcore.db.connectionsrrenvironrr r8__annotations__rr rrrrrr frozensetrrhrrBr!r*r&r'r(rs1. ' *+> JJNN=2VW cW }f=> c>!#JJNN+,"#jjnn^V<BBDH\\ t\,C,CD TD%%BC yC1+%%KIKcJcJr'