from fastapi import HTTPException
from app.models import Message
from database.queries.messages import create_conversation, send_message_to_mongodb


async def send(message: Message):
    conversation_url = create_conversation(message.sender, message.receiver)

    if conversation_url is not None:
        success = send_message_to_mongodb(conversation_url, message.sender, message.conversation)

        if success:
            return {"success": True, "message": "Message sent successfully"}
        raise HTTPException(status_code=500, detail="Internal Server Error")

    raise HTTPException(status_code=500, detail="Error creating conversation")