npm install tradingview-screener-ts

import { Query, col, And, Or } from 'tradingview-screener-ts'

const [total, rows] = await new Query()
  .set_markets('crypto')
  .select('name', 'close', 'volume', 'market_cap_basic', 'change')
  .order_by('market_cap_basic', false)
  .limit(50)
  .get_scanner_data()
// rows: [{ ticker: 'BINANCE:BTCUSDT', name: 'Bitcoin', close: 62000, ... }]

interface ScreenerRowDict { s: string; d: unknown[] }
interface ScreenerDict    { totalCount: number; data: ScreenerRowDict[] | null }

// get_scanner_data returns:
[number, Record<string, unknown>[]]
// [totalCount, [{ ticker, col1, col2, ... }, ...]]

'close'       // daily
'close|1'     // 1-minute
'close|5'     // 5-minute
'close|60'    // 1-hour
'close|240'   // 4-hour
'close|1W'    // weekly
'close|1M'    // monthly

col('close').gt(100)              col('close').ge(100)
col('close').lt(100)              col('close').le(100)
col('close').eq(100)              col('close').ne(100)
col('close').between(10, 50)      col('close').not_between(10, 50)
col('type').isin(['stock'])       col('type').not_in(['etf'])
col('tags').has(['value'])        col('tags').has_none_of(['etf'])
col('close').crosses(col('EMA20'))
col('close').crosses_above(col('EMA20'))
col('close').crosses_below(col('EMA20'))
col('close').above_pct(col('SMA200'), 0.05)
col('close').below_pct(col('SMA200'), 0.05)
col('name').like('Apple%')        col('name').not_like('Apple%')
col('eps').empty()                col('eps').not_empty()
col('date').in_day_range(0, 0)    col('date').in_week_range(0, 2)

Railway ais-relay.cjs
  └── seedTvStockScreener()     → market:tv-screener:stocks:v1    (TTL 5m)
  └── seedTvCryptoScreener()    → market:tv-screener:crypto:v1    (TTL 5m)
  └── seedTvForexScreener()     → market:tv-screener:forex:v1     (TTL 5m)
  └── seedTvTechnicals()        → market:tv-technicals:v1         (TTL 5m)
  └── seedTvEarningsCalendar()  → market:tv-earnings:v1           (TTL 1h)
  └── seedTvSectorSummary()     → market:tv-sectors:v1            (TTL 5m)

Vercel RPC handlers (read-only from Redis):
  └── list-tv-stock-screener.ts
  └── list-tv-crypto-screener.ts
  └── list-tv-forex-screener.ts
  └── get-tv-technicals.ts
  └── list-tv-earnings.ts
  └── list-tv-sectors.ts

Frontend → circuit breaker → RPC → Redis

// scripts/seed-tv-stock-screener.mjs
import { Query, col } from 'tradingview-screener-ts';
import { runSeed, CHROME_UA } from './_seed-utils.mjs';

const TV_KEY = 'market:tv-screener:stocks:v1';
const CACHE_TTL = 300; // 5 minutes

async function seedTvStockScreener() {
  const [total, rows] = await new Query()
    .select(
      'name', 'close', 'change', 'volume', 'market_cap_basic',
      'relative_volume_10d_calc', 'RSI', 'sector', 'country'
    )
    .where(
      col('market_cap_basic').gt(1_000_000_000),
      col('active_symbol').eq(true),
      col('is_primary').eq(true)
    )
    .order_by('Value.Traded', false)
    .limit(100)
    .get_scanner_data();

  if (!rows.length) throw new Error('TradingView returned no stock data');

  await runSeed(TV_KEY, { rows, total }, CACHE_TTL);
}

seedTvStockScreener().catch(err => {
  console.error('FATAL:', err.message);
  process.exit(1);
});

// In scripts/ais-relay.cjs — add to seedAllMarketData():

const { Query, col } = require('tradingview-screener-ts');

async function seedTvStockScreener() {
  try {
    const [total, rows] = await new Query()
      .select('name', 'close', 'change', 'volume', 'market_cap_basic', 'RSI', 'sector')
      .where(col('market_cap_basic').gt(1_000_000_000), col('is_primary').eq(true))
      .order_by('Value.Traded', false)
      .limit(100)
      .get_scanner_data();

    if (rows.length > 0) {
      await redisSet('market:tv-screener:stocks:v1', JSON.stringify({ rows, total }), 'EX', 300);
      console.log(`[TV Screener] Seeded ${rows.length} stocks`);
    }
  } catch (err) {
    console.error('[TV Screener] Failed:', err.message);
  }
}

// server/worldmonitor/market/v1/list-tv-stock-screener.ts
import { getCachedJson } from '@/_shared/redis';
import type { ListTvStockScreenerRequest, ListTvStockScreenerResponse } from '@generated/...';

const CACHE_KEY = 'market:tv-screener:stocks:v1';

