通过node.js使用FCM HTTP v1 API发送通知

Question

作为所有针对 FCM 的 npm 模块似乎仍在使用传统的 HTTP API，我正在尝试通过最新的 HTTP v1 API 在 node 上实现 FCM 消息传递。虽然文档提到了Google 客户端 API，但要求使用它似乎过度，因为我只需要Google Auth Library中的 JWT oAuth2Client。到目前为止，我想出的模块如下：

var request = require('request');
var googleAuth = require('google-auth-library');

module.exports.Sender = function(projectId, key) {

  var _projectId = projectId;
  var _key = key;
  var _tokens = {};

  var _jwtClient = new googleAuth.JWT(
    key.client_email,
    null,
    key.private_key,
    ['https://www.googleapis.com/auth/firebase.messaging'],
    null
  );

  var _getAccessToken = function() {

    return new Promise(function(resolve, reject) {
      _jwtClient.authorize(function(error, tokens) {
        if (error) {
          reject(error);
          return;
        }
        _tokens = tokens;
        resolve(tokens.access_token);
      });
    });
  };

  var _sendMessage = function(message) {

    return new Promise(function(resolve, reject) {
      request({
        method: 'POST',
        url: 'https://fcm.googleapis.com/v1/projects/' + _projectId + '/messages:send',
        headers: {
          'Content-type': 'application/json',
          'Authorization': 'Bearer ' + _tokens.access_token
        },
        body: message,
        json: true
      }, function(error, response, body) {
        if(error) reject(error);
        else {
          resolve(response);
        }
      });
    });
  };

  return {
    getAccessToken: _getAccessToken,
    sendMessage: _sendMessage
  }
}

关于使用它：

var fcm = require('./index.js');

var projectId = 'someProjectId';
var key = require('./someServiceAccount.json');

var sender = new fcm.Sender(projectId, key);

var message = {
  validate_only: false,
  message: {
    token: 'someDeviceToken',
    android: {
      collapse_key: 'someCollapseKey',
      priority: 'HIGH',
      restricted_package_name: 'com.some.domain',
      data: {
        title: 'someTitle',
        body: 'someBody',
        sound: 'default',
        action: 'someAction'
      }
    },
    apns: {
      headers: {
        'apns-priority': '10'
      },
      payload: {
        aps: {
          alert: {
            title: 'someTitle',
            body: 'someBody'
          },
          sound: 'default',
          badge: 2
        },
        action: 'someAction'
      }
    }
  }
};


sender.getAccessToken() //TODO: should be done once in sender
.then(function(accessToken) {
  return sender.sendMessage(message);
})
.then(function(response) {
  console.log(response.body);
})
.catch(function(error) {
  console.log(error);
});

所有的都很好，我正在使用cordova-plugin-firebase接收设备上的通知。

API调用使用oAuth2进行身份验证，其中访问令牌需要定期刷新(似乎是每1小时)。文档中指出：

请注意，刷新令牌的调用是幂等的。当您的令牌过期时，将自动调用令牌刷新方法以检索更新的令牌。

然而，我似乎无法弄清楚这是如何实现的。JWT授权调用只留下一个包含访问令牌字符串的一般对象。由于JWT客户端扩展了oAuth2Client，因此我浏览了其源代码，它似乎有一个request method可以自动刷新访问令牌。

另外，JWT.authorize返回的对象的refresh_token似乎总是'jwt-placeholder'。

这使我感到困惑：

• 如何获取有效的刷新令牌？

• 如果没有使用任何前端交互，我是否可以通过JWT客户端使用oAuth2Client方法（generateAuthUrl）？

• 使用请求方法会阻止我的代码吗？

• 我需要某种类型的消息队列吗？

虽然我在继续研究和编码，但我想知道是否有人能够在此期间给我一些指导或有用的文档。

- Will Kru

Answer 1

我使用请求方法使其正常工作。这也消除了对请求模块的需求。如果我理解正确，oAuth2Client应该自动刷新访问令牌，并在请求失败时进行一次重试。

我的更新后的发送器模块:

var googleAuth = require('google-auth-library');

module.exports.Sender = function(projectId, key) {

  var _projectId = projectId;
  var _jwtClient = new googleAuth.JWT(
    key.client_email,
    null,
    key.private_key,
    ['https://www.googleapis.com/auth/firebase.messaging'],
    null
  );

  var _init = function() {

    return new Promise(function(resolve, reject) {
      _jwtClient.authorize(function(error, tokens) {
        if (error) {
          reject(error);
          return;
        }
        resolve();
      });
    });
  };

  var _sendMessage = function(message) {

    return _jwtClient.request({
      method: 'post',
      url: 'https://fcm.googleapis.com/v1/projects/' + _projectId + '/messages:send',
      data: message
    });
  }

  return {
    init: _init,
    sendMessage: _sendMessage
  }
}

和用法：

sender.init()
.then(function(accessToken) {
  return sender.sendMessage(message);
})
.then(function(response) {
  console.log(response.data);
})
.catch(function(error) {
  console.log(error);
});

然而，有关refresh_token的问题仍然存在，因为JWT客户端替代了它。如何正确实现这一点？

- Will Kru