format and retext control plane errors
All checks were successful
Tests / test (push) Successful in 28s

This commit is contained in:
Tobias Brunner 2025-07-10 16:32:41 +02:00
parent 9317547630
commit 9c3ce54bb3
No known key found for this signature in database

View file

@ -1,5 +1,6 @@
import copy import copy
import json import json
import re
import kubernetes import kubernetes
import rules import rules
@ -604,6 +605,32 @@ class ServiceInstance(ServalaModelMixin, models.Model):
spec_data = prune_empty_data(spec_data) spec_data = prune_empty_data(spec_data)
return spec_data return spec_data
@classmethod
def _format_kubernetes_error(cls, error_message):
"""
Format Kubernetes API error messages for better user experience.
Converts validation error arrays into unordered lists.
"""
# Pattern to match validation errors in brackets
pattern = r"\[([^\]]+)\]"
match = re.search(pattern, error_message)
if not match:
return error_message
errors_text = match.group(1)
# Split by comma and clean up each error
errors = [error.strip() for error in errors_text.split(",")]
if len(errors) > 1:
# Format as HTML unordered list
error_list = "".join(f"<li>{error}</li>" for error in errors)
# Replace the bracketed section with the formatted list
formatted_message = re.sub(pattern, f"<ul>{error_list}</ul>", error_message)
return mark_safe(formatted_message)
return error_message
@classmethod @classmethod
def create_instance(cls, name, organization, context, created_by, spec_data): def create_instance(cls, name, organization, context, created_by, spec_data):
# Ensure the namespace exists # Ensure the namespace exists
@ -657,12 +684,21 @@ class ServiceInstance(ServalaModelMixin, models.Model):
try: try:
error_body = json.loads(e.body) error_body = json.loads(e.body)
reason = error_body.get("message", str(e)) reason = error_body.get("message", str(e))
message = _(f"Kubernetes API error: {reason}.") formatted_reason = cls._format_kubernetes_error(reason)
message = _("Error reported by control plane: {reason}").format(
reason=formatted_reason
)
raise ValidationError(organization.add_support_message(message)) raise ValidationError(organization.add_support_message(message))
except (ValueError, TypeError): except (ValueError, TypeError):
message = _(f"Kubernetes API error: {str(e)}.") formatted_error = cls._format_kubernetes_error(str(e))
message = _("Error reported by control plane: {error}").format(
error=formatted_error
)
raise ValidationError(organization.add_support_message(message)) raise ValidationError(organization.add_support_message(message))
message = _(f"Error creating instance: {str(e)}.") formatted_error = cls._format_kubernetes_error(str(e))
message = _("Error creating instance: {error}").format(
error=formatted_error
)
raise ValidationError(organization.add_support_message(message)) raise ValidationError(organization.add_support_message(message))
return instance return instance
@ -685,19 +721,28 @@ class ServiceInstance(ServalaModelMixin, models.Model):
except ApiException as e: except ApiException as e:
if e.status == 404: if e.status == 404:
message = _( message = _(
"Service instance not found in Kubernetes. It may have been deleted externally." "Service instance not found in control plane. It may have been deleted externally."
) )
raise ValidationError(self.organization.add_support_message(message)) raise ValidationError(self.organization.add_support_message(message))
try: try:
error_body = json.loads(e.body) error_body = json.loads(e.body)
reason = error_body.get("message", str(e)) reason = error_body.get("message", str(e))
message = _(f"Kubernetes API error updating instance: {reason}.") formatted_reason = self._format_kubernetes_error(reason)
message = _(
"Error reported by control plane while updating instance: {reason}"
).format(reason=formatted_reason)
raise ValidationError(self.organization.add_support_message(message)) raise ValidationError(self.organization.add_support_message(message))
except (ValueError, TypeError): except (ValueError, TypeError):
message = _(f"Kubernetes API error updating instance: {str(e)}.") formatted_error = self._format_kubernetes_error(str(e))
message = _(
"Error reported by control plane while updating instance: {error}"
).format(error=formatted_error)
raise ValidationError(self.organization.add_support_message(message)) raise ValidationError(self.organization.add_support_message(message))
except Exception as e: except Exception as e:
message = _(f"Error updating instance: {str(e)}.") formatted_error = self._format_kubernetes_error(str(e))
message = _("Error updating instance: {error}").format(
error=formatted_error
)
raise ValidationError(self.organization.add_support_message(message)) raise ValidationError(self.organization.add_support_message(message))
@transaction.atomic @transaction.atomic