iPLddlmZddlZddlZddlmZddlmZddlmZddlmZddlm Z ddlm Z dd lm Z dd lm Z dd lm Z dd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z ddl!m"Z"ddl#m$Z$ddl#m%Z%ddl#m&Z&ddl#m'Z'ddl#m(Z(dd l)m*Z*dd!l+m,Z,erZdd"lm-Z-dd#lm.Z.dd$lm/Z/dd%lm0Z0dd&lm1Z1dd'lm2Z2dd(l3m4Z4dd)l!m5Z5dd*l6m7Z7dd+l8m9Z9dd,l#m:Z:dd-l;mm?Z?dd0l>m@Z@ed1ed23ZAGd4d5e ZBdd:ZCeDd;ejEdkZHeFd?kZIeFd@kZJeFdAkZKeZL ddBlMmNZNn#eO$r ddBl#mNZNYnwxYwGdCdDZPerddIZQnddJlRmQZQ ddKlmSZSdLZTeFdMkZUn#eO$resGdNdOePZSdPZTdPZUYnwxYw ddQlmVZVeWeVe"ZX dddWZYdLZZn#eO$resGdXdYePZVdPZZYnwxYweKrddZl!m[Z[ndd[l\m]Z[ede^e[fZ_ee^e[fZ`dd_ZaddaZbddcZcddZdejeddhZfddiZgddlZhddnZiddoZjddpZkddtZlddvZmddxZnddzZoddZpdZqdZrddZsddZtddZudZvddZwdZxeyejzdrdZ{dZ|ndZ{dZ|ddZ}ddZ~ddZdZddZddZddZGddej:ZeQeddZGdde$ZeQeddZddZddZddZddZdZddZeHrddlmZddlmZeZn ddlmZdZddÄZddńZddDŽZdS)) annotationsN)Any)Callable)Dict)Iterable)Iterator)Mapping)Optional)Protocol)Set)Type) TYPE_CHECKING)TypeVar)Union) __version__)inspectschema)sql)types)url)CheckConstraint)Column)ForeignKeyConstraint)visitors) DialectKWArgs) BindParameter) ColumnClause) quoted_name) TextClause)UnaryExpression)traverse) TypeGuard) ClauseElement)Index)Table) Connection)Dialect) Transaction) Inspector)ColumnCollection) SQLCompiler)Insert) ColumnElement) Constraint) SchemaItem)Select) TableClause_CE)zColumnElement[Any]r0)boundceZdZd dZdS) _CompilerProtocolelementrcompilerkwreturnstrc dSN)selfr7r8r9s ^/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/alembic/util/sqla_compat.py__call__z_CompilerProtocol.__call__>s N)r7rr8rr9rr:r;)__name__ __module__ __qualname__rAr>rBr@r6r6=s(      rBr6valuer;r:Union[int, str]c4 t|S#|cYSxYwr=)int)rFs r@ _safe_intrJBs%5zz sc,g|]}t|Sr>)rJ).0xs r@ rNJsEEEaYq\\EEErBz (\d+|[abc]\d)))rO)rOrQ)rOrQ)) _NONE_NAMEceZdZdZdS) _Unsupportedz.Placeholder for unsupported SQLAlchemy classesN)rCrDrE__doc__r>rBr@rWrWZs4444rBrWr7Type[ClauseElement]dialects0Callable[[_CompilerProtocol], _CompilerProtocol]cdSr=r>)r7rZs r@compilesr]`s  rB)r])ComputedT)rOrPceZdZdS)r^NrCrDrEr>rBr@r^r^m DrBr^F)Identityidentity&Union[Identity, schema.Sequence, None]dialect_kwargsboolDict[str, Any]cXiStrH}|r1ttsJ|jnUi}tt rj|d<j j|d<d}|fd|D|S)Nalwayson_null) start incrementminvaluemaxvalue nominvalue nomaxvaluecyclecacheordercVi|]%}t|d|t|d&Sr=)getattr)rLkeyrds r@ z._get_identity_options_dict..sCxd33?355???rB) identity_has_dialect_kwargs_as_dict isinstancerupdaterfrcrjrk)rdrfas_dictattrss` r@_get_identity_options_dictrs  I ( ''))G 8!(M:::::x6777G(H-- :$,O!#/)1)9GI& E NN$   rBceZdZdS)rcNrar>rBr@rcrc{rbrBrc) _NoneName)symbolname_ConstraintName!TypeGuard[_ConstraintNameDefined]cL|tupt|ttfSr=)rUr{r;rrs r@constraint_name_definedrs# :  CD3 2B!C!CCrBTypeGuard[str]c,t|tSr=)r{r;rs r@constraint_name_stringrs dC  rB Optional[str]c(t|r|ndSr=)rrs r@constraint_name_or_noners*$// 944T9rBauto connectionOptional[Connection]Iterator[None]c#K |j}n#t$rd}YnwxYw|dVdS|s7|J|5dVddddS#1swxYwYdSdVdSr=)in_transactionAttributeErrorbeginrrs r@_ensure_scope_for_ddlrs #2       ~ )))!!##                     EEEEEs AA!AcTtr|j|S|j|S)N) hide_password)sqla_14render_as_string __to_string__)rrs r@url_render_as_stringrs6>#s#-@@@@ s }====rBr'r)cPt|}|r|S|Sr=)_get_connection_transactionrr transactions r@"_safe_begin_connection_transactionrs1.j99K"!!!rBNonecTt|}|r|dSdSr=)rcommitrs r@#_safe_commit_connection_transactionrs;.j99KrBcTt|}|r|dSdSr=)rrollbackrs r@%_safe_rollback_connection_transactionrs;.j99KrBcH |j}|S#t$rYdSwxYw)NF)rrrs r@_get_connection_in_transactionrsC #2 ~ uus  !!idxr%Iterable[ColumnElement[Any]]c|jSr=) expressions)rs r@_idx_table_bound_expressionsr s ?rB schema_itemc Vt|dr |jdi|S|jdi|S)N_copyr>)hasattrrcopy)rr9s r@rrsF{G$$& { &&2&&&{%%"%%%rBOptional[Transaction]cTtr|S|j}|jSr=)rget_transaction_root_Connection__transaction)rrs r@rrs/*))+++  ))rBurl.URLcttjdrtjj|i|Stj|i|S)Ncreate)rrURLr)argr9s r@ _create_urlr"sBsw!!#w~s)b)))w"r"""rB connectable tablename schemanameUnion[str, None]ctr#t|||S|j|||Sr=)rr has_tabledialect)rrrs r@_connectable_has_tabler)sL {##--iDDD",, J   rBc trD|5}|||cdddS#1swxYwYdS|j||Sr=)r_operation_contextexecutebind) inspector statementparamsconns r@_exec_on_inspectorr4s9  ) ) + + 3t<< 622 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3~%%i888s?AAcFts|jSddlm}|j|juS)Nrr)rnullablesqlalchemy.sqlr_user_defined_nullableNULL_UNSPECIFIED)metadata_columnrs r@_nullability_might_be_unsetr<s:  ''))))))  2f6M M rBcFtsdStd|DS)NFc3@K|]}t|tVdSr=)r{r^rLsds r@ z._server_default_is_computed..K,EE:b(++EEEEEErB) has_computedanyserver_defaults r@_server_default_is_computedrGs- FuEEnEEEEEErBcFtsdStd|DS)NFc3@K|]}t|tVdSr=)r{rcrs r@rz._server_default_is_identity..RrrB)rrrs r@_server_default_is_identityrNs- FuEEnEEEEEErB constraintr/r&cTt|tr |j}|J|S|jSr=)r{rparenttable)rrs r@_table_for_constraintrUs7*233 !    rBct|trd|jDSt|trt |jSt |jS)Ncg|] }|j Sr>)r)rLfks r@rNz+_columns_for_constraint..`s888b 888rB)r{relementsr _find_columnssqltextlistcolumnsrs r@_columns_for_constraintr^s`*233(88J$78888 J 0 0(Z/000J&'''rBrr*rchtr||dS||dSr=)r reflect_table reflecttable)rrs r@_reflect_tablergs= &&ud333%% 4   rBc~t|r-t|\}}||j|S|Sr=)_type_has_variants_get_variant_mappinggetr)type_r base_typemappings r@_resolve_for_variantrps?%  1%88 7{{7<333 rB_variant_mappingc*t|jSr=)rgrrs r@rrzsE*+++rBc||jfSr=)rrs r@rr}se,,,rBc8t|tjuSr=)typesqltypesVariantrs r@rrsE{{h...rBc|j|jfSr=)implrrs r@rrsz5=((rBrrc tr.jJjJtjt sJfdjD}jj}jj}jdj j j}jdj j j}djD}j }j }j } j} ||||||||| | f S)Nc4g|]}j|jSr>)rr)rLrwrs r@rNz_fk_spec..s1), 3$rBrc&g|]}|jjSr>)columnr)rLr7s r@rNz_fk_spec..sMMMggn)MMMrB)rrrr{rr& column_keysrrrrondeleteonupdate deferrable initially) rsource_columns source_table source_schema target_schema target_tabletarget_columnsrrrrs ` r@_fk_specrs4!---"...*+U333330:0FN$)L%,M'*17>M&q)06;LMM9LMMMN"H"H&J$I  rBc|jd}|d}|dd|}|jJ||jjkS)Nr.)r _get_colspecsplitpopjoinrrw)rspectokenstablekeys r@_fk_is_self_referentialr(sj  q ! . . 0 0D ZZ__F JJrNNNxxH   ( ( ( z(, ,,rBc|jSr=) _type_boundrs r@_is_type_boundr+s   !!rBcRt}t|id|ji|S)z2locate Column objects within the given expression.r)setr"add)clausecolss r@rrs+%(EED VR(DH-... KrB collectionr+r%Union[Column[Any], ColumnClause[Any]]c|jJ||j}t|dst|dr|j|dS||dS)z(remove a column from a ColumnCollection.N _immutable _readonly)rwr_parentremove)r1r to_removes r@_remove_column_from_collectionr9sz : ! ! !6:&Iz<((%GJ ,L,L%!!),,,,,)$$$$$rBtext_*Union[str, TextClause, ColumnElement[Any]]&Union[ColumnElement[Any], Column[Any]]ct|tr1t|tj}|||St|t rt||St|trt||j St|tj rt||Std)zAa workaround for the Index construct's severe lack of flexibilityz#String or text() construct expected)r{r;rr NULLTYPE append_columnr _textual_index_element_textual_index_columntextrr._copy_expression ValueError)rr:cs r@rArAs% @ 5(+ , , A E: & &@%eU333 E1 2 2@$UEJ777 E3, - -@u--->???rB expressionrc:fd}tj|i|S)Nct|trV|jO|jurF|jjvrj|jSt |}||SdSr=)r{rrrrErr?)colrErs r@replacez!_copy_expression..replacesq sF # #  % --x<>))#~ch//#JJ**1---4rB)rreplacement_traverse)rFrrJs ` r@rCrCs:       (B  rBc$eZdZdZdZd d Zd Zd S) r@aQWrap around a sqlalchemy text() construct in such a way that we appear like a column-oriented SQL expression to an Index construct. The issue here is that currently the Postgresql dialect, the biggest recipient of functional indexes, keys all the index expressions to the corresponding column expressions when rendering CREATE INDEX, so the Index we create here needs to have a .columns collection that is the same length as the .expressions collection. Ultimately SQLAlchemy should support text() expressions in indexes. See SQLAlchemy issue 3174. _textual_idx_elementrr&rBr r:rc||_||_|j|_tj|jjt j|_||jdSr=) rrBrwrrr r> fake_columnr?)r?rrBs r@__init__z_textual_index_element.__init__ sQ  9!=9JKK D,-----rBc|jgSr=)rO)r?s r@ get_childrenz#_textual_index_element.get_childrens !!rBN)rr&rBr r:r)rCrDrErX__visit_name__rPrRr>rBr@r@r@sH  ,N...."""""rBr@r8r,c (|j|jfi|Sr=)processrBr7r8r9s r@_render_textual_index_columnrWs! 8 GL / /B / //rBceZdZdS)_literal_bindparamNrar>rBr@rYrYsDrBrYc |j|fi|Sr=)render_literal_bindparamrVs r@_render_literal_bindparamr\#s -8 ,W ; ; ; ;;rBrIrr c"tr|jSiSr=)sqla_13kwargs)rIs r@_column_kwargsr`*sz rBUnion[Index, Constraint]rOptional[Dialect]c|jdS|Jtr|j|dSt |jdrt |j}nt }|t|jd}||}t|tj r+| |d}| |S|j|S)NF_alembic_quotequote)rfr)rridentifier_preparerformat_constraintrr rr; __class__r{rr% ddl_compiler_prepared_index_name)rrquoted_name_clsnew_nameds r@_get_constraint_final_namero1st    M *<< u=   :?G , , *%)$9$9OO)O"?3z#7#7uEEE))x)88 j&, / / M$$Wd33A))*55 5.@@LL LrBUnion[Constraint, Index]c|tr-|jdS|J|j|d}|duS|jduS)NFrd)rrrgrh)rrrs r@_constraint_is_namedrrVsa + ? "5"""*<< u=  4d**rB mysql_dialectr(cTtr|jSt|jo|jSr=)r is_mariadbrgserver_version_info _is_mariadbrss r@rwrwes6 ''  - *)   rBc|jSr=) _mariadb_normalized_version_inforxs r@rzrzos  99rBUnion[TableClause, Table]r-ctr&|S|dS)NT)inline)rinsertr})rs r@_insert_inlinerss8)||~~$$&&&||4|(((rB)create_mock_engine)select create_enginec &tdd|S)Nz postgresql://mock)strategyexecutorr)rrr9s r@rrs  fx    rBr1c@tjt|fi|Sr=)rrr)rr9s r@_selectrs z$w--..2...rBindexc>|jD]}t|rdSdSNTF)r is_expression)rexprs r@is_expression_indexrs5!    44  5rBrct|tr|j}t|tt|tr|jrdSdSr)r{r!r7r is_literal)rs r@rrsT T? + +| T? + + dL ) )T_t 5rB)rFr;r:rG)r7rYrZr;r:r[)F)rdrerfrgr:rh)rrr:r)rrr:r)rrr:r)rrr:r)T)rr'r:r))rr'r:r)rrr:rg)rr%r:r)rr3r:r3)rr'r:r)r:r)rr'rr;rrr:rg)r:rg)rr/r:r&)rr*rr&r:r)rrr:r)rrr:rg)rr/r:rg)r1r+rr2r:r)rr&r:r;r:r<)rFr3rr&r:r3)r7r@r8r,r:r;)r7rYr8r,r:r;)rIrr:r )rrarrbr:r)rrprrbr:rg)rsr(r:rg)rr{r:r-)r:r1)rr%r:rg)rrr:rg) __future__r contextlibretypingrrrrrr r r r r rrr sqlalchemyrrrrrr sqlalchemy.enginersqlalchemy.schemarrrrrsqlalchemy.sql.basersqlalchemy.sql.elementsrrrr r!sqlalchemy.sql.visitorsr"typing_extensionsr#r$r%r&r'r(r)sqlalchemy.engine.reflectionr*r+sqlalchemy.sql.compilerr,sqlalchemy.sql.dmlr-r.sqlalchemy.sql.schemar/r0sqlalchemy.sql.selectabler1r2r3r6rJtuplefindall_versr^r sqla_14_18 sqla_14_26sqla_2sqlalchemy_versionsqlalchemy.sql.namingrU ImportErrorrWr]sqlalchemy.ext.compilerr^rhas_computed_reflectionrc issubclassryr has_identityrsqlalchemy.utilrr;r_ConstraintNameDefinedrrrAUTOINCREMENT_DEFAULTcontextmanagerrrrrrrrrrrrrrrrrrrrr TypeEnginerrrr(r+rr9rArCr@rWrYr\r`rorrrwrzrrr _sa_selectrrrrr>rBr@rs #"""""  """"""((((((!!!!!!------$$$$$$222222######------111111000000//////......333333,,,,,,''''''6((((((            ,,,,,,))))))------666666444444333333))))))555555000000000000000000555555 ge5!CDEEE         EE:2:&6 DDEEE   6/ 6/ j j $ A>>>>>>>AAA@@@@@@@@A555555551     100000 2//////L#z1$$$      |   L#$3//////#-*X}"E"E %%%%%%NLLc      |   LLL f 4-------333333c9,-sI~.DDDD !!!! ::::  ,>>>>""""    &&&&****####    999   FFFFFFFF    (((     78  233),,,---- ///)))B----""""%%%%$@@@@$*"""""S.""":  !!000"!0           <<<< "M"M"M"MJ + + + +    :::)))) /------0/////GG((((((   ////s6F F$#F$GG-,G-1H H&%H&