on_error

var Directive = core.Directive{
	Name: "on_error",
	Example: `@on_error {
  when error.kind == "Timeout" -> cov.recoverable
  else -> runtime.noop
}`,
	Handler: handleDirective,
}

var ErrorInfoAction = action.New("error.info", func(ctx context.Context, _ any) (map[string]any, error) {
	recovered, ok := contracts.RecoveredErrorFrom(ctx)
	if !ok || recovered == nil {
		return nil, xerr.NotFound("no recovered error in context")
	}
	return map[string]any{
		"kind":    recovered.Kind,
		"message": recovered.Err.Error(),
	}, nil
}).
	Description("Return information about the recovered error").
	Tag("error", "recovery").
	Build()

var ErrorPassthroughAction = action.New("error.passthrough", func(_ context.Context, req any) (any, error) {
	if m, ok := req.(map[string]any); ok {
		if errMap, ok := m["error"].(map[string]any); ok {
			if _, hasKind := errMap["kind"]; hasKind {
				if inner, hasInput := m["input"]; hasInput {
					return inner, nil
				}
			}
		}
	}
	return req, nil
}).
	Description("Return the original request, discarding the error envelope").
	Tag("error", "recovery").
	Build()

var ErrorReraiseAction = action.New("error.reraise", func(ctx context.Context, req any) (any, error) {
	if m, ok := req.(map[string]any); ok {
		if errMap, ok := m["error"].(map[string]any); ok {
			if original, ok := errMap["original"].(error); ok && original != nil {
				return nil, original
			}
		}
	}
	if recovered, ok := contracts.RecoveredErrorFrom(ctx); ok && recovered != nil {
		return nil, recovered.Err
	}
	return nil, xerr.Internal("error.reraise: no recovered error available")
}).
	Description("Propagate the recovered error back up the pipeline").
	Tag("error", "recovery").
	Build()