Test cases

Author: rakshil14-2

awscrt/aws_iot_metrics.py

@@ -249,61 +249,61 @@ def _get_encoded_feature_list(client_options):
     if client_options.retry_jitter_mode is not None:
         val = _retry_jitter_metrics_value(client_options.retry_jitter_mode)
         if val:
-            features.append(f"{MetricsFeatureId.RETRY_JITTER_MODE}/{val}")
+            features.append(f"{MetricsFeatureId.RETRY_JITTER_MODE.value}/{val}")
 
     # B: session_behavior
     if client_options.session_behavior is not None:
         val = _client_session_behavior_metrics_value(client_options.session_behavior)
         if val:
-            features.append(f"{MetricsFeatureId.SESSION_BEHAVIOR}/{val}")
+            features.append(f"{MetricsFeatureId.SESSION_BEHAVIOR.value}/{val}")
 
     # C: offline_queue_behavior
     if client_options.offline_queue_behavior is not None:
         val = _client_operation_queue_behavior_metrics_value(client_options.offline_queue_behavior)
         if val:
-            features.append(f"{MetricsFeatureId.OFFLINE_QUEUE_BEHAVIOR}/{val}")
+            features.append(f"{MetricsFeatureId.OFFLINE_QUEUE_BEHAVIOR.value}/{val}")
 
     # D: outbound_topic_alias_behavior
     if client_options.topic_aliasing_options is not None:
         if client_options.topic_aliasing_options.outbound_behavior is not None:
             val = _outbound_topic_alias_behavior_metrics_value(client_options.topic_aliasing_options.outbound_behavior)
             if val:
-                features.append(f"{MetricsFeatureId.OUTBOUND_TOPIC_ALIAS_BEHAVIOR}/{val}")
+                features.append(f"{MetricsFeatureId.OUTBOUND_TOPIC_ALIAS_BEHAVIOR.value}/{val}")
 
     # E: inbound_topic_alias_behavior
     if client_options.topic_aliasing_options is not None:
         if client_options.topic_aliasing_options.inbound_behavior is not None:
             val = _inbound_topic_alias_behavior_metrics_value(client_options.topic_aliasing_options.inbound_behavior)
             if val:
-                features.append(f"{MetricsFeatureId.INBOUND_TOPIC_ALIAS_BEHAVIOR}/{val}")
+                features.append(f"{MetricsFeatureId.INBOUND_TOPIC_ALIAS_BEHAVIOR.value}/{val}")
 
     # F: protocol_version - MQTT5 always uses client options
-    features.append(f"{MetricsFeatureId.PROTOCOL_VERSION}/{MetricsProtocolVersionValue.MQTT5}")
+    features.append(f"{MetricsFeatureId.PROTOCOL_VERSION.value}/{MetricsProtocolVersionValue.MQTT5.value}")
 
     # G: socket_implementation - Detect based on platform
-    features.append(f"{MetricsFeatureId.SOCKET_IMPLEMENTATION}/{_detect_socket_implementation()}")
+    features.append(f"{MetricsFeatureId.SOCKET_IMPLEMENTATION.value}/{_detect_socket_implementation().value}")
 
     # H: http_proxy_type - Determine based on whether proxy uses TLS
     if client_options.http_proxy_options is not None:
         proxy_type = MetricsHttpProxyTypeValue.HTTPS if getattr(
             client_options.http_proxy_options,
             'tls_connection_options',
             None) is not None else MetricsHttpProxyTypeValue.HTTP
-        features.append(f"{MetricsFeatureId.HTTP_PROXY_TYPE}/{proxy_type}")
+        features.append(f"{MetricsFeatureId.HTTP_PROXY_TYPE.value}/{proxy_type.value}")
 
     # I: certificate_source - Would need to be tracked from TLS context setup. This is set at a IoT SDK level
 
     # J: tls_cipher_preference - security policy
     if client_options.tls_ctx is not None:
         val = _tls_cipher_preference_metrics_value(client_options.tls_ctx.cipher_pref)
         if val:
-            features.append(f"{MetricsFeatureId.TLS_CIPHER_PREFERENCE}/{val}")
+            features.append(f"{MetricsFeatureId.TLS_CIPHER_PREFERENCE.value}/{val}")
 
     # K: minimum_tls_version - The minimum TLS version set on TLSContextOptions
     if client_options.tls_ctx is not None:
         val = _minimum_tls_version_metrics_value(client_options.tls_ctx.min_tls_ver)
         if val:
-            features.append(f"{MetricsFeatureId.MINIMUM_TLS_VERSION}/{val}")
+            features.append(f"{MetricsFeatureId.MINIMUM_TLS_VERSION.value}/{val}")
 
     return ",".join(features)
 
@@ -331,26 +331,26 @@ def _get_encoded_feature_list_mqtt3(proxy_options, tls_ctx=None):
         str: The encoded feature list string.
     """
     features = [
-        f"{MetricsFeatureId.PROTOCOL_VERSION}/{MetricsProtocolVersionValue.MQTT311}",
-        f"{MetricsFeatureId.SOCKET_IMPLEMENTATION}/{_detect_socket_implementation()}"
+        f"{MetricsFeatureId.PROTOCOL_VERSION.value}/{MetricsProtocolVersionValue.MQTT311.value}",
+        f"{MetricsFeatureId.SOCKET_IMPLEMENTATION.value}/{_detect_socket_implementation().value}"
     ]
     # H: http_proxy_type - Determine based on whether proxy uses TLS
     if proxy_options is not None:
         proxy_type = MetricsHttpProxyTypeValue.HTTPS if getattr(
             proxy_options, 'tls_connection_options', None) is not None else MetricsHttpProxyTypeValue.HTTP
-        features.append(f"{MetricsFeatureId.HTTP_PROXY_TYPE}/{proxy_type}")
+        features.append(f"{MetricsFeatureId.HTTP_PROXY_TYPE.value}/{proxy_type.value}")
 
     # J: tls_cipher_preference - security policy
     if tls_ctx is not None:
         val = _tls_cipher_preference_metrics_value(tls_ctx.cipher_pref)
         if val:
-            features.append(f"{MetricsFeatureId.TLS_CIPHER_PREFERENCE}/{val}")
+            features.append(f"{MetricsFeatureId.TLS_CIPHER_PREFERENCE.value}/{val}")
 
     # K: minimum_tls_version - the minimum TLS version set on TLSContextOptions
     if tls_ctx is not None:
         val = _minimum_tls_version_metrics_value(tls_ctx.min_tls_ver)
         if val:
-            features.append(f"{MetricsFeatureId.MINIMUM_TLS_VERSION}/{val}")
+            features.append(f"{MetricsFeatureId.MINIMUM_TLS_VERSION.value}/{val}")
 
     return ",".join(features)