ԫiC*dZddlZddlmZeGddZeGddZeGdd ZeGd d Zd efd Zd efdZ d efdZ d efdZ eGddZ eGddZ eGddZd e fdZd e fdZd efdZdZedk(redededej*dej,ed ej.ed!ej*dej,ed"ej0eed#eZej5D]\ZZed$ed%eyy)&a Genesis Elestio Infrastructure Configuration Central configuration for all Elestio cloud services. Import this module to get connection details for PostgreSQL, Qdrant, and Redis. Usage: from elestio_config import PostgresConfig, QdrantConfig, RedisConfig # PostgreSQL conn = psycopg2.connect(PostgresConfig.connection_string) # Qdrant client = QdrantClient(url=QdrantConfig.url, api_key=QdrantConfig.api_key) # Redis r = redis.from_url(RedisConfig.connection_string) N) dataclassceZdZUdZdZeed<dZeed<dZ eed<dZ eed <dZ eed <e d efd Z ed efd Zy)PostgresConfigz+PostgreSQL (Episodic Memory) configuration.z(postgresql-genesis-u50607.vm.elestio.apphostiXcportpostgresuserzCiBjh6LM7Yuqkq-jo2r7eQDwpassworddatabasereturnc d|jd|jd|jd|jd|j S)Nz postgresql://:@/)r r rrr selfs ;/mnt/e/genesis-system/data/genesis-memory/elestio_config.pyconnection_stringz PostgresConfig.connection_string!s@tyyk4==/499+QtyykQRSWS`S`Rabbc|}|j|j|j|j|jdS)z'Get connection parameters for psycopg2.rrr r r rclsconfigs rget_connection_paramsz$PostgresConfig.get_connection_params%s8KKKKKK   rN)__name__ __module__ __qualname____doc__rstr__annotations__rintr r r propertyr classmethoddictrrrrrsn5:D#:D#D#.Hc.Hc c3cc  d    rrceZdZUdZdZeed<dZeed<dZ eed<dZ eed <d Z eed <d Z eed <e defdZedefdZy) QdrantConfigz%Qdrant (Vector Memory) configuration.z"qdrant-b3knu-u50607.vm.elestio.apprir@7b74e6621bd0e6650789f6662bca4cbf4143d3d1d710a0002b3b563973ca6876api_keygenesis_vectorscollection_namei vector_sizeCosinedistancer c:d|jd|jSNhttps://rrrrs rurlzQdrantConfig.url<$))Adii[11rcB|}|j|jdS)z Get parameters for QdrantClient.r4r*r7rs rget_client_paramszQdrantConfig.get_client_params@s#::~~  rN)rrrrrr r!rr"r*r,r-r/r#r4r$r%r8r&rrr(r(2su/4D#4D#UGSU,OS,KHc 2S22 $  rr(ceZdZUdZdZeed<dZeed<dZ eed<dZ eed <e d efd Z e d efd Ze d efd Zy) RedisConfigz%Redis (Working Memory) configuration.z#redis-genesis-u50607.vm.elestio.appri grdefaultr ze2ZyYYr4oWRdASI2CaLc-r r cnd|jd|jd|jd|jS)Nzredis://rr)r r rrrs rrzRedisConfig.connection_stringRs1$))Admm_Adii[$))MMrcp|}|j|j|j|jddS)z'Get connection parameters for redis-py.T)rrusernamer decode_responsesrrr r rs rrz!RedisConfig.get_connection_paramsVs4KKKK  $   rc"|jS)z9Alias for get_connection_params (backward compatibility).)rrs rr8zRedisConfig.get_client_paramsbs((**rN)rrrrrr r!rr"r r r#rr$r%rr8r&rrr:r:Js/5D#5D#D#+Hc+ N3NN  d    +$++rr:cheZdZUdZdZeed<dZeed<dZ eed<e defd Z e de fd Z y ) N8NConfigz+n8n (Workflow Orchestration) configuration.z!n8n-genesis-u50607.vm.elestio.apprirzeyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiIxZTA3Y2UwYi1lZmZmLTRlODItOGRkZS02ODA3OGZiNjU4MDQiLCJpc3MiOiJuOG4iLCJhdWQiOiJwdWJsaWMtYXBpIiwiaWF0IjoxNzY2Nzc2MDAyfQ.viRWPPX8t6cTqXEtBEw7pj-0ar_Nvjrh0_8T1LGLi6or*r c"d|jdS)Nr2z/api/v1)rrs rapi_urlzN8NConfig.api_urlos$))G,,rcd|jiS)Nz X-N8N-API-KEYr*rs rheaderszN8NConfig.headersss..rN)rrrrrr r!rr"r*r#rFr%rIr&rrrDrDhs\53D#3D#OeGSe ---///rrDr c ttjjdtjt tjjdtj tjjdtjtjjdtjtjjdtjS)z-Get PostgreSQL config with env var overrides.GENESIS_POSTGRES_HOSTGENESIS_POSTGRES_PORTGENESIS_POSTGRES_USERGENESIS_POSTGRES_PASSWORDGENESIS_POSTGRES_DATABASEr) rosenvirongetrr"rr r r r&rrget_postgres_configrSys  ZZ^^3^5H5H I  79L9LM N ZZ^^3^5H5H I ;^=T=TU ;^=T=TU  rc 8ttjjdtjt tjjdtj tjjdtjS)z)Get Qdrant config with env var overrides.GENESIS_QDRANT_HOSTGENESIS_QDRANT_PORTGENESIS_QDRANT_API_KEY)rrr*)r(rPrQrRrr"rr*r&rrget_qdrant_configrXs_  ZZ^^1<3D3D E  5|7H7HI J 79M9MN rc ttjjdtjt tjjdtj tjjdtjtjjdtjS)z(Get Redis config with env var overrides.GENESIS_REDIS_HOSTGENESIS_REDIS_PORTGENESIS_REDIS_USERGENESIS_REDIS_PASSWORDr@) r:rPrQrRrr"rr r r&rrget_redis_configr^sx  ZZ^^0+2B2B C  4k6F6FG H ZZ^^0+2B2B C 8+:N:NO  rcttjjdtjtjjdtj S)z&Get n8n config with env var overrides.GENESIS_N8N_HOSTGENESIS_N8N_API_KEY)rr*)rDrPrQrRrr*r&rrget_n8n_configrbs?  ZZ^^.  ? 4i6G6GH rcJeZdZUdZej j ddZee d<dZ e e d<ej j ddZ ee d <e ej j d d Z e e d <ed efdZed efdZed efdZed efdZy)BrowserlessConfigu% Browserless (Cloud Browser Army) — LIVE on Elestio DO Sydney ✅ Service: browserless-genesis (MICRO-1C-1G, running, created 1 day ago) Provider: Digital Ocean, Australia/Sydney — optimal for AU client QA. Provides cloud-hosted Chromium via WebSocket/REST (Playwright-compatible). Enables 10-50 parallel browser sessions without local resource consumption. Used by: scripts/browserless_qa_army.py, all browser automation agents. Get TOKEN from: Elestio dashboard → browserless-genesis → Env Vars → TOKEN BROWSERLESS_HOSTz)browserless-genesis-u50607.vm.elestio.appri rBROWSERLESS_TOKENtokenBROWSERLESS_MAX_SESSIONS10max_concurrentr cxd|jd|j}|jr|d|jS|S)z9WebSocket URL for playwright.chromium.connect_over_cdp().zwss://r?token=)rrrh)rbases rws_urlzBrowserlessConfig.ws_urls> {!DII;//3zz$wtzzl+CtCrc:d|jd|jS)z8HTTP base URL for REST API (screenshots, PDF, scraping).r2rr3rs rhttp_urlzBrowserlessConfig.http_urls$))Adii[11rc^|jd}|jr|d|jS|S)Nz /pressurerm)rqrh)rr4s r health_urlzBrowserlessConfig.health_urls2y).2jj#gdjj\*AcArc$|jS)a Use this with playwright.chromium.connect_over_cdp(): from elestio_config import BrowserlessConfig config = BrowserlessConfig() browser = await p.chromium.connect_over_cdp(config.get_playwright_connect_url()) )rorBs rget_playwright_connect_urlz,BrowserlessConfig.get_playwright_connect_urlsu||rN)rrrrrPrQrRrr r!rr"rhrkr#rorqrsr$rur&rrrdrds  13^_D#_D# 3R8E38bjjnn-GNONCO DDD 2#22BCBB3rrdceZdZUdZej j ddZee d<e ej j ddZ e e d<ej j dd Z ee d <d Z ee d <ed efdZy)FalkorDBConfigu FalkorDB (Episodic Graph Memory) — TO BE PROVISIONED on Elestio. Purpose: AIVA's graph memory — who did what, when, why, how it connects. Provision: Elestio → New Service → FalkorDB → MEDIUM-2C-4G → Netcup US falkordb-py: pip install falkordb FALKORDB_HOSTz&falkordb-genesis-u50607.vm.elestio.appr FALKORDB_PORT6379rFALKORDB_PASSWORDrgr genesis_episodic graph_namer cX|}|j|j|jdS)z Use with falkordb-py: import falkordb db = falkordb.FalkorDB(**FalkorDBConfig.get_client_params()) graph = db.select_graph(FalkorDBConfig.graph_name) rrr rrs rr8z FalkorDBConfig.get_client_paramss$ V[[fooVVrN)rrrrrPrQrRrr r!r"rr r}r$r%r8r&rrrwrws  0XYD#YBJJNN?F;Bll74<<.!9:RPRRrN)rrrrrPrQrRrr r!r"rr*r#rFr%rIr&rrrrs  0XYD#YBJJNN?F;>"4b9GS9 222SSSrrctS)zEGet Browserless config. Set BROWSERLESS_TOKEN from Elestio dashboard.)rdr&rrget_browserless_configrs  rctS)z8Get FalkorDB config. Provision service first on Elestio.)rwr&rrget_falkordb_configr  rctS)z.Get Graphiti config. Provision after FalkorDB.)rr&rrget_graphiti_configrrrci} ddl}t}|jditj }|j }|j d|jd|d< ddl }t}|j|jdd|jid }|jd k(rd|d <nd |j|d < ddl}t!}|j"dit$j } | j'd|d<|S#t$r}d||d<Yd}~d}~wwxYw#t$r}d||d <Yd}~~d}~wwxYw#t$r}d||d<Yd}~|Sd}~wwxYw)z%Test all Elestio service connections.rNzSELECT 1u ✅ Connected postgresqlu❌ z /collectionszapi-key )rItimeoutqdrantu ❌ Status redisr&)psycopg2rSconnectrrcursorexecuteclose ExceptionrequestsrXrRr4r* status_coderr^Redisr:ping) resultsrrconnrerresprrs rtest_connectionsr sG +$&xI."F"F"HIz" /  '"$||zzl, '/    s " /GH "-d.>.>-? @GH  &!# EKK >+;;= > * N; +"&qc  + '"1#J' &!!: N&sJA(D-A"D7AE D4"D//D47 EE  E E1E,,E1__main__zGenesis Elestio Configurationz(========================================z PostgreSQL: rz Qdrant: z Redis: z n8n: zTesting connections...z z: )rrP dataclassesrrr(r:rDrSrXr^rbrdrwrrrrrrprintrrr4rFritemsservicestatusr&rrrs& !     2     . ++ +:  / /  / ^<+  ++ +\ WW W0 SS S( 1 ^ ^ *Z z )* (O L)../q1A1F1F0G HI L++, -. L++,Akm.@.@-A BC L,,- ./ G "# G"==?( 7)2fX&'(r