Prepended "iglu://" to schema fields

Author: fblundun

snowplow_tracker/emitters.py

@@ -34,7 +34,7 @@
 
 DEFAULT_MAX_LENGTH = 10
 THREAD_TIMEOUT = 10
-PAYLOAD_DATA_SCHEMA = "com.snowplowanalytics/payload_data/jsonschema/1-0-0"
+PAYLOAD_DATA_SCHEMA = "iglu://com.snowplowanalytics/payload_data/jsonschema/1-0-0"
 
 new_contract("protocol", lambda x: x == "http" or x == "https")
 

snowplow_tracker/test/integration/test_integration.py

@@ -128,51 +128,51 @@ def test_integration_struct_event(self):
     def test_integration_unstruct_event_non_base64(self):
         t = tracker.Tracker(default_emitter, default_subject, encode_base64=False)
         with HTTMock(pass_response_content):
-            t.track_unstruct_event({"schema": "com.acme/viewed_product/jsonschema/2-0-2", "data": {"product_id": "ASO01043", "price$flt": 49.95, "walrus$tms": 1000}})
+            t.track_unstruct_event({"schema": "iglu://com.acme/viewed_product/jsonschema/2-0-2", "data": {"product_id": "ASO01043", "price$flt": 49.95, "walrus$tms": 1000}})
         expected_fields = {"e": "ue"}
         for key in expected_fields:
             self.assertEquals(from_querystring(key, querystrings[-1]), expected_fields[key])
         envelope_string = from_querystring("ue_pr", querystrings[-1])
         envelope = json.loads(unquote_plus(envelope_string))
         self.assertEquals(envelope, {
-            "schema": "com.snowplowanalytics/unstruct_event/jsonschema/1-0-0",
-            "data": {"schema": "com.acme/viewed_product/jsonschema/2-0-2", "data": {"product_id": "ASO01043", "price$flt": 49.95, "walrus$tms": 1000}}
+            "schema": "iglu://com.snowplowanalytics/unstruct_event/jsonschema/1-0-0",
+            "data": {"schema": "iglu://com.acme/viewed_product/jsonschema/2-0-2", "data": {"product_id": "ASO01043", "price$flt": 49.95, "walrus$tms": 1000}}
         })
 
     def test_integration_unstruct_event_base64(self):
         t = tracker.Tracker(default_emitter, default_subject, encode_base64=True)
         with HTTMock(pass_response_content):
-            t.track_unstruct_event({"schema": "com.acme/viewed_product/jsonschema/2-0-2", "data": {"product_id": "ASO01043", "price$flt": 49.95, "walrus$tms": 1000}})
+            t.track_unstruct_event({"schema": "iglu://com.acme/viewed_product/jsonschema/2-0-2", "data": {"product_id": "ASO01043", "price$flt": 49.95, "walrus$tms": 1000}})
         expected_fields = {"e": "ue"}
         for key in expected_fields:
             self.assertEquals(from_querystring(key, querystrings[-1]), expected_fields[key])
         envelope_string = from_querystring("ue_px", querystrings[-1])
         envelope = json.loads((base64.urlsafe_b64decode(bytearray(envelope_string, "utf-8"))).decode("utf-8"))
         self.assertEquals(envelope, {
-            "schema": "com.snowplowanalytics/unstruct_event/jsonschema/1-0-0",
-            "data": {"schema": "com.acme/viewed_product/jsonschema/2-0-2", "data": {"product_id": "ASO01043", "price$flt": 49.95, "walrus$tms": 1000}}
+            "schema": "iglu://com.snowplowanalytics/unstruct_event/jsonschema/1-0-0",
+            "data": {"schema": "iglu://com.acme/viewed_product/jsonschema/2-0-2", "data": {"product_id": "ASO01043", "price$flt": 49.95, "walrus$tms": 1000}}
         })
 
     def test_integration_context_non_base64(self):
         t = tracker.Tracker(default_emitter, default_subject, encode_base64=False)
         with HTTMock(pass_response_content):
-            t.track_page_view("localhost", "local host", None, [{"schema": "com.example/user/jsonschema/2-0-3", "data": {"user_type": "tester"}}])
+            t.track_page_view("localhost", "local host", None, [{"schema": "iglu://com.example/user/jsonschema/2-0-3", "data": {"user_type": "tester"}}])
         envelope_string = from_querystring("co", querystrings[-1])
         envelope = json.loads(unquote_plus(envelope_string))
         self.assertEquals(envelope, {
-            "schema": "com.snowplowanalytics/contexts/jsonschema/1-0-0",
-            "data":[{"schema": "com.example/user/jsonschema/2-0-3", "data": {"user_type": "tester"}}]
+            "schema": "iglu://com.snowplowanalytics/contexts/jsonschema/1-0-0",
+            "data":[{"schema": "iglu://com.example/user/jsonschema/2-0-3", "data": {"user_type": "tester"}}]
         })
 
     def test_integration_context_base64(self):
         t = tracker.Tracker(default_emitter, default_subject, encode_base64=True)
         with HTTMock(pass_response_content):
-            t.track_page_view("localhost", "local host", None, [{"schema": "com.example/user/jsonschema/2-0-3", "data": {"user_type": "tester"}}])
+            t.track_page_view("localhost", "local host", None, [{"schema": "iglu://com.example/user/jsonschema/2-0-3", "data": {"user_type": "tester"}}])
         envelope_string = from_querystring("cx", querystrings[-1])
         envelope = json.loads((base64.urlsafe_b64decode(bytearray(envelope_string, "utf-8"))).decode("utf-8"))
         self.assertEquals(envelope, {
-            "schema": "com.snowplowanalytics/contexts/jsonschema/1-0-0",
-            "data":[{"schema": "com.example/user/jsonschema/2-0-3", "data": {"user_type": "tester"}}]
+            "schema": "iglu://com.snowplowanalytics/contexts/jsonschema/1-0-0",
+            "data":[{"schema": "iglu://com.example/user/jsonschema/2-0-3", "data": {"user_type": "tester"}}]
         })
 
     def test_integration_standard_nv_pairs(self):

snowplow_tracker/tracker.py

@@ -33,8 +33,8 @@
 DEFAULT_ENCODE_BASE64 = True
 SNOWPLOW_VENDOR = "com.snowplowanalytics"
 SCHEMA_TAG = "jsonschema"
-CONTEXT_SCHEMA = "com.snowplowanalytics/contexts/%s/1-0-0" % SCHEMA_TAG
-UNSTRUCT_EVENT_SCHEMA = "com.snowplowanalytics/unstruct_event/%s/1-0-0" % SCHEMA_TAG
+CONTEXT_SCHEMA = "iglu://com.snowplowanalytics/contexts/%s/1-0-0" % SCHEMA_TAG
+UNSTRUCT_EVENT_SCHEMA = "iglu://com.snowplowanalytics/unstruct_event/%s/1-0-0" % SCHEMA_TAG
 
 
 """