Add 4 resources (signals, arbitrage, marketmaker, template) — v0.2.0a1

Ports the A1 roadmap wave from @cryptohopper/sdk@0.2.0-alpha.1 to Python.
Same 4 domains, same endpoint mapping, same hyphenated-path handling
(market-cancel, get-backlogs, delete-backlog, save-template,
set-market-trend). Method names are snake_case per Python idiom
(chart_data, exchange_start, get_market_trend, etc).

All 40 tests passing (11 new), ruff clean, mypy --strict clean.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: pimfeltkamp

CHANGELOG.md

@@ -3,7 +3,17 @@
 All notable changes to the `cryptohopper` Python package are documented in this file.
 The format is loosely based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/).
 
-## 0.1.0a1 — Unreleased
+## 0.2.0a1 — Unreleased
+
+Adds four more API domains: `signals`, `arbitrage`, `marketmaker`, `template`.
+
+### Added
+- **`signals`** — `list`, `performance`, `stats`, `distribution`, `chart_data`.
+- **`arbitrage`** — `exchange_start`, `exchange_cancel`, `exchange_results`, `exchange_history`, `exchange_total`, `exchange_reset_total`, `market_start`, `market_cancel`, `market_result`, `market_history`, `backlogs`, `backlog`, `delete_backlog`.
+- **`marketmaker`** — `get`, `cancel`, `history`, `get_market_trend`, `set_market_trend`, `delete_market_trend`, `backlogs`, `backlog`, `delete_backlog`.
+- **`template`** — `list`, `get`, `basic`, `save`, `update`, `load`, `delete`.
+
+## 0.1.0a1 — 2026-04-24
 
 Initial release. Covers six core API domains.
 

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "cryptohopper"
-version = "0.1.0a1"
+version = "0.2.0a1"
 description = "Official Python SDK for the Cryptohopper API"
 readme = "README.md"
 requires-python = ">=3.10"

src/cryptohopper/_client.py

@@ -24,11 +24,15 @@
 HttpMethod = Literal["GET", "POST", "PATCH", "DELETE", "PUT"]
 
 if TYPE_CHECKING:
+    from .resources.arbitrage import Arbitrage
     from .resources.backtest import Backtests
     from .resources.exchange import Exchange
     from .resources.hoppers import Hoppers
     from .resources.market import Market
+    from .resources.marketmaker import MarketMaker
+    from .resources.signals import Signals
     from .resources.strategy import Strategies
+    from .resources.template import Templates
     from .resources.user import User
 
 
@@ -62,6 +66,10 @@ class CryptohopperClient:
     backtest: Backtests
     market: Market
     user: User
+    signals: Signals
+    arbitrage: Arbitrage
+    marketmaker: MarketMaker
+    template: Templates
 
     def __init__(
         self,
@@ -86,11 +94,15 @@ def __init__(
         self._owns_http = http_client is None
 
         # Import here to avoid a circular at module import time.
+        from .resources.arbitrage import Arbitrage
         from .resources.backtest import Backtests
         from .resources.exchange import Exchange
         from .resources.hoppers import Hoppers
         from .resources.market import Market
+        from .resources.marketmaker import MarketMaker
+        from .resources.signals import Signals
         from .resources.strategy import Strategies
+        from .resources.template import Templates
         from .resources.user import User
 
         self.user = User(self)
@@ -99,6 +111,10 @@ def __init__(
         self.strategy = Strategies(self)
         self.backtest = Backtests(self)
         self.market = Market(self)
+        self.signals = Signals(self)
+        self.arbitrage = Arbitrage(self)
+        self.marketmaker = MarketMaker(self)
+        self.template = Templates(self)
 
     def __enter__(self) -> CryptohopperClient:
         return self

src/cryptohopper/_version.py

@@ -1 +1 @@
-CURRENT_VERSION = "0.1.0a1"
+CURRENT_VERSION = "0.2.0a1"

src/cryptohopper/resources/arbitrage.py

@@ -0,0 +1,94 @@
+"""``client.arbitrage`` — exchange + market arbitrage operations.
+
+Two distinct flavours:
+  • ``exchange_*`` — cross-exchange arbitrage.
+  • ``market_*``   — intra-exchange market arbitrage.
+Plus a shared backlog API.
+"""
+
+from __future__ import annotations
+
+from collections.abc import Sequence
+from typing import TYPE_CHECKING, Any
+
+if TYPE_CHECKING:
+    from .._client import CryptohopperClient
+
+BacklogId = int | str
+
+
+class Arbitrage:
+    def __init__(self, client: CryptohopperClient) -> None:
+        self._client = client
+
+    # ─── Cross-exchange arbitrage ─────────────────────────────────────────
+
+    def exchange_start(self, data: dict[str, Any]) -> dict[str, Any]:
+        """Start a cross-exchange arbitrage run. Requires ``trade``."""
+        return self._client._request("POST", "/arbitrage/exchange", json=data)
+
+    def exchange_cancel(self, data: dict[str, Any] | None = None) -> dict[str, Any]:
+        """Cancel a cross-exchange arbitrage run. Requires ``trade``."""
+        return self._client._request("POST", "/arbitrage/cancel", json=data or {})
+
+    def exchange_results(self, **params: Any) -> Sequence[dict[str, Any]]:
+        """Fetch results of exchange-arbitrage runs. Requires ``read``."""
+        return self._client._request(
+            "GET", "/arbitrage/results", params=params or None
+        )
+
+    def exchange_history(self, **params: Any) -> Sequence[dict[str, Any]]:
+        """Historical exchange-arbitrage runs. Requires ``read``."""
+        return self._client._request(
+            "GET", "/arbitrage/history", params=params or None
+        )
+
+    def exchange_total(self) -> dict[str, Any]:
+        """Running totals across exchange-arbitrage runs. Requires ``read``."""
+        return self._client._request("GET", "/arbitrage/total")
+
+    def exchange_reset_total(self) -> dict[str, Any]:
+        """Reset the running totals. Requires ``manage``."""
+        return self._client._request("POST", "/arbitrage/resettotal", json={})
+
+    # ─── Intra-exchange market arbitrage ──────────────────────────────────
+
+    def market_start(self, data: dict[str, Any]) -> dict[str, Any]:
+        """Start an intra-exchange arbitrage run. Requires ``trade``."""
+        return self._client._request("POST", "/arbitrage/market", json=data)
+
+    def market_cancel(self, data: dict[str, Any] | None = None) -> dict[str, Any]:
+        """Cancel a market-arbitrage run. Requires ``trade``."""
+        return self._client._request("POST", "/arbitrage/market-cancel", json=data or {})
+
+    def market_result(self, **params: Any) -> dict[str, Any]:
+        """Result of a specific market-arbitrage run. Requires ``read``."""
+        return self._client._request(
+            "GET", "/arbitrage/market-result", params=params or None
+        )
+
+    def market_history(self, **params: Any) -> Sequence[dict[str, Any]]:
+        """Historical market-arb runs. Requires ``read``."""
+        return self._client._request(
+            "GET", "/arbitrage/market-history", params=params or None
+        )
+
+    # ─── Backlog (shared) ────────────────────────────────────────────────
+
+    def backlogs(self, **params: Any) -> Sequence[dict[str, Any]]:
+        """List queued/pending backlog items. Requires ``read``."""
+        return self._client._request(
+            "GET", "/arbitrage/get-backlogs", params=params or None
+        )
+
+    def backlog(self, backlog_id: BacklogId) -> dict[str, Any]:
+        """Fetch a single backlog item. Requires ``read``."""
+        return self._client._request(
+            "GET", "/arbitrage/get-backlog", params={"backlog_id": backlog_id}
+        )
+
+    def delete_backlog(self, backlog_id: BacklogId) -> dict[str, Any]:
+        """Delete a backlog item. Requires ``manage``."""
+        return self._client._request(
+            "POST", "/arbitrage/delete-backlog", json={"backlog_id": backlog_id}
+        )

src/cryptohopper/resources/marketmaker.py

@@ -0,0 +1,72 @@
+"""``client.marketmaker`` — market-maker bot ops + market-trend overrides + backlog."""
+
+from __future__ import annotations
+
+from collections.abc import Sequence
+from typing import TYPE_CHECKING, Any
+
+if TYPE_CHECKING:
+    from .._client import CryptohopperClient
+
+BacklogId = int | str
+
+
+class MarketMaker:
+    def __init__(self, client: CryptohopperClient) -> None:
+        self._client = client
+
+    def get(self, **params: Any) -> dict[str, Any]:
+        """Fetch the market-maker state for a hopper. Requires ``read``."""
+        return self._client._request("GET", "/marketmaker/get", params=params or None)
+
+    def cancel(self, data: dict[str, Any] | None = None) -> dict[str, Any]:
+        """Cancel running market-maker orders. Requires ``trade``."""
+        return self._client._request("POST", "/marketmaker/cancel", json=data or {})
+
+    def history(self, **params: Any) -> Sequence[dict[str, Any]]:
+        """Historical order activity. Requires ``read``."""
+        return self._client._request(
+            "GET", "/marketmaker/history", params=params or None
+        )
+
+    # ─── Market-trend overrides ──────────────────────────────────────────
+
+    def get_market_trend(self, **params: Any) -> dict[str, Any]:
+        """Read the current market-trend override. Requires ``read``."""
+        return self._client._request(
+            "GET", "/marketmaker/get-market-trend", params=params or None
+        )
+
+    def set_market_trend(self, data: dict[str, Any]) -> dict[str, Any]:
+        """Set a market-trend override. Requires ``manage``."""
+        return self._client._request(
+            "POST", "/marketmaker/set-market-trend", json=data
+        )
+
+    def delete_market_trend(
+        self, data: dict[str, Any] | None = None
+    ) -> dict[str, Any]:
+        """Remove the current market-trend override. Requires ``manage``."""
+        return self._client._request(
+            "POST", "/marketmaker/delete-market-trend", json=data or {}
+        )
+
+    # ─── Backlog ─────────────────────────────────────────────────────────
+
+    def backlogs(self, **params: Any) -> Sequence[dict[str, Any]]:
+        """List queued/pending market-maker backlog items. Requires ``read``."""
+        return self._client._request(
+            "GET", "/marketmaker/get-backlogs", params=params or None
+        )
+
+    def backlog(self, backlog_id: BacklogId) -> dict[str, Any]:
+        """Fetch a single backlog item. Requires ``read``."""
+        return self._client._request(
+            "GET", "/marketmaker/get-backlog", params={"backlog_id": backlog_id}
+        )
+
+    def delete_backlog(self, backlog_id: BacklogId) -> dict[str, Any]:
+        """Delete a backlog item. Requires ``manage``."""
+        return self._client._request(
+            "POST", "/marketmaker/delete-backlog", json={"backlog_id": backlog_id}
+        )

src/cryptohopper/resources/signals.py

@@ -0,0 +1,40 @@
+"""``client.signals`` — signal-provider analytics.
+
+Distinct from ``client.market.signals``, which browses marketplace signals
+as a consumer.
+"""
+
+from __future__ import annotations
+
+from collections.abc import Sequence
+from typing import TYPE_CHECKING, Any
+
+if TYPE_CHECKING:
+    from .._client import CryptohopperClient
+
+
+class Signals:
+    def __init__(self, client: CryptohopperClient) -> None:
+        self._client = client
+
+    def list(self, **params: Any) -> Sequence[dict[str, Any]]:
+        """Signals this provider has published."""
+        return self._client._request("GET", "/signals/signals", params=params or None)
+
+    def performance(self, **params: Any) -> dict[str, Any]:
+        """Performance stats (winrate, avg profit per signal, etc.)."""
+        return self._client._request(
+            "GET", "/signals/performance", params=params or None
+        )
+
+    def stats(self) -> dict[str, Any]:
+        """Overall provider stats."""
+        return self._client._request("GET", "/signals/stats")
+
+    def distribution(self) -> dict[str, Any]:
+        """Distribution of signals across exchanges / markets / types."""
+        return self._client._request("GET", "/signals/distribution")
+
+    def chart_data(self, **params: Any) -> dict[str, Any]:
+        """Data series for charting the provider's performance over time."""
+        return self._client._request("GET", "/signals/chartdata", params=params or None)

src/cryptohopper/resources/template.py

@@ -0,0 +1,60 @@
+"""``client.template`` — bot templates (reusable hopper configurations)."""
+
+from __future__ import annotations
+
+from collections.abc import Sequence
+from typing import TYPE_CHECKING, Any
+
+if TYPE_CHECKING:
+    from .._client import CryptohopperClient
+
+TemplateId = int | str
+
+
+class Templates:
+    def __init__(self, client: CryptohopperClient) -> None:
+        self._client = client
+
+    def list(self) -> Sequence[dict[str, Any]]:
+        """List all templates the user has access to. Requires ``read``."""
+        return self._client._request("GET", "/template/templates")
+
+    def get(self, template_id: TemplateId) -> dict[str, Any]:
+        """Fetch a template. Requires ``read``."""
+        return self._client._request(
+            "GET", "/template/get", params={"template_id": template_id}
+        )
+
+    def basic(self, template_id: TemplateId) -> dict[str, Any]:
+        """Fetch the basic (lightweight) view of a template. Requires ``read``."""
+        return self._client._request(
+            "GET", "/template/basic", params={"template_id": template_id}
+        )
+
+    def save(self, data: dict[str, Any]) -> dict[str, Any]:
+        """Save a new template. Requires ``manage``."""
+        return self._client._request("POST", "/template/save-template", json=data)
+
+    def update(
+        self, template_id: TemplateId, data: dict[str, Any]
+    ) -> dict[str, Any]:
+        """Update an existing template. Requires ``manage``."""
+        return self._client._request(
+            "POST", "/template/update", json={"template_id": template_id, **data}
+        )
+
+    def load(
+        self, template_id: TemplateId, hopper_id: TemplateId
+    ) -> dict[str, Any]:
+        """Apply a template to a hopper. Requires ``manage``."""
+        return self._client._request(
+            "POST",
+            "/template/load",
+            json={"template_id": template_id, "hopper_id": hopper_id},
+        )
+
+    def delete(self, template_id: TemplateId) -> dict[str, Any]:
+        """Delete a template. Requires ``manage``."""
+        return self._client._request(
+            "POST", "/template/delete", json={"template_id": template_id}
+        )