gavindiaz/polymarket-analyst_github
1
0
Fork 0
mirror of https://github.com/theodore-song/polymarket-analyst.git synced 2026-07-27 16:07:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Run arena cycles every minute

Browse Source
This commit is contained in:
Theodore Song
2026-07-15 22:39:06 -04:00
parent 5481afebd2
commit 25c9e3f1d5
3 changed files with 44 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api/state.js
+7 -7
View File
@@ -43,18 +43,18 @@ export default async function handler(req, res) {
const currentAgents = agentStateFromItems(current && current.items);
const incomingAgents = agentStateFromItems(body.items);
if (!body.force && currentAgents) {
const currentHour = currentAgents.last_cycle_hour || "";
const incomingHour = incomingAgents && incomingAgents.last_cycle_hour ? incomingAgents.last_cycle_hour : "";
if (currentHour && (!incomingAgents || !incomingHour)) {
const currentCycle = currentAgents.last_cycle_hour || "";
const incomingCycle = incomingAgents && incomingAgents.last_cycle_hour ? incomingAgents.last_cycle_hour : "";
if (currentCycle && (!incomingAgents || !incomingCycle)) {
return conflictResponse(res, "Cloud already has a cycle result; refusing unscheduled local state", current);
}
if (currentHour && incomingHour && incomingHour < currentHour) {
if (currentCycle && incomingCycle && incomingCycle < currentCycle) {
return conflictResponse(res, "Incoming state is older than the shared cloud result", current);
}
const sameHour = currentHour && currentHour === incomingHour;
const sameCycle = currentCycle && currentCycle === incomingCycle;
const differentRun = currentAgents.last_run && incomingAgents.last_run && currentAgents.last_run !== incomingAgents.last_run;
if (sameHour && differentRun) {
return conflictResponse(res, "This cycle hour already has a cloud result", current);
if (sameCycle && differentRun) {
return conflictResponse(res, "This cycle already has a cloud result", current);
}
}
const state = { version: 1, updated_at: new Date().toISOString(), items: body.items };