Ditlead new components (#16565)

* Package version

* Base and generic webhook source

* List Campaigns action

* add newline

* pnpm

Author: GTFalcao

components/catch_all_verifier/catch_all_verifier.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/ditlead/actions/list-campaigns/list-campaigns.mjs

@@ -0,0 +1,20 @@
+import ditlead from "../../ditlead.app.mjs";
+
+export default {
+  key: "ditlead-list-campaigns",
+  name: "List Campaigns",
+  description: "List campaigns in Ditlead. [See the documentation](https://ditlead.com/developer/api#tag/Campaign/paths/~1v1~1campaign/get)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    ditlead,
+  },
+  async run({ $ }) {
+    const { data } = await this.ditlead.listCampaigns({
+      $,
+    });
+
+    $.export("$summary", `Successfully listed ${data.length} campaigns`);
+    return data;
+  },
+};

components/ditlead/common/constants.mjs

@@ -0,0 +1,18 @@
+export const WEBHOOK_EVENT_TYPES = [
+  "email.bounced",
+  "email.opened",
+  "contact.replied",
+  "contact.created",
+  "contact.contacted",
+  "contact.started_campaign",
+  "contact.restarted_campaign",
+  "contact.completed_campaign",
+  "contact.unsubscribed",
+  "campaign.scheduled",
+  "campaign.started",
+  "campaign.paused",
+  "campaign.restarted",
+  "campaign.completed",
+  "campaign.limit",
+  "campaign.errored",
+];

components/ditlead/ditlead.app.mjs

@@ -1,11 +1,41 @@
+import { axios } from "@pipedream/platform";
+
 export default {
   type: "app",
   app: "ditlead",
   propDefinitions: {},
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    _makeRequest({
+      $, headers, ...args
+    }) {
+      return axios($, {
+        baseURL: "https://api.ditlead.com/v1",
+        headers: {
+          ...headers,
+          Authorization: `Bearer ${this.$auth.api_key}`,
+        },
+        ...args,
+      });
+    },
+    createWebhook(args) {
+      return this._makeRequest({
+        method: "POST",
+        url: "/webhook",
+        ...args,
+      });
+    },
+    deleteWebhook(args) {
+      return this._makeRequest({
+        method: "DELETE",
+        url: "/webhook",
+        ...args,
+      });
+    },
+    listCampaigns(args) {
+      return this._makeRequest({
+        url: "/campaign",
+        ...args,
+      });
     },
   },
-};
+};

components/ditlead/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/ditlead",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream DitLead Components",
   "main": "ditlead.app.mjs",
   "keywords": [
@@ -11,5 +11,8 @@
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "3.0.3"
   }
-}
+}

components/ditlead/sources/common/base.mjs

@@ -0,0 +1,49 @@
+import ditlead from "../../ditlead.app.mjs";
+
+export default {
+  props: {
+    ditlead,
+    db: "$.service.db",
+    http: "$.interface.http",
+  },
+  hooks: {
+    async activate() {
+      const { id } = await this.ditlead.createWebhook({
+        data: {
+          url: this.http.endpoint,
+          name: "Pipedream Source",
+          eventId: this.getEventTypes(),
+        },
+      });
+      this._setWebhookId(id);
+    },
+    async deactivate() {
+      await this.ditlead.deleteWebhook({
+        data: {
+          subscriptionId: this._getWebhookId(),
+        },
+      });
+    },
+  },
+  methods: {
+    getEventTypes() {
+      throw new Error("Event types not specified for this component");
+    },
+    _setWebhookId(value) {
+      this.db.set("webhookId", value);
+    },
+    _getWebhookId() {
+      return this.db.get("webhookId");
+    },
+
+  },
+  async run(event) {
+    const { body } = event;
+    const ts = Date.now();
+    this.$emit(body, {
+      id: ts,
+      summary: "New event",
+      ts,
+    });
+  },
+};

components/ditlead/sources/new-webhook-event/new-webhook-event.mjs

@@ -0,0 +1,27 @@
+import common from "../common/base.mjs";
+import { WEBHOOK_EVENT_TYPES } from "../../common/constants.mjs";
+
+export default {
+  ...common,
+  key: "ditlead-new-webhook-event",
+  name: "New Webhook Event",
+  description: "Emit new events according to the selected event types. [See the documentation](https://ditlead.com/developer/api#tag/Webhook/paths/~1v1~1webhook/post)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    ...common.props,
+    eventTypes: {
+      type: "string[]",
+      label: "Event Types",
+      description: "Select one or more event types to listen for.",
+      options: WEBHOOK_EVENT_TYPES,
+    },
+  },
+  methods: {
+    ...common.methods,
+    getEventTypes() {
+      return this.eventTypes;
+    },
+  },
+};

components/membado/membado.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/planpoint/planpoint.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/szybkisms/szybkisms.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};