refactor kontor-api to use SQLAlchemy 2.0 features for mapping fields

(cherry picked from commit e57abdbef7e13e3880738cd639225df5db0c37be)

kontor-api/src/apis/base.py

@@ -9,3 +9,4 @@ api_router.include_router(mediaactor.router, prefix="/media", tags=["media"])
 api_router.include_router(mediaactorfile.router, prefix="/media", tags=["media"])
 api_router.include_router(tysc.router, prefix="/tysc", tags=["tysc"])
 api_router.include_router(admin.router, prefix="/login", tags=["login"])
+api_router.include_router(user.router, prefix="/user", tags=["user"])

kontor-api/src/apis/version1/comic.py

@@ -13,7 +13,7 @@ router = APIRouter()
 
 
 @router.get("/comics")
-def get_all_comics(db: SessionDep) -> List[ComicResponse]:
+def get_all_comics(db: SessionDep) -> List[ComicResponse]: # type: ignore
     results: List[ComicResponse] = []
     comics = list_comics(db)
     for comic in comics:
@@ -34,7 +34,7 @@ def get_comic(comic_id: AnyStr, db: SessionDep) -> ComicDetailsResponse:
 
 
 @router.get("/artists", response_model=List[ArtistResponse])
-def get_all_artists(db: SessionDep) -> List[ArtistResponse]:
+def get_all_artists(db: SessionDep) -> List[ArtistResponse]: # type: ignore
     results: List[ArtistResponse] = []
     artists = db.query(Artist).all()
     for artist in artists:
@@ -52,7 +52,7 @@ def get_artist(artist_id: AnyStr, db: SessionDep) -> ArtistDetailResponse:
 
 
 @router.post("/artists", status_code=status.HTTP_201_CREATED)
-def add_artist(db: SessionDep, artist_creation: ArtistCreation) -> ArtistResponse:
+def add_artist(db: SessionDep, artist_creation: ArtistCreation) -> ArtistResponse: # type: ignore
     artist: Artist = Artist()
     setattr(artist, "name", artist_creation.name)
     try:
@@ -64,7 +64,7 @@ def add_artist(db: SessionDep, artist_creation: ArtistCreation) -> ArtistRespons
     return response
 
 @router.get("/issues", response_model=List[IssueDetailsResponse])
-def get_issues(db: SessionDep) -> List[IssueDetailsResponse]:
+def get_issues(db: SessionDep) -> List[IssueDetailsResponse]: # type: ignore
     results: List[IssueDetailsResponse] = []
     issues = db.query(Issue).all()
     for issue in issues:

kontor-api/src/apis/version1/mediaactor.py

@@ -1,9 +1,9 @@
 from fastapi import APIRouter, status, HTTPException
 from sqlalchemy import select
 from src.core.log_conf import logger
-from src.db.repository.media import create_new_mediaactor, delete_mediaactor
+from src.db.repository.media import create_new_mediaactor, delete_mediaactor, get_actor_details
 from src.db.session import SessionDep
-from src.schema.media.actor import Actor, MediaActorResponse, get_actor_details
+from src.schema.media.actor import MediaActorModel, MediaActorResponse
 from src.db.models.media import MediaActor
 
 router = APIRouter()
@@ -32,13 +32,10 @@ def delete_actor(actor_id: str, db: SessionDep): # type: ignore
     if not media_actor:
         raise HTTPException(status_code=404, detail="MediaActor could not be found")
     logger.info(f"delete MediaActor: {actor_id}")
-    actor_files = media_actor.media_actor_files
-    logger.info(f"MediaActorFiles links {len(actor_files)}")
-    if len(actor_files) == 0:
-        delete_mediaactor(db, media_actor.id)
+    delete_mediaactor(db, media_actor.id)
 
 @router.post("/actors", status_code=status.HTTP_201_CREATED)
-def add_actor(new_actor: Actor, db: SessionDep) -> MediaActorResponse: # type: ignore
+def add_actor(new_actor: MediaActorModel, db: SessionDep) -> MediaActorResponse: # type: ignore
     logger.info(f"add actor {new_actor.url}")
     try:
         mediaActor: MediaActor = create_new_mediaactor(new_actor, db)

kontor-api/src/apis/version1/mediaactorfile.py

@@ -1,18 +1,19 @@
+from typing import List
 from fastapi import APIRouter, status, HTTPException
 from sqlalchemy import select
 from src.db.models.media import MediaActorFile
-from src.db.repository.media import delete_mediaactorfile
+from src.db.repository.media import delete_mediaactorfile, get_actorfile_details
 from src.db.session import SessionDep
-from src.schema.media.actorfile import MediaActorFileResponse, get_actorfile_details
+from src.schema.media.actorfile import MediaActorFileResponse
 
 router = APIRouter()
 
-@router.get("/actorfiles", response_model=list[MediaActorFileResponse])
-def get_all_actorfiles(db: SessionDep) -> list[MediaActorFileResponse]: # type: ignore
-    results: list[MediaActorFileResponse] = []
+@router.get("/actorfiles", response_model=List[MediaActorFileResponse])
+def get_all_actorfiles(db: SessionDep) -> List[MediaActorFileResponse]: # type: ignore
+    results: List[MediaActorFileResponse] = []
     actorfiles = db.scalars(select(MediaActorFile)).all()
-    for mediaactorfile in actorfiles:
-        response = MediaActorFileResponse(id=mediaactorfile.id, actor_id=str(mediaactorfile.media_actor_id), file_id=str(mediaactorfile.media_file_id))
+    for media_actorfile in actorfiles:
+        response = get_actorfile_details(media_actorfile)
         results.append(response)
     return results
 
@@ -30,4 +31,3 @@ def delete_actorfile(actorfile_id: str, db: SessionDep): # type: ignore
     if not media_actorfile:
         raise HTTPException(status_code=404, detail="MediaActor could not be found")
     delete_mediaactorfile(db, media_actorfile.id)
-

kontor-api/src/apis/version1/user.py

@@ -0,0 +1,47 @@
+from typing import List
+from fastapi import APIRouter, HTTPException, status
+from sqlalchemy import select
+from src.core.log_conf import logger
+
+from src.db.models.admin import Profile
+from src.db.repository.user import create_new_profile, get_profile_details
+from src.db.session import SessionDep
+from src.schema.user.profile import ProfileResponse, ProfileModel
+
+
+router = APIRouter()
+
+@router.get("/profiles", response_model=List[ProfileResponse])
+def get_all_profiles(db: SessionDep) -> List[ProfileResponse]: # type: ignore
+    results: List[ProfileResponse] = []
+    profiles = db.scalars(select(Profile)).all()
+    for profile in profiles:
+        response = get_profile_details(profile)
+        results.append(response)
+    return results
+
+@router.get("/profiles/{profile_id}", response_model=ProfileResponse)
+def get_profile(profile_id: str, db: SessionDep) -> ProfileResponse: # type: ignore
+    profile = db.get(Profile, profile_id)
+    if not profile:
+        raise HTTPException(status_code=404, detail="MediaActor could not be found")
+    response = get_profile_details(profile)
+    return response
+
+@router.delete("/profiles/{profile_id}", status_code=status.HTTP_204_NO_CONTENT)
+def delete_profile(profile_id: str, db: SessionDep): # type: ignore
+    profile = db.get(Profile, profile_id)
+    if not profile:
+        raise HTTPException(status_code=404, detail="Profile could not be found")
+    logger.info(f"delete Profile: {profile_id}")
+    delete_profile(profile_id=profile_id, db=db)
+
+@router.post("/profiles", status_code=status.HTTP_201_CREATED)
+def add_profile(new_profile: ProfileModel, db: SessionDep) -> ProfileResponse: # type: ignore
+    logger.info(f"add profile {new_profile.user_name}")
+    try:
+        profile: Profile = create_new_profile(new_profile, db)
+    except:
+        raise HTTPException(status_code=409, detail="Profile duplicate")
+    response = get_profile_details(profile)
+    return response

