Function performCreateJob

apps/sim/lib/workflows/schedules/orchestration.ts:129–263

(
  params: PerformCreateJobParams
)

}

export async function performCreateJob(
  params: PerformCreateJobParams
): Promise<PerformScheduleResult> {
  if (!params.prompt.trim()) {
    return { success: false, error: 'prompt is required', errorCode: 'validation' }
  }

  const cronExpression = params.cronExpression || null
  if (!cronExpression && !params.time) {
    return {
      success: false,
      error: 'At least one of cronExpression or time must be provided',
      errorCode: 'validation',
    }
  }

  let endsAt: Date | null = null
  if (params.endsAt) {
    const parsedEndsAt = new Date(params.endsAt)
    if (Number.isNaN(parsedEndsAt.getTime())) {
      return {
        success: false,
        error: `Invalid endsAt value: ${params.endsAt}`,
        errorCode: 'validation',
      }
    }
    endsAt = parsedEndsAt
  }

  let nextRunAt: Date | null = null
  if (cronExpression) {
    const validation = validateCronExpression(cronExpression, params.timezone)
    if (!validation.isValid) {
      return {
        success: false,
        error: validation.error || 'Invalid cron expression',
        errorCode: 'validation',
      }
    }
    nextRunAt = computeNextRunAt({ cronExpression, timezone: params.timezone, endsAt })
  }

  if (params.time) {
    const parsed = parseOneTimeRun(params.time, params.timezone)
    if (!parsed) {
      return {
        success: false,
        error: `Invalid time value: ${params.time}`,
        errorCode: 'validation',
      }
    }
    if (!cronExpression || parsed > new Date()) nextRunAt = parsed
  }

  if (params.startDate) {
    const start = new Date(params.startDate)
    if (start > new Date()) nextRunAt = start
  }