feat: usage Stats

Author: Abhi591

CHANGELOG.md

@@ -5,6 +5,11 @@ 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.15.0] - 2025-12-08
+### Added
+
+- Sends usage statistics to VWO servers automatically during SDK initialization
+
 ## [1.14.0] - 2025-11-24
 
 ### Added

pom.xml

@@ -19,7 +19,7 @@ limitations under the License. -->
 
     <groupId>com.vwo.sdk</groupId>
     <artifactId>vwo-fme-java-sdk</artifactId>
-    <version>1.14.0</version>
+    <version>1.15.0</version>
     <packaging>jar</packaging>
 
     <name>VWO FME Java SDK</name>

src/main/java/com/vwo/VWO.java

@@ -84,8 +84,7 @@ public static VWO init(VWOInitOptions options) {
         VWO instance = VWO.setInstance(options);
         long initTime = System.currentTimeMillis() - initStartTime;
         // send sdk init event
-        instance.sendSdkInitEvent(initTime);
+        instance.sendSdkInitAndUsageStatsEvent(initTime);
         return instance;
     }
 }
-

src/main/java/com/vwo/VWOClient.java

@@ -63,6 +63,9 @@ public VWOClient(String settings, VWOBuilder vwoBuilder) {
             if (vwoBuilder.getBatchEventQueue() != null) {
                 vwoBuilder.getBatchEventQueue().setSettings(this.processedSettings);
             }
+            if (!DataTypeUtil.isNull(this.processedSettings.getCollectionPrefix()) && !this.processedSettings.getCollectionPrefix().isEmpty()) {
+                this.vwoBuilder.getSettingsManager().collectionPrefix = this.processedSettings.getCollectionPrefix();
+            }
             SettingsUtil.processSettings(this.processedSettings, this.vwoBuilder.getLoggerService());
         } catch (Exception exception) {
            System.err.println("exception occurred while parsing settings " + exception.getMessage());
@@ -73,7 +76,7 @@ public VWOClient(String settings, VWOBuilder vwoBuilder) {
      * This method is used to send the sdk init event
      * @param settingsInitTime The time taken to initialize the settings
      */
-    protected void sendSdkInitEvent(long settingsInitTime) {
+    protected void sendSdkInitAndUsageStatsEvent(long settingsInitTime) {
         try {
             if ( this.processedSettings == null ) {
                 throw new IllegalStateException("processedSettings is null");
@@ -89,6 +92,12 @@ protected void sendSdkInitEvent(long settingsInitTime) {
                     EventUtil.sendSdkInitEvent(this.vwoBuilder.getSettingsManager(), this.vwoBuilder.getSettingsManager().settingsFetchTime, settingsInitTime, EventEnum.VWO_SDK_INIT_EVENT.getValue());
                 }
             }
+
+            // get usage stats account id from settings
+            Integer usageStatsAccountId = this.processedSettings.getUsageStatsAccountId();
+            if (!DataTypeUtil.isNull(usageStatsAccountId) && usageStatsAccountId != 0) {
+                EventUtil.sendUsageStatsEvent(this.vwoBuilder.getSettingsManager(), usageStatsAccountId);
+            }
         } catch (Exception exception) {
             vwoBuilder.getLoggerService().log(LogLevelEnum.ERROR, "SDK_INIT_EVENT_FAILED", new HashMap<String, Object>() {{
                 put("err", exception.getMessage());

src/main/java/com/vwo/constants/Constants.java

@@ -28,7 +28,7 @@ public class Constants {
   public static final int DEFAULT_REQUEST_TIME_INTERVAL = 600; // 10 * 60(secs) = 600 secs i.e. 10 minutes
   public static final int DEFAULT_EVENTS_PER_REQUEST = 100;
   public static final String SDK_NAME = "vwo-fme-java-sdk";
-  public static final String SDK_VERSION = "1.14.0";
+  public static final String SDK_VERSION = "1.15.0";
   public static final long SETTINGS_EXPIRY = 10000000;
   public static final long SETTINGS_TIMEOUT = 50000;
 

src/main/java/com/vwo/enums/EventEnum.java

@@ -20,7 +20,8 @@ public enum EventEnum {
     VWO_SYNC_VISITOR_PROP("vwo_syncVisitorProp"),
     VWO_SDK_INIT_EVENT("vwo_fmeSdkInit"),
     VWO_ERROR("vwo_log"),
-    VWO_DEBUGGER_EVENT("vwo_sdkDebug");
+    VWO_DEBUGGER_EVENT("vwo_sdkDebug"),
+    VWO_USAGE_STATS("vwo_sdkUsageStats");
 
     private final String value;
 

src/main/java/com/vwo/models/Settings.java

@@ -29,6 +29,8 @@ public class Settings {
     private List<Feature> features;
     @JsonProperty("accountId")
     private Integer accountId;
+    @JsonProperty("usageStatsAccountId")
+    private Integer usageStatsAccountId;
     @JsonProperty("groups")
     private Map<String, Groups> groups;
     @JsonProperty("campaignGroups")
@@ -69,6 +71,14 @@ public void setAccountId(Integer accountId) {
         this.accountId = accountId;
     }
 
+    public Integer getUsageStatsAccountId() {
+        return usageStatsAccountId;
+    }
+
+    public void setUsageStatsAccountId(Integer usageStatsAccountId) {
+        this.usageStatsAccountId = usageStatsAccountId;
+    }
+
     public Map<String, Groups> getGroups() {
         return groups;
     }

src/main/java/com/vwo/services/BatchEventQueue.java

@@ -68,6 +68,7 @@ public void setSettings(Settings settings) {
     public void enqueue(EventArchPayload eventData) {
         synchronized (LockObject) {
             Map<String, Object> payload = VWOClient.objectMapper.convertValue(eventData, Map.class);
+            payload = NetworkUtil.removeNullValues(payload);
             batchQueue.add(payload);
             loggerService.log(LogLevelEnum.DEBUG, "Event added to queue. Current queue size: " + batchQueue.size());
 

src/main/java/com/vwo/services/SettingsManager.java

@@ -48,6 +48,7 @@ public class SettingsManager {
     public boolean isSettingsValidOnInit = false;
     public Long settingsFetchTime;
     public LoggerService loggerService;
+    public String collectionPrefix = "";
 
     public SettingsManager(VWOInitOptions options, LoggerService loggerService) {
         this.loggerService = loggerService;

src/main/java/com/vwo/utils/EventUtil.java

@@ -16,6 +16,7 @@
 package com.vwo.utils;
 
 import com.vwo.services.SettingsManager;
+import com.vwo.enums.EventEnum;
 
 import java.util.Map;
 
@@ -52,4 +53,30 @@ public static void sendSdkInitEvent(SettingsManager settingsManager, Long settin
          // Send the event immediately
          NetworkUtil.sendEventDirectlyToDacdn(settingsManager, properties, payload, eventName);
     }
+
+     /**
+     * Sends usage stats event
+     * This event is triggered when the usage stats is called.
+     * 
+     * @param usageStatsAccountId The account ID of the usage stats account.
+     */
+     public static void sendUsageStatsEvent(SettingsManager settingsManager, Integer usageStatsAccountId) {
+        // Create event properties
+        Map<String, String> properties = NetworkUtil.getEventsBaseProperties(
+            EventEnum.VWO_USAGE_STATS.getValue(),
+            null,
+            null,
+            usageStatsAccountId
+        );
+
+        // Create payload for usage stats event
+        Map<String, Object> payload = NetworkUtil.getUsageStatsPayloadData(
+            settingsManager,
+            EventEnum.VWO_USAGE_STATS.getValue(),
+            usageStatsAccountId
+        );
+
+        // Send the event immediately
+        NetworkUtil.sendEventDirectlyToDacdn(settingsManager, properties, payload, EventEnum.VWO_USAGE_STATS.getValue());
+    }
 }