TheMagicDrip new components

components/ai_textraction/ai_textraction.app.mjs

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

components/attractwell/attractwell.app.mjs

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

components/deepimage/deepimage.app.mjs

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

components/fluidforms/fluidforms.app.mjs

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

components/gainsight_nxt/gainsight_nxt.app.mjs

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

components/gainsight_px/gainsight_px.app.mjs

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

components/nerv/nerv.app.mjs

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

components/runpod/runpod.app.mjs

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

components/runware/runware.app.mjs

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

components/teach_n_go/teach_n_go.app.mjs

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

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-or-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,
+      };
+    },
+  },
+};