mirror of
https://github.com/wowlikon/LibraryAPI.git
synced 2025-12-11 21:30:46 +00:00
88 lines
3.1 KiB
Python
88 lines
3.1 KiB
Python
from fastapi import APIRouter, Depends, HTTPException
|
|
from sqlmodel import Session, select
|
|
from typing import List, Dict
|
|
|
|
from library_service.settings import get_session
|
|
from library_service.models.db import Author, Book, Genre, AuthorBookLink, GenreBookLink
|
|
from library_service.models.dto import AuthorRead, BookRead, GenreRead
|
|
|
|
router = APIRouter(tags=["relations"])
|
|
|
|
# Add author to book
|
|
@router.post("/relationships/author-book", response_model=AuthorBookLink)
|
|
def add_author_to_book(author_id: int, book_id: int, session: Session = Depends(get_session)):
|
|
author = session.get(Author, author_id)
|
|
if not author:
|
|
raise HTTPException(status_code=404, detail="Author not found")
|
|
|
|
book = session.get(Book, book_id)
|
|
if not book:
|
|
raise HTTPException(status_code=404, detail="Book not found")
|
|
|
|
existing_link = session.exec(
|
|
select(AuthorBookLink)
|
|
.where(AuthorBookLink.author_id == author_id)
|
|
.where(AuthorBookLink.book_id == book_id)
|
|
).first()
|
|
|
|
if existing_link:
|
|
raise HTTPException(status_code=400, detail="Relationship already exists")
|
|
|
|
link = AuthorBookLink(author_id=author_id, book_id=book_id)
|
|
session.add(link)
|
|
session.commit()
|
|
session.refresh(link)
|
|
return link
|
|
|
|
# Remove author from book
|
|
@router.delete("/relationships/author-book", response_model=Dict[str, str])
|
|
def remove_author_from_book(author_id: int, book_id: int, session: Session = Depends(get_session)):
|
|
link = session.exec(
|
|
select(AuthorBookLink)
|
|
.where(AuthorBookLink.author_id == author_id)
|
|
.where(AuthorBookLink.book_id == book_id)
|
|
).first()
|
|
|
|
if not link:
|
|
raise HTTPException(status_code=404, detail="Relationship not found")
|
|
|
|
session.delete(link)
|
|
session.commit()
|
|
return {"message": "Relationship removed successfully"}
|
|
|
|
# Get relationships
|
|
@router.get("/relationships/author-book", response_model=List[AuthorBookLink])
|
|
def get_relationships(session: Session = Depends(get_session)):
|
|
relationships = session.exec(select(AuthorBookLink)).all()
|
|
return relationships
|
|
|
|
# Get author's books
|
|
@router.get("/authors/{author_id}/books/", response_model=List[BookRead])
|
|
def get_books_for_author(author_id: int, session: Session = Depends(get_session)):
|
|
author = session.get(Author, author_id)
|
|
if not author:
|
|
raise HTTPException(status_code=404, detail="Author not found")
|
|
|
|
books = session.exec(
|
|
select(Book)
|
|
.join(AuthorBookLink)
|
|
.where(AuthorBookLink.author_id == author_id)
|
|
).all()
|
|
|
|
return [BookRead(**book.model_dump()) for book in books]
|
|
|
|
# Get book's authors
|
|
@router.get("/books/{book_id}/authors/", response_model=List[AuthorRead])
|
|
def get_authors_for_book(book_id: int, session: Session = Depends(get_session)):
|
|
book = session.get(Book, book_id)
|
|
if not book:
|
|
raise HTTPException(status_code=404, detail="Book not found")
|
|
|
|
authors = session.exec(
|
|
select(Author)
|
|
.join(AuthorBookLink)
|
|
.where(AuthorBookLink.book_id == book_id)
|
|
).all()
|
|
|
|
return [AuthorRead(**author.model_dump()) for author in authors]
|