2.7.4 (#73)

* improvement: add retry mechanism with exponential backoff to improve reliability for Google Cloud Storage API PUT errors

* 2.7.4-alpha.1

* 2.7.4

Author: BrkYld

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@appcircle/cli",
-  "version": "2.7.3",
+  "version": "2.7.4",
   "description": "CLI tool for running Appcircle services from the command line",
   "main": "bin/appcircle.js",
   "bin": {

package.json

@@ -317,6 +317,40 @@ export async function uploadArtifact(options: OptionsType<{ message: string; app
   return uploadResponse.data;
 }
 
+async function putUploadWithRetry(url: string, file: fs.ReadStream, headers: any, maxRetries = 5) {
+  let attempt = 0;
+  let delay = 1000;
+
+  while (true) {
+    try {
+      return await axios.put(url, file, {
+        maxContentLength: Infinity,
+        maxBodyLength: Infinity,
+        headers,
+        transformRequest: [(d) => d],
+        responseType: 'arraybuffer',
+      });
+    } catch (error: any) {
+      const status = error?.response?.status;
+      const retryable =
+        status === 503 ||
+        error?.code === 'ECONNRESET' ||
+        error?.message?.includes('socket hang up');
+
+      if (!retryable || attempt >= maxRetries) {
+        throw error;
+      }
+      attempt++;
+      const jitter = Math.floor(Math.random() * 300);
+
+      await new Promise((resolve) => setTimeout(resolve, delay + jitter)); // SLEEP
+
+      delay *= 2;
+    }
+  }
+
+}
+
 export async function uploadArtifactWithSignedUrl(
   options: OptionsType<{ app: string; uploadInfo: FileUploadInformation }>
 ) {
@@ -338,15 +372,9 @@ export async function uploadArtifactWithSignedUrl(
 
   if (!configuration || !configuration.httpMethod || configuration.httpMethod === 'PUT') {
     const file = fs.createReadStream(app);
-    return axios.put(uploadUrl, file, {
-      maxContentLength: Infinity,
-      maxBodyLength: Infinity,
-      headers: {
+    return putUploadWithRetry(uploadUrl,file, {
         'Content-Length': stats.size,
-        'Content-Type': 'application/octet-stream',
-      },
-      transformRequest: [(d) => d],
-      responseType: 'arraybuffer',
+        'Content-Type': 'application/octet-stream',  
     });
   }