import { z } from "zod"; import { zodResolver } from "@hookform/resolvers/zod"; import { useForm } from "react-hook-form"; import { Button } from "@/components/ui/button"; import { Form, FormControl, FormField, FormItem, FormLabel, FormMessage, } from "@/components/ui/form"; import { Input } from "@/components/ui/input"; import { dataExtractionGoalDescription, extractedInformationSchemaDescription, navigationGoalDescription, navigationPayloadDescription, urlDescription, webhookCallbackUrlDescription, } from "../data/descriptionHelperContent"; import { Textarea } from "@/components/ui/textarea"; import { useMutation, useQueryClient } from "@tanstack/react-query"; import { getClient } from "@/api/AxiosClient"; import { useToast } from "@/components/ui/use-toast"; import { InfoCircledIcon, ReloadIcon } from "@radix-ui/react-icons"; import { Tooltip, TooltipContent, TooltipProvider, TooltipTrigger, } from "@/components/ui/tooltip"; import { ToastAction } from "@radix-ui/react-toast"; import { Link } from "react-router-dom"; import fetchToCurl from "fetch-to-curl"; import { apiBaseUrl } from "@/util/env"; import { useCredentialGetter } from "@/hooks/useCredentialGetter"; import { useApiCredential } from "@/hooks/useApiCredential"; const createNewTaskFormSchema = z .object({ url: z.string().url({ message: "Invalid URL", }), webhookCallbackUrl: z.string().or(z.null()).optional(), // url maybe, but shouldn't be validated as one navigationGoal: z.string().or(z.null()).optional(), dataExtractionGoal: z.string().or(z.null()).optional(), navigationPayload: z.string().or(z.null()).optional(), extractedInformationSchema: z.string().or(z.null()).optional(), }) .superRefine(({ navigationGoal, dataExtractionGoal }, ctx) => { if (!navigationGoal && !dataExtractionGoal) { ctx.addIssue({ code: z.ZodIssueCode.custom, message: "At least one of navigation goal or data extraction goal must be provided", path: ["navigationGoal"], }); ctx.addIssue({ code: z.ZodIssueCode.custom, message: "At least one of navigation goal or data extraction goal must be provided", path: ["dataExtractionGoal"], }); return z.NEVER; } }); export type CreateNewTaskFormValues = z.infer; type Props = { initialValues: CreateNewTaskFormValues; }; function transform(value: unknown) { return value === "" ? null : value; } function createTaskRequestObject(formValues: CreateNewTaskFormValues) { return { url: formValues.url, webhook_callback_url: transform(formValues.webhookCallbackUrl), navigation_goal: transform(formValues.navigationGoal), data_extraction_goal: transform(formValues.dataExtractionGoal), proxy_location: "NONE", error_code_mapping: null, navigation_payload: transform(formValues.navigationPayload), extracted_information_schema: transform( formValues.extractedInformationSchema, ), }; } function CreateNewTaskForm({ initialValues }: Props) { const queryClient = useQueryClient(); const { toast } = useToast(); const credentialGetter = useCredentialGetter(); const apiCredential = useApiCredential(); const form = useForm({ resolver: zodResolver(createNewTaskFormSchema), defaultValues: initialValues, }); const mutation = useMutation({ mutationFn: async (formValues: CreateNewTaskFormValues) => { const taskRequest = createTaskRequestObject(formValues); const client = await getClient(credentialGetter); return client.post< ReturnType, { data: { task_id: string } } >("/tasks", taskRequest); }, onError: (error) => { toast({ variant: "destructive", title: "There was an error creating the task.", description: error.message, }); }, onSuccess: (response) => { toast({ title: "Task Created", description: `${response.data.task_id} created successfully.`, action: ( ), }); queryClient.invalidateQueries({ queryKey: ["tasks"], }); }, }); function onSubmit(values: CreateNewTaskFormValues) { mutation.mutate(values); } return (
(
URL *

{urlDescription}

)} /> (
Webhook Callback URL

{webhookCallbackUrlDescription}

)} /> (
Navigation Goal

{navigationGoalDescription}