parent
d0c8c6c297
commit
75f5bc79da
4 changed files with 59 additions and 20 deletions
|
|
@ -9,3 +9,31 @@ Functions:
|
||||||
- List: Description
|
- List: Description
|
||||||
- Functions: Description
|
- Functions: Description
|
||||||
"""
|
"""
|
||||||
|
from typing import Annotated
|
||||||
|
from fastapi import Depends, Query
|
||||||
|
|
||||||
|
from src.database import db_dependency
|
||||||
|
|
||||||
|
from src.service.exceptions import ServiceNotFoundException
|
||||||
|
from src.service.models import Service
|
||||||
|
from src.service.schemas import ServiceIDMixin
|
||||||
|
|
||||||
|
|
||||||
|
async def get_service_model_query(db: db_dependency, service_id: Annotated[int, Query(gt=0)]):
|
||||||
|
service_model = db.get(Service, service_id)
|
||||||
|
if service_model is None:
|
||||||
|
raise ServiceNotFoundException(service_id=service_id)
|
||||||
|
|
||||||
|
return service_model
|
||||||
|
|
||||||
|
service_model_query_dependency = Annotated[type[Service], Depends(get_service_model_query)]
|
||||||
|
|
||||||
|
|
||||||
|
async def get_service_model_body(db: db_dependency, request_model: ServiceIDMixin):
|
||||||
|
service_model = db.get(Service, request_model.service_id)
|
||||||
|
if service_model is None:
|
||||||
|
raise ServiceNotFoundException(service_id=request_model.service_id)
|
||||||
|
|
||||||
|
return service_model
|
||||||
|
|
||||||
|
service_model_body_dependency = Annotated[type[Service], Depends(get_service_model_body)]
|
||||||
|
|
|
||||||
|
|
@ -5,3 +5,15 @@ Exceptions:
|
||||||
- List: Description
|
- List: Description
|
||||||
- Exceptions: Description
|
- Exceptions: Description
|
||||||
"""
|
"""
|
||||||
|
from typing import Optional
|
||||||
|
|
||||||
|
from fastapi import HTTPException, status
|
||||||
|
|
||||||
|
|
||||||
|
class ServiceNotFoundException(HTTPException):
|
||||||
|
def __init__(self, service_id: Optional[int] = None) -> None:
|
||||||
|
detail = "Service not found" if service_id is None else f"Service with ID '{service_id}' was not found."
|
||||||
|
super().__init__(
|
||||||
|
status_code=status.HTTP_404_NOT_FOUND,
|
||||||
|
detail=detail,
|
||||||
|
)
|
||||||
|
|
|
||||||
|
|
@ -5,17 +5,15 @@ Endpoints:
|
||||||
- List: Description
|
- List: Description
|
||||||
- Endpoints: Description
|
- Endpoints: Description
|
||||||
"""
|
"""
|
||||||
from typing import Annotated
|
from fastapi import APIRouter, status
|
||||||
|
|
||||||
from fastapi import APIRouter, HTTPException, status
|
|
||||||
from fastapi.params import Path
|
|
||||||
|
|
||||||
from src.database import db_dependency
|
from src.database import db_dependency
|
||||||
|
|
||||||
from src.service.models import Service
|
from src.service.models import Service
|
||||||
from src.service.utils import generate_api_key
|
from src.service.utils import generate_api_key
|
||||||
|
from src.service.dependencies import service_model_body_dependency
|
||||||
from src.service.schemas import ServiceGetServiceResponse, ServicePostServiceRequest, ServicePostServiceResponse, \
|
from src.service.schemas import ServiceGetServiceResponse, ServicePostServiceRequest, ServicePostServiceResponse, \
|
||||||
ServiceWithKeyResponse, ServicePatchKeyResponse
|
ServiceWithKeyResponse, ServicePatchKeyResponse, ServicePatchKeyRequest, ServiceDeleteServiceRequest
|
||||||
|
|
||||||
router = APIRouter(
|
router = APIRouter(
|
||||||
tags=["Service"],
|
tags=["Service"],
|
||||||
|
|
@ -41,27 +39,19 @@ async def register_service(db: db_dependency, service_request: ServicePostServic
|
||||||
db.commit()
|
db.commit()
|
||||||
return {"service": response}
|
return {"service": response}
|
||||||
|
|
||||||
@router.patch("/{service_id}/key", response_model=ServicePatchKeyResponse)
|
@router.patch("/key", response_model=ServicePatchKeyResponse)
|
||||||
async def regenerate_api_key(db: db_dependency, service_id: Annotated[int, Path(gt=0,description="Service database ID")]):
|
async def regenerate_api_key(db: db_dependency, service_model: service_model_body_dependency, request_model: ServicePatchKeyRequest):
|
||||||
# TODO: super_admin_dependency
|
# TODO: super_admin_dependency
|
||||||
service_model = db.get(Service, service_id)
|
|
||||||
if service_model is None:
|
|
||||||
raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Service not found")
|
|
||||||
|
|
||||||
key = generate_api_key()
|
key = generate_api_key()
|
||||||
service_model.api_key = key
|
service_model.api_key = key
|
||||||
|
|
||||||
db.flush()
|
db.flush()
|
||||||
response = ServiceWithKeyResponse(**service_model.__dict__)
|
response = ServiceWithKeyResponse(**service_model.__dict__)
|
||||||
|
|
||||||
db.commit()
|
db.commit()
|
||||||
return {"service": response}
|
return {"service": response}
|
||||||
|
|
||||||
@router.delete("/{service_id}", status_code=status.HTTP_204_NO_CONTENT)
|
@router.delete("/", status_code=status.HTTP_204_NO_CONTENT)
|
||||||
async def remove_service(db: db_dependency, service_id: Annotated[int, Path(gt=0,description="Service database ID")]):
|
async def remove_service(db: db_dependency, service_model: service_model_body_dependency, request_model: ServiceDeleteServiceRequest):
|
||||||
# TODO: super_admin_dependency
|
# TODO: super_admin_dependency
|
||||||
service_model = db.get(Service, service_id)
|
|
||||||
if service_model is None:
|
|
||||||
raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Service not found")
|
|
||||||
|
|
||||||
db.delete(service_model)
|
db.delete(service_model)
|
||||||
db.commit()
|
db.commit()
|
||||||
|
|
|
||||||
|
|
@ -9,6 +9,9 @@ from pydantic import ConfigDict
|
||||||
|
|
||||||
from src.schemas import CustomBaseModel
|
from src.schemas import CustomBaseModel
|
||||||
|
|
||||||
|
class ServiceIDMixin(CustomBaseModel):
|
||||||
|
service_id: int
|
||||||
|
|
||||||
class ServiceResponse(CustomBaseModel):
|
class ServiceResponse(CustomBaseModel):
|
||||||
model_config = ConfigDict(from_attributes=True, extra="ignore")
|
model_config = ConfigDict(from_attributes=True, extra="ignore")
|
||||||
|
|
||||||
|
|
@ -27,5 +30,11 @@ class ServicePostServiceRequest(CustomBaseModel):
|
||||||
class ServicePostServiceResponse(CustomBaseModel):
|
class ServicePostServiceResponse(CustomBaseModel):
|
||||||
service: ServiceWithKeyResponse
|
service: ServiceWithKeyResponse
|
||||||
|
|
||||||
|
class ServicePatchKeyRequest(ServiceIDMixin):
|
||||||
|
pass
|
||||||
|
|
||||||
class ServicePatchKeyResponse(CustomBaseModel):
|
class ServicePatchKeyResponse(CustomBaseModel):
|
||||||
service: ServiceWithKeyResponse
|
service: ServiceWithKeyResponse
|
||||||
|
|
||||||
|
class ServiceDeleteServiceRequest(ServiceIDMixin):
|
||||||
|
pass
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue