#j, UdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z ddl mZddlmZddlmZmZmZmZmZddlmZmZmZmZmZdd lmZmZm Z m!Z!ej"d d ej"d d dej#d<da$e dze%d<dZ&dZ'de(de)de(de)de*e(e)ff dZ+dZ,e-dkr e,dSdS)z Command-line interface for Hindsight API. Run the server with: hindsight-api Run as background daemon: hindsight-api --daemon Stop with Ctrl+C. N) MemoryEngine __version__) create_app) print_banner)DEFAULT_WORKERSENV_HOST ENV_WORKERSHindsightConfig_get_raw_config)DEFAULT_DAEMON_PORTDEFAULT_IDLE_TIMEOUTENV_DAEMON_CHILDIdleTimeoutMiddleware daemonize)DefaultExtensionContextOperationValidatorExtensionTenantExtensionload_extensionignorezwebsockets.legacy is deprecated)messagez7websockets.server.WebSocketServerProtocol is deprecatedfalseTOKENIZERS_PARALLELISM_memorycXttj tj}|tj|tddS#t$r}td|Yd}~dSd}~wwxYwdSdS)z7Synchronous cleanup function to stop resources on exit.Nz pg0 stopped.z Error stopping pg0: ) r_pg0asyncionew_event_looprun_until_completestopcloseprint Exception)loopes Z/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/hindsight_api/main.py_cleanupr'0sw|7 0)++D  # #GL$5$5$7$7 8 8 8 JJLLL " # # # # # 0 0 0 .1.. / / / / / / / / / 0 77sA'A>> B%B  B%cptd|dttjddS)z(Handle SIGINT/SIGTERM to ensure cleanup.z Received signal z, shutting down...rN)r"r'sysexit)signumframes r&_signal_handlerr-=s6 9v 9 9 9::: JJJHQKKKKK args_host args_port config_host config_portreturnc||kr|nt}||ks$tjtr|}nd}||fS)zResolve host/port for daemon mode. Defaults to 127.0.0.1 for security, but honors explicit user overrides via --host flag or HINDSIGHT_API_HOST env var. Uses DEFAULT_DAEMON_PORT unless the user specified a custom port. z 127.0.0.1)r osenvirongetr )r/r0r1r2porthosts r&resolve_daemon_host_portr:DsL"[00996IDK2:>>(#;#; :r.c  t}tjdd}|d|jd|jd|dt |jd |jd  |d |jgd d|jd|ddd|dt t tj tttdtdtd |ddd|dddd| d !|d"dd#|d$d%d&|d'd%d(|d)d%d*|d+dd,td-|d.t td/td |}tjt&d0k}|jp|}|rBt+|j|j|j|j1\|_|_t-|st/t1|j|jkr't3j||j|j|j2}||s|t;jt>tAj t@j!tDtAj t@j#tDtId3tJ}|r&d4d%l&'d5|j(j)tId6tT}|r&d4d%l&'d7|j(j)tW|||j,8a-|rEt]|j/tZ9}|0|'d:tctZd;|j2d}|j5d?kp|j6} d4d%l7} d@} | j8dAkrJ d4d%l9} | :d@} t/dBnU#tv$rt/dCYn:wxYw d4d%l<} dD} t/dEn#tv$rt/dFYnwxYw| rdGn||j|j|j|j=|j>dH| dIdJdK }|j6rd;|dL<|j5d?kr |j5|dM<|j?r |j?|dN<|j@r |j@|dO<|jAr |jA|dP<|sSd?dQlBmC}||j|j|j/|jD|jE|jF|jG|j2t|jI|jJR 7d4d%l&d4d%lK}fdS}|L|d;TMtjOdUi|d%S)VzMain entry point for the CLI.z hindsight-apizHindsight API Server)prog descriptionz--hostzHost to bind to (default: z, env: HINDSIGHT_API_HOST))defaulthelpz--portzPort to bind to (default: z, env: HINDSIGHT_API_PORT))typer>r?z --log-level)criticalerrorwarninginfodebugtracezLog level (default: z, env: HINDSIGHT_API_LOG_LEVEL))r>choicesr?z--reload store_truez5Enable auto-reload on code changes (development only))actionr?z --workersz!Number of worker processes (env: z , default: )z --access-logzEnable access logz--no-access-log access_log store_falsezDisable access log (default))destrIr?F)rKz--proxy-headersz1Enable X-Forwarded-Proto, X-Forwarded-For headersz--forwarded-allow-ipsNz7Comma separated list of IPs to trust with proxy headersz --ssl-keyfilez SSL key filez--ssl-certfilezSSL certificate filez--daemonz$Run as background daemon (uses port z, auto-exits after idle)z--idle-timeoutzBIdle timeout in seconds before auto-exit in daemon mode (default: 1)r/r0r1r2)r9r8 log_levelOPERATION_VALIDATORrzLoaded operation validator: TENANTzLoaded tenant extension: )operation_validatortenant_extensionrun_migrations) database_url memory_enginez)Extension context set on tenant extensionTz/mcp)memoryhttp_api_enabledmcp_api_enabledmcp_mount_pathinitialize_memory) idle_timeoutrrwin32zDwinloop installed as asyncio event loop policy (Windows uvloop port)z7winloop not installed, using default asyncio event loopuvloopz)uvloop available, will use for event loopz6uvloop not installed, using default asyncio event loopzhindsight_api.server:appwsproto) appr9r8rOrK proxy_headerswsr$timeout_keep_alivetimeout_graceful_shutdownreloadworkersforwarded_allow_ips ssl_keyfile ssl_certfile)print_startup_info) r9r8rU llm_provider llm_modelembeddings_providerreranker_provider mcp_enabledversionvector_extensiontext_search_extensionc<ddl}|d tj}tj||dS#t$r%}d|dYd}~dSd}~wwxYw)NrzIdle checker error: T)exc_info) timesleeprrset_event_loopr _check_idler#rB)rxr$r%idle_middlewareloggings r&run_idle_checkerzmain..run_idle_checker8s KKK JJqMMM I-//&t,,,''(C(C(E(EFFFFF I I I 8Q884 HHHHHHHHH IsAA,, B6BB)targetdaemon)Pr argparseArgumentParser add_argumentr9intr8rOr5getenvr strr set_defaultsr r parse_argsr6r7rrr:rr"r dataclassesreplaceconfigure_logging log_configatexitregisterr'signalSIGINTr-SIGTERMrrr}rD __class____name__rrrun_migrations_on_startuprrrU set_contextrrqrr\rhrgr)platformwinloopinstall ImportErrorr^rKrcrirjrkbannerrlrmrnrorprrsrt threadingThreadstartuvicornrun)configparserargsis_daemon_child is_daemonrRrSextension_contextrbuse_import_stringr) loop_implrr^uvicorn_configrlrr~r|r}s @@r&mainrTs   F  $ *F  &+,p,p,p,p   Q&+ Q Q Q    JJJ UF$4 U U U   <>uvvv  BIk3+?+?@@AA [ [ [ [ [ [  |BUVVV ) ]Ywxxx 5))) ,5h 4m  NKKK ($=STTT  a4G a a a   $ iRf i i i      Djnn%566#=O .I 7ii      49     ~)))$V$)$)W[Wefff   OH M&-111 M&./222))>@[\\^ \4G4Q4Z\\]]]&h@@X V1A1K1TVVWWW/)7GB3,!    $$%6777 @AAA *    CO/$BSTTT q(7DKJJJI |w M NNN OO   !I X Y Y Y Y M M M K L L L L L M L MMM I = > > > > L L L J K K K K K L.?G))C  ^o+ %&  N {(#'x  |a$(Ly! I040H,- 9(,(8}% ;)-):~&  ......,,& & :$6*#4"("> " I I I I I I  0>>DDFFF K!!.!!!!!s$3)SS98S9=TT/.T/__main__).__doc__rrrrr5rr)warningsrrrapirrrrrr r r r rr rrrr extensionsrrrrfilterwarningsr6r__annotations__r'r-rrtupler:rrrr.r&rs1     '''''''' \\\\\\\\\\\\\\nmmmmmmmmmmm*KLLLL*cdddd(/ #$ $ ### 0 0 0 3 3 S _b glmprumugv     q"q"q"h zDFFFFFr.