feat: use web UUID to connect with web-insights & web-testing

Author: Abhi591

CHANGELOG.md

@@ -5,6 +5,36 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [1.19.0] - 2026-02-17
+
+- Added support to use the context `id` as the visitor UUID instead of auto-generating one. You can read the visitor UUID from the flag result via `flag.get_uuid()` (e.g. to pass to the web client).
+
+Example usage:
+
+```python
+from vwo import init
+
+# Initialize the SDK
+vwo_client = init({
+    "account_id": "123456",
+    "sdk_key": "32-alpha-numeric-sdk-key",
+})
+
+# Default: SDK generates a UUID from id and account
+context_with_generated_uuid = {"id": "user-123"}
+flag1 = vwo_client.get_flag("feature-key", context_with_generated_uuid)
+
+# Use your own UUID (e.g. from web client) by passing a valid web UUID as id
+context_with_custom_uuid = {
+    "id": "D7E2EAA667909A2DB8A6371FF0975C2A5",  # your existing UUID
+}
+flag2 = vwo_client.get_flag("feature-key", context_with_custom_uuid)
+
+# Get the UUID from the flag result (e.g. to pass to web client)
+uuid = flag1.get_uuid()
+print("Visitor UUID:", uuid)
+```
+
 ## [1.18.0] - 2026-02-05
 
 ### Added

setup.py

