Exclude live games from movement alerts

src/db.js

@@ -250,6 +250,7 @@ export class BetStore {
         source TEXT NOT NULL,
         book TEXT NOT NULL,
         event_name TEXT,
+        event_commence_time TIMESTAMPTZ,
         player_name TEXT NOT NULL,
         market_type TEXT NOT NULL,
         market_label TEXT NOT NULL,
@@ -262,6 +263,10 @@ export class BetStore {
       );
     `);
 
+    await this.pool.query(`
+      ALTER TABLE scan_markets ADD COLUMN IF NOT EXISTS event_commence_time TIMESTAMPTZ;
+    `);
+
     await this.pool.query(`
       CREATE TABLE IF NOT EXISTS scan_reports (
         id INT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY,
@@ -733,6 +738,7 @@ export class BetStore {
               source,
               book,
               event_name,
+              event_commence_time,
               player_name,
               market_type,
               market_label,
@@ -742,7 +748,7 @@ export class BetStore {
               implied_probability,
               raw_label
             )
-            VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13)
+            VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14)
           `,
           [
             scanRunId,
@@ -750,6 +756,7 @@ export class BetStore {
             entry.source,
             entry.book,
             entry.eventName,
+            entry.eventCommenceTime ?? null,
             entry.playerName,
             entry.marketType,
             entry.marketLabel,
@@ -810,6 +817,7 @@ export class BetStore {
         source: entry.source,
         book: entry.book,
         eventName: entry.event_name,
+        eventCommenceTime: entry.event_commence_time?.toISOString?.() ?? (entry.event_commence_time ? String(entry.event_commence_time) : null),
         playerName: entry.player_name,
         marketType: entry.market_type,
         marketLabel: entry.market_label,

src/market-scanner.js

@@ -527,6 +527,7 @@ export function normalizeOddsApiEntries(payload = []) {
             bookKey: String(bookmaker.key || '').trim(),
             eventName: `${event.away_team} @ ${event.home_team}`,
             eventId: event.id,
+            eventCommenceTime: event.commence_time ?? null,
             team: null,
             playerName,
             playerKey: normalizePlayerName(playerName),
@@ -1136,6 +1137,33 @@ function extractNoisyStrikeoutEntries(text, section) {
   return entries;
 }
 
+function getEntryCommenceTime(entry) {
+  const rawValue = entry?.eventCommenceTime ?? entry?.eventCommenceAt ?? null;
+  if (!rawValue) {
+    return null;
+  }
+
+  const parsed = rawValue instanceof Date ? rawValue : new Date(rawValue);
+  return Number.isNaN(parsed.getTime()) ? null : parsed;
+}
+
+function isPregameEntry(entry, now = new Date()) {
+  if (entry?.source === 'circa') {
+    return true;
+  }
+
+  const commenceTime = getEntryCommenceTime(entry);
+  if (!commenceTime) {
+    return true;
+  }
+
+  return commenceTime.getTime() > now.getTime();
+}
+
+function isPregameSharpRow(row, now = new Date()) {
+  return row?.entries?.some((entry) => isPregameEntry(entry, now)) ?? isPregameEntry(row, now);
+}
+
 function extractStrikeoutLaneEntriesFromSnippet(text, section) {
   const rawLines = String(text ?? '')
     .replace(/\r\n/g, '\n')
@@ -2210,6 +2238,7 @@ export function analyzeSharpMarkets(entries, config = {}) {
       booksCompared: uniqueEntries.length,
       marketStatus: normalizeBookFilter(sharpEntry.book) === 'Circa' ? 'circa' : 'mgm_fallback',
       eventName: sharpEntry.eventName ?? bestSoftEntry.eventName ?? null,
+      eventCommenceTime: sharpEntry.eventCommenceTime ?? bestSoftEntry.eventCommenceTime ?? null,
       entries: uniqueEntries,
       softEntries,
     };
@@ -4020,11 +4049,15 @@ export class MarketScanner {
     const currentRun = analysis.scanRunId ? await this.store.getScanRunById(analysis.scanRunId) : null;
     const previousRun = currentRun ? await this.store.getPreviousScanRun(currentRun.id, 'scan') : null;
     if (currentRun && previousRun) {
+      const now = new Date();
       const currentState = analyzeSharpMarkets(currentRun.entries, this.config).groupedState;
       const previousState = analyzeSharpMarkets(previousRun.entries, this.config).groupedState;
 
       if (this.config.staleBookAlertsEnabled) {
         for (const [comparisonKey, state] of currentState.entries()) {
+          if (!isPregameSharpRow(state.sharpRow, now)) {
+            continue;
+          }
           const prior = previousState.get(comparisonKey);
           if (!prior) {
             continue;
@@ -4061,6 +4094,9 @@ export class MarketScanner {
 
       if (this.config.reverseAlertsEnabled) {
         for (const [comparisonKey, state] of currentState.entries()) {
+          if (!isPregameSharpRow(state.sharpRow, now)) {
+            continue;
+          }
           const prior = previousState.get(comparisonKey);
           if (!prior) {
             continue;

test/market-scanner.test.js

@@ -27,6 +27,7 @@ test('normalizes odds api entries into shared market keys', () => {
       id: 'event-1',
       away_team: 'Yankees',
       home_team: 'Red Sox',
+      commence_time: '2026-04-07T23:10:00Z',
       bookmakers: [
         {
           title: 'FanDuel',
@@ -49,6 +50,7 @@ test('normalizes odds api entries into shared market keys', () => {
   assert.equal(entries[0].source, 'odds_api');
   assert.equal(entries[0].book, 'FanDuel');
   assert.equal(entries[0].playerName, 'Aaron Judge');
+  assert.equal(entries[0].eventCommenceTime, '2026-04-07T23:10:00Z');
 });
 
 test('normalizes batter home run over outcomes as yes', () => {
@@ -391,7 +393,7 @@ test('fetches odds api entries from event-level endpoints', async () => {
     if (asString.includes('/events?')) {
       return {
         ok: true,
-        json: async () => [{ id: 'event-1' }],
+        json: async () => [{ id: 'event-1', commence_time: '2026-04-07T23:10:00Z' }],
       };
     }
 
@@ -403,6 +405,7 @@ test('fetches odds api entries from event-level endpoints', async () => {
           id: 'event-1',
           away_team: 'Yankees',
           home_team: 'Red Sox',
+          commence_time: '2026-04-07T23:10:00Z',
           bookmakers: [
             {
               key: 'fanduel',
@@ -436,6 +439,7 @@ test('fetches odds api entries from event-level endpoints', async () => {
 
     assert.equal(entries.length, 1);
     assert.equal(entries[0].playerName, 'Aaron Judge');
+    assert.equal(entries[0].eventCommenceTime, '2026-04-07T23:10:00Z');
     assert.ok(calls.some((url) => url.includes('/events?')));
     assert.ok(calls.some((url) => url.includes('/events/event-1/odds')));
     assert.ok(calls.some((url) => url.includes('regions=us')));
@@ -445,6 +449,134 @@ test('fetches odds api entries from event-level endpoints', async () => {
   }
 });
 
+test('movement alerts skip games that have already started', async () => {
+  const sentPayloads = [];
+  const latestRun = {
+    id: 2,
+    entries: [
+      {
+        marketKey: 'julio|home_runs|yes|0.5',
+        source: 'odds_api',
+        book: 'Circa',
+        eventName: 'Mariners @ Astros',
+        eventCommenceTime: '2026-04-07T00:00:00Z',
+        playerName: 'Julio Rodriguez',
+        team: 'SEA',
+        marketType: 'batter_home_runs',
+        marketLabel: 'Home Runs',
+        side: 'yes',
+        lineValue: 0.5,
+        oddsInput: '+380',
+        impliedProbability: americanToImpliedProbability('+380'),
+      },
+      {
+        marketKey: 'julio|home_runs|yes|0.5',
+        source: 'odds_api',
+        book: 'FanDuel',
+        eventName: 'Mariners @ Astros',
+        eventCommenceTime: '2026-04-07T00:00:00Z',
+        playerName: 'Julio Rodriguez',
+        team: 'SEA',
+        marketType: 'batter_home_runs',
+        marketLabel: 'Home Runs',
+        side: 'yes',
+        lineValue: 0.5,
+        oddsInput: '+430',
+        impliedProbability: americanToImpliedProbability('+430'),
+      },
+    ],
+  };
+  const previousRun = {
+    id: 1,
+    entries: [
+      {
+        marketKey: 'julio|home_runs|yes|0.5',
+        source: 'odds_api',
+        book: 'Circa',
+        eventName: 'Mariners @ Astros',
+        eventCommenceTime: '2026-04-07T00:00:00Z',
+        playerName: 'Julio Rodriguez',
+        team: 'SEA',
+        marketType: 'batter_home_runs',
+        marketLabel: 'Home Runs',
+        side: 'yes',
+        lineValue: 0.5,
+        oddsInput: '+380',
+        impliedProbability: americanToImpliedProbability('+380'),
+      },
+      {
+        marketKey: 'julio|home_runs|yes|0.5',
+        source: 'odds_api',
+        book: 'FanDuel',
+        eventName: 'Mariners @ Astros',
+        eventCommenceTime: '2026-04-07T00:00:00Z',
+        playerName: 'Julio Rodriguez',
+        team: 'SEA',
+        marketType: 'batter_home_runs',
+        marketLabel: 'Home Runs',
+        side: 'yes',
+        lineValue: 0.5,
+        oddsInput: '+500',
+        impliedProbability: americanToImpliedProbability('+500'),
+      },
+    ],
+  };
+  const store = {
+    getLatestScanRun: async () => latestRun,
+    getScanRunById: async () => latestRun,
+    getPreviousScanRun: async () => previousRun,
+    canSendScanAlert: async () => true,
+    recordScanAlert: async () => {},
+  };
+
+  const scanner = new MarketScanner({
+    client: {
+      channels: {
+        fetch: async () => ({
+          isTextBased: () => true,
+          send: async (payload) => {
+            sentPayloads.push(payload);
+            return { id: `message-${sentPayloads.length}` };
+          },
+        }),
+      },
+    },
+    store,
+    embeds: {
+      buildCircaAlertEmbed: () => ({ data: { title: 'circa' } }),
+      buildSharpAlertEmbed: () => ({ data: { title: 'sharp' } }),
+      buildStaleBookAlertEmbed: () => ({ data: { title: 'stale' } }),
+      buildReverseAlertEmbed: () => ({ data: { title: 'reverse' } }),
+    },
+    config: {
+      enabled: true,
+      oddsWorkflowEnabled: true,
+      circaWorkflowEnabled: false,
+      scanAlertChannelId: 'alerts',
+      staleBookAlertsEnabled: true,
+      reverseAlertsEnabled: true,
+      sharpEdgeAlertsEnabled: false,
+      staleBookAlertThreshold: 0.01,
+      reverseAlertThreshold: 0.01,
+      scanAlertCooldownMinutes: 0,
+      marketBoardDefaultLimit: 10,
+    },
+    logger: {
+      log: () => {},
+      error: () => {},
+    },
+  });
+
+  scanner.collectMarketAnalysis = async () => ({
+    circaAlerts: [],
+    edgeRows: [],
+    scanRunId: 2,
+  });
+
+  await scanner.runDisagreementScan();
+  assert.equal(sentPayloads.length, 0);
+});
+
 test('sharp analysis prefers Circa and falls back to BetMGM when Circa is missing', () => {
   const rows = analyzeSharpMarkets([
     {