Function createOrUpdateSchedule

packages/server/src/services/schedule/index.ts:71–136

(input: CreateScheduleInput)

const SCHEDULE_BATCH_SIZE = 100

const createOrUpdateSchedule = async (input: CreateScheduleInput): Promise<ScheduleRecord> => {
    try {
        const appServer = getRunningExpressApp()
        const repo = appServer.AppDataSource.getRepository(ScheduleRecord)

        const validation = validateCronExpression(input.cronExpression, input.timezone ?? FALLBACK_TIMEZONE)
        const cronExpression = validation.valid ? input.cronExpression : FALLBACK_CRON_EXPRESSION
        const timezone = validation.valid ? input.timezone ?? FALLBACK_TIMEZONE : FALLBACK_TIMEZONE

        // Upsert: find existing record for this target + triggerType
        const existing = await repo.findOne({
            where: {
                targetId: input.targetId,
                triggerType: input.triggerType,
                workspaceId: input.workspaceId
            }
        })

        if (existing) {
            const updateSchedule = new ScheduleRecord()
            const bodySchedule: ICommonObject = {
                cronExpression,
                timezone
            }
            if (input.enabled !== undefined) bodySchedule.enabled = input.enabled
            if (input.scheduleInputMode !== undefined) bodySchedule.scheduleInputMode = input.scheduleInputMode
            if (input.defaultInput !== undefined) bodySchedule.defaultInput = input.defaultInput
            if (input.defaultForm !== undefined) bodySchedule.defaultForm = input.defaultForm
            if (input.nodeId !== undefined) bodySchedule.nodeId = input.nodeId
            bodySchedule.endDate = input.endDate ?? null
            bodySchedule.nextRunAt = computeNextRunAt(cronExpression, timezone) ?? null

            // NOTE: Use assign + merge to update `endDate` and `nextRunAt` even if they are null
            Object.assign(updateSchedule, bodySchedule)
            const merged = repo.merge(existing, updateSchedule)
            const saved = await repo.save(merged)
            logger.debug(`[ScheduleService]: Updated schedule ${saved.id} for ${input.triggerType}:${input.targetId}`)
            return saved
        }

        const record = repo.create({
            triggerType: input.triggerType,
            targetId: input.targetId,
            nodeId: input.nodeId,
            cronExpression: cronExpression,
            timezone: timezone,
            enabled: input.enabled !== undefined ? input.enabled : validation.valid, // default to enabled if valid, disabled if invalid
            scheduleInputMode: input.scheduleInputMode,
            defaultInput: input.defaultInput,
            defaultForm: input.defaultForm,
            endDate: input.endDate,
            nextRunAt: computeNextRunAt(cronExpression, timezone) ?? undefined,
            workspaceId: input.workspaceId
        })

        const saved = await repo.save(record)
        logger.debug(`[ScheduleService]: Created schedule ${saved.id} for ${input.triggerType}:${input.targetId}`)
        return saved