export async function listTvStockScreener(
  _req: ListTvStockScreenerRequest
): Promise<ListTvStockScreenerResponse> {
  const data = await getCachedJson<{ rows: TvStockRow[]; total: number }>(CACHE_KEY, true);
  return { stocks: data?.rows ?? [], total: data?.total ?? 0 };
}

new Query()
  .select('name', 'close', 'change', 'change_abs', 'volume',
          'market_cap_basic', 'RSI', 'relative_volume_10d_calc',
          'sector', 'country', 'exchange')
  .where(
    col('market_cap_basic').gt(1_000_000_000),  // >$1B market cap
    col('is_primary').eq(true),
    col('active_symbol').eq(true)
  )
  .order_by('Value.Traded', false)
  .limit(100)

new Query()
  .set_markets('crypto')
  .select('name', 'close', 'change', 'change|1W', 'volume',
          'market_cap_basic', 'RSI', 'Recommend.All',
          'relative_volume_10d_calc', '24h_vol_change')
  .order_by('market_cap_basic', false)
  .limit(50)

// One query per sector, or use sector field + aggregate
new Query()
  .select('sector', 'change')
  .where(
    col('market_cap_basic').gt(500_000_000),
    col('type').isin(['stock']),
    col('exchange').not_in(['OTC']),
    col('is_primary').eq(true)
  )
  .order_by('Value.Traded', false)
  .limit(2000)
// Then group by 'sector' and average 'change' on the Railway side

new Query()
  .set_markets('forex')
  .select('name', 'close', 'change', 'change_abs', 'volume',
          'RSI', 'MACD.macd', 'EMA20', 'BB.upper', 'BB.lower')
  .set_tickers(
    'FX:EURUSD', 'FX:GBPUSD', 'FX:USDJPY', 'FX:USDCHF',
    'FX:AUDUSD', 'FX:USDCAD', 'FX:NZDUSD', 'FX:USDHKD',
    'FX:USDCNH', 'FX:EURGBP'
  )
  .get_scanner_data()

new Query()
  .set_markets('futures')
  .select('name', 'close', 'change', 'change_abs', 'volume',
          'open', 'high', 'low', 'price_52_week_high', 'price_52_week_low')
  .set_tickers(
    'NYMEX:CL1!',  // WTI Crude Oil
    'NYMEX:NG1!',  // Natural Gas
    'COMEX:GC1!',  // Gold
    'COMEX:SI1!',  // Silver
    'CBOT:ZW1!',   // Wheat
    'CBOT:ZC1!',   // Corn
    'CBOT:ZS1!',   // Soybeans
    'NYMEX:HO1!',  // Heating Oil
    'NYMEX:RB1!',  // RBOB Gasoline
    'COMEX:HG1!',  // Copper
    'COMEX:PL1!',  // Platinum
    'COMEX:PA1!',  // Palladium
  )
  .get_scanner_data()

// Golden cross: EMA50 crossed above EMA200
new Query()
  .select('name', 'close', 'change', 'EMA50', 'EMA200', 'volume', 'RSI')
  .where(
    col('EMA50').crosses_above(col('EMA200')),
    col('volume').gt(500_000),
    col('market_cap_basic').gt(500_000_000)
  )
  .limit(20)
  .get_scanner_data()

// Oversold (RSI < 30) with positive change
new Query()
  .select('name', 'close', 'change', 'RSI', 'volume', 'market_cap_basic')
  .where(
    col('RSI').between(20, 30),
    col('change').gt(0),
    col('volume').gt(1_000_000)
  )
  .limit(20)
  .get_scanner_data()

// Strong buy recommendations
new Query()
  .select('name', 'close', 'Recommend.All', 'RSI', 'MACD.macd')
  .where(col('Recommend.All').between(0.5, 1.0))
  .order_by('Recommend.All', false)
  .limit(20)
  .get_scanner_data()

new Query()
  .select('name', 'close', 'change', 'market_cap_basic',
          'earnings_release_next_trading_date_fq',
          'earnings_per_share_forecast_next_fq',
          'earnings_per_share_basic_ttm')
  .where(
    col('earnings_release_next_trading_date_fq').in_day_range(0, 7),
    col('market_cap_basic').gt(1_000_000_000)
  )
  .order_by('market_cap_basic', false)
  .limit(50)
  .get_scanner_data()

// Top movers today
new Query()
  .select('name', 'close', 'change', 'volume', 'relative_volume_10d_calc', 'sector')
  .where(
    col('change').gt(5),                         // up 5%+
    col('volume').gt(1_000_000),
    col('relative_volume_10d_calc').gt(2)        // 2x normal volume
  )
  .order_by('change', false)
  .limit(20)
  .get_scanner_data()

// Pre-market movers
new Query()
  .select('name', 'close', 'premarket_change', 'premarket_volume', 'market_cap_basic')
  .where(
    col('premarket_change').not_empty(),
    col('premarket_volume').gt(100_000),
    col('market_cap_basic').gt(500_000_000)
  )
  .order_by('premarket_change', false)
  .limit(20)
  .get_scanner_data()

