o zgF @sddlmZddlmZmZmZddlmZddlm Z m Z ddl m Z ddl mZmZddlmZddlmZeZejd ed ee jee jfd ed efd dZejd eed ee jee jfded efddZejdeed ee jee jfd efddZejdeed ee jee jfd efddZejdeed ee jee jfded efddZejdeed ee jee jfded efddZdS) )List) APIRouterDepends HTTPException)Session)funccase)deps) MessageCreateMessageResponse)Message)message_service/)response_modelpayloaddbcCst||j|j|j}|S)z Allows the currently logged-in user to send a new message. The sender_id is derived from the authenticated user's ID, and the message is saved based on the receiver_id and content from the payload. )r Zcreate_messageid receiver_idcontent)rr current_usermessager%/app/app/api/v1/endpoints/messages.py send_message s r friend_idcC$t||j|}|stddd|S)zS Retrieves the conversation history between the current user and a friend. No conversation found status_codedetailr Zget_messages_between_usersrrrrrmessagesrrr get_messages  r$z/unreadcCstj||jd}|S)zG Retrieves all unread messages for the current logged-in user. )r)r get_unread_messagesr)rrZunreadrrrr&)sr&z/threadscCs"t||j}|stddd|S)u 로그인한 사용자가 참여하는 모든 대화 스레드를 조회합니다. 각 스레드는 해당 대화 상대(친구)와의 최신 메시지를 포함합니다. rzNo conversations found.r)r get_conversation_threadsrr)rrthreadsrrrr'4s  r'z/conversation/{friend_id}cCr)zd Retrieves the full conversation history between the current user and the specified friend. rrrr!r"rrrget_conversation_with_userBr%r)z/read sender_idcCstj||j|d}|S)u POST /api/v1/messages/read 현재 로그인한 사용자의, 특정 발신자(sender_id)로부터 온 메시지를 읽음 처리합니다. )rr*)r Zmark_messages_as_readr)r*rrZupdated_messagesrrrmark_messages_as_read_endpointPs r+N) typingrfastapirrrsqlalchemy.ormr sqlalchemyrrZapp.apir Zapp.schemas.messager r Zapp.models.messager Z app.servicesr routerpostget_dbget_current_userrgetintr$r&r'r)r+rrrrsj