kontor-api/src/db/models/admin.py

@@ -1,6 +1,7 @@
 from datetime import datetime
+from typing import List
 
-from sqlalchemy import Column, ForeignKey, Integer, String, Boolean
+from sqlalchemy import ForeignKey
 from sqlalchemy.orm import relationship, mapped_column, Mapped
 
 from src.db.models.base import Base, BaseMixin
@@ -8,23 +9,23 @@ from src.db.models.base import Base, BaseMixin
 
 class Profile(Base, BaseMixin):
     __tablename__ = 'profile'
-    first_name = Column(String)
-    last_name = Column(String)
-    user_name = Column(String, nullable=False)
-    email = Column(String)
-    password = Column(String)
-    enabled = Column(Boolean)
-    assignments = relationship("Assignment")
-    tokens = relationship("Token")
+    first_name: Mapped[str]
+    last_name: Mapped[str]
+    user_name: Mapped[str] =  mapped_column(nullable=False)
+    email: Mapped[str]
+    password: Mapped[str]
+    enabled: Mapped[bool]
+    assignments: Mapped[List["Assignment"]] = relationship(back_populates="profile")
+    tokens: Mapped[List["Token"]] = relationship(back_populates="profile")
 
     def get_full_name(self) -> str:
-        full_name = ""
+        full_name: str = ""
         if self.first_name is not None:
-            full_name += self.first_name
+            full_name += str(self.first_name)
         if self.last_name is not None:
             if len(full_name) > 0:
                 full_name += " "
-            full_name += self.last_name
+            full_name += str(self.last_name)
         return full_name
 
     def __str__(self):
@@ -33,42 +34,42 @@ class Profile(Base, BaseMixin):
 
 class Token(Base, BaseMixin):
     __tablename__ = "token"
-    token = Column(String, nullable=False, unique=True)
-    name = Column(String)
-    last_used_date: Mapped[datetime] = mapped_column()
-    enabled = Column(Boolean)
-    profile_id = Column(String, ForeignKey("profile.id"), nullable=False)
-    profile = relationship("Profile", back_populates="tokens")
+    token: Mapped[str] = mapped_column(nullable=False, unique=True)
+    name: Mapped[str]
+    last_used_date: Mapped[datetime]
+    enabled: Mapped[bool]
+    profile_id = mapped_column(ForeignKey("profile.id"), nullable=False)
+    profile: Mapped[Profile] = relationship(back_populates="tokens")
 
 
 class Permission(Base, BaseMixin):
     __tablename__ = "permission"
-    name = Column(String, nullable=False)
-    assignments = relationship("Assignment")
+    name: Mapped[str] = mapped_column(nullable=False)
+    assignments: Mapped[List["Assignment"]] = relationship(back_populates="permission")
 
 
 class Assignment(Base, BaseMixin):
     __tablename__ = "assignment"
-    profile_id = Column(String, ForeignKey("profile.id"), nullable=False)
-    profile = relationship("Profile", back_populates="assignments")
-    permission_id = Column(String, ForeignKey("permission.id"), nullable=False)
-    permission = relationship("Permission", back_populates="assignments")
+    profile_id = mapped_column(ForeignKey("profile.id"), nullable=False)
+    profile: Mapped[Profile] = relationship(back_populates="assignments")
+    permission_id = mapped_column(ForeignKey("permission.id"), nullable=False)
+    permission: Mapped[Permission] = relationship(back_populates="assignments")
 
 
 class MailAccount(Base, BaseMixin):
     __tablename__ = "mail_account"
-    host = Column(String)
-    port = Column(Integer)
-    protocol = Column(String)
-    user_name = Column(String)
-    password = Column(String)
-    start_tls = Column(Boolean)
+    host: Mapped[str]
+    port: Mapped[int]
+    protocol: Mapped[str]
+    user_name: Mapped[str]
+    password: Mapped[str]
+    start_tls: Mapped[bool]
 
 
 class Mail(Base, BaseMixin):
     __tablename__ = "mail"
-    folder: Mapped[str] = mapped_column()
-    subject: Mapped[str] = mapped_column()
-    body: Mapped[str] = mapped_column()
-    sent_date: Mapped[datetime] = mapped_column()
-    received_date: Mapped[datetime] = mapped_column()
+    folder: Mapped[str]
+    subject: Mapped[str]
+    body: Mapped[str]
+    sent_date: Mapped[datetime]
+    received_date: Mapped[datetime]

kontor-api/src/db/models/base.py

@@ -1,7 +1,8 @@
+from typing import Optional
 import uuid
 from datetime import datetime
 
-from sqlalchemy import func, Column, String, Boolean
+from sqlalchemy import func
 from sqlalchemy.orm import DeclarativeBase, Mapped, mapped_column
 
 
@@ -10,13 +11,9 @@ class Base(DeclarativeBase):
 
 
 class BaseMixin:
-    #id = Column(String, primary_key=True, default=uuid.uuid4)
     id: Mapped[str] = mapped_column(primary_key=True, default=str(uuid.uuid4()))
-    # created_date = Column(DateTime)
     created_date: Mapped[datetime] = mapped_column(default=func.now())
-    # last_modified_date = Column(DateTime)
     last_modified_date: Mapped[datetime] = mapped_column(default=func.now())
-    # version = Column(Integer)
     version: Mapped[int] = mapped_column(default=0)
 
 

kontor-api/src/db/models/comic.py

@@ -1,8 +1,8 @@
 import uuid
 from datetime import datetime
-from typing import AnyStr, Dict, List, Optional, Any
+from typing import Dict, List, Optional, Any
 from natsort import natsorted
-from sqlalchemy import Column, ForeignKey, Integer, String, Boolean, func
+from sqlalchemy import ForeignKey, func
 from sqlalchemy.orm import relationship, Mapped, mapped_column
 
 from src.db.models.base import Base, BaseMixin
@@ -14,12 +14,12 @@ class Publisher(Base):
     created_date: Mapped[datetime] = mapped_column(default=func.now())
     last_modified_date: Mapped[datetime] = mapped_column(default=func.now())
     version: Mapped[int] = mapped_column(default=0)
