func ActionOutputHandler()

in codecatalyst-runner/pkg/actions/action_output_handler.go [19:85]
65 lines of code
12 McCabe index (conditional complexity)

func ActionOutputHandler(outputs map[string]string, suppressOutput bool) runner.Feature {
	return func(ctx context.Context, plan runner.Plan, e runner.PlanExecutor) error {
		log.Ctx(ctx).Debug().Msg("ENTER ActionOutputHandler")
		var action *Action
		if ap, ok := plan.(ActionProvider); ok {
			action = ap.Action()
		} else {
			return fmt.Errorf("plan must implement ActionProvider for ActionOutputHandler")
		}
		lineHandlers := []lineHandler{
			actionOutputLineHandler(outputs, maps.Keys(action.Outputs.Variables)),
		}
		if suppressOutput {
			log.Ctx(ctx).Debug().Msgf("suppressing action output")
		} else {
			rawLogger := log.Ctx(ctx).With().Logger()
			lineHandlers = append(lineHandlers, func(s string) bool {
				s = strings.TrimRight(s, "\r\n")
				rawLogger.Info().Msg(s)
				return true
			})
		}
		logWriter := newLineWriter(lineHandlers...)
		log.Ctx(ctx).Debug().Msgf("Setting stdout/stderr to %+v", logWriter)
		plan.EnvironmentConfiguration().Stdout = logWriter
		plan.EnvironmentConfiguration().Stderr = logWriter

		if err := e(ctx); err != nil {
			maps.Clear(outputs)
			return err
		}
		for k, v := range outputs {
			if k == "ACTION_RUN_SUMMARY" {
				delete(outputs, k)
				// handle ACTION_RUN_SUMMARY output
				actionRunSummaries := make([]ActionRunSummaryMessage, 0)
				err := json.Unmarshal([]byte(v), &actionRunSummaries)
				if err != nil {
					return fmt.Errorf("unable to unmarshal ACTION_RUN_SUMMARY: %w\n%s", err, v)
				}
				var actionRunErrors error
				for _, actionRunSummary := range actionRunSummaries {
					if actionRunSummary.Level == ActionRunSummaryLevelError {
						actionRunErrors = errors.Join(
							actionRunErrors,
							fmt.Errorf("[%s] %s", actionRunSummary.Text, actionRunSummary.Message),
						)
					}
				}
				if actionRunErrors != nil {
					return actionRunErrors
				}
			}
		}
		log.Ctx(ctx).Debug().Msgf("action outputs: %+v", outputs)
		if len(outputs) > 0 {
			log.Ctx(ctx).Info().Msgf("")
			log.Ctx(ctx).Info().Msgf("💬 OUTPUTS:")
			for k, v := range outputs {
				log.Ctx(ctx).Info().Msgf("    %s = %s", k, v)
			}
			log.Ctx(ctx).Info().Msgf("")
		}
		log.Ctx(ctx).Debug().Msg("EXIT ActionOutputHandler")
		return nil
	}
}