帆.js:流套接字并发送到控制器

Question

我正在用 Sails 编写一个 REST API.js除了常规的 HTTP 路由之外，我需要应用程序侦听来自 Salesforce 的套接字上的通知。

我有一个带有一些逻辑的控制器，但我不知道如何让它在启动时订阅套接字，所以现在没有任何内容可以到达它。

控制器：

pushTopicHandler: function(req, res) {
  if (!req.isSocket) {
    return res.badRequest();
  }
  var nforce = require('nforce');
  var org = nforce.createConnection({
      clientId: sails.config.client_id,
      clientSecret: sails.config.client_secret,
      redirectUri: sails.config.callback_url + '/oauth/_callback',
      mode: 'multi',
      environment: 'sandbox'
  });
  org.authenticate({ username: sails.config.sfUsername, password: sails.config.sfPassword }, function(err, oauth) {
      if(err) return res.serverError(err);
      var str = org.stream({ topic: sails.config.push_topic, oauth: oauth });
      str.on('connect', function(){
        console.log('Connected to pushtopic: ' + sails.config.push_topic);
      });
      str.on('error', function(error) {
        console.log('Error received from pushtopic: ' + error);
      });
      str.on('data', function(data) {
        console.log('Received the following from pushtopic ---');
        console.log(data);
      });
    });
  }

Answer 1

Sails 有一个bootstrap.js文件，可让您在服务器启动之前编写任何想要运行的内容。

我能够在该文件cb()之前在一个小函数中订阅推送主题并且它可以工作，服务器正常启动 REST API，并且它仍在侦听事件。