U jؘ@sddlmZmZddlmZmZddlmZmZddlm Z m Z ddl Z ddl m Z ddlmZdd lmZdd lmZmZmZmZdd lmZdd lmZmZdd lmZmZddgZdZ dZ!ej"ddgddddZ#ej"ddgdeddZ$ej"ddgdeddZ%ej"d dgded!d"Z&ej"d#dgded$d%Z'ej"d&ddgdd'd(Z(ej"d)dgdd*d+Z)d,d-Z*d.d/Z+d0d1Z,d2d3Z-dS)4)requestjsonify) jwt_requiredget_jwt_identity)datetime timedelta) credentials messagingN) DESCENDING)ObjectId)notifications_bp)get_dbSERVICES_DB_MAPUSER_DATABASE_NAMEinsert_log_in_user_history)etiqueta_centro)subscribe_token_to_topicsend_topic_notification)enviar_alerta_whatsappenviar_mensaje_prueba_waZ 56976494291Z 56935741906ITG_CHILE_WHATSAPP_SECUREZ evento_centroz8//ingest_notifications///POSTF)methodsstrict_slashesc8 CsF|}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)}t| ||||}|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:}-|-rt|-d;ddd}.t|.dd?|/WYqW5d}/~/XYnXq|&std@|!dA| g}0g}1|&r|&D]}2t|2tdBt| |||| iddC}3d}4|3dDdEkrr|3d i}5dF|5krrt|5dFdGkrr|5dFdGd}4|2|4dHt dI}6|1|6|0|2|3dD|4|3d dJq|1r|r|jd}7| jdK|7idL|1dHdMitdN|||0dOdfWStk 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 Jsz(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?wamidrE timestamp)numerorErIr"_id$set)Z whatsapp_logZdelivery_statuszNotificaciones procesadas)r! inserted_ids push_statusZwhatsapp_statuszError: Error interno) lowerrgetrreplace capitalizerjson isinstancedictlistvaluesrrnowupperappendnotificaciones insert_manyrNrrrfindr/striplen ExceptionprintrPLANTILLA_NANOOX update_one)8SERVICEREGIONAREACENTRO service_keytarget_db_nameZr_normZa_normZc_normZcentro_id_unificadoZ received_dataclientdbZdocs_to_insertitemdocresultrNZultimo_mensajeZid_jaulaZ event_timeZ emoji_statusZ color_hexZ msg_lowerZnombre_visibleZtitulo_eleganteZcuerpo_eleganterOdb_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_dbrKrErIZ data_resp log_entryZ last_alert_idr.r.r2ingest_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(r7limit2hours)rz$gtez$in)r)r(z$Acceso denegado al centro solicitado)r"r!r^r)cSs |ddS)Nr)r)rS)xr.r.r2<z#get_notifications..T)keyreversecSsi|]}|d|qS)rLr.)r0rpr.r.r2 @sz%get_notifications..notificaciones_lecturasr8 user_emailr8r rLr$r,r&read)userr~zError en GET: r5rQ)r"obtener_centros_permitidos_usuariorrargsrSintrr[rrrrRrYrZr`sortr rextendrckeyssetaddr/rWrXr]rbrd)current_usernameZallowed_centersZ req_centro_idZ service_reqrZhours_lookbackZutc_nowZ cutoff_timequeryrmZ raw_resultsZ target_dbZ dbs_to_searchdb_namecolcursorZ final_sliceZ notif_ids_mapZ list_of_idsZread_setZ reads_cursorr response_datarpZdoc_oidr,rzr.r.r2get_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 tokenr r<rBrMrzError suscribiendo: NrFUsuario z suscrito a z centros.)rEr!Ztopicsr-r5rQ)rrget_jsonrSrrrrf%obtener_todos_los_topicos_del_sistemafind_oneverificar_permiso_inversor]rrbrcrdr/) rr"rrmtopicos_permitidosZ set_universouser_docZtopicZ suscritostrzr.r.r2subscribe_devicepsD         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 requeridor u.👋 [LOGOUT] Iniciando limpieza para usuario rr r<rBz$unsetru✅ [LOGOUT] Token limpiado de z temas y eliminado de DB.zToken limpiador-zError en logout_push: r5rQN)rrrrSrrdrr Zunsubscribe_from_topicZ success_countrrrfrcr/) rr"rZtodos_los_temasr~Ztemaresponsermrzr.r.r2logout_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álidor uServicio no válidoruFalta el parámetro user_emailrLr )r(r+u(La notificación ha expirado o no existerrMr()r8rr(Zread_atT)upsertCreatedZUpdatedz[ACK] z -> Notif z ()historial_usersemailrB Desconocidor+zAlerta sin texto)r7rDr+read_notificationz%Error escribiendo historial usuario: NrFz Lectura registrada correctamente)rEr!actionr-zError en ACK: zError interno del servidor)r!r5rQ)r is_validrrRrrSrrr^rrrfrr[ upserted_idrdrr<r\rrcr/)rgZNOTIFICATION_IDrkrlrrmrnZ notif_existsrqrrr col_historyr real_usernamelog_datarzr.r.r2acknowledge_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.) ForbiddenrrentryrchangesvalueZstatusesrEr$Z recipient_idrJz [WHATSAPP] z -> Estado: zwhatsapp_log.wamidrM)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/rarWrXitemsrTrY)r"Z target_phonekvZdb_phoneroexiste_telefono_en_estructurar.r2rs       z7whatsapp_webhook..existe_telefono_en_estructurar )rBr?r>r>rBrZWHATSAPPuNotificación ExternaZ message_readru leyó la alerta.)r7rDrZ 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-)rmethodosenvironrSrrdrVrrYrrZr^rfrr[modified_countrr`rrc)Z VERIFY_TOKENmodetoken challenger"rrrrmrEZ new_statusZwa_idZ numero_metarJZ target_dbsrrnZ col_notifrqrrrsrZ cursor_usersZusuario_encontradour>rrrzr.rr2whatsapp_webhookDs                 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 rErFr-r zError en ruta de WhatsApp: r!rPrQN)rrrcrd)rK resultadorzr.r.r2trigger_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'] rBr>FrETrrr r) rrr<rrSrrWrXsplitrbrUr])rBrm users_colrZcentros_permitidosr>regionareasarea centros_dict centro_raw servicios tiene_accesosrvr"partsc_namea_namer_nameZ formatted_idr.r.r2rs6        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<rBr>FrETrrrr rzError obteniendo permisos para rCN) rrrrSrrWrXrrbrUr]rcrd)rBrmrrrr>rrrrrrrrr"rrrrZ topic_fmtrzr.r.r2obtener_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`rSrrrbrUr)rmrZtodos_los_topicosrrr>rrrcentrosr_rcarr.r.r2r<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>rETz'Error verificando permiso inverso para rCN) rrbrRrSrrWrXrcrd)rZ topic_strrZr_topicZa_topicZc_topicrtrurvZdb_centro_key_reversedr> datos_centroservicioinforzr.r.r2rYs(     r).flaskrrflask_jwt_extendedrrrrZfirebase_adminrr Zpytzpymongor bsonr rr shared_db_utilsrrrrblueprints.etiquetasrZ push_servicerrZwhatsapp_servicerrZ PHONE_TO_SENDrrerouter|rrrrrrrrrrr.r.r.r2sL     k l ? / `  )5