-    name = Column(String, unique=True)
-    weblink = Column(String, nullable=True)
+    name: Mapped[str] = mapped_column(unique=True)
+    weblink: Mapped[Optional[str]]
     parent_publisher_id: Mapped[Optional[str]] = mapped_column(ForeignKey('publisher.id'))
-    parent_publisher: Mapped[Optional['Publisher']] = relationship("Publisher", back_populates="imprints", remote_side=[id])
-    imprints: Mapped[List['Publisher']] = relationship('Publisher', back_populates="parent_publisher")
-    comics = relationship("Comic")
+    parent_publisher: Mapped[Optional['Publisher']] = relationship(back_populates="imprints", remote_side=[id])
+    imprints: Mapped[List['Publisher']] = relationship(back_populates="parent_publisher")
+    comics = relationship(back_populates="publisher")
 
     def __repr__(self):
         return f'Publisher({self.id} {self.name})'
@@ -30,17 +30,17 @@ class Publisher(Base):
 
 class Comic(Base, BaseMixin):
     __tablename__ = 'comic'
-    title = Column(String, unique=True)
-    publisher_id = Column(String, ForeignKey('publisher.id'), nullable=False)
-    publisher = relationship("Publisher", back_populates="comics")
-    current_order = Column(Boolean)
-    completed = Column(Boolean)
-    weblink = Column(String, nullable=True)
-    issues = relationship("Issue", order_by="Issue.issue_number")
-    story_arcs = relationship("StoryArc")
-    trade_paperbacks = relationship("TradePaperback")
-    volumes = relationship("Volume")
-    comic_works = relationship("ComicWork")
+    title: Mapped[str] = mapped_column(unique=True)
+    publisher_id: Mapped[str] = mapped_column(ForeignKey('publisher.id'), nullable=False)
+    publisher: Mapped[Publisher] = relationship(back_populates="comics")
+    current_order: Mapped[bool]
+    completed: Mapped[bool]
+    weblink: Mapped[Optional[str]]
+    issues: Mapped[List["Issue"]] = relationship(back_populates="comic", order_by="Issue.issue_number")
+    story_arcs: Mapped[List["StoryArc"]] = relationship(back_populates="comic")
+    trade_paperbacks: Mapped[List["TradePaperback"]] = relationship(back_populates="comic")
+    volumes: Mapped[List["Volume"]] = relationship(back_populates="comic")
+    comic_works: Mapped[List["ComicWork"]] = relationship(back_populates="comic")
 
     def __repr__(self):
         return f'Comic({self.id} {self.version} {self.title} {self.publisher.name})'
@@ -66,46 +66,46 @@ class Comic(Base, BaseMixin):
 
 class Volume(Base, BaseMixin):
     __tablename__ = "volume"
-    name = Column(String, nullable=False)
-    comic_id = Column(String, ForeignKey("comic.id"), nullable=False)
-    comic = relationship("Comic", back_populates="volumes")
-    story_arcs = relationship("StoryArc")
-    issues = relationship("Issue")
+    name: Mapped[str] = mapped_column(nullable=False)
+    comic_id: Mapped[str] = mapped_column(ForeignKey("comic.id"), nullable=False)
+    comic: Mapped[Comic] = relationship(back_populates="volumes")
+    story_arcs: Mapped[List["StoryArc"]] = relationship(back_populates="volume")
+    issues: Mapped[List["Issue"]] = relationship(back_populates="volume")
 
 
 class TradePaperback(Base, BaseMixin):
     __tablename__ = "trade_paperback"
-    name = Column(String, nullable=False)
-    issue_start = Column(Integer)
-    issue_end = Column(Integer)
-    comic_id = Column(String, ForeignKey("comic.id"), nullable=False)
-    comic = relationship("Comic", back_populates="trade_paperbacks")
+    name: Mapped[str] = mapped_column(nullable=False)
+    issue_start: Mapped[int]
+    issue_end: Mapped[int]
+    comic_id: Mapped[str] = mapped_column(ForeignKey("comic.id"), nullable=False)
+    comic: Mapped[Comic] = relationship(back_populates="trade_paperbacks")
 
 
 class StoryArc(Base, BaseMixin):
     __tablename__ = "story_arc"
-    name = Column(String, nullable=False)
-    comic_id = Column(String, ForeignKey("comic.id"), nullable=False)
-    comic = relationship("Comic", back_populates="story_arcs")
-    volume_id = Column(String, ForeignKey("volume.id"), nullable=True)
-    volume = relationship("Volume", back_populates="story_arcs")
-    issues = relationship("Issue")
+    name: Mapped[str] = mapped_column(nullable=False)
+    comic_id: Mapped[str] = mapped_column(ForeignKey("comic.id"), nullable=False)
+    comic: Mapped[Comic] = relationship(back_populates="story_arcs")
+    volume_id: Mapped[str] = mapped_column(ForeignKey("volume.id"), nullable=True)
+    volume: Mapped[Volume] = relationship(back_populates="story_arcs")
+    issues: Mapped[List["Issue"]] = relationship(back_populates="story_arc")
 
 
 class Issue(Base, BaseMixin):
     __tablename__ = "issue"
-    issue_number = Column(String)
-    title = Column(String, nullable=True)
-    published_on: Mapped[datetime] = mapped_column(nullable=True)
-    in_stock = Column(Boolean)
-    is_read = Column(Boolean)
-    comic_id = Column(String, ForeignKey("comic.id"), nullable=False)
-    comic = relationship("Comic", back_populates="issues")
-    volume_id = Column(String, ForeignKey("volume.id"), nullable=True)
-    volume = relationship("Volume", back_populates="issues")
-    story_arc_id = Column(String, ForeignKey("story_arc.id"), nullable=True)
-    story_arc = relationship("StoryArc", back_populates="issues")
-    issue_works = relationship("IssueWork")
+    issue_number: Mapped[str]
+    title: Mapped[Optional[str]]
+    published_on: Mapped[Optional[datetime]]
+    in_stock: Mapped[bool]
+    is_read: Mapped[bool]
+    comic_id: Mapped[str] = mapped_column(ForeignKey("comic.id"), nullable=False)
+    comic: Mapped[Comic] = relationship(back_populates="issues")
+    volume_id: Mapped[str] = mapped_column(ForeignKey("volume.id"), nullable=True)
+    volume: Mapped[Volume] = relationship(back_populates="issues")
+    story_arc_id: Mapped[str] = mapped_column(ForeignKey("story_arc.id"), nullable=True)
+    story_arc: Mapped[StoryArc] = relationship(back_populates="issues")
+    issue_works: Mapped[List["IssueWork"]] = relationship(back_populates="issue")
 
     def get_full_title(self) -> AnyStr:
         full_title: AnyStr = self.issue_number
@@ -127,10 +127,10 @@ class Issue(Base, BaseMixin):
 
 class Artist(Base, BaseMixin):
     __tablename__ = "artist"
