<пhT ddlZddlmZddlmZmZddlmZddlm Z m Z m Z ddl mZmZddlmZmZmZmZmZmZm Zeej0dej2d ej2d ej2d eej2d d ej2dZeedZe ddeZdZej>e ddZ ej>e ddZ!y)N) load_dotenv) create_engineevent)URL) sessionmakerSessionwith_loader_criteria)has_request_contextg)BaseCaseDocumentPromptTopicUserrzpostgresql+psycopg2DB_USER DB_PASSWORDDB_HOSTDB_PORTi8DB_NAME) drivernameusernamepasswordhostportdatabaseT) pool_pre_pingF) autocommit autoflushbindcbtdtjjty)Nu📦 Initializing database...)r )printr metadata create_allengine/var/www/html/dynbot5004/db.pyinit_dbr)s  )*MM&)r'do_orm_executec |jsytrttdsyt t tddxsdsy|j jttfddttfddttfddttfd dttfd dttfd d|_y) zLAuto-apply WHERE tenant_id = g.tenant_id to SELECTs on tenant-scoped models.N tenant_idrc"|jk(SNr,clstids r(z+_enforce_tenant_on_select..1S]]c5Ir'T)include_aliasesc"|jk(Sr.r/r0s r(r3z+_enforce_tenant_on_select..2r4r'c"|jk(Sr.r/r0s r(r3z+_enforce_tenant_on_select..3r4r'c"|jk(Sr.r/r0s r(r3z+_enforce_tenant_on_select..4r4r'c"|jk(Sr.r/r0s r(r3z+_enforce_tenant_on_select..5r4r'c"|jk(Sr.r/r0s r(r3z+_enforce_tenant_on_select..6r4r') is_selectr hasattrr intgetattr statementoptionsr r rrrr ChatSession) execute_stater2s @r(_enforce_tenant_on_selectrC#s  " "  !ga&= gaa(-A .C ,55==T)I[_`X)I[_`V)I[_`U)I[_`T)I[_`[)I[_` Mr' before_flushctrttdsytt tddxsd}|sy|j D],}t|dst |dddvs t |d|.y)z+Fill tenant_id on new objects when missing.r,Nr)Nr)r r<r r=r>newsetattr)session flush_context instancesr2objs r(_autofill_tenant_on_insertrL:sm !ga&= gaa(-A .C {{+ 3 $k4)HI)U Cc *+r')"osdotenvr sqlalchemyrrsqlalchemy.enginersqlalchemy.ormrr SASessionr flaskr r modelsr r rrrrrAcreategetenvr=urlr% SessionLocalr) listens_forrCrLr&r'r(rZs +!SS)UTT cjj$ RYYy ! RYY} % 9  YRYYy$ ' ( RYYy !  s$ /uFK *9./0,9n- +. +r'