如何在Nest JS中使用Gmail API將電子郵件標記為已讀？

Question

我正在使用Nest.js進行編碼，現在我成功地獲取了電子郵件資料。現在，我想透過訊息ID逐一取得每封電子郵件，並檢查該電子郵件是否已讀或未讀。如果電子郵件未讀，我想將其標記為已讀並在資料庫中進行更新。任何了解的人請為此重寫程式碼，注意：我正在使用PrismaORM進行資料庫操作//google-sheet.service.tsimport{Injectable}from'@nestjs/common

P粉127901279 · Answer

import { Injectable } from '@nestjs/common';
import { google } from 'googleapis';
import { JWT } from 'google-auth-library';
import { EnvironmentService } from 'src/core/environments/environments.service';
import axios from 'axios';

@Injectable()
export class GmailService {
  constructor(private environmentService: EnvironmentService) {}

  async getEMails() {
    try {
      const oAuth2Client = new google.auth.OAuth2(
        this.environmentService.clientId(),
        this.environmentService.clientSecret(),
        this.environmentService.googleUri(),
      );

      await oAuth2Client.setCredentials({
        refresh_token: this.environmentService.refresh_token(),
      });

      // Fetch all email IDs
      const fetchingIdUrl = 'https://gmail.googleapis.com/gmail/v1/users/email@gmail.com/messages/';

      const { token } = await oAuth2Client.getAccessToken();
      const config: any = {
        headers: {
          Authorization: `Bearer ${token}`,
        },
      };

      const response = await axios.get(fetchingIdUrl, config);
      const emailIds = response.data.messages.map((message: any) => message.id);

      for (const emailId of emailIds) {
        // Fetch individual email by ID
        const fetchingEmailById = `https://gmail.googleapis.com/gmail/v1/users/email@gmail.com/messages/${emailId}`;
        const emailResponse = await axios.get(fetchingEmailById, config);

        const emailData = emailResponse.data;
        console.log(emailData);

        // Check if the email is unread and mark it as read
        if (!emailData.labelIds.includes('UNREAD')) {
          continue; // Skip if the email is already read
        }

        // Mark the email as read
        await markEmailAsRead(emailId, config);

        // Update the email status in the database here
        // Replace the following line with your database update logic
        console.log(`Marked email with ID ${emailId} as read.`);
      }
    } catch (err) {
      console.error('Error fetching emails:', err.message);
    }
  }

  // Helper function to mark an email as read
  async markEmailAsRead(emailId: string, config: any) {
    const markAsReadUrl = `https://gmail.googleapis.com/gmail/v1/users/email@gmail.com/messages/${emailId}/modify`;
    const requestBody = {
      removeLabelIds: ['UNREAD'],
    };
    await axios.post(markAsReadUrl, requestBody, config);
  }
}