Add always visible logs on core connection errors

Author: timokoessler

library/agent/Agent.test.ts

@@ -668,8 +668,6 @@ t.test("it logs when failed to report event", async () => {
     "Found token, reporting enabled!",
     "Failed to start agent",
     "Heartbeat...",
-    "Failed to do heartbeat",
-    "Failed to report attack",
   ]);
 });
 

library/agent/Agent.ts

@@ -1,4 +1,4 @@
-/* eslint-disable max-lines-per-function */
+/* eslint-disable max-lines-per-function, no-console */
 import { hostname, platform, release } from "os";
 import { convertRequestBodyToString } from "../helpers/convertRequestBodyToString";
 import { getAgentVersion } from "../helpers/getAgentVersion";
@@ -113,6 +113,18 @@ export class Agent {
         this.timeoutInMS
       );
 
+      if (!result.success) {
+        if (result.error === "invalid_token") {
+          console.error(
+            "Aikido: Unable to access the Aikido platform, please check your token."
+          );
+        } else {
+          console.error(
+            `Aikido: Failed to connect to the Aikido platform: ${result.error}`
+          );
+        }
+      }
+
       this.updateServiceConfig(result);
 
       await this.updateBlockedLists();
@@ -193,8 +205,10 @@ export class Agent {
     this.attackLogger.log(attack);
 
     if (this.token) {
-      this.api.report(this.token, attack, this.timeoutInMS).catch(() => {
-        this.logger.log("Failed to report attack");
+      this.api.report(this.token, attack, this.timeoutInMS).catch((err) => {
+        console.error(
+          `Aikido: Failed to report attack event to Aikido platform: ${err.message}`
+        );
       });
     }
   }
@@ -203,8 +217,10 @@ export class Agent {
    * Sends a heartbeat via the API to the server (only when not in serverless mode)
    */
   private heartbeat(timeoutInMS = this.timeoutInMS) {
-    this.sendHeartbeat(timeoutInMS).catch(() => {
-      this.logger.log("Failed to do heartbeat");
+    this.sendHeartbeat(timeoutInMS).catch((err) => {
+      console.error(
+        `Aikido: Failed to send heartbeat event to Aikido platform: ${err.message}`
+      );
     });
   }
 
@@ -291,6 +307,12 @@ export class Agent {
         timeoutInMS
       );
 
+      if (!response.success && response.error === "invalid_token") {
+        console.error(
+          "Aikido: Unable to access the Aikido platform, please check your token."
+        );
+      }
+
       this.updateServiceConfig(response);
     }
   }
@@ -354,7 +376,7 @@ export class Agent {
       this.serviceConfig.updateBlockedIPAddresses(blockedIPAddresses);
       this.serviceConfig.updateBlockedUserAgents(blockedUserAgents);
     } catch (error: any) {
-      this.logger.log(`Failed to update blocked lists: ${error.message}`);
+      console.error(`Aikido: Failed to update blocked lists: ${error.message}`);
     }
   }
 
@@ -432,7 +454,6 @@ export class Agent {
       this.logger.log("No token provided, disabling reporting.");
 
       if (!this.block && !isAikidoCI()) {
-        // eslint-disable-next-line no-console
         console.log(
           "AIKIDO: Running in monitoring only mode without reporting to Aikido Cloud. Set AIKIDO_BLOCK=true to enable blocking."
         );

library/agent/api/fetchBlockedLists.ts

@@ -25,6 +25,11 @@ export async function fetchBlockedLists(token: Token): Promise<{
   });
 
   if (statusCode !== 200) {
+    if (statusCode === 401) {
+      throw new Error(
+        `Unable to access the Aikido platform, please check your token.`
+      );
+    }
     throw new Error(`Failed to fetch blocked lists: ${statusCode}`);
   }