feat: identify and track for loops

Author: danrowden

src/cdk/v2/destinations/loops/procWorkflow.yaml

@@ -0,0 +1,65 @@
+bindings:
+  - name: EventType
+    path: ../../../../constants
+  - path: ../../bindings/jsontemplate
+    exportAll: true
+  - name: removeUndefinedAndNullValues
+    path: ../../../../v0/util
+
+steps:
+  - name: messageType
+    template: |
+      .message.type.toLowerCase();
+
+  - name: validateInput
+    template: |
+      $.assert(.message.type, "message Type is not present. Aborting message.");
+      $.assert(.message.type in {{$.EventType.([.TRACK, .IDENTIFY])}}, 
+        "message type " + .message.type + " is not supported");
+
+  - name: validateIdentifyEmail
+    condition: $.outputs.messageType === {{$.EventType.IDENTIFY}}
+    template: |
+      console.log(.message.context.traits);
+      $.assert(.message.context.traits.email, "email is required. Aborting");
+
+  - name: validateTrackIdentifier
+    condition: $.outputs.messageType === {{$.EventType.TRACK}}
+    template: |
+      const userId = .message.({{{{$.getGenericPaths("userIdOnly")}}}});
+      $.assert(.message.context.traits?.email || userId,
+        "Either email or userId is required. Aborting");
+
+  - name: validateEventName
+    condition: $.outputs.messageType === {{$.EventType.TRACK}}
+    template: |
+      $.assert(.message.event, "event is required for track call")
+
+  - name: prepareContext
+    template: |
+      $.context.messageType = .message.type.toLowerCase();
+      $.context.payload = {};
+      $.context.finalHeaders = {
+          "authorization": "Bearer " + .destination.Config.apiKey,
+          "content-type": "application/json"
+        };
+
+  - name: identifyPayload
+    condition: $.outputs.messageType === {{$.EventType.IDENTIFY}}
+    template: |
+      $.context.endpoint = "https://app.loops.so/api/v1/contacts/update";
+      const payload = {}
+      Object.assign(payload, .message.context.traits);
+      payload.userId = .message.userId;
+      $.context.payload = payload;
+
+  - name: trackPayload
+    condition: $.outputs.messageType === {{$.EventType.TRACK}}
+    template: |
+      $.context.endpoint = "https://app.loops.so/api/v1/events/send";
+      const payload = {}
+      Object.assign(payload, .message.context.traits);
+      payload.userId = .message.userId;
+      payload.eventName = .message.event;
+      payload.eventProperties = .message.properties;
+      $.context.payload = payload;