>'j d dl mZ d dlmZ d dlmZmZmZ d dlm Z G d de Z
d Z e Z edde Z
d
ed d fd
Zd eed d f fdZddZddZddZddZddZy ) ) Generator)
create_engine)DeclarativeBaseSession sessionmaker) get_settingsc e Zd Zy)BaseN)__name__
__module__ __qualname__ 1/var/www/html/kelly/kelly-backend/app/database.pyr
r
s r r
c $ t } | j }i }ddi}|j d rd|d< nP|j | j | j
| j | j dkD r| j |d< t |fd |i|S )
N
pool_pre_pingTsqliteFcheck_same_thread) pool_size max_overflow pool_timeoutr pool_recycle connect_args) r database_url
startswithupdate db_pool_sizedb_max_overflowdb_pool_timeoutdb_pool_recycler )settingsurlr
engine_kwargss r _create_enginer$
s ~H
CL*D1M
~~h ,1 () ++!11!11
# #a ',4,D,DM. ) I< I= IIr F)
autocommit autoflushbinddbreturnNc $ | j y)zKReturn a request session to the pool before slow async I/O (SMTP, uploads).N)closer( s r release_db_connectionr- # s HHJr c # K t } | | j y # t $ r | j w xY w# | j w xY ww)N) SessionLocal Exceptionrollbackr+ r, s r get_dbr2 ( sJ B
s# A$ A?A AAc ddl m}m} t | j j } || }d|j
vry|j d D ch c] }|d }}d|v ry| j 5 }d|v r|j |d n |j |d ddd yc c}w # t $ r Y yw xY w# t $ r Y (w xY w# 1 sw Y yxY w)
zTAdd users.email_verified for existing databases (existing rows default to verified).r inspecttextusersNnameemail_verified
postgresqlzWALTER TABLE users ADD COLUMN IF NOT EXISTS email_verified BOOLEAN NOT NULL DEFAULT truezFALTER TABLE users ADD COLUMN email_verified BOOLEAN NOT NULL DEFAULT 1)
sqlalchemyr5 r6 strr" lowerget_table_names get_columnsr0 beginexecute)enginer5 r6 r" inspccolsconns r sync_users_email_verified_columnrG 3 s (
fjj/
!Cv $..0 0 #'#3#3G#<=# &
sS C C B<'C > C C<C C
C
C C C C C(c
X ddl m}m} || }d|j vry|j d D ch c] }|d }}ddddddd}|j
D cg c] \ }}||vs ||f } }}| sy| j j d k( }
| j 5 } | D ]C \ }}|
r | j |d
| d | & | j |d | d | E ddd yc c}w # t
$ r Y yw xY wc c}}w # t
$ r Y uw xY w# 1 sw Y yxY w)
z8Add user profile fields used by the user profile screen.r r4 r7 Nr8 z VARCHAR(32)z VARCHAR(512)) phone_numberaddress postal_code
profile_imageotpgoogle_drive_linkr: z+ALTER TABLE users ADD COLUMN IF NOT EXISTS z ALTER TABLE users ADD COLUMN ) r; r5 r6 r> r? r0 itemsdialectr8 r@ rA ) rB r5 r6 rC rD rE additionsr8 ddlmissingis_pgrF s r sync_user_profile_columnsrV T sQ (v $..0 0 #'#3#3G#<=# S !
sc C< C< C7C< " D /D $)D D+D 7C< < DD D D D D D)c ddl m} | j j dk( }| j 5 }|r|j |d n |j |d ddd y# t $ r Y w xY w# 1 sw Y yxY w)z1Indexes for admin list-users ordering/pagination.r )r6 r: zZCREATE INDEX IF NOT EXISTS ix_users_created_at_id_desc ON users (created_at DESC, id DESC)zKCREATE INDEX IF NOT EXISTS ix_users_created_at_id ON users (created_at, id)N)r; r6 rQ r8 r@ rA r0 )rB r6 rU rF s r sync_users_list_indexesrX x s NN < /E 4 LL:
4
!
s) A; A,, A85A;7A88A;;Bc p ddl m} ddl m} ddlm} t
j j t y )Nr )models) models_admin)models_programme)r' ) apprZ r[
app.programmer\ r
metadata
create_allrB )rZ r[ r\ s r init_dbra s .MM & )r c J ddl m} |j j | d y )Nr )UserTrackTraceT)r'
checkfirst)
app.modelsrc __table__create)rB rc s r sync_user_track_traces_tablerh s ) ##D#Ar )r) N)collections.abcr r; r sqlalchemy.ormr r r
app.configr r
r$ rB r/ r- r2 rG rV rX ra rh r r r rl s % $ A A # ? J$
uFK g $
'4-. B!H2*Br