-    name = Column(String, nullable=False)
-    weblink = Column(String, nullable=True)
-    comic_works = relationship("ComicWork")
-    issue_works = relationship("IssueWork")
+    name: Mapped[str] = mapped_column(nullable=False)
+    weblink: Mapped[str] = mapped_column(nullable=True)
+    comic_works: Mapped[List["ComicWork"]] = relationship(back_populates="artist")
+    issue_works: Mapped[List["IssueWork"]] = relationship(back_populates="artist")
 
     def get_comics(self) -> Dict[Any, List[Comic]]:
         works: Dict[Any, List[Comic]] = {}
@@ -146,12 +146,12 @@ class Artist(Base, BaseMixin):
 
 class WorkType(Base, BaseMixin):
     __tablename__ = "worktype"
-    name = Column(String, nullable=False, unique=True)
-    comic_works = relationship("ComicWork")
-    issue_works = relationship("IssueWork")
+    name: Mapped[str] = mapped_column(nullable=False, unique=True)
+    comic_works: Mapped[List["ComicWork"]] = relationship(back_populates="work_type")
+    issue_works: Mapped[List["IssueWork"]] = relationship(back_populates="work_type")
 
-    def get_artists(self) -> Dict[str, List[str]]:
-        works: Dict[str, List[str]] = {}
+    def get_artists(self) -> Dict[str, List[Artist]]:
+        works: Dict[str, List[Artist]] = {}
         for work in self.comic_works:
             comic = work.comic.title
             artist = work.artist
@@ -170,12 +170,12 @@ class WorkType(Base, BaseMixin):
 
 class ComicWork(Base, BaseMixin):
     __tablename__ = "comic_work"
-    comic_id = Column(String, ForeignKey("comic.id"), nullable=False)
-    comic = relationship("Comic", back_populates="comic_works")
-    artist_id = Column(String, ForeignKey("artist.id"), nullable=False)
-    artist = relationship("Artist", back_populates="comic_works")
-    work_type_id = Column(String, ForeignKey("worktype.id"), nullable=False)
-    work_type = relationship("WorkType", back_populates="comic_works")
+    comic_id: Mapped[str] = mapped_column(ForeignKey("comic.id"), nullable=False)
+    comic: Mapped[Comic] = relationship(back_populates="comic_works")
+    artist_id: Mapped[str] = mapped_column(ForeignKey("artist.id"), nullable=False)
+    artist: Mapped[Artist] = relationship(back_populates="comic_works")
+    work_type_id: Mapped[str] = mapped_column(ForeignKey("worktype.id"), nullable=False)
+    work_type: Mapped[WorkType] = relationship(back_populates="comic_works")
 
 
 class IssueWork(Base, BaseMixin):

kontor-api/src/db/models/database.py

