2024-11-09 14:32:24 -08:00
|
|
|
# api/routes/tools.py
|
|
|
|
from typing import Dict
|
2024-11-26 15:39:36 -08:00
|
|
|
|
|
|
|
from fastapi import APIRouter, Depends, HTTPException
|
|
|
|
|
2024-11-09 14:32:24 -08:00
|
|
|
from ...datamodel import Tool
|
2024-11-26 15:39:36 -08:00
|
|
|
from ..deps import get_db
|
2024-11-09 14:32:24 -08:00
|
|
|
|
|
|
|
router = APIRouter()
|
|
|
|
|
|
|
|
|
|
|
|
@router.get("/")
|
2024-11-26 15:39:36 -08:00
|
|
|
async def list_tools(user_id: str, db=Depends(get_db)) -> Dict:
|
2024-11-09 14:32:24 -08:00
|
|
|
"""List all tools for a user"""
|
|
|
|
response = db.get(Tool, filters={"user_id": user_id})
|
2024-11-26 15:39:36 -08:00
|
|
|
return {"status": True, "data": response.data}
|
2024-11-09 14:32:24 -08:00
|
|
|
|
|
|
|
|
|
|
|
@router.get("/{tool_id}")
|
2024-11-26 15:39:36 -08:00
|
|
|
async def get_tool(tool_id: int, user_id: str, db=Depends(get_db)) -> Dict:
|
2024-11-09 14:32:24 -08:00
|
|
|
"""Get a specific tool"""
|
2024-11-26 15:39:36 -08:00
|
|
|
response = db.get(Tool, filters={"id": tool_id, "user_id": user_id})
|
2024-11-09 14:32:24 -08:00
|
|
|
if not response.status or not response.data:
|
|
|
|
raise HTTPException(status_code=404, detail="Tool not found")
|
2024-11-26 15:39:36 -08:00
|
|
|
return {"status": True, "data": response.data[0]}
|
2024-11-09 14:32:24 -08:00
|
|
|
|
|
|
|
|
|
|
|
@router.post("/")
|
2024-11-26 15:39:36 -08:00
|
|
|
async def create_tool(tool: Tool, db=Depends(get_db)) -> Dict:
|
2024-11-09 14:32:24 -08:00
|
|
|
"""Create a new tool"""
|
|
|
|
response = db.upsert(tool)
|
|
|
|
if not response.status:
|
|
|
|
raise HTTPException(status_code=400, detail=response.message)
|
2024-11-26 15:39:36 -08:00
|
|
|
return {"status": True, "data": response.data}
|
2024-11-09 14:32:24 -08:00
|
|
|
|
|
|
|
|
|
|
|
@router.delete("/{tool_id}")
|
2024-11-26 15:39:36 -08:00
|
|
|
async def delete_tool(tool_id: int, user_id: str, db=Depends(get_db)) -> Dict:
|
2024-11-09 14:32:24 -08:00
|
|
|
"""Delete a tool"""
|
2024-11-26 15:39:36 -08:00
|
|
|
db.delete(filters={"id": tool_id, "user_id": user_id}, model_class=Tool)
|
|
|
|
return {"status": True, "message": "Tool deleted successfully"}
|