Add job request wrapper internal reuse architecture guard

Co-authored-by: Shri Sukhani <shrisukhani@users.noreply.github.com>

Author: cursoragent

CONTRIBUTING.md

@@ -122,6 +122,7 @@ This runs lint, format checks, compile checks, tests, and package build.
   - `tests/test_job_query_params_helper_usage.py` (shared scrape/crawl query-param helper usage enforcement),
   - `tests/test_job_request_helper_usage.py` (shared scrape/crawl/extract request-helper usage enforcement),
   - `tests/test_job_request_internal_reuse.py` (shared job request helper internal reuse of shared model request helpers),
+  - `tests/test_job_request_wrapper_internal_reuse.py` (parsed job-request wrapper internal reuse of shared model request helpers),
   - `tests/test_job_route_builder_usage.py` (shared job/web request-helper route-builder usage enforcement),
   - `tests/test_job_route_constants_usage.py` (shared scrape/crawl/extract route-constant usage enforcement),
   - `tests/test_job_start_payload_helper_usage.py` (shared scrape/crawl start-payload helper usage enforcement),

tests/test_architecture_marker_usage.py

@@ -72,6 +72,7 @@
     "tests/test_job_poll_helper_boundary.py",
     "tests/test_job_poll_helper_usage.py",
     "tests/test_job_request_internal_reuse.py",
+    "tests/test_job_request_wrapper_internal_reuse.py",
     "tests/test_job_route_builder_usage.py",
     "tests/test_job_route_constants_usage.py",
     "tests/test_job_request_helper_usage.py",

tests/test_job_request_wrapper_internal_reuse.py

@@ -0,0 +1,53 @@
+import ast
+from pathlib import Path
+
+import pytest
+
+pytestmark = pytest.mark.architecture
+
+
+MODULE_PATH = Path("hyperbrowser/client/managers/job_request_utils.py")
+
+SYNC_WRAPPER_TO_MODEL_HELPER = {
+    "start_job": "post_model_request(",
+    "get_job_status": "get_model_request(",
+    "get_job": "get_model_request(",
+    "put_job_action": "put_model_request(",
+}
+
+ASYNC_WRAPPER_TO_MODEL_HELPER = {
+    "start_job_async": "post_model_request_async(",
+    "get_job_status_async": "get_model_request_async(",
+    "get_job_async": "get_model_request_async(",
+    "put_job_action_async": "put_model_request_async(",
+}
+
+
+def _collect_function_sources() -> dict[str, str]:
+    module_text = MODULE_PATH.read_text(encoding="utf-8")
+    module_ast = ast.parse(module_text)
+    function_sources: dict[str, str] = {}
+    for node in module_ast.body:
+        if isinstance(node, (ast.FunctionDef, ast.AsyncFunctionDef)):
+            function_source = ast.get_source_segment(module_text, node)
+            if function_source is not None:
+                function_sources[node.name] = function_source
+    return function_sources
+
+
+def test_sync_job_request_wrappers_delegate_to_model_helpers():
+    function_sources = _collect_function_sources()
+    for wrapper_name, helper_call in SYNC_WRAPPER_TO_MODEL_HELPER.items():
+        wrapper_source = function_sources[wrapper_name]
+        assert helper_call in wrapper_source
+        assert "client.transport." not in wrapper_source
+        assert "parse_response_model(" not in wrapper_source
+
+
+def test_async_job_request_wrappers_delegate_to_model_helpers():
+    function_sources = _collect_function_sources()
+    for wrapper_name, helper_call in ASYNC_WRAPPER_TO_MODEL_HELPER.items():
+        wrapper_source = function_sources[wrapper_name]
+        assert helper_call in wrapper_source
+        assert "client.transport." not in wrapper_source
+        assert "parse_response_model(" not in wrapper_source