实现Web应用中Gmail新邮件的实时通知

POST https://www.googleapis.com/gmail/v1/users/me/watch
Authorization: Bearer YOUR_ACCESS_TOKEN
Content-Type: application/json

{
  "topicName": "projects/YOUR_PROJECT_ID/topics/gmail-notifications-topic",
  "labelIds": ["INBOX"] // 可选：只监听收件箱的邮件，否则会监听所有邮件变化
}

<?php
defined('BASEPATH') OR exit('No direct script access allowed');

class Webhook extends CI_Controller {

    public function __construct() {
        parent::__construct();
        // 载入必要的库或模型，例如用于处理OAuth token、Gmail API客户端等
        // $this->load->model('user_model');
        // $this->load->library('gmail_api_client'); // 自定义的Gmail API客户端封装
    }

    /**
     * Gmail Pub/Sub 推送通知的接收端点
     */
    public function gmail() {
        // 1. 获取原始POST请求体
        $input = file_get_contents('php://input');
        $data = json_decode($input, true);

        // 记录原始请求，便于调试
        log_message('info', 'Received Gmail Webhook: ' . $input);

        // 2. 验证Pub/Sub消息（可选但强烈推荐）
        // 您可以通过检查请求头部的 'X-Goog-Pubsub-Subscription' 和 'X-Goog-Pubsub-Topic' 来验证消息来源
        // 并且可以实现更复杂的签名验证来确保消息未被篡改
        $subscription_name = $this->input->get_request_header('X-Goog-Pubsub-Subscription');
        $topic_name = $this->input->get_request_header('X-Goog-Pubsub-Topic');
        // 确保这些头部与您配置的相符

        // 3. 解析消息内容
        if (isset($data['message']['data'])) {
            $message_data_base64 = $data['message']['data'];
            $message_data_decoded = base64_decode($message_data_base64);
            $notification = json_decode($message_data_decoded, true);

            if (isset($notification['emailAddress']) && isset($notification['historyId'])) {
                $user_email = $notification['emailAddress'];
                $new_history_id = $notification['historyId'];

                log_message('info', 'Processing Gmail notification for ' . $user_email . ' with historyId: ' . $new_history_id);

                // 4. 根据通知获取新邮件详情
                // 在这里，您需要：
                // a. 根据 $user_email 从您的数据库中获取该用户的OAuth访问令牌和刷新令牌。
                // b. 使用这些令牌初始化Google_Client和Google_Service_Gmail对象。
                // c. 调用 Gmail API 的 users.history.list 方法，传入 $new_history_id 作为 startHistoryId。
                //    这将返回自该 historyId 之后的所有邮件历史记录。

                try {
                    // 伪代码：
                    // $user_oauth_tokens = $this->user_model->get_user_tokens_by_email($user_email);
                    // if (!$user_oauth_tokens) {
                    //     log_message('error', 'No OAuth tokens found for user: ' . $user_email);
                    //     $this->output->set_status_header(400)->set_output('User tokens not found.');
                    //     return;
                    // }

                    // $gmail_client = $this->gmail_api_client->get_service($user_oauth_tokens); // 自定义方法，传入token
                    // $history_response = $gmail_client->users_history->listUsersHistory(
                    //     $user_email,
                    //     ['startHistoryId' => $new_history_id]
                    // );

                    // 5. 遍历历史记录，查找新邮件
                    // if (isset($history_response['history'])) {
                    //     foreach ($history_response['history'] as $history_item) {
                    //         if (isset($history_item['messagesAdded'])) {
                    //             foreach ($history_item['messagesAdded'] as $message_added) {
                    //                 $message_id = $message_added['message']['id'];
                    //                 log_message('info', 'New mail received: ' . $message_id . ' for ' . $user_email);
                    //                 // 在这里执行您的业务逻辑，例如：
                    //                 // - 从Gmail API获取邮件详情 (users.messages.get)
                    //                 // - 更新数据库
                    //                 // - 发送内部通知
                    //                 // - 触发其他自动化流程
                    //             }
                    //         }
                    //     }
                    // }

                    // 6. 更新用户的最新 historyId 到数据库，以便下次通知从正确的位置开始
                    // $this->user_model->update_user_last_history_id($user_email, $new_history_id);

                } catch (Google\Service\Exception $e) {
                    log_message('error', 'Gmail API error in webhook: ' . $e->getMessage());
                    // 根据错误类型返回不同的HTTP状态码
                    $this->output->set_status_header(500)->set_output('Gmail API error.');
                    return;
                } catch (Exception $e) {
                    log_message('error', 'General error in webhook: ' . $e->getMessage());
                    $this->output->set_status_header(500)->set_output('Internal server error.');
                    return;
                }

            } else {
                log_message('warning', 'Invalid Gmail notification format: ' . $message_data_decoded);
                $this->output->set_status_header(400)->set_output('Invalid notification format.');
                return;
            }
        } else {
            log_message('warning', 'Missing message data in Gmail Webhook: ' . $input);
            $this->output->set_status_header(400)->set_output('Missing message data.');
            return;
        }

        // Pub/Sub 要求接收方在成功处理消息后返回 200 OK 状态码
        $this->output->set_status_header(200)->set_output('OK');
    }
}

$route['webhook/gmail'] = 'webhook/gmail';