Merge pull request #30 from code0-tech/feat/#29

Retry connection to aquila on failure

Author: nicosammito

actions/gls-action/src/index.ts

@@ -176,15 +176,14 @@ action.on(CodeZeroEvent.error, (error: Error) => {
     console.error("Stream error:", error.message);
     console.log("Attempting to reconnect in 5s...");
     setTimeout(() => {
-        action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: unknown) => {
-            console.error("Reconnect failed:", err);
-        });
+        action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: Error) => {
+            action.emit(CodeZeroEvent.error, err);
+        })
     }, 5000);
 });
 
-action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: unknown) => {
-    console.error("Failed to connect:", err);
-    process.exit(1);
+action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: Error) => {
+    action.emit(CodeZeroEvent.error, err);
 });
 
 action.on(CodeZeroEvent.moduleUpdated, (message: any) => {

actions/shopify-action/src/index.ts

@@ -52,15 +52,14 @@ action.on(CodeZeroEvent.error, (error: Error) => {
     console.error("Stream error:", error.message);
     console.log("Attempting to reconnect in 5s...");
     setTimeout(() => {
-        action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: unknown) => {
-            console.error("Reconnect failed:", err);
-        });
+        action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: Error) => {
+            action.emit(CodeZeroEvent.error, err);
+        })
     }, 5000);
 });
 
-action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: unknown) => {
-    console.error("Failed to connect:", err);
-    process.exit(1);
+action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: Error) => {
+    action.emit(CodeZeroEvent.error, err);
 });
 
 action.on(CodeZeroEvent.moduleUpdated, (message: any) => {

actions/shopware-action/src/index.ts

@@ -32,15 +32,14 @@ action.on(CodeZeroEvent.error, (error: Error) => {
     console.error("Stream error:", error.message);
     console.log("Attempting to reconnect in 5s...");
     setTimeout(() => {
-        action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: unknown) => {
-            console.error("Reconnect failed:", err);
-        });
+        action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: Error) => {
+            action.emit(CodeZeroEvent.error, err);
+        })
     }, 5000);
 });
 
-action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: unknown) => {
-    console.error("Failed to connect:", err);
-    process.exit(1);
+action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: Error) => {
+    action.emit(CodeZeroEvent.error, err);
 });
 
 action.on(CodeZeroEvent.moduleUpdated, (message: any) => {

actions/woocommerce-action/src/index.ts

@@ -28,15 +28,14 @@ action.on(CodeZeroEvent.error, (error: Error) => {
     console.error("Stream error:", error.message);
     console.log("Attempting to reconnect in 5s...");
     setTimeout(() => {
-        action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: unknown) => {
-            console.error("Reconnect failed:", err);
-        });
+        action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: Error) => {
+            action.emit(CodeZeroEvent.error, err);
+        })
     }, 5000);
 });
 
-action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: unknown) => {
-    console.error("Failed to connect:", err);
-    process.exit(1);
+action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: Error) => {
+    action.emit(CodeZeroEvent.error, err);
 });
 
 action.on(CodeZeroEvent.moduleUpdated, (message: any) => {