diff --git a/worker.js b/worker.js index ffe6995..e405f4e 100644 --- a/worker.js +++ b/worker.js @@ -33,6 +33,7 @@ async function main() { let latestMarketState = null; + // Handles markets that rotated BEFORE Kalshi posted the final result async function processOrphans() { if (paper._resetting) return; try { @@ -53,10 +54,8 @@ async function main() { } } - // Settle delayed positions before continuing + // Check orphans immediately on startup, then every 60 seconds await processOrphans(); - - // Continuously check open positions every 60s for delayed results setInterval(processOrphans, 60000); const tracker = new MarketTracker(); @@ -91,7 +90,6 @@ async function main() { if (paper._resetting) return; - // Only attempt to settle and notify if the result is already available if (result) { const settledPositions = await paper.settle(ticker, result); if (settledPositions) {