@@ -1,395 +0,0 @@
-import json
-import logging
-from datetime import datetime
-from enum import Enum, auto
-from pathlib import Path
-from typing import Any, List
-
-from sqlalchemy import select
-from sqlalchemy.exc import IntegrityError
-from sqlalchemy.orm import sessionmaker
-
-from src.db.models.tysc import Card, CardSet, Rooster, Team, FieldPosition, Player, Vendor, Sport
-from src.db.models.comic import Issue, TradePaperback, StoryArc, Volume, ComicWork, Artist, Comic, Publisher, WorkType
-from src.db.models.bookshelf import ArticleAuthor, BookAuthor, BookshelfPublisher, Article, Book, Author
-from src.db.models.admin import Mail, MailAccount, ModuleData, Token, Assignment, Permission, Profile
-from src.db.models.metadata import MetaDataTable, MetaDataColumn
-from src.db.models.media import MediaVideo, MediaArticle, MediaFile, MediaActor, MediaActorFile
-
-
-class ColumnEntry(Enum):
-    COLUMN_NAME = 'column'
-    COLUMN_LABEL = 'label'
-    COLUMN_ORDER = 'order'
-    COLUMN_REF_COLUMN = 'ref_column'
-    COLUMN_TYPE = 'type'
-    COLUMN_WIDGET = 'widget'
-
-
-class StatusType(Enum):
-    UNKNOWN = auto()
-    FILE_NAME = auto()
-    FILE_ID = auto()
-    DUPLICATE = auto()
-    CLOUD_LINK = auto()
-    CLOUD_LINK_ID = auto()
-
-class ExportType(Enum):
-    JSON = "JSON"
-    YAML = "YAML"
-    SQLITE = "SQLite"
-
-
-class KontorDB:
-
-    def __init__(self, db_engine: Any):
-        self.engine = db_engine
-        self.registry = {}
-        self.init_registry()
-
-    def init_registry(self):
-        self.registry[Card.__tablename__] = Card
-        self.registry[CardSet.__tablename__] = CardSet
-        self.registry[Rooster.__tablename__] = Rooster
-        self.registry[Team.__tablename__] = Team
-        self.registry[FieldPosition.__tablename__] = FieldPosition
-        self.registry[Player.__tablename__] = Player
-        self.registry[Vendor.__tablename__] = Vendor
-        self.registry[Sport.__tablename__] = Sport
-        self.registry[Issue.__tablename__] = Issue
-        self.registry[TradePaperback.__tablename__] = TradePaperback
-        self.registry[StoryArc.__tablename__] = StoryArc
-        self.registry[Volume.__tablename__] = Volume
-        self.registry[ComicWork.__tablename__] = ComicWork
-        self.registry[Artist.__tablename__] = Artist
-        self.registry[Comic.__tablename__] = Comic
-        self.registry[Publisher.__tablename__] = Publisher
-        self.registry[WorkType.__tablename__] = WorkType
-        self.registry[ArticleAuthor.__tablename__] = ArticleAuthor
-        self.registry[BookAuthor.__tablename__] = BookAuthor
-        self.registry[BookshelfPublisher.__tablename__] = BookshelfPublisher
-        self.registry[Article.__tablename__] = Article
-        self.registry[Book.__tablename__] = Book
-        self.registry[Author.__tablename__] = Author
-        self.registry[MediaFile.__tablename__] = MediaFile
-        self.registry[MediaActor.__tablename__] = MediaActor
-        self.registry[MediaActorFile.__tablename__] = MediaActorFile
-        self.registry[MediaArticle.__tablename__] = MediaArticle
-        self.registry[MediaVideo.__tablename__] = MediaVideo
-        self.registry[MetaDataColumn.__tablename__] = MetaDataColumn
-        self.registry[MetaDataTable.__tablename__] = MetaDataTable
-        self.registry[Assignment.__tablename__] = Assignment
-        self.registry[Token.__tablename__] = Token
-        self.registry[Profile.__tablename__] = Profile
-        self.registry[Permission.__tablename__] = Permission
-        self.registry[ModuleData.__tablename__] = ModuleData
-        self.registry[MailAccount.__tablename__] = MailAccount
-        self.registry[Mail.__tablename__] = Mail
-
-    def get_table_names(self) -> list:
-        result = []
-        __session__ = sessionmaker(self.engine)
-        with __session__() as session:
-            tables = session.scalars(select(MetaDataTable)).all()
-            result = [table.table_name for table in tables]
-        return result
-
-    def get_table_by_name(self, table_name: str) -> dict:
-        result = {}
-        __session__ = sessionmaker(self.engine)
-        _filter = {'table_name': table_name}
-        with __session__() as session:
-            table = session.query(MetaDataTable).filter_by(**_filter).one()
-            result['id'] = table.id
-            result['table_name'] = table.table_name
-        return result
-
-    def get_column_meta_data(self, table_name: str, view_only=True) -> dict:
-        meta_data = {}
-        order = 0
-        __session__ = sessionmaker(self.engine)
-        columns = list()
-        table_info = self.get_table_by_name(table_name)
-        _filters = {'table_id': table_info['id']}
-        if view_only:
-            _filters['is_shown'] = True
-        with __session__() as session:
-            columns = session.query(MetaDataColumn).filter_by(**_filters).all()
-        for column in columns:
-            # self.log.info("get_column_meta_data: %s %s %d", column.column_name, column.column_label, column.column_order)
-            meta_data[order] = {
-                ColumnEntry.COLUMN_NAME: column.column_name,
-                ColumnEntry.COLUMN_LABEL: column.column_label,
-                ColumnEntry.COLUMN_ORDER: column.column_order,
-                ColumnEntry.COLUMN_REF_COLUMN: column.ref_column,
-                ColumnEntry.COLUMN_TYPE: column.column_type
-            }
-            order += 1
-        return meta_data
-
-    def get_columns(self, table_name: str) -> dict:
-        columns = {}
-        __session__ = sessionmaker(self.engine)
-        table_info = self.get_table_by_name(table_name)
-        _filters = {'table_id': table_info['id']}
-        with __session__() as session:
-            for column in session.query(MetaDataColumn).filter_by(**_filters).all():
-                columns[column.column_name] = {
-                    ColumnEntry.COLUMN_ORDER: column.column_order,
-                    ColumnEntry.COLUMN_TYPE: column.column_type
-                }
-        return columns
-
-    def get_filters(self, table_name: str) -> dict:
-        _filter_map = {}
-        __session__ = sessionmaker(self.engine)
-        table_info = self.get_table_by_name(table_name)
-        _filters = {'table_id': table_info['id'], 'show_filter': True}
-        with __session__() as session:
-            for column in session.query(MetaDataColumn).filter_by(**_filters).all():
-                _filter_map[column.column_name] = {
-                    ColumnEntry.COLUMN_LABEL: column.filter_label,
-                    ColumnEntry.COLUMN_WIDGET: None
-                }
-        return _filter_map
-
-    def data(self, table_name: str, columns: dict, filters: dict) -> list:
-        data = []
-        __session__ = sessionmaker(self.engine)
-        table = self.registry[table_name]
-        with __session__() as session:
-            entries = []
-            if len(filters) == 0:
-                entries = session.scalars(select(table)).all()
-            else:
-                entries = session.scalars(select(table).filter_by(**filters)).all()
-            for entry in entries:
-                # self.log.info("data: %s", entry)
-                row = []
-                for order in columns.keys():
-                    column_name = columns[order][ColumnEntry.COLUMN_NAME]
-                    ref_column = columns[order][ColumnEntry.COLUMN_REF_COLUMN]
-                    if str(column_name).endswith("_id"):
-                        ref_table = column_name[:-3]
-                        ref = getattr(entry, ref_table)
-                        value = getattr(ref, ref_column)
-                        row.append(value)
-                    else:
-                        row.append(getattr(entry, column_name))
-                data.append(row)
-        # self.log.info("data: %s", data)
-        return data
-
-    def export_db(self, export_type: str, export_file_name: str) -> dict:
-        results = {}
-        db = {}
-        export_table_list = self.get_table_names()
-        for table in export_table_list:
-            columns = self.get_column_meta_data(table, view_only=False)
-            if table in self.registry:
-                model = self.registry[table]
-            else:
-                logging.info(f"table {table} is not registered")
-                continue
-            __session__ = sessionmaker(self.engine)
-            with __session__() as session:
-                rows = session.query(model).all()
-                entries = []
-                for row in rows:
-                    # print(row)
-                    entry = {}
-                    for order in columns:
-                        # print(columns[order])
-                        column_name = columns[order][ColumnEntry.COLUMN_NAME]
-                        # print(f"get value {column_name} from {row} of table {table}")
-                        try:
-                            value = getattr(row, column_name)
-                            if isinstance(value, datetime):
-                                entry[column_name] = str(value)
-                            else:
-                                entry[column_name] = value
-                        except AttributeError:
-                            pass
-                    entries.append(entry)
-                db[table] = entries
-                results[table] = len(entries)
-        match export_type:
-            case "JSON":
-                json_dump = json.dumps(db, indent=4)
-                with open(export_file_name, "w") as dump_file:
-                    dump_file.write(json_dump)
-            case "YAML":
-                pass
-            case "SQLite":
-                pass
-        logging.info(f"{len(results)} tables exported")
-        return results
-
-    def import_db(self, import_file_name: str) -> dict:
-        result = {}
-        import_file = Path(import_file_name)
-        if not import_file.exists():
-            logging.info(f"File {import_file_name} does not exist. Do nothing.")
-            return result
-        match import_file.suffix:
-            case '.json':
-                print("read json file")
-                with open(import_file_name, 'r') as json_file:
-                    json_load = json.load(json_file)
-                for table in json_load:
-                    logging.info(f"{table}: {len(json_load[table])}")
-                    result[table] = self.import_table(table, json_load[table])
-            case '.yml':
-                print("read yaml file")
-            case '.yaml':
-                print("read yaml file")
-            case '.db':
-                print("read sqlite file")
-        return result
-
-    def import_table(self, table_name: str, items:list) -> dict:
-        result = {}
-        updated = []
-        added = []
-        remaining = []
-        existing_ids = self.get_ids(table_name)
-        logging.info(f"found {len(existing_ids)} existing ids for table {table_name}")
-        for item in items:
-            current_id = item['id']
-            # print(f"import item: {item}")
-            found_item = None
-            __session__ = sessionmaker(self.engine)
-            with __session__() as session:
-                found_item = session.get(self.registry[table_name], current_id)
-                # print(f"found item: {found_item}")
-            if found_item is not None:
-                changed = self.update_entry(table_name, current_id, item)
-                updated.append(item)
-                if changed:
-                    logging.info(f"{current_id} has changed")
-                    updated.append(item)
-                existing_ids.remove(current_id)
-            else:
-                try:
-                    self.add_entry(table_name, item)
-                    added.append(item)
-                except IntegrityError as error:
-                    logging.info(f"Could not add item, due to: {error.detail}")
-        if len(existing_ids) > 0:
-            print(f"remaining items for {table_name}: {existing_ids}")
-            remaining.extend(existing_ids)
-        result['updated'] = updated
-        result['added'] = added
-        result['remaining'] = remaining
-        return result
-
-    def get_ids(self, table_name: str) -> list:
-        existing_ids = []
-        __session__ = sessionmaker(self.engine)
-        with __session__() as session:
-            items = session.query(self.registry[table_name]).all()
-            for item in items:
-                existing_ids.append(getattr(item, 'id'))
-        return existing_ids
-
-    def add_entry(self, table_name: str, update_item: dict):
-        logging.debug(f"add entry to table {table_name} with {update_item}")
-        __session__ = sessionmaker(self.engine)
-        with __session__() as session:
-            add_item = self.registry[table_name]()
-            for key in update_item.keys():
-                update_value = update_item[key]
-                setattr(add_item, key, update_value)
-            session.add(add_item)
-            session.commit()
-
-    def update_entry(self, table_name, current_id, update_item: dict) -> bool:
-        # self.log.info("update entry to table %s", table_name)
-        __session__ = sessionmaker(self.engine)
-        with __session__() as session:
-            existing_item = session.query(self.registry[table_name]).get(current_id)
-            changed = False
-            for key in update_item.keys():
-                update_value = update_item[key]
-                existing_value = getattr(existing_item, key)
-                if type(existing_value) is not type(update_value):
-                    existing_value = str(existing_value)
-                if existing_value != update_value:
-                    logging.info(f"{key} has changed: {existing_value} != {update_value}")
-                    setattr(existing_item, key, update_value)
-                    session.commit()
-                    changed = True
-                    logging.info(f"update {key} with {update_value}")
-        return changed
-
-    def add_link(self, link: str) -> dict:
-        result = {}
-        __session__ = sessionmaker(self.engine)
-        with __session__() as session:
-            media_file = MediaFile()
-            media_file.id = str(uuid.uuid4())
-            media_file.created_date = datetime.now()
-            media_file.last_modified_date = datetime.now()
-            media_file.version = 0
-            media_file.url = link
-            media_file.review = 1
-            media_file.should_download = 1
-            try:
-                session.add(media_file)
-                session.commit()
-                result['added'] = {'url': media_file.url, 'title': media_file.title, 'review': media_file.review, 'download': media_file.should_download}
-            except IntegrityError as error:
-                session.rollback()
-                result['error'] = error.orig
-        return result
-
-    def update_titles(self) -> dict:
-        update_list = {}
-        __session__ = sessionmaker(self.engine)
-        _filter = { 'review': True}
-        with __session__() as session:
-            links = session.query(MediaFile).filter_by(**_filter).all()
-            self.log.info("%d entries found for updating titles", len(links))
-            for link in links:
-                url = link.url
-                if url is None:
-                    continue
-                link.update_title()
-                session.commit()
-                update_list[link.id] = link.title
-        return update_list
-
-    def get_download_list(self) -> List[str]:
-        download_list = []
-        __session__ = sessionmaker(self.engine)
-        _filter = { 'should_download': True}
-        with __session__() as session:
-            links = session.query(MediaFile).filter_by(**_filter).all()
-            for link in links:
-                url = link.url
-                if url is None:
-                    continue
-                download_list.append(link.id)
-        return download_list
-
-    def download_file(self, entry_id: str, download_dir = "/data/media", dl_tool = "yt-dlp") -> str:
-        __session__ = sessionmaker(self.engine)
-        with __session__() as session:
-            link = session.query(MediaFile).get(entry_id)
-            link.download_file(download_dir, dl_tool)
-            session.commit()
-            file_name = link.file_name
-        return file_name
-
-    def delete_entries(self):
-        for (table_name, table) in self.registry.items():
-            # self.log.info("delete entries from table %s", table_name)
-            __session__ = sessionmaker(self.engine)
-            with __session__() as session:
-                items = session.query(table).all()
-                for item in items:
-                    session.delete(item)
-                session.commit()
-
-    def check_files(self):
-        pass

