feat: support AggregateError

src/actions.ts

@@ -6,6 +6,7 @@ import { LogReturn, Logs } from "@ubiquity-os/ubiquity-os-logger";
 import { config } from "dotenv";
 import { CommentHandler } from "./comment";
 import { Context } from "./context";
+import { transformError } from "./error";
 import { customOctokit } from "./octokit";
 import { verifySignature } from "./signature";
 import { inputSchema } from "./types/input-schema";
@@ -96,16 +97,12 @@ export async function createActionsPlugin<TConfig = unknown, TEnv = unknown, TCo
   } catch (error) {
     console.error(error);
 
-    let loggerError: LogReturn | null;
-    if (error instanceof Error) {
-      core.setFailed(error);
-      loggerError = context.logger.error(`Error: ${error}`, { error: error });
-    } else if (error instanceof LogReturn) {
-      core.setFailed(error.logMessage.raw);
-      loggerError = error;
-    } else {
-      core.setFailed(`Error: ${error}`);
-      loggerError = context.logger.error(`Error: ${error}`);
+    const loggerError = transformError(context, error);
+
+    if (loggerError instanceof LogReturn) {
+      core.setFailed(loggerError.logMessage.diff);
+    } else if (loggerError instanceof Error) {
+      core.setFailed(loggerError);
     }
 
     if (pluginOptions.postCommentOnError && loggerError) {

src/error.ts

@@ -0,0 +1,28 @@
+import { LogReturn } from "@ubiquity-os/ubiquity-os-logger";
+import { Context } from "./context";
+
+export function transformError(context: Context, error: unknown) {
+  let loggerError: LogReturn | Error;
+  if (error instanceof AggregateError) {
+    loggerError = context.logger.error(
+      error.errors
+        .map((err) => {
+          if (err instanceof LogReturn) {
+            return err.logMessage.raw;
+          } else if (err instanceof Error) {
+            return err.message;
+          } else {
+            return err;
+          }
+        })
+        .join("\n\n"),
+      { error }
+    );
+  } else if (error instanceof Error || error instanceof LogReturn) {
+    loggerError = error;
+  } else {
+    loggerError = context.logger.error(String(error));
+  }
+
+  return loggerError;
+}

src/server.ts

@@ -1,11 +1,12 @@
 import { EmitterWebhookEventName as WebhookEventName } from "@octokit/webhooks";
 import { Value } from "@sinclair/typebox/value";
-import { LogReturn, Logs } from "@ubiquity-os/ubiquity-os-logger";
+import { Logs } from "@ubiquity-os/ubiquity-os-logger";
 import { Hono } from "hono";
 import { env as honoEnv } from "hono/adapter";
 import { HTTPException } from "hono/http-exception";
 import { CommentHandler } from "./comment";
 import { Context } from "./context";
+import { transformError } from "./error";
 import { PluginRuntimeInfo } from "./helpers/runtime-info";
 import { customOctokit } from "./octokit";
 import { verifySignature } from "./signature";
@@ -101,12 +102,7 @@ export function createPlugin<TConfig = unknown, TEnv = unknown, TCommand = unkno
     } catch (error) {
       console.error(error);
 
-      let loggerError: LogReturn | Error | null;
-      if (error instanceof Error || error instanceof LogReturn) {
-        loggerError = error;
-      } else {
-        loggerError = context.logger.error(`Error: ${error}`);
-      }
+      const loggerError = transformError(context, error);
 
       if (pluginOptions.postCommentOnError && loggerError) {
         await context.commentHandler.postComment(context, loggerError);