Trigger morning report from Circa release

src/config.js

@@ -23,6 +23,7 @@ export function getConfig() {
   const scanReportChannelId = process.env.SCAN_REPORT_CHANNEL_ID?.trim() || null;
   const scanAlertChannelId = process.env.SCAN_ALERT_CHANNEL_ID?.trim() || null;
   const scanMorningTime = process.env.SCAN_MORNING_TIME?.trim() || '08:00';
+  const scanMorningFallbackTime = process.env.SCAN_MORNING_FALLBACK_TIME?.trim() || '09:45';
   const scanTimeZone = process.env.SCAN_TIMEZONE?.trim() || 'America/Chicago';
   const scanMinBooks = Number(process.env.SCAN_MIN_BOOKS || 3);
   const scanDisagreementThreshold = Number(process.env.SCAN_DISAGREEMENT_THRESHOLD || 0.08);
@@ -104,6 +105,7 @@ export function getConfig() {
       scanReportChannelId,
       scanAlertChannelId,
       scanMorningTime,
+      scanMorningFallbackTime,
       scanTimeZone,
       scanMinBooks,
       scanDisagreementThreshold,

src/market-scanner.js

@@ -3912,6 +3912,7 @@ export class MarketScanner {
       reportChannelId: this.config.scanReportChannelId,
       alertChannelId: this.config.scanAlertChannelId,
       morningTime: this.config.scanMorningTime,
+      morningFallbackTime: this.config.scanMorningFallbackTime,
       timeZone: this.config.scanTimeZone,
       frequencyMinutes: this.config.scanFrequencyMinutes,
       circaChannelId: this.config.circaChannelId,
@@ -4183,12 +4184,18 @@ export class MarketScanner {
     }
 
     const dateKey = getZonedDateKey(now, this.config.scanTimeZone);
-    if (getZonedTime(now, this.config.scanTimeZone) !== this.config.scanMorningTime) {
+    const hasReport = await this.store.hasScanReport(dateKey, 'morning');
+    if (hasReport) {
       return null;
     }
 
-    const hasReport = await this.store.hasScanReport(dateKey, 'morning');
-    if (hasReport) {
+    const currentTime = getZonedTime(now, this.config.scanTimeZone);
+    const fallbackTime = this.config.scanMorningFallbackTime ?? '09:45';
+    const fallbackReached = currentTime >= fallbackTime;
+    const circaPosted = this.config.circaWorkflowEnabled
+      ? Boolean(await this.store.getCircaDailyPost(dateKey))
+      : false;
+    if (!circaPosted && !fallbackReached) {
       return null;
     }
 
@@ -4530,6 +4537,9 @@ export class MarketScanner {
 
       await this.store.recordCircaDailyPost(dateKey, snapshot.id, this.config.circaChannelId);
       this.status.lastCircaBoardAt = new Date().toISOString();
+      if (this.config.oddsWorkflowEnabled) {
+        await this.maybeRunMorningReport(new Date());
+      }
       return groupedMarkets;
     } finally {
       this.circaBoardRunning = false;

test/market-scanner.test.js

@@ -1434,6 +1434,90 @@ test('home run odds lookup accepts expanded sportsbook books', async () => {
   }
 });
 
+test('morning report waits for Circa post before fallback time', async () => {
+  const scanner = new MarketScanner({
+    client: {},
+    store: {
+      hasScanReport: async () => false,
+      getCircaDailyPost: async () => null,
+    },
+    embeds: {},
+    config: {
+      enabled: true,
+      oddsWorkflowEnabled: true,
+      circaWorkflowEnabled: true,
+      scanTimeZone: 'America/Chicago',
+      scanMorningFallbackTime: '09:45',
+    },
+  });
+
+  let called = false;
+  scanner.runMorningReport = async () => {
+    called = true;
+    return { ok: true };
+  };
+
+  const result = await scanner.maybeRunMorningReport(new Date('2026-04-07T14:30:00Z'));
+  assert.equal(result, null);
+  assert.equal(called, false);
+});
+
+test('morning report runs immediately after same-day Circa post', async () => {
+  const scanner = new MarketScanner({
+    client: {},
+    store: {
+      hasScanReport: async () => false,
+      getCircaDailyPost: async () => ({ postDate: '2026-04-07', snapshotId: 123 }),
+    },
+    embeds: {},
+    config: {
+      enabled: true,
+      oddsWorkflowEnabled: true,
+      circaWorkflowEnabled: true,
+      scanTimeZone: 'America/Chicago',
+      scanMorningFallbackTime: '09:45',
+    },
+  });
+
+  let invokedDateKey = null;
+  scanner.runMorningReport = async (dateKey) => {
+    invokedDateKey = dateKey;
+    return { ok: true };
+  };
+
+  const result = await scanner.maybeRunMorningReport(new Date('2026-04-07T14:30:00Z'));
+  assert.deepEqual(result, { ok: true });
+  assert.equal(invokedDateKey, '2026-04-07');
+});
+
+test('morning report falls back at 9:45 America/Chicago without Circa post', async () => {
+  const scanner = new MarketScanner({
+    client: {},
+    store: {
+      hasScanReport: async () => false,
+      getCircaDailyPost: async () => null,
+    },
+    embeds: {},
+    config: {
+      enabled: true,
+      oddsWorkflowEnabled: true,
+      circaWorkflowEnabled: true,
+      scanTimeZone: 'America/Chicago',
+      scanMorningFallbackTime: '09:45',
+    },
+  });
+
+  let invokedDateKey = null;
+  scanner.runMorningReport = async (dateKey) => {
+    invokedDateKey = dateKey;
+    return { ok: true };
+  };
+
+  const result = await scanner.maybeRunMorningReport(new Date('2026-04-07T14:45:00Z'));
+  assert.deepEqual(result, { ok: true });
+  assert.equal(invokedDateKey, '2026-04-07');
+});
+
 test('direct player odds lookups reuse cached Odds API entries within the ttl window', async () => {
   const scanner = new MarketScanner({
     client: {},