feat: service developments

pyproject.toml

@@ -25,6 +25,7 @@ sqlalchemy-clickhouse = "^0.1.5.post0"
 alembic = "^1.13.2"
 clickhouse-sqlalchemy = "^0.3.2"
 python-dotenv = "^1.0.1"
+addict = "^2.4.0"
 
 
 [build-system]

src/recommendation_engine/app/features/comments/services/comments.py

@@ -0,0 +1,3 @@
+class CommentService:
+    def parse_all_comments(self, comments):
+        pass

src/recommendation_engine/app/features/comments/services/extraction.py

@@ -0,0 +1,27 @@
+from addict import Dict
+from typing import List
+
+from ..domain.values.comment import CommentValue
+from ..domain.entity.getir import GetirComments
+from ....shared_kernel.extractor import Extractor
+from ..domain.entity.yemek_sepeti import YemekSepetiComments
+from ....shared_kernel.domain_providers import Providers
+
+
+class CommentsExtractorService(Extractor):
+    def __init__(self, provider_type: Providers, **kwargs):
+        self.kwargs = Dict(**kwargs)
+        self.provider = self.initialize_provider(provider_type)
+
+    def initialize_provider(
+        self, provider_type: Providers
+    ) -> GetirComments | YemekSepetiComments:
+        if provider_type == Providers.YEMEK_SEPETI:
+            return YemekSepetiComments(restaurant_id=self.kwargs.restaurant_id)
+        elif provider_type == Providers.GETIR:
+            return GetirComments(restaurant_id=self.kwargs.restaurant_id)
+        else:
+            ValueError("Provider is not defined.")
+
+    def crawl(self) -> List[CommentValue]:
+        return self.provider.process()

src/recommendation_engine/app/features/menu/services/__init__.py

@@ -0,0 +1,2 @@
+from .menu import MenuService
+from .extraction import MenuExtractorService

src/recommendation_engine/app/features/menu/services/extraction.py

@@ -0,0 +1,31 @@
+from addict import Dict
+from typing import List
+
+from ..domain.values import GeoValue
+from ..domain.values.menu import MenuValue
+from ..domain.entity.getir import GetirMenu
+from ....shared_kernel.extractor import Extractor
+from ..domain.entity.yemeksepeti import YemeksepetiMenu
+from ....shared_kernel.domain_providers import Providers
+
+
+class MenuExtractorService(Extractor):
+    def __init__(self, provider_type: Providers, **kwargs):
+        self.kwargs = Dict(**kwargs)
+        self.provider = self.initialize_provider(provider_type)
+
+    def initialize_provider(
+        self, provider_type: Providers
+    ) -> YemeksepetiMenu | GetirMenu:
+        if provider_type == Providers.YEMEK_SEPETI:
+            geo_value = GeoValue(lat=self.kwargs.lat, lon=self.kwargs.lon)
+            return YemeksepetiMenu(
+                geo_value=geo_value, restaurant_id=self.kwargs.restaurant_id
+            )
+        elif provider_type == Providers.GETIR:
+            return GetirMenu(restaurant_slug=self.kwargs.restaurant_slug)
+        else:
+            ValueError("Provider is not defined.")
+
+    def crawl(self) -> List[MenuValue]:
+        return self.provider.process()

src/recommendation_engine/app/features/menu/services/menu.py

@@ -0,0 +1,3 @@
+class MenuService:
+    def parse_all_menus(self, menus):
+        pass

src/recommendation_engine/app/tasks/menu.py

@@ -1,13 +1,19 @@
 from celery.app.task import Task
 
+
 from ..shared_kernel.scheduler.celery_app import celery_application
+from ..features.menu.services import MenuExtractorService, MenuService
 
 
 class MenuTask(Task):
     __name__ = "MenuTask"
 
     def run(self, *args, **kwargs):
-        pass
+        menu_service = MenuService()
+        menu_extractor = MenuExtractorService(**kwargs)
+
+        restaurant_list = menu_extractor.crawl()
+        menu_service.parse_all_menus(restaurant_list)
 
 
 celery_application.register_task(MenuTask)