Initial shared webhook with 3 sources

Author: GTFalcao

components/salesforge/salesforge.app.mjs

@@ -1,11 +1,62 @@
+import { axios } from "@pipedream/platform";
+
 export default {
   type: "app",
   app: "salesforge",
-  propDefinitions: {},
+  propDefinitions: {
+    workspaceId: {
+      type: "string",
+      label: "Workspace ID",
+      description: "Select a workspace or provide a workspace ID",
+      async options() {
+        const workspaces = await this.listWorkspaces();
+        return workspaces?.map((workspace) => ({
+          label: workspace.name,
+          value: workspace.id,
+        }));
+      },
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    _apiUrl() {
+      return "https://api.salesforge.ai/public/v2";
+    },
+    async _makeRequest({
+      $ = this,
+      path,
+      ...args
+    }) {
+      return axios($, {
+        url: `${this._apiUrl()}${path}`,
+        headers: {
+          "authorization": `${this.$auth.api_key}`,
+        },
+        ...args,
+      });
+    },
+    async listWorkspaces(args = {}) {
+      return this._makeRequest({
+        path: "/workspaces",
+        ...args,
+      });
+    },
+    async createWebhook({
+      workspaceId, ...args
+    }) {
+      return this._makeRequest({
+        path: `/workspaces/${workspaceId}/integrations/webhooks`,
+        method: "POST",
+        ...args,
+      });
+    },
+    async deleteWebhook({
+      workspaceId, webhookId, ...args
+    }) {
+      return this._makeRequest({
+        path: `/workspaces/${workspaceId}/integrations/webhooks/${webhookId}`,
+        method: "DELETE",
+        ...args,
+      });
     },
   },
 };

components/salesforge/sources/common/webhook.mjs

@@ -0,0 +1,61 @@
+import { v4 as uuid } from "uuid";
+import salesforge from "../../salesforge.app.mjs";
+
+export default {
+  props: {
+    salesforge,
+    db: "$.service.db",
+    http: "$.interface.http",
+    workspaceId: {
+      propDefinition: [
+        salesforge,
+        "workspaceId",
+      ],
+    },
+  },
+  methods: {
+    _getWebhookId() {
+      return this.db.get("webhookId");
+    },
+    _setWebhookId(webhookId) {
+      this.db.set("webhookId", webhookId);
+    },
+    generateMeta(data) {
+      const { id } = data;
+      return {
+        id: id || uuid(),
+        summary: this.getSummary(data),
+        ts: Date.now(),
+      };
+    },
+  },
+  hooks: {
+    async activate() {
+      const response = await this.salesforge.createWebhook({
+        workspaceId: this.workspaceId,
+        data: {
+          name: `Pipedream ${this.getEventType()} webhook`,
+          type: this.getEventType(),
+          url: this.http.endpoint,
+        },
+      });
+      this._setWebhookId(response.id);
+    },
+    async deactivate() {
+      const webhookId = this._getWebhookId();
+      if (webhookId) {
+        await this.salesforge.deleteWebhook({
+          workspaceId: this.workspaceId,
+          webhookId,
+        });
+      }
+    },
+  },
+  async run(event) {
+    const { body } = event;
+    if (body) {
+      const meta = this.generateMeta(body);
+      this.$emit(body, meta);
+    }
+  },
+};

components/salesforge/sources/email-opened-instant/email-opened-instant.mjs

@@ -0,0 +1,20 @@
+import common from "../common/webhook.mjs";
+
+export default {
+  ...common,
+  key: "salesforge-email-opened-instant",
+  name: "Email Opened (Instant)",
+  description: "Emit new event when an email is opened in Salesforge. [See the documentation](https://api.salesforge.ai/public/v2/swagger/index.html)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    getEventType() {
+      return "email_opened";
+    },
+    getSummary(data) {
+      return `Email opened: ${data.name || data.id}`;
+    },
+  },
+};

components/salesforge/sources/email-sent-instant/email-sent-instant.mjs

@@ -0,0 +1,20 @@
+import common from "../common/webhook.mjs";
+
+export default {
+  ...common,
+  key: "salesforge-email-sent-instant",
+  name: "Email Sent (Instant)",
+  description: "Emit new event when an email is sent in Salesforge. [See the documentation](https://api.salesforge.ai/public/v2/swagger/index.html)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    getEventType() {
+      return "email_sent";
+    },
+    getSummary(data) {
+      return `Email sent: ${data.name || data.id}`;
+    },
+  },
+};

components/salesforge/sources/link-clicked-instant/link-clicked-instant.mjs

@@ -0,0 +1,20 @@
+import common from "../common/webhook.mjs";
+
+export default {
+  ...common,
+  key: "salesforge-link-clicked-instant",
+  name: "Link Clicked (Instant)",
+  description: "Emit new event when a link is clicked in Salesforge. [See the documentation](https://api.salesforge.ai/public/v2/swagger/index.html)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    getEventType() {
+      return "link_clicked";
+    },
+    getSummary(data) {
+      return `Link clicked: ${data.name || data.url || data.id}`;
+    },
+  },
+};