o h= @sdZddlZddlmZddlmZddlmZmZddlm Z m Z m Z m Z m Z ddlmZddlmZdd lmZdd lmZmZdd lmZdd lmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&dd l'm(Z(m)Z)m*Z*e+e,Z-e ddgdZ.iZ/iZ0dade1de2de3fddZ4dade1de5de2fddZ6e.j7de egde efdefddZ8e.j7de egde efde1defd d!Z9e.j:d"e egde efdefd#d$Z;dd%lmd&e egde efde1d'e2d(ed7e%d,e ee efd-e&d4edede%fd:d;ZDe.j:dd?ZEe.j7d@e"d,ddAe ee efdBe2dCe2dDedede"f dEdFZFe.j7dGe%d,e ee efdHe2dDedede%fdIdJZGe.j:d@e%d,e ee efd-edDedede%fdKdLZHe.j>dGe%d,e ee efdHe2d-edDedede%f dMdNZIe.jJdGed,e ee efdHe2dDededefdOdPZKe.j7dQed,defdRdSZLe.j:dTe!d,e efdUedede!fdVdWZMe.j7dTe!d,e dXdYdZe efd[e1dede!fd\d]ZNe.j:d^e!d,e efdUedede!fd_d`ZOdS)bzu Authentication and user management API endpoints. Handles registration, login, logout, and user profile management. N)List) lru_cache)datetime timedelta) APIRouterDepends HTTPExceptionstatusQuery)Session)settings)get_db)get_current_admin_userget_current_user)User) AdminUserCreateAdminUserUpdateGoogleAuthRequestGoogleAuthCodeRequestGoogleOAuthUrlResponseMessageResponsePasswordChange TokenResponseUserListResponse UserLogin UserRegister UserResponse UserUpdate) AuthService UserServiceGoogleAuthServicez /api/authauthentication)prefixtags cache_keymax_age_minutesreturncCs*|durtj}|tvr dStt|kS)z$Check if cache entry is still valid.NF)r CACHE_TTL_MINUTES _cache_expiryrnow)r$r%r*-/var/www/html/aiguide_backend/routers/auth.py_is_cache_valid"s r,datacCs0|durtj}|t|<tt|dt|<dS)zSet cache entry with expiry.N)minutes)r r' _admin_cacherr)rr()r$r-r%r*r*r+ _set_cache+sr0z /admin/tables) dependenciesdbcs`d}t|ddr t|Sddlm}||j}|}dd|D}d|i}t||dd|S) z6Get list of available database tables for admin panel.available_tables )r%rinspectcSsg|]}|dvr|qS)userspaymentslayerslayer_translationspoispoi_translationsr*).0tabler*r*r+ Az(get_available_tables..tables)r,r/ sqlalchemyr6bindget_table_namesr0)r2r$r6 inspectorrB app_tablesresultr*r*r+get_available_tables4s   rIz/admin/table/{table_name} table_namec s6ddlm}gd}||vrtdddznddlm}||j}||}dd |D}||d |d }|} g} | D]9} t| d rP| t | j q@t| d r]| | q@i} t |D]\} }| t| krs| | | |<qc| | q@||| t| dWSty}z tddt|dd}~ww)zGet data from specific table.rtextr7Table not allowed status_codedetailr5cSg|]}|dqSnamer*r>colr*r*r+r@Xz"get_table_data..zSELECT * FROM z LIMIT 100_mapping_asdict)rJcolumnsr- total_rowszError fetching table data: N)rCrLrr6rD get_columnsexecutefetchallhasattrappenddictrXrY enumeratelen Exceptionstr)rJr2rLallowed_tablesr6rF table_columnsrZrHrowsr-rowrow_dicticol_nameer*r*r+get_table_dataIsB          roz/admin/refresh-tablesc s<zddiWSty}z tddt|dd}~ww)z"Refresh table structures and data.messagezTables refreshed successfullyr\zError refreshing tables: rON)rerrf)r2rnr*r*r+refresh_tablesxs rq)DictAnyz%/admin/table/{table_name}/{record_id} record_id update_datac s ddlm}td|d|td|tddd|Dgd }||vr7td d d zdd lm}||j}||}dd|D} i} g} |D]\} } | dkr`qW| | vrj| | qW| | | <qW| rtd dd | dd dd| Dd | std dd g}d|i}| D]\}}| |d||||<qd|dd |d}| |||}| |j dkrtddd dt| dWStyty}z|t|}d|vr%d|vr%d |vr td!d"d#d$d%d&d d'|vrtd!d"d(d)d%d&d td!d"d*d%d+d d,|vs3d-|vr=td!d"d.d/d+d d0|vsKd1|vrUtd!d"d2d3d+d d4|vscd5|vrmtd!d"d6d7d+d td8|d|d9|td:d;d d<}~ww)=z$Update a specific record in a table.rrKu📨 Update request for z record u📋 Update data: u📊 Data types: cSsg|] \}}|t|jfqSr*)type__name__)r>kvr*r*r+r@sz'update_table_record..r7rMrNrOr5cSrRrSr*rUr*r*r+r@rWidzInvalid columns: z, z. Allowed columns: cSsg|]}|dkr|qS)rzr*)r>cr*r*r+r@rAzNo valid fields to updatertz = :zUPDATE z SET z WHERE id = :record_idizRecord not foundzRecord updated successfully)rpupdated_fieldszDuplicate entryzfor keyz users.emailivalidation_erroruMEmail уже используется другим пользователемemailduplicate_value)rvrpfieldcodez users.nameu3Имя пользователя уже занятоrTu;Значение должно быть уникальным)rvrprzforeign key constraintz cannot add or update a child rowu3Связанная запись не найденаforeign_key_errorzcannot be nullznot null constraintuGОбязательное поле не может быть пустымrequired_fieldzinvalid input syntax incorrectu*Неверный формат данныхinvalid_formatzDatabase error updating z: r\uGОшибка обновления записи в базе данныхN)rCrLloggerinfoitemsrr6rDr]rajoinr^commitrowcountlistkeysrerollbackrflowererror)rJrtrur2rLrgr6rFrhrZ valid_updatesinvalid_columnsrxry set_clausesparamscolumnvaluequeryrHrn error_strr*r*r+update_table_records       $            rz /register)response_model user_datacst||}tdi|S)z.Register new user (always created as partner).Nr*)r register_userr)rr2rHr*r*r+registers rz/logincst||S)z User login.)r login_user)rr2r*r*r+login#s rz/logout current_usercst|}tdi|S)z User logout.Nr*)r logout_userr)rr2rHr*r*r+logout)s rz/mecs t|S)zGet current user information.)rfrom_orm)rr*r*r+get_current_user_info4s rcst|||S)zUpdate user information.)rupdate_user_profile)rrr2r*r*r+update_user_info<srz/change-password password_datact|||}tdi|S)zChange user password.Nr*)rchange_passwordr)rrr2rHr*r*r+rFrz /admin/usersdskiplimit current_admincst|||S)zGet all users (admin only).)r get_all_users)rrrr2r*r*r+rRrz/admin/users/{user_id}user_idcst||}t|S)zGet user by ID (admin only).)rget_user_by_idrr)rrr2userr*r*r+r]s  rcst||S)zCreate new user (admin only).)rcreate_user_by_admin)rrr2r*r*r+ create_userhs rcst|||S)zUpdate user (admin only).)rupdate_user_by_admin)rrrr2r*r*r+ update_userrrrcr)zDelete user (admin only).Nr*)rdelete_user_by_adminr)rrr2rHr*r*r+ delete_user}rrz /google/urlcst}t|dS)z#Get Google OAuth authorization URL.auth_url)r get_oauth_urlrrr*r*r+get_google_oauth_urls rz/google/callback auth_datact||tS)z5Handle Google OAuth callback with authorization code.)r handle_oauth_callbackrrr2r*r*r+google_oauth_callbackr.zAuthorization code from Google) descriptionrcs$tdt|d}t||tS)z9Handle Google OAuth callback (GET) with code query param.u'🔄 Google OAuth GET callback received)r)rrrr rr)rr2rr*r*r+google_oauth_callback_gets  rz /google/tokencr)z6Authenticate user with Google ID token (for frontend).)r authenticate_with_tokenrrr*r*r+google_token_authrr)N)P__doc__loggingtypingr functoolsrrrfastapirrrr r sqlalchemy.ormr configr databaser r1rrmodelsrschemasrrrrrrrrrrrrrservicesrrr getLoggerrwrrouterr/r(rfintboolr,rbr0getrIropostrqrrrsputrrrrrrrrrrrdeleterrrrrr*r*r*r+sf      <   .