TheMagicDrip new components

components/the_magic_drip/actions/add-lead-to-campaign/add-lead-to-campaign.mjs

@@ -0,0 +1,72 @@
+import app from "../../the_magic_drip.app.mjs";
+
+export default {
+  key: "the_magic_drip-add-lead-to-campaign",
+  name: "Add Lead to Campaign",
+  description: "Add a lead to a campaign. [See the documentation](https://docs.themagicdrip.com/api-reference/endpoint/post-v1campaignleads)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    campaignId: {
+      propDefinition: [
+        app,
+        "campaignId",
+      ],
+    },
+    firstName: {
+      type: "string",
+      label: "First Name",
+      description: "First name of the lead",
+      optional: true,
+    },
+    lastName: {
+      type: "string",
+      label: "Last Name",
+      description: "Last name of the lead",
+    },
+    linkedInPublicUrl: {
+      type: "string",
+      label: "LinkedIn Public URL",
+      description: "LinkedIn public URL of the lead",
+      optional: true,
+    },
+    company: {
+      type: "string",
+      label: "Company",
+      description: "Company of the lead",
+      optional: true,
+    },
+    companyLinkedInUrl: {
+      type: "string",
+      label: "Company LinkedIn URL",
+      description: "LinkedIn URL of the company",
+      optional: true,
+    },
+    customVariables: {
+      type: "object",
+      label: "Custom Variables",
+      description: "More information about the lead",
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const {
+      app, campaignId, ...lead
+    } = this;
+    const response = await app.addLeadToCampaign({
+      $,
+      campaignId,
+      data: {
+        leadsWithCustomVariables: [
+          lead,
+        ],
+      },
+    });
+    $.export(
+      "$summary",
+      `Successfully added lead "${lead.lastName}" to campaign`,
+    );
+    return response;
+  },
+};

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

@@ -0,0 +1,19 @@
+import app from "../../the_magic_drip.app.mjs";
+
+export default {
+  key: "the_magic_drip-list-campaigns",
+  name: "List Campaigns",
+  description: "Retrieve all available campaigns. [See the documentation](https://docs.themagicdrip.com/api-reference/endpoint/get-v1campaign)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+  },
+  async run({ $ }) {
+    const { campaigns } = await this.app.listCampaigns({
+      $,
+    });
+    $.export("$summary", `Sucessfully retrieved ${campaigns?.length ?? 0} campaigns`);
+    return campaigns;
+  },
+};

components/the_magic_drip/actions/list-templates/list-templates.mjs

@@ -0,0 +1,19 @@
+import app from "../../the_magic_drip.app.mjs";
+
+export default {
+  key: "the_magic_drip-list-templates",
+  name: "List Templates",
+  description: "Retrieve all available templates. [See the documentation](https://docs.themagicdrip.com/api-reference/endpoint/get-v1templates)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+  },
+  async run({ $ }) {
+    const { templates } = await this.app.listTemplates({
+      $,
+    });
+    $.export("$summary", `Sucessfully retrieved ${templates?.length ?? 0} templates`);
+    return templates;
+  },
+};

components/the_magic_drip/actions/mark-campaign-active-or-inactive/mark-campaign-active-or-inactive.mjs

@@ -0,0 +1,39 @@
+import app from "../../the_magic_drip.app.mjs";
+
+export default {
+  key: "the_magic_drip-mark-campaign-active-inactive",
+  name: "Mark Campaign Active or Inactive",
+  description: "Marks a campaign as active or inactive. [See the documentation](https://docs.themagicdrip.com/api-reference/endpoint/post-v1campaign-active)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    campaignId: {
+      propDefinition: [
+        app,
+        "campaignId",
+      ],
+    },
+    activate: {
+      type: "boolean",
+      label: "Activate",
+      description: "Set to `true` to activate, or `false` to deactivate the campaign",
+    },
+  },
+  async run({ $ }) {
+    const {
+      campaignId, activate,
+    } = this;
+    const response = await this.app.markCampaignActiveInactive({
+      $,
+      campaignId,
+      activate,
+    });
+
+    $.export("$summary", `Successfully ${activate
+      ? ""
+      : "de"}activated campaign`);
+
+    return response;
+  },
+};

components/the_magic_drip/package.json

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

components/the_magic_drip/sources/common.mjs

