socket.js

  // шлет запрос в сокет
        _sendToMediator: function (query) {
            var self = this;
            return self._getMediator()
                .then(function () {
                    if ( !self.mediator.connected ) {
                        // пытаемся еще раз подключиться к медиатору
                        self._getMediator(true);
                        return self.$q.reject(null);
                    }

                    var requestId = _.uniqueId('parse_');
                    self.mediator.send({
                        request_id: requestId,
                        query: query
                    });
                    var deferred = self.$q.defer();
                    self._mediatorRequests[requestId] = deferred;
                    return deferred.promise;
                });
        },
        // слушает все события с сокета, отправленные этому клиенту
        _handleMediatorResponse: function (response) {
            if ( !_.has(response, 'request_id') ) {
                return this._flushMediatorRequests();
            }

            var requestId = response.request_id;
            var deferred = this._mediatorRequests[requestId];
            if ( !deferred ) return;

            delete this._mediatorRequests[requestId];

            if ( _.has(response, 'data') && !_.isNull(response.data) ) {
                deferred.resolve(response.data);
            }
            else {
                deferred.reject(response.error);
            }
        },