new components

Author: michelle0927

components/stripo/actions/get-raw-html/get-raw-html.mjs

@@ -0,0 +1,26 @@
+import stripo from "../../stripo.app.mjs";
+
+export default {
+  key: "stripo-get-raw-html",
+  name: "Get Raw HTML & CSS",
+  description: "Retrieves the HTML and CSS code of the selected email message in Stripo. [See the documentation](https://api.stripo.email/reference/getrawemail)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    stripo,
+    emailId: {
+      propDefinition: [
+        stripo,
+        "emailId",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.stripo.getRawHtml({
+      $,
+      emailId: this.emailId,
+    });
+    $.export("$summary", `Successfully retrieved HTML & CSS from email with ID: ${this.emailId}`);
+    return response;
+  },
+};

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

@@ -0,0 +1,26 @@
+import stripo from "../../stripo.app.mjs";
+
+export default {
+  key: "stripo-remove-email",
+  name: "Remove Email",
+  description: "Removes an existing message from the user's project in Stripo. [See the documentation](https://api.stripo.email/reference/deleteemail)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    stripo,
+    emailId: {
+      propDefinition: [
+        stripo,
+        "emailId",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.stripo.removeEmail({
+      $,
+      emailId: this.emailId,
+    });
+    $.export("$summary", `Successfully removed email with ID: ${this.emailId}`);
+    return response;
+  },
+};

components/stripo/actions/search-emails/search-emails.mjs

@@ -0,0 +1,44 @@
+import stripo from "../../stripo.app.mjs";
+
+export default {
+  key: "stripo-search-emails",
+  name: "Search Emails",
+  description: "Searches existing emails by search query in Stripo. [See the documentation](https://api.stripo.email/reference/findemails)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    stripo,
+    query: {
+      propDefinition: [
+        stripo,
+        "query",
+      ],
+    },
+    maxResults: {
+      type: "integer",
+      label: "Max Results",
+      description: "The maximum number of results to return",
+      default: 100,
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const results = this.stripo.paginate({
+      fn: this.stripo.listEmails,
+      params: {
+        queryStr: this.query,
+      },
+      max: this.maxResults,
+    });
+
+    const emails = [];
+    for await (const item of results) {
+      emails.push(item);
+    }
+
+    $.export("$summary", `Successfully retrieved ${emails.length} email${emails.length === 1
+      ? ""
+      : "s"}`);
+    return emails;
+  },
+};

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

@@ -19,10 +19,10 @@ export default {
       },
     },
     query: {
-      type: "string",
-      label: "Query",
-      description: "A query to search for",
-      optional: true,
+      propDefinition: [
+        stripo,
+        "query",
+      ],
     },
   },
   methods: {

components/stripo/stripo.app.mjs

@@ -3,7 +3,32 @@ import { axios } from "@pipedream/platform";
 export default {
   type: "app",
   app: "stripo",
-  propDefinitions: {},
+  propDefinitions: {
+    emailId: {
+      type: "string",
+      label: "Email ID",
+      description: "The identifier of an email",
+      async options({ page }) {
+        const { data } = await this.listEmails({
+          params: {
+            page,
+          },
+        });
+        return data?.map(({
+          emailId: value, name: label,
+        }) => ({
+          value,
+          label,
+        })) || [];
+      },
+    },
+    query: {
+      type: "string",
+      label: "Query",
+      description: "The query to search for",
+      optional: true,
+    },
+  },
   methods: {
     _baseUrl() {
       return "https://my.stripo.email/emailgeneration/v1";
@@ -28,6 +53,23 @@ export default {
         ...opts,
       });
     },
+    getRawHtml({
+      emailId, ...opts
+    }) {
+      return this._makeRequest({
+        path: `/raw-email/${emailId}`,
+        ...opts,
+      });
+    },
+    removeEmail({
+      emailId, ...opts
+    }) {
+      return this._makeRequest({
+        method: "DELETE",
+        path: `/emails/${emailId}`,
+        ...opts,
+      });
+    },
     async *paginate({
       fn, params, max,
     }) {