@@ -121,7 +121,7 @@ def run(self):
 
 setup(
     name="vwo-fme-python-sdk",
-    version="1.18.0",
+    version="1.19.0",
     description="VWO Feature Management and Experimentation SDK for Python",
     long_description=long_description,
     long_description_content_type="text/markdown",

vwo/api/get_flag_api.py

@@ -58,7 +58,6 @@ def __init__(self):
         self._should_check_for_experiment_rules = False
         self._passed_rules_information: Dict[str, Any] = {}
         self._evaluated_feature_map: Dict[str, Any] = {}
-        self._get_flag_response = GetFlag()
 
     def get(
         self,
@@ -77,6 +76,8 @@ def get(
         """
 
         feature = get_feature_from_key(settings, feature_key)
+        is_enabled = False
+        variables = []
         decision = {
             "featureName": feature.get_name() if feature else None,
             "featureId": feature.get_id() if feature else None,
@@ -115,9 +116,7 @@ def get(
                             experimentKey=stored_data["experimentKey"],
                         )
                     )
-                    self._get_flag_response.set_is_enabled(True)
-                    self._get_flag_response.set_variables(variation.get_variables())
-                    return self._get_flag_response
+                    return GetFlag(is_enabled=True, variables=variation.get_variables(), session_id=context.get_session_id(), uuid=context.get_vwo_uuid())
         elif (
             stored_data
             and stored_data.get("rolloutKey")
@@ -135,8 +134,9 @@ def get(
                         experimentKey=stored_data["rolloutKey"],
                     )
                 )
-                self._get_flag_response.set_is_enabled(True)
-                self._get_flag_response.set_variables(variation.get_variables())
+                is_enabled = True
+                variables = variation.get_variables()
+
                 self._should_check_for_experiment_rules = True
                 feature_info = {
                     "rolloutId": stored_data["rolloutId"],
@@ -148,14 +148,12 @@ def get(
 
         if feature is None:
             LogManager.get_instance().error_log("FEATURE_NOT_FOUND", data={"featureKey": feature_key}, debug_data = debug_event_props)
-            self._get_flag_response.set_is_enabled(False)
-            return self._get_flag_response
+            is_enabled = False
+            return GetFlag(is_enabled=is_enabled, variables=variables, session_id=context.get_session_id(), uuid=context.get_vwo_uuid())
 
         if context.get_session_id() is None:
             context.set_session_id(get_current_unix_timestamp())
 
-        self._get_flag_response.set_session_id(context.get_session_id())
-
         SegmentationManager.get_instance().set_contextual_data(
             settings, feature, context
         )
@@ -164,7 +162,7 @@ def get(
             feature, CampaignTypeEnum.ROLLOUT.value
         )
 
-        if roll_out_rules and not self._get_flag_response.is_enabled():
+        if roll_out_rules and not is_enabled:
             rollout_rules_to_evaluate: List[CampaignModel] = []
 
             for rule in roll_out_rules:
@@ -215,8 +213,8 @@ def get(
                 )
 
                 if isinstance(variation, VariationModel) and not None:
-                    self._get_flag_response.set_is_enabled(True)
-                    self._get_flag_response.set_variables(variation.get_variables())
+                    is_enabled = True
+                    variables = variation.get_variables()
                     self._should_check_for_experiment_rules = True
                     self._update_integrations_decision_object(
                         rollout_rules_to_evaluate[0], variation, decision
@@ -283,12 +281,9 @@ def get(
                         else:
                             if payload is not None and len(payload) > 0:
                                 batchPayload.append(payload)
-
-                        self._get_flag_response.set_is_enabled(True)
-                        self._get_flag_response.set_variables(
-                            whitelisted_object["variation"].get_variables()
-                        )
-
+                        
+                        is_enabled = True
+                        variables = whitelisted_object["variation"].get_variables()
                         self._passed_rules_information.update(
                             {
                                 "experimentId": rule.get_id(),
@@ -307,8 +302,8 @@ def get(
                 )
 
                 if isinstance(variation, VariationModel) and not None:
-                    self._get_flag_response.set_is_enabled(True)
-                    self._get_flag_response.set_variables(variation.get_variables())
+                    is_enabled = True
+                    variables = variation.get_variables()
 
                     self._update_integrations_decision_object(
                         experiment_rules_to_evaluate[0], variation, decision
@@ -331,7 +326,7 @@ def get(
                         if payload is not None and len(payload) > 0:
                             batchPayload.append(payload)
 
-        if self._get_flag_response.is_enabled():
+        if is_enabled:
             StorageDecorator().set_data_in_storage(
                 {
                     "featureKey": feature_key,
@@ -363,9 +358,7 @@ def get(
                     userId=context.get_id(),
                     featureKey=feature_key,
                     status=(
-                        "enabled"
-                        if self._get_flag_response.is_enabled()
-                        else "disabled"
+                        "enabled" if is_enabled else "disabled"
                     ),
                 )
             )
@@ -374,7 +367,7 @@ def get(
                 settings,
                 EventEnum.VWO_VARIATION_SHOWN.value,
                 feature.get_impact_campaign().get_campaign_id(),
-                (2 if self._get_flag_response.is_enabled() else 1),
+                (2 if is_enabled else 1),
                 context
             )
             if (
@@ -392,7 +385,7 @@ def get(
                 batchPayload, settings.get_account_id(), settings.get_sdk_key()
             )
 
-        return self._get_flag_response
+        return GetFlag(is_enabled=is_enabled, variables=variables, session_id=context.get_session_id(), uuid=context.get_vwo_uuid())
 
     def _update_integrations_decision_object(
         self,

vwo/constants/Constants.py

@@ -17,7 +17,7 @@ class Constants:
     # TODO: read from setup.py
     sdk_meta = {
         "name": "vwo-fme-python-sdk",
-        "version": "1.18.0"
+        "version": "1.19.0"
     }
 
     # Constants

vwo/models/settings/settings_model.py

@@ -33,6 +33,7 @@ def __init__(self, data: Dict):
         self._version = data["version"]
         self._collection_prefix = data.get("collectionPrefix", None)
         self._poll_interval = data.get("pollInterval", Constants.POLLING_INTERVAL)
+        self._is_web_connectivity_enabled = data.get("isWebConnectivityEnabled", True)
 
     # Getter methods for accessing private attributes
     def get_features(self) -> List[FeatureModel]:
@@ -88,4 +89,7 @@ def set_poll_interval(self, value: int):
         self._poll_interval = value
 
     def get_poll_interval(self) -> int:
-        return self._poll_interval
+        return self._poll_interval
+
+    def get_is_web_connectivity_enabled(self) -> bool:
+        return self._is_web_connectivity_enabled

vwo/models/user/context_model.py

@@ -33,7 +33,12 @@ def __init__(self, context: Dict):
         self.session_id = context.get("session_id", None)
         if self.session_id is None:
             self.session_id = get_current_unix_timestamp()
-        self._vwo_uuid = get_uuid(self.id, str(SettingsManager.get_instance().get_account_id()))
+        
+        # if uuid is provided in the context, use it, otherwise generate a new one
+        if context.get("uuid") is not None:
+            self._vwo_uuid = context.get("uuid")
+        else:
+            self._vwo_uuid = get_uuid(self.id, str(SettingsManager.get_instance().get_account_id()))
 
     def get_id(self) -> str:
         return str(self.id) if self.id is not None else None

vwo/models/user/get_flag.py

@@ -18,27 +18,25 @@
 
 
 class GetFlag:
-    def __init__(self):
-        self._is_enabled = False
-        self._variables = []
-        self._session_id = None
+    def __init__(self, is_enabled: bool, variables: List[VariableModel], session_id: int, uuid: str):
+        self._uuid = uuid
+        self._is_enabled = is_enabled
+        self._variables = variables
+        self._session_id = session_id
+
+    def get_uuid(self) -> str:
+        return self._uuid
 
     def is_enabled(self) -> bool:
         return self._is_enabled
 
-    def set_is_enabled(self, is_enabled: bool) -> None:
-        self._is_enabled = is_enabled
-
     def get_variables(self) -> List[Dict[str, Any]]:
         # convert variables to Dict
         variables = []
         for variable in self._variables:
             variables.append(variable.to_dict())
         return variables
 
-    def set_variables(self, variables: List[VariableModel]) -> None:
-        self._variables = variables
-
     def get_variable(self, variable_key: str, default_value: Any = None) -> str:
         for variable in self._variables:
             if variable.get_key() == variable_key:
@@ -47,6 +45,3 @@ def get_variable(self, variable_key: str, default_value: Any = None) -> str:
 
     def get_session_id(self) -> int:
         return self._session_id
-
-    def set_session_id(self, session_id: int) -> None:
-        self._session_id = session_id

vwo/resources/debug-messages.json

@@ -11,5 +11,6 @@
     "IMPRESSION_FOR_TRACK_USER": "Impression built for vwo_variationShown(VWO standard event for tracking user) event haivng Account ID:{accountId}, User ID:{userId}, and experiment ID:{campaignId}",
     "IMPRESSION_FOR_TRACK_GOAL": "Impression built for event:{eventName} event having Account ID:{accountId}, and user ID:{userId}",
     "IMPRESSION_FOR_SYNC_VISITOR_PROP": "Impression built for {eventName}(VWO internal event) event for Account ID:{accountId}, and user ID:{userId}",
-    "BATCHING_INITIALIZED": "BATCHING_INITIALIZED"
+    "BATCHING_INITIALIZED": "BATCHING_INITIALIZED",
+    "WEB_UUID_FOUND": "VWO Web Testing identified UUID {uuid} as the Context ID for API {apiName}"
   }

vwo/utils/network_util.py

@@ -106,7 +106,6 @@ def get_events_base_properties(
 def _get_event_base_payload(
     settings: SettingsModel,
     user_id: str,
-    session_id: str,
     event_name: str,
     visitor_user_agent: str = "",
     ip_address: str = "",
@@ -135,9 +134,7 @@ def _get_event_base_payload(
         "d": {
             "msgId": f"{uuid_value}-{get_current_unix_timestamp_in_millis()}",
             "visId": uuid_value,
-            "sessionId": (
-                session_id if session_id is not None else get_current_unix_timestamp()
-            ),
+            "sessionId": get_current_unix_timestamp(),
             "event": {
                 "props": props,
                 "name": event_name,
@@ -180,7 +177,6 @@ def get_track_user_payload_data(
     properties = _get_event_base_payload(
         settings,
         user_id,
-        context.get_session_id(),
         event_name,
         visitor_user_agent,
         ip_address,
@@ -189,6 +185,11 @@ def get_track_user_payload_data(
     if context.get_session_id() is not None and context.get_session_id() != 0:
         properties["d"]["sessionId"] = context.get_session_id()
 
+    # if uuid is provided in the context, use it, otherwise generate a new one
+    if context.get_vwo_uuid() is not None and context.get_vwo_uuid() != "":
+        properties["d"]["msgId"] = f"{context.get_vwo_uuid()}-{get_current_unix_timestamp_in_millis()}"
+        properties["d"]["visId"] = context.get_vwo_uuid()
+
     properties["d"]["event"]["props"]["id"] = campaign_id
     properties["d"]["event"]["props"]["variation"] = str(variation_id)
     properties["d"]["event"]["props"]["isFirst"] = 1
@@ -224,12 +225,17 @@ def get_track_goal_payload_data(
     event_properties: Dict[str, Any],
 ) -> Dict[str, Any]:
     properties = _get_event_base_payload(
-        settings, context.get_id(), context.get_session_id(), event_name, context.get_user_agent(), context.get_ip_address()
+        settings, context.get_id(), event_name, context.get_user_agent(), context.get_ip_address()
         )
 
     if context.get_session_id() is not None and context.get_session_id() != 0:
         properties["d"]["sessionId"] = context.get_session_id()
 
+    # if uuid is provided in the context, use it, otherwise generate a new one
+    if context.get_vwo_uuid() is not None and context.get_vwo_uuid() != "":
+        properties["d"]["msgId"] = f"{context.get_vwo_uuid()}-{get_current_unix_timestamp_in_millis()}"
+        properties["d"]["visId"] = context.get_vwo_uuid()
+
     properties["d"]["event"]["props"]["isCustomEvent"] = True
     properties["d"]["event"]["props"]["variation"] = 1  # Temporary value for variation
     properties["d"]["event"]["props"]["id"] = 1  # Temporary value for ID
@@ -261,6 +267,11 @@ def get_attribute_payload_data(
     if context.get_session_id() is not None and context.get_session_id() != 0:
         properties["d"]["sessionId"] = context.get_session_id()
 
+    # if uuid is provided in the context, use it, otherwise generate a new one
+    if context.get_vwo_uuid() is not None and context.get_vwo_uuid() != "":
+        properties["d"]["msgId"] = f"{context.get_vwo_uuid()}-{get_current_unix_timestamp_in_millis()}"
+        properties["d"]["visId"] = context.get_vwo_uuid()
+
     properties["d"]["event"]["props"]["isCustomEvent"] = True
     properties["d"]["event"]["props"][
         Constants.VWO_FS_ENVIRONMENT
@@ -461,7 +472,7 @@ def get_messaging_event_payload(
     # Get user ID and properties
     settings = SettingsManager.get_instance()
     user_id = f"{settings.get_account_id()}_{settings.get_sdk_key()}"
-    properties = _get_event_base_payload(None, user_id, get_current_unix_timestamp(), event_name, None, None)
+    properties = _get_event_base_payload(None, user_id, event_name, None, None)
 
     # Set the environment key and product
     properties["d"]["event"]["props"]["vwo_envKey"] = settings.get_sdk_key()
@@ -501,7 +512,7 @@ def get_sdk_init_event_payload(
     # Get user ID and properties
     settings = SettingsManager.get_instance()
     user_id = f"{settings.get_account_id()}_{settings.get_sdk_key()}"
-    properties = _get_event_base_payload(None, user_id, get_current_unix_timestamp(), event_name, None, None)
+    properties = _get_event_base_payload(None, user_id, event_name, None, None)
 
     # Set the required fields as specified
     properties["d"]["event"]["props"][
@@ -536,7 +547,7 @@ def get_sdk_usage_stats_event_payload(
     settings = SettingsManager.get_instance()
     user_id = f"{settings.get_account_id()}_{settings.get_sdk_key()}"
     properties = _get_event_base_payload(
-        None, user_id, get_current_unix_timestamp(), event_name, None, None, True, usage_stats_account_id
+        None, user_id, event_name, None, None, True, usage_stats_account_id
     )
 
     # Set the required fields as specified