[ffe] integrate datadog-ffe

Author: dd-oleksii

ddtrace/internal/native/__init__.py

@@ -15,7 +15,7 @@
 from ._native import SerializationError  # noqa: F401
 from ._native import TraceExporter  # noqa: F401
 from ._native import TraceExporterBuilder  # noqa: F401
-from ._native import ffande_process_config  # noqa: F401
+from ._native import ffe  # noqa: F401
 from ._native import logger  # noqa: F401
 from ._native import store_metadata  # noqa: F401
 

ddtrace/internal/native/_native.pyi

@@ -1,4 +1,5 @@
-from typing import Dict, List, Literal, Optional
+from typing import Dict, List, Literal, Optional, Any
+from enum import Enum
 
 class DDSketch:
     def __init__(self): ...
@@ -447,11 +448,56 @@ class SerializationError(Exception):
 
     ...
 
-def ffande_process_config(config_bytes: bytes) -> Optional[bool]:
+class ffe:
     """
-    Process feature flagging and experimentation configuration rules.
-
-    :param config_bytes: Raw bytes containing the configuration data
-    :return: True if processing was successful, False otherwise, None on error
+    Native Feature Flags and Experimentation module.
     """
-    ...
+
+    class FlagType(Enum):
+        String = ...
+        Integer = ...
+        Float = ...
+        Boolean = ...
+        Object = ...
+
+    class Reason(Enum):
+        Static = ...
+        Default = ...
+        TargetingMatch = ...
+        Split = ...
+        Cached = ...
+        Disabled = ...
+        Unknown = ...
+        Stale = ...
+        Error = ...
+
+    class ErrorCode(Enum):
+        TypeMismatch = ...
+        ParseError = ...
+        FlagNotFound = ...
+        TargetingKeyMissing = ...
+        InvalidContext = ...
+        ProviderNotReady = ...
+        General = ...
+
+    class ResolutionDetails:
+        @property
+        def value() -> Optional[Any]: ...
+        @property
+        def error_code() -> Optional[ffe.ErrorCode]: ...
+        @property
+        def error_message() -> Optional[str]: ...
+        @property
+        def reason() -> Optional[ffe.Reason]: ...
+        @property
+        def variant() -> Optional[str]: ...
+        @property
+        def flag_metadata() -> dict[str, str]: ...
+        @property
+        def do_log() -> bool: ...
+        @property
+        def extra_logging() -> Optional[dict[str, str]]: ...
+
+    class Configuration:
+        def __init__(config_bytes: bytes) -> None: ...
+        def resolve_value(self, flag_key: str, expected_type: ffe.FlagType, context: dict) -> ffe.ResolutionDetails: ...

ddtrace/internal/openfeature/_native.py

@@ -1,9 +1,10 @@
 """
-Native interface for FFAndE (Feature Flagging and Experimentation) processing.
+Native interface for FFE (Feature Flagging and Experimentation) processing.
 
 This module provides the interface to the PyO3 native function that processes
 feature flag configuration rules.
 """
+
 from typing import Optional
 
 from ddtrace.internal.logger import get_logger
@@ -14,19 +15,13 @@
 is_available = True
 
 try:
-    from ddtrace.internal.native._native import ffande_process_config
+    from ddtrace.internal.native._native import ffe
 except ImportError:
     is_available = False
-    log.debug("FFAndE native module not available, feature flag processing disabled")
-
-    # Provide a no-op fallback
-    def ffande_process_config(config_bytes: bytes) -> Optional[bool]:
-        """Fallback implementation when native module is not available."""
-        log.warning("FFAndE native module not available, ignoring configuration")
-        return None
+    log.debug("FFE native module not available, feature flag processing disabled")
 
 
-def process_ffe_configuration(config_bytes: bytes) -> bool:
+def process_ffe_configuration(config_bytes: bytes) -> Optional[ffe.Configuration]:
     """
     Process feature flag configuration by forwarding raw bytes to native function.
 
@@ -37,15 +32,11 @@ def process_ffe_configuration(config_bytes: bytes) -> bool:
         True if processing was successful, False otherwise
     """
     if not is_available:
-        log.debug("FFAndE native module not available, skipping configuration")
+        log.debug("FFE native module not available, skipping configuration")
         return False
 
     try:
-        result = ffande_process_config(config_bytes)
-        if result is None:
-            log.debug("FFAndE native processing returned None")
-            return False
-        return result
+        return ffe.Configuration(config_bytes)
     except Exception as e:
         log.error("Error processing FFE configuration: %s", e, exc_info=True)
-        return False
+        return None