iwjUdZddlZddlZddlZddlZddlmZmZddlmZm Z ddl m Z ddl m Z mZmZmZmZddlmZddlmZmZddlZddlZdd lmZej6j9d d Zej6j9d d Zeej6j9ddZ ej6j9ddZ!ej6j9ddZ"ej6j9ddZ#ejHejJddejLdZ'da(eee)d<defdZ*defdZ+dZ,dZ-dZ.e d e fd!Z/e d"d#d$e/%Z0e0jced&gd&gd&g'ed(fd)e2fd*Z3Gd+d,eZ4Gd-d.eZ5Gd/d0eZ6Gd1d2eZ7Gd3d4eZ8Gd5d6eZ9e0jud7d8efd9Z;e0jud:e6ee3g;de8ee3g;d?Z=e0jud@e6ee3g;de0j9d@e8ee3g;dBZ?e0jdCee3gDdVdEed AIVA (Telnyx Voice Assistant) -> Bridge API -> PostgreSQL <- Claude Code (polls) Run: BRIDGE_API_KEY=your-secret-key uvicorn bridge_api:app --host 0.0.0.0 --port 8765 Environment Variables: BRIDGE_API_KEY - API key for authentication (required) GENESIS_POSTGRES_HOST - PostgreSQL host (default: Elestio) GENESIS_POSTGRES_PORT - PostgreSQL port (default: 25432) GENESIS_POSTGRES_USER - PostgreSQL user (default: postgres) GENESIS_POSTGRES_PASSWORD - PostgreSQL password GENESIS_POSTGRES_DATABASE - PostgreSQL database (default: postgres) N)datetimetimezone)OptionalList)asynccontextmanager)FastAPI HTTPExceptionDependsHeaderRequest)CORSMiddleware) BaseModelField)ThreadedConnectionPoolBRIDGE_API_KEYzgenesis-bridge-2026GENESIS_POSTGRES_HOSTz(postgresql-genesis-u50607.vm.elestio.appGENESIS_POSTGRES_PORT25432GENESIS_POSTGRES_USERpostgresGENESIS_POSTGRES_PASSWORDzetY0eog17tD-dDuj--IRHGENESIS_POSTGRES_DATABASEz.%(asctime)s [BRIDGE] %(levelname)s %(message)sz%Y-%m-%d %H:%M:%S)levelformatdatefmtcommand_bridgepoolreturnctddttttt ddddd }t jdtdtdt |S) zNCreate a fresh connection pool with TCP keepalives to prevent idle disconnect. ) minconnmaxconnhostportuserpassworddatabase keepaliveskeepalives_idlekeepalives_intervalkeepalives_countconnect_timeoutzPostgreSQL pool created -> :/)rPG_HOSTPG_PORTPG_USERPG_PASSPG_DBloginfo)ps 7/mnt/e/genesis-system/AIVA/command_bridge/bridge_api.py _create_poolr;DsW    AHH*7)1WIQug FG Hc.t tatSN)rr;r<r:get_poolr@Ys |~ Kr<cf tj}|jjd|S#t$rl}t j d|d trtjn#t$rYnwxYwtatjcYd}~Sd}~wwxYw)zMGet a connection from the pool, recreating pool if all connections are stale.SELECT 1zStale pool detected (u) — recreating poolN) r@getconncursorexecute Exceptionr7warningrcloseallr;)connes r:get_connrK`s z!!# j)  +A3.CDE     ~||~s?8; B0B+A98B+9 BB+B B+%B0+B0c tj|y#t$r$ |jYy#t$rYYywxYwwxYw)z Return a connection to the pool.N)r@putconnrFclose)rIs r:put_connrOssF 4   JJL    s$ A 8 AA AA c$t} |j}ttjj tjj tddj}|j||j|jtjd t#|y#t$r.}|jtj!d|d}~wwxYw#t#|wxYw)z,Create schema and table if they don't exist.z schema.sqlrzSchema genesis_bridge ensuredzSchema creation failed: N)rKrDopenospathjoindirname__file__readrEcommitrNr7r8rFrollbackerrorrO)rIcur schema_sqlrJs r: ensure_schemar^s :Dkkm GGLL2L A3 $&  J   01    ,QC01  s$B/C C?)C::C??D DappcKtjdttjddtr*tj tjdyyw)zStartup/shutdown lifecycle.zCommand Bridge starting up...z5Command Bridge ONLINE - Kinan <-> Claude relay activeNz%Command Bridge shut down, pool closed)r7r8r^rrH)r_s r:lifespanrasHHH ,-OHH DE    89 sA+A-zGenesis Command Bridgez?Voice-to-Terminal directive relay: Kinan -> AIVA -> Claude Codez1.0.0)title descriptionversionra*) allow_origins allow_methods allow_headers)default x_bridge_keyc8K|tk7r tddyw)zSimple API key authentication.izInvalid or missing X-Bridge-Key status_codedetailT)rr )rjs r:verify_api_keyros~%4UVV sceZdZUdZeddZeed<eddZeed <ed d Z eed <ee d Z e ed<y)DirectiveRequestz*Directive from Kinan (via AIVA) to Claude..zThe directive from Kinanrcmessagenormallow/normal/high/urgentrircpriority aiva_voicezOrigin of the directivesource Extra contextdefault_factoryrcmetadataN) __name__ __module__ __qualname____doc__rrsstr__annotations__rwrydictr}r?r<r:rqrqsL4*DEGSE(8PQHcQ :STFCT4_MHdMr<rqcleZdZUdZeddZeed<eddZeed <ee d Z e ed <y ) StatusRequestz#Status update from Claude to Kinan..zStatus update textrrrsrtrurvrwrzr{r}N) r~rrrrrsrrrwrr}r?r<r:rrs:-*>?GS?(8PQHcQ4_MHdMr<rc0eZdZUdZeed<eed<eed<y)DirectiveResponsez#Response after queuing a directive.statusidrsN)r~rrrrrintr?r<r:rrs- K G Lr<rc\eZdZUdZeed<eed<eed<eed<dZeeed<iZ e ed<y) QueuedMessagezA message from the queue.rrsrw created_atNryr}) r~rrrrrrryrr}rr?r<r:rrs1# G LMO FHSM Hdr<rc,eZdZUdZeeed<eed<y)StatusResponsezResponse with pending messages.updatescountN)r~rrrrrrrr?r<r:rrs) -  Jr<rc6eZdZUdZeddZeeed<y)ExecuteRequestz4Mark a directive as executed with optional response.NzExecution result summaryrrresponse) r~rrrrrrrrr?r<r:rrs>#D6PQHhsmQr<rz/bridge/telnyx-webhookrequestc ^ K|jd{}tjdtj|ddd d}i}d|vr(|d}|j d|j di}nqd |vrm|d }d|vr(|d}|j d|j di}nt |j5r t7|ndt |dd=|d?k(rd?n|d@k(rdAnd8f|j| jtjdB|dC|ddDit|Stj9dG|ddH|dIiS7#tj$rd |i}YwxYw#t $rP} |j#tj%d| ddt | ddicYd} ~ t|Sd} ~ wwxYw#t|wxYw#t $rP} |j#tj%d1| dd2t | ddicYd} ~ t|Sd} ~ wwxYw#t|wxYw#t $rA} |j#tj%dE| ddFicYd} ~ t|Sd} ~ wwxYw#t|wxYw#t $r5} tj%dJ| ddKt | ddicYd} ~ Sd} ~ wwxYww)Lz Handle Telnyx Voice Assistant tool webhook calls. Telnyx sends the tool call details here. We parse the function name and parameters, execute the appropriate action, and return the result for AIVA to speak back to Kinan. NzTelnyx webhook received: )indent function_name argumentsfunction_argumentsdatapayload directiverelay_directive_to_clauderwrtresultz>No directive provided. Please tell me what to relay to Claude.zINSERT INTO genesis_bridge.command_queue (direction, message, priority, source, metadata) VALUES ('kinan_to_claude', %s, %s, 'aiva_voice', %s) RETURNING idviatelnyx_webhookr DIRECTIVE # queued []: dz2Got it. I've relayed that to Claude as directive #z with z* priority. Claude will pick it up shortly.Failed to queue directive: z8Sorry, I couldn't relay that to Claude. Database error: check_claude_statuscursor_factoryzUPDATE genesis_bridge.command_queue SET status = 'read', read_at = NOW() WHERE direction = 'claude_to_kinan' AND status = 'pending' RETURNING id, message, priority, created_at, metadatazLNo new updates from Claude at the moment. Everything is running as expected. (z priority)zUpdate r: rszI have z updater sz from Claude. z ... Delivered z! status updates to Kinan via AIVAFailed to fetch status: z:Sorry, I couldn't check Claude's status right now. Error: log_conversation_summarysummaryoutcome completed caller_moodneutralfrom caller_numberduration_secondszINSERT INTO aiva_rlm.aiva_interactions (call_id, caller_number, transcript, call_duration_seconds, outcome, outcome_label) VALUES (gen_random_uuid()::text, %s, %s, %s, %s, %s)2ipositive frustratednegativez3Call logged to aiva_rlm.aiva_interactions: outcome=z, mood=z)>)@H aG Sb)&1Z&? &1\&A y    NwiW^_j^klm "`a  KK,]O< = @Oyz{ {U 8'' 5()4  58 m  7s;< $\]`ab]cdheh]i\j"kll  m : o  4QC89 $^_bcd_efjgj_k^l"mnn  o D T  8<= "RSS  T  [ .qc23J3q6RVSV<.YZZ[sX-R4X- B1W,>R.W,X- W, BR7% W,0X-1W,A0T#2 W,=X->BT# W,X-BW,/B;V* W,5X-6W,X-R40W,3R44W,7 T:T :T;T? W, X- TT T  W,# U<,:U7&U<'U?+ W,6X-7U<<U?? V  W, W+WWW W,X-WW W))W,, X*5*X%X* X-%X**X-z/bridge/directive)response_model dependenciesreqc K|jdvr tddt} |j}|j d|j |j|j tj|jf|jd}|j|jtjd|d|jd |j d d td ||j t!|S#t"$rC}|j%tj'd|tdt)|d }~wwxYw#t!|wxYww)zi Queue a directive from Kinan to Claude. Called by AIVA via Telnyx tool webhook or directly. )lowrthighurgentizInvalid priorityrlzINSERT INTO genesis_bridge.command_queue (direction, message, priority, source, metadata) VALUES ('kinan_to_claude', %s, %s, %s, %s) RETURNING idrrrrNrqueuedrrrsrr)rwr rKrDrErsryrrr}rrYrNr7r8rrOrFrZr[rrrIr\rrJs r:post_directivers'  ||>>4FGG :Dkkm  [[#,, DJJs||4L M  "   ;vhi ~STcAR@STU VS[[Q  <  /s34CF;;< s5&E4C D E4 E!>EE!!E$$ E11E4z/bridge/directivescKt} |jtjj}|j d|j }|j|jg}|D][}|jt|d|d|d|dj|jd|jdi ]|r"tjd t|d t!|t| t#|S#t$$rC}|j'tj)d |t+dt-|d}~wwxYw#t#|wxYww)z Claude polls this to get new directives from Kinan. Returns pending kinan_to_claude messages and marks them as 'read'. rzUPDATE genesis_bridge.command_queue SET status = 'read', read_at = NOW() WHERE direction = 'kinan_to_claude' AND status = 'pending' RETURNING id, message, priority, created_at, source, metadatarrsrwrryr}rrsrwrryr}rz directives to ClauderrzFailed to fetch directives: rrlNrKrDrrrrErrYrNrr isoformatrr7r8rrrOrFrZr[r rrIr\rrrrJs r:get_directivesrsF :D"kk)G)GkH  P ||~   C NN4y N _"<0::<778, WWZ4     HHz#g,/DE FgS\B  <  045CF;;< 5 E?DD  E? E,)>E''E,,E// E<<E?z/bridge/statusc Kt} |j}|jd|j|jt j |jf|jd}|j|jtjd|d|jd|jddtd||j t|S#t$rC}|j!tj#d |t%d t'| d}~wwxYw#t|wxYww) zf Claude posts status updates for Kinan. AIVA will read these when Kinan asks for updates. zINSERT INTO genesis_bridge.command_queue (direction, message, priority, source, metadata) VALUES ('claude_to_kinan', %s, %s, 'claude_terminal', %s) RETURNING idrzSTATUS #z posted [rNrrrzFailed to post status: rrl)rKrDrErsrwrrr}rrYrNr7r8rrOrFrZr[r rrs r: post_statusrs :Dkkm  [[#,, 3<<(@ A  "   8F89S\\N#ckk$3>O=PQR VS[[Q  <  +A3/0CF;;< s5 ECC/# E/ D;8>D66D;;D>> E  EcKt} |jtjj}|j d|j }|j|jg}|D][}|jt|d|d|d|dj|jd|jdi ]|r"tjd t|d t!|t| t#|S#t$$rC}|j'tj)d |t+dt-|d}~wwxYw#t#|wxYww)z AIVA polls this to get status updates from Claude for Kinan. Returns pending claude_to_kinan messages and marks them as 'read'. rzUPDATE genesis_bridge.command_queue SET status = 'read', read_at = NOW() WHERE direction = 'claude_to_kinan' AND status = 'pending' RETURNING id, message, priority, created_at, source, metadatarrsrwrryr}rrz status updates for KinanrrrrlNrrs r: get_statusrsF :D"kk)G)GkH  P ||~   C NN4y N _"<0::<778, WWZ4     HHz#g,/HI JgS\B  <  ,QC01CF;;< rz(/bridge/directive/{directive_id}/execute)r directive_idc(Kt} |j}|r |jnd}|jd||f|j }|j |j |s tddtjd|dd|d t|S#t$rt$rC}|jtjd |td t|d}~wwxYw#t|wxYww) z:Mark a directive as executed, with optional response text.NzUPDATE genesis_bridge.command_queue SET status = 'executed', executed_at = NOW(), response = %s WHERE id = %s AND direction = 'kinan_to_claude' RETURNING idizDirective not foundrlz Directive #z marked as executedexecuted)rrzFailed to mark executed: r)rKrDrrErrYrNr r7r8rOrFrZr[r)rrrIr\ response_textrrJs r: mark_executedr&s :Dkkm(+    L )  lln  C8MN N ;|n,?@A$L9   <  -aS12CF;;< s5 DBB* D*C?<>C::C??D DDz/bridge/historylimit directionc,Kt} |jtjj}|r|j d||fn|j d|f|j }|j|D]%}dD]}||s ||j||< '|t|dt|S#t$r3}tjd|tdt|d }~wwxYw#t|wxYww) zGet recent command history.raSELECT id, direction, message, priority, status, source, created_at, read_at, executed_at, response, metadata FROM genesis_bridge.command_queue WHERE direction = %s ORDER BY created_at DESC LIMIT %szSELECT id, direction, message, priority, status, source, created_at, read_at, executed_at, response, metadata FROM genesis_bridge.command_queue ORDER BY created_at DESC LIMIT %s)rread_at executed_at)historyrzFailed to fetch history: rrlN)rKrDrrrrErrNrrrOrFr7r[r r)rrrIr\rrkeyrJs r: get_historyrGs :D!kk)G)GkH  KK8 E"   KK8  ||~  4C? 4s8"3x113CH 4 4  #d)4  < -aS12CF;;< s; DBC'C9 D D.C<<DD DDz/bridge/telnyx-transcriptc XK |jd{}tjdt |dd |j d|}|j d|}|j dxs|j dxsm|j dxsZ|j dxsG|j dxs4d t jtjj}|j d xsN|j d xs;|j d xs(|j d xs|j d xsd }|j dxs;|j dxs(|j dxs|j dxsd }t|trdjd|D}n t |}|j dxs(|j dxs|j dxsd} tt|}|j dxs|j dxsd} t%} | j'} | j)dt |ddt |dd|dd|t | dd| dvrdndf| j+| j-tjd|d|d t3|  d#d$iS7#t$ri}YwxYw#t t"f$rd}YwxYw#t$r2} | j/tj1d!| Yd} ~ rd} ~ wwxYw#t3| wxYw#t$r%} tj1d"| Yd} ~ d#d$iSd} ~ wwxYww)%u, Receive Telnyx post-call transcript and log to aiva_rlm.aiva_interactions. Configure in Telnyx: AI Assistant → transcription.webhook_url → this endpoint. Accepts any Telnyx transcript webhook format and extracts what it can. Returns 200 immediately so Telnyx doesn't retry. Nz$Telnyx transcript webhook received: i,rrcall_control_idcall_idrzunknown-rr caller_idr transcript transcription c 3K|]I}|jddjd|jd|jddKyw)role?rcontenttextrN)rupper).0ts r: z$telnyx_transcript..sO#55$**,-RivbAQ0R/ST#sAArrrrra INSERT INTO aiva_rlm.aiva_interactions (call_id, caller_number, transcript, call_duration_seconds, outcome, outcome_label) VALUES (%s, %s, %s, %s, %s, %s) ON CONFLICT DO NOTHING riP)rresolvedsuccessrrz Logged call rz s) to aiva_rlm.aiva_interactionsz&Failed to log transcript to aiva_rlm: z%Transcript webhook processing error: rreceived)rrFr7r8rrrnowrutc timestamprlistrUrfloat ValueError TypeErrorrKrDrErYrNrZr[rO) rrrrrrraw_transcriptrrrrIr\rJs r:telnyx_transcriptros\\^#HH3CIdsO3D EFO?xx%((9d+ KK) * C{{9% C{{4  Cxx)* Cxx "  C (,,x||4>>@AB  KK  {{?+ {{;' xx xx(     KK % {{?+ xx % xx(   nd +#'#J ^,J KK* + {{:& xx*+    5?+H++i(NDHHY,?N;z ++-C KK G Tc"M"3B'6E"G Sb!%)MM S\   KKM IIK HH|G9Bxj8XY Z TN j !!q$ hI& H 2 D MMO II>qcB C C D TN ? 9!=>> j !! ?sN*LK?L$N*GM9L+2M9BL+/ M9;N*?L L N*LN*L(%M9'L((M9+ M&4(M!M)!M&&M)) M66M99 N'N"N*"N''N*z/bridge/healthcK t}|j}|jd|jt |dddt j tjjdS#t$rO}dddt|dd t j tjjdcYd}~Sd}~wwxYww) z Health check - no auth required.rBhealthyzgenesis-command-bridge connected)rservicer*r unhealthyzerror: Nr) rKrDrErNrOrr rr rrFr)rIr\rJs r:healthrs zkkm J  /#!hll3==?    !/!#a&#,0!hll3==?    s6CA;B?C C AC CCCC__main__ BRIDGE_PORT8765z Starting Command Bridge on port z0.0.0.0r8)r&r' log_levelr>)N)JrrSsysrloggingrrtypingrr contextlibrfastapirr r r r fastapi.middleware.corsr pydanticrrrpsycopg2.extras psycopg2.poolrenvironrrr2rr3r4r5r6 basicConfigINFO getLoggerr7rrr;r@rKrOr^rar_add_middlewarerrorqrrrrrpostrrrrrputrrrrr~uvicornr'r8runr?r<r:r2s* '!*DD2%0  02GH **..02\ ] bjjnn4g> ? **..0* = **..46M N 2J?  ,, ;  g() *.h%&- , *(& 0::: "Q   %%% .4D-AsNyNNIN IY RYR "#V['V[$V[| .?wWeOfNgh.i> nGTbLcKde(f(V +CZB[\c]@ '.*A)BC$S$(3-$D$N %&a"Wa"'a"H   8 z rzz~~mV4 5DHH/v 67GKK)$&A r<