diff --git a/packages/backend/src/apps/gmail/actions/create-draft/index.js b/packages/backend/src/apps/gmail/actions/create-draft/index.js
new file mode 100644
index 00000000..e42c772a
--- /dev/null
+++ b/packages/backend/src/apps/gmail/actions/create-draft/index.js
@@ -0,0 +1,204 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+ name: 'Create draft',
+ key: 'createDraft',
+ description: 'Create a new draft email message.',
+ arguments: [
+ {
+ label: 'Subject',
+ key: 'subject',
+ type: 'string',
+ required: true,
+ description: '',
+ variables: true,
+ },
+ {
+ label: 'TOs',
+ key: 'tos',
+ type: 'dynamic',
+ required: false,
+ description: '',
+ fields: [
+ {
+ label: 'To',
+ key: 'to',
+ type: 'string',
+ required: false,
+ variables: true,
+ },
+ ],
+ },
+ {
+ label: 'CCs',
+ key: 'ccs',
+ type: 'dynamic',
+ required: false,
+ description: '',
+ fields: [
+ {
+ label: 'CC',
+ key: 'cc',
+ type: 'string',
+ required: false,
+ variables: true,
+ },
+ ],
+ },
+ {
+ label: 'BCCs',
+ key: 'bccs',
+ type: 'dynamic',
+ required: false,
+ description: '',
+ fields: [
+ {
+ label: 'BCC',
+ key: 'bcc',
+ type: 'string',
+ required: false,
+ variables: true,
+ },
+ ],
+ },
+ {
+ label: 'From',
+ key: 'from',
+ type: 'dropdown',
+ required: false,
+ description:
+ 'Select an email address or alias from your Gmail Account. Defaults to the primary email address.',
+ variables: true,
+ source: {
+ type: 'query',
+ name: 'getDynamicData',
+ arguments: [
+ {
+ name: 'key',
+ value: 'listEmails',
+ },
+ ],
+ },
+ },
+ {
+ label: 'From Name',
+ key: 'fromName',
+ type: 'string',
+ required: false,
+ description: '',
+ variables: true,
+ },
+ {
+ label: 'Body Type',
+ key: 'bodyType',
+ type: 'dropdown',
+ required: false,
+ description: '',
+ variables: true,
+ options: [
+ {
+ label: 'plain',
+ value: 'plain',
+ },
+ {
+ label: 'html',
+ value: 'html',
+ },
+ ],
+ },
+ {
+ label: 'Body',
+ key: 'emailBody',
+ type: 'string',
+ required: true,
+ description: '',
+ variables: true,
+ },
+ {
+ label: 'Signature',
+ key: 'signature',
+ type: 'dropdown',
+ required: false,
+ description: '',
+ variables: true,
+ source: {
+ type: 'query',
+ name: 'getDynamicData',
+ arguments: [
+ {
+ name: 'key',
+ value: 'listSignatures',
+ },
+ ],
+ },
+ },
+ ],
+
+ async run($) {
+ const {
+ tos,
+ ccs,
+ bccs,
+ from,
+ fromName,
+ subject,
+ bodyType,
+ emailBody,
+ signature,
+ } = $.step.parameters;
+ const userId = $.auth.data.userId;
+
+ const allTos = tos?.map((entry) => entry.to);
+ const allCcs = ccs?.map((entry) => entry.cc);
+ const allBccs = bccs?.map((entry) => entry.bcc);
+ const contentType =
+ bodyType === 'html'
+ ? 'text/html; charset="UTF-8"'
+ : 'text/plain; charset="UTF-8"';
+
+ const email =
+ 'From: ' +
+ fromName +
+ ' <' +
+ from +
+ '>' +
+ '\r\n' +
+ 'To: ' +
+ allTos.join(',') +
+ '\r\n' +
+ 'Cc: ' +
+ allCcs.join(',') +
+ '\r\n' +
+ 'Bcc: ' +
+ allBccs.join(',') +
+ '\r\n' +
+ 'Subject: ' +
+ subject +
+ '\r\n' +
+ 'Content-Type: ' +
+ contentType +
+ '\r\n' +
+ '\r\n' +
+ emailBody +
+ '\r\n' +
+ '\r\n' +
+ signature;
+
+ const base64EncodedEmailBody = Buffer.from(email).toString('base64');
+
+ const body = {
+ message: {
+ raw: base64EncodedEmailBody,
+ },
+ };
+
+ const { data } = await $.http.post(
+ `/gmail/v1/users/${userId}/drafts`,
+ body
+ );
+
+ $.setActionItem({
+ raw: data,
+ });
+ },
+});
diff --git a/packages/backend/src/apps/gmail/actions/index.js b/packages/backend/src/apps/gmail/actions/index.js
new file mode 100644
index 00000000..28b72220
--- /dev/null
+++ b/packages/backend/src/apps/gmail/actions/index.js
@@ -0,0 +1,7 @@
+import createDraft from './create-draft/index.js';
+import replyToEmail from './reply-to-email/index.js';
+import sendEmail from './send-email/index.js';
+import sendToTrash from './send-to-trash/index.js';
+import starEmail from './star-email/index.js';
+
+export default [createDraft, replyToEmail, sendEmail, sendToTrash, starEmail];
diff --git a/packages/backend/src/apps/gmail/actions/reply-to-email/index.js b/packages/backend/src/apps/gmail/actions/reply-to-email/index.js
new file mode 100644
index 00000000..5585e6b1
--- /dev/null
+++ b/packages/backend/src/apps/gmail/actions/reply-to-email/index.js
@@ -0,0 +1,228 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+ name: 'Reply to email',
+ key: 'replyToEmail',
+ description: 'Respond to an email.',
+ arguments: [
+ {
+ label: 'Thread',
+ key: 'threadId',
+ type: 'dropdown',
+ required: false,
+ description: '',
+ variables: true,
+ source: {
+ type: 'query',
+ name: 'getDynamicData',
+ arguments: [
+ {
+ name: 'key',
+ value: 'listThreads',
+ },
+ ],
+ },
+ },
+ {
+ label: 'TOs',
+ key: 'tos',
+ type: 'dynamic',
+ required: false,
+ description: 'Who will receive this email?',
+ fields: [
+ {
+ label: 'To',
+ key: 'to',
+ type: 'string',
+ required: false,
+ variables: true,
+ },
+ ],
+ },
+ {
+ label: 'CCs',
+ key: 'ccs',
+ type: 'dynamic',
+ required: false,
+ description:
+ 'Who else needs to be included in the CC field of this email?',
+ fields: [
+ {
+ label: 'CC',
+ key: 'cc',
+ type: 'string',
+ required: false,
+ variables: true,
+ },
+ ],
+ },
+ {
+ label: 'BCCs',
+ key: 'bccs',
+ type: 'dynamic',
+ required: false,
+ description:
+ 'Who else needs to be included in the BCC field of this email?',
+ fields: [
+ {
+ label: 'BCC',
+ key: 'bcc',
+ type: 'string',
+ required: false,
+ variables: true,
+ },
+ ],
+ },
+ {
+ label: 'From',
+ key: 'from',
+ type: 'dropdown',
+ required: false,
+ description:
+ 'Choose an email address or alias from your Gmail Account. This defaults to the primary email address.',
+ variables: true,
+ source: {
+ type: 'query',
+ name: 'getDynamicData',
+ arguments: [
+ {
+ name: 'key',
+ value: 'listEmails',
+ },
+ ],
+ },
+ },
+ {
+ label: 'From Name',
+ key: 'fromName',
+ type: 'string',
+ required: false,
+ description: '',
+ variables: true,
+ },
+ {
+ label: 'Reply To',
+ key: 'replyTo',
+ type: 'string',
+ required: false,
+ description: 'Specify a single reply address other than your own.',
+ variables: true,
+ },
+ {
+ label: 'Body Type',
+ key: 'bodyType',
+ type: 'dropdown',
+ required: false,
+ description: '',
+ variables: true,
+ options: [
+ {
+ label: 'plain',
+ value: 'plain',
+ },
+ {
+ label: 'html',
+ value: 'html',
+ },
+ ],
+ },
+ {
+ label: 'Body',
+ key: 'emailBody',
+ type: 'string',
+ required: true,
+ description: '',
+ variables: true,
+ },
+ {
+ label: 'Label',
+ key: 'labelId',
+ type: 'dropdown',
+ required: false,
+ description: '',
+ variables: true,
+ source: {
+ type: 'query',
+ name: 'getDynamicData',
+ arguments: [
+ {
+ name: 'key',
+ value: 'listLabels',
+ },
+ ],
+ },
+ },
+ ],
+
+ async run($) {
+ const {
+ tos,
+ ccs,
+ bccs,
+ from,
+ fromName,
+ replyTo,
+ threadId,
+ bodyType,
+ emailBody,
+ labelId,
+ } = $.step.parameters;
+ const userId = $.auth.data.userId;
+
+ const allTos = tos?.map((entry) => entry.to);
+ const allCcs = ccs?.map((entry) => entry.cc);
+ const allBccs = bccs?.map((entry) => entry.bcc);
+ const contentType =
+ bodyType === 'html'
+ ? 'text/html; charset="UTF-8"'
+ : 'text/plain; charset="UTF-8"';
+
+ const email =
+ 'From: ' +
+ fromName +
+ ' <' +
+ from +
+ '>' +
+ '\r\n' +
+ 'In-Reply-To: ' +
+ threadId +
+ '\r\n' +
+ 'References: ' +
+ threadId +
+ '\r\n' +
+ 'Reply-To: ' +
+ replyTo +
+ '\r\n' +
+ 'To: ' +
+ allTos.join(',') +
+ '\r\n' +
+ 'Cc: ' +
+ allCcs.join(',') +
+ '\r\n' +
+ 'Bcc: ' +
+ allBccs.join(',') +
+ '\r\n' +
+ 'Content-Type: ' +
+ contentType +
+ '\r\n' +
+ '\r\n' +
+ emailBody;
+
+ const base64EncodedEmailBody = Buffer.from(email).toString('base64');
+
+ const body = {
+ threadId: threadId,
+ labelIds: [labelId],
+ raw: base64EncodedEmailBody,
+ };
+
+ const { data } = await $.http.post(
+ `/gmail/v1/users/${userId}/messages/send`,
+ body
+ );
+
+ $.setActionItem({
+ raw: data,
+ });
+ },
+});
diff --git a/packages/backend/src/apps/gmail/actions/send-email/index.js b/packages/backend/src/apps/gmail/actions/send-email/index.js
new file mode 100644
index 00000000..e8101324
--- /dev/null
+++ b/packages/backend/src/apps/gmail/actions/send-email/index.js
@@ -0,0 +1,234 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+ name: 'Send email',
+ key: 'sendEmail',
+ description: 'Send a new email message.',
+ arguments: [
+ {
+ label: 'TOs',
+ key: 'tos',
+ type: 'dynamic',
+ required: false,
+ description: '',
+ fields: [
+ {
+ label: 'To',
+ key: 'to',
+ type: 'string',
+ required: false,
+ variables: true,
+ },
+ ],
+ },
+ {
+ label: 'CCs',
+ key: 'ccs',
+ type: 'dynamic',
+ required: false,
+ description: '',
+ fields: [
+ {
+ label: 'CC',
+ key: 'cc',
+ type: 'string',
+ required: false,
+ variables: true,
+ },
+ ],
+ },
+ {
+ label: 'BCCs',
+ key: 'bccs',
+ type: 'dynamic',
+ required: false,
+ description: '',
+ fields: [
+ {
+ label: 'BCC',
+ key: 'bcc',
+ type: 'string',
+ required: false,
+ variables: true,
+ },
+ ],
+ },
+ {
+ label: 'From',
+ key: 'from',
+ type: 'dropdown',
+ required: false,
+ description:
+ 'Select an email address or alias from your Gmail Account. Defaults to the primary email address.',
+ variables: true,
+ source: {
+ type: 'query',
+ name: 'getDynamicData',
+ arguments: [
+ {
+ name: 'key',
+ value: 'listEmails',
+ },
+ ],
+ },
+ },
+ {
+ label: 'From Name',
+ key: 'fromName',
+ type: 'string',
+ required: false,
+ description: '',
+ variables: true,
+ },
+ {
+ label: 'Reply To',
+ key: 'replyTo',
+ type: 'string',
+ required: false,
+ description: 'Specify a single reply address other than your own.',
+ variables: true,
+ },
+ {
+ label: 'Subject',
+ key: 'subject',
+ type: 'string',
+ required: true,
+ description: '',
+ variables: true,
+ },
+ {
+ label: 'Body Type',
+ key: 'bodyType',
+ type: 'dropdown',
+ required: false,
+ description: '',
+ variables: true,
+ options: [
+ {
+ label: 'plain',
+ value: 'plain',
+ },
+ {
+ label: 'html',
+ value: 'html',
+ },
+ ],
+ },
+ {
+ label: 'Body',
+ key: 'emailBody',
+ type: 'string',
+ required: true,
+ description: '',
+ variables: true,
+ },
+ {
+ label: 'Signature',
+ key: 'signature',
+ type: 'dropdown',
+ required: false,
+ description: '',
+ variables: true,
+ source: {
+ type: 'query',
+ name: 'getDynamicData',
+ arguments: [
+ {
+ name: 'key',
+ value: 'listSignatures',
+ },
+ ],
+ },
+ },
+ {
+ label: 'Label',
+ key: 'labelId',
+ type: 'dropdown',
+ required: false,
+ description: '',
+ variables: true,
+ source: {
+ type: 'query',
+ name: 'getDynamicData',
+ arguments: [
+ {
+ name: 'key',
+ value: 'listLabels',
+ },
+ ],
+ },
+ },
+ ],
+
+ async run($) {
+ const {
+ tos,
+ ccs,
+ bccs,
+ from,
+ fromName,
+ replyTo,
+ subject,
+ bodyType,
+ emailBody,
+ signature,
+ labelId,
+ } = $.step.parameters;
+ const userId = $.auth.data.userId;
+
+ const allTos = tos?.map((entry) => entry.to);
+ const allCcs = ccs?.map((entry) => entry.cc);
+ const allBccs = bccs?.map((entry) => entry.bcc);
+ const contentType =
+ bodyType === 'html'
+ ? 'text/html; charset="UTF-8"'
+ : 'text/plain; charset="UTF-8"';
+
+ const email =
+ 'From: ' +
+ fromName +
+ ' <' +
+ from +
+ '>' +
+ '\r\n' +
+ 'Reply-To: ' +
+ replyTo +
+ '\r\n' +
+ 'To: ' +
+ allTos.join(',') +
+ '\r\n' +
+ 'Cc: ' +
+ allCcs.join(',') +
+ '\r\n' +
+ 'Bcc: ' +
+ allBccs.join(',') +
+ '\r\n' +
+ 'Subject: ' +
+ subject +
+ '\r\n' +
+ 'Content-Type: ' +
+ contentType +
+ '\r\n' +
+ '\r\n' +
+ emailBody +
+ '\r\n' +
+ '\r\n' +
+ signature;
+
+ const base64EncodedEmailBody = Buffer.from(email).toString('base64');
+
+ const body = {
+ labelIds: [labelId],
+ raw: base64EncodedEmailBody,
+ };
+
+ const { data } = await $.http.post(
+ `/gmail/v1/users/${userId}/messages/send`,
+ body
+ );
+
+ $.setActionItem({
+ raw: data,
+ });
+ },
+});
diff --git a/packages/backend/src/apps/gmail/actions/send-to-trash/index.js b/packages/backend/src/apps/gmail/actions/send-to-trash/index.js
new file mode 100644
index 00000000..60587635
--- /dev/null
+++ b/packages/backend/src/apps/gmail/actions/send-to-trash/index.js
@@ -0,0 +1,40 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+ name: 'Send to trash',
+ key: 'sendToTrash',
+ description: 'Send an existing email message to the trash.',
+ arguments: [
+ {
+ label: 'Message ID',
+ key: 'messageId',
+ type: 'dropdown',
+ required: true,
+ description: '',
+ variables: true,
+ source: {
+ type: 'query',
+ name: 'getDynamicData',
+ arguments: [
+ {
+ name: 'key',
+ value: 'listMessages',
+ },
+ ],
+ },
+ },
+ ],
+
+ async run($) {
+ const { messageId } = $.step.parameters;
+ const userId = $.auth.data.userId;
+
+ const { data } = await $.http.post(
+ `/gmail/v1/users/${userId}/messages/${messageId}/trash`
+ );
+
+ $.setActionItem({
+ raw: data,
+ });
+ },
+});
diff --git a/packages/backend/src/apps/gmail/actions/star-email/index.js b/packages/backend/src/apps/gmail/actions/star-email/index.js
new file mode 100644
index 00000000..c7e06bcc
--- /dev/null
+++ b/packages/backend/src/apps/gmail/actions/star-email/index.js
@@ -0,0 +1,45 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+ name: 'Star an email',
+ key: 'starEmail',
+ description: 'Star an email message.',
+ arguments: [
+ {
+ label: 'Message ID',
+ key: 'messageId',
+ type: 'dropdown',
+ required: true,
+ description: '',
+ variables: true,
+ source: {
+ type: 'query',
+ name: 'getDynamicData',
+ arguments: [
+ {
+ name: 'key',
+ value: 'listMessages',
+ },
+ ],
+ },
+ },
+ ],
+
+ async run($) {
+ const { messageId } = $.step.parameters;
+ const userId = $.auth.data.userId;
+
+ const body = {
+ addLabelIds: ['STARRED'],
+ };
+
+ const { data } = await $.http.post(
+ `/gmail/v1/users/${userId}/messages/${messageId}/modify`,
+ body
+ );
+
+ $.setActionItem({
+ raw: data,
+ });
+ },
+});
diff --git a/packages/backend/src/apps/gmail/auth/refresh-token.js b/packages/backend/src/apps/gmail/auth/refresh-token.js
index 7c5b7020..2c137caa 100644
--- a/packages/backend/src/apps/gmail/auth/refresh-token.js
+++ b/packages/backend/src/apps/gmail/auth/refresh-token.js
@@ -12,7 +12,12 @@ const refreshToken = async ($) => {
const { data } = await $.http.post(
'https://oauth2.googleapis.com/token',
- params.toString()
+ params.toString(),
+ {
+ additionalProperties: {
+ skipAddingAuthHeader: true,
+ },
+ }
);
await $.auth.set({
diff --git a/packages/backend/src/apps/gmail/auth/verify-credentials.js b/packages/backend/src/apps/gmail/auth/verify-credentials.js
index a636b72c..8c9b7afe 100644
--- a/packages/backend/src/apps/gmail/auth/verify-credentials.js
+++ b/packages/backend/src/apps/gmail/auth/verify-credentials.js
@@ -36,6 +36,7 @@ const verifyCredentials = async ($) => {
refreshToken: data.refresh_token,
resourceName: currentUser.resourceName,
screenName: `${displayName} - ${email}`,
+ userId: email,
});
};
diff --git a/packages/backend/src/apps/gmail/common/add-auth-header.js b/packages/backend/src/apps/gmail/common/add-auth-header.js
index 02477aa4..f957ebf9 100644
--- a/packages/backend/src/apps/gmail/common/add-auth-header.js
+++ b/packages/backend/src/apps/gmail/common/add-auth-header.js
@@ -1,5 +1,8 @@
const addAuthHeader = ($, requestConfig) => {
- if ($.auth.data?.accessToken) {
+ if (
+ !requestConfig.additionalProperties?.skipAddingAuthHeader &&
+ $.auth.data?.accessToken
+ ) {
requestConfig.headers.Authorization = `${$.auth.data.tokenType} ${$.auth.data.accessToken}`;
}
diff --git a/packages/backend/src/apps/gmail/dynamic-data/index.js b/packages/backend/src/apps/gmail/dynamic-data/index.js
new file mode 100644
index 00000000..37661b45
--- /dev/null
+++ b/packages/backend/src/apps/gmail/dynamic-data/index.js
@@ -0,0 +1,13 @@
+import listEmails from './list-emails/index.js';
+import listLabels from './list-labels/index.js';
+import listMessages from './list-messages/index.js';
+import listSignatures from './list-signatures/index.js';
+import listThreads from './list-threads/index.js';
+
+export default [
+ listEmails,
+ listLabels,
+ listMessages,
+ listSignatures,
+ listThreads,
+];
diff --git a/packages/backend/src/apps/gmail/dynamic-data/list-emails/index.js b/packages/backend/src/apps/gmail/dynamic-data/list-emails/index.js
new file mode 100644
index 00000000..1820a1a1
--- /dev/null
+++ b/packages/backend/src/apps/gmail/dynamic-data/list-emails/index.js
@@ -0,0 +1,23 @@
+import getCurrentUser from '../../common/get-current-user.js';
+
+export default {
+ name: 'List emails',
+ key: 'listEmails',
+
+ async run($) {
+ const emails = {
+ data: [],
+ };
+
+ const currentUser = await getCurrentUser($);
+
+ for (const emailAddress of currentUser.emailAddresses) {
+ emails.data.push({
+ value: emailAddress.value,
+ name: emailAddress.value,
+ });
+ }
+
+ return emails;
+ },
+};
diff --git a/packages/backend/src/apps/gmail/dynamic-data/list-labels/index.js b/packages/backend/src/apps/gmail/dynamic-data/list-labels/index.js
new file mode 100644
index 00000000..65decf94
--- /dev/null
+++ b/packages/backend/src/apps/gmail/dynamic-data/list-labels/index.js
@@ -0,0 +1,22 @@
+export default {
+ name: 'List labels',
+ key: 'listLabels',
+
+ async run($) {
+ const labels = {
+ data: [],
+ };
+ const userId = $.auth.data.userId;
+
+ const { data } = await $.http.get(`/gmail/v1/users/${userId}/labels`);
+
+ for (const label of data.labels) {
+ labels.data.push({
+ value: label.id,
+ name: label.name,
+ });
+ }
+
+ return labels;
+ },
+};
diff --git a/packages/backend/src/apps/gmail/dynamic-data/list-messages/index.js b/packages/backend/src/apps/gmail/dynamic-data/list-messages/index.js
new file mode 100644
index 00000000..077267be
--- /dev/null
+++ b/packages/backend/src/apps/gmail/dynamic-data/list-messages/index.js
@@ -0,0 +1,31 @@
+export default {
+ name: 'List messages',
+ key: 'listMessages',
+
+ async run($) {
+ const messages = {
+ data: [],
+ };
+ const userId = $.auth.data.userId;
+
+ const { data } = await $.http.get(`/gmail/v1/users/${userId}/messages`);
+
+ if (data.messages) {
+ for (const message of data.messages) {
+ const { data: messageData } = await $.http.get(
+ `/gmail/v1/users/${userId}/messages/${message.id}`
+ );
+ const subject = messageData.payload.headers.find(
+ (header) => header.name === 'Subject'
+ );
+
+ messages.data.push({
+ value: message.id,
+ name: subject?.value,
+ });
+ }
+ }
+
+ return messages;
+ },
+};
diff --git a/packages/backend/src/apps/gmail/dynamic-data/list-signatures/index.js b/packages/backend/src/apps/gmail/dynamic-data/list-signatures/index.js
new file mode 100644
index 00000000..dab0b38a
--- /dev/null
+++ b/packages/backend/src/apps/gmail/dynamic-data/list-signatures/index.js
@@ -0,0 +1,24 @@
+export default {
+ name: 'List signatures',
+ key: 'listSignatures',
+
+ async run($) {
+ const signatures = {
+ data: [],
+ };
+ const userId = $.auth.data.userId;
+
+ const { data } = await $.http.get(
+ `/gmail/v1/users/${userId}/settings/sendAs`
+ );
+
+ for (const sendAs of data.sendAs) {
+ signatures.data.push({
+ value: sendAs.signature,
+ name: sendAs.sendAsEmail,
+ });
+ }
+
+ return signatures;
+ },
+};
diff --git a/packages/backend/src/apps/gmail/dynamic-data/list-threads/index.js b/packages/backend/src/apps/gmail/dynamic-data/list-threads/index.js
new file mode 100644
index 00000000..6d40fa2f
--- /dev/null
+++ b/packages/backend/src/apps/gmail/dynamic-data/list-threads/index.js
@@ -0,0 +1,31 @@
+export default {
+ name: 'List threads',
+ key: 'listThreads',
+
+ async run($) {
+ const threads = {
+ data: [],
+ };
+ const userId = $.auth.data.userId;
+
+ const { data } = await $.http.get(`/gmail/v1/users/${userId}/threads`);
+
+ if (data.threads) {
+ for (const thread of data.threads) {
+ const { data: threadData } = await $.http.get(
+ `/gmail/v1/users/${userId}/threads/${thread.id}`
+ );
+ const subject = threadData.messages[0].payload.headers.find(
+ (header) => header.name === 'Subject'
+ );
+
+ threads.data.push({
+ value: thread.id,
+ name: subject?.value,
+ });
+ }
+ }
+
+ return threads;
+ },
+};
diff --git a/packages/backend/src/apps/gmail/index.js b/packages/backend/src/apps/gmail/index.js
index 786e2a1e..ca20b94b 100644
--- a/packages/backend/src/apps/gmail/index.js
+++ b/packages/backend/src/apps/gmail/index.js
@@ -1,6 +1,10 @@
import defineApp from '../../helpers/define-app.js';
import addAuthHeader from './common/add-auth-header.js';
import auth from './auth/index.js';
+import triggers from './triggers/index.js';
+import dynamicData from './dynamic-data/index.js';
+import actions from './actions/index.js';
+
export default defineApp({
name: 'Gmail',
key: 'gmail',
@@ -12,4 +16,7 @@ export default defineApp({
supportsConnections: true,
beforeRequest: [addAuthHeader],
auth,
+ triggers,
+ dynamicData,
+ actions,
});
diff --git a/packages/backend/src/apps/gmail/triggers/index.js b/packages/backend/src/apps/gmail/triggers/index.js
new file mode 100644
index 00000000..3ce85787
--- /dev/null
+++ b/packages/backend/src/apps/gmail/triggers/index.js
@@ -0,0 +1,3 @@
+import newEmails from './new-emails/index.js';
+
+export default [newEmails];
diff --git a/packages/backend/src/apps/gmail/triggers/new-emails/index.js b/packages/backend/src/apps/gmail/triggers/new-emails/index.js
new file mode 100644
index 00000000..1853b049
--- /dev/null
+++ b/packages/backend/src/apps/gmail/triggers/new-emails/index.js
@@ -0,0 +1,68 @@
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+ name: 'New emails',
+ key: 'newEmails',
+ pollInterval: 15,
+ description:
+ 'Triggers when a new email is received in the specified mailbox.',
+ arguments: [
+ {
+ label: 'Label',
+ key: 'labelId',
+ type: 'dropdown',
+ required: false,
+ description:
+ "If you don't choose a label, this event will be triggered for all emails, including Drafts.",
+ variables: true,
+ source: {
+ type: 'query',
+ name: 'getDynamicData',
+ arguments: [
+ {
+ name: 'key',
+ value: 'listLabels',
+ },
+ ],
+ },
+ },
+ ],
+
+ async run($) {
+ const userId = $.auth.data.userId;
+ const labelId = $.step.parameters.labelId;
+
+ const params = {
+ maxResults: 500,
+ pageToken: undefined,
+ };
+
+ if (labelId) {
+ params.labelIds = labelId;
+ }
+
+ do {
+ const { data } = await $.http.get(`/gmail/v1/users/${userId}/messages`, {
+ params,
+ });
+ params.pageToken = data.nextPageToken;
+
+ if (!data?.messages?.length) {
+ return;
+ }
+
+ for (const message of data.messages) {
+ const { data: messageData } = await $.http.get(
+ `/gmail/v1/users/${userId}/messages/${message.id}`
+ );
+
+ $.pushTriggerItem({
+ raw: messageData,
+ meta: {
+ internalId: messageData.id,
+ },
+ });
+ }
+ } while (params.pageToken);
+ },
+});
diff --git a/packages/docs/pages/.vitepress/config.js b/packages/docs/pages/.vitepress/config.js
index a4ba2ef8..62b13e44 100644
--- a/packages/docs/pages/.vitepress/config.js
+++ b/packages/docs/pages/.vitepress/config.js
@@ -218,7 +218,11 @@ export default defineConfig({
text: 'Gmail',
collapsible: true,
collapsed: true,
- items: [{ text: 'Connection', link: '/apps/gmail/connection' }],
+ items: [
+ { text: 'Triggers', link: '/apps/gmail/triggers' },
+ { text: 'Connection', link: '/apps/gmail/connection' },
+ { text: 'Actions', link: '/apps/gmail/actions' },
+ ],
},
{
text: 'Google Calendar',
diff --git a/packages/docs/pages/apps/gmail/actions.md b/packages/docs/pages/apps/gmail/actions.md
new file mode 100644
index 00000000..0754a728
--- /dev/null
+++ b/packages/docs/pages/apps/gmail/actions.md
@@ -0,0 +1,20 @@
+---
+favicon: /favicons/gmail.svg
+items:
+ - name: Create draft
+ desc: Create a new draft email message.
+ - name: Reply to email
+ desc: Respond to an email.
+ - name: Send email
+ desc: Send a new email message.
+ - name: Send to trash
+ desc: Send an existing email message to the trash.
+ - name: Star an email
+ desc: Star an email message.
+---
+
+
+
+
diff --git a/packages/docs/pages/apps/gmail/triggers.md b/packages/docs/pages/apps/gmail/triggers.md
new file mode 100644
index 00000000..49205c51
--- /dev/null
+++ b/packages/docs/pages/apps/gmail/triggers.md
@@ -0,0 +1,12 @@
+---
+favicon: /favicons/gmail.svg
+items:
+ - name: New emails
+ desc: Triggers when a new email is received in the specified mailbox.
+---
+
+
+
+
diff --git a/packages/docs/pages/guide/available-apps.md b/packages/docs/pages/guide/available-apps.md
index 7bb4d57e..bde689dd 100644
--- a/packages/docs/pages/guide/available-apps.md
+++ b/packages/docs/pages/guide/available-apps.md
@@ -22,6 +22,7 @@ The following integrations are currently supported by Automatisch.
- [Ghost](/apps/ghost/triggers)
- [GitHub](/apps/github/triggers)
- [GitLab](/apps/gitlab/triggers)
+- [Gmail](/apps/gmail/triggers)
- [Google Calendar](/apps/google-calendar/triggers)
- [Google Drive](/apps/google-drive/triggers)
- [Google Forms](/apps/google-forms/triggers)