fran1215/fastapi-test

1from fastapi import APIRouter2from config.db import conn3from schemas.msg import MessageEntity, MessageEntityList4from models.msg import Message5from bson import ObjectId6 7msg = APIRouter()8 9@msg.get("/messages")10def find_all_msgs():11    return MessageEntityList(conn.Instant.Mensajes.find())12 13@msg.post("/messages")14def create_msg(msg: Message):15    new_msg = dict(msg)16    17    id = conn.Instant.Mensajes.insert_one(new_msg).inserted_id18    19    return MessageEntity(conn.Instant.Mensajes.find_one({"_id": id}))20 21@msg.get("/messages/{id}")22def find_user_by_id(id: str):23    return MessageEntity(conn.Instant.Mensajes.find_one({"_id": ObjectId(id)}))24 25@msg.put("/messages/{id}")26def update_user(id: str, msg: Message):27    conn.Instant.Mensajes.update_one({"_id": ObjectId(id)}, {"$set": dict(msg)})28    29    return MessageEntity(conn.Instant.Mensajes.find_one({"_id": ObjectId(id)}))30 31@msg.delete("/messages/{id}")32def delete_user(id: str):33    conn.Instant.Mensajes.delete_one({"_id": ObjectId(id)})34 35    return "Deleted successfully"