Откуда берется объект сокета - PullRequest
Новая
       28

Откуда берется объект сокета

0 голосов
/ 28 октября 2019

Я пытаюсь реализовать динамические маршруты сокетов в моем остальных приложениях по обратной связи. В приведенном ниже коде, который я получил от: https://github.com/raymondfeng/loopback4-example-websocket, он принимает объект сокета, который устанавливает маршрут равным 1 на основе nsp.name. Он продолжает ходить в чаты / 1. Откуда этот объект сокета? Я хочу знать, чтобы вместо перехода к chats / 1 я мог сделать его динамическим в зависимости от URL. Такие как чаты / 2. 

import {Application, ApplicationConfig} from '@loopback/core';
import {HttpServer} from '@loopback/http-server';
import * as express from 'express';
import * as path from 'path';
import {WebSocketController} from './controllers';
import {WebSocketServer} from './websocket.server';

// tslint:disable:no-any

export class WebSocketDemoApplication extends Application {
  readonly httpServer: HttpServer;
  readonly wsServer: WebSocketServer;

  constructor(options: ApplicationConfig = {}) {
    super(options);

    /**
     * Create an Express app to serve the home page
     */
    const expressApp = express();
    const root = path.resolve(__dirname, '../../public');
    expressApp.use('/', express.static(root));

    // Create an http server backed by the Express app
    this.httpServer = new HttpServer(expressApp, options.websocket);

    // Create ws server from the http server
    const wsServer = new WebSocketServer(this.httpServer);
    this.bind('servers.websocket.server1').to(wsServer);
    wsServer.use((socket, next) => {
      console.log('Global middleware - socket:', socket.id);
      next();
    });
    // Add a route
   const ns = wsServer.route(WebSocketController, /^\/chats\/\d+$/);
    ns.use((socket, next) => {
      //console.log(socket)
      console.log(
        'Middleware for namespace %s - socket: %s',
        socket.nsp.name,
        socket.id,
      );
      next();
    });
    this.wsServer = wsServer;
  }

  start() {
    return this.wsServer.start();
  }

  stop() {
    return this.wsServer.stop();
  }
}
...