fix: Improve error messages for missing Blob token in BlobCheck, BlobCreate, BlobSync, and BlobUpdate functions

Author: BorDevTech

data/controls/blobs/blobCheck.ts

@@ -1,15 +1,16 @@
 import { VetResult } from "@/app/types/vet-result";
 import { list } from "@vercel/blob";
 
-export default async function BlobCheck(blobKey: string, data: VetResult[] = [], options?: { token?: string }) {
-    const token = options?.token ?? process.env.BLOB_READ_WRITE_TOKEN;
-    if (!token) throw new Error("Missing Blob token");
+export default async function BlobCheck(blobKey: string, data: VetResult[] = []) {
+    const token = process.env.BLOB_READ_WRITE_TOKEN;
+
     try {
-        const historicBlobs = await list({ token });
+        const historicBlobs = await list();
         return historicBlobs.blobs.some((blob) => blob.pathname === blobKey);
 
     } catch (error) {
         console.warn(`⚠️ Failed to list blobs for ${blobKey}:`, error);
+        if (!token) throw new Error("Missing Blob token, failed to Check");
         return false;
 
     }

data/controls/blobs/blobCreate.ts

@@ -2,7 +2,7 @@ import { put } from "@vercel/blob";
 
 export default async function BlobCreate(blobKey: string, options?: { token?: string }) {
     const token = options?.token ?? process.env.BLOB_READ_WRITE_TOKEN;
-    if (!token) throw new Error("Missing Blob token");
+    if (!token) throw new Error("Missing Blob token, failed to Create");
     await put(blobKey, JSON.stringify([], null, 2), {
         access: "public",
         contentType: "application/json",

data/controls/blobs/blobSync.ts

@@ -2,6 +2,7 @@ import { VetResult } from "@/app/types/vet-result";
 import BlobCheck from "./blobCheck";
 import BlobCreate from "./blobCreate";
 import BlobUpdate from "./blobUpdate";
+const token = process.env.BLOB_READ_WRITE_TOKEN;
 
 export default async function BlobSync(region: string, results: VetResult[]) {
     try {
@@ -16,21 +17,23 @@ export default async function BlobSync(region: string, results: VetResult[]) {
         };
 
 
-        const exists = await BlobCheck(blobKey);
+        const exists = await BlobCheck(blobKey, results);
         if (!exists) {
             console.log("⚠️ Blob not found, creating...");
             // ☁️ Upload to Vercel Blob
-            await BlobCreate(blobKey);
-        }
-        else if (results.length > 0) {
+            await BlobCreate(blobKey, { token });
+        } else if (exists && results.length > 0) {
             console.log("✅ Blob already exists")
             console.log("⚠️ Updating existing blob with new results...");
 
-            const blob = await BlobUpdate(blobKey, payload);
+            const blob = await BlobUpdate(blobKey, payload, { token });
 
             console.log(`🚀 Uploaded to Blob: ${blob.url}`);
             console.log(`📥 Download URL: ${blob.downloadUrl}`);
         }
+        else if (exists && results.length === 0) {
+            console.log("ℹ️ Blob exists, but no new results to update.");
+        }
         console.log("🔍 BlobCheck result:", exists);
 
 

data/controls/blobs/blobUpdate.ts

@@ -12,7 +12,7 @@ export default async function BlobUpdate(blobKey: string, payload: Payload = {
     results: []
 }, options?: { token?: string }) {
     const token = options?.token ?? process.env.BLOB_READ_WRITE_TOKEN;
-    if (!token) throw new Error("Missing Blob token");
+    if (!token) throw new Error("Missing Blob token, failed to Update");
     const blob = await put(blobKey, JSON.stringify(payload, null, 2), {
         access: "public",
         contentType: "application/json",