kontor-api/src/db/models/media.py

@@ -3,18 +3,19 @@ import re
 import subprocess
 from datetime import datetime
 from pathlib import Path
+from typing import List, Optional
 
 import requests
 from bs4 import BeautifulSoup
-from sqlalchemy import Column, String, ForeignKey, Boolean
-from sqlalchemy.orm import relationship
+from sqlalchemy import ForeignKey
+from sqlalchemy.orm import Mapped, relationship, mapped_column
 
 from src.db.models.base import Base, BaseMixin, BaseVideoMixin
 
 
 class MediaFile(Base, BaseMixin, BaseVideoMixin):
     __tablename__ = 'media_file'
-    media_actor_files = relationship("MediaActorFile")
+    media_actor_files: Mapped[List["MediaActorFile"]] = relationship(back_populates="media_file")
 
     def __repr__(self):
         return f'MediaFile({self.id} {self.title} {self.title})'
@@ -22,51 +23,6 @@ class MediaFile(Base, BaseMixin, BaseVideoMixin):
     def __str__(self):
         return f'{self.title}({self.id})'
 
-    def update_title(self) -> None:
-        logging.info(f"update title for {self.url}")
-        try:
-            r = requests.get(str(self.url))
-            soup = BeautifulSoup(r.content, "html.parser")
-            title = soup.title.get_text() # type: ignore
-            self.title = title
-            self.review = False
-        except:
-            self.title = None
-            self.review = True
-        self.last_modified_date = datetime.now()
-
-    def download_file(self, download_dir: str, dl_tool: str):
-        logging.info(f"download file for {self.url} to {download_dir}")
-        result = subprocess.run([dl_tool, self.url], cwd=download_dir, capture_output=True, text=True) # type: ignore
-        if result.returncode == 0:
-            output = result.stdout
-            output = re.sub(' +', ' ', output)
-            lines_list = output.splitlines()
-            file_name = self.__parse_output__(lines_list)
-            if file_name is None:
-                self.review = True
-                self.should_download = True
-                self.file_name = None
-            else:
-                download_file = Path(file_name)
-                self.should_download = False
-                self.file_name = download_file.name
-                self.cloud_link = str(download_file.absolute())
-            self.last_modified_date = datetime.now()
-
-    def __parse_output__(self, lines_list):
-        self.file_name = None
-        for line in lines_list:
-            if 'has already been downloaded' in line:
-                end_len = len(' has already been downloaded')
-                self.file_name = line[11:-end_len]
-            if 'Destination' in line:
-                line_len = len(line)
-                start_len = len('[download] Destination: ')
-                file_len = line_len - start_len
-                self.file_name = line[-file_len:]
-        return self.file_name
-
 
 class MediaActor(Base, BaseMixin):
     __tablename__ = 'media_actor'
@@ -82,10 +38,10 @@ class MediaActor(Base, BaseMixin):
 
 class MediaActorFile(Base, BaseMixin):
     __tablename__ = 'media_actor_file'
-    media_actor_id = Column(String, ForeignKey("media_actor.id"), nullable=False)
-    media_actor = relationship("MediaActor", back_populates="media_actor_files")
-    media_file_id = Column(String, ForeignKey("media_file.id"), nullable=True)
-    media_file = relationship("MediaFile", back_populates="media_actor_files")
+    media_actor_id: Mapped[str] = mapped_column(ForeignKey("media_actor.id"), nullable=False)
+    media_actor: Mapped[MediaActor] = relationship(back_populates="media_actor_files")
+    media_file_id: Mapped[str] = mapped_column(ForeignKey("media_file.id"), nullable=True)
+    media_file: Mapped[MediaFile] = relationship(back_populates="media_actor_files")
 
     def __repr__(self):
         return f'MediaActorFile({self.id} {self.media_actor_id} {self.media_file_id})'