@@ -0,0 +1,56 @@
+import app from "../the_magic_drip.app.mjs";
+import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
+
+export default {
+  props: {
+    app,
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
+    db: "$.service.db",
+  },
+  methods: {
+    _getSavedIds() {
+      return this.db.get("savedIds") || [];
+    },
+    _setSavedIds(value) {
+      this.db.set("savedIds", value);
+    },
+    getItemId(item) {
+      return item.id;
+    },
+    getItemMetadata() {
+      return {
+        summary: "New event",
+        ts: Date.now(),
+      };
+    },
+    async getAndProcessData(maxEmits = 0) {
+      const savedIds = this._getSavedIds();
+      const items = await this.getItems();
+
+      items?.filter?.((item) => !savedIds.includes(this.getItemId(item))).forEach((item, index) => {
+        if ((!maxEmits) || (index < maxEmits)) {
+          this.$emit(item, {
+            id: this.getItemId(item),
+            ...this.getItemMetadata(item),
+          });
+        }
+        savedIds.push(this.getItemId(item));
+      });
+
+      this._setSavedIds(savedIds);
+    },
+  },
+  hooks: {
+    async deploy() {
+      await this.getAndProcessData(5);
+    },
+  },
+  async run() {
+    await this.getAndProcessData();
+  },
+};

components/the_magic_drip/sources/new-campaign-created/new-campaign-created.mjs

@@ -0,0 +1,27 @@
+import common from "../common.mjs";
+
+export default {
+  ...common,
+  key: "the_magic_drip-new-campaign-created",
+  name: "New Campaign Created",
+  description: "Emit new event when a campaign is created. [See the documentation](https://docs.themagicdrip.com/api-reference/endpoint/get-v1campaign)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    async getItems() {
+      const { campaigns } = await this.app.listCampaigns();
+      return campaigns;
+    },
+    getItemId(item) {
+      return item.workflowId;
+    },
+    getItemMetadata(item) {
+      return {
+        summary: `New Campaign: ${item.name}`,
+        ts: item.createdAt,
+      };
+    },
+  },
+};

components/the_magic_drip/sources/new-template-created/new-template-created.mjs

@@ -0,0 +1,27 @@
+import common from "../common.mjs";
+
+export default {
+  ...common,
+  key: "the_magic_drip-new-template-created",
+  name: "New Template Created",
+  description: "Emit new event when a template is created. [See the documentation](https://docs.themagicdrip.com/api-reference/endpoint/get-v1templates)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    async getItems() {
+      const { templates } = await this.app.listTemplates();
+      return templates;
+    },
+    getItemId(item) {
+      return item.templateId;
+    },
+    getItemMetadata(item) {
+      return {
+        summary: `New Template: ${item.name}`,
+        ts: item.createdAt,
+      };
+    },
+  },
+};

components/the_magic_drip/the_magic_drip.app.mjs

@@ -1,11 +1,80 @@
+import { axios } from "@pipedream/platform";
+
 export default {
   type: "app",
   app: "the_magic_drip",
-  propDefinitions: {},
+  propDefinitions: {
+    campaignId: {
+      type: "string",
+      label: "Campaign ID",
+      description: "Select a campaign",
+      async options() {
+        const { campaigns } = await this.listCampaigns();
+        return campaigns?.map((campaign) => ({
+          label: campaign.name,
+          value: campaign.workflowId,
+        }));
+      },
+    },
+    linkedinUrl: {
+      type: "string",
+      label: "LinkedIn URL",
+      description: "The LinkedIn URL of the lead",
+      optional: true,
+    },
+    desiredState: {
+      type: "boolean",
+      label: "Desired State",
+      description: "Set to true to activate, false to deactivate the campaign",
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    _baseUrl() {
+      return "https://api.themagicdrip.com/v1";
+    },
+    async _makeRequest({
+      $, path, headers, ...otherOpts
+    } = {}) {
+      return axios($, {
+        ...otherOpts,
+        url: this._baseUrl() + path,
+        headers: {
+          ...headers,
+          "x-api-key": this.$auth.api_key,
+        },
+      });
+    },
+    async listCampaigns(opts = {}) {
+      return this._makeRequest({
+        path: "/campaign",
+        ...opts,
+      });
+    },
+    async addLeadToCampaign({
+      campaignId, ...opts
+    }) {
+      return this._makeRequest({
+        method: "POST",
+        path: `/campaign/leads/${campaignId}`,
+        ...opts,
+      });
+    },
+    async markCampaignActiveInactive({
+      campaignId, activate, ...opts
+    }) {
+      return this._makeRequest({
+        method: "POST",
+        path: `/campaign/${campaignId}/${activate
+          ? "active"
+          : "inactive"}`,
+        ...opts,
+      });
+    },
+    async listTemplates(opts = {}) {
+      return this._makeRequest({
+        path: "/templates",
+        ...opts,
+      });
     },
   },
-};
+};