Centralize request routing, enforce feature parity in CI, add request cancellation

.github/workflows/ci.yml

@@ -6,6 +6,9 @@ on:
   pull_request:
     branches: [main]
 
+permissions:
+  contents: read
+
 jobs:
   # Check version synchronization
   version-check:
@@ -17,7 +20,7 @@ jobs:
       - name: Set up Python
         uses: actions/setup-python@v5
         with:
-          python-version: "3.14"
+          python-version: "3.12"
 
       - name: Check version sync
         run: python scripts/sync-versions.py --check
@@ -32,15 +35,18 @@ jobs:
       - name: Set up Python
         uses: actions/setup-python@v5
         with:
-          python-version: "3.14"
+          python-version: "3.12"
 
       - name: Check feature parity
         run: python scripts/check-feature-parity.py
 
   # TypeScript CI
   typescript:
-    name: TypeScript
+    name: TypeScript (Node ${{ matrix.node-version }})
     runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        node-version: ["18", "20", "22"]
     defaults:
       run:
         working-directory: ts
@@ -50,7 +56,7 @@ jobs:
       - name: Set up Node.js
         uses: actions/setup-node@v4
         with:
-          node-version: "20"
+          node-version: ${{ matrix.node-version }}
           cache: "npm"
           cache-dependency-path: ts/package-lock.json
 
@@ -72,7 +78,7 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        python-version: ["3.14"]
+        python-version: ["3.11", "3.12", "3.13"]
     defaults:
       run:
         working-directory: python
@@ -96,7 +102,7 @@ jobs:
         run: mypy numbersprotocol_capture --ignore-missing-imports
 
       - name: Run tests
-        run: pytest -v
+        run: pytest -v --cov-fail-under=75
 
   # All checks passed
   ci-success:

python/numbersprotocol_capture/client.py

@@ -175,7 +175,7 @@ def _request(
         *,
         data: dict[str, Any] | None = None,
         files: dict[str, Any] | None = None,
-        json_body: dict[str, Any] | None = None,
+        json_body: dict[str, Any] | list[Any] | None = None,
         nid: str | None = None,
     ) -> dict[str, Any]:
         """Makes an authenticated API request."""
@@ -445,25 +445,7 @@ def get_history(self, nid: str) -> list[Commit]:
             params["testnet"] = "true"
 
         url = f"{HISTORY_API_URL}?{urlencode(params)}"
-
-        headers = {
-            "Content-Type": "application/json",
-            "Authorization": f"token {self._token}",
-        }
-
-        try:
-            response = self._client.get(url, headers=headers)
-        except httpx.RequestError as e:
-            raise create_api_error(0, f"Network error: {e}", nid) from e
-
-        if not response.is_success:
-            raise create_api_error(
-                response.status_code,
-                "Failed to fetch asset history",
-                nid,
-            )
-
-        data = response.json()
+        data = self._request("GET", url, nid=nid)
 
         return [
             Commit(
@@ -511,28 +493,7 @@ def get_asset_tree(self, nid: str) -> AssetTree:
             for c in commits
         ]
 
-        headers = {
-            "Content-Type": "application/json",
-            "Authorization": f"token {self._token}",
-        }
-
-        try:
-            response = self._client.post(
-                MERGE_TREE_API_URL,
-                headers=headers,
-                json=commit_data,
-            )
-        except httpx.RequestError as e:
-            raise create_api_error(0, f"Network error: {e}", nid) from e
-
-        if not response.is_success:
-            raise create_api_error(
-                response.status_code,
-                "Failed to merge asset trees",
-                nid,
-            )
-
-        data = response.json()
+        data = self._request("POST", MERGE_TREE_API_URL, json_body=commit_data, nid=nid)
         merged = data.get("mergedAssetTree", data)
 
         # Map known fields and put the rest in extra
@@ -675,51 +636,24 @@ def search_asset(
             form_data["sample_count"] = str(options.sample_count)
 
         # Verify Engine API requires token in Authorization header, not form data
-        headers = {"Authorization": f"token {self._token}"}
-
-        try:
-            if files_data:
-                response = self._client.post(
-                    ASSET_SEARCH_API_URL,
-                    headers=headers,
-                    data=form_data,
-                    files=files_data,
-                )
-            else:
-                response = self._client.post(
-                    ASSET_SEARCH_API_URL,
-                    headers=headers,
-                    data=form_data,
-                )
-        except httpx.RequestError as e:
-            raise create_api_error(0, f"Network error: {e}") from e
-
-        if not response.is_success:
-            message = f"Asset search failed with status {response.status_code}"
-            try:
-                error_data = response.json()
-                message = (
-                    error_data.get("message")
-                    or error_data.get("error")
-                    or message
-                )
-            except Exception:
-                pass
-            raise create_api_error(response.status_code, message)
-
-        data = response.json()
+        response_data = self._request(
+            "POST",
+            ASSET_SEARCH_API_URL,
+            data=form_data,
+            files=files_data,
+        )
 
         # Map response to our type
         similar_matches = [
             SimilarMatch(nid=m["nid"], distance=m["distance"])
-            for m in data.get("similar_matches", [])
+            for m in response_data.get("similar_matches", [])
         ]
 
         return AssetSearchResult(
-            precise_match=data.get("precise_match", ""),
-            input_file_mime_type=data.get("input_file_mime_type", ""),
+            precise_match=response_data.get("precise_match", ""),
+            input_file_mime_type=response_data.get("input_file_mime_type", ""),
             similar_matches=similar_matches,
-            order_id=data.get("order_id", ""),
+            order_id=response_data.get("order_id", ""),
         )
 
     def search_nft(self, nid: str) -> NftSearchResult:
@@ -740,34 +674,7 @@ def search_nft(self, nid: str) -> NftSearchResult:
         if not nid:
             raise ValidationError("nid is required for NFT search")
 
-        headers = {
-            "Content-Type": "application/json",
-            "Authorization": f"token {self._token}",
-        }
-
-        try:
-            response = self._client.post(
-                NFT_SEARCH_API_URL,
-                headers=headers,
-                json={"nid": nid},
-            )
-        except httpx.RequestError as e:
-            raise create_api_error(0, f"Network error: {e}", nid) from e
-
-        if not response.is_success:
-            message = f"NFT search failed with status {response.status_code}"
-            try:
-                error_data = response.json()
-                message = (
-                    error_data.get("message")
-                    or error_data.get("error")
-                    or message
-                )
-            except Exception:
-                pass
-            raise create_api_error(response.status_code, message, nid)
-
-        data = response.json()
+        data = self._request("POST", NFT_SEARCH_API_URL, json_body={"nid": nid}, nid=nid)
 
         # Map response to our type
         records = [

python/pyproject.toml

@@ -8,7 +8,7 @@ version = "0.2.1"
 description = "Python SDK for Numbers Protocol Capture API"
 readme = "README.md"
 license = "MIT"
-requires-python = ">=3.14"
+requires-python = ">=3.11"
 authors = [
     { name = "Numbers Protocol" }
 ]
@@ -26,7 +26,9 @@ classifiers = [
     "License :: OSI Approved :: MIT License",
     "Operating System :: OS Independent",
     "Programming Language :: Python :: 3",
-    "Programming Language :: Python :: 3.14",
+    "Programming Language :: Python :: 3.11",
+    "Programming Language :: Python :: 3.12",
+    "Programming Language :: Python :: 3.13",
     "Topic :: Software Development :: Libraries :: Python Modules",
     "Typing :: Typed",
 ]
@@ -61,7 +63,7 @@ packages = ["numbersprotocol_capture"]
 
 [tool.ruff]
 line-length = 100
-target-version = "py313"  # Use py313 until ruff supports py314
+target-version = "py311"
 
 [tool.ruff.lint]
 select = [
@@ -81,7 +83,7 @@ ignore = [
 known-first-party = ["numbersprotocol_capture"]
 
 [tool.mypy]
-python_version = "3.14"
+python_version = "3.11"
 strict = true
 warn_return_any = true
 warn_unused_ignores = true

scripts/check-feature-parity.py

@@ -10,6 +10,7 @@
 """
 
 import re
+import sys
 from dataclasses import dataclass
 from pathlib import Path
 
@@ -140,8 +141,8 @@ def check_py_features() -> None:
                 feature.py_implemented = True
 
 
-def print_report() -> None:
-    """Print feature parity report."""
+def print_report() -> bool:
+    """Print feature parity report. Returns True if full parity achieved."""
     print("=" * 60)
     print("Feature Parity Report")
     print("=" * 60)
@@ -204,15 +205,19 @@ def print_report() -> None:
 
     if parity_count == total_features:
         print("\n✓ Full feature parity achieved!")
+        return True
     else:
         missing = total_features - parity_count
         print(f"\n✗ {missing} feature(s) missing parity")
+        return False
 
 
 def main() -> None:
     check_ts_features()
     check_py_features()
-    print_report()
+    all_parity = print_report()
+    if not all_parity:
+        sys.exit(1)
 
 
 if __name__ == "__main__":