@@ -95,20 +51,20 @@ class MediaActorFile(Base, BaseMixin):
 
 class MediaArticle(Base, BaseMixin):
     __tablename__ = 'media_article'
-    review = Column(Boolean)
-    title = Column(String)
-    url = Column(String, unique=True)
+    review: Mapped[bool]
+    title: Mapped[str]
+    url: Mapped[str] = mapped_column(unique=True)
 
 
 class MediaVideo(Base, BaseMixin):
     __tablename__ = 'media_video'
-    cloud_link = Column(String)
-    file_name = Column(String)
-    path = Column(String)
-    review = Column(Boolean)
-    title = Column(String)
-    url = Column(String, unique=True)
-    should_download = Column(Boolean)
+    cloud_link: Mapped[str]
+    file_name: Mapped[str]
+    path: Mapped[str]
+    review: Mapped[bool]
+    title: Mapped[str]
+    url: Mapped[str] = mapped_column(unique=True)
+    should_download: Mapped[bool]
 
     def __repr__(self):
         return f'MediaFile({self.id} {self.title} {self.url})'

kontor-api/src/db/models/tysc.py

@@ -1,5 +1,6 @@
-from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Boolean
-from sqlalchemy.orm import relationship
+from typing import List
+from sqlalchemy import ForeignKey, UniqueConstraint
+from sqlalchemy.orm import relationship, mapped_column, Mapped
 
 from src.db.models.base import Base, BaseMixin
 
@@ -9,18 +10,18 @@ class Sport(Base, BaseMixin):
     __table_args__ = (
         UniqueConstraint("name"),
     )
-    name = Column(String, nullable=False, index=True, unique=True)
-    teams = relationship("Team")
-    positions = relationship("FieldPosition")
+    name: Mapped[str] = mapped_column(nullable=False, index=True, unique=True)
+    teams: Mapped[List["Team"]] = relationship(back_populates="sport")
+    positions: Mapped[List["FieldPosition"]] = relationship(back_populates="sport")
 
 
 class Team(Base, BaseMixin):
     __tablename__ = "team"
-    name = Column(String, nullable=False, index=True, unique=True)
-    short_name = Column(String, nullable=False, )
-    sport_id = Column(String, ForeignKey("sport.id"), nullable=False)
-    sport = relationship("Sport", back_populates="teams")
-    roosters = relationship("Rooster")
+    name: Mapped[str] = mapped_column(nullable=False, index=True, unique=True)
+    short_name: Mapped[str] = mapped_column(nullable=False)
+    sport_id: Mapped[str] = mapped_column(ForeignKey("sport.id"), nullable=False)
+    sport: Mapped[Sport] = relationship(back_populates="teams")
+    roosters: Mapped[List["Rooster"]] = relationship(back_populates="team")
 
 
 class FieldPosition(Base, BaseMixin):
@@ -29,11 +30,11 @@ class FieldPosition(Base, BaseMixin):
         UniqueConstraint("name", "sport_id"),
         UniqueConstraint("short_name", "sport_id"),
     )
-    name = Column(String, nullable=False, index=True)
-    short_name = Column(String, nullable=False)
-    sport_id = Column(String, ForeignKey("sport.id"), nullable=False, index=True)
-    sport = relationship("Sport", back_populates="positions")
-    roosters = relationship("Rooster")
+    name: Mapped[str] = mapped_column(nullable=False, index=True)
+    short_name: Mapped[str] = mapped_column(nullable=False)
+    sport_id: Mapped[str] = mapped_column(ForeignKey("sport.id"), nullable=False, index=True)
+    sport: Mapped[Sport] = relationship(back_populates="positions")
+    roosters: Mapped[List["Rooster"]] = relationship(back_populates="position")
 
 
 class Player(Base, BaseMixin):
@@ -41,9 +42,9 @@ class Player(Base, BaseMixin):
     __table_args__ = (
         UniqueConstraint("first_name", "last_name"),
     )
-    first_name = Column(String, nullable=False, index=True)
-    last_name = Column(String, nullable=False, index=True)
-    roosters = relationship("Rooster")
+    first_name: Mapped[str] = mapped_column(nullable=False, index=True)
+    last_name: Mapped[str] = mapped_column(nullable=False, index=True)
+    roosters: Mapped[List["Rooster"]] = relationship(back_populates="player")
 
     def get_full_name(self) -> str:
         return f"{self.last_name}, {self.first_name}"
@@ -54,21 +55,21 @@ class Rooster(Base, BaseMixin):
     __table_args__ = (
         UniqueConstraint("year", "team_id", "player_id", "position_id"),
     )
-    year = Column(Integer)
-    team_id = Column(String, ForeignKey("team.id"), nullable=False, index=True)
-    team = relationship("Team", back_populates="roosters")
-    player_id = Column(String, ForeignKey("player.id"), nullable=False, index=True)
-    player = relationship("Player", back_populates="roosters")
-    position_id = Column(String, ForeignKey("field_position.id"), nullable=False, index=True)
-    position = relationship("FieldPosition", back_populates="roosters")
-    cards = relationship("Card")
+    yea: Mapped[int]
+    team_id: Mapped[str] = mapped_column(ForeignKey("team.id"), nullable=False, index=True)
+    team: Mapped[Team] = relationship(back_populates="roosters")
+    player_id: Mapped[str] = mapped_column(ForeignKey("player.id"), nullable=False, index=True)
+    player: Mapped[Player] = relationship(back_populates="roosters")
+    position_id: Mapped[str] = mapped_column(ForeignKey("field_position.id"), nullable=False, index=True)
+    position: Mapped[FieldPosition] = relationship(back_populates="roosters")
+    cards: Mapped[List["Card"]] = relationship(back_populates="rooster")
 
 
 class Vendor(Base, BaseMixin):
     __tablename__ = "vendor"
-    name = Column(String, nullable=False, unique=True, index=True)
-    card_sets = relationship("CardSet")
-    cards = relationship("Card")
+    name: Mapped[str] = mapped_column(nullable=False, unique=True, index=True)
+    card_sets: Mapped[List["CardSet"]] = relationship(back_populates="vendor")
+    cards: Mapped[List["Card"]] = relationship(back_populates="vendor")
 
 
 class CardSet(Base, BaseMixin):
@@ -76,12 +77,12 @@ class CardSet(Base, BaseMixin):
     __table_args__ = (
         UniqueConstraint("name", "vendor_id"),
     )
-    name = Column(String, index=True)
-    parallel_set = Column(Boolean)
-    insert_set = Column(Boolean)
-    vendor_id = Column(String, ForeignKey("vendor.id"), nullable=False, index=True)
-    vendor = relationship("Vendor", back_populates="card_sets")
-    cards = relationship("Card")
+    name: Mapped[str] = mapped_column(index=True)
+    parallel_set: Mapped[bool]
+    insert_set: Mapped[bool]
+    vendor_id: Mapped[str] = mapped_column(ForeignKey("vendor.id"), nullable=False, index=True)
+    vendor: Mapped[Vendor] = relationship(back_populates="card_sets")
+    cards: Mapped[List["Card"]] = relationship(back_populates="card_set")
 
 
 class Card(Base, BaseMixin):
