import { arktypeResolver } from "@hookform/resolvers/arktype"; import { useMutation } from "@tanstack/react-query"; import { type } from "arktype"; import { CheckCircle, Loader2, Plug, Save, XCircle } from "lucide-react"; import { useEffect, useState } from "react"; import { useForm } from "react-hook-form"; import { cn } from "~/client/lib/utils"; import { deepClean } from "~/utils/object"; import { Button } from "../../../components/ui/button"; import { Form, FormControl, FormDescription, FormField, FormItem, FormLabel, FormMessage, } from "../../../components/ui/form"; import { Input } from "../../../components/ui/input"; import { Select, SelectContent, SelectItem, SelectTrigger, SelectValue } from "../../../components/ui/select"; import { volumeConfigSchemaBase } from "~/schemas/volumes"; import { testConnectionMutation } from "../../../api-client/@tanstack/react-query.gen"; import { Tooltip, TooltipContent, TooltipTrigger } from "../../../components/ui/tooltip"; import { useSystemInfo } from "~/client/hooks/use-system-info"; import { DirectoryForm, NFSForm, SMBForm, WebDAVForm, RcloneForm, SFTPForm } from "./volume-forms"; export const formSchema = type({ name: "2<=string<=32", }).and(volumeConfigSchemaBase); const cleanSchema = type.pipe((d) => formSchema(deepClean(d))); export type FormValues = typeof formSchema.inferIn; type Props = { onSubmit: (values: FormValues) => void; mode?: "create" | "update"; initialValues?: Partial; formId?: string; loading?: boolean; className?: string; }; const defaultValuesForType = { directory: { backend: "directory" as const, path: "/" }, nfs: { backend: "nfs" as const, port: 2049, version: "4.1" as const }, smb: { backend: "smb" as const, port: 445, vers: "3.0" as const }, webdav: { backend: "webdav" as const, port: 80, ssl: false, path: "/webdav" }, rclone: { backend: "rclone" as const, path: "/" }, sftp: { backend: "sftp" as const, port: 22, path: "/", skipHostKeyCheck: false }, }; export const CreateVolumeForm = ({ onSubmit, mode = "create", initialValues, formId, loading, className }: Props) => { const form = useForm({ resolver: arktypeResolver(cleanSchema as unknown as typeof formSchema), defaultValues: initialValues || { name: "", backend: "directory", }, resetOptions: { keepDefaultValues: true, keepDirtyValues: false, }, }); const { watch, getValues } = form; const { capabilities } = useSystemInfo(); const watchedBackend = watch("backend"); useEffect(() => { if (mode === "create") { form.reset({ name: form.getValues().name, ...defaultValuesForType[watchedBackend as keyof typeof defaultValuesForType], }); } }, [watchedBackend, form, mode]); const [testMessage, setTestMessage] = useState<{ success: boolean; message: string } | null>(null); const testBackendConnection = useMutation({ ...testConnectionMutation(), onMutate: () => { setTestMessage(null); }, onError: (error) => { setTestMessage({ success: false, message: error?.message || "Failed to test connection. Please try again.", }); }, onSuccess: (data) => { setTestMessage(data); }, }); const handleTestConnection = async () => { const formValues = getValues(); if ( formValues.backend === "nfs" || formValues.backend === "smb" || formValues.backend === "webdav" || formValues.backend === "sftp" ) { testBackendConnection.mutate({ body: { config: formValues }, }); } }; return (
( Name Unique identifier for the volume. )} /> ( Backend Choose the storage backend for this volume. )} /> {watchedBackend === "directory" && } {watchedBackend === "nfs" && } {watchedBackend === "webdav" && } {watchedBackend === "smb" && } {watchedBackend === "rclone" && } {watchedBackend === "sftp" && } {watchedBackend && watchedBackend !== "directory" && watchedBackend !== "rclone" && (
{testMessage && (
{testMessage.message}
)}
)} {mode === "update" && ( )} ); };