feat: added output management (#253)

Co-authored-by: I555296 <lokesh.kumar.kuntal@sap.com>
Co-authored-by: Venkatakrishnan774 <s.venkatakrishnan01+sap@sap.com>

Author: 3 people

.env_integration_tests.example

@@ -62,3 +62,11 @@ CLOUD_SDK_CFG_OBJECTSTORE_DEFAULT_HOST=your-objectstore-host-here
 CLOUD_SDK_CFG_OBJECTSTORE_DEFAULT_ACCESS_KEY_ID=your-access-key-id-here
 CLOUD_SDK_CFG_OBJECTSTORE_DEFAULT_SECRET_ACCESS_KEY=your-secret-access-key-here
 CLOUD_SDK_CFG_OBJECTSTORE_DEFAULT_BUCKET=your-bucket-name-here
+
+# OUTPUT MANAGEMENT
+# For cloud mode (destination-based):
+CLOUD_SDK_OMS_DESTINATION_NAME=your-output-management-destination-name-here
+CLOUD_SDK_OMS_ACCESS_STRATEGY=PROVIDER_ONLY
+CLOUD_SDK_OMS_INSTANCE=default
+# For local mode (no credentials needed):
+# CLOUD_SDK_OMS_TEST_MODE=local

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "sap-cloud-sdk"
-version = "0.39.1"
+version = "0.40.0"
 description = "SAP Cloud SDK for Python"
 readme = "README.md"
 license = "Apache-2.0"
@@ -37,6 +37,7 @@ dependencies = [
     "opentelemetry-instrumentation-django~=0.63b1",
     "opentelemetry-instrumentation-flask~=0.63b1",
     "mcp>=1.1.0",
+    "cryptography>=46.0.3",
 ]
 
 [project.optional-dependencies]

src/sap_cloud_sdk/core/telemetry/module.py

@@ -18,6 +18,7 @@ class Module(str, Enum):
     DMS = "dms"
     EXTENSIBILITY = "extensibility"
     OBJECTSTORE = "objectstore"
+    OUTPUT_MANAGEMENT = "outputmanagement"
     PRINT = "print"
     TELEMETRY = "telemetry"
 

src/sap_cloud_sdk/core/telemetry/operation.py

@@ -209,5 +209,10 @@ class Operation(str, Enum):
     AGENT_MEMORY_GET_RETENTION_CONFIG = "get_retention_config"
     AGENT_MEMORY_UPDATE_RETENTION_CONFIG = "update_retention_config"
 
+    # Output Management Operations
+    OUTPUT_MANAGEMENT_SEND_EMAIL = "send_email"
+    OUTPUT_MANAGEMENT_SEND_EMAIL_WITH_MCP = "send_email_with_mcp"
+    OUTPUT_MANAGEMENT_SEND_OUTPUT_REQUEST = "send_output_request"
+
     def __str__(self) -> str:
         return self.value

src/sap_cloud_sdk/outputmanagement/__init__.py

@@ -0,0 +1,179 @@
+"""SAP Ariba Output Management Service SDK for Python."""
+
+import logging
+import os
+from typing import Optional
+
+from .client import OutputManagementClient
+from ._service_client import OutputManagementServiceClient
+from ._models import (
+    OutputRequest,
+    OutputRequestBuilder,
+    OutputResponse,
+    EmailConfiguration,
+    AttachmentConfig,
+    OutputManagementInfo,
+    OutputRequestData,
+    DirectShareConfiguration,
+    FormConfiguration,
+    PreGeneratedAttachment,
+)
+from .config import DestinationCredentialConfig
+from .constants import FileFormat, Channel
+from .exceptions import (
+    OutputManagementException,
+    AuthenticationException,
+    ValidationException,
+    NetworkException,
+    DestinationNotFoundException,
+    DestinationAccessException,
+)
+
+logger = logging.getLogger(__name__)
+
+
+def create_client(
+    destination_credential_config: Optional[DestinationCredentialConfig] = None,
+    destination_name: Optional[str] = None,
+    access_strategy: Optional[str] = None,
+    instance: Optional[str] = None,
+) -> OutputManagementClient:
+    """
+    Create an Output Management client with configuration from environment or parameters.
+
+    This is the recommended factory function for creating clients. It follows the SDK's
+    standard pattern of reading configuration from environment variables with optional overrides.
+
+    Environment Variables:
+        - CLOUD_SDK_OMS_DESTINATION_NAME: Default destination name
+        - CLOUD_SDK_OMS_ACCESS_STRATEGY: Default access strategy (PROVIDER_ONLY or SUBSCRIBER_ONLY)
+        - CLOUD_SDK_OMS_INSTANCE: Default destination service instance name
+
+    Args:
+        destination_credential_config: Pre-configured DestinationCredentialConfig object.
+            If provided, other parameters are ignored.
+        destination_name: Name of the destination. If not provided, reads from
+            CLOUD_SDK_OMS_DESTINATION_NAME environment variable.
+        access_strategy: Destination access strategy. If not provided, reads from
+            CLOUD_SDK_OMS_ACCESS_STRATEGY environment variable or defaults to "PROVIDER_ONLY".
+        instance: Destination service instance name. If not provided, reads from
+            CLOUD_SDK_OMS_INSTANCE environment variable or defaults to "default".
+
+    Returns:
+        Configured OutputManagementClient instance
+
+    Raises:
+        ValidationException: If destination_name is not provided and not found in environment
+            (when destination_credential_config is not provided)
+
+    Example:
+        ```python
+        from sap_cloud_sdk.outputmanagement import create_client, DestinationCredentialConfig
+
+        # Using environment variables
+        client = create_client()
+
+        # With explicit parameters
+        client = create_client(
+            destination_name="MY_OMS_DESTINATION",
+            access_strategy="PROVIDER_ONLY",
+            instance="default"
+        )
+
+        # With DestinationCredentialConfig
+        config = DestinationCredentialConfig(
+            destination_name="MY_OMS_DESTINATION",
+            access_strategy="PROVIDER_ONLY",
+            instance="default"
+        )
+        client = create_client(destination_credential_config=config)
+
+        # Use the client's 4 methods
+        response = client.send_email(
+            notification_template_key="PO_NOTIFICATION",
+            to=["user@example.com"],
+            business_document={"PurchaseOrder": {"id": "PO-123"}}
+        )
+        ```
+    """
+    # If destination_credential_config is provided, use it directly
+    if destination_credential_config is not None:
+        destination_config = destination_credential_config
+        logger.info(
+            f"Creating Output Management client with provided DestinationCredentialConfig: "
+            f"destination '{destination_config.destination_name}'"
+        )
+    else:
+        # Validate and build config from individual parameters
+        # Read from environment variables with parameter overrides
+        dest_name = destination_name or os.getenv("CLOUD_SDK_OMS_DESTINATION_NAME")
+        access_strat = access_strategy or os.getenv(
+            "CLOUD_SDK_OMS_ACCESS_STRATEGY", "PROVIDER_ONLY"
+        )
+        inst = instance or os.getenv("CLOUD_SDK_OMS_INSTANCE", "default")
+
+        if not dest_name:
+            raise ValidationException(
+                "Destination name must be provided either as parameter or via "
+                "CLOUD_SDK_OMS_DESTINATION_NAME environment variable",
+                error_code="MISSING_DESTINATION_NAME",
+            )
+
+        logger.info(
+            f"Creating Output Management client with destination '{dest_name}', "
+            f"access_strategy '{access_strat}', instance '{inst}'"
+        )
+
+        # Create destination config
+        destination_config = DestinationCredentialConfig(
+            destination_name=dest_name,
+            access_strategy=access_strat,
+            instance=inst,
+        )
+
+    # Get the destination object
+    http_destination = destination_config.get_destination()
+
+    # Get the base URL from destination
+    base_url = destination_config.get_base_url()
+    logger.info(f"Retrieved destination base URL: {base_url}")
+
+    # Create service client directly
+    service_client = OutputManagementServiceClient(
+        base_url=base_url,
+        destination=http_destination,
+        destination_instance=destination_config.instance or "default",
+    )
+
+    # Wrap it in the unified OutputManagementClient
+    return OutputManagementClient(service_client)
+
+
+__all__ = [
+    # Main client and factory function
+    "OutputManagementClient",
+    "create_client",
+    # Models
+    "OutputRequest",
+    "OutputRequestBuilder",
+    "OutputResponse",
+    "EmailConfiguration",
+    "AttachmentConfig",
+    "OutputManagementInfo",
+    "OutputRequestData",
+    "DirectShareConfiguration",
+    "FormConfiguration",
+    "PreGeneratedAttachment",
+    # Configuration
+    "DestinationCredentialConfig",
+    # Constants/Enums
+    "FileFormat",
+    "Channel",
+    # Exceptions
+    "OutputManagementException",
+    "AuthenticationException",
+    "ValidationException",
+    "NetworkException",
+    "DestinationNotFoundException",
+    "DestinationAccessException",
+]