如何在Firebase HTTP函数中解析和验证云任务令牌

const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp();

exports.myCloudTaskFunction = functions.https.onRequest(async (req, res) => {
  // 获取任务令牌
  const queueName = req.headers['x-appengine-queuename'];
  const taskName = req.headers['x-cloudtasks-taskname'];

  if (!queueName || !taskName) {
    res.status(400).send('Missing task token headers');
    return;
  }

  // 验证任务令牌
  try {
    const task = await admin.cloudtasks().getTask({
      name: taskName,
      project: process.env.GCLOUD_PROJECT
    });

    if (!task) {
      res.status(403).send('Invalid task token');
      return;
    }

    // 处理任务逻辑
    const payload = JSON.parse(req.body);
    console.log('Processing task:', payload);

    res.status(200).send('Task processed successfully');
  } catch (error) {
    console.error('Error verifying task token:', error);
    res.status(500).send('Internal server error');
  }
});