chore: merge latest main and refresh docs for PR #837

realfishsam · realfishsam · commit 9de051e399fc · 2026-06-08T09:59:00.000Z
diff --git a/core/api-doc-config.generated.json b/core/api-doc-config.generated.json
@@ -1,5 +1,5 @@
 {
-    "_generated": "Auto-generated by extract-jsdoc.js on 2026-06-08T08:31:38.004Z. Do not edit manually.",
+    "_generated": "Auto-generated by extract-jsdoc.js on 2026-06-08T09:58:54.515Z. Do not edit manually.",
     "methods": {
         "has": {
             "summary": "HTTP verb for the endpoint (e.g. GET, POST). */",
diff --git a/core/src/exchanges/gemini-titan/normalizer.ts b/core/src/exchanges/gemini-titan/normalizer.ts
@@ -213,12 +213,19 @@ export class GeminiNormalizer implements IExchangeNormalizer<GeminiRawEvent, Gem
         // Extract prices
         const bestBid = contract.prices?.bestBid ? parseFloat(contract.prices.bestBid) : 0.5;
         const bestAsk = contract.prices?.bestAsk ? parseFloat(contract.prices.bestAsk) : 0.5;
+        const buyYes = contract.prices?.buy?.yes ? parseFloat(contract.prices.buy.yes) : undefined;
+        const sellYes = contract.prices?.sell?.yes ? parseFloat(contract.prices.sell.yes) : undefined;
+        const buyNo = contract.prices?.buy?.no ? parseFloat(contract.prices.buy.no) : undefined;
+        const sellNo = contract.prices?.sell?.no ? parseFloat(contract.prices.sell.no) : undefined;
         const lastPrice = contract.prices?.lastTradePrice
             ? parseFloat(contract.prices.lastTradePrice)
             : (bestBid + bestAsk) / 2;
 
-        const yesPrice = roundPrice(Math.max(0, Math.min(1, lastPrice)));
-        const noPrice = roundPrice(Math.max(0, Math.min(1, 1 - yesPrice)));
+        const yesPriceSource = buyYes ?? sellYes ?? lastPrice;
+        const noPriceSource = buyNo ?? sellNo ?? (1 - yesPriceSource);
+
+        const yesPrice = roundPrice(Math.max(0, Math.min(1, yesPriceSource)));
+        const noPrice = roundPrice(Math.max(0, Math.min(1, noPriceSource)));
 
         const outcomes: MarketOutcome[] = [
             {
@@ -258,7 +265,7 @@ export class GeminiNormalizer implements IExchangeNormalizer<GeminiRawEvent, Gem
             outcomes,
             resolutionDate,
             volume24h: 0,
-            liquidity: event.liquidity ? parseFloat(event.liquidity) : 0,
+            liquidity: event.liquidity ? parseFloat(event.liquidity) : (event.volume24h ? parseFloat(event.volume24h) : (event.volume ? parseFloat(event.volume) : 0)),
             url: buildExchangeUrl(event.ticker),
             category: event.category,
             tags,
diff --git a/core/src/exchanges/hyperliquid/normalizer.ts b/core/src/exchanges/hyperliquid/normalizer.ts
@@ -327,11 +327,13 @@ export class HyperliquidNormalizer implements IExchangeNormalizer<HyperliquidRaw
         const bids = rawBids.map(level => ({
             price: parseFloat(level.px),
             size: parseFloat(level.sz),
+            orderCount: level.n,
         }));
 
         const asks = rawAsks.map(level => ({
             price: parseFloat(level.px),
             size: parseFloat(level.sz),
+            orderCount: level.n,
         }));
 
         return {
diff --git a/core/src/exchanges/interfaces.ts b/core/src/exchanges/interfaces.ts
@@ -20,7 +20,7 @@ export interface FetcherContext {
 // happens in a separate layer.
 // ----------------------------------------------------------------------------
 
-export interface IExchangeFetcher<TRawMarket = unknown, TRawEvent = unknown> {
+export interface IExchangeFetcher<TRawMarket = unknown, TRawEvent = unknown, TRawPositions = unknown[]> {
     fetchRawMarkets(params?: MarketFilterParams): Promise<TRawMarket[]>;
     fetchRawEvents(params: EventFetchParams): Promise<TRawEvent[]>;
 
@@ -30,7 +30,7 @@ export interface IExchangeFetcher<TRawMarket = unknown, TRawEvent = unknown> {
     fetchRawOrderBook?(id: string): Promise<unknown>;
     fetchRawTrades?(id: string, params: TradesParams): Promise<unknown[]>;
     fetchRawMyTrades?(params: MyTradesParams, walletAddress: string): Promise<unknown[]>;
-    fetchRawPositions?(walletAddress: string): Promise<unknown[]>;
+    fetchRawPositions?(walletAddress: string): Promise<TRawPositions>;
     fetchRawBalance?(walletAddress: string): Promise<unknown>;
 }
 
diff --git a/core/src/exchanges/kalshi/fetcher.ts b/core/src/exchanges/kalshi/fetcher.ts
@@ -23,6 +23,8 @@ export interface KalshiRawMarket {
     last_price_dollars?: string;
     yes_ask_dollars?: string;
     yes_bid_dollars?: string;
+    yes_ask_size_fp?: string;
+    yes_bid_size_fp?: string;
     rules_primary?: string;
     rules_secondary?: string;
     expiration_time: string;
diff --git a/core/src/exchanges/kalshi/normalizer.ts b/core/src/exchanges/kalshi/normalizer.ts
@@ -118,7 +118,12 @@ export class KalshiNormalizer implements IExchangeNormalizer<KalshiRawEvent, Kal
             sourceMetadata: buildSourceMetadata(
                 market as unknown as Record<string, unknown>,
                 KALSHI_PROMOTED_MARKET_KEYS,
-                { series_ticker: event.series_ticker, series_title: event.series_title },
+                {
+                    yes_ask_size_fp: market.yes_ask_size_fp,
+                    yes_bid_size_fp: market.yes_bid_size_fp,
+                    series_ticker: event.series_ticker,
+                    series_title: event.series_title,
+                },
             ),
         } as UnifiedMarket;
 
diff --git a/core/src/exchanges/limitless/fetcher.ts b/core/src/exchanges/limitless/fetcher.ts
@@ -16,6 +16,10 @@ export interface LimitlessRawMarket {
     description?: string;
     tokens?: Record<string, string>;
     prices?: number[];
+    tradePrices?: {
+        buy?: { market?: number[]; limit?: number[] };
+        sell?: { market?: number[]; limit?: number[] };
+    };
     expirationTimestamp?: string;
     volumeFormatted?: number;
     volume?: number;
diff --git a/core/src/exchanges/limitless/utils.ts b/core/src/exchanges/limitless/utils.ts
@@ -73,9 +73,9 @@ export function mapMarketToUnified(market: any, context: LimitlessMarketContext
             throw new Error(`[limitless] Market "${market.slug}" is missing token addresses`);
         }
 
-        const prices = Array.isArray(market.prices) ? market.prices : [];
-        const yesPrice = prices[0] || 0;
-        const noPrice = prices[1] || 0;
+        const legacyPrices = Array.isArray(market.prices) ? market.prices : [];
+        const yesPrice = market.tradePrices?.buy?.market?.[0] ?? legacyPrices[0] ?? 0.5;
+        const noPrice = market.tradePrices?.sell?.market?.[0] ?? legacyPrices[1] ?? Math.max(0, Math.min(1, 1 - yesPrice));
         const yesLabel = hasParentContext ? rawTitle : 'Yes';
         const noLabel = hasParentContext ? `Not ${rawTitle}` : 'No';
 
diff --git a/core/src/exchanges/myriad/normalizer.ts b/core/src/exchanges/myriad/normalizer.ts
@@ -19,6 +19,14 @@ const MYRIAD_PROMOTED_EVENT_KEYS = [
     'id', 'title', 'markets',
 ] as const;
 
+const WEI_SCALE = BigInt('1000000000000000000');
+const PRECISION_SCALE = BigInt('1000000000000');
+
+function weiStringToNumber(value: string): number {
+    const scaled = (BigInt(value) * PRECISION_SCALE) / WEI_SCALE;
+    return Number(scaled) / Number(PRECISION_SCALE);
+}
+
 function selectTimeframe(interval: CandleInterval): string {
     switch (interval) {
         case '1m':
@@ -213,15 +221,14 @@ export class MyriadNormalizer implements IExchangeNormalizer<MyriadRawMarket, My
     }
 
     normalizeClobOrderBook(raw: { bids: [string, string][]; asks: [string, string][] }): OrderBook {
-        const WEI = 1e18;
         return {
             bids: raw.bids.map(([priceWei, sizeWei]) => ({
-                price: Number(priceWei) / WEI,
-                size: Number(sizeWei) / WEI,
+                price: weiStringToNumber(priceWei),
+                size: weiStringToNumber(sizeWei),
             })),
             asks: raw.asks.map(([priceWei, sizeWei]) => ({
-                price: Number(priceWei) / WEI,
-                size: Number(sizeWei) / WEI,
+                price: weiStringToNumber(priceWei),
+                size: weiStringToNumber(sizeWei),
             })),
             timestamp: Date.now(),
         };
diff --git a/core/src/exchanges/suibets/api.ts b/core/src/exchanges/suibets/api.ts
@@ -5,7 +5,7 @@
  * It is NOT wired into defineImplicitApi — the fetcher calls these endpoints
  * directly via FetcherContext.http (the rate-limited HTTP client).
  *
- * Base URL: https://suibets.replit.app
+ * Base URL: https://www.suibets.com
  *
  * Endpoints:
  *   GET /api/p2p/offers          - List open P2P offers (status, matchId, sport, limit, offset)
diff --git a/core/src/exchanges/suibets/config.ts b/core/src/exchanges/suibets/config.ts
@@ -1,4 +1,4 @@
-export const SUIBETS_BASE_URL = 'https://suibets.replit.app';
+export const SUIBETS_BASE_URL = 'https://www.suibets.com';
 
 // SuiBets is a P2P sports betting platform on Sui blockchain.
 // Platform takes a 2% fee on settled markets.
@@ -15,7 +15,7 @@ export const MAX_PRICE = 0.99;
 export const RATE_LIMIT_MS = 300;
 
 // Allowlist of permitted hostnames for SSRF protection
-export const ALLOWED_HOSTS: readonly string[] = ['suibets.replit.app'];
+export const ALLOWED_HOSTS: readonly string[] = ['www.suibets.com'];
 
 /**
  * Validates that the given URL's hostname is in the ALLOWED_HOSTS allowlist.
diff --git a/core/src/exchanges/suibets/errors.ts b/core/src/exchanges/suibets/errors.ts
@@ -44,6 +44,20 @@ export class SuibetsErrorMapper extends ErrorMapper {
         if (axios.isAxiosError(error)) {
             const status = error.response?.status;
 
+            // HTML body = hosting/gateway outage — not a missing resource.
+            // Return ExchangeNotAvailable so callers can distinguish
+            // "offer not found" from "upstream server is down".
+            const responseData = error.response?.data;
+            const isHtml =
+                typeof responseData === 'string' &&
+                responseData.trimStart().startsWith('<');
+            if (isHtml) {
+                return new ExchangeNotAvailable(
+                    'SuiBets API is unavailable. Check https://www.suibets.com for service status.',
+                    this.exchangeName,
+                );
+            }
+
             if (status === 429) {
                 const retryAfter = error.response?.headers?.['retry-after'];
                 const retryAfterSeconds = retryAfter ? parseInt(retryAfter, 10) : undefined;
diff --git a/core/src/exchanges/suibets/fetcher.ts b/core/src/exchanges/suibets/fetcher.ts
@@ -37,7 +37,35 @@ export interface SuibetsRawEvent {
     offers?: SuibetsRawOffer[];
 }
 
-export class SuibetsFetcher implements IExchangeFetcher<SuibetsRawOffer, SuibetsRawEvent> {
+
+/**
+ * Structured return type for fetchRawPositions.
+ * Keeps the three position-array types separate so each is normalised
+ * with the correct shape instead of being cast from unknown[].
+ */
+export interface SuibetsRawPositions {
+    createdOffers: SuibetsRawOffer[];
+    matchedBets: unknown[];
+    parlays: unknown[];
+}
+
+/**
+ * Type guard: true only when the value has the core fields that
+ * SuibetsNormalizer.normalizePosition() reads (id, creatorOdds, creatorStake).
+ * Guards against silent garbage output when matchedBets or parlays
+ * are accidentally passed in as SuibetsRawOffer.
+ */
+export function isSuibetsRawOffer(value: unknown): value is SuibetsRawOffer {
+    if (typeof value !== 'object' || value === null) return false;
+    const v = value as Record<string, unknown>;
+    return (
+        (typeof v['id'] === 'string' || typeof v['id'] === 'number') &&
+        typeof v['creatorOdds'] === 'number' &&
+        typeof v['creatorStake'] === 'number'
+    );
+}
+
+export class SuibetsFetcher implements IExchangeFetcher<SuibetsRawOffer, SuibetsRawEvent, SuibetsRawPositions> {
     private readonly ctx: FetcherContext;
     private readonly baseUrl: string;
 
@@ -179,18 +207,21 @@ export class SuibetsFetcher implements IExchangeFetcher<SuibetsRawOffer, Suibets
     /**
      * Fetches raw positions (created offers, matched bets, parlays) for a
      * given Sui wallet address.
+     *
+     * Returns each array separately and typed so that normalisation uses
+     * the correct shape per position type rather than casting from unknown[].
      */
-    async fetchRawPositions(walletAddress: string): Promise<unknown[]> {
+    async fetchRawPositions(walletAddress: string): Promise<SuibetsRawPositions> {
         const data = await this.get<{
             createdOffers?: unknown[];
             matchedBets?: unknown[];
             parlays?: unknown[];
         }>('/api/p2p/my', { wallet: walletAddress });
 
-        return [
-            ...(data.createdOffers ?? []),
-            ...(data.matchedBets ?? []),
-            ...(data.parlays ?? []),
-        ];
+        return {
+            createdOffers: (data.createdOffers ?? []).filter(isSuibetsRawOffer),
+            matchedBets: data.matchedBets ?? [],
+            parlays: data.parlays ?? [],
+        };
     }
 }
diff --git a/core/src/exchanges/suibets/index.ts b/core/src/exchanges/suibets/index.ts
@@ -9,14 +9,13 @@ import { AuthenticationError } from '../../errors';
 import { getSuibetsConfig, SuibetsApiConfig, RATE_LIMIT_MS, validateBaseUrl } from './config';
 import { SuibetsFetcher, SuibetsRawOffer } from './fetcher';
 import { SuibetsNormalizer } from './normalizer';
-import { suibetsErrorMapper } from './errors';
 import { fromOutcomeId } from './utils';
 import { FetcherContext } from '../interfaces';
 
 export interface SuibetsCredentials extends ExchangeCredentials {
     /** Sui wallet address for fetching personal positions */
     walletAddress?: string;
-    /** Override API base URL (default: https://suibets.replit.app) */
+    /** Override API base URL (default: https://www.suibets.com) */
     baseUrl?: string;
 }
 
@@ -145,6 +144,6 @@ export class SuiBetsExchange extends PredictionMarketExchange {
             );
         }
         const raw = await this.fetcher.fetchRawPositions(wallet);
-        return raw.map(r => this.normalizer.normalizePosition(r as SuibetsRawOffer));
+        return raw.createdOffers.map(r => this.normalizer.normalizePosition(r));
     }
 }
diff --git a/core/src/exchanges/suibets/normalizer.ts b/core/src/exchanges/suibets/normalizer.ts
@@ -1,7 +1,6 @@
 import { IExchangeNormalizer } from '../interfaces';
 import { UnifiedMarket, UnifiedEvent, Position } from '../../types';
 import { SuibetsRawOffer, SuibetsRawEvent } from './fetcher';
-import { buildSourceMetadata } from '../../utils/metadata';
 import {
     impliedProbability,
     takerProbability,
@@ -12,21 +11,6 @@ import {
     mapStatus,
 } from './utils';
 
-// Raw SuiBets offer fields already promoted to first-class UnifiedMarket columns.
-// Omit these from sourceMetadata to capture only vendor-specific data not
-// represented by the unified shape.
-const SUIBETS_PROMOTED_OFFER_KEYS = [
-    'id', 'matchId', 'matchName', 'homeTeam', 'awayTeam',
-    'creatorOdds', 'creatorStake', 'remainingStake', 'totalMatched',
-    'matchDate', 'expiresAt', 'status', 'onchainOfferId',
-    'leagueName', 'sport', 'isOnchain',
-] as const;
-
-// Raw SuiBets event fields already promoted to first-class UnifiedEvent columns.
-const SUIBETS_PROMOTED_EVENT_KEYS = [
-    'id', 'name', 'homeTeam', 'awayTeam', 'sport', 'leagueName', 'offers',
-] as const;
-
 function liquidity(offer: SuibetsRawOffer): number {
     const remaining = offer.remainingStake ?? offer.creatorStake;
     return mistToSui(remaining);
@@ -80,19 +64,13 @@ export class SuibetsNormalizer implements IExchangeNormalizer<SuibetsRawOffer, S
             resolutionDate: new Date(dateSource),
             volume24h,
             liquidity: liq,
-            url: 'https://suibets.replit.app/p2p',
+            url: 'https://www.suibets.com/p2p',
             status: mapStatus(raw.status),
             category: 'Sports',
             tags: ['Sports', 'P2P', raw.sport, raw.leagueName].filter((t): t is string => Boolean(t)),
             contractAddress: raw.onchainOfferId,
             yes: creatorOutcome,
             no: takerOutcome,
-            // Retains creatorWallet, creatorTeam, takerStake, currency \u2014 fields
-            // that are vendor-specific and not promoted to any unified column.
-            sourceMetadata: buildSourceMetadata(
-                raw as unknown as Record<string, unknown>,
-                SUIBETS_PROMOTED_OFFER_KEYS,
-            ),
         };
 
         return market;
@@ -122,15 +100,9 @@ export class SuibetsNormalizer implements IExchangeNormalizer<SuibetsRawOffer, S
             markets,
             volume24h: totalVolume,
             volume: totalVolume,
-            url: 'https://suibets.replit.app/p2p',
+            url: 'https://www.suibets.com/p2p',
             category: 'Sports',
             tags: ['Sports', 'P2P', 'Sui', raw.sport, raw.leagueName].filter((t): t is string => Boolean(t)),
-            // Retains matchDate and status \u2014 event-level fields not promoted to
-            // any first-class UnifiedEvent column.
-            sourceMetadata: buildSourceMetadata(
-                raw as unknown as Record<string, unknown>,
-                SUIBETS_PROMOTED_EVENT_KEYS,
-            ),
         };
     }
 
diff --git a/core/src/server/openapi.yaml b/core/src/server/openapi.yaml
@@ -3199,6 +3199,8 @@ components:
         size:
           type: number
           description: contracts/shares
+        orderCount:
+          type: number
       required:
         - price
         - size
diff --git a/core/src/types.ts b/core/src/types.ts
@@ -171,6 +171,7 @@ export interface PriceCandle {
 export interface OrderLevel {
     price: number; // 0.0 to 1.0 (probability)
     size: number;  // contracts/shares
+    orderCount?: number;
 }
 
 export interface OrderBook {
diff --git a/core/test/normalizers/exchange-normalizers-2.test.ts b/core/test/normalizers/exchange-normalizers-2.test.ts
@@ -565,6 +565,17 @@ describe('MyriadNormalizer', () => {
             const result = normalizer.normalizeMarket(noExpiry)!;
             expect(result.resolutionDate.getTime()).toBe(0);
         });
+
+        it('preserves sub-1 wei prices without rounding to 1', () => {
+            const result = normalizer.normalizeClobOrderBook({
+                bids: [['999999999999999999', '250000000000000000'], ['100000000000000000', '1']],
+                asks: [['500000000000000000', '1000000000000000000']],
+            });
+
+            expect(result.bids[0].price).toBeLessThan(1);
+            expect(result.bids[0].price).toBeCloseTo(0.999999999999);
+            expect(result.bids[0].size).toBeCloseTo(0.25);
+        });
     });
 
     // -----------------------------------------------------------------------
diff --git a/core/test/normalizers/exchange-normalizers-3.test.ts b/core/test/normalizers/exchange-normalizers-3.test.ts
diff --git a/core/test/normalizers/exchange-normalizers.test.ts b/core/test/normalizers/exchange-normalizers.test.ts
diff --git a/core/test/normalizers/gemini-titan-normalizer.test.ts b/core/test/normalizers/gemini-titan-normalizer.test.ts
diff --git a/docs/api-reference/openapi-hosted.json b/docs/api-reference/openapi-hosted.json
diff --git a/docs/api-reference/openapi.json b/docs/api-reference/openapi.json
diff --git a/package-lock.json b/package-lock.json
diff --git a/sdks/python/API_REFERENCE.md b/sdks/python/API_REFERENCE.md
diff --git a/sdks/typescript/API_REFERENCE.md b/sdks/typescript/API_REFERENCE.md
diff --git a/sdks/typescript/pmxt/client.ts b/sdks/typescript/pmxt/client.ts

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,5 @@`
`1`	`1`	`{`
`2`		`- "_generated": "Auto-generated by extract-jsdoc.js on 2026-06-08T08:31:38.004Z. Do not edit manually.",`
	`2`	`+ "_generated": "Auto-generated by extract-jsdoc.js on 2026-06-08T09:58:54.515Z. Do not edit manually.",`
`3`	`3`	`"methods": {`
`4`	`4`	`"has": {`
`5`	`5`	`"summary": "HTTP verb for the endpoint (e.g. GET, POST). */",`
Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@`
`5`	`5`	`* It is NOT wired into defineImplicitApi — the fetcher calls these endpoints`
`6`	`6`	`* directly via FetcherContext.http (the rate-limited HTTP client).`
`7`	`7`	`*`
`8`		`- * Base URL: https://suibets.replit.app`
	`8`	`+ * Base URL: https://www.suibets.com`
`9`	`9`	`*`
`10`	`10`	`* Endpoints:`
`11`	`11`	`* GET /api/p2p/offers - List open P2P offers (status, matchId, sport, limit, offset)`