Function executeCreateJob

apps/sim/lib/copilot/tools/handlers/jobs.ts:65–142

(
  params: Record<string, unknown>,
  context: ExecutionContext
)

type ManageJobParams = z.infer<typeof ManageJobParamsSchema>

export async function executeCreateJob(
  params: Record<string, unknown>,
  context: ExecutionContext
): Promise<ToolCallResult> {
  const parsedParams = CreateJobParamsSchema.safeParse(params)
  if (!parsedParams.success) {
    return { success: false, error: 'Invalid create job parameters' }
  }

  const rawParams: CreateJobParams = parsedParams.data
  const timezone = rawParams.timezone || context.userTimezone || 'UTC'
  const { title, prompt, cron, time, lifecycle, successCondition, maxRuns } = rawParams

  if (!prompt) {
    return { success: false, error: 'prompt is required' }
  }

  if (!cron && !time) {
    return { success: false, error: 'At least one of cron or time must be provided' }
  }

  if (!context.userId || !context.workspaceId) {
    return { success: false, error: 'Missing user or workspace context' }
  }

  let taskName: string | null = null
  if (context.chatId) {
    try {
      const [chat] = await db
        .select({ title: copilotChats.title })
        .from(copilotChats)
        .where(eq(copilotChats.id, context.chatId))
        .limit(1)
      taskName = chat?.title || null
    } catch (err) {
      logger.warn('Failed to look up chat title for job', {
        chatId: context.chatId,
        error: toError(err).message,
      })
    }
  }

  try {
    const result = await performCreateJob({
      workspaceId: context.workspaceId,
      userId: context.userId,
      title,
      prompt,
      cronExpression: cron,
      time,
      timezone,
      lifecycle,
      successCondition,
      maxRuns,
      sourceChatId: context.chatId,
      sourceTaskName: taskName,
    })
    if (!result.success || !result.schedule) {