@@ -89,11 +90,11 @@ class Card(Base, BaseMixin):
     __table_args__ = (
         UniqueConstraint("card_number", "year", "vendor_id", "card_set_id"),
     )
-    card_number = Column(Integer, index=True)
-    year = Column(Integer, index=True)
-    card_set_id = Column(String, ForeignKey("card_set.id"), nullable=False)
-    card_set = relationship("CardSet", back_populates="cards")
-    rooster_id = Column(String, ForeignKey("rooster.id"), nullable=False)
-    rooster = relationship("Rooster", back_populates="cards")
-    vendor_id = Column(String, ForeignKey("vendor.id"), nullable=False)
-    vendor = relationship("Vendor", back_populates="cards")
+    card_number: Mapped[int] = mapped_column(index=True)
+    year: Mapped[int] = mapped_column(index=True)
+    card_set_id: Mapped[str] = mapped_column(ForeignKey("card_set.id"), nullable=False)
+    card_set: Mapped[CardSet] = relationship(back_populates="cards")
+    rooster_id: Mapped[str] = mapped_column(ForeignKey("rooster.id"), nullable=False)
+    rooster: Mapped[Rooster] = relationship(back_populates="cards")
+    vendor_id: Mapped[str] = mapped_column(ForeignKey("vendor.id"), nullable=False)
+    vendor: Mapped[Vendor] = relationship(back_populates="cards")

kontor-api/src/db/repository/comics/worktype.py

@@ -1,6 +1,6 @@
 import uuid
 from datetime import datetime
-from typing import AnyStr
+from typing import AnyStr, Optional
 
 from sqlalchemy.orm import Session
 
@@ -22,11 +22,12 @@ def create_new_worktype(work: AddWorkType, db: Session) -> WorkType:
     return worktype
 
 
-def update_worktype(work: AddWorkType, worktype_id: AnyStr, db: Session) -> WorkType:
+def update_worktype(work: AddWorkType, worktype_id: AnyStr, db: Session) -> Optional[WorkType]:
     logger.info("update worktype")
-    worktype = db.get(WorkType, worktype_id)
-    worktype.name = work.worktype
-    db.add(worktype)
-    db.commit()
-    db.refresh(worktype)
+    worktype: Optional[WorkType] = db.get(WorkType, worktype_id)
+    if worktype is not None:
+        worktype.name = work.worktype
+        db.add(worktype)
+        db.commit()
+        db.refresh(worktype)
     return worktype

kontor-api/src/db/repository/user.py

@@ -0,0 +1,50 @@
+from datetime import datetime
+from typing import Optional
+import uuid
+from src.core.log_conf import logger
+from src.db.models.admin import Assignment, Profile
+from sqlalchemy.orm import Session
+
+from src.schema.user.profile import ProfileModel, ProfileResponse
+
+
+
+def create_new_profile(new_profile: ProfileModel, db: Session) -> Profile:
+    logger.info(f"create MediaActor with url {new_profile.user_name}")
+    profile: Profile = Profile()
+    profile.id = str(uuid.uuid4())
+    profile.user_name = new_profile.user_name
+    profile.first_name = new_profile.first_name
+    profile.last_name = new_profile.last_name
+    profile.created_date = datetime.now()
+    profile.last_modified_date = datetime.now()
+    profile.version = 0
+    db.add(profile)
+    db.commit()
+    db.refresh(profile)
+    logger.info(f"created {profile}")
+    return profile
+
+def delete_profile(db: Session, profile_id: str):
+    logger.info(f"delete Profile with id {profile_id}")
+    profile: Optional[Profile] = db.get(Profile, profile_id)
+    if profile is not None:
+        assignments = profile.assignments
+        for assignment in assignments:
+            delete_assignment(db, assignment.id)
+        db.delete(profile)
+        db.commit()
+
+def get_profile_details(profile: Profile) -> ProfileResponse:
+    reponse: ProfileResponse = ProfileResponse(
+        id=profile.id, 
+        user_name=str(profile.user_name)
+    )
+    return reponse
+
+def delete_assignment(db: Session, assignment_id: str) -> None:
+    logger.info(f"delete Assignment with id {assignment_id}")
+    assignment: Optional[Assignment] = db.get(Assignment, assignment_id)
+    if assignment is not None:
+        db.delete(assignment)
+        db.commit()

kontor-api/src/schema/media/actor.py

@@ -1,18 +1,12 @@
-from datetime import datetime
-
-from src.db.models.media import MediaActor
+from typing import Optional
 from pydantic import BaseModel
 
 
 class MediaActorResponse(BaseModel):
     id: str
-    name: str | None
+    name: Optional[str]
     url: str
 
-class Actor(BaseModel):
-    name: str | None
+class MediaActorModel(BaseModel):
+    name: Optional[str]
     url: str
-
-def get_actor_details(media_actor: MediaActor) -> MediaActorResponse:
-    reponse: MediaActorResponse = MediaActorResponse(id=media_actor.id, name=str(media_actor.name), url=str(media_actor.url))
-    return reponse

kontor-api/src/schema/media/actorfile.py

@@ -1,6 +1,6 @@
 from datetime import datetime
 
-from src.db.models.media import MediaActorFile, MediaFile
+from src.db.models.media import MediaActorFile
 from pydantic import BaseModel
 
 
@@ -8,9 +8,3 @@ class MediaActorFileResponse(BaseModel):
     id: str
     file_id: str
     actor_id: str
-
-def get_actorfile_details(media_actorfile: MediaActorFile) -> MediaActorFileResponse:
-    response: MediaActorFileResponse = MediaActorFileResponse(id=media_actorfile.id, 
-                                                              file_id=str(media_actorfile.media_file_id), 
-                                                              actor_id=str(media_actorfile.media_actor_id))
-    return response

kontor-api/src/schema/media/file.py

@@ -30,9 +30,11 @@ def get_file_details(mediafile: MediaFile) -> MediaFileResponse:
 
 def set_file(model: MediaFileResponse, mediafile: MediaFile) -> None:
     mediafile.file_name = model.file_name
-    mediafile.cloud_link = model.cloud_link # type: ignore
-    mediafile.url = model.url # type: ignore
-    mediafile.title = model.title
+    mediafile.cloud_link = model.cloud_link
+    if model.url is not None:
+        mediafile.url = model.url
+    if model.title is not None:
+        mediafile.title = model.title
     mediafile.last_modified_date = datetime.now()
     mediafile.review = model.review
     mediafile.should_download = model.should_download

kontor-api/src/schema/user/profile.py

@@ -0,0 +1,13 @@
+from pydantic import BaseModel
+
+from src.db.models.admin import Profile
+
+
+class ProfileResponse(BaseModel):
+    id: str
+    user_name: str
+
+class ProfileModel(BaseModel):
+    user_name: str
+    first_name: str
+    last_name: str