Merge branch 'master' into danny/connect-docs-typos

Author: dannyroosevelt

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/guru/.gitignore

@@ -0,0 +1,37 @@
+import guru from "../../guru.app.mjs";
+
+export default {
+  key: "guru-add-tag-to-card",
+  name: "Add Tag to Card",
+  description: "Links an existing tag to a specified card in Guru. [See the documentation](https://developer.getguru.com/reference/getv1cardsgetextendedfact)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    guru,
+    cardId: {
+      propDefinition: [
+        guru,
+        "cardId",
+      ],
+    },
+    tags: {
+      propDefinition: [
+        guru,
+        "tags",
+      ],
+      type: "string",
+      label: "Tag",
+      description: "The ID of the tag to add to the card",
+    },
+  },
+  async run({ $ }) {
+    const response = await this.guru.linkTagToCard({
+      $,
+      cardId: this.cardId,
+      tagId: this.tags,
+    });
+
+    $.export("$summary", `Successfully linked tag ${this.tags} to card ${this.cardId}`);
+    return response;
+  },
+};

components/guru/actions/add-tag-to-card/add-tag-to-card.mjs

@@ -0,0 +1,70 @@
+import { SHARE_STATUS_OPTIONS } from "../../common/constants.mjs";
+import { parseObject } from "../../common/utils.mjs";
+import guru from "../../guru.app.mjs";
+
+export default {
+  key: "guru-create-card",
+  name: "Create Card",
+  description: "Creates a new card on your Guru account. [See the documentation](https://developer.getguru.com/reference/postv1cardscreateextendedfact)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    guru,
+    title: {
+      type: "string",
+      label: "Card Title",
+      description: "The title of the card to create",
+    },
+    content: {
+      type: "string",
+      label: "Content",
+      description: "The content of the card to create",
+    },
+    shareStatus: {
+      type: "string",
+      label: "Share Status",
+      description: "The share status of the card.",
+      options: SHARE_STATUS_OPTIONS,
+      optional: true,
+    },
+    collection: {
+      propDefinition: [
+        guru,
+        "collection",
+      ],
+    },
+    folderIds: {
+      propDefinition: [
+        guru,
+        "folderIds",
+      ],
+    },
+    tags: {
+      propDefinition: [
+        guru,
+        "tags",
+      ],
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const response = await this.guru.createCard({
+      $,
+      data: {
+        preferredPhrase: this.title,
+        content: this.content,
+        shareStatus: this.shareStatus,
+        collection: {
+          id: this.collection,
+        },
+        folderIds: parseObject(this.folderIds),
+        tags: parseObject(this.tags)?.map((item) => ({
+          id: item,
+        })),
+      },
+    });
+
+    $.export("$summary", `Created card "${this.title}" successfully`);
+    return response;
+  },
+};