Function useCreateWorkflow

apps/sim/hooks/queries/workflows.ts:162–303

()

}

export function useCreateWorkflow() {
  const queryClient = useQueryClient()

  return useMutation({
    mutationFn: async (variables: CreateWorkflowVariables): Promise<CreateWorkflowMutationData> => {
      const { workspaceId, name, description, folderId, sortOrder, id, deduplicate } = variables

      logger.info(`Creating new workflow in workspace: ${workspaceId}`)

      const createdWorkflow = await requestJson(createWorkflowContract, {
        body: {
          id,
          name: name || generateCreativeWorkflowName(),
          description: description || 'New workflow',
          workspaceId,
          folderId: folderId || null,
          sortOrder,
          deduplicate,
        },
      })
      const workflowId = createdWorkflow.id

      logger.info(`Successfully created workflow ${workflowId}`)

      return {
        id: workflowId,
        name: createdWorkflow.name,
        description: createdWorkflow.description,
        workspaceId,
        folderId: createdWorkflow.folderId,
        sortOrder: createdWorkflow.sortOrder ?? 0,
        subBlockValues: createdWorkflow.subBlockValues,
      }
    },
    onMutate: async (variables) => {
      await queryClient.cancelQueries({
        queryKey: workflowKeys.list(variables.workspaceId, 'active'),
      })

      const snapshot = queryClient.getQueryData<WorkflowMetadata[]>(
        workflowKeys.list(variables.workspaceId, 'active')
      )

      const tempId = variables.id ?? generateId()
      let sortOrder: number
      if (variables.sortOrder !== undefined) {
        sortOrder = variables.sortOrder
      } else {
        const currentWorkflows = Object.fromEntries(
          getWorkflows(variables.workspaceId).map((w) => [w.id, w])
        )
        sortOrder = getTopInsertionSortOrder(
          currentWorkflows,
          getFolderMap(variables.workspaceId),
          variables.workspaceId,
          variables.folderId
        )
      }