Class LimitlessNormalizer

core/src/exchanges/limitless/normalizer.ts:31–166

}

export class LimitlessNormalizer implements IExchangeNormalizer<LimitlessRawMarket, LimitlessRawEvent> {

    normalizeMarket(raw: LimitlessRawMarket): UnifiedMarket | null {
        return mapMarketToUnified(raw);
    }

    normalizeEvent(raw: LimitlessRawEvent): UnifiedEvent | null {
        if (!raw) return null;

        let marketsList: UnifiedMarket[] = [];

        if (raw.markets && Array.isArray(raw.markets)) {
            const eventTitle = raw.title || raw.question || '';
            marketsList = raw.markets
                .map((child: any) => mapMarketToUnified(child, {
                    eventId: raw.slug,
                    eventTitle,
                    eventDescription: raw.description,
                    categories: raw.categories,
                    tags: raw.tags,
                }))
                .filter((m: any): m is UnifiedMarket => m !== null);
        } else {
            const unifiedMarket = mapMarketToUnified(raw);
            if (unifiedMarket) marketsList = [unifiedMarket];
        }

        return {
            id: raw.slug,
            title: raw.title || raw.question || '',
            description: raw.description || '',
            slug: raw.slug,
            markets: marketsList,
            volume24h: marketsList.reduce((sum, m) => sum + m.volume24h, 0),
            volume: marketsList.some(m => m.volume !== undefined)
                ? marketsList.reduce((sum, m) => sum + (m.volume ?? 0), 0)
                : undefined,
            url: `https://limitless.exchange/markets/${raw.slug}`,
            image: raw.logo || `https://limitless.exchange/api/og?slug=${raw.slug}`,
            category: raw.categories?.[0],
            tags: raw.tags || [],
            sourceMetadata: buildSourceMetadata(
                raw as unknown as Record<string, unknown>,
                LIMITLESS_PROMOTED_EVENT_KEYS,
            ),
        } as UnifiedEvent;
    }

    normalizeOHLCV(rawPrices: LimitlessRawPricePoint[], params: OHLCVParams): PriceCandle[] {
        let candles = rawPrices.map((p) => {
            const price = Number(p.price);
            const ts = Number(p.timestamp);

            return {
                timestamp: ts,
                open: price,
                high: price,
                low: price,