fixes

src/components/Apps/AppViewer.tsx

@@ -165,6 +165,8 @@ export const AppViewer = forwardRef<HTMLIFrameElement, AppViewerProps>(
         const publishLocation = e.detail?.publishLocation;
         const chunksSubmitted = e.detail?.chunksSubmitted;
         const totalChunks = e.detail?.totalChunks;
+        const retry = e.detail?.retry;
+        const filename = e.detail?.filename;
         try {
           if (publishLocation === undefined || publishLocation === null) return;
           const dataToBeSent = {};
@@ -174,6 +176,12 @@ export const AppViewer = forwardRef<HTMLIFrameElement, AppViewerProps>(
           if (totalChunks !== undefined && totalChunks !== null) {
             dataToBeSent.totalChunks = totalChunks;
           }
+          if (retry !== undefined && retry !== null) {
+            dataToBeSent.retry = retry;
+          }
+          if (filename !== undefined && filename !== null) {
+            dataToBeSent.filename = filename;
+          }
           const targetOrigin = new URL(iframe.src).origin;
           iframe.contentWindow?.postMessage(
             {

src/components/Chat/ChatGroup.tsx

@@ -903,7 +903,7 @@ export const ChatGroup = ({
             240000,
             true
           );
-          if (res !== true)
+          if (res?.error)
             throw new Error(
               t('core:message.error.publish_image', {
                 postProcess: 'capitalizeFirstChar',

src/qdn/publish/publish.ts

@@ -26,6 +26,10 @@ async function reusablePost(endpoint, _body) {
     },
     body: _body,
   });
+  if (!response.ok) {
+    const errorText = await response.text();
+    throw new Error(errorText);
+  }
   let data;
   try {
     data = await response.clone().json();
@@ -68,7 +72,46 @@ async function uploadChunkWithRetry(endpoint, formData, index, maxRetries = 3) {
         throw new Error(`Chunk ${index} failed after ${maxRetries} attempts`);
       }
       // Wait 10 seconds before next retry
-      await new Promise((res) => setTimeout(res, 10_000));
+      await new Promise((res) => setTimeout(res, 25_000));
+    }
+  }
+}
+
+async function resuablePostRetry(
+  endpoint,
+  body,
+  maxRetries = 3,
+  appInfo,
+  resourceInfo
+) {
+  let attempt = 0;
+  while (attempt < maxRetries) {
+    try {
+      const response = await reusablePost(endpoint, body);
+
+      return response;
+    } catch (err) {
+      attempt++;
+      if (attempt >= maxRetries) {
+        throw new Error(
+          err instanceof Error
+            ? err?.message || `Failed to make request`
+            : `Failed to make request`
+        );
+      }
+      if (appInfo?.tabId && resourceInfo) {
+        executeEvent('receiveChunks', {
+          tabId: appInfo.tabId,
+          publishLocation: {
+            name: resourceInfo?.name,
+            identifier: resourceInfo?.identifier,
+            service: resourceInfo?.service,
+          },
+          retry: true,
+        });
+      }
+      // Wait 10 seconds before next retry
+      await new Promise((res) => setTimeout(res, 25_000));
     }
   }
 }
@@ -106,7 +149,13 @@ export const publishData = async ({
   };
 
   const convertBytesForSigning = async (transactionBytesBase58: string) => {
-    return await reusablePost('/transactions/convert', transactionBytesBase58);
+    return await resuablePostRetry(
+      '/transactions/convert',
+      transactionBytesBase58,
+      3,
+      appInfo,
+      { identifier, name: registeredName, service }
+    );
   };
 
   const getArbitraryFee = async () => {
@@ -163,9 +212,12 @@ export const publishData = async ({
   };
 
   const processTransactionVersion2 = async (bytes) => {
-    return await reusablePost(
+    return await resuablePostRetry(
       '/transactions/process?apiVersion=2',
-      Base58.encode(bytes)
+      Base58.encode(bytes),
+      3,
+      appInfo,
+      { identifier, name: registeredName, service }
     );
   };
 
@@ -226,7 +278,6 @@ export const publishData = async ({
     }
 
     let transactionBytes = await uploadData(registeredName, data, fee);
-
     if (!transactionBytes || transactionBytes.error) {
       throw new Error(transactionBytes?.message || 'Error when uploading');
     } else if (transactionBytes.includes('Error 500 Internal Server Error')) {
@@ -336,9 +387,14 @@ export const publishData = async ({
           chunksSubmitted: 1,
           totalChunks: 1,
           processed: false,
+          filename: filename || title || `${service}-${identifier || ''}`,
         });
       }
-      return await reusablePost(uploadDataUrl, postBody);
+      return await resuablePostRetry(uploadDataUrl, postBody, 3, appInfo, {
+        identifier,
+        name: registeredName,
+        service,
+      });
     }
 
     const file = data;
@@ -365,6 +421,8 @@ export const publishData = async ({
         chunksSubmitted: 0,
         totalChunks,
         processed: false,
+        filename:
+          file?.name || filename || title || `${service}-${identifier || ''}`,
       });
     }
     for (let index = 0; index < totalChunks; index++) {
@@ -399,7 +457,7 @@ export const publishData = async ({
       headers: {},
     });
 
-    if (!response.ok) {
+    if (!response?.ok) {
       const errorText = await response.text();
       throw new Error(`Finalize failed: ${errorText}`);
     }

src/qortal/get.ts

@@ -1600,6 +1600,23 @@ export const publishMultipleQDNResources = async (
     );
   }
 
+  const totalFileSize = resources.reduce((acc, resource) => {
+    const file = resource?.file;
+    if (file && file?.size && !isNaN(file?.size)) {
+      return acc + file.size;
+    }
+    return acc;
+  }, 0);
+  if (totalFileSize > 0) {
+    const urlCheck = `/arbitrary/check/tmp?totalSize=${totalFileSize}`;
+
+    const checkEndpoint = await createEndpoint(urlCheck);
+    const checkRes = await fetch(checkEndpoint);
+    if (!checkRes.ok) {
+      throw new Error('Not enough space on your hard drive');
+    }
+  }
+
   const encrypt = data?.encrypt;
 
   for (const resource of resources) {
@@ -1746,7 +1763,7 @@ export const publishMultipleQDNResources = async (
   };
 
   const failedPublishesIdentifiers: FailedPublish[] = [];
-
+  const publishedResponses = [];
   for (const resource of resources) {
     try {
       const requiredFields = ['service'];
@@ -1861,31 +1878,29 @@ export const publishMultipleQDNResources = async (
           resource?.base64 || resource?.data64 || resourceEncrypt
             ? 'base64'
             : 'file';
-        await retryTransaction(
+
-          publishData,
+        const response = await publishData({
-          [
+          apiVersion: 2,
-            {
+          category,
-              apiVersion: 2,
+          data: rawData,
-              category,
+          description,
-              data: rawData,
+          filename: filename,
-              description,
+          identifier: encodeURIComponent(identifier),
-              filename: filename,
+          registeredName: encodeURIComponent(resource?.name || name),
-              identifier: encodeURIComponent(identifier),
+          service: service,
-              registeredName: encodeURIComponent(resource?.name || name),
+          tag1,
-              service: service,
+          tag2,
-              tag1,
+          tag3,
-              tag2,
+          tag4,
-              tag3,
+          tag5,
-              tag4,
+          title,
-              tag5,
+          uploadType: dataType,
-              title,
+          withFee: true,
-              uploadType: dataType,
+          appInfo,
-              withFee: true,
+        });
-              appInfo,
+        if (response?.signature) {
-            },
+          publishedResponses.push(response);
-          ],
+        }
-          true
-        );
         await new Promise((res) => {
           setTimeout(() => {
             res();
@@ -1937,7 +1952,7 @@ export const publishMultipleQDNResources = async (
       true
     );
   }
-  return true;
+  return publishedResponses;
 };
 
 export const voteOnPoll = async (data, isFromExtension) => {