Add id support to customer and anonymous events

lib/customerio/client.rb

@@ -170,6 +170,7 @@ def create_anonymous_event(anonymous_id, event_name, attributes = {})
     def create_event(url:, event_name:, anonymous_id: nil, attributes: {})
       body = { :name => event_name, :data => attributes }
       body[:timestamp] = attributes[:timestamp] if valid_timestamp?(attributes[:timestamp])
+      body[:id] = attributes[:id] if valid_ulid?(attributes[:id])
       body[:anonymous_id] = anonymous_id unless is_empty?(anonymous_id)
 
       @client.request_and_verify_response(:post, url, body)
@@ -179,6 +180,10 @@ def valid_timestamp?(timestamp)
       timestamp && timestamp.is_a?(Integer) && timestamp > 999999999 && timestamp < 100000000000
     end
 
+    def valid_ulid?(id)
+      id && id.is_a?(String) && id.length == 26
+    end
+
     def is_empty?(val)
       val.nil? || (val.is_a?(String) && val.strip == "")
     end

spec/client_spec.rb

@@ -382,6 +382,54 @@ def json(data)
       client.track(5, "purchase", type: "socks", price: "13.99", timestamp: "Hello world")
     end
 
+    it "allows sending of an id" do
+      stub_request(:post, api_uri('/api/v1/customers/5/events')).
+        with(body: json({
+          name: "purchase",
+          data: {
+            type: "socks",
+            price: "13.99",
+            id: "01G653VCS2Z4KQYQJCBVVB2CCW"
+          },
+          id: "01G653VCS2Z4KQYQJCBVVB2CCW"
+        })).
+        to_return(status: 200, body: "", headers: {})
+
+      client.track(5, "purchase", type: "socks", price: "13.99", id: "01G653VCS2Z4KQYQJCBVVB2CCW")
+    end
+
+    it "doesn't send id if id isn't a string" do
+      stub_request(:post, api_uri('/api/v1/customers/5/events')).
+        with(body: json({
+          name: "purchase",
+          data: {
+            type: "socks",
+            price: "13.99",
+            id: 1234
+          }
+        })).
+
+        to_return(status: 200, body: "", headers: {})
+
+      client.track(5, "purchase", type: "socks", price: "13.99", id: 1234)
+    end
+
+    it "doesn't send id if id isn't a ULID" do
+      stub_request(:post, api_uri('/api/v1/customers/5/events')).
+        with(body: json({
+          name: "purchase",
+          data: {
+            type: "socks",
+            price: "13.99",
+            id: "1234"
+          }
+        })).
+
+        to_return(status: 200, body: "", headers: {})
+
+      client.track(5, "purchase", type: "socks", price: "13.99", id: "1234")
+    end
+
     context "tracking an anonymous event" do
       let(:anon_id) { "anon-id" }
 
@@ -425,6 +473,23 @@ def json(data)
         client.track_anonymous(anon_id, "purchase", type: "socks", price: "13.99", timestamp: 1561231234)
       end
 
+      it "allows sending of an id" do
+        stub_request(:post, api_uri('/api/v1/events')).
+          with(body: {
+            anonymous_id: anon_id,
+            name: "purchase",
+            data: {
+              type: "socks",
+              price: "13.99",
+              id: "01G653VCS2Z4KQYQJCBVVB2CCW"
+            },
+            id: "01G653VCS2Z4KQYQJCBVVB2CCW"
+          }).
+          to_return(status: 200, body: "", headers: {})
+
+        client.track_anonymous(anon_id, "purchase", type: "socks", price: "13.99", id: "01G653VCS2Z4KQYQJCBVVB2CCW")
+      end
+
       it "raises an error if POST doesn't return a 2xx response code" do
           stub_request(:post, api_uri('/api/v1/events')).
             with(body: { anonymous_id: anon_id, name: "purchase", data: {} }).