mirror of
https://github.com/microsoft/autogen.git
synced 2025-07-07 17:11:06 +00:00
fe96f7de24
* fix import issue related to agentchat update #4245 * update uv lock file * fix db auto_upgrade logic issue. * im prove msg rendering issue * Support termination condition combination. Closes #4325 * fix db instantiation bug * update yarn.lock, closes #4260 #4262 * remove deps for now with vulnerabilities found by dependabot #4262 * update db tests * add ability to load sessions from db .. * format updates, add format checks to ags * format check fixes * linting and ruff check fixes * make tests for ags non-parrallel to avoid db race conditions. * format updates * fix concurrency issue * minor ui tweaks, move run start to websocket * lint fixes * update uv.lock * Update python/packages/autogen-studio/autogenstudio/datamodel/types.py Co-authored-by: Eric Zhu <ekzhu@users.noreply.github.com> * Update python/packages/autogen-studio/autogenstudio/teammanager.py Co-authored-by: Eric Zhu <ekzhu@users.noreply.github.com> * reuse user proxy from agentchat * ui tweaks --------- Co-authored-by: Eric Zhu <ekzhu@users.noreply.github.com> Co-authored-by: Hussein Mozannar <hmozannar@microsoft.com>
42 lines
1.3 KiB
Python
42 lines
1.3 KiB
Python
# api/routes/teams.py
|
|
from typing import Dict
|
|
|
|
from fastapi import APIRouter, Depends, HTTPException
|
|
|
|
from ...datamodel import Team
|
|
from ..deps import get_db
|
|
|
|
router = APIRouter()
|
|
|
|
|
|
@router.get("/")
|
|
async def list_teams(user_id: str, db=Depends(get_db)) -> Dict:
|
|
"""List all teams for a user"""
|
|
response = db.get(Team, filters={"user_id": user_id})
|
|
return {"status": True, "data": response.data}
|
|
|
|
|
|
@router.get("/{team_id}")
|
|
async def get_team(team_id: int, user_id: str, db=Depends(get_db)) -> Dict:
|
|
"""Get a specific team"""
|
|
response = db.get(Team, filters={"id": team_id, "user_id": user_id})
|
|
if not response.status or not response.data:
|
|
raise HTTPException(status_code=404, detail="Team not found")
|
|
return {"status": True, "data": response.data[0]}
|
|
|
|
|
|
@router.post("/")
|
|
async def create_team(team: Team, db=Depends(get_db)) -> Dict:
|
|
"""Create a new team"""
|
|
response = db.upsert(team)
|
|
if not response.status:
|
|
raise HTTPException(status_code=400, detail=response.message)
|
|
return {"status": True, "data": response.data}
|
|
|
|
|
|
@router.delete("/{team_id}")
|
|
async def delete_team(team_id: int, user_id: str, db=Depends(get_db)) -> Dict:
|
|
"""Delete a team"""
|
|
db.delete(filters={"id": team_id, "user_id": user_id}, model_class=Team)
|
|
return {"status": True, "message": "Team deleted successfully"}
|