Loading src/srm/domain/models/runtime_inventory/enums.py +1 −0 Original line number Diff line number Diff line Loading @@ -48,3 +48,4 @@ class CapabilityInstanceState(StrEnum): FAILED = "failed" TERMINATING = "terminating" TERMINATED = "terminated" UNKNOWN = "unknown" src/srm/domain/models/topology/enums.py +8 −0 Original line number Diff line number Diff line Loading @@ -41,9 +41,17 @@ class CapabilityState(StrEnum): class CapabilityKind(StrEnum): QUERY_AVAILABLE_RESOURCES = "query_available_resources" DEPLOY_WORKLOAD = "deploy_workload" UPDATE_WORKLOAD = "update_workload" SCALE_WORKLOAD = "scale_workload" TERMINATE_WORKLOAD = "terminate_workload" GET_WORKLOAD_RUNTIME_STATE = "get_workload_runtime_state" QOD_SESSION = "qod_session" TRAFFIC_INFLUENCE = "traffic_influence" DEVICE_LOCATION = "device_location" NUMBER_VERIFICATION = "number_verification" SIM_SWAP = "sim_swap" KYC_MATCH = "kyc_match" CONSENT_VALIDATION = "consent_validation" class ControlPathBindingState(StrEnum): Loading src/srm/domain/models/topology/models.py +2 −1 Original line number Diff line number Diff line Loading @@ -3,6 +3,7 @@ from uuid import UUID from pydantic import Field from srm.domain.models.catalog.enums import RuntimeKind from srm.domain.models.common import AuditedModel from srm.domain.models.topology.enums import ( CapabilityKind, Loading Loading @@ -63,7 +64,7 @@ class ControlPathBinding(AuditedModel): ref: str control_path_ref: str supported_runtime_kinds: list[str] = Field(default_factory=list) supported_runtime_kinds: list[RuntimeKind] = Field(default_factory=list) supported_actions: list[str] = Field(default_factory=list) priority: int = 100 Loading src/srm/domain/ports/__init__.py 0 → 100644 +79 −0 Original line number Diff line number Diff line """Domain ports.""" from srm.domain.ports.transformation_functions import ( AuthenticationError, AuthorizationError, BackendAdmissionDenied, BackendOperationInProgress, BindingUnavailable, CapabilityConflict, CapabilityExecutionPort, CapabilityLifecycleRequest, CapabilityLifecycleResult, CapabilityQueryRequest, CapabilityQueryResult, CapabilityRuntimeState, CapabilityRuntimeStateRequest, ControlPathUnavailable, DeploymentUnit, DeploymentUnitType, DomainCommunicationError, DomainExecutionFailed, DomainTimeoutError, InvalidTargetRef, QueryConfidence, ResolvedCapabilityTarget, ResourceConstraintViolation, ResourceNotFound, TemporaryDomainFailure, TFSDKError, TopologyDiscoveryPort, TransformationFunctionCapability, TransformationFunctionControlPathBinding, TransformationFunctionDiscoveryPort, TransformationFunctionDomain, TransformationFunctionExecutionPort, TransformationFunctionZone, UnsupportedAction, UnsupportedCapability, ValidationError, ) __all__ = [ "AuthenticationError", "AuthorizationError", "BackendAdmissionDenied", "BackendOperationInProgress", "BindingUnavailable", "CapabilityConflict", "CapabilityExecutionPort", "CapabilityLifecycleRequest", "CapabilityLifecycleResult", "CapabilityQueryRequest", "CapabilityQueryResult", "CapabilityRuntimeState", "CapabilityRuntimeStateRequest", "ControlPathUnavailable", "DeploymentUnit", "DeploymentUnitType", "DomainCommunicationError", "DomainExecutionFailed", "DomainTimeoutError", "InvalidTargetRef", "QueryConfidence", "ResolvedCapabilityTarget", "ResourceConstraintViolation", "ResourceNotFound", "TFSDKError", "TemporaryDomainFailure", "TopologyDiscoveryPort", "TransformationFunctionCapability", "TransformationFunctionControlPathBinding", "TransformationFunctionDiscoveryPort", "TransformationFunctionDomain", "TransformationFunctionExecutionPort", "TransformationFunctionZone", "UnsupportedAction", "UnsupportedCapability", "ValidationError", ] src/srm/domain/ports/transformation_functions/__init__.py 0 → 100644 +85 −0 Original line number Diff line number Diff line """Transformation function adapter contract.""" from srm.domain.ports.transformation_functions.enums import ( DeploymentUnitType, QueryConfidence, ) from srm.domain.ports.transformation_functions.errors import ( AuthenticationError, AuthorizationError, BackendAdmissionDenied, BackendOperationInProgress, BindingUnavailable, CapabilityConflict, ControlPathUnavailable, DomainCommunicationError, DomainExecutionFailed, DomainTimeoutError, InvalidTargetRef, ResourceConstraintViolation, ResourceNotFound, TemporaryDomainFailure, TFSDKError, UnsupportedAction, UnsupportedCapability, ValidationError, ) from srm.domain.ports.transformation_functions.models import ( CapabilityLifecycleRequest, CapabilityLifecycleResult, CapabilityQueryRequest, CapabilityQueryResult, CapabilityRuntimeState, CapabilityRuntimeStateRequest, DeploymentUnit, ResolvedCapabilityTarget, TransformationFunctionCapability, TransformationFunctionControlPathBinding, TransformationFunctionDomain, TransformationFunctionZone, ) from srm.domain.ports.transformation_functions.ports import ( CapabilityExecutionPort, TopologyDiscoveryPort, TransformationFunctionDiscoveryPort, TransformationFunctionExecutionPort, ) __all__ = [ "AuthenticationError", "AuthorizationError", "BackendAdmissionDenied", "BackendOperationInProgress", "BindingUnavailable", "CapabilityConflict", "CapabilityExecutionPort", "CapabilityLifecycleRequest", "CapabilityLifecycleResult", "CapabilityQueryRequest", "CapabilityQueryResult", "CapabilityRuntimeState", "CapabilityRuntimeStateRequest", "ControlPathUnavailable", "DeploymentUnit", "DeploymentUnitType", "DomainCommunicationError", "DomainExecutionFailed", "DomainTimeoutError", "InvalidTargetRef", "QueryConfidence", "ResolvedCapabilityTarget", "ResourceConstraintViolation", "ResourceNotFound", "TFSDKError", "TemporaryDomainFailure", "TopologyDiscoveryPort", "TransformationFunctionCapability", "TransformationFunctionControlPathBinding", "TransformationFunctionDiscoveryPort", "TransformationFunctionDomain", "TransformationFunctionExecutionPort", "TransformationFunctionZone", "UnsupportedAction", "UnsupportedCapability", "ValidationError", ] Loading
src/srm/domain/models/runtime_inventory/enums.py +1 −0 Original line number Diff line number Diff line Loading @@ -48,3 +48,4 @@ class CapabilityInstanceState(StrEnum): FAILED = "failed" TERMINATING = "terminating" TERMINATED = "terminated" UNKNOWN = "unknown"
src/srm/domain/models/topology/enums.py +8 −0 Original line number Diff line number Diff line Loading @@ -41,9 +41,17 @@ class CapabilityState(StrEnum): class CapabilityKind(StrEnum): QUERY_AVAILABLE_RESOURCES = "query_available_resources" DEPLOY_WORKLOAD = "deploy_workload" UPDATE_WORKLOAD = "update_workload" SCALE_WORKLOAD = "scale_workload" TERMINATE_WORKLOAD = "terminate_workload" GET_WORKLOAD_RUNTIME_STATE = "get_workload_runtime_state" QOD_SESSION = "qod_session" TRAFFIC_INFLUENCE = "traffic_influence" DEVICE_LOCATION = "device_location" NUMBER_VERIFICATION = "number_verification" SIM_SWAP = "sim_swap" KYC_MATCH = "kyc_match" CONSENT_VALIDATION = "consent_validation" class ControlPathBindingState(StrEnum): Loading
src/srm/domain/models/topology/models.py +2 −1 Original line number Diff line number Diff line Loading @@ -3,6 +3,7 @@ from uuid import UUID from pydantic import Field from srm.domain.models.catalog.enums import RuntimeKind from srm.domain.models.common import AuditedModel from srm.domain.models.topology.enums import ( CapabilityKind, Loading Loading @@ -63,7 +64,7 @@ class ControlPathBinding(AuditedModel): ref: str control_path_ref: str supported_runtime_kinds: list[str] = Field(default_factory=list) supported_runtime_kinds: list[RuntimeKind] = Field(default_factory=list) supported_actions: list[str] = Field(default_factory=list) priority: int = 100 Loading
src/srm/domain/ports/__init__.py 0 → 100644 +79 −0 Original line number Diff line number Diff line """Domain ports.""" from srm.domain.ports.transformation_functions import ( AuthenticationError, AuthorizationError, BackendAdmissionDenied, BackendOperationInProgress, BindingUnavailable, CapabilityConflict, CapabilityExecutionPort, CapabilityLifecycleRequest, CapabilityLifecycleResult, CapabilityQueryRequest, CapabilityQueryResult, CapabilityRuntimeState, CapabilityRuntimeStateRequest, ControlPathUnavailable, DeploymentUnit, DeploymentUnitType, DomainCommunicationError, DomainExecutionFailed, DomainTimeoutError, InvalidTargetRef, QueryConfidence, ResolvedCapabilityTarget, ResourceConstraintViolation, ResourceNotFound, TemporaryDomainFailure, TFSDKError, TopologyDiscoveryPort, TransformationFunctionCapability, TransformationFunctionControlPathBinding, TransformationFunctionDiscoveryPort, TransformationFunctionDomain, TransformationFunctionExecutionPort, TransformationFunctionZone, UnsupportedAction, UnsupportedCapability, ValidationError, ) __all__ = [ "AuthenticationError", "AuthorizationError", "BackendAdmissionDenied", "BackendOperationInProgress", "BindingUnavailable", "CapabilityConflict", "CapabilityExecutionPort", "CapabilityLifecycleRequest", "CapabilityLifecycleResult", "CapabilityQueryRequest", "CapabilityQueryResult", "CapabilityRuntimeState", "CapabilityRuntimeStateRequest", "ControlPathUnavailable", "DeploymentUnit", "DeploymentUnitType", "DomainCommunicationError", "DomainExecutionFailed", "DomainTimeoutError", "InvalidTargetRef", "QueryConfidence", "ResolvedCapabilityTarget", "ResourceConstraintViolation", "ResourceNotFound", "TFSDKError", "TemporaryDomainFailure", "TopologyDiscoveryPort", "TransformationFunctionCapability", "TransformationFunctionControlPathBinding", "TransformationFunctionDiscoveryPort", "TransformationFunctionDomain", "TransformationFunctionExecutionPort", "TransformationFunctionZone", "UnsupportedAction", "UnsupportedCapability", "ValidationError", ]
src/srm/domain/ports/transformation_functions/__init__.py 0 → 100644 +85 −0 Original line number Diff line number Diff line """Transformation function adapter contract.""" from srm.domain.ports.transformation_functions.enums import ( DeploymentUnitType, QueryConfidence, ) from srm.domain.ports.transformation_functions.errors import ( AuthenticationError, AuthorizationError, BackendAdmissionDenied, BackendOperationInProgress, BindingUnavailable, CapabilityConflict, ControlPathUnavailable, DomainCommunicationError, DomainExecutionFailed, DomainTimeoutError, InvalidTargetRef, ResourceConstraintViolation, ResourceNotFound, TemporaryDomainFailure, TFSDKError, UnsupportedAction, UnsupportedCapability, ValidationError, ) from srm.domain.ports.transformation_functions.models import ( CapabilityLifecycleRequest, CapabilityLifecycleResult, CapabilityQueryRequest, CapabilityQueryResult, CapabilityRuntimeState, CapabilityRuntimeStateRequest, DeploymentUnit, ResolvedCapabilityTarget, TransformationFunctionCapability, TransformationFunctionControlPathBinding, TransformationFunctionDomain, TransformationFunctionZone, ) from srm.domain.ports.transformation_functions.ports import ( CapabilityExecutionPort, TopologyDiscoveryPort, TransformationFunctionDiscoveryPort, TransformationFunctionExecutionPort, ) __all__ = [ "AuthenticationError", "AuthorizationError", "BackendAdmissionDenied", "BackendOperationInProgress", "BindingUnavailable", "CapabilityConflict", "CapabilityExecutionPort", "CapabilityLifecycleRequest", "CapabilityLifecycleResult", "CapabilityQueryRequest", "CapabilityQueryResult", "CapabilityRuntimeState", "CapabilityRuntimeStateRequest", "ControlPathUnavailable", "DeploymentUnit", "DeploymentUnitType", "DomainCommunicationError", "DomainExecutionFailed", "DomainTimeoutError", "InvalidTargetRef", "QueryConfidence", "ResolvedCapabilityTarget", "ResourceConstraintViolation", "ResourceNotFound", "TFSDKError", "TemporaryDomainFailure", "TopologyDiscoveryPort", "TransformationFunctionCapability", "TransformationFunctionControlPathBinding", "TransformationFunctionDiscoveryPort", "TransformationFunctionDomain", "TransformationFunctionExecutionPort", "TransformationFunctionZone", "UnsupportedAction", "UnsupportedCapability", "ValidationError", ]