o g @sddlmZddlmZddlmZmZddlmZddl m Z ddl m Z ddl Z e dZd ed ed ed ed ef ddZd ededed eefddZd ed ed eefddZd ed ed efddZd eded eefddZdS))List)Session)funccase)Message)ExpoPushNotificationService)UserN adimsayardb sender_id receiver_idcontentreturnc Cs8t|||d}|||||zi|ttj|k}t d||rA|j p1dd|j p7d }|s@d}n t d|dd}|dd t|d krYd nd}tj||d ||d ||j|d dddt d|d|W|Sty}zt dt|WYd}~|Sd}~ww)zU Creates a new message record in the database and sends a push notification. )r r r zSender:  ZSomeonezSender with id z not foundN2z...zNew message from messageT)typer message_idZconversation_idZis_chat new_message)r user_idtitlerdatanotification_typez Message notification sent: user z to z"Message push notification failed: )raddcommitrefreshqueryrfilteridfirstloggerinfo first_name last_namestriperrorlenrsend_push_to_user Exceptionstr) r r r r rsenderZ sender_nameZpreviewer-$/app/app/services/message_service.pycreate_message sF   r/user1_iduser2_idcCs@|ttj|ktj|k@tj|ktj|k@BtjS)zS Retrieves all messages exchanged between two users, ordered by sent time. )rrrr r order_bysent_atall)r r0r1r-r-r.get_messages_between_users;s  r5cCs*|ttj|ktjdktjS)z9 Retrieves all unread messages for the receiver. F)rrrr is_readr2r3r4)r r r-r-r.get_unread_messagesDs  r7cCsF|ttj|ktj|ktjdk}|D]}d|_q||S)zS Marks all messages from a specific sender as read for the given receiver. FT)rrrr r r6r4r)r r r messagesmsgr-r-r.mark_messages_as_readMs r:rcCs|ttjdttj|ktjftjdd tj|ktj|kB d }|t |tj|j jktj|ktj|j jk@tj|ktj|j jk@B@tj}|S)u Retrieves conversation threads for the given user. 각 스레드는 대화 상대(친구)와의 최신 메시지를 포함합니다. latest_sent_at)else_ friend_id)rrmaxrr3labelrr r rgroup_bysubqueryjoincr;r=r2descr4)r rrAthreadsr-r-r.get_conversation_threads[s6   rF)typingrsqlalchemy.ormr sqlalchemyrrZapp.models.messager+app.services.expo_push_notification_servicerapp.models.userrlogging getLoggerr!intr*r/r5r7r:rFr-r-r-r.s      /