Function normalizeBulkForceRunRequest

internal/task/force_ops.go:595–644

(req BulkForceRunRequest, requireReason bool)

}

func normalizeBulkForceRunRequest(req BulkForceRunRequest, requireReason bool) (BulkForceRunRequest, error) {
	if len(req.RunIDs) == 0 {
		return BulkForceRunRequest{}, fmt.Errorf("%w: bulk force run_ids is required", ErrValidation)
	}
	if len(req.RunIDs) > MaxForceRunBulkIDs {
		return BulkForceRunRequest{}, forceRunDiagnosticError(
			diagnosticcontract.CodeBulkTooLarge,
			"Bulk force operation is too large",
			fmt.Sprintf("Bulk force operations accept at most %d run ids.", MaxForceRunBulkIDs),
			diagnosticcontract.SeverityError,
			"",
			map[string]any{"limit": MaxForceRunBulkIDs, "count": len(req.RunIDs)},
			ErrBulkTooLarge,
		)
	}
	seen := make(map[string]struct{}, len(req.RunIDs))
	ids := make([]string, 0, len(req.RunIDs))
	for _, id := range req.RunIDs {
		trimmed := strings.TrimSpace(id)
		if trimmed == "" {
			return BulkForceRunRequest{}, fmt.Errorf(
				"%w: bulk force run_ids must not contain empty values",
				ErrValidation,
			)
		}
		if _, ok := seen[trimmed]; ok {
			continue
		}
		seen[trimmed] = struct{}{}
		ids = append(ids, trimmed)
	}
	req.RunIDs = ids
	req.Reason = strings.TrimSpace(req.Reason)
	if requireReason && req.Reason == "" {
		return BulkForceRunRequest{}, forceRunDiagnosticError(
			diagnosticcontract.CodeForceOpRequiresReason,
			"Force fail requires a reason",
			"Provide a reason so every failed row has clear audit evidence.",
			diagnosticcontract.SeverityError,
			"agh task fail <run-id...> --reason \"operator recovery\"",
			nil,
			ErrForceOpRequiresReason,
		)
	}
	req.Metadata = normalizeRawJSON(req.Metadata)
	if err := ValidateMetadataSize(req.Metadata, "bulk_force.metadata"); err != nil {
		return BulkForceRunRequest{}, err
	}
	return req, nil
}

func forceRunDiagnosticError(
	code string,