U ^j@sddlmZmZddlmZmZddlmZmZddlm Z m Z ddl Z ddl m Z ddlmZdd lmZdd lmZmZmZmZdd lmZmZdd lmZmZd dgZdZdZej ddgddddZ!ej ddgdeddZ"ej ddgdeddZ#ej ddgded d!Z$ej d"dgded#d$Z%ej d%ddgdd&d'Z&ej d(dgdd)d*Z'd+d,Z(d-d.Z)d/d0Z*d1d2Z+dS)3)requestjsonify) jwt_requiredget_jwt_identity)datetime timedelta) credentials messagingN) DESCENDING)ObjectId)notifications_bp)get_dbSERVICES_DB_MAPUSER_DATABASE_NAMEinsert_log_in_user_history)subscribe_token_to_topicsend_topic_notification)enviar_alerta_whatsappenviar_mensaje_prueba_waZ 56976494291Z 56935741906ITG_CHILE_WHATSAPP_SECUREZ evento_centroz8//ingest_notifications///POSTF)methodsstrict_slashesc7 Cs*|}t|}|s.tdd|didfSz|dddd}|dddd}|dddd}|d|d|} tj} | stddid fWSt| t rt | } t| t std d id fWSt } | |} g} | D]L}| t d ||d dd|dd|dddd}| |q| sXtd didfWS| j| }dd|jD}| dd}| ddd}| ddd}d}d}|}d |ksd!|ksd"|ksd#|krd$}d%}nd&|ksd'|krd(}d)}|d|d*|}|d*|d+|d,}t| ||||d| d-d.|d/d0d1}| t}|d2}|}|}|d|d|}|} d3|d4|d4|d4| }!|!d5}"|!d6}#||"d7|#d7dd8i}$g}%|$D]}&z|&d9i}'|'|i}(|(|i})|)|i}*|*| i}+|+d:},|,rvt|,d;ddd}-t|-dd?|.WYqW5d}.~.XYnXq|%std@| dA|g}/g}0|%r|%D]}1t|1tdB| iddC}2d}3|2dDdEkrV|2d i}4dF|4krVt|4dFdGkrV|4dFdGd}3|1|3dHt dI}5|0|5|/|1|2dD|3|2d dJq|0r|r|jd}6| jdK|6idL|0dHdMitdN|||/dOdfWStk r$}.z&tdP|.tddQidRfWYSd}.~.XYnXdS)SNmensajez Servicio 'z' no soportado. -z Sin datosmsgzSe espera lista o dictzAlerta datauAlerta sin descripcióncriticalidZ unknown_idtime)local_id local_time) centro_idserver_timestamptitlemessageZseverityraw_datazNo hay alertascSsg|] }t|qS)str).0oidr-r-A/var/www/itgmanager/itgmanager/blueprints/notifications/routes.py Isz(ingest_notifications..r*r+r%r&u⚠️z#FFA500Zfalloerrorucríticoupérdidau🚨z#FF0000okZ restablecidou✅z#00FF00z - z registrado a las z de hoyZFCM_PLUGIN_ACTIVITY)servicenotification_idr'Z click_actionZalerts_channel)colorZandroid_channel_id)r'r)bodyZ data_payload extra_kwargsusersz permisos..z.statusz.phoneT)z$existsz$nepermisosphone+u' Error extrayendo teléfono de usuario username: z5 Info: Nadie tiene configurado recibir WhatsApp para z en centro)Znumero_destinoZnombre_plantillaZ header_varsZ body_varsstatussuccessmessagesrsent)r>wamidrD timestamp)numerorDrHr!_id$set)Z whatsapp_logZdelivery_statuszNotificaciones procesadas)r inserted_ids push_statusZwhatsapp_statuszError: Error interno)lowerrgetrreplace capitalizerjson isinstancedictlistvaluesrrnowupperappendnotificaciones insert_manyrMrrfindr.striplen ExceptionprintrPLANTILLA_NANOOX update_one)7SERVICEREGIONAREACENTRO service_keytarget_db_nameZr_normZa_normZc_normZcentro_id_unificadoZ received_dataclientdbZdocs_to_insertitemdocresultrMZultimo_mensajeZid_jaulaZ event_timeZ emoji_statusZ color_hexZ msg_lowerZtitulo_eleganteZcuerpo_eleganterNdb_users col_usersr_keya_keyc_keyZs_keyZpath_to_serviceZ path_statusZ path_phoneZusuarios_destinatariosZ lista_numerosusuarior= region_data area_dataZ centro_dataZ servicio_dataZtelefonoZtelefono_limpioeZwhatsapp_resultsZwhatsapp_log_dbrJrDrHZ data_resp log_entryZ last_alert_idr-r-r1ingest_notificationss           (                r{z/api/notificationsGET)rc Cszzt}t|}|s.tgddiddfWStjd}tjd}ttjdd}ttjd d }t}|t |d }d |id |id}|r||kr||d<ntgdddfWSt } g} |rt | } | r| gng} n t t } | D]V} z6| | d}||dt|}| t |Wqtk rLYqYqXq| jdddd| d|}dd|D}t |}t}| D]Z} z@| | dd |i|dddi}|D]}||dqWnYqYnXqg}|D]h}|d}t||d<|d i}t|tr8|d!d|d!<nd|d!<|d=||k|d"<||qt||t|d#ddfWStk r}z*td$|td%t|id&fWYSd}~XYnXdS)'Ncountr)r!Z query_infor,r'r6limit2hours)rz$gtez$in)r(r'z$Acceso denegado al centro solicitado)r!r r]r(cSs |ddS)Nr(r)rR)xr-r-r1:z#get_notifications..T)keyreversecSsi|]}|d|qS)rKr-)r/ror-r-r1 >sz%get_notifications..notificaciones_lecturasr7 user_emailr7r rKr#r+r%read)userr}zError en GET: r4rP)r"obtener_centros_permitidos_usuariorrargsrRintrrZrrrrQrXrYr_sortr r~extendrbkeyssetaddr.rVrWr\rarc)current_usernameZallowed_centersZ req_centro_idZ service_reqr~Zhours_lookbackZutc_nowZ cutoff_timequeryrlZ raw_resultsZ target_dbZ dbs_to_searchdb_namecolcursorZ final_sliceZ notif_ids_mapZ list_of_idsZread_setZ reads_cursorr response_dataroZdoc_oidr+ryr-r-r1get_notificationss             rz/api/notifications/subscribec CsVzt}t}|d}|s2tddidfWSt}|tdd|idd|iig}t}|td d|i}|D]}t ||r|| |q|d}|rz"|D]} t |g| qt |}Wn0tk r} ztd | W5d } ~ XYnXtd d |d |d|ddfWStk rP} ztdt| idfWYSd } ~ XYnXd S)u/ Vía Correcta: 1. Recibe un token (que asumimos es NUEVO o VÁLIDO para este usuario). 2. Calcula permisos reales en DB. 3. Suscribe SOLO a los permisos reales. NO intenta desuscribir de lo prohibido, porque confiamos en que el token es fresco o exclusivo de este usuario. fcm_tokenr z Falta tokenrr;rArLrzError suscribiendo: NrEUsuario z suscrito a z centros.)rDr Ztopicsr,r4rP)rrget_jsonrRrrrre%obtener_todos_los_topicos_del_sistemafind_oneverificar_permiso_inversor\rrarbrcr.) rr!rrltopicos_permitidosZ set_universouser_docZtopicZ suscritostryr-r-r1subscribe_devicensD         rz/api/logout_pushc Cszt}t}|d}|s0tddidfWStd|t}d}|r|D]6}z$t|g|}|j dkrv|d7}WqPYqPXqPt }|t d d |id dd iitd |d tddidfWSt k r}z*td|tdt|idfWYSd}~XYnXdS)u Ruta de LIMPIEZA: Recibe el token que se va a destruir y fuerza la desuscripción de todos los tópicos del sistema. rr zToken requeridoru.👋 [LOGOUT] Iniciando limpieza para usuario rr r;rAz$unsetru✅ [LOGOUT] Token limpiado de z temas y eliminado de DB.zToken limpiador,zError en logout_push: r4rPN)rrrrRrrcrr Zunsubscribe_from_topicZ success_countrrrerbr.) rr!rZtodos_los_temasr}Ztemaresponserlryr-r-r1logout_push_devices6     rz /ack//c Cszt|s tddidfWS|}t|}|sHtddidfWSt}|sdtddidfWSt}||}|j dt|iddd }|stdd idfWS|j j t||d d t|||d t didd}|jrdnd} td|d|d| d|jrzt|t} | d} | j d|iddi} | rNd| krN| dn|} ||d d|ddd}t| | |dWn2tk r}ztd|W5d }~XYnXtd!d"| d#d$fWStk r}z,td%|td&t|d'd(fWYSd }~XYnXd S))u Registra la lectura ('firma') de un usuario sobre una notificación. Simula el evento "Usuario hizo clic en la alerta". r uID de notificación inválidoruServicio no válidoruFalta el parámetro user_emailrKr )r'r*u(La notificación ha expirado o no existerrLr')r7rr'Zread_atT)upsertCreatedZUpdatedz[ACK] z -> Notif z ()historial_usersemailrA Desconocidor*zAlerta sin texto)r6rCr*read_notificationz%Error escribiendo historial usuario: NrEz Lectura registrada correctamente)rDr actionr,zError en ACK: zError interno del servidor)r r4rP)r is_validrrQrrRrrr]rrrerrZ upserted_idrcrr;r[rrbr.)rfZNOTIFICATION_IDrjrkrrlrmZ notif_existsrprrq col_historyr real_usernamelog_dataryr-r-r1acknowledge_notificationsz     rz/whatsapp/webhookc sxtjdkrltjdd}tjd}tjd}tjd}|dkr\||kr\td|d fStd d Sntjd krttj}z|d igd}|digd}|di}d|kr:t}|dD]l} | d} | d} | d} | d} td| d| t t }|D]R}||}|j }| d| id| tdi}|jdkrtd|qjq| dkr|t}|d}|d}fdd |id!d!d!d"}d}|D],}|d#}|r|| r|}qq|r(|d$d%}d&d'd(| d)|d*d+}t|||d,td-|qtd.| d/qWn2tk rn}ztd0|W5d}~XYnXd1SdS)2Nr|rZ tu_token_aquizhub.modezhub.verify_tokenz hub.challengeZ subscribez1[WEBHOOK] Meta ha verificado la URL exitosamente.r,u+[WEBHOOK] Intento de verificación fallido.) ForbiddenrrentryrchangesvalueZstatusesrDr#Z recipient_idrIz [WHATSAPP] z -> Estado: zwhatsapp_log.wamidrL)zwhatsapp_log.$.statuszwhatsapp_log.$.updated_atz# [DB UPDATE] Alerta actualizada en rr;rcst|}t|tr~|D]\\}}|dkr\|r\t|dddd}||kr\dSt|ttfr||rdSqn$t|tr|D]}||rdSqdS)Nr>r?rrTF)r.r`rVrWitemsrSrX)r!Z target_phonekvZdb_phonernexiste_telefono_en_estructurar-r1rs       z7whatsapp_webhook..existe_telefono_en_estructurar )rAr>r=r=rArZWHATSAPPuNotificación ExternaZ message_readru leyó la alerta.)r6rCrZ message_iddetailsru,[HISTORIAL] ÉXITO: Registrado 'Visto' para u [HISTORIAL] Teléfono u4 reportó lectura pero no se encontró dueño en DB.z [WEBHOOK ERROR] Procesando: )ZEVENT_RECEIVEDr,)rmethodosenvironrRrrcrUrrXrrYr]rerrZmodified_countrr_rrb)Z VERIFY_TOKENmodetoken challenger!rrrrlrDZ new_statusZwa_idZ numero_metarIZ target_dbsrrmZ col_notifrprqrrrZ cursor_usersZusuario_encontradour=rrryr-rr1whatsapp_webhookBs                 rz/test-whatsapp/c Cs~z4t|}|ddkr$t|dfWSt|dfWSWnDtk rx}z&td|tddidfWYSd }~XYnXd S) u Ruta de prueba. Se usa GET para poder ejecutarla fácilmente desde la barra de direcciones del navegador. Ejemplo: https://test.itgchile.com/itg_7xR9L2m_secure/test-whatsapp/56912345678 rDrEr,rzError en ruta de WhatsApp: r rOrPN)rrrbrc)rJ resultadoryr-r-r1trigger_whatsapp_tests rc Cst}|tj}|d|i}|r*d|kr.gSg}|di}|D]\}}|D]\}} | D]\} } d} | D](\} }t|trz|ddkrzd} qqz| rfz^| d}t |dkr|d }|d  }|d  }|d|d|}| |WqfYqfXqfqVqF|S) z Retorna una lista de IDs de centros (formato Topic) permitidos para el usuario. Ej: ['Loslagos-Puertomontt-Itg', 'Aysen-Aysen-Puntacola'] rAr=FrDTrrr r) rrr;rrRrrVrWsplitrarTr\)rArl users_colrZcentros_permitidosr=regionareasarea centros_dict centro_raw servicios tiene_accesosrvr!partsc_namea_namer_nameZ formatted_idr-r-r1rs6        rc Cspz(t}|td}|d|i}|r0d|kr6gWSg}|di}|D]\}}|D]\}} | D]\} } d} | D](\} }t|tr|ddkrd} qq| rnz^| d}t|dkr |d  }|d  }|d  }|d|d|}| |WqnYqnYqnXqnq^qN|WSt k rj}z t d |d |gWYSd}~XYnXdS)u Consulta la DB y retorna una lista de los tópicos (Centros) a los que el usuario tiene acceso real. Retorna ej: ['Loslagos-Puertomontt-Itg', 'Aysen-Aysen-Puntacola'] r;rAr=FrDTrrrr rzError obteniendo permisos para rBN) rrrrRrrVrWrrarTr\rbrc)rArlrrrr=rrrrrrrrr!rrrrZ topic_fmtryr-r-r1obtener_topicos_permitidoss>       rc Cst}|td}t}|iddi}|D]}|di}|D]\}}|D]\}} | D]n\} } zX| d} t| dkr| d} | d}| d}| |d|d| WqdYqdXqdqTqDq,|S)u Escanea la colección de usuarios para descubrir TODOS los centros (tópicos) que existen. Retorna un SET con strings tipo 'Loslagos-Puertomontt-Itg'. r;r=r rrrr) rrrr_rRrrrarTr)rlrZtodos_los_topicosrrr=rrrcentrosr_rcarr-r-r1r:s&       rc Csz|d}t|dkrWdS|\}}}|}|}|}|d|d|} |di} | |i|i| } | sWdS| D](\} } t| tr| ddkrWdSqWdStk r}ztd|d|WYdSd }~XYnXd S) u Recibe un Tópico: "Loslagos-Puertomontt-Itg" Lo transforma a Key DB: "itg-puertomontt-loslagos" (Al revés y minúsculas) Y verifica si existe en los permisos del usuario. rrFr=rDTz'Error verificando permiso inverso para rBN) rrarQrRrrVrWrbrc)rZ topic_strrZr_topicZa_topicZc_topicrsrtruZdb_centro_key_reversedr= datos_centroservicioinforyr-r-r1rWs(     r),flaskrrflask_jwt_extendedrrrrZfirebase_adminrr Zpytzpymongor bsonr rr shared_db_utilsrrrrZ push_servicerrZwhatsapp_servicerrZ PHONE_TO_SENDrrdrouter{rrrrrrrrrrr-r-r-r1sJ    j l ? / `  )5