fix: align SDK parity type gaps (#958)

Author: realfishsam

sdks/python/pmxt/__init__.py

@@ -56,6 +56,8 @@
     PaginatedEventsResult,
     Order,
     BuiltOrder,
+    CreateOrderParams,
+    TxPayload,
     Position,
     Balance,
     MarketFilterCriteria,
@@ -82,6 +84,7 @@
     PriceComparison,
     ArbitrageOpportunity,
     SubscribedAddressSnapshot,
+    SubscriptionOption,
     ExecutionPriceResult,
     MatchRelation,
     ClusterSortOption,
@@ -229,6 +232,8 @@ def restart_server() -> None:
     "PaginatedEventsResult",
     "Order",
     "BuiltOrder",
+    "CreateOrderParams",
+    "TxPayload",
     "ExecutionPriceResult",
     "Position",
     "Balance",
@@ -241,6 +246,7 @@ def restart_server() -> None:
     "PriceComparison",
     "ArbitrageOpportunity",
     "SubscribedAddressSnapshot",
+    "SubscriptionOption",
     "MatchRelation",
     "ClusterSortOption",
     "MatchedClusterSort",

sdks/python/pmxt/client.py

@@ -52,6 +52,7 @@
     TradesParams,
     FetchOrderBookParams,
     SubscribedAddressSnapshot,
+    SubscriptionOption,
     FirehoseEvent,
     MatchResult,
     EventMatchResult,
@@ -2268,6 +2269,7 @@ def fetch_trades(
         since: Optional[int] = None,
         start: Optional[Union[str, int]] = None,
         end: Optional[Union[str, int]] = None,
+        resolution: Optional[str] = None,
         **kwargs
     ) -> List[Trade]:
         """
@@ -2281,6 +2283,7 @@ def fetch_trades(
             since: Return trades since this timestamp (Unix milliseconds)
             start: Start of time range (ISO 8601 string or epoch seconds/ms)
             end: End of time range (ISO 8601 string or epoch seconds/ms)
+            resolution: Optional trade resolution/status filter forwarded to the venue
             **kwargs: Additional parameters
 
         Returns:
@@ -2302,6 +2305,8 @@ def fetch_trades(
                 params_dict["start"] = start
             if end is not None:
                 params_dict["end"] = end
+            if resolution is not None:
+                params_dict["resolution"] = resolution
 
             # Add any extra keyword arguments
             for key, value in kwargs.items():
@@ -2663,7 +2668,7 @@ def watch_trades(
     def watch_address(
         self,
         address: str,
-        types: Optional[List[str]] = None,
+        types: Optional[List[SubscriptionOption]] = None,
     ) -> SubscribedAddressSnapshot:
         """
         Watch real-time updates of a public wallet via WebSocket.

sdks/python/pmxt/feed_client.py

@@ -15,6 +15,8 @@
 from dataclasses import dataclass, field
 from typing import List, Optional, Dict, Any, Tuple
 
+from .errors import PmxtError
+
 
 @dataclass(frozen=True)
 class Ticker:
@@ -190,10 +192,10 @@ def _request(self, url: str, params: Optional[Dict[str, Any]] = None) -> Any:
         except urllib.error.HTTPError as e:
             body = json.loads(e.read()) if e.fp else {}
             msg = body.get("error", e.reason)
-            raise RuntimeError(f"Feed API error ({e.code}): {msg}") from e
+            raise PmxtError(f"Feed API error ({e.code}): {msg}") from e
 
         if not body.get("success"):
-            raise RuntimeError(f"Feed API error: {body.get('error', 'unknown')}")
+            raise PmxtError(f"Feed API error: {body.get('error', 'unknown')}")
         return body["data"]
 
     @staticmethod

sdks/python/pmxt/models.py

@@ -18,6 +18,7 @@
 OrderSide = Literal["buy", "sell"]
 OrderType = Literal["market", "limit"]
 OutcomeType = Literal["yes", "no", "up", "down"]
+SubscriptionOption = Literal["trades", "positions", "balances"]
 
 
 @dataclass
@@ -501,7 +502,7 @@ class BuiltOrder:
     exchange: str
     """The exchange name this order was built for."""
 
-    params: Dict[str, Any]
+    params: "CreateOrderParams"
     """The original params used to build this order."""
 
     raw: Any
@@ -510,10 +511,28 @@ class BuiltOrder:
     signed_order: Optional[Dict[str, Any]] = None
     """For CLOB exchanges (Polymarket): the EIP-712 signed order."""
 
-    tx: Optional[Dict[str, Any]] = None
+    tx: Optional["TxPayload"] = None
     """For on-chain AMM exchanges: the EVM transaction payload."""
 
 
+class CreateOrderParams(TypedDict, total=False):
+    """Parameters used to build or create an order."""
+    market_id: str
+    outcome_id: str
+    side: OrderSide
+    type: OrderType
+    amount: float
+    price: float
+    fee: int
+
+
+class TxPayload(TypedDict):
+    """EVM transaction payload returned for on-chain AMM orders."""
+    to: str
+    data: str
+    value: str
+    chainId: int
+
 @dataclass
 class Position:
     """A current position in a market.
@@ -767,6 +786,7 @@ class TradesParams(TypedDict, total=False):
     until: int
     limit: int
     cursor: str
+    resolution: str
 
 
 class HistoryFilterParams(TypedDict, total=False):
@@ -934,12 +954,12 @@ class MatchedMarketCluster:
     confidence: float
     """Cluster confidence score."""
 
+    volume_24h: float
+    """Total 24-hour volume across markets in the cluster."""
+
     category: Optional[str] = None
     """Canonical category selected by the hosted API."""
 
-    volume_24h: Optional[float] = None
-    """Total 24-hour volume across markets in the cluster."""
-
     raw_matches: Optional[List[Dict[str, Any]]] = None
     """Pairwise match edges used to build the cluster when requested."""
 
@@ -963,12 +983,12 @@ class MatchedEventCluster:
     confidence: float
     """Cluster confidence score."""
 
+    volume_24h: float
+    """Total 24-hour volume across events in the cluster."""
+
     category: Optional[str] = None
     """Canonical category selected by the hosted API."""
 
-    volume_24h: Optional[float] = None
-    """Total 24-hour volume across events in the cluster."""
-
     raw_matches: Optional[List[Dict[str, Any]]] = None
     """Pairwise match edges used to build the cluster when requested."""
 

sdks/typescript/pmxt/client.ts

@@ -1135,6 +1135,9 @@ export abstract class Exchange {
             return this._hostedSubmitOrder(built);
         }
         await this.initPromise;
+        if (this.isHosted) {
+            throw new PmxtError("submitOrder is not available in hosted mode. Use createOrder instead.");
+        }
         try {
             const args: any[] = [];
             args.push(built);

sdks/typescript/pmxt/router.ts

@@ -224,6 +224,8 @@ export class Router extends Exchange {
         marketId?: string;
         slug?: string;
         url?: string;
+        query?: string;
+        category?: string;
         relation?: MatchRelation;
         minConfidence?: number;
         limit?: number;
@@ -234,6 +236,8 @@ export class Router extends Exchange {
         marketId?: string;
         slug?: string;
         url?: string;
+        query?: string;
+        category?: string;
         relation?: MatchRelation;
         minConfidence?: number;
         limit?: number;
@@ -246,6 +250,8 @@ export class Router extends Exchange {
         if (marketId) query.marketId = marketId;
         if (params.slug ?? params.market?.slug) query.slug = params.slug ?? params.market?.slug;
         if (params.url) query.url = params.url;
+        if (params.query) query.query = params.query;
+        if (params.category) query.category = params.category;
         if (params.relation) query.relation = params.relation;
         if (params.minConfidence !== undefined) query.minConfidence = params.minConfidence;
         if (params.limit !== undefined) query.limit = params.limit;
@@ -274,6 +280,8 @@ export class Router extends Exchange {
         marketId?: string;
         slug?: string;
         url?: string;
+        query?: string;
+        category?: string;
         relation?: MatchRelation;
         minConfidence?: number;
         limit?: number;
@@ -284,6 +292,8 @@ export class Router extends Exchange {
         marketId?: string;
         slug?: string;
         url?: string;
+        query?: string;
+        category?: string;
         relation?: MatchRelation;
         minConfidence?: number;
         limit?: number;
@@ -303,6 +313,8 @@ export class Router extends Exchange {
         event?: UnifiedEvent;
         eventId?: string;
         slug?: string;
+        query?: string;
+        category?: string;
         relation?: MatchRelation;
         minConfidence?: number;
         limit?: number;
@@ -312,6 +324,8 @@ export class Router extends Exchange {
         event?: UnifiedEvent;
         eventId?: string;
         slug?: string;
+        query?: string;
+        category?: string;
         relation?: MatchRelation;
         minConfidence?: number;
         limit?: number;
@@ -323,6 +337,8 @@ export class Router extends Exchange {
         const eventId = params.eventId ?? (!params.event?.slug ? params.event?.id : undefined);
         if (eventId) query.eventId = eventId;
         if (params.slug ?? params.event?.slug) query.slug = params.slug ?? params.event?.slug;
+        if (params.query) query.query = params.query;
+        if (params.category) query.category = params.category;
         if (params.relation) query.relation = params.relation;
         if (params.minConfidence !== undefined) query.minConfidence = params.minConfidence;
         if (params.limit !== undefined) query.limit = params.limit;

sdks/typescript/scripts/generate-client-methods.js

@@ -424,10 +424,18 @@ function generateMethod(name, params, config, sf) {
     const argsCode = buildArgsLines(params, sf);
     const returnCode = buildReturnLines(config);
     const { returnTs } = config;
+    const localOnlyGuard = name === 'submitOrder'
+        ? [
+            `        if (this.isHosted) {`,
+            `            throw new PmxtError("submitOrder is not available in hosted mode. Use createOrder instead.");`,
+            `        }`,
+        ]
+        : [];
 
     return [
         `    async ${name}(${sig}): Promise<${returnTs}> {`,
         `        await this.initPromise;`,
+        ...localOnlyGuard,
         `        try {`,
         `            ${argsCode}`,
         `            const response = await this.fetchWithRetry(\`\${this.resolveBaseUrl()}/api/\${this.exchangeName}/${name}\`, {`,