new Query()
  .set_markets('bonds')
  .select('name', 'close', 'change', 'yield', 'duration', 'country')
  .set_tickers(
    'TVC:US10Y',   // US 10-year yield
    'TVC:US02Y',   // US 2-year yield
    'TVC:US30Y',   // US 30-year yield
    'TVC:DE10Y',   // German 10Y
    'TVC:GB10Y',   // UK 10Y
    'TVC:JP10Y',   // Japan 10Y
    'TVC:IT10Y',   // Italy 10Y
    'TVC:CN10Y',   // China 10Y
  )
  .get_scanner_data()

const [total, rows] = await new Query()
  .select('name', 'description', 'close', 'change', 'volume', 'market_cap_basic', 'sector')
  .where(
    col('is_primary').eq(true),
    col('active_symbol').eq(true),
    col('exchange').not_in(['OTC'])
  )
  .order_by('Value.Traded', false)
  .limit(50)
  .get_scanner_data()

const [total, rows] = await new Query()
  .set_markets('crypto')
  .select('name', 'close', 'change', 'market_cap_basic', 'volume', 'RSI')
  .order_by('market_cap_basic', false)
  .limit(50)
  .get_scanner_data()

const [total, rows] = await new Query()
  .set_index('SP;SPX')
  .select('name', 'close', 'change', 'volume', 'market_cap_basic', 'sector', 'RSI')
  .order_by('market_cap_basic', false)
  .limit(505)
  .get_scanner_data()

// Fetch all large-cap stocks with sector; aggregate by sector on Railway side
const [total, rows] = await new Query()
  .select('sector', 'change', 'market_cap_basic')
  .where(
    col('market_cap_basic').gt(500_000_000),
    col('type').isin(['stock']),
    col('is_primary').eq(true),
    col('exchange').not_in(['OTC']),
    col('sector').not_empty()
  )
  .limit(2000)
  .get_scanner_data()

// Group and average on Railway:
const sectorChange = Object.entries(
  rows.reduce((acc, r) => {
    const s = r.sector as string
    if (!acc[s]) acc[s] = { sum: 0, count: 0 }
    acc[s].sum += (r.change as number) ?? 0
    acc[s].count++
    return acc
  }, {} as Record<string, { sum: number; count: number }>)
).map(([name, { sum, count }]) => ({ name, change: sum / count }))

const [total, rows] = await new Query()
  .set_markets('forex')
  .set_tickers(
    'FX:EURUSD', 'FX:GBPUSD', 'FX:USDJPY', 'FX:USDCHF',
    'FX:AUDUSD', 'FX:USDCAD', 'FX:NZDUSD', 'FX:EURGBP',
    'FX:EURJPY', 'FX:GBPJPY'
  )
  .select('name', 'close', 'change', 'change_abs', 'high', 'low', 'RSI')
  .get_scanner_data()

const [total, rows] = await new Query()
  .set_markets('futures')
  .set_tickers(
    'NYMEX:CL1!', 'NYMEX:NG1!', 'COMEX:GC1!', 'COMEX:SI1!',
    'CBOT:ZW1!', 'CBOT:ZC1!', 'CBOT:ZS1!', 'COMEX:HG1!'
  )
  .select('name', 'close', 'change', 'high', 'low', 'volume')
  .get_scanner_data()

const [total, rows] = await new Query()
  .select('name', 'close', 'change', 'change|1W', 'change|1M',
          'RSI', 'RSI|1W', 'volume', 'market_cap_basic')
  .where(col('market_cap_basic').gt(1_000_000_000))
  .order_by('Value.Traded', false)
  .limit(50)
  .get_scanner_data()

const [total, rows] = await new Query()
  .select('name', 'close', 'change', 'market_cap_basic',
          'earnings_release_next_trading_date_fq',
          'earnings_per_share_forecast_next_fq')
  .where(
    col('earnings_release_next_trading_date_fq').in_day_range(0, 7),
    col('market_cap_basic').gt(1_000_000_000)
  )
  .order_by('market_cap_basic', false)
  .limit(50)
  .get_scanner_data()

// Price above 52-week high
const [total, rows] = await new Query()
  .select('name', 'close', 'change', 'volume', 'price_52_week_high')
  .where(
    col('close').above_pct(col('price_52_week_high'), 1.0),  // AT or above 52wk high
    col('volume').gt(1_000_000)
  )
  .order_by('change', false)
  .limit(20)
  .get_scanner_data()

// Golden cross (EMA50 > EMA200)
const [total2, rows2] = await new Query()
  .select('name', 'close', 'change', 'EMA50', 'EMA200', 'volume')
  .where(
    col('EMA50').crosses_above(col('EMA200')),
    col('volume').gt(500_000)
  )
  .limit(20)
  .get_scanner_data()

// RSI oversold with positive change
const [total, rows] = await new Query()
  .select('name', 'close', 'change', 'RSI', 'Recommend.All')
  .where(
    col('RSI').between(20, 35),
    col('change').gt(0),
    col('volume').gt(500_000),
    col('market_cap_basic').gt(500_000_000)
  )
  .limit(20)
  .get_scanner_data()