test(exotaxoserver): newly tested endpoint

Author: grololo06

QA/py/tests/api_wrappers.py

@@ -84,3 +84,6 @@ def api_check_job_failed(fastapi, job_id, expected_message):
         expected_message,
     ), job_dict
     return rsp
+
+
+UPLOAD_FILE_URL = "/user_files/"

QA/py/tests/holes.py

@@ -10,7 +10,7 @@
 from tests.credentials import USER_AUTH, CREATOR_AUTH
 from tests.test_classification import OBJECT_SET_SUMMARY_URL
 from tests.test_import import PLAIN_FILE_PATH, do_test_import
-from tests.test_import_simple import UPLOAD_FILE_URL
+from tests.api_wrappers import UPLOAD_FILE_URL
 
 MYFILES_URL = "/my_files/{sub_path}"
 COMMON_FILES_URL = "/common_files/?path={sub_path}"

QA/py/tests/test_import.py

@@ -7,6 +7,8 @@
 from pathlib import Path
 
 import pytest
+from starlette import status
+
 from API_models.crud import *
 
 # noinspection PyPackageRequirements
@@ -17,17 +19,15 @@
 from API_operations.CRUD.Projects import ProjectsService
 from API_operations.JsonDumper import JsonDumper
 
-
 # noinspection PyPackageRequirements
 from DB.Job import DBJobStateEnum
-from starlette import status
-
 from tests.api_wrappers import (
     api_file_import,
     api_wait_for_stable_job,
     api_check_job_questions,
+    UPLOAD_FILE_URL,
 )
-from tests.credentials import ADMIN_AUTH, ADMIN_USER_ID
+from tests.credentials import ADMIN_AUTH, ADMIN_USER_ID, CREATOR_USER_ID, CREATOR_AUTH
 from tests.jobs import (
     check_job_ok,
     check_job_errors,

QA/py/tests/test_import_simple.py

@@ -25,10 +25,9 @@
 from tests.credentials import ADMIN_USER_ID, CREATOR_AUTH, CREATOR_USER_ID
 from tests.test_import import PLAIN_DIR, create_project, PLAIN_FILE_PATH
 from tests.jobs import check_job_ok
-from tests.api_wrappers import api_wait_for_stable_job
+from tests.api_wrappers import api_wait_for_stable_job, UPLOAD_FILE_URL
 
 IMPORT_IMAGES_URL = "/simple_import/{project_id}?dry_run={dry_run}"
-UPLOAD_FILE_URL = "/user_files/"
 
 
 # @pytest.mark.skip()

QA/py/tests/test_my_files.py

@@ -20,13 +20,13 @@
     api_file_import,
     api_wait_for_stable_job,
     api_check_job_errors,
+    UPLOAD_FILE_URL,
 )
 from tests.test_import import (
     SHARED_DIR,
     V6_FILE,
     create_project,
 )
-from tests.test_import_simple import UPLOAD_FILE_URL
 
 SEPARATOR = "/"
 DIRPATH = "XXX"

QA/py/tests/test_taxoserver.py

@@ -8,6 +8,7 @@
 
 SEARCH_WORMS_URL = "/searchworms/{}"
 TAXA_FROM_CENTRAL_URL = "/taxa/pull_from_central"
+TAXON_PUT = "/taxon/central"
 
 ACARTIA_RSP = [
     {
@@ -123,3 +124,56 @@ def test_pull_taxa_update_from_central(fastapi, mocker):
         rsp = fastapi.get(TAXA_FROM_CENTRAL_URL, headers=ADMIN_AUTH)
         # assert rsp.status_code == status.HTTP_200_OK
         assert rsp.json() == {"inserts": 0, "updates": 0, "error": None}
+
+
+def test_add_taxon_in_central(fastapi, mocker):
+    # Mock the 'call' method of EcoTaxoServerClient
+    mock_call = mocker.patch("providers.EcoTaxoServer.EcoTaxoServerClient.call")
+    mock_response = mocker.Mock()
+    mock_response.json.return_value = {"msg": "ok", "id": 789999}
+    mock_call.return_value = mock_response
+
+    params = {
+        "name": "NewTaxon",
+        "parent_id": 1,
+        "taxotype": "P",
+        "creator_email": "creator@test.com",
+        "source_desc": "Test source",
+        "source_url": "http://test.com",
+    }
+
+    rsp = fastapi.put(TAXON_PUT, params=params, headers=ADMIN_AUTH)
+
+    assert rsp.status_code == status.HTTP_200_OK
+    assert rsp.json()["msg"] == "ok"
+
+    # Verify the mock was called correctly
+    # The service adds 'creation_datetime' and 'taxostatus'
+    called_args = mock_call.call_args
+    assert called_args[0][0] == "/settaxon/"
+    sent_params = called_args[0][1]
+    assert sent_params["name"] == "NewTaxon"
+    assert (
+        sent_params["parent_id"] == "1"
+    )  # FastAPI Query params are strings in request.query_params
+    assert sent_params["taxotype"] == "P"
+    assert sent_params["creator_email"] == "creator@test.com"
+    assert sent_params["taxostatus"] == "N"
+    assert "creation_datetime" in sent_params
+
+
+def test_add_taxon_in_central_unauthorized(fastapi, mocker):
+    # Mock the 'call' method of EcoTaxoServerClient
+    mock_call = mocker.patch("providers.EcoTaxoServer.EcoTaxoServerClient.call")
+
+    params = {
+        "name": "NewTaxonUnauthorized",
+        "parent_id": 1,
+        "taxotype": "P",
+        "creator_email": "creator@test.com",
+    }
+
+    # Unauthenticated call
+    rsp = fastapi.put(TAXON_PUT, params=params)
+    assert rsp.status_code == status.HTTP_403_FORBIDDEN
+    assert mock_call.call_count == 0