wip

Author: michelle0927

components/stripo/actions/create-email/create-email.mjs

@@ -0,0 +1,84 @@
+import stripo from "../../stripo.app.mjs";
+import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
+import sampleEmit from "./test-event.mjs";
+
+export default {
+  key: "stripo-new-email-created",
+  name: "New Email Created",
+  description: "Emit new event when a new email is created in Stripo. [See the documentation](https://api.stripo.email/reference/findemails)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    stripo,
+    db: "$.service.db",
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
+    query: {
+      type: "string",
+      label: "Query",
+      description: "A query to search for",
+      optional: true,
+    },
+  },
+  methods: {
+    _getLastTs() {
+      return this.db.get("lastTs") || 0;
+    },
+    _setLastTs(lastTs) {
+      this.db.set("lastTs", lastTs);
+    },
+    generateMeta(email) {
+      return {
+        id: email.emailId,
+        summary: `New Email: ${email.name}`,
+        ts: Date.parse(email.updatedTime),
+      };
+    },
+    async processEvent(max) {
+      const lastTs = this._getLastTs();
+
+      const results = this.stripo.paginate({
+        fn: this.stripo.listEmails,
+        params: {
+          queryStr: this.query,
+          sortingColumn: "createdTime",
+          sortingAsc: false,
+        },
+        max,
+      });
+
+      const emails = [];
+      for await (const item of results) {
+        const ts = Date.parse(item.updatedTime);
+        if (ts >= lastTs) {
+          emails.push(item);
+        }
+      }
+
+      if (!emails.length) {
+        return;
+      }
+
+      this._setLastTs(Date.parse(emails[0].updatedTime));
+
+      emails.reverse().forEach((email) => {
+        const meta = this.generateMeta(email);
+        this.$emit(email, meta);
+      });
+    },
+  },
+  hooks: {
+    async deploy() {
+      await this.processEvent(25);
+    },
+  },
+  async run() {
+    await this.processEvent();
+  },
+  sampleEmit,
+};

components/stripo/sources/new-email-created/new-email-created.mjs

@@ -0,0 +1,11 @@
+export default {
+  "emailId": 9031276,
+  "name": "New Message",
+  "editorUrl": "https://my.stripo.email/cabinet/#/template-editor/?emailId=9031276&projectId=1189279&type=EMAIL",
+  "previewUrl": "https://viewstripo.email/575439dc-9d57-4e3f-989e-23a1a63971901738788020521",
+  "updatedTime": "2025-02-05T20:40:34.46",
+  "hasAmp": false,
+  "preheader": null,
+  "title": "",
+  "previewImage": "https://doc.stripocdn.email/content/guids/cabinet-icons/87baef10-e401-11ef-a29e-e99b514f747b.png"
+}

components/stripo/sources/new-email-created/test-event.mjs

@@ -3,24 +3,7 @@ import { axios } from "@pipedream/platform";
 export default {
   type: "app",
   app: "stripo",
-  propDefinitions: {
-    templateId: {
-      type: "string",
-      label: "Template ID",
-      description: "An ID of a template with the auto-generated area. Please note that this template should be yours (saved in the project you have access to), not a basic or a public one.",
-      async options({ page }) {
-        const { data } = await this.listTemplates({
-          params: page,
-        });
-        return data?.map(({
-          templateId: value, name: label,
-        }) => ({
-          value,
-          label,
-        })) || [];
-      },
-    },
-  },
+  propDefinitions: {},
   methods: {
     _baseUrl() {
       return "https://my.stripo.email/emailgeneration/v1";
@@ -34,22 +17,40 @@ export default {
         url: `${this._baseUrl()}${path}`,
         headers: {
           "Stripo-Api-Auth": this.$auth.api_key,
+          "Content-Type": "application/json",
         },
         ...opts,
       });
     },
-    listTemplates(opts = {}) {
+    listEmails(opts = {}) {
       return this._makeRequest({
-        path: "/templates",
+        path: "/emails",
         ...opts,
       });
     },
-    createEmail(opts = {}) {
-      return this._makeRequest({
-        method: "POST",
-        path: "/email",
-        ...opts,
-      });
+    async *paginate({
+      fn, params, max,
+    }) {
+      params = {
+        ...params,
+        page: 0,
+      };
+      let totalResults, count = 0;
+      do {
+        const {
+          data, total,
+        } = await fn({
+          params,
+        });
+        totalResults = total;
+        for (const item of data) {
+          yield item;
+          count++;
+          if (max && count >= max) {
+            return;
+          }
+        }
+      } while (count < totalResults);
     },
   },
 };