sendtouser.js

import _ from 'lodash';

export function start(api, next) {
  api.actions.addMiddleware({
    name: 'addUserIdToConnection',
    global: true,
    priority: 21,
    preProcessor(data, midNext) {
      if (data.session) data.connection.userId = data.session.id;
      midNext();
    }
  });

  api._sendToUser = (userId, data) => {
    let conns = _.filter(api.connections.connections, (i) => {
      return i.userId == userId && i.canChat == true;
    });
    for (let conn of conns) { conn.sendMessage(data); }
  };

  api.sendToUser = (userId, data) => {
    api.redis.doCluster('api._sendToUser', [userId, data]);
  };

  next();
}