o h\l@sddlmZmZmZmZddlmZddlmZddlZddl Z ddl Z ddl Z ddl Z e j e jde eZeeZdejd<dejd <d ejd <d Ze jd ZeeZGdddejZGdddejZGdddejZdLddZddZddZddZ ddZ!ddZ"d d!Z#d"d#Z$d$d%Z%d&d'Z&ej'd(d)gd*d+d,Z(e'd-d.d/Z)e'd0d1d2Z*e'd3d4d5Z+e'd6d7d8Z,e'd9d:d;Z-e'd<d=d>Z.ej'd?d)gd*d@dAZ/e'dBdCdDZ0dEdFZ1e1edGkrej2dHdIdJdKdSdS)M)Flaskrequestjsonifyrender_template) SQLAlchemy)datetimeN)levelzmssql+pyodbc://sa:Sistemas123*%2F@194.163.45.32:1433/RappiWebhooks?driver=ODBC+Driver+17+for+SQL+Server&TrustServerCertificate=yes&Encrypt=yes&timeout=30SQLALCHEMY_DATABASE_URIFSQLALCHEMY_TRACK_MODIFICATIONSwebhooks_secret_2025 SECRET_KEYzhttps://cierresmig.onlineRAPPI_WEBHOOK_SECRETc@seZdZdZejejddZejedddZ eedZ eedZ eedZ ejej ddZejejejdZeed ZejejddZejejddZeej Zd S) WebhookEvent WebhookEventsT primary_key2Fnullableddefault-N)__name__ __module__ __qualname__ __tablename__dbColumnIntegeridString evento_tipoorder_idstore_id event_nameText datos_jsonDateTimerutcnowfecha_recepcion ip_origenBoolean firma_valida procesadoerror_procesamientor0r0/var/www/html/Webhooks/app.pyr#src@seZdZdZejejddZeejedZ eje dddZ ee dZ ee dZ ee dZee dZee d ZeejZeejZejejejd Zd S) RappiEventDetailRappiEventDetailsTrzWebhookEvents.idrFrrrN)rrrrrrrr ForeignKeywebhook_event_idr! event_typer#r$r% event_timemessager& courier_dataadditional_infor(rr)fecha_procesamientor0r0r0r1r22s  r2c@s~eZdZdZejejddZejedddZ eej Z eedZ eedZ ejejejdZeej Zd S) SystemLog SystemLogsTrINFOrrrN)rrrrrrrr r!rr&r9endpoint ip_addressr(rr) timestampadditional_datar0r0r0r1r=As r=c Csz.t|||tr tjnd|rt|ndd}tj|tjt d|d|WdSt yI}zt d|WYd}~dSd}~ww)zRegistrar eventos del sistemaN)rr9rArBrD[z] zError logging system event: ) r=r remote_addrjsondumpsrsessionaddcommitloggerinfo Exceptionerror)rr9rArD log_entryer0r0r1log_system_eventNs   rRc Cstr|sdSzH|d}d}d}|D]}|dd\}}|dkr#|}q|dkr)|}q|r.|s1WdS|d|}ttd |d tj} t|| WSt yi} zt d | WYd} ~ dSd} ~ ww) z,Validar la firma de Rappi usando HMAC SHA256F,N=tsign.zutf-8zError validating signature: ) r splithmacnewencodehashlibsha256 hexdigestcompare_digestrNrLrO) payload_bodysignature_headerpartsrC signaturepartkeyvaluesigned_payloadexpected_signaturerQr0r0r1validate_rappi_signature_s: rjc Csztd|d|vrt|dkrtdWdSd|vr?d|vr?|dd}d|vr7td Wd Std Wd Sd|vrUd|vrUt|dkrUtd Wd Sd|vr}d|vr}d|vr}|dd}d|vrutdWdStdWdSd|vrd|vrd|vrd|vrtdWdSd|vrd|vrtdWdSd|vrd|vrd|vrd|vrtdWd Std!t|Wd"Sty}zt d#|WYd$}~d"Sd$}~ww)%uEIdentificar el tipo de evento basándose en la estructura del payloadz"Identificando evento con payload: r$rUzEvento identificado como PINGPINGr9approvedz&Evento identificado como MENU_APPROVED MENU_APPROVEDz4Evento identificado como MENU_REJECTED (con mensaje) MENU_REJECTEDz4Evento identificado como MENU_REJECTED (sin mensaje)r#eventcancelz+Evento identificado como ORDER_EVENT_CANCELORDER_EVENT_CANCELz6Evento identificado como ORDER_OTHER_EVENT (por event)ORDER_OTHER_EVENTr8additional_informationz5Evento identificado como ORDER_OTHER_EVENT (completo)external_store_idenabledz+Evento identificado como STORE_CONNECTIVITYSTORE_CONNECTIVITYlatlng eta_in_millisz*Evento identificado como ORDER_RT_TRACKINGORDER_RT_TRACKINGz0No se pudo identificar el tipo de evento. Keys: UNKNOWNz$Error identificando tipo de evento: N) rLrMlengetlowerwarninglistkeysrNrO) webhook_datar9r%rQr0r0r1identify_event_typesP         rc Csz3|d}|d}|d}|stdtd|||d}tj|tdd|||d d Wd StyH}z t d |d }~ww)z"Procesar evento ORDER_EVENT_CANCELr#r$rpzNo se pudo obtener order_idrr)r7r#r$r%r@uCancelación procesada: )rpr$rDTz%Error processing ORDER_EVENT_CANCEL: N) r~ ValueErrorr2rrIrJrRrNrLrO)rr#r$r% event_detailrQr0r0r1process_order_event_cancels,     rc CszH|d}|d}|d}|d}|di}|d}td|||||r-t|ndt|d }tj|td d |d |Wd Sty]}z t d|d}~ww)z!Procesar evento ORDER_OTHER_EVENTr#r$rpr8rtr:rsN)r7r#r$r%r8r:r;r@zEvento de orden procesado: z - Tz$Error processing ORDER_OTHER_EVENT: r~r2rGrHrrIrJrRrNrLrO) rr#r$r%r8rtr:rrQr0r0r1process_order_other_events0       rc Cspz"|d}|d}td||d}tj|tdd|WdSty7}z td|d }~ww) zProcesar evento MENU_APPROVEDr$r9rn)r7r$r9r@uMenú aprobado para tienda: Tz Error processing MENU_APPROVED: N r~r2rrIrJrRrNrLrO)rr$r9rrQr0r0r1process_menu_approveds    rc Cdz|d}td|d}tj|tdd|WdSty1}z td|d}~ww) zProcesar evento MENU_REJECTEDr$ror7r$r@uMenú rechazado para tienda: Tz Error processing MENU_REJECTED: Nrrr$rrQr0r0r1process_menu_rejected  rc Cr) zProcesar evento PINGr$rkrr@zPing recibido para tienda: TzError processing PING: Nrrr0r0r1 process_ping"rrc Csz6|d}|d}|d}td||td|id}tj||r'dnd}tdd |d |Wd StyK}z t d |d }~ww)z"Procesar evento STORE_CONNECTIVITYrurvr9rw)r7r$r9r; habilitada deshabilitadar@zTienda  Tz%Error processing STORE_CONNECTIVITY: Nr)rr$rvr9rstatusrQr0r0r1process_store_connectivity6s&      rc CszL|d}|d}|d}|d|d|d|d|dd }td t|t|t|td|id }tj|td d |WdSt ya}z t d|d}~ww)z!Procesar evento ORDER_RT_TRACKINGr#r$ courier_idrxryrzeta_type created_at)rxryrzrrr{)r7r#r$r;r:r@z!Tracking actualizado para orden: Tz$Error processing ORDER_RT_TRACKING: N) r~r2strrGrHrrIrJrRrNrLrO)rr#r$r tracking_inforrQr0r0r1process_order_rt_trackingOs2     r/webhook/rappiPOST)methodsc Csxztjdd}tjd}tjdd}tdddd t|id d}trEndpoint para probar manualmente la identificación de eventosrOzNo JSON data providedrT)ridentified_event_typerrr4N)rrrrrrrNr) test_datar7rQr0r0r1test_webhook_manuals   rz/configcCs ttdttdgddS)uMostrar configuración actualrTr)r has_secretdatabase_connectedsupported_events)rrrr r0r0r0r1 show_configs rc Csz.tttdtdddtdidWdWdS1s'wYWdStyC}z t d|d}~ww) zInicializar base de datosz(Base de datos inicializada correctamenter@zSistema de webhooks iniciadorrrNz#Error inicializando base de datos: ) app app_contextr create_allrLrMrRrrNrO)rQr0r0r1 init_databases   &r__main__z0.0.0.0iT)hostportdebug)NN)3flaskrrrrflask_sqlalchemyrrrGosr]rZlogging basicConfigr@ getLoggerrrLrconfigrenvironr~r rModelrr2r=rRrjrrrrrrrrrouterrrrrrrrrrrunr0r0r0r1sn       "<#   $ ' !  1