Add Circa daily board and movement feed

.env.example

@@ -9,6 +9,11 @@ ODDS_API_SPORT_KEY=baseball_mlb
 ODDS_API_REGIONS=us
 ODDS_API_MARKETS=batter_home_runs,batter_hits,batter_total_bases,batter_rbis,batter_runs_scored,batter_hits_runs_rbis,pitcher_strikeouts
 CIRCA_DROPBOX_URL=
+CIRCA_CHANNEL_ID=
+CIRCA_DAILY_TIME=09:30
+CIRCA_TIMEZONE=America/Chicago
+CIRCA_RETRY_MINUTES=30
+CIRCA_MOVEMENT_FREQUENCY_MINUTES=5
 SCAN_REPORT_CHANNEL_ID=
 SCAN_ALERT_CHANNEL_ID=
 SCAN_MORNING_TIME=08:00

deploy/oracle/roibot.env.example

@@ -9,6 +9,11 @@ ODDS_API_SPORT_KEY=baseball_mlb
 ODDS_API_REGIONS=us
 ODDS_API_MARKETS=batter_home_runs,batter_hits,batter_total_bases,batter_rbis,batter_runs_scored,batter_hits_runs_rbis,pitcher_strikeouts
 CIRCA_DROPBOX_URL=
+CIRCA_CHANNEL_ID=
+CIRCA_DAILY_TIME=09:30
+CIRCA_TIMEZONE=America/Chicago
+CIRCA_RETRY_MINUTES=30
+CIRCA_MOVEMENT_FREQUENCY_MINUTES=5
 SCAN_REPORT_CHANNEL_ID=
 SCAN_ALERT_CHANNEL_ID=
 SCAN_MORNING_TIME=08:00

src/commands.js

@@ -211,6 +211,45 @@ export const commands = [
   new SlashCommandBuilder()
     .setName('circatest')
     .setDescription('Run a Circa OCR diagnostic and preview parsed entries.'),
+  new SlashCommandBuilder()
+    .setName('circamarket')
+    .setDescription('Show the latest Circa market in the current channel.')
+    .addStringOption((option) =>
+      option
+        .setName('market')
+        .setDescription('Choose which Circa market to show.')
+        .setRequired(true)
+        .addChoices(
+          { name: 'Home Runs', value: 'home_runs' },
+          { name: 'Hits', value: 'hits' },
+          { name: 'Total Bases', value: 'total_bases' },
+          { name: 'RBIs', value: 'rbis' },
+          { name: 'Runs', value: 'runs' },
+          { name: 'Hits + Runs + RBIs', value: 'hits_runs_rbis' },
+          { name: 'Pitcher Strikeouts', value: 'pitcher_strikeouts_generic' }
+        )
+    ),
+  new SlashCommandBuilder()
+    .setName('circahr')
+    .setDescription('Show the latest Circa Home Runs market in this channel.'),
+  new SlashCommandBuilder()
+    .setName('circahits')
+    .setDescription('Show the latest Circa Hits market in this channel.'),
+  new SlashCommandBuilder()
+    .setName('circatb')
+    .setDescription('Show the latest Circa Total Bases market in this channel.'),
+  new SlashCommandBuilder()
+    .setName('circarbis')
+    .setDescription('Show the latest Circa RBIs market in this channel.'),
+  new SlashCommandBuilder()
+    .setName('circaruns')
+    .setDescription('Show the latest Circa Runs market in this channel.'),
+  new SlashCommandBuilder()
+    .setName('circahrri')
+    .setDescription('Show the latest Circa Hits + Runs + RBIs market in this channel.'),
+  new SlashCommandBuilder()
+    .setName('circak')
+    .setDescription('Show the latest Circa Pitcher Strikeouts market in this channel.'),
   new SlashCommandBuilder()
     .setName('alerts')
     .setDescription('Post the analyst alert-role embed to the welcome channel.'),

src/config.js

@@ -23,6 +23,11 @@ export function getConfig() {
   const scanDisagreementThreshold = Number(process.env.SCAN_DISAGREEMENT_THRESHOLD || 0.08);
   const scanAlertCooldownMinutes = Number(process.env.SCAN_ALERT_COOLDOWN_MINUTES || 180);
   const scanFrequencyMinutes = Number(process.env.SCAN_FREQUENCY_MINUTES || 15);
+  const circaChannelId = process.env.CIRCA_CHANNEL_ID?.trim() || null;
+  const circaDailyTime = process.env.CIRCA_DAILY_TIME?.trim() || '09:30';
+  const circaTimeZone = process.env.CIRCA_TIMEZONE?.trim() || 'America/Chicago';
+  const circaRetryMinutes = Number(process.env.CIRCA_RETRY_MINUTES || 30);
+  const circaMovementFrequencyMinutes = Number(process.env.CIRCA_MOVEMENT_FREQUENCY_MINUTES || 5);
 
   if (!token) {
     throw new Error('Missing DISCORD_TOKEN in environment.');
@@ -40,11 +45,20 @@ export function getConfig() {
     adminRoleName,
     scanner: {
       enabled: Boolean(
+        circaDropboxUrl
+        && circaChannelId
+        || oddsApiKey
+        && scanReportChannelId
+        && scanAlertChannelId
+        && circaDropboxUrl
+      ),
+      oddsWorkflowEnabled: Boolean(
         oddsApiKey
         && scanReportChannelId
         && scanAlertChannelId
         && circaDropboxUrl
       ),
+      circaWorkflowEnabled: Boolean(circaDropboxUrl && circaChannelId),
       oddsApiKey,
       oddsApiBaseUrl,
       oddsApiSportKey,
@@ -59,6 +73,11 @@ export function getConfig() {
       scanDisagreementThreshold,
       scanAlertCooldownMinutes,
       scanFrequencyMinutes,
+      circaChannelId,
+      circaDailyTime,
+      circaTimeZone,
+      circaRetryMinutes,
+      circaMovementFrequencyMinutes,
     },
   };
 }

src/db.js

@@ -281,6 +281,52 @@ export class BetStore {
         last_sent_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
       );
     `);
+
+    await this.pool.query(`
+      CREATE TABLE IF NOT EXISTS circa_snapshots (
+        id INT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY,
+        file_name TEXT NOT NULL,
+        file_source TEXT,
+        fingerprint TEXT NOT NULL UNIQUE,
+        file_date DATE,
+        seen_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+        entry_count INT NOT NULL DEFAULT 0
+      );
+    `);
+
+    await this.pool.query(`
+      CREATE TABLE IF NOT EXISTS circa_snapshot_entries (
+        id INT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY,
+        snapshot_id INT NOT NULL REFERENCES circa_snapshots(id) ON DELETE CASCADE,
+        market_key TEXT NOT NULL,
+        player_name TEXT NOT NULL,
+        team TEXT,
+        market_type TEXT NOT NULL,
+        market_label TEXT NOT NULL,
+        side TEXT NOT NULL,
+        line_value DOUBLE PRECISION,
+        odds_input TEXT NOT NULL,
+        implied_probability DOUBLE PRECISION NOT NULL,
+        raw_label TEXT
+      );
+    `);
+
+    await this.pool.query(`
+      CREATE TABLE IF NOT EXISTS circa_daily_posts (
+        post_date DATE PRIMARY KEY,
+        snapshot_id INT NOT NULL REFERENCES circa_snapshots(id),
+        channel_id TEXT NOT NULL,
+        created_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
+      );
+    `);
+
+    await this.pool.query(`
+      CREATE TABLE IF NOT EXISTS circa_movement_posts (
+        movement_key TEXT PRIMARY KEY,
+        last_snapshot_fingerprint TEXT NOT NULL,
+        last_sent_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
+      );
+    `);
   }
 
   async upsertUser(user) {
@@ -784,6 +830,267 @@ export class BetStore {
     );
   }
 
+  async getLatestCircaSnapshot() {
+    const { rows } = await this.pool.query(
+      `
+        SELECT *
+        FROM circa_snapshots
+        ORDER BY seen_at DESC
+        LIMIT 1
+      `
+    );
+
+    if (!rows[0]) {
+      return null;
+    }
+
+    return this.getCircaSnapshotById(Number(rows[0].id));
+  }
+
+  async getPreviousCircaSnapshot(snapshotId) {
+    const { rows } = await this.pool.query(
+      `
+        SELECT *
+        FROM circa_snapshots
+        WHERE id < $1
+        ORDER BY id DESC
+        LIMIT 1
+      `,
+      [snapshotId]
+    );
+
+    if (!rows[0]) {
+      return null;
+    }
+
+    return this.getCircaSnapshotById(Number(rows[0].id));
+  }
+
+  async getCircaSnapshotByFingerprint(fingerprint) {
+    const { rows } = await this.pool.query(
+      `
+        SELECT *
+        FROM circa_snapshots
+        WHERE fingerprint = $1
+        LIMIT 1
+      `,
+      [fingerprint]
+    );
+
+    if (!rows[0]) {
+      return null;
+    }
+
+    return this.getCircaSnapshotById(Number(rows[0].id));
+  }
+
+  async getCircaSnapshotById(snapshotId) {
+    const { rows } = await this.pool.query(
+      `
+        SELECT *
+        FROM circa_snapshots
+        WHERE id = $1
+        LIMIT 1
+      `,
+      [snapshotId]
+    );
+
+    if (!rows[0]) {
+      return null;
+    }
+
+    const snapshotRow = rows[0];
+    const entryResult = await this.pool.query(
+      `
+        SELECT *
+        FROM circa_snapshot_entries
+        WHERE snapshot_id = $1
+        ORDER BY market_label, player_name, side, line_value NULLS FIRST
+      `,
+      [snapshotId]
+    );
+
+    return {
+      id: Number(snapshotRow.id),
+      fileName: snapshotRow.file_name,
+      fileSource: snapshotRow.file_source,
+      fingerprint: snapshotRow.fingerprint,
+      fileDate: snapshotRow.file_date ? new Date(snapshotRow.file_date).toISOString().slice(0, 10) : null,
+      seenAt: snapshotRow.seen_at?.toISOString?.() ?? String(snapshotRow.seen_at),
+      entryCount: Number(snapshotRow.entry_count),
+      entries: entryResult.rows.map((entry) => ({
+        marketKey: entry.market_key,
+        playerName: entry.player_name,
+        team: entry.team,
+        marketType: entry.market_type,
+        marketLabel: entry.market_label,
+        side: entry.side,
+        lineValue: numberOrNull(entry.line_value),
+        oddsInput: entry.odds_input,
+        impliedProbability: Number(entry.implied_probability),
+        rawLabel: entry.raw_label,
+      })),
+    };
+  }
+
+  async recordCircaSnapshot(snapshot) {
+    const existing = await this.getCircaSnapshotByFingerprint(snapshot.fingerprint);
+    if (existing) {
+      return existing;
+    }
+
+    const client = await this.pool.connect();
+
+    try {
+      await client.query('BEGIN');
+      const { rows } = await client.query(
+        `
+          INSERT INTO circa_snapshots (file_name, file_source, fingerprint, file_date, entry_count)
+          VALUES ($1, $2, $3, $4, $5)
+          RETURNING id
+        `,
+        [
+          snapshot.fileName,
+          snapshot.fileSource ?? null,
+          snapshot.fingerprint,
+          snapshot.fileDate ?? null,
+          snapshot.entries.length,
+        ]
+      );
+      const snapshotId = Number(rows[0].id);
+
+      for (const entry of snapshot.entries) {
+        await client.query(
+          `
+            INSERT INTO circa_snapshot_entries (
+              snapshot_id,
+              market_key,
+              player_name,
+              team,
+              market_type,
+              market_label,
+              side,
+              line_value,
+              odds_input,
+              implied_probability,
+              raw_label
+            )
+            VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11)
+          `,
+          [
+            snapshotId,
+            entry.marketKey,
+            entry.playerName,
+            entry.team ?? null,
+            entry.marketType,
+            entry.marketLabel,
+            entry.side,
+            entry.lineValue ?? null,
+            entry.oddsInput,
+            entry.impliedProbability,
+            entry.rawLabel ?? null,
+          ]
+        );
+      }
+
+      await client.query('COMMIT');
+      return this.getCircaSnapshotById(snapshotId);
+    } catch (error) {
+      await client.query('ROLLBACK');
+      throw error;
+    } finally {
+      client.release();
+    }
+  }
+
+  async getCircaDailyPost(postDate) {
+    const { rows } = await this.pool.query(
+      `
+        SELECT post_date, snapshot_id, channel_id, created_at
+        FROM circa_daily_posts
+        WHERE post_date = $1
+      `,
+      [postDate]
+    );
+
+    if (!rows[0]) {
+      return null;
+    }
+
+    return {
+      postDate: rows[0].post_date?.toISOString?.().slice(0, 10) ?? String(rows[0].post_date),
+      snapshotId: Number(rows[0].snapshot_id),
+      channelId: rows[0].channel_id,
+      createdAt: rows[0].created_at?.toISOString?.() ?? String(rows[0].created_at),
+    };
+  }
+
+  async recordCircaDailyPost(postDate, snapshotId, channelId) {
+    await this.pool.query(
+      `
+        INSERT INTO circa_daily_posts (post_date, snapshot_id, channel_id, created_at)
+        VALUES ($1, $2, $3, NOW())
+        ON CONFLICT (post_date) DO UPDATE SET
+          snapshot_id = EXCLUDED.snapshot_id,
+          channel_id = EXCLUDED.channel_id,
+          created_at = NOW()
+      `,
+      [postDate, snapshotId, channelId]
+    );
+  }
+
+  async getLatestCircaDailyPost() {
+    const { rows } = await this.pool.query(
+      `
+        SELECT post_date, snapshot_id, channel_id, created_at
+        FROM circa_daily_posts
+        ORDER BY post_date DESC
+        LIMIT 1
+      `
+    );
+
+    if (!rows[0]) {
+      return null;
+    }
+
+    return {
+      postDate: rows[0].post_date?.toISOString?.().slice(0, 10) ?? String(rows[0].post_date),
+      snapshotId: Number(rows[0].snapshot_id),
+      channelId: rows[0].channel_id,
+      createdAt: rows[0].created_at?.toISOString?.() ?? String(rows[0].created_at),
+    };
+  }
+
+  async canSendCircaMovement(movementKey, fingerprint) {
+    const { rows } = await this.pool.query(
+      `
+        SELECT last_snapshot_fingerprint
+        FROM circa_movement_posts
+        WHERE movement_key = $1
+      `,
+      [movementKey]
+    );
+
+    if (!rows[0]) {
+      return true;
+    }
+
+    return rows[0].last_snapshot_fingerprint !== fingerprint;
+  }
+
+  async recordCircaMovement(movementKey, fingerprint) {
+    await this.pool.query(
+      `
+        INSERT INTO circa_movement_posts (movement_key, last_snapshot_fingerprint, last_sent_at)
+        VALUES ($1, $2, NOW())
+        ON CONFLICT (movement_key) DO UPDATE SET
+          last_snapshot_fingerprint = EXCLUDED.last_snapshot_fingerprint,
+          last_sent_at = NOW()
+      `,
+      [movementKey, fingerprint]
+    );
+  }
+
   async close() {
     await this.pool.end();
   }

src/embeds.js

@@ -293,6 +293,7 @@ export function buildCommandsEmbed() {
       { name: '/scanrun', value: 'Run the market scanner manually. Admin only.' },
       { name: '/scanreport', value: 'Post the morning scan reports immediately. Admin only.' },
       { name: '/circatest', value: 'Run a Circa OCR diagnostic preview. Admin only.' },
+      { name: 'Circa Market Commands', value: '`/circamarket`, `/circahr`, `/circahits`, `/circatb`, `/circarbis`, `/circaruns`, `/circahrri`, `/circak` post the latest parsed Circa markets in the channel where you run them. Admin only.' },
       { name: '/alerts', value: 'Post the public analyst alert-role panel to the welcome channel. Only for jew_olympics.' },
       { name: '/welcome', value: 'Post the public welcome embed and tag everyone. Only for Kenny F\'n Powers.' }
     );
@@ -395,6 +396,7 @@ export function buildScanStatusEmbed(status) {
       : 'Scanner is disabled because one or more scan environment variables are missing.')
     .addFields(
       { name: 'Enabled', value: status.enabled ? 'Yes' : 'No', inline: true },
+      { name: 'Odds / Circa', value: `${status.oddsWorkflowEnabled ? 'On' : 'Off'} / ${status.circaWorkflowEnabled ? 'On' : 'Off'}`, inline: true },
       { name: 'Frequency', value: `${status.frequencyMinutes} minutes`, inline: true },
       { name: 'Morning Time', value: `${status.morningTime} (${status.timeZone})`, inline: true },
       { name: 'Report Channel', value: status.reportChannelId ? `<#${status.reportChannelId}>` : 'Not set', inline: true },
@@ -404,6 +406,13 @@ export function buildScanStatusEmbed(status) {
       { name: 'Last Report', value: status.lastReportAt ?? 'Never', inline: true },
       { name: 'Last Circa File', value: status.lastCircaFileName ?? 'None', inline: false },
       { name: 'Last Counts', value: `API: ${status.lastApiEntries ?? 0} | Circa: ${status.lastCircaEntries ?? 0} | Alerts: ${status.lastAlertCount ?? 0}`, inline: false },
+      { name: 'Circa Channel', value: status.circaChannelId ? `<#${status.circaChannelId}>` : 'Not set', inline: true },
+      { name: 'Circa Daily / Retry', value: `${status.circaDailyTime ?? '09:30'} (${status.circaTimeZone ?? 'America/Chicago'}) / ${status.circaRetryMinutes ?? 30}m`, inline: true },
+      { name: 'Circa Move Frequency', value: `${status.circaMovementFrequencyMinutes ?? 5} minutes`, inline: true },
+      { name: 'Last Seen Fingerprint', value: status.lastCircaFingerprintAt ?? 'Never', inline: true },
+      { name: 'Last Daily Board', value: status.lastCircaBoardAt ?? 'Never', inline: true },
+      { name: 'Last Move Scan', value: status.lastCircaMovementScanAt ?? 'Never', inline: true },
+      { name: 'Board Retry State', value: status.circaRetryState ?? 'Idle', inline: false },
       { name: 'Last Error', value: status.lastScanError ?? 'None', inline: false },
     );
 }
@@ -482,6 +491,83 @@ export function buildCircaFailureEmbed(details) {
     );
 }
 
+function chunkLines(lines, maxLength = 1000) {
+  const chunks = [];
+  let current = [];
+  let currentLength = 0;
+
+  for (const line of lines) {
+    const lineLength = line.length + (current.length > 0 ? 1 : 0);
+    if (current.length > 0 && currentLength + lineLength > maxLength) {
+      chunks.push(current.join('\n'));
+      current = [line];
+      currentLength = line.length;
+    } else {
+      current.push(line);
+      currentLength += lineLength;
+    }
+  }
+
+  if (current.length > 0) {
+    chunks.push(current.join('\n'));
+  }
+
+  return chunks;
+}
+
+export function buildCircaMarketEmbed(snapshot, marketLabel, entries, options = {}) {
+  const embed = new EmbedBuilder()
+    .setColor(PALETTE.gold)
+    .setTitle(`Circa ${marketLabel}`)
+    .setDescription(`Source file: **${snapshot.fileName ?? 'Unknown'}**`)
+    .setFooter({ text: options.footerText ?? 'Latest parsed Circa market snapshot' });
+
+  if (entries.length === 0) {
+    return embed.addFields({ name: 'No props', value: 'No parsed props were available for this market.' });
+  }
+
+  const lines = entries.map((entry) => {
+    const team = entry.team ? ` (${entry.team})` : '';
+    const side = `${String(entry.side ?? '').toUpperCase()}${entry.lineValue !== null && entry.lineValue !== undefined ? ` ${entry.lineValue}` : ''}`;
+    return `${entry.playerName}${team} | ${side} | ${entry.oddsInput}`;
+  });
+
+  const chunks = chunkLines(lines).slice(0, 25);
+  embed.addFields(
+    chunks.map((value, index) => ({
+      name: index === 0 ? 'Props' : `Props ${index + 1}`,
+      value,
+      inline: false,
+    }))
+  );
+
+  if (chunks.length < Math.ceil(lines.length / 1000)) {
+    embed.addFields({
+      name: 'Trimmed',
+      value: `Displayed the first ${chunks.length} embed sections for this market.`,
+      inline: false,
+    });
+  }
+
+  return embed;
+}
+
+export function buildCircaMovementEmbed(movement, snapshot) {
+  return new EmbedBuilder()
+    .setColor(PALETTE.blue)
+    .setTitle('Circa Movement')
+    .setDescription(`${movement.playerName} - ${movement.marketLabel}`)
+    .addFields(
+      { name: 'Side', value: `${String(movement.side).toUpperCase()}${movement.lineValue !== null && movement.lineValue !== undefined ? ` ${movement.lineValue}` : ''}`, inline: true },
+      { name: 'Old Odds', value: movement.oldOddsInput, inline: true },
+      { name: 'New Odds', value: movement.newOddsInput, inline: true },
+      { name: 'Implied Change', value: `${movement.impliedChangePercent >= 0 ? '+' : ''}${movement.impliedChangePercent.toFixed(2)}%`, inline: true },
+      { name: 'Percent Change', value: `${movement.relativePercentChange >= 0 ? '+' : ''}${movement.relativePercentChange.toFixed(2)}%`, inline: true },
+      { name: 'Source File', value: snapshot.fileName ?? 'Unknown', inline: true },
+    )
+    .setFooter({ text: 'Posted only because this Circa prop moved from the prior seen snapshot.' });
+}
+
 function escapeCsv(value) {
   const stringValue = String(value);
   if (stringValue.includes(',') || stringValue.includes('"') || stringValue.includes('\n')) {

src/index.js

@@ -35,6 +35,7 @@ import {
   buildCircaDiagnosticEmbed,
   buildCircaAlertEmbed,
   buildCircaFailureEmbed,
+  buildCircaMarketEmbed,
   buildDeleteBetEmbed,
   buildEditBetEmbed,
   buildErrorEmbed,
@@ -278,6 +279,46 @@ async function handleChatInput(interaction, store, config) {
     return;
   }
 
+  if (commandName === 'circamarket') {
+    await handleCircaMarket(interaction, config);
+    return;
+  }
+
+  if (commandName === 'circahr') {
+    await handleCircaShortcut(interaction, config, 'home_runs');
+    return;
+  }
+
+  if (commandName === 'circahits') {
+    await handleCircaShortcut(interaction, config, 'hits');
+    return;
+  }
+
+  if (commandName === 'circatb') {
+    await handleCircaShortcut(interaction, config, 'total_bases');
+    return;
+  }
+
+  if (commandName === 'circarbis') {
+    await handleCircaShortcut(interaction, config, 'rbis');
+    return;
+  }
+
+  if (commandName === 'circaruns') {
+    await handleCircaShortcut(interaction, config, 'runs');
+    return;
+  }
+
+  if (commandName === 'circahrri') {
+    await handleCircaShortcut(interaction, config, 'hits_runs_rbis');
+    return;
+  }
+
+  if (commandName === 'circak') {
+    await handleCircaShortcut(interaction, config, 'pitcher_strikeouts_generic');
+    return;
+  }
+
   if (commandName === 'alerts') {
     await handleAlerts(interaction);
     return;
@@ -933,6 +974,42 @@ async function handleCircaTest(interaction, config) {
   }
 }
 
+async function handleCircaMarket(interaction, config) {
+  const marketType = interaction.options.getString('market', true);
+  await handleCircaShortcut(interaction, config, marketType);
+}
+
+async function handleCircaShortcut(interaction, config, marketType) {
+  const isAdmin = await memberHasRoleName(interaction, config.adminRoleName);
+  if (!isAdmin) {
+    await denyAdminOnly(interaction, config.adminRoleName);
+    return;
+  }
+
+  const scanner = interaction.client.__marketScanner;
+  if (!scanner?.getStatus().circaWorkflowEnabled) {
+    await interaction.reply({
+      embeds: [buildErrorEmbed('Circa disabled', 'Set the Circa environment variables before using Circa commands.')],
+      flags: MessageFlags.Ephemeral,
+    });
+    return;
+  }
+
+  await interaction.deferReply();
+  try {
+    const market = await scanner.getLatestCircaMarket(marketType);
+    await interaction.editReply({
+      embeds: [buildCircaMarketEmbed(market.snapshot, market.marketLabel, market.entries, {
+        footerText: `Manual Circa view requested by ${interaction.user.displayName ?? interaction.user.username}`,
+      })],
+    });
+  } catch (error) {
+    await interaction.editReply({
+      embeds: [buildErrorEmbed('Circa market unavailable', error.message || 'The Circa market lookup hit an unexpected error.')],
+    });
+  }
+}
+
 async function handleButton(interaction, store) {
   const alertRoleName = parseAlertRoleButtonId(interaction.customId);
   if (alertRoleName) {

src/market-scanner.js

@@ -6,6 +6,7 @@ import os from 'node:os';
 import path from 'node:path';
 import { execFile } from 'node:child_process';
 import { promisify } from 'node:util';
+import { createHash } from 'node:crypto';
 
 if (!globalThis.DOMMatrix) {
   globalThis.DOMMatrix = DOMMatrix;
@@ -39,6 +40,26 @@ const MARKET_TYPE_LABELS = {
   pitcher_strikeouts_generic: 'Pitcher Strikeouts',
 };
 
+export const CIRCA_MARKET_DISPLAY_ORDER = [
+  'home_runs',
+  'hits',
+  'total_bases',
+  'rbis',
+  'runs',
+  'hits_runs_rbis',
+  'pitcher_strikeouts_generic',
+];
+
+const CIRCA_MARKET_ALIASES = {
+  batter_home_runs: 'home_runs',
+  batter_hits: 'hits',
+  batter_total_bases: 'total_bases',
+  batter_rbis: 'rbis',
+  batter_runs_scored: 'runs',
+  batter_hits_runs_rbis: 'hits_runs_rbis',
+  pitcher_strikeouts: 'pitcher_strikeouts_generic',
+};
+
 const OCR_MARKET_PATTERNS = [
   { type: 'home_runs', label: 'Home Runs', pattern: /(home\s*runs?|hr\b)/i },
   { type: 'total_bases', label: 'Total Bases', pattern: /(total\s*bases?|tb\b)/i },
@@ -1461,6 +1482,147 @@ function getZonedTime(date, timeZone) {
   return `${parts.hour}:${parts.minute}`;
 }
 
+function compareCircaMarketOrder(left, right) {
+  const leftIndex = CIRCA_MARKET_DISPLAY_ORDER.indexOf(left);
+  const rightIndex = CIRCA_MARKET_DISPLAY_ORDER.indexOf(right);
+  const normalizedLeft = leftIndex === -1 ? Number.MAX_SAFE_INTEGER : leftIndex;
+  const normalizedRight = rightIndex === -1 ? Number.MAX_SAFE_INTEGER : rightIndex;
+  return normalizedLeft - normalizedRight || left.localeCompare(right);
+}
+
+function normalizeCircaMarketType(marketType) {
+  return CIRCA_MARKET_ALIASES[marketType] ?? marketType;
+}
+
+function groupCircaMarkets(entries = []) {
+  const grouped = new Map();
+
+  for (const entry of entries) {
+    const normalizedMarketType = normalizeCircaMarketType(entry.marketType);
+    if (!grouped.has(normalizedMarketType)) {
+      grouped.set(normalizedMarketType, {
+        marketType: normalizedMarketType,
+        marketLabel: MARKET_TYPE_LABELS[normalizedMarketType] ?? entry.marketLabel ?? normalizedMarketType,
+        entries: [],
+      });
+    }
+
+    grouped.get(normalizedMarketType).entries.push({
+      ...entry,
+      marketType: normalizedMarketType,
+      marketLabel: MARKET_TYPE_LABELS[normalizedMarketType] ?? entry.marketLabel ?? normalizedMarketType,
+    });
+  }
+
+  return [...grouped.values()]
+    .map((group) => ({
+      ...group,
+      entries: [...group.entries].sort((left, right) =>
+        left.playerName.localeCompare(right.playerName)
+        || String(left.side).localeCompare(String(right.side))
+        || (left.lineValue ?? 0) - (right.lineValue ?? 0)
+      ),
+    }))
+    .sort((left, right) => compareCircaMarketOrder(left.marketType, right.marketType));
+}
+
+function serializeCircaEntries(entries = []) {
+  return [...entries]
+    .map((entry) => ({
+      marketKey: entry.marketKey,
+      playerName: entry.playerName,
+      team: entry.team ?? null,
+      marketType: normalizeCircaMarketType(entry.marketType),
+      marketLabel: MARKET_TYPE_LABELS[normalizeCircaMarketType(entry.marketType)] ?? entry.marketLabel,
+      side: entry.side,
+      lineValue: entry.lineValue ?? null,
+      oddsInput: entry.oddsInput,
+      impliedProbability: entry.impliedProbability,
+    }))
+    .sort((left, right) =>
+      left.marketKey.localeCompare(right.marketKey)
+      || left.oddsInput.localeCompare(right.oddsInput)
+    );
+}
+
+function buildCircaFingerprint(fileName, entries = []) {
+  return createHash('sha256')
+    .update(JSON.stringify({ fileName, entries: serializeCircaEntries(entries) }))
+    .digest('hex');
+}
+
+function parseFileDateFromName(fileName) {
+  const timestamp = parseDateFromCircaFilename(fileName);
+  if (timestamp === null) {
+    return null;
+  }
+
+  return new Date(timestamp).toISOString().slice(0, 10);
+}
+
+function buildMovementKey(entry) {
+  return [
+    normalizePlayerName(entry.playerName),
+    normalizeCircaMarketType(entry.marketType),
+    entry.side,
+    entry.lineValue ?? 'na',
+  ].join('|');
+}
+
+function americanOddsToNumber(oddsInput) {
+  const value = Number(String(oddsInput ?? '').trim());
+  return Number.isFinite(value) ? value : null;
+}
+
+function buildCircaMovements(previousSnapshot, currentSnapshot) {
+  if (!previousSnapshot || !currentSnapshot) {
+    return [];
+  }
+
+  const previousEntries = new Map(previousSnapshot.entries.map((entry) => [buildMovementKey(entry), entry]));
+  const movements = [];
+
+  for (const currentEntry of currentSnapshot.entries) {
+    const key = buildMovementKey(currentEntry);
+    const previousEntry = previousEntries.get(key);
+    if (!previousEntry || previousEntry.oddsInput === currentEntry.oddsInput) {
+      continue;
+    }
+
+    const oldImplied = previousEntry.impliedProbability ?? americanToImpliedProbability(previousEntry.oddsInput);
+    const newImplied = currentEntry.impliedProbability ?? americanToImpliedProbability(currentEntry.oddsInput);
+    const oldOddsNumber = americanOddsToNumber(previousEntry.oddsInput);
+    const newOddsNumber = americanOddsToNumber(currentEntry.oddsInput);
+    const impliedChange = (newImplied ?? 0) - (oldImplied ?? 0);
+    const relativePercentChange = oldImplied && Number.isFinite(oldImplied)
+      ? (impliedChange / oldImplied) * 100
+      : 0;
+
+    movements.push({
+      movementKey: key,
+      playerName: currentEntry.playerName,
+      marketType: normalizeCircaMarketType(currentEntry.marketType),
+      marketLabel: MARKET_TYPE_LABELS[normalizeCircaMarketType(currentEntry.marketType)] ?? currentEntry.marketLabel,
+      side: currentEntry.side,
+      lineValue: currentEntry.lineValue ?? null,
+      oldOddsInput: previousEntry.oddsInput,
+      newOddsInput: currentEntry.oddsInput,
+      oldOddsNumber,
+      newOddsNumber,
+      impliedChangePercent: impliedChange * 100,
+      relativePercentChange,
+    });
+  }
+
+  return movements.sort((left, right) =>
+    Math.abs(right.impliedChangePercent) - Math.abs(left.impliedChangePercent)
+  );
+}
+
+function hasReachedZonedTime(now, timeZone, targetTime) {
+  return getZonedTime(now, timeZone) >= targetTime;
+}
+
 export class MarketScanner {
   constructor({ client, store, config, embeds, logger = console }) {
     this.client = client;
@@ -1470,9 +1632,16 @@ export class MarketScanner {
     this.logger = logger;
     this.scanTimer = null;
     this.reportTimer = null;
+    this.circaRetryTimer = null;
+    this.circaMovementTimer = null;
     this.running = false;
+    this.circaRunning = false;
+    this.circaMovementRunning = false;
+    this.circaBoardRunning = false;
     this.status = {
       enabled: config.enabled,
+      oddsWorkflowEnabled: config.oddsWorkflowEnabled,
+      circaWorkflowEnabled: config.circaWorkflowEnabled,
       lastScanAt: null,
       lastReportAt: null,
       lastScanError: null,
@@ -1480,6 +1649,10 @@ export class MarketScanner {
       lastApiEntries: 0,
       lastAlertCount: 0,
       lastCircaFileName: null,
+      lastCircaFingerprintAt: null,
+      lastCircaBoardAt: null,
+      lastCircaMovementScanAt: null,
+      circaRetryState: 'Idle',
     };
   }
 
@@ -1495,26 +1668,62 @@ export class MarketScanner {
       morningTime: this.config.scanMorningTime,
       timeZone: this.config.scanTimeZone,
       frequencyMinutes: this.config.scanFrequencyMinutes,
+      circaChannelId: this.config.circaChannelId,
+      circaDailyTime: this.config.circaDailyTime,
+      circaMovementFrequencyMinutes: this.config.circaMovementFrequencyMinutes,
     });
 
-    this.scanTimer = setInterval(() => {
+    if (this.config.oddsWorkflowEnabled) {
+      this.scanTimer = setInterval(() => {
+        this.runDisagreementScan().catch((error) => {
+          this.status.lastScanError = error.message;
+          this.logger.error('Scanner interval failed', error);
+        });
+      }, this.config.scanFrequencyMinutes * 60 * 1000);
+
+      this.reportTimer = setInterval(() => {
+        this.maybeRunMorningReport().catch((error) => {
+          this.status.lastScanError = error.message;
+          this.logger.error('Morning report interval failed', error);
+        });
+      }, 60 * 1000);
+
       this.runDisagreementScan().catch((error) => {
         this.status.lastScanError = error.message;
-        this.logger.error('Scanner interval failed', error);
+        this.logger.error('Initial scanner run failed', error);
+      });
+    }
+
+    if (this.config.circaWorkflowEnabled) {
+      this.circaRetryTimer = setInterval(() => {
+        this.maybeRunCircaDailyBoard().catch((error) => {
+          this.status.lastScanError = error.message;
+          this.logger.error('Circa daily board interval failed', error);
+        });
+      }, Math.max(1, this.config.circaRetryMinutes) * 60 * 1000);
+
+      this.circaMovementTimer = setInterval(() => {
+        this.runCircaMovementScan().catch((error) => {
+          this.status.lastScanError = error.message;
+          this.logger.error('Circa movement interval failed', error);
+        });
+      }, Math.max(1, this.config.circaMovementFrequencyMinutes) * 60 * 1000);
+
+      this.refreshCircaSnapshot().catch((error) => {
+        this.status.lastScanError = error.message;
+        this.logger.error('Initial Circa snapshot refresh failed', error);
       });
-    }, this.config.scanFrequencyMinutes * 60 * 1000);
 
-    this.reportTimer = setInterval(() => {
-      this.maybeRunMorningReport().catch((error) => {
+      this.maybeRunCircaDailyBoard().catch((error) => {
         this.status.lastScanError = error.message;
-        this.logger.error('Morning report interval failed', error);
+        this.logger.error('Initial Circa board check failed', error);
       });
-    }, 60 * 1000);
 
-    this.runDisagreementScan().catch((error) => {
-      this.status.lastScanError = error.message;
-      this.logger.error('Initial scanner run failed', error);
-    });
+      this.runCircaMovementScan().catch((error) => {
+        this.status.lastScanError = error.message;
+        this.logger.error('Initial Circa movement scan failed', error);
+      });
+    }
   }
 
   async stop() {
@@ -1524,6 +1733,12 @@ export class MarketScanner {
     if (this.reportTimer) {
       clearInterval(this.reportTimer);
     }
+    if (this.circaRetryTimer) {
+      clearInterval(this.circaRetryTimer);
+    }
+    if (this.circaMovementTimer) {
+      clearInterval(this.circaMovementTimer);
+    }
     if (ocrWorkerPromise) {
       const worker = await ocrWorkerPromise;
       await worker.terminate();
@@ -1541,6 +1756,11 @@ export class MarketScanner {
       frequencyMinutes: this.config.scanFrequencyMinutes,
       minBooks: this.config.scanMinBooks,
       disagreementThreshold: this.config.scanDisagreementThreshold,
+      circaChannelId: this.config.circaChannelId,
+      circaDailyTime: this.config.circaDailyTime,
+      circaTimeZone: this.config.circaTimeZone,
+      circaRetryMinutes: this.config.circaRetryMinutes,
+      circaMovementFrequencyMinutes: this.config.circaMovementFrequencyMinutes,
     };
   }
 
@@ -1563,6 +1783,10 @@ export class MarketScanner {
   }
 
   async runMorningReport(dateKey = getZonedDateKey(new Date(), this.config.scanTimeZone)) {
+    if (!this.config.oddsWorkflowEnabled) {
+      throw new Error('Odds workflow is disabled.');
+    }
+
     const analysis = await this.collectMarketAnalysis('morning');
     const channel = await this.client.channels.fetch(this.config.scanReportChannelId);
     if (!channel?.isTextBased()) {
@@ -1589,6 +1813,10 @@ export class MarketScanner {
   }
 
   async runDisagreementScan() {
+    if (!this.config.oddsWorkflowEnabled) {
+      throw new Error('Odds workflow is disabled.');
+    }
+
     const analysis = await this.collectMarketAnalysis('scan');
     const channel = await this.client.channels.fetch(this.config.scanAlertChannelId);
     if (!channel?.isTextBased()) {
@@ -1617,7 +1845,7 @@ export class MarketScanner {
   }
 
   async runCircaDiagnostic() {
-    const result = await fetchCircaEntries(this.config);
+    const result = await this.fetchLatestCircaSnapshot({ persist: true });
     return {
       fileName: result.fileName,
       rawTextSample: result.text.slice(0, 1000),
@@ -1626,6 +1854,185 @@ export class MarketScanner {
     };
   }
 
+  async fetchLatestCircaSnapshot(options = {}) {
+    if (!this.config.circaDropboxUrl) {
+      throw new Error('No Circa source configured.');
+    }
+
+    const result = await fetchCircaEntries(this.config);
+    const normalizedEntries = serializeCircaEntries(result.entries);
+    const snapshotPayload = {
+      fileName: result.fileName ?? 'Unknown',
+      fileSource: result.source ?? 'Public Dropbox folder',
+      fileDate: parseFileDateFromName(result.fileName ?? ''),
+      fingerprint: buildCircaFingerprint(result.fileName ?? 'Unknown', normalizedEntries),
+      entries: normalizedEntries,
+    };
+
+    const snapshot = options.persist === false
+      ? { ...snapshotPayload, id: null, seenAt: new Date().toISOString(), entryCount: normalizedEntries.length }
+      : await this.store.recordCircaSnapshot(snapshotPayload);
+
+    this.status.lastCircaEntries = normalizedEntries.length;
+    this.status.lastCircaFileName = snapshot.fileName;
+    this.status.lastCircaFingerprintAt = snapshot.seenAt;
+    this.status.lastScanError = null;
+
+    return {
+      ...snapshot,
+      rawTextSample: result.text.slice(0, 1000),
+      text: result.text,
+      source: result.source,
+    };
+  }
+
+  async refreshCircaSnapshot() {
+    if (this.circaRunning) {
+      return this.store.getLatestCircaSnapshot();
+    }
+
+    this.circaRunning = true;
+    try {
+      return await this.fetchLatestCircaSnapshot({ persist: true });
+    } catch (error) {
+      this.status.lastScanError = error.message;
+      await this.sendCircaFailureAlert(error);
+      throw error;
+    } finally {
+      this.circaRunning = false;
+    }
+  }
+
+  async maybeRunCircaDailyBoard(now = new Date()) {
+    if (!this.config.circaWorkflowEnabled) {
+      return null;
+    }
+
+    const dateKey = getZonedDateKey(now, this.config.circaTimeZone);
+    const alreadyPosted = await this.store.getCircaDailyPost(dateKey);
+    if (alreadyPosted) {
+      this.status.circaRetryState = 'Posted for today';
+      return null;
+    }
+
+    if (!hasReachedZonedTime(now, this.config.circaTimeZone, this.config.circaDailyTime)) {
+      this.status.circaRetryState = `Waiting for ${this.config.circaDailyTime} ${this.config.circaTimeZone}`;
+      return null;
+    }
+
+    const snapshot = await this.refreshCircaSnapshot();
+    if (snapshot.fileDate !== dateKey) {
+      this.status.circaRetryState = `Waiting for new ${dateKey} Circa file`;
+      return null;
+    }
+
+    await this.postCircaDailyBoard(snapshot, dateKey);
+    this.status.circaRetryState = 'Posted for today';
+    return snapshot;
+  }
+
+  async postCircaDailyBoard(snapshot, dateKey = getZonedDateKey(new Date(), this.config.circaTimeZone)) {
+    if (this.circaBoardRunning) {
+      throw new Error('Circa board is already running');
+    }
+
+    this.circaBoardRunning = true;
+    try {
+      const channel = await this.client.channels.fetch(this.config.circaChannelId);
+      if (!channel?.isTextBased()) {
+        throw new Error(`Circa channel ${this.config.circaChannelId} is not text-based`);
+      }
+
+      const groupedMarkets = groupCircaMarkets(snapshot.entries);
+      for (const group of groupedMarkets) {
+        await channel.send({
+          embeds: [this.embeds.buildCircaMarketEmbed(snapshot, group.marketLabel, group.entries, {
+            footerText: `Daily Circa board for ${dateKey}`,
+          })],
+        });
+      }
+
+      await this.store.recordCircaDailyPost(dateKey, snapshot.id, this.config.circaChannelId);
+      this.status.lastCircaBoardAt = new Date().toISOString();
+      return groupedMarkets;
+    } finally {
+      this.circaBoardRunning = false;
+    }
+  }
+
+  async runCircaMovementScan() {
+    if (!this.config.circaWorkflowEnabled) {
+      throw new Error('Circa workflow is disabled.');
+    }
+
+    if (this.circaMovementRunning) {
+      return [];
+    }
+
+    this.circaMovementRunning = true;
+    try {
+      const currentSnapshot = await this.refreshCircaSnapshot();
+      const previousSnapshot = currentSnapshot?.id
+        ? await this.store.getPreviousCircaSnapshot(currentSnapshot.id)
+        : null;
+
+      this.status.lastCircaMovementScanAt = new Date().toISOString();
+      if (!previousSnapshot) {
+        return [];
+      }
+
+      const movements = buildCircaMovements(previousSnapshot, currentSnapshot);
+      if (movements.length === 0) {
+        return [];
+      }
+
+      const channel = await this.client.channels.fetch(this.config.circaChannelId);
+      if (!channel?.isTextBased()) {
+        throw new Error(`Circa channel ${this.config.circaChannelId} is not text-based`);
+      }
+
+      const posted = [];
+      for (const movement of movements) {
+        const canPost = await this.store.canSendCircaMovement(movement.movementKey, currentSnapshot.fingerprint);
+        if (!canPost) {
+          continue;
+        }
+
+        await channel.send({
+          embeds: [this.embeds.buildCircaMovementEmbed(movement, currentSnapshot)],
+        });
+        await this.store.recordCircaMovement(movement.movementKey, currentSnapshot.fingerprint);
+        posted.push(movement);
+      }
+
+      return posted;
+    } finally {
+      this.circaMovementRunning = false;
+    }
+  }
+
+  async getLatestCircaMarket(marketType) {
+    const snapshot = await this.store.getLatestCircaSnapshot();
+    if (!snapshot) {
+      throw new Error('No stored Circa snapshot is available yet.');
+    }
+
+    const normalizedMarketType = normalizeCircaMarketType(marketType);
+    const groupedMarkets = groupCircaMarkets(snapshot.entries);
+    const group = groupedMarkets.find((entry) => entry.marketType === normalizedMarketType);
+
+    if (!group) {
+      throw new Error(`No parsed Circa market was found for ${MARKET_TYPE_LABELS[normalizedMarketType] ?? normalizedMarketType}.`);
+    }
+
+    return {
+      snapshot,
+      marketType: normalizedMarketType,
+      marketLabel: group.marketLabel,
+      entries: group.entries,
+    };
+  }
+
   async collectMarketAnalysis(scanType) {
     if (this.running) {
       throw new Error('Market scanner is already running');
@@ -1635,7 +2042,7 @@ export class MarketScanner {
     try {
       const [oddsEntries, circaResult] = await Promise.all([
         fetchOddsApiEntries(this.config),
-        fetchCircaEntries(this.config),
+        this.fetchLatestCircaSnapshot({ persist: true }),
       ]);
       const allEntries = [...oddsEntries, ...circaResult.entries];
       const analysis = analyzeMarkets(allEntries, {
@@ -1649,6 +2056,7 @@ export class MarketScanner {
       this.status.lastApiEntries = oddsEntries.length;
       this.status.lastCircaEntries = circaResult.entries.length;
       this.status.lastCircaFileName = circaResult.fileName ?? null;
+      this.status.lastCircaFingerprintAt = circaResult.seenAt ?? new Date().toISOString();
 
       return analysis;
     } catch (error) {
@@ -1663,7 +2071,12 @@ export class MarketScanner {
   }
 
   async sendCircaFailureAlert(error) {
-    const channel = await this.client.channels.fetch(this.config.scanAlertChannelId).catch(() => null);
+    const fallbackChannelId = this.config.scanAlertChannelId ?? this.config.circaChannelId;
+    if (!fallbackChannelId) {
+      return;
+    }
+
+    const channel = await this.client.channels.fetch(fallbackChannelId).catch(() => null);
     if (!channel?.isTextBased()) {
       return;
     }