使用令牌的Faye身份验证

Question

我正在使用faye消息传递系统，我想添加身份验证!我浏览了这个网站，并按照教程进行了操作。

在客户端我有一个外发消息的扩展:

var droneFaye = new faye.Client("/faye", {
            timeout: 120
        });
var USER_TOKEN = 'ifd63cylqwsyaq9c2ptzywjujgtfpxs';
    droneFaye.addExtension({
        outgoing: function(message, callback) {
            if (message.channel !== '/meta/subscribe')
                return callback(message);
            message.ext = message.ext || {};
            message.ext.token = USER_TOKEN;
            console.log(message);
            callback(message);
        }
    });

服务器端:

var token = 'ifd63cylqwsyaq9c2ptzywjujgtfpxs'
    var serverAuth = {
    incoming: function(message, callback) {
        // Let non-subscribe messages through
        if (message.channel !== '/meta/subscribe')
            return callback(message);
        // Get subscribed channel and auth token
        var msgToken = message.ext && message.ext.token;
        // Find the right token for the channel
        if (token !== msgToken) {
            message.error = 'Invalid subscription auth token';
        }
        console.log(message);
        callback(message);
    }
};
var adapter = new faye.NodeAdapter({
    mount:'/faye',
    timeout:45
});
adapter.addExtension(serverAuth);
adapter.attach(httpServer);

我在服务器上有一个这样的订阅:

adapter.getClient().subscribe("/drone/move", function(cmd) {});

好吧!因此，当我启动服务器并且没有CLIENT时，它已经调用了订阅的扩展，它将在控制台上输出:

{ channel: '/meta/subscribe',
  clientId: '2isdeb0ds77zl0lh82ob1kqu29y1cajnv80',
  subscription: '/drone/move',
  id: '2',
  error: 'Invalid subscription auth token' }

一旦客户端连接到服务器，它将再次调用扩展，它将输出如下:

{ channel: '/meta/subscribe',
  clientId: '3kechs0c7smpc05z5o7d0a8qcd301d8zi41',
  subscription: '/drone/move',
  id: '3',
  ext: { userId: 18787, token: 'ifd63cylqwsyaq9c2ptzywjujgtfpxs' } }

这个看起来不错!但是没有其他消息会到达服务器，即使它们有正确的令牌并且没有错误消息!

仅供参考。如果您向消息对象添加带有值的错误键，它将不会将消息传递给其订阅…应该是这样的!

也是当我注释掉消息时。扩展错误，它工作正常，但当然没有身份验证。

那么，有没有人知道为什么服务器调用扩展，即使没有客户端，第二，为什么faye不给消息给它的订阅，即使在消息对象中没有错误?

谢谢!

Answer 1

也有人问过这个问题，并在这里回答了:

这是由对adapter.getClient().subscribe()的调用引起的。

[…服务器端客户端(<adapter>.getClient())返回一个连接到服务器，因此遍历与客户端相同的扩展(传入，传出)。

[…附加一个传出扩展，你会看到它被响应到服务器-客户端。