@feathersjs/socketio/lib/middleware.js

const debug = require('debug')('@feathersjs/socketio/middleware');

exports.disconnect = (app, getParams) => (socket, next) => {
  socket.once('disconnect', () => app.emit('disconnect', getParams(socket)));
  next();
};

exports.params = (app, socketMap) => (socket, next) => {
  socket.feathers = {
    provider: 'socketio',
    headers: socket.handshake.headers
  };

  socketMap.set(socket.feathers, socket);

  next();
};

exports.authentication = (app, getParams, settings = {}) => (socket, next) => {
  const service = app.defaultAuthentication ? app.defaultAuthentication(settings.service) : null;

  if (service === null) {
    return next();
  }

  const config = service.configuration;
  const authStrategies = config.parseStrategies || config.authStrategies || [];

  if (authStrategies.length === 0) {
    return next();
  }

  service.parse(socket.handshake, null, ...authStrategies)
    .then(async authentication => {
      if (authentication) {
        debug('Parsed authentication from HTTP header', authentication);
        socket.feathers.authentication = authentication;
        await service.create(authentication, {
          provider: 'socketio',
          connection: getParams(socket)
        });
      }

      next();
    }).catch(next);
};