如何访问 socket.io 上的会话数据（节点客户端会话）？

Question

我的应用程序中的会话数据由node-client-sessions（如Using secure client-side sessions to build simple and scalable Node.JS applications 中的建议）处理，现在我有socket.io（websockets）来处理一些实时功能。我想通过握手时的会话数据对登录用户进行身份验证。但是 socket.io 在握手时给了我们这个handshakeData 对象，它并没有完全暴露请求对象。我需要访问请求的会话属性。有什么想法吗？

我正在使用expressjs (nodejs)。

更新

受@LaurentPerrin 的启发，我深入研究了客户端会话源代码，发现解码和编码功能暴露在外。也许不像直接弄乱我的会话对象那么容易，但到目前为止非常有效。

我的代码，到目前为止：

/*jslint node: true, es5: true, nomen: true, unparam: true */

'use strict';

var encode = require('client-sessions').util.encode,
    decode = require('client-sessions').util.decode,
    cookie = require('cookie'),

    cookieSettings = require('./persistors/cookieSettings'),

    authorized = {
        'me@domain.com': 1
    };

module.exports = function websocket(io) {
    io.set('authorization', function (handshakeData, callback) {
        var session_data;
        if (!handshakeData.headers.cookie) {
            callback({
                status: 'forbidden',
                reason: 'no session',
                source: 'socket_io'
            }, false);
            return;
        }
        session_data = decode(cookieSettings, cookie.parse(handshakeData.headers.cookie).session).content;
        if (authorized[session_data.email]) {
            handshakeData.session_data = session_data;
            callback(null, true);
        } else {
            // callback({
            //     status: 'forbidden',
            //     reason: 'unauthorized',
            //     source: 'socket_io'
            // }, false);
            callback(null, false);
        }
        return;
    });
    io.set('transports', ['websocket', 'flashsocket']);
    io.sockets.on('connection', function (socket) {
        console.log('connected')
        socket.on('credenciamento', function (data) {
            console.log(socket.handshake.session_data.email);
            socket.broadcast.emit('credenciamento', {
                inscrito_id: data.inscrito_id
            });
        });
    });
};

这绝不是完整的。但是授权部分似乎工作得很好。 =)

现在，关于回调函数。起初我像@LaurentPerrin 一样使用它，传递一个带有错误响应的对象。但它会产生警告。 Socket.io 认为发生了错误：

warn - handshake error [object Object]

所以在第二个时刻，我在未授权时将null 作为第一个参数传递：

info - handshake unauthorized

考虑到 socket.io 理解每一件事的方式，第二种方式在语义上似乎更正确。 =)

我选择第二种方式。自己挑一个。

Answer 1

不确定它是否完全相同，但我在我的情况下写了这个。请注意，我在 express 依赖项中直接 require 以避免版本问题。

var cookie = require('express/node_modules/cookie'),
    parseSignedCookie = require('express/node_modules/connect').utils.parseSignedCookie,
    parseJSONCookie = require('express/node_modules/connect').utils.parseJSONCookie;

…

io.set('authorization', authorizeSocket);

…

function authorizeSocket(handshake, done) {
  if (!handshake.headers.cookie)
    return done({status: 'forbidden', reason: 'no session', source: 'socket_io'}, false);

  var cookies = cookie.parse(handshake.headers.cookie),
      signed = cookies['your_session_cookie'];

  if (!signed)
    return done({status: 'forbidden', reason: 'tampered cookie', source: 'socket_io'}, false);

  var raw = parseSignedCookie(signed, 'your_session_secret'),
  json = parseJSONCookie(raw);

  if (!json || !json.passport || !json.passport.user)
    return done({status: 'forbidden', reason: 'bad session', source: 'socket_io'}, false);

  // finally...
  var user = json.passport.user;

  handshake.user = user;

  done(null, true);
}