fix(api): add CCXT-compatible params bag to loadMarkets

core/src/BaseExchange.ts

@@ -679,15 +679,19 @@ export abstract class PredictionMarketExchange {
      * `Object.values(exchange.markets)` locally.
      *
      * @param reload - Force a fresh fetch from the API even if markets are already loaded
+     * @param params - Optional exchange-specific fetch parameters (CCXT-compatible trailing bag)
      * @returns Dictionary of markets indexed by marketId
      */
-    async loadMarkets(reload: boolean = false): Promise<Record<string, UnifiedMarket>> {
+    async loadMarkets(
+        reload: boolean = false,
+        params: MarketFetchParams = {}
+    ): Promise<Record<string, UnifiedMarket>> {
         if (this.loadedMarkets && !reload) {
             return this.markets;
         }
 
         // Fetch all markets (implementation dependent, usually fetches active markets)
-        const markets = await this.fetchMarkets();
+        const markets = await this.fetchMarkets(params);
 
         // Reset caches
         this.markets = {};

core/src/server/openapi.yaml

@@ -181,9 +181,11 @@ paths:
               properties:
                 args:
                   type: array
-                  maxItems: 1
+                  maxItems: 2
                   items:
-                    type: boolean
+                    oneOf:
+                      - type: boolean
+                      - type: object
                 credentials:
                   $ref: '#/components/schemas/ExchangeCredentials'
       responses:

core/test/unit/baseExchange.core.test.ts

@@ -56,4 +56,16 @@ describe('BaseExchange public read bounds', () => {
         expect(markets).toEqual([MARKET_B]);
         expect(exchange.marketCalls).toEqual([undefined]);
     });
+
+    it('forwards params from loadMarkets to fetchMarkets', async () => {
+        const exchange = new RecordingExchange();
+
+        await exchange.loadMarkets(false, { limit: 1 });
+
+        expect(exchange.marketCalls).toEqual([{ limit: 1 }]);
+        expect(exchange.markets).toEqual({
+            [MARKET_A.id]: MARKET_A,
+            [MARKET_B.id]: MARKET_B,
+        });
+    });
 });

docs/api-reference/openapi.json

@@ -953,9 +953,16 @@
                 "properties": {
                   "args": {
                     "type": "array",
-                    "maxItems": 1,
+                    "maxItems": 2,
                     "items": {
-                      "type": "boolean"
+                      "oneOf": [
+                        {
+                          "type": "boolean"
+                        },
+                        {
+                          "type": "object"
+                        }
+                      ]
                     }
                   },
                   "credentials": {

sdks/python/pmxt/client.py

@@ -1266,7 +1266,9 @@ def call_api(self, operation_id: str, params: Optional[Dict[str, Any]] = None) -
 
     # Market Data Methods
 
-    def load_markets(self, reload: bool = False) -> Dict[str, UnifiedMarket]:
+    def load_markets(
+        self, reload: bool = False, params: Optional[Dict[str, Any]] = None
+    ) -> Dict[str, UnifiedMarket]:
         """
         Load and cache all markets from the exchange into self.markets.
         Subsequent calls return the cached result without hitting the API again.
@@ -1278,6 +1280,7 @@ def load_markets(self, reload: bool = False) -> Dict[str, UnifiedMarket]:
 
         Args:
             reload: Force a fresh fetch even if markets are already loaded
+            params: Optional exchange-specific fetch parameters (CCXT-compatible trailing bag)
 
         Returns:
             Dict[str, UnifiedMarket] - All markets indexed by marketId
@@ -1291,7 +1294,7 @@ def load_markets(self, reload: bool = False) -> Dict[str, UnifiedMarket]:
         if self._loaded_markets and not reload:
             return self.markets
 
-        markets = self.fetch_markets()
+        markets = self.fetch_markets(params or {})
 
         self.markets = {}
         self.markets_by_slug = {}

sdks/typescript/pmxt/client.ts

@@ -1059,11 +1059,15 @@ export abstract class Exchange {
         }
     }
 
-    async loadMarkets(reload: boolean = false): Promise<Record<string, UnifiedMarket>> {
+    async loadMarkets(
+        reload: boolean = false,
+        params: Record<string, unknown> = {}
+    ): Promise<Record<string, UnifiedMarket>> {
         await this.initPromise;
         try {
             const args: any[] = [];
             args.push(reload);
+            args.push(params);
             const response = await this.fetchWithRetry(`${this.resolveBaseUrl()}/api/${this.exchangeName}/loadMarkets`, {
                 method: 'POST',
                 headers: { 'Content-Type': 'application/json', ...this.getAuthHeaders() },