Function runResolutionSync

src/lib/resolutionSync.ts:66–135

()

// ── Main sync function ──

export async function runResolutionSync(): Promise<{ monitors: number; alerts: number }> {
  const db = getDb();
  let totalAlerts = 0;

  // 1. Build/refresh monitor list from all active events with resolution_source
  const events = db.prepare(`
    SELECT id, title, resolution_source, end_date, tags_json, markets_json
    FROM events
    WHERE is_active = 1 AND is_closed = 0 AND resolution_source IS NOT NULL
  `).all() as EventRow[];

  const upsertMonitor = db.prepare(`
    INSERT INTO resolution_monitors (event_id, source_type, feed_url, org_name, monitor_config)
    VALUES (?, ?, ?, ?, ?)
    ON CONFLICT(event_id) DO UPDATE SET
      source_type = excluded.source_type,
      feed_url = excluded.feed_url,
      org_name = excluded.org_name,
      monitor_config = excluded.monitor_config
  `);

  const upsertTx = db.transaction(() => {
    for (const event of events) {
      const target = parseResolutionSource(event.resolution_source);
      switch (target.type) {
        case "known_feed":
          upsertMonitor.run(event.id, target.type, target.feedUrl, target.orgName, null);
          break;
        case "price_feed": {
          const config = JSON.stringify({ provider: target.provider, symbol: target.symbol });
          upsertMonitor.run(event.id, target.type, target.url, target.provider, config);
          break;
        }
        case "sports_feed":
          upsertMonitor.run(event.id, target.type, target.feedUrl, target.source, null);
          break;
        default:
          upsertMonitor.run(event.id, "unmonitorable", null, null, null);
      }
    }
  });
  upsertTx();

  // 2. Get all monitorable types
  const allMonitors = db.prepare(`
    SELECT rm.*, e.title, e.end_date, e.tags_json, e.markets_json
    FROM resolution_monitors rm
    JOIN events e ON e.id = rm.event_id
    WHERE rm.source_type IN ('known_feed', 'price_feed', 'sports_feed')
      AND e.is_active = 1 AND e.is_closed = 0
  `).all() as EnrichedMonitor[];

  const feedMonitors = allMonitors.filter((m) => m.source_type === "known_feed" || m.source_type === "sports_feed");
  const priceMonitors = allMonitors.filter((m) => m.source_type === "price_feed");

  // 3a. RSS-based monitoring (known_feed + sports_feed)
  totalAlerts += await runRssMonitoring(feedMonitors);