feat: add preset traffic source attributes

aws-solutions · Apr 10, 2024 · 45d5f29 · 45d5f29
1 parent cd37cc4
commit 45d5f29
Show file tree

Hide file tree

Showing 3 changed files with 108 additions and 2 deletions.
diff --git a/README.md b/README.md
@@ -79,15 +79,24 @@ public void onCreate() {
 }
 ```
 #### 3.2 Initialize the SDK with global attributes and custom configuration
+
+The following example code shows how to add traffic source fields as global attributes when initializing the SDK.
+
 ```java
 import software.aws.solution.clickstream.ClickstreamAnalytics;
 
 public void onCreate() {
     super.onCreate();
     try{
         ClickstreamAttribute globalAttributes = ClickstreamAttribute.builder()
-            .add("_traffic_source_name", "Summer promotion")
-            .add("_traffic_source_medium", "Search engine")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_SOURCE, "amazon")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_MEDIUM, "cpc")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CAMPAIGN, "summer_promotion")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CAMPAIGN_ID, "summer_promotion_01")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_TERM, "running_shoes")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CONTENT, "banner_ad_1")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CLID, "amazon_ad_123")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CLID_PLATFORM, "amazon_ads")
             .build();
         ClickstreamConfiguration configuration = new ClickstreamConfiguration()
             .withAppId("your appId")

diff --git a/clickstream/src/main/java/software/aws/solution/clickstream/ClickstreamAnalytics.java b/clickstream/src/main/java/software/aws/solution/clickstream/ClickstreamAnalytics.java
@@ -326,5 +326,60 @@ public static class Attr {
          * screen unique id.
          */
         public static final String SCREEN_UNIQUE_ID = ReservedAttribute.SCREEN_UNIQUE_ID;
+
+        /**
+         * traffic source source.
+         */
+        public static final String TRAFFIC_SOURCE_SOURCE = "_traffic_source_source";
+
+        /**
+         * traffic source medium.
+         */
+        public static final String TRAFFIC_SOURCE_MEDIUM = "_traffic_source_medium";
+
+        /**
+         * traffic source campaign.
+         */
+        public static final String TRAFFIC_SOURCE_CAMPAIGN = "_traffic_source_campaign";
+
+        /**
+         * traffic source campaign id.
+         */
+        public static final String TRAFFIC_SOURCE_CAMPAIGN_ID = "_traffic_source_campaign_id";
+
+        /**
+         * traffic source term.
+         */
+        public static final String TRAFFIC_SOURCE_TERM = "_traffic_source_term";
+
+        /**
+         * traffic source content.
+         */
+        public static final String TRAFFIC_SOURCE_CONTENT = "_traffic_source_content";
+
+        /**
+         * traffic source clid.
+         */
+        public static final String TRAFFIC_SOURCE_CLID = "_traffic_source_clid";
+
+        /**
+         * traffic source clid platform.
+         */
+        public static final String TRAFFIC_SOURCE_CLID_PLATFORM = "_traffic_source_clid_platform";
+
+        /**
+         * app install channel.
+         */
+        public static final String APP_INSTALL_CHANNEL = "_app_install_channel";
+
+        /**
+         * event value.
+         */
+        public static final String VALUE = "_value";
+
+        /**
+         * event currency.
+         */
+        public static final String CURRENCY = "_currency";
     }
 }
diff --git a/clickstream/src/test/java/software/aws/solution/clickstream/IntegrationTest.java b/clickstream/src/test/java/software/aws/solution/clickstream/IntegrationTest.java
@@ -243,6 +243,8 @@ public void testAddItem() throws Exception {
         ClickstreamEvent event = ClickstreamEvent.builder()
             .name("testItem")
             .add(ClickstreamAnalytics.Item.ITEM_ID, 123)
+            .add(ClickstreamAnalytics.Attr.VALUE, 11000)
+            .add(ClickstreamAnalytics.Attr.CURRENCY, "USD")
             .setItems(new ClickstreamItem[] {item1, item2})
             .build();
         ClickstreamAnalytics.recordEvent(event);
@@ -309,6 +311,46 @@ public void testAddGlobalAttribute() throws Exception {
         }
     }
 
+    /**
+     * test add traffic source attribute.
+     *
+     * @throws Exception exception
+     */
+    @Test
+    public void testAddGlobalAttributeForTrafficSource() throws Exception {
+        ClickstreamAttribute globalAttribute = ClickstreamAttribute.builder()
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_SOURCE, "amazon")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_MEDIUM, "cpc")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CAMPAIGN, "summer_promotion")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CAMPAIGN_ID, "summer_promotion_01")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_TERM, "running_shoes")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CONTENT, "banner_ad_1")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CLID, "amazon_ad_123")
+            .add(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CLID_PLATFORM, "amazon_ads")
+            .add(ClickstreamAnalytics.Attr.APP_INSTALL_CHANNEL, "amazon_store")
+            .build();
+        ClickstreamAnalytics.addGlobalAttributes(globalAttribute);
+        ClickstreamAnalytics.recordEvent("testEvent");
+        assertEquals(1, dbUtil.getTotalNumber());
+        try (Cursor cursor = dbUtil.queryAllEvents()) {
+            cursor.moveToFirst();
+            String eventString = cursor.getString(2);
+            JSONObject jsonObject = new JSONObject(eventString);
+            JSONObject attribute = jsonObject.getJSONObject("attributes");
+            Assert.assertEquals("amazon", attribute.getString(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_SOURCE));
+            Assert.assertEquals("cpc", attribute.getString(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_MEDIUM));
+            Assert.assertEquals("summer_promotion",
+                attribute.getString(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CAMPAIGN));
+            Assert.assertEquals("summer_promotion_01",
+                attribute.getString(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CAMPAIGN_ID));
+            Assert.assertEquals("running_shoes", attribute.getString(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_TERM));
+            Assert.assertEquals("banner_ad_1", attribute.getString(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CONTENT));
+            Assert.assertEquals("amazon_ad_123", attribute.getString(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CLID));
+            Assert.assertEquals("amazon_ads",
+                attribute.getString(ClickstreamAnalytics.Attr.TRAFFIC_SOURCE_CLID_PLATFORM));
+            Assert.assertEquals("amazon_store", attribute.getString(ClickstreamAnalytics.Attr.APP_INSTALL_CHANNEL));
+        }
+    }
 
     /**
      * test add delete global attribute.