feat(repositories): implementación de la capa de repositorios y abstracción de acceso a datos

backend/app/repositories/__init__.py

@@ -1 +1,21 @@
-# repositories/__init__ — SkillStat
+from .category_repository import CategoryRepository
+from .city_repository import CityRepository
+from .skill_repository import SkillRepository
+from .job_repository import JobRepository
+from .job_skill_repository import JobSkillRepository
+from .user_repository import UserRepository
+from .alert_repository import AlertRepository
+from .trend_snapshot_repository import TrendSnapshotRepository
+from .backup_repository import BackupRepository
+
+__all__ = [
+    'CategoryRepository',
+    'CityRepository',
+    'SkillRepository',
+    'JobRepository',
+    'JobSkillRepository',
+    'UserRepository',
+    'AlertRepository',
+    'TrendSnapshotRepository',
+    'BackupRepository',
+]

backend/app/repositories/alert_repository.py

@@ -1 +1,6 @@
-# alert_repository — SkillStat
+from app.repositories.base_repository import BaseRepository
+from app.models import Alert
+
+class AlertRepository(BaseRepository):
+    def __init__(self):
+        super().__init__(Alert)

backend/app/repositories/backup_repository.py

@@ -1 +1,6 @@
-# backup_repository — SkillStat
+from app.repositories.base_repository import BaseRepository
+from app.models import Backup
+
+class BackupRepository(BaseRepository):
+    def __init__(self):
+        super().__init__(Backup)

backend/app/repositories/base_repository.py

@@ -1 +1,46 @@
-# base_repository — SkillStat
+from app.extensions import db
+
+class BaseRepository:
+    def __init__(self, model):
+        self.model = model
+
+    def get_all(self):
+        return db.session.query(self.model).all()
+
+    def get_by_id(self, id):
+        return db.session.get(self.model, id)
+
+    def create(self, data):
+        # Protegemos la transacción con un bloque de manejo de errores para garantizar que una falla en la escritura no deje bloqueada la sesión de la base de datos
+        try:
+            instance = self.model(**data)
+            db.session.add(instance)
+            db.session.commit()
+            return instance
+        except Exception as e:
+            db.session.rollback()
+            raise e
+
+    def update(self, id, data):
+        try:
+            instance = self.get_by_id(id)
+            if instance:
+                for key, value in data.items():
+                    setattr(instance, key, value)
+                db.session.commit()
+            return instance
+        except Exception as e:
+            db.session.rollback()
+            raise e
+
+    def delete(self, id):
+        try:
+            instance = self.get_by_id(id)
+            if instance:
+                db.session.delete(instance)
+                db.session.commit()
+                return True
+            return False
+        except Exception as e:
+            db.session.rollback()
+            raise e

backend/app/repositories/category_repository.py

@@ -1 +1,6 @@
-# category_repository — SkillStat
+from app.repositories.base_repository import BaseRepository
+from app.models import Category
+
+class CategoryRepository(BaseRepository):
+    def __init__(self):
+        super().__init__(Category)

backend/app/repositories/city_repository.py

@@ -1 +1,6 @@
-# city_repository — SkillStat
+from app.repositories.base_repository import BaseRepository
+from app.models import City
+
+class CityRepository(BaseRepository):
+    def __init__(self):
+        super().__init__(City)

backend/app/repositories/job_repository.py

@@ -1 +1,6 @@
-# job_repository — SkillStat
+from app.repositories.base_repository import BaseRepository
+from app.models import Job
+
+class JobRepository(BaseRepository):
+    def __init__(self):
+        super().__init__(Job)

backend/app/repositories/job_skill_repository.py

@@ -0,0 +1,6 @@
+from app.repositories.base_repository import BaseRepository
+from app.models import JobSkill
+
+class JobSkillRepository(BaseRepository):
+    def __init__(self):
+        super().__init__(JobSkill)

backend/app/repositories/skill_repository.py

@@ -1 +1,6 @@
-# skill_repository — SkillStat
+from app.repositories.base_repository import BaseRepository
+from app.models import Skill
+
+class SkillRepository(BaseRepository):
+    def __init__(self):
+        super().__init__(Skill)

backend/app/repositories/trend_snapshot_repository.py

@@ -0,0 +1,6 @@
+from app.repositories.base_repository import BaseRepository
+from app.models import TrendSnapshot
+
+class TrendSnapshotRepository(BaseRepository):
+    def __init__(self):
+        super().__init__(TrendSnapshot)

backend/app/repositories/user_repository.py

@@ -1 +1,6 @@
-# user_repository — SkillStat
+from app.repositories.base_repository import BaseRepository
+from app.models import User
+
+class UserRepository(BaseRepository):
+    def __init__(self):
+        super().__init__(User)