feat(engine): enhance error handling and hook context in action execution

- Add error information to inputs for fail and complete hooks to improve error tracking.
- Include hook context details in action inputs to provide better context during plugin execution.
- Update the handling of outputs and statuses in the engine to ensure comprehensive error reporting.

Signed-off-by: zxypro1 <[email protected]>

Author: zxypro1

packages/engine/src/actions/index.ts

@@ -246,8 +246,20 @@ You can still use them now, but we suggest to modify them.`)
       const instance = await loadComponent(hook.value, { logger: this.logger });
       // Determine the inputs for the plugin based on the record's pluginOutput.
       const inputs = isEmpty(this.record.pluginOutput) ? this.inputs : this.record.pluginOutput;
+      // 添加hook上下文信息
+      const inputsWithHookContext = {
+        ...inputs,
+        hookContext: {
+          hookType: hook.hookType,        // 例如: 'pre', 'fail', 'success', 'complete'
+          hookName: `${hook.hookType}-${this.record.command}`,  // 例如: 'fail-deploy', 'complete-deploy'
+          command: this.record.command,   // 例如: 'deploy', 'remove'
+          actionType: hook.actionType,    // 'plugin'
+          level: hook.level,              // 'project' 或 'global'
+          projectName: this.option.projectName,  // 项目名称
+        },
+      };
       // Execute the plugin with the determined inputs and provided arguments.
-      this.record.pluginOutput = await instance(inputs, hook.args, this.logger);
+      this.record.pluginOutput = await instance(inputsWithHookContext, hook.args, this.logger);
       // If prop 'replace_output' is true, replace the record's step output with the plugin output.
       if (hook.replace_output) {
         this.record.step.output = cloneDeep(this.record.pluginOutput);

packages/engine/src/index.ts

@@ -430,8 +430,12 @@ class Engine {
           }
         } catch (e) {
           this.logger.warn(get(e, 'data'));
+          // 将error信息添加到inputs中传递给fail hook
+          set(newInputs, 'error', e);
           res = get(await newActionInstance?.start(IHookType.FAIL, newInputs), 'step.output') || {};
         }
+        // complete hook需要知道是否有error
+        set(newInputs, 'output', res);
         const pluginCompleteResult = await newActionInstance?.start(IHookType.COMPLETE, newInputs);
         if (!isEmpty(pluginCompleteResult)) {
           res = get(pluginCompleteResult, 'step.output');
@@ -530,7 +534,12 @@ class Engine {
     } catch (error) {
       // On error, attempt to trigger the project's fail hook and update the recorded context.
       try {
-        const res = await this.actionInstance?.start(IHookType.FAIL, this.record.componentProps);
+        // 将error信息添加到inputs中传递给fail hook
+        const failInputs = {
+          ...this.record.componentProps,
+          error: error,
+        };
+        const res = await this.actionInstance?.start(IHookType.FAIL, failInputs);
         this.recordContext(item, get(res, 'pluginOutput', {}));
       } catch (error) {
         this.record.status = STEP_STATUS.FAILURE;
@@ -558,10 +567,14 @@ class Engine {
 
     // Attempt to trigger the project's complete hook regardless of status.
     try {
-      const res = await this.actionInstance?.start(IHookType.COMPLETE, {
+      // complete hook需要包含error信息（如果有的话）
+      const completeInputs = {
         ...this.record.componentProps,
         output: get(item, 'output', {}),
-      });
+        error: get(item, 'error'),
+        status: this.record.status,
+      };
+      const res = await this.actionInstance?.start(IHookType.COMPLETE, completeInputs);
       this.recordContext(item, get(res, 'pluginOutput', {}));
     } catch (error) {
       this.record.status = STEP_STATUS.FAILURE;