mirror of
https://github.com/cssgunc/compass.git
synced 2025-04-09 22:00:18 -04:00
7d705ac743
* Implemented API routes for getting all, creating, updating, and deleting resources, services, and tags. * Updated main.py for API routes to include tags and rolled entities back. * Created API routes for create, update, delete, get_all, and get_by_name. Deleted service methods for get by id. * Defaults created_at to current time * Write markdown file for HTTP requests using curl --------- Co-authored-by: pmoharana-cmd <pmoharana032474@gmail.com>
53 lines
1.7 KiB
Python
53 lines
1.7 KiB
Python
from fastapi import Depends
|
|
|
|
from backend.models.enum_for_models import UserTypeEnum
|
|
from backend.models.user_model import User
|
|
from backend.services.exceptions import TagNotFoundException
|
|
from ..database import db_session
|
|
from sqlalchemy.orm import Session
|
|
from ..models.tag_model import Tag
|
|
from ..entities.tag_entity import TagEntity
|
|
from sqlalchemy import select
|
|
|
|
# Add in checks for user permission?
|
|
class TagService:
|
|
|
|
def __init__(self, session: Session = Depends(db_session)):
|
|
self._session = session
|
|
|
|
def get_all(self) -> list[Tag]:
|
|
"""Returns a list of all Tags"""
|
|
query = select(TagEntity)
|
|
entities = self._session.scalars(query).all()
|
|
|
|
return [entity.to_model() for entity in entities]
|
|
|
|
def create(self, subject: User, tag: Tag) -> Tag:
|
|
entity = TagEntity.from_model(tag)
|
|
self._session.add(entity)
|
|
self._session.commit()
|
|
return entity.to_model()
|
|
|
|
def update(self, subject: User, tag: Tag) -> Tag:
|
|
query = select(TagEntity).where(TagEntity.id == tag.id)
|
|
entity = self._session.scalars(query).one_or_none()
|
|
|
|
if entity is None:
|
|
raise TagNotFoundException(f"Tag with id {tag.id} does not exist")
|
|
|
|
entity.content = tag.content
|
|
self._session.commit()
|
|
return entity.to_model()
|
|
|
|
|
|
def delete(self, subject: User, tag: Tag) -> None:
|
|
query = select(TagEntity).where(TagEntity.id == tag.id)
|
|
entity = self._session.scalars(query).one_or_none()
|
|
|
|
if entity is None:
|
|
raise TagNotFoundException(f"Tag with id {tag.id} does not exist")
|
|
|
|
self._session.delete(entity)
|
|
self._session.commit()
|
|
|