Commit 1c9085b2 authored by Paris Stentoumis's avatar Paris Stentoumis
Browse files

feat: first version of tf-sdk ports

parent 462ed8b6
Loading
Loading
Loading
Loading
+1 −0
Original line number Diff line number Diff line
@@ -48,3 +48,4 @@ class CapabilityInstanceState(StrEnum):
    FAILED = "failed"
    TERMINATING = "terminating"
    TERMINATED = "terminated"
    UNKNOWN = "unknown"
+8 −0
Original line number Diff line number Diff line
@@ -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):
+2 −1
Original line number Diff line number Diff line
@@ -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,
@@ -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
+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",
]
+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