Polymarket Weather NOAA

How It Works

Configuration

Source Code

/**
 * Polymarket Weather NOAA Bot
 *
 * Exploits mispriced temperature bucket markets on Polymarket using
 * free NOAA (National Oceanic and Atmospheric Administration) forecast data.
 *
 * NOAA publishes hyper-accurate 24-48 hour forecasts built on decades of
 * satellite data and supercomputer simulations. Meanwhile, Polymarket
 * temperature bucket markets are priced by retail users guessing.
 *
 * The result: NOAA says 94% confidence NYC hits 74-76°F Saturday, but
 * the market prices that bucket at 11¢. Buy at 11¢, sell when it
 * corrects to 45-60¢ — a 3-4x return on a near-certain outcome.
 *
 * Reference bots:
 *   automatedAItradingbot: +$72.5K (weather only)
 *   0x594edB9112f526Fa6A80b8F858A6379C8A2c1C11: +$39.3K/month, 80% win rate
 *   aboss: +$42.4K (automated weather specialist)
 *
 * Stack: OpenClaw AI agent + Simmer Markets weather skill + NOAA API
 * Requires: Polymarket CLOB API access, USDC on Polygon.
 * License: MIT — Free to use, modify, and distribute.
 *
 * Generated by Moneybot Trading Platform
 * https://jc.holdings/trading
 */

// ── Configuration ──────────────────────────────────────────────

const CONFIG = {
  // Entry/exit thresholds
  entryThreshold: 0.15,       // Only buy buckets priced below 15¢
  exitThreshold: 0.45,        // Sell when market corrects above 45¢
  noaaConfidenceMin: 0.80,    // Only trade when NOAA confidence >= 80%

  // Position sizing
  maxPositionSize: 2.00,      // Max $2 per position (start small)
  maxTradesPerScan: 5,        // Max trades per scan cycle

  // Scanning
  scanIntervalMs: 120000,     // Scan every 2 minutes
  locations: ['NYC', 'Chicago', 'Seattle', 'Atlanta', 'Dallas', 'Miami'],

  // Risk
  maxOpenPositions: 15,       // Max concurrent positions
  maxDailyTrades: 50,         // Hard cap on daily trades
  safeguards: true,           // Enable risk safeguards
  trendDetection: true,       // Enable weather trend detection

  // APIs
  polymarketApiUrl: 'https://clob.polymarket.com',
  noaaApiUrl: 'https://api.weather.gov',
  chainId: 137, // Polygon
};

// ── NOAA Forecast Interface ────────────────────────────────────

/**
 * Fetch NOAA point forecast for a city.
 * NOAA provides gridpoint forecasts with temperature probability distributions.
 */
async function fetchNOAAForecast(location) {
  // NOAA uses a two-step process: first get the grid point, then the forecast
  const CITY_COORDS = {
    NYC: { lat: 40.7128, lon: -74.0060 },
    Chicago: { lat: 41.8781, lon: -87.6298 },
    Seattle: { lat: 47.6062, lon: -122.3321 },
    Atlanta: { lat: 33.7490, lon: -84.3880 },
    Dallas: { lat: 32.7767, lon: -96.7970 },
    Miami: { lat: 25.7617, lon: -80.1918 },
  };

  const coords = CITY_COORDS[location];
  if (!coords) return null;

  // Step 1: Get grid endpoint
  const pointResp = await fetch(
    CONFIG.noaaApiUrl + '/points/' + coords.lat + ',' + coords.lon,
    { headers: { 'User-Agent': 'PolymarketWeatherBot/1.0' } }
  );
  const pointData = await pointResp.json();
  const forecastUrl = pointData.properties?.forecast;
  if (!forecastUrl) return null;

  // Step 2: Get detailed forecast
  const fcstResp = await fetch(forecastUrl, {
    headers: { 'User-Agent': 'PolymarketWeatherBot/1.0' },
  });
  const fcstData = await fcstResp.json();

  return fcstData.properties?.periods || [];
}

/**
 * Parse NOAA forecast into temperature probability buckets.
 * NOAA provides point forecasts with confidence intervals.
 */
function parseTemperatureBuckets(forecast, targetDate) {
  const period = forecast.find(p => {
    const pDate = new Date(p.startTime).toDateString();
    return pDate === targetDate.toDateString() && p.isDaytime;
  });

  if (!period) return null;

  const temp = period.temperature;
  const unit = period.temperatureUnit;

  // NOAA short-range forecasts have ~2-3°F error margin
  // Build probability distribution around the point forecast
  const buckets = [];
  for (let low = temp - 10; low <= temp + 10; low += 2) {
    const high = low + 2;
    const distFromCenter = Math.abs((low + 1) - temp);
    // Gaussian-like probability distribution
    const probability = Math.exp(-(distFromCenter * distFromCenter) / 18);
    buckets.push({
      low,
      high,
      unit,
      noaaProbability: Math.round(probability * 100) / 100,
    });
  }

  // Normalize probabilities to sum to ~1
  const total = buckets.reduce((s, b) => s + b.noaaProbability, 0);
  buckets.forEach(b => { b.noaaProbability = Math.round((b.noaaProbability / total) * 100) / 100; });

  return buckets;
}

// ── Polymarket Interface ───────────────────────────────────────

/**
 * Fetch active weather/temperature markets from Polymarket.
 */
async function fetchWeatherMarkets() {
  const resp = await fetch(CONFIG.polymarketApiUrl + '/markets', {
    headers: { 'Accept': 'application/json' },
  });
  const markets = await resp.json();

  return markets.filter(m =>
    m.active &&
    (m.category || '').toLowerCase().includes('weather') ||
    (m.tags || []).some(t => t.toLowerCase().includes('temperature')) ||
    (m.question || '').match(/temperature|°F|°C|weather|high.*above|low.*below/i)
  );
}

/**
 * Get the best ask price for a temperature bucket contract.
 */
async function getBucketPrice(tokenId) {
  const resp = await fetch(CONFIG.polymarketApiUrl + '/book?token_id=' + tokenId);
  const book = await resp.json();
  return {
    bestAsk: book.asks?.[0]?.price || 1,
    askLiquidity: book.asks?.reduce((sum, o) => sum + parseFloat(o.size) * parseFloat(o.price), 0) || 0,
  };
}

// ── Edge Detection ─────────────────────────────────────────────

/**
 * Compare NOAA forecast probabilities to Polymarket prices.
 * Returns opportunities where the edge exceeds the entry threshold.
 */
async function findWeatherEdge(location) {
  const forecast = await fetchNOAAForecast(location);
  if (!forecast || forecast.length === 0) return [];

  const markets = await fetchWeatherMarkets();
  const opportunities = [];

  // Check next 48 hours of forecasts
  const now = new Date();
  for (let dayOffset = 0; dayOffset <= 2; dayOffset++) {
    const targetDate = new Date(now);
    targetDate.setDate(targetDate.getDate() + dayOffset);

    const buckets = parseTemperatureBuckets(forecast, targetDate);
    if (!buckets) continue;

    // Match NOAA buckets to Polymarket contracts
    for (const bucket of buckets) {
      if (bucket.noaaProbability < CONFIG.noaaConfidenceMin) continue;

      // Find matching Polymarket contract
      const matchingMarket = markets.find(m => {
        const q = (m.question || '').toLowerCase();
        return q.includes(location.toLowerCase()) &&
               (q.includes(bucket.low + '') || q.includes(bucket.high + ''));
      });

      if (!matchingMarket) continue;

      // Get current market price
      const priceData = await getBucketPrice(matchingMarket.outcomes?.[0]?.tokenId);
      const marketPrice = priceData.bestAsk;

      // Edge = NOAA probability - market price
      const edge = bucket.noaaProbability - marketPrice;

      if (marketPrice < CONFIG.entryThreshold && edge > 0.3) {
        opportunities.push({
          location,
          bucket: bucket.low + '-' + bucket.high + '°' + bucket.unit,
          noaaProb: bucket.noaaProbability,
          marketPrice,
          edge,
          market: matchingMarket,
          liquidity: priceData.askLiquidity,
        });
      }
    }
  }

  return opportunities;
}

// ── Execution ──────────────────────────────────────────────────

async function executeTrade(opportunity) {
  console.log('[TRADE] ' + opportunity.location + ': ' + opportunity.bucket);
  console.log('  NOAA: ' + (opportunity.noaaProb * 100).toFixed(0) + '% | Market: $' + opportunity.marketPrice.toFixed(3));
  console.log('  Edge: ' + (opportunity.edge * 100).toFixed(0) + '% | Position: $' + CONFIG.maxPositionSize);

  // TODO: Replace with actual Polymarket CLOB API order
  // const order = await submitOrder({
  //   tokenId: opportunity.market.outcomes[0].tokenId,
  //   side: 'BUY',
  //   price: opportunity.marketPrice,
  //   size: CONFIG.maxPositionSize / opportunity.marketPrice,
  //   type: 'GTC',
  // });

  return { success: true, opportunity };
}

// ── Main Loop ──────────────────────────────────────────────────

let dailyTrades = 0;
let totalProfit = 0;
let openPositions = [];

async function scanAndTrade() {
  if (dailyTrades >= CONFIG.maxDailyTrades) {
    console.log('[SCAN] Daily trade limit reached.');
    return;
  }

  console.log('[SCAN] Scanning ' + CONFIG.locations.length + ' cities for weather edge...');

  for (const location of CONFIG.locations) {
    try {
      const opportunities = await findWeatherEdge(location);
      console.log('[' + location + '] ' + opportunities.length + ' opportunities found');

      const sorted = opportunities.sort((a, b) => b.edge - a.edge);
      const toTrade = sorted.slice(0, CONFIG.maxTradesPerScan);

      for (const opp of toTrade) {
        if (dailyTrades >= CONFIG.maxDailyTrades) break;
        if (openPositions.length >= CONFIG.maxOpenPositions) break;

        const result = await executeTrade(opp);
        if (result.success) {
          dailyTrades++;
          openPositions.push(opp);
        }
      }

      // Rate limit between cities
      await new Promise(r => setTimeout(r, 500));
    } catch (err) {
      console.error('[ERROR] ' + location + ': ' + err.message);
    }
  }
}

// Reset daily counter at midnight UTC
function resetDaily() {
  const now = new Date();
  const msUntilMidnight = new Date(now.getFullYear(), now.getMonth(), now.getDate() + 1) - now;
  setTimeout(() => {
    dailyTrades = 0;
    console.log('[RESET] Daily trade counter reset');
    resetDaily();
  }, msUntilMidnight);
}

// ── Entry Point ────────────────────────────────────────────────

async function main() {
  console.log('=== Polymarket Weather NOAA Bot ===');
  console.log('Entry threshold: $' + CONFIG.entryThreshold);
  console.log('Exit threshold: $' + CONFIG.exitThreshold);
  console.log('NOAA min confidence: ' + (CONFIG.noaaConfidenceMin * 100) + '%');
  console.log('Locations: ' + CONFIG.locations.join(', '));
  console.log('Scan interval: ' + (CONFIG.scanIntervalMs / 1000) + 's');
  console.log('');

  resetDaily();

  while (true) {
    await scanAndTrade();
    await new Promise(r => setTimeout(r, CONFIG.scanIntervalMs));
  }
}

main().catch(console.error);

export { CONFIG, findWeatherEdge, executeTrade, fetchNOAAForecast, fetchWeatherMarkets };

Where to Run This Bot

Compare All Brokers →