feat(): update resume contracts

src/template_project/adapters/data_gateways/key_skills.py

@@ -23,8 +23,6 @@ class KeySkillsDataGateway:
         return result.scalars().all()
 
     async def add_skills(self, name: list[str]) -> None:
-        insert_statement = insert(key_skills_table).values(
-            [{"name": _} for _ in name]
-        )
+        insert_statement = insert(key_skills_table).values([{"name": _} for _ in name])
         with contextlib.suppress(IntegrityError):
             await self._session.execute(insert_statement)

src/template_project/adapters/data_gateways/resume.py

@@ -4,9 +4,29 @@ from typing import override
 from sqlalchemy import select
 from sqlalchemy.ext.asyncio import AsyncSession
 
-from template_project.adapters.data_gateways.tables import resume_prediction_table, resume_table
-from template_project.application.resume.data_gateway import ResumeDataGateway, ResumePredictionDataGateway
-from template_project.application.resume.entity import Resume, ResumeEmbeddingId, ResumeId, ResumePrediction
+from template_project.adapters.data_gateways.tables import (
+    resume_education_table,
+    resume_experience_table,
+    resume_prediction_table,
+    resume_project_table,
+    resume_table,
+)
+from template_project.application.resume.data_gateway import (
+    ResumeDataGateway,
+    ResumeEducationDataGateway,
+    ResumeExperienceDataGateway,
+    ResumePredictionDataGateway,
+    ResumeProjectDataGateway,
+)
+from template_project.application.resume.entity import (
+    Resume,
+    ResumeEducation,
+    ResumeEmbeddingId,
+    ResumeExperience,
+    ResumeId,
+    ResumePrediction,
+    ResumeProject,
+)
 from template_project.application.resume.errors import ResumeNotFoundError
 from template_project.application.user.entity import UserId
 
@@ -29,12 +49,7 @@ class DefaultResumeDataGateway(ResumeDataGateway):
 
     @override
     async def list_by_user_id(self, user_id: UserId, limit: int, offset: int) -> Sequence[Resume]:
-        statement = (
-            select(Resume)
-            .where(resume_table.c.user_id == user_id)
-            .limit(limit)
-            .offset(offset)
-        )
+        statement = select(Resume).where(resume_table.c.user_id == user_id).limit(limit).offset(offset)
         result = await self._session.execute(statement)
         return result.scalars().all()
 
@@ -73,3 +88,36 @@ class DefaultResumePredictionDataGateway(ResumePredictionDataGateway):
         statement = select(ResumePrediction).where(resume_prediction_table.c.resume_id == resume_id)
         result = await self._session.execute(statement)
         return result.scalar()
+
+
+class DefaultResumeExperienceDataGateway(ResumeExperienceDataGateway):
+    def __init__(self, session: AsyncSession) -> None:
+        self._session = session
+
+    @override
+    async def load_by_resume_id(self, resume_id: ResumeId) -> Sequence[ResumeExperience]:
+        statement = select(ResumeExperience).where(resume_experience_table.c.resume_id == resume_id)
+        result = await self._session.execute(statement)
+        return result.scalars().all()
+
+
+class DefaultResumeEducationDataGateway(ResumeEducationDataGateway):
+    def __init__(self, session: AsyncSession) -> None:
+        self._session = session
+
+    @override
+    async def load_by_resume_id(self, resume_id: ResumeId) -> Sequence[ResumeEducation]:
+        statement = select(ResumeEducation).where(resume_education_table.c.resume_id == resume_id)
+        result = await self._session.execute(statement)
+        return result.scalars().all()
+
+
+class DefaultResumeProjectDataGateway(ResumeProjectDataGateway):
+    def __init__(self, session: AsyncSession) -> None:
+        self._session = session
+
+    @override
+    async def load_by_resume_id(self, resume_id: ResumeId) -> Sequence[ResumeProject]:
+        statement = select(ResumeProject).where(resume_project_table.c.resume_id == resume_id)
+        result = await self._session.execute(statement)
+        return result.scalars().all()

src/template_project/adapters/data_gateways/tables.py

@@ -3,7 +3,6 @@ from typing import Any, Final, override
 
 from pgvector.sqlalchemy import Vector
 from sqlalchemy import (
-    ARRAY,
     Boolean,
     Column,
     DateTime,
@@ -23,8 +22,16 @@ from sqlalchemy.orm import registry
 
 from template_project.application.access_token.entity import AccessToken
 from template_project.application.auth_identity.entity import AuthIdentity, AuthMethod
+from template_project.application.common.enums import EducationGrade
 from template_project.application.notification_device.entity import NotificationDevice
-from template_project.application.resume.entity import Resume, ResumeEmbedding, ResumePrediction
+from template_project.application.resume.entity import (
+    Resume,
+    ResumeEducation,
+    ResumeEmbedding,
+    ResumeExperience,
+    ResumePrediction,
+    ResumeProject,
+)
 from template_project.application.user.entity import User
 from template_project.application.user.profile.entity import Profile
 
@@ -127,6 +134,7 @@ resume_table: Final = Table(
     Column("created_at", DateTime(timezone=True), nullable=False),
     Column("user_id", UUID, ForeignKey("users.id", ondelete="CASCADE"), nullable=False),
     Column("position", String, nullable=False),
+    Column("location", String, nullable=False),
     Column("about_me", String, nullable=False),
     Column("key_skills", StringArrayType(), nullable=False, server_default=text("'[]'::jsonb")),
     Column("experience_type", String, nullable=False),
@@ -158,7 +166,43 @@ key_skills_table: Final = Table(
     "key_skills",
     meta_data,
     Column("id", Integer, autoincrement=True, primary_key=True),
-    Column("name", String, nullable=False, unique=True)
+    Column("name", String, nullable=False, unique=True),
+)
+
+resume_experience_table: Final = Table(
+    "resume_experience",
+    meta_data,
+    Column("id", UUID, primary_key=True),
+    Column("deleted_at", DateTime(timezone=True)),
+    Column("created_at", DateTime(timezone=True), nullable=False),
+    Column("resume_id", UUID, ForeignKey("resume.id", ondelete="CASCADE"), nullable=False),
+    Column("place", String, nullable=False),
+    Column("description", String, nullable=False),
+    Column("months_duration", Integer, nullable=False),
+)
+
+resume_education_table: Final = Table(
+    "resume_education",
+    meta_data,
+    Column("id", UUID, primary_key=True),
+    Column("deleted_at", DateTime(timezone=True)),
+    Column("created_at", DateTime(timezone=True), nullable=False),
+    Column("resume_id", UUID, ForeignKey("resume.id", ondelete="CASCADE"), nullable=False),
+    Column("place", String, nullable=False),
+    Column("grade", Enum(EducationGrade, name="education_grade"), nullable=False),
+    Column("specialization", String, nullable=False),
+    Column("description", String, nullable=True),
+)
+
+resume_project_table: Final = Table(
+    "resume_project",
+    meta_data,
+    Column("id", UUID, primary_key=True),
+    Column("deleted_at", DateTime(timezone=True)),
+    Column("created_at", DateTime(timezone=True), nullable=False),
+    Column("resume_id", UUID, ForeignKey("resume.id", ondelete="CASCADE"), nullable=False),
+    Column("name", String, nullable=False),
+    Column("description", String, nullable=False),
 )
 
 
@@ -182,3 +226,6 @@ mapper_registry.map_imperatively(
         "recommended_skills": resume_prediction_table.c.recommended_skills,
     },
 )
+mapper_registry.map_imperatively(ResumeExperience, resume_experience_table)
+mapper_registry.map_imperatively(ResumeEducation, resume_education_table)
+mapper_registry.map_imperatively(ResumeProject, resume_project_table)