使用Gmail API与Nodemailer发送邮件后添加AutoResponse标签失败

问题概述 #

使用Gmail API结合Nodemailer向未读邮件线程发送自动回复，尝试为已回复的线程添加AutoResponse标签时触发400错误，提示Invalid label: SENT。

错误信息 #

error: {
        code: 400,
        message: 'Invalid label: SENT',
        errors: [
          {
            message: 'Invalid label: SENT',
            domain: 'global',
            reason: 'invalidArgument'
          }
        ],
        status: 'INVALID_ARGUMENT'
      }

问题分析 #

1. 自定义标签使用错误：Gmail API不允许直接使用自定义标签的显示名称（如AutoResponse），必须使用标签的唯一ID。错误提示中的SENT大概率是误将系统标签名称当作自定义标签ID传入，或自定义标签ID配置错误。
2. 代码逻辑顺序错误：原代码在判断线程是否需要回复前就调用了threads.modify接口，导致无论是否需要回复都修改了标签。
3. 函数调用错误：原代码将threads.modify的返回值（Promise结果）赋值给addLabelToThread，后续又将其当作函数调用，会引发类型错误。

修复方案 #

步骤1：获取自定义标签ID #

先调用Gmail API的users.labels.list接口获取所有标签，找到AutoResponse标签对应的ID（格式类似Label_1234567890）：

gmail.users.labels.list({ userId: "me" }, (err, res) => {
  if (err) console.log(err);
  else {
    const autoResponseLabel = res.data.labels.find(label => label.name === "AutoResponse");
    console.log("AutoResponse标签ID：", autoResponseLabel.id);
  }
});

步骤2：修正代码逻辑 #

将标签添加逻辑封装为函数，仅在发送自动回复成功后调用；使用正确的标签ID；调整判断逻辑顺序：

const checkForNewMessages = () => {
  gmail.users.messages.list(
    {
      userId: "me",
      q: `is:unread`,
    },
    async (err, res) => {
      if (err) return console.log("The API returned an error: " + err);

      const messages = res.data.messages;
      // 替换为实际的AutoResponse标签ID
      const AUTO_RESPONSE_LABEL_ID = "Label_1234567890";

      if (messages?.length) {
        console.log("New message received!");

        for (const message of messages) {
          const messageDetails = await gmail.users.messages.get({
            userId: "me",
            id: message.id,
          });
          const threadId = messageDetails.data.threadId;
          const threadDetails = await gmail.users.threads.get({
            userId: "me",
            id: threadId,
          });

          // 封装添加标签的函数
          const addLabelToThread = async () => {
            try {
              await gmail.users.threads.modify({
                userId: "me",
                id: threadId,
                resource: {
                  addLabelIds: [AUTO_RESPONSE_LABEL_ID],
                  removeLabelIds: ["INBOX"],
                },
              });
              console.log(`线程${threadId}已添加AutoResponse标签`);
            } catch (labelErr) {
              console.log("添加标签失败：", labelErr);
            }
          };

          // 判断线程是否已有自己的回复
          const hasMyReply = threadDetails.data.messages.some(
            (msg) =>
              msg.labelIds.includes("SENT") &&
              msg.payload.headers.find(
                (header) =>
                  header.name === "From" &&
                  header.value.includes("mymail@gmail.com")
              )
          );

          if (!hasMyReply) {
            const subject = messageDetails.data.payload.headers.find(h => h.name === "Subject")?.value || "无主题";
            console.log(`收到新邮件线程：主题"${subject}"，线程ID${threadId}`);

            // 初始化Nodemailer transporter（建议移到函数外，避免重复创建）
            const transporter = nodemailer.createTransport({
              service: "gmail",
              auth: {
                type: "OAuth2",
                user: "mymail@gmail.com",
                clientId: process.env.CLIENT_ID,
                clientSecret: process.env.CLIENT_SECRET,
                refreshToken: process.env.REFRESH_TOKEN,
                accessToken: oAuth2Client.getAccessToken(),
              },
            });

            const mailOptions = {
              from: "mymail@gmail.com",
              to: messageDetails.data.payload.headers.find(h => h.name === "From")?.value,
              subject: `Re: ${subject}`,
              text: "Thank you for your message. I will respond as soon as I am available",
            };

            transporter.sendMail(mailOptions, async (err, info) => {
              if (err) {
                console.log("发送自动回复失败：", err);
              } else {
                console.log(`已向${mailOptions.to}发送自动回复：${info.response}`);
                // 发送成功后添加标签
                await addLabelToThread();
              }
            });

          } else {
            console.log(`线程${threadId}已有你的回复，跳过自动回复`);
          }
        }
      } else {
        console.log("无新邮件");
      }
    }
  );
};

额外优化建议 #

• 将Nodemailer的transporter初始化移到函数外部，避免每次检查邮件时重复创建连接。
• 增加错误处理，避免单个邮件处理失败导致整个循环终止。
• 可以使用批量操作接口优化性能，减少API调用次数。

内容的提问来源于stack exchange，提问作者Aviroop Banerjee