refactor: Extract useUpload into its own reusable hook

apps/web/components/dashboard/UploadDropzone.tsx

@@ -1,6 +1,7 @@
 "use client";
 
 import React, { useCallback, useState } from "react";
+import useUpload from "@/lib/hooks/upload-file";
 import { parseNetscapeBookmarkFile } from "@/lib/netscapeBookmarkParser";
 import { cn } from "@/lib/utils";
 import { useMutation } from "@tanstack/react-query";
@@ -9,10 +10,6 @@ import DropZone from "react-dropzone";
 
 import { useCreateBookmarkWithPostHook } from "@hoarder/shared-react/hooks/bookmarks";
 import { BookmarkTypes } from "@hoarder/shared/types/bookmarks";
-import {
-  zUploadErrorSchema,
-  zUploadResponseSchema,
-} from "@hoarder/shared/types/uploads";
 
 import LoadingSpinner from "../ui/spinner";
 import { toast } from "../ui/use-toast";
@@ -35,26 +32,13 @@ export function useUploadAsset() {
     },
   });
 
-  const { mutateAsync: runUploadAsset } = useMutation({
-    mutationFn: async (file: File) => {
-      const formData = new FormData();
-      formData.append("file", file);
-      const resp = await fetch("/api/assets", {
-        method: "POST",
-        body: formData,
-      });
-      if (!resp.ok) {
-        throw new Error(await resp.text());
-      }
-      return zUploadResponseSchema.parse(await resp.json());
-    },
+  const { mutateAsync: runUploadAsset } = useUpload({
     onSuccess: async (resp) => {
       const assetType =
         resp.contentType === "application/pdf" ? "pdf" : "image";
-      return createBookmark({ ...resp, type: BookmarkTypes.ASSET, assetType });
+      await createBookmark({ ...resp, type: BookmarkTypes.ASSET, assetType });
     },
-    onError: (error, req) => {
-      const err = zUploadErrorSchema.parse(JSON.parse(error.message));
+    onError: (err, req) => {
       toast({
         description: `${req.name}: ${err.error}`,
         variant: "destructive",

apps/web/lib/hooks/upload-file.ts

@@ -0,0 +1,38 @@
+import { useMutation } from "@tanstack/react-query";
+
+import {
+  ZUploadError,
+  zUploadErrorSchema,
+  ZUploadResponse,
+  zUploadResponseSchema,
+} from "@hoarder/shared/types/uploads";
+
+export default function useUpload({
+  onSuccess,
+  onError,
+}: {
+  onError?: (e: ZUploadError, req: File) => void;
+  onSuccess?: (resp: ZUploadResponse, req: File) => Promise<void>;
+}) {
+  return useMutation({
+    mutationFn: async (file: File) => {
+      const formData = new FormData();
+      formData.append("file", file);
+      const resp = await fetch("/api/assets", {
+        method: "POST",
+        body: formData,
+      });
+      if (!resp.ok) {
+        throw new Error(await resp.text());
+      }
+      return zUploadResponseSchema.parse(await resp.json());
+    },
+    onSuccess: onSuccess,
+    onError: (error, req) => {
+      const err = zUploadErrorSchema.parse(JSON.parse(error.message));
+      if (onError) {
+        onError(err, req);
+      }
+    },
+  });
+}

packages/shared/types/uploads.ts

@@ -4,6 +4,8 @@ export const zUploadErrorSchema = z.object({
   error: z.string(),
 });
 
+export type ZUploadError = z.infer<typeof zUploadErrorSchema>;
+
 export const zUploadResponseSchema = z.object({
   assetId: z.string(),
   contentType: z.string(),