open-webui/backend/apps/web/routers/chats.py

120 lines
3.2 KiB
Python
Raw Normal View History

from fastapi import Depends, Request, HTTPException, status
2023-12-26 06:44:28 +01:00
from datetime import datetime, timedelta
from typing import List, Union, Optional
from utils.utils import get_current_user
2023-12-26 06:44:28 +01:00
from fastapi import APIRouter
from pydantic import BaseModel
2023-12-26 10:27:43 +01:00
import json
2023-12-26 06:44:28 +01:00
from apps.web.models.users import Users
from apps.web.models.chats import (
ChatModel,
2023-12-26 10:27:43 +01:00
ChatResponse,
2023-12-26 19:41:55 +01:00
ChatTitleForm,
2023-12-26 06:44:28 +01:00
ChatForm,
ChatTitleIdResponse,
Chats,
)
from utils.utils import (
bearer_scheme,
)
from constants import ERROR_MESSAGES
router = APIRouter()
############################
# GetChats
############################
@router.get("/", response_model=List[ChatTitleIdResponse])
async def get_user_chats(
user=Depends(get_current_user), skip: int = 0, limit: int = 50
):
return Chats.get_chat_lists_by_user_id(user.id, skip, limit)
2023-12-26 06:44:28 +01:00
2023-12-27 07:10:22 +01:00
############################
# GetAllChats
############################
@router.get("/all", response_model=List[ChatResponse])
async def get_all_user_chats(user=Depends(get_current_user)):
return [
ChatResponse(**{**chat.model_dump(), "chat": json.loads(chat.chat)})
for chat in Chats.get_all_chats_by_user_id(user.id)
]
2023-12-27 07:10:22 +01:00
2023-12-26 06:44:28 +01:00
############################
# CreateNewChat
############################
2023-12-26 10:27:43 +01:00
@router.post("/new", response_model=Optional[ChatResponse])
async def create_new_chat(form_data: ChatForm, user=Depends(get_current_user)):
chat = Chats.insert_new_chat(user.id, form_data)
return ChatResponse(**{**chat.model_dump(), "chat": json.loads(chat.chat)})
2023-12-26 06:44:28 +01:00
############################
# GetChatById
############################
2023-12-26 10:27:43 +01:00
@router.get("/{id}", response_model=Optional[ChatResponse])
async def get_chat_by_id(id: str, user=Depends(get_current_user)):
chat = Chats.get_chat_by_id_and_user_id(id, user.id)
2023-12-26 06:44:28 +01:00
if chat:
return ChatResponse(**{**chat.model_dump(), "chat": json.loads(chat.chat)})
2023-12-26 06:44:28 +01:00
else:
raise HTTPException(
status_code=status.HTTP_401_UNAUTHORIZED, detail=ERROR_MESSAGES.NOT_FOUND
)
2023-12-26 06:44:28 +01:00
############################
# UpdateChatById
############################
2023-12-26 10:27:43 +01:00
@router.post("/{id}", response_model=Optional[ChatResponse])
async def update_chat_by_id(
id: str, form_data: ChatForm, user=Depends(get_current_user)
):
chat = Chats.get_chat_by_id_and_user_id(id, user.id)
if chat:
updated_chat = {**json.loads(chat.chat), **form_data.chat}
2023-12-26 19:41:55 +01:00
chat = Chats.update_chat_by_id(id, updated_chat)
return ChatResponse(**{**chat.model_dump(), "chat": json.loads(chat.chat)})
else:
raise HTTPException(
status_code=status.HTTP_401_UNAUTHORIZED,
detail=ERROR_MESSAGES.ACCESS_PROHIBITED,
)
2023-12-26 10:27:43 +01:00
############################
# DeleteChatById
############################
@router.delete("/{id}", response_model=bool)
async def delete_chat_by_id(id: str, user=Depends(get_current_user)):
result = Chats.delete_chat_by_id_and_user_id(id, user.id)
return result
2023-12-30 09:15:37 +01:00
############################
# DeleteAllChats
############################
@router.delete("/", response_model=bool)
async def delete_all_user_chats(user=Depends(get_current_user)):
result = Chats.delete_chats_by_user_id(user.id)
return result