import os
from typing import Dict, List, Any, Optional, cast
from fastapi import APIRouter,Request
from app.api.routers.request.base import userMng,conversations
from app.api.routers.request.models import ChatRequestData

api_router = r = APIRouter()
v1_router = v = APIRouter()


@v.post("/chat-messages")
async def post_conversations(request: Request,data: ChatRequestData):
    userMng.findNoExistCreate(data.user)
    
    conversaObj = conversations()
    conversationinfo = conversaObj.get(data.user)
    if conversationinfo is None:
        conversationinfo = conversaObj.add(data.user, "新建会话")

    return None

@v.get("/messages")
async def query_messages(user:str, conversation_id:str):
    pass

@v.post("/conversations/{itemid}/name")
async def post_conversations(user:str):
    pass

@v.get("/conversations")
async def query_conversations(user:str):
    user_id = '' if user is None else user
    userMng.findNoExistCreate(user_id)

    return {
        "limit": 20,
        "has_more": False,
        "data": conversations().gets(user_id)
    }    


@r.get("/conversations")
async def query_conversations(first_id:int = None, limit:int = None, pinned:bool = None):
    pass

#meta查询
@r.get("/meta")
async def query_meta():
    pass

#name查询
@r.get("/name查询")
def query_name():
    with sessionlocal() as session:
        name = session.query(NameOrm).first()

    return Name.from_orm(name)

#parameters查询
@r.get("/parameters")
async def query_parameters():
    pass

#msite查询
@r.get("/site")
async def query_site():
    pass