Enhance Gmail component with thread message listing functionality

components/gmail/actions/list-thread-messages/list-thread-messages.mjs

@@ -0,0 +1,34 @@
+import gmail from "../../gmail.app.mjs";
+
+export default {
+  key: "gmail-list-thread-messages",
+  name: "List Thread Messages",
+  description: "List messages in a thread. [See the docs](https://developers.google.com/workspace/gmail/api/reference/rest/v1/users.threads/get)",
+  version: "0.0.1",
+  annotations: {
+    destructiveHint: false,
+    openWorldHint: true,
+    readOnlyHint: true,
+  },
+  type: "action",
+  props: {
+    gmail,
+    threadId: {
+      propDefinition: [
+        gmail,
+        "threadId",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const { messages = [] } = await this.gmail.getThread({
+      threadId: this.threadId,
+    });
+
+    const suffix = messages.length === 1
+      ? ""
+      : "s";
+    $.export("$summary", `Successfully listed ${messages.length} message${suffix}`);
+    return messages;
+  },
+};

components/gmail/gmail.app.mjs

@@ -3,12 +3,12 @@ import {
   axios,
   ConfigurationError,
 } from "@pipedream/platform";
+import { JWT } from "google-auth-library";
 import { convert } from "html-to-text";
 import mime from "mime/types/standard.js";
-import MailComposer from "nodemailer/lib/mail-composer/index.js";
 import addressparser from "nodemailer/lib/addressparser/index.js";
+import MailComposer from "nodemailer/lib/mail-composer/index.js";
 import constants from "./common/constants.mjs";
-import { JWT } from "google-auth-library";
 
 export default {
   type: "app",
@@ -166,6 +166,33 @@ export default {
         }
       },
     },
+    threadId: {
+      type: "string",
+      label: "Thread ID",
+      description: "Identifier of the thread to list messages from",
+      async options({ prevContext }) {
+        try {
+          const {
+            threads, nextPageToken,
+          } = await this.listThreads({
+            pageToken: prevContext?.nextPageToken,
+          });
+          return {
+            options: threads.map(({
+              id: value, snippet: label,
+            }) => ({
+              value,
+              label,
+            })),
+            context: {
+              nextPageToken,
+            },
+          };
+        } catch {
+          return [];
+        }
+      },
+    },
     q: {
       type: "string",
       label: "Search Query",
@@ -421,6 +448,20 @@ export default {
       });
       return data;
     },
+    async listThreads(opts = {}) {
+      const { data } = await this._client().users.threads.list({
+        userId: constants.USER_ID,
+        ...opts,
+      });
+      return data;
+    },
+    async getThread({ threadId }) {
+      const { data } = await this._client().users.threads.get({
+        userId: constants.USER_ID,
+        id: threadId,
+      });
+      return data;
+    },
     async getProfile() {
       const { data } = await this._client().users.getProfile({
         userId: constants.USER_ID,

components/gmail/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/gmail",
-  "version": "1.3.5",
+  "version": "1.4.0",
   "description": "Pipedream Gmail Components",
   "main": "gmail.app.mjs",
   "keywords": [