Skip to content
This repository was archived by the owner on Sep 3, 2025. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
21 changes: 11 additions & 10 deletions src/dispatch/case/priority/service.py
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ def get_default_or_raise(*, db_session, project_id: int) -> CasePriority:
"input": None,
"ctx": {"error": ValueError("No default case priority defined.")},
}
]
],
)
return case_priority

Expand Down Expand Up @@ -73,9 +73,11 @@ def get_by_name_or_raise(
"loc": ("case_priority",),
"input": case_priority_in.name,
"msg": "Value error, Case priority not found.",
"ctx": {"error": ValueError(f"Case priority not found: {case_priority_in.name}")}
"ctx": {
"error": ValueError(f"Case priority not found: {case_priority_in.name}")
},
}
]
],
)

return case_priority
Expand All @@ -85,13 +87,12 @@ def get_by_name_or_default(
*, db_session, project_id: int, case_priority_in=CasePriorityRead
) -> CasePriority:
"""Returns a case priority based on a name or the default if not specified."""
if case_priority_in:
if case_priority_in.name:
return get_by_name_or_raise(
db_session=db_session,
project_id=project_id,
case_priority_in=case_priority_in,
)
if case_priority_in and case_priority_in.name:
case_priority = get_by_name(
db_session=db_session, project_id=project_id, name=case_priority_in.name
)
if case_priority:
return case_priority
return get_default_or_raise(db_session=db_session, project_id=project_id)


Expand Down
47 changes: 25 additions & 22 deletions src/dispatch/case/severity/service.py
Original file line number Diff line number Diff line change
Expand Up @@ -32,13 +32,15 @@ def get_default_or_raise(*, db_session, project_id: int) -> CaseSeverity:
case_severity = get_default(db_session=db_session, project_id=project_id)

if not case_severity:
raise ValidationError([
{
"loc": ("case_severity",),
"msg": "No default case severity defined.",
"type": "value_error",
}
])
raise ValidationError(
[
{
"loc": ("case_severity",),
"msg": "No default case severity defined.",
"type": "value_error",
}
]
)
return case_severity


Expand All @@ -61,14 +63,16 @@ def get_by_name_or_raise(
)

if not case_severity:
raise ValidationError([
{
"loc": ("case_severity",),
"msg": "Case severity not found.",
"type": "value_error",
"case_severity": case_severity_in.name,
}
])
raise ValidationError(
[
{
"loc": ("case_severity",),
"msg": "Case severity not found.",
"type": "value_error",
"case_severity": case_severity_in.name,
}
]
)

return case_severity

Expand All @@ -77,13 +81,12 @@ def get_by_name_or_default(
*, db_session, project_id: int, case_severity_in=CaseSeverityRead
) -> CaseSeverity:
"""Returns a case severity based on a name or the default if not specified."""
if case_severity_in:
if case_severity_in.name:
return get_by_name_or_raise(
db_session=db_session,
project_id=project_id,
case_severity_in=case_severity_in,
)
if case_severity_in and case_severity_in.name:
case_severity = get_by_name(
db_session=db_session, project_id=project_id, name=case_severity_in.name
)
if case_severity:
return case_severity
return get_default_or_raise(db_session=db_session, project_id=project_id)


Expand Down
12 changes: 6 additions & 6 deletions src/dispatch/case/type/service.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@

from sqlalchemy.sql.expression import true

from dispatch.case import service as case_service
Expand Down Expand Up @@ -58,11 +57,12 @@ def get_by_name_or_raise(*, db_session, project_id: int, case_type_in=CaseTypeRe

def get_by_name_or_default(*, db_session, project_id: int, case_type_in=CaseTypeRead) -> CaseType:
"""Returns a case type based on a name or the default if not specified."""
if case_type_in:
if case_type_in.name:
return get_by_name_or_raise(
db_session=db_session, project_id=project_id, case_type_in=case_type_in
)
if case_type_in and case_type_in.name:
case_type = get_by_name(
db_session=db_session, project_id=project_id, name=case_type_in.name
)
if case_type:
return case_type
return get_default_or_raise(db_session=db_session, project_id=project_id)


Expand Down
43 changes: 23 additions & 20 deletions src/dispatch/incident/priority/service.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,12 +36,14 @@ def get_default_or_raise(*, db_session, project_id: int) -> IncidentPriority:
incident_priority = get_default(db_session=db_session, project_id=project_id)

if not incident_priority:
raise ValidationError([
{
"msg": "No default incident priority defined.",
"loc": "incident_priority",
}
])
raise ValidationError(
[
{
"msg": "No default incident priority defined.",
"loc": "incident_priority",
}
]
)
return incident_priority


Expand All @@ -64,13 +66,15 @@ def get_by_name_or_raise(
)

if not incident_priority:
raise ValidationError([
{
"msg": "Incident priority not found.",
"loc": "incident_priority",
"incident_priority": incident_priority_in.name,
}
])
raise ValidationError(
[
{
"msg": "Incident priority not found.",
"loc": "incident_priority",
"incident_priority": incident_priority_in.name,
}
]
)

return incident_priority

Expand All @@ -79,13 +83,12 @@ def get_by_name_or_default(
*, db_session, project_id: int, incident_priority_in=IncidentPriorityRead
) -> IncidentPriority:
"""Returns a incident priority based on a name or the default if not specified."""
if incident_priority_in:
if incident_priority_in.name:
return get_by_name_or_raise(
db_session=db_session,
project_id=project_id,
incident_priority_in=incident_priority_in,
)
if incident_priority_in and incident_priority_in.name:
incident_priority = get_by_name(
db_session=db_session, project_id=project_id, name=incident_priority_in.name
)
if incident_priority:
return incident_priority
return get_default_or_raise(db_session=db_session, project_id=project_id)


Expand Down
36 changes: 18 additions & 18 deletions src/dispatch/incident/severity/service.py
Original file line number Diff line number Diff line change
Expand Up @@ -44,9 +44,9 @@ def get_default_or_raise(*, db_session, project_id: int) -> IncidentSeverity:
"loc": ("incident_severity",),
"input": None,
"msg": "No default incident severity defined.",
"ctx": {"error": ValueError("No default incident severity defined.")}
"ctx": {"error": ValueError("No default incident severity defined.")},
}
]
],
)

return incident_severity
Expand All @@ -71,14 +71,16 @@ def get_by_name_or_raise(
)

if not incident_severity:
raise ValidationError([
{
"msg": "Incident severity not found.",
"loc": ("incident_severity",),
"type": "value_error.not_found",
"incident_severity": incident_severity_in.name,
}
])
raise ValidationError(
[
{
"msg": "Incident severity not found.",
"loc": ("incident_severity",),
"type": "value_error.not_found",
"incident_severity": incident_severity_in.name,
}
]
)

return incident_severity

Expand All @@ -87,14 +89,12 @@ def get_by_name_or_default(
*, db_session, project_id: int, incident_severity_in=IncidentSeverityRead
) -> IncidentSeverity:
"""Returns an incident severity based on a name or the default if not specified."""
if incident_severity_in:
if incident_severity_in.name:
return get_by_name_or_raise(
db_session=db_session,
project_id=project_id,
incident_severity_in=incident_severity_in,
)

if incident_severity_in and incident_severity_in.name:
incident_severity = get_by_name(
db_session=db_session, project_id=project_id, name=incident_severity_in.name
)
if incident_severity:
return incident_severity
return get_default_or_raise(db_session=db_session, project_id=project_id)


Expand Down
15 changes: 8 additions & 7 deletions src/dispatch/incident/type/service.py
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ def get_default_or_raise(*, db_session, project_id: int) -> IncidentType:
"input": None,
"ctx": {"error": ValueError("No default incident type defined.")},
}
]
],
)
return incident_type

Expand Down Expand Up @@ -74,7 +74,7 @@ def get_by_name_or_raise(
"input": incident_type_in.name,
"ctx": {"error": ValueError("Incident type not found.")},
}
]
],
)

return incident_type
Expand All @@ -84,11 +84,12 @@ def get_by_name_or_default(
*, db_session, project_id: int, incident_type_in=IncidentTypeRead
) -> IncidentType:
"""Returns a incident_type based on a name or the default if not specified."""
if incident_type_in:
if incident_type_in.name:
return get_by_name_or_raise(
db_session=db_session, project_id=project_id, incident_type_in=incident_type_in
)
if incident_type_in and incident_type_in.name:
incident_type = get_by_name(
db_session=db_session, project_id=project_id, name=incident_type_in.name
)
if incident_type:
return incident_type
return get_default_or_raise(db_session=db_session, project_id=project_id)


Expand Down
26 changes: 14 additions & 12 deletions src/dispatch/organization/service.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@

from pydantic import ValidationError
from sqlalchemy.sql.expression import true

Expand All @@ -25,13 +24,15 @@ def get_default_or_raise(*, db_session) -> Organization:
organization = get_default(db_session=db_session)

if not organization:
raise ValidationError([
{
"loc": ("organization",),
"msg": "No default organization defined.",
"type": "value_error",
}
])
raise ValidationError(
[
{
"loc": ("organization",),
"msg": "No default organization defined.",
"type": "value_error",
}
]
)
return organization


Expand Down Expand Up @@ -85,10 +86,11 @@ def get_by_slug_or_raise(*, db_session, organization_in: OrganizationRead) -> Or

def get_by_name_or_default(*, db_session, organization_in: OrganizationRead) -> Organization:
"""Returns a organization based on a name or the default if not specified."""
if organization_in.name:
return get_by_name_or_raise(db_session=db_session, organization_in=organization_in)
else:
return get_default_or_raise(db_session=db_session)
if organization_in and organization_in.name:
organization = get_by_name(db_session=db_session, name=organization_in.name)
if organization:
return organization
return get_default_or_raise(db_session=db_session)


def get_all(*, db_session) -> list[Organization | None]:
Expand Down
24 changes: 13 additions & 11 deletions src/dispatch/project/service.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@

from pydantic import ValidationError
from sqlalchemy.orm import Session
from sqlalchemy.sql.expression import true
Expand All @@ -22,13 +21,15 @@ def get_default_or_raise(*, db_session: Session) -> Project:
project = get_default(db_session=db_session)

if not project:
raise ValidationError([
{
"loc": ("project",),
"msg": "No default project defined.",
"type": "value_error",
}
])
raise ValidationError(
[
{
"loc": ("project",),
"msg": "No default project defined.",
"type": "value_error",
}
]
)
return project


Expand Down Expand Up @@ -57,9 +58,10 @@ def get_by_name_or_raise(*, db_session: Session, project_in: ProjectRead) -> Pro

def get_by_name_or_default(*, db_session, project_in: ProjectRead) -> Project:
"""Returns a project based on a name or the default if not specified."""
if project_in:
if project_in.name:
return get_by_name_or_raise(db_session=db_session, project_in=project_in)
if project_in and project_in.name:
project = get_by_name(db_session=db_session, name=project_in.name)
if project:
return project
return get_default_or_raise(db_session=db_session)


Expand Down
Loading
Loading