fix ci/cd and more

Author: Aleks-Ti

README.md

@@ -1,3 +1,8 @@
 # API-medication-management
 
+Посмотреть бота можно в Telegram @MrChesterBot
+
+В этом репозитории находится API для обработки напоминаний, и микросервис для поставки напоминаний в очередь, для отправки конечному пользователю напоминания в Telegram.
+Бот находится в репозитории `https://github.com/Aleks-Ti/medication-management`
+
 ![Схема приложения](./image/architecture.png)

event_microservice/src/event/repository.py

@@ -1,3 +1,4 @@
+import logging
 from datetime import UTC, datetime, timedelta
 
 from sqlalchemy import Row

event_microservice/src/settings/configuration.py

@@ -55,7 +55,7 @@ class MQEnvs:
     network_port: int | None = int(getenv("RMQ_NETWOTK_PORT"))
     user: str | None = str(getenv("RMQ_USER"))
     password: str | None = str(getenv("RMQ_PASSWORD"))
-    host: str = os.getenv("RMQ_HOST") if os.getenv("DEV") == "local_container" else "host.docker.internal"
+    host: str = os.getenv("RMQ_HOST") if os.getenv("DEV") == "prod" else "host.docker.internal"
 
     def __post_init__(self):
         required_vars = ["network_port", "user", "password", "host"]

pyproject.toml

@@ -11,6 +11,7 @@ dependencies = [
     "fastapi>=0.115.5",
     "pika>=1.3.2",
     "pydantic>=2.9.2",
+    "pytest>=8.3.4",
     "sqlalchemy>=2.0.36",
     "uvicorn>=0.32.0",
 ]
@@ -87,3 +88,8 @@ exclude = [
 
 [tool.ruff.pydocstyle]
 convention = "google"
+
+[tool.pytest.ini_options]
+testpaths = ["tests"]
+filterwarnings = "ignore::DeprecationWarning"
+addopts = "-v -p no:cacheprovider"

src/settings/configuration.py

@@ -55,7 +55,7 @@ class MQEnvs:
     network_port: int | None = int(getenv("RMQ_NETWOTK_PORT"))
     user: str | None = str(getenv("RMQ_USER"))
     password: str | None = str(getenv("RMQ_PASSWORD"))
-    host: str = getenv("RMQ_HOST", "localhost")
+    host: str = getenv("RMQ_HOST") if getenv("DEV") == "local_container" else "host.docker.internal"
 
     def __post_init__(self) -> None:
         required_vars = ["ui_port", "network_port", "user", "password", "host"]

tests/fixtures/__init__.py

@@ -0,0 +1,51 @@
+from unittest.mock import MagicMock, Mock
+
+import pytest
+
+from src.drug_regimen.repository import ManagerRepository, RegimenRepository
+from src.drug_regimen.schemas import AddRegimenSchema, UpdateRegimenSchema
+from src.drug_regimen.service import RegimenService
+from src.utils.time_conversion import conversion_reception_time_to_GMT
+
+
+@pytest.fixture
+def regimen_service():
+    regimen_repository = Mock(spec=RegimenRepository)
+    manager_repository = Mock(spec=ManagerRepository)
+    return RegimenService(regimen_repository, manager_repository)
+
+
+def test_regimen_service_init(regimen_service):
+    assert regimen_service.regimen_repository is not None
+    assert regimen_service.manager_repository is not None
+    assert regimen_service.conversion_time is conversion_reception_time_to_GMT
+
+
+@pytest.mark.asyncio
+async def test_add_one_complex(regimen_service):
+    regimen_data = AddRegimenSchema(manager_id=1, reception_time="10:00", supplement="test", is_active=True)
+    manager_obj = Mock()
+    regimen_service.manager_repository.find_one.return_value = manager_obj
+    regimen_service.regimen_repository.add_one.return_value = Mock()
+
+    await regimen_service.add_one_complex(regimen_data)
+
+    regimen_service.manager_repository.find_one.assert_called_once_with(regimen_data.manager_id)
+    regimen_service.regimen_repository.add_one.assert_called_once()
+
+
+@pytest.mark.asyncio
+async def test_update_regmen(regimen_service):
+    regimen_data = UpdateRegimenSchema(reception_time="11:00", supplement="test2", is_active=False)
+    regimen_id = 1
+    regimen_obj = Mock()
+    regimen_service.regimen_repository.find_one_ON_manager.return_value = regimen_obj
+    regimen_service.regimen_repository.update_one.return_value = Mock()
+
+    await regimen_service.update_regmen(regimen_data, regimen_id)
+
+    regimen_service.regimen_repository.find_one_ON_manager.assert_called_once_with(regimen_id)
+    regimen_service.regimen_repository.update_one.assert_called_once_with(
+        regimen_obj.id,
+        regimen_data.model_dump(exclude_none=True),
+    )