openpondai/agents/dca-agent
dca-agent
typescript
import type { DcaAgentConfig } from "../config";
const DEFAULT_DCA_SCHEDULE_SECONDS = 7 * 24 * 60 * 60;
function resolveCronFields(cron: string | undefined) {
if (!cron) return null;
const fields = cron.trim().split(/\s+/).filter(Boolean);
if (fields.length === 5) return fields;
if (fields.length === 6) return fields.slice(1);
return null;
}
export function resolveDcaScheduleSeconds(config: DcaAgentConfig): number {
const cronFields = resolveCronFields(config.schedule?.cron);
if (!cronFields) {
return DEFAULT_DCA_SCHEDULE_SECONDS;
}
const [minute, hour, dayOfMonth, month, dayOfWeek] = cronFields;
if (
minute &&
hour &&
dayOfMonth &&
month &&
dayOfWeek &&
/^\*\/(\d+)$/.test(minute) &&
hour === "*" &&
dayOfMonth === "*" &&
month === "*" &&
dayOfWeek === "*"
) {
const intervalMinutes = Number.parseInt(minute.slice(2), 10);
if (Number.isFinite(intervalMinutes) && intervalMinutes > 0) {
return intervalMinutes * 60;
}
}
if (
minute &&
hour &&
dayOfMonth &&
month &&
dayOfWeek &&
/^\d+$/.test(minute) &&
hour === "*" &&
dayOfMonth === "*" &&
month === "*" &&
dayOfWeek === "*"
) {
return 60 * 60;
}
if (
minute &&
hour &&
dayOfMonth &&
month &&
dayOfWeek &&
/^\d+$/.test(minute) &&
/^\*\/(\d+)$/.test(hour) &&
dayOfMonth === "*" &&
month === "*" &&
dayOfWeek === "*"
) {
const intervalHours = Number.parseInt(hour.slice(2), 10);
if (Number.isFinite(intervalHours) && intervalHours > 0) {
return intervalHours * 60 * 60;
}
}
if (
minute &&
hour &&
dayOfMonth &&
month &&
dayOfWeek &&
/^\d+$/.test(minute) &&
/^\d+$/.test(hour) &&
dayOfMonth === "*" &&
month === "*" &&
dayOfWeek === "*"
) {
return 24 * 60 * 60;
}
if (
minute &&
hour &&
dayOfMonth &&
month &&
dayOfWeek &&
/^\d+$/.test(minute) &&
/^\d+$/.test(hour) &&
dayOfMonth === "*" &&
month === "*" &&
dayOfWeek !== "*"
) {
const weeklyRuns = dayOfWeek
.split(",")
.map((value) => value.trim())
.filter((value) => value.length > 0).length;
return weeklyRuns > 1
? Math.round(DEFAULT_DCA_SCHEDULE_SECONDS / weeklyRuns)
: DEFAULT_DCA_SCHEDULE_SECONDS;
}
if (
minute &&
hour &&
dayOfMonth &&
month &&
dayOfWeek &&
/^\d+$/.test(minute) &&
/^\d+$/.test(hour) &&
dayOfMonth !== "*" &&
month === "*" &&
dayOfWeek === "*"
) {
return 30 * 24 * 60 * 60;
}
return DEFAULT_DCA_SCHEDULE_SECONDS;
}