test: added missing tests

Author: JanssenBrm

tests/conftest.py

@@ -1,11 +1,22 @@
+from unittest.mock import MagicMock
+
 import pytest
 from fastapi.testclient import TestClient
+from sqlalchemy.orm import Session
+
 from app.main import app
 
+
 @pytest.fixture
 def client():
     return TestClient(app)
 
+    
+@pytest.fixture
+def fake_db_session():
+    # A simple mock DB session object
+    return MagicMock(spec=Session)
+
 
 # @pytest.fixture(autouse=True)
 # def disable_auth(monkeypatch):

tests/services/test_processing.py

@@ -4,7 +4,7 @@
 
 from app.database.models.processing_job import ProcessingJobRecord
 from app.schemas import BaseJobRequest, ProcessingJobSummary, ProcessType, ProcessingStatusEnum, ServiceDetails
-from app.services.processing import create_processing_job
+from app.services.processing import create_processing_job, get_processing_jobs_by_user_id
 
 
 def make_job_request():
@@ -22,7 +22,7 @@ def make_job_request():
 
 @patch("app.services.processing.save_job_to_db")
 @patch("app.services.processing.get_processing_platform")
-def test_create_processing_job_calls_platform_execute(mock_get_platform, mock_save_job_to_db):
+def test_create_processing_job_calls_platform_execute(mock_get_platform, mock_save_job_to_db, fake_db_session):
 
     # Arrange
     fake_job= make_job_request()
@@ -36,7 +36,7 @@ def test_create_processing_job_calls_platform_execute(mock_get_platform, mock_sa
 
     mock_save_job_to_db.return_value =fake_record
 
-    result = create_processing_job(None, "foobar", fake_job)
+    result = create_processing_job(fake_db_session, "foobar", fake_job)
 
     mock_get_platform.assert_called_once_with(fake_job.label)
     fake_platform.execute_job.assert_called_once_with(
@@ -48,11 +48,30 @@ def test_create_processing_job_calls_platform_execute(mock_get_platform, mock_sa
     assert result == fake_summary
 
 
-@patch("app.services.processing.save_job_to_db")
 @patch("app.services.processing.get_processing_platform")
-def test_create_processing_job_platform_raises(mock_get_platform, mock_save_job_to_db):
+def test_create_processing_job_platform_raises(mock_get_platform, fake_db_session):
     fake_summary = make_job_request() 
     mock_get_platform.side_effect = ValueError("Unsupported platform")
 
     with pytest.raises(ValueError, match="Unsupported platform"):
-        create_processing_job(None, "foobar", fake_summary)
+        create_processing_job(fake_db_session, "foobar", fake_summary)
+
+@patch("app.services.processing.get_jobs_by_user_id")
+def test_get_processing_jobs_by_user_id(mock_get_jobs, fake_db_session):
+    # Arrange
+    fake_db_records = [
+        MagicMock(id=1, title="Job 1", status=ProcessingStatusEnum.CREATED),
+        MagicMock(id=2, title="Job 2", status=ProcessingStatusEnum.CREATED),
+    ]
+    mock_get_jobs.return_value = fake_db_records
+
+    # Act
+    results = get_processing_jobs_by_user_id(fake_db_session, user="user1")
+
+    # Assert
+    mock_get_jobs.assert_called_once_with(fake_db_session, "user1")
+    assert len(results) == len(fake_db_records)
+    for i, job_summary in enumerate(results):
+        assert job_summary.id == fake_db_records[i].id
+        assert job_summary.title == fake_db_records[i].title
+        assert job_summary.status == fake_db_records[i].status