Api stubs

chia/apis/__init__.py

@@ -0,0 +1,19 @@
+from __future__ import annotations
+
+from chia.apis.api_protocol_registry import ApiProtocolRegistry
+from chia.apis.farmer_stub import FarmerApiStub
+from chia.apis.full_node_stub import FullNodeApiStub
+from chia.apis.harvester_stub import HarvesterApiStub
+from chia.apis.introducer_stub import IntroducerApiStub
+from chia.apis.timelord_stub import TimelordApiStub
+from chia.apis.wallet_stub import WalletNodeApiStub
+
+__all__ = [
+    "ApiProtocolRegistry",
+    "FarmerApiStub",
+    "FullNodeApiStub",
+    "HarvesterApiStub",
+    "IntroducerApiStub",
+    "TimelordApiStub",
+    "WalletNodeApiStub",
+]

chia/apis/api_protocol_registry.py

@@ -0,0 +1,19 @@
+from __future__ import annotations
+
+from chia.apis.farmer_stub import FarmerApiStub
+from chia.apis.full_node_stub import FullNodeApiStub
+from chia.apis.harvester_stub import HarvesterApiStub
+from chia.apis.introducer_stub import IntroducerApiStub
+from chia.apis.timelord_stub import TimelordApiStub
+from chia.apis.wallet_stub import WalletNodeApiStub
+from chia.protocols.outbound_message import NodeType
+from chia.server.api_protocol import ApiProtocol
+
+ApiProtocolRegistry: dict[NodeType, type[ApiProtocol]] = {
+    NodeType.FULL_NODE: FullNodeApiStub,
+    NodeType.WALLET: WalletNodeApiStub,
+    NodeType.INTRODUCER: IntroducerApiStub,
+    NodeType.TIMELORD: TimelordApiStub,
+    NodeType.FARMER: FarmerApiStub,
+    NodeType.HARVESTER: HarvesterApiStub,
+}

chia/apis/farmer_stub.py

@@ -0,0 +1,90 @@
+from __future__ import annotations
+
+import logging
+from typing import TYPE_CHECKING, ClassVar, Optional, cast
+
+if TYPE_CHECKING:
+    from chia.server.api_protocol import ApiProtocol
+
+# Minimal imports to avoid circular dependencies
+from chia.protocols import farmer_protocol, harvester_protocol
+from chia.protocols.harvester_protocol import (
+    PlotSyncDone,
+    PlotSyncPathList,
+    PlotSyncPlotList,
+    PlotSyncStart,
+    RespondPlots,
+    RespondSignatures,
+)
+from chia.protocols.outbound_message import Message
+from chia.server.api_protocol import ApiMetadata
+from chia.server.ws_connection import WSChiaConnection
+
+
+class FarmerApiStub:
+    """Lightweight API stub for FarmerAPI to break circular dependencies."""
+
+    if TYPE_CHECKING:
+        _protocol_check: ClassVar[ApiProtocol] = cast("FarmerApiStub", None)
+
+    log: logging.Logger
+    metadata: ClassVar[ApiMetadata] = ApiMetadata()
+
+    def ready(self) -> bool:
+        """Check if the farmer is ready."""
+        return True
+
+    @metadata.request(peer_required=True)
+    async def new_proof_of_space(
+        self, new_proof_of_space: harvester_protocol.NewProofOfSpace, peer: WSChiaConnection
+    ) -> None:
+        """Handle new proof of space from harvester."""
+
+    @metadata.request()
+    async def respond_signatures(self, response: RespondSignatures) -> None:
+        """Handle signature response from harvester."""
+
+    @metadata.request()
+    async def new_signage_point(self, new_signage_point: farmer_protocol.NewSignagePoint) -> None:
+        """Handle new signage point from full node."""
+
+    @metadata.request()
+    async def request_signed_values(self, full_node_request: farmer_protocol.RequestSignedValues) -> Optional[Message]:
+        """Handle request for signed values from full node."""
+        return None
+
+    @metadata.request(peer_required=True)
+    async def farming_info(self, request: farmer_protocol.FarmingInfo, peer: WSChiaConnection) -> None:
+        """Handle farming info from full node."""
+
+    @metadata.request(peer_required=True)
+    async def respond_plots(self, _: RespondPlots, peer: WSChiaConnection) -> None:
+        """Handle respond plots from harvester."""
+
+    @metadata.request(peer_required=True)
+    async def plot_sync_start(self, message: PlotSyncStart, peer: WSChiaConnection) -> None:
+        """Handle plot sync start."""
+
+    @metadata.request(peer_required=True)
+    async def plot_sync_loaded(self, message: PlotSyncPlotList, peer: WSChiaConnection) -> None:
+        """Handle plot sync loaded."""
+
+    @metadata.request(peer_required=True)
+    async def plot_sync_removed(self, message: PlotSyncPathList, peer: WSChiaConnection) -> None:
+        """Handle plot sync removed."""
+
+    @metadata.request(peer_required=True)
+    async def plot_sync_invalid(self, message: PlotSyncPathList, peer: WSChiaConnection) -> None:
+        """Handle plot sync invalid."""
+
+    @metadata.request(peer_required=True)
+    async def plot_sync_keys_missing(self, message: PlotSyncPathList, peer: WSChiaConnection) -> None:
+        """Handle plot sync keys missing."""
+
+    @metadata.request(peer_required=True)
+    async def plot_sync_duplicates(self, message: PlotSyncPathList, peer: WSChiaConnection) -> None:
+        """Handle plot sync duplicates."""
+
+    @metadata.request(peer_required=True)
+    async def plot_sync_done(self, message: PlotSyncDone, peer: WSChiaConnection) -> None:
+        """Handle plot sync done."""