@nestjs/websockets - npm Package Compare versions

Comparing version 5.0.0-beta.3 to 5.0.0-beta.4

adapters/io-adapter.d.ts

@@ -5,3 +5,3 @@ /// <reference types="node" />
 import { WebSocketAdapter } from '@nestjs/common';
-import { Observable } from 'rxjs/Observable';
+import { Observable } from 'rxjs';
 export declare class IoAdapter implements WebSocketAdapter {
@@ -8,0 +8,0 @@ private readonly httpServer;

adapters/io-adapter.js

@@ -14,4 +14,4 @@ "use strict";
 const constants_1 = require("../constants");
+const rxjs_1 = require("rxjs");
 const operators_1 = require("rxjs/operators");
-const fromEvent_1 = require("rxjs/observable/fromEvent");
 const shared_utils_1 = require("@nestjs/common/utils/shared.utils");
@@ -46,3 +46,3 @@ class IoAdapter {
     bindMessageHandlers(client, handlers, process) {
-        handlers.forEach(({ message, callback }) => fromEvent_1.fromEvent(client, message)
+        handlers.forEach(({ message, callback }) => rxjs_1.fromEvent(client, message)
             .pipe(operators_1.mergeMap(data => process(callback(data))), operators_1.filter(result => !!result && result.event))
@@ -49,0 +49,0 @@ .subscribe(({ event, data }) => client.emit(event, data)));

adapters/ws-adapter.d.ts

@@ -5,3 +5,3 @@ /// <reference types="node" />
 import { WebSocketAdapter } from '@nestjs/common';
-import { Observable } from 'rxjs/Observable';
+import { Observable } from 'rxjs';
 export declare class WsAdapter implements WebSocketAdapter {
@@ -8,0 +8,0 @@ private readonly httpServer;

adapters/ws-adapter.js

@@ -14,6 +14,5 @@ "use strict";
 const common_1 = require("@nestjs/common");
+const rxjs_1 = require("rxjs");
 const operators_1 = require("rxjs/operators");
-const fromEvent_1 = require("rxjs/observable/fromEvent");
 const shared_utils_1 = require("@nestjs/common/utils/shared.utils");
-const empty_1 = require("rxjs/observable/empty");
 const missing_dependency_exception_1 = require("@nestjs/core/errors/exceptions/missing-dependency.exception");
@@ -48,3 +47,3 @@ let wsPackage = {};
     bindMessageHandlers(client, handlers, process) {
-        fromEvent_1.fromEvent(client, 'message')
+        rxjs_1.fromEvent(client, 'message')
             .pipe(operators_1.mergeMap(data => this.bindMessageHandler(data, handlers, process)), operators_1.filter(result => !!result))
@@ -57,3 +56,3 @@ .subscribe(response => client.send(JSON.stringify(response)));
         if (!messageHandler) {
-            return empty_1.empty();
+            return rxjs_1.EMPTY;
         }
@@ -60,0 +59,0 @@ const { callback } = messageHandler;

constants.d.ts

@@ -7,3 +7,3 @@ export declare const MESSAGE_MAPPING_METADATA = "__isMessageMapping";
 export declare const PORT_METADATA = "port";
-export declare const GATEWAY_MIDDLEWARES = "__gatewayMiddlewares";
+export declare const GATEWAY_MIDDLEWARES = "__gatewayMiddleware";
 export declare const GATEWAY_OPTIONS = "__gatewayOptions";
@@ -10,0 +10,0 @@ export declare const CONNECTION_EVENT = "connection";

constants.js

@@ -9,3 +9,3 @@ "use strict";
 exports.PORT_METADATA = 'port';
-exports.GATEWAY_MIDDLEWARES = '__gatewayMiddlewares';
+exports.GATEWAY_MIDDLEWARES = '__gatewayMiddleware';
 exports.GATEWAY_OPTIONS = '__gatewayOptions';
@@ -12,0 +12,0 @@ exports.CONNECTION_EVENT = 'connection';

gateway-metadata-explorer.d.ts

 import { NestGateway } from './interfaces/nest-gateway.interface';
 import { MetadataScanner } from '@nestjs/core/metadata-scanner';
-import { Observable } from 'rxjs/Observable';
+import { Observable } from 'rxjs';
 export declare class GatewayMetadataExplorer {
@@ -5,0 +5,0 @@ private readonly metadataScanner;

interfaces/observable-socket-server.interface.d.ts

@@ -1,3 +0,2 @@
-import { ReplaySubject } from 'rxjs/ReplaySubject';
-import { Subject } from 'rxjs/Subject';
+import { ReplaySubject, Subject } from 'rxjs';
 export interface ObservableSocketServer {
@@ -4,0 +3,0 @@ server: any;

observable-socket.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const Subject_1 = require("rxjs/Subject");
-const ReplaySubject_1 = require("rxjs/ReplaySubject");
+const rxjs_1 = require("rxjs");
 class ObservableSocket {
     static create(server) {
         return {
-            init: new ReplaySubject_1.ReplaySubject(),
-            connection: new Subject_1.Subject(),
-            disconnect: new Subject_1.Subject(),
+            init: new rxjs_1.ReplaySubject(),
+            connection: new rxjs_1.Subject(),
+            disconnect: new rxjs_1.Subject(),
             server,
@@ -12,0 +11,0 @@ };

package.json

 {
   "name": "@nestjs/websockets",
-  "version": "5.0.0-beta.3",
+  "version": "5.0.0-beta.4",
   "description": "Nest - modern, fast, powerful node.js web framework (@websockets)",
@@ -9,3 +9,2 @@ "author": "Kamil Mysliwiec",
     "iterare": "0.0.8",
-    "reflect-metadata": "0.1.12",
     "socket.io": "^2.0.3"
@@ -16,4 +15,4 @@ },
     "@nestjs/core": "^5.*",
-    "rxjs": "^5.5.6"
+    "rxjs": "^6.0.0"
   }
 }

socket-module.js

@@ -53,3 +53,3 @@ "use strict";
             if (!this.applicationConfig) {
-                return void 0;
+                return undefined;
             }
@@ -56,0 +56,0 @@ const adapter = this.applicationConfig.getIoAdapter();

utils/socket-gateway.decorator.js

@@ -16,5 +16,5 @@ "use strict";
         Reflect.defineMetadata(constants_1.GATEWAY_OPTIONS, opt, target);
-        Reflect.defineMetadata(constants_1.GATEWAY_MIDDLEWARES, opt.middlewares, target);
+        Reflect.defineMetadata(constants_1.GATEWAY_MIDDLEWARES, opt.middleware, target);
     };
 }
 exports.WebSocketGateway = WebSocketGateway;

web-sockets-controller.d.ts

@@ -5,3 +5,3 @@ import 'reflect-metadata';
 import { MessageMappingProperties } from './gateway-metadata-explorer';
-import { Subject } from 'rxjs/Subject';
+import { Subject, Observable } from 'rxjs';
 import { SocketServerProvider } from './socket-server-provider';
@@ -12,3 +12,2 @@ import { Type } from '@nestjs/common/interfaces/type.interface';
 import { WsContextCreator } from './context/ws-context-creator';
-import { Observable } from 'rxjs/Observable';
 export declare class WebSocketsController {
@@ -20,7 +19,7 @@ private readonly socketServerProvider;
     private readonly metadataExplorer;
-    private readonly middlewaresInjector;
+    private readonly middlewareInjector;
     constructor(socketServerProvider: SocketServerProvider, container: NestContainer, config: ApplicationConfig, contextCreator: WsContextCreator);
     hookGatewayIntoServer(instance: NestGateway, metatype: Type<any>, module: string): void;
     subscribeObservableServer(instance: NestGateway, options: any, port: number, module: string): void;
-    injectMiddlewares({server}: {
+    injectMiddleware({server}: {
         server: any;
@@ -27,0 +26,0 @@ }, instance: NestGateway, module: string): void;

web-sockets-controller.js

@@ -14,8 +14,7 @@ "use strict";
 const gateway_metadata_explorer_1 = require("./gateway-metadata-explorer");
+const rxjs_1 = require("rxjs");
 const constants_1 = require("./constants");
 const metadata_scanner_1 = require("@nestjs/core/metadata-scanner");
-const middlewares_injector_1 = require("./middlewares-injector");
+const middleware_injector_1 = require("./middleware-injector");
 const shared_utils_1 = require("@nestjs/common/utils/shared.utils");
-const fromPromise_1 = require("rxjs/observable/fromPromise");
-const of_1 = require("rxjs/observable/of");
 const operators_1 = require("rxjs/operators");
@@ -29,3 +28,3 @@ class WebSocketsController {
         this.metadataExplorer = new gateway_metadata_explorer_1.GatewayMetadataExplorer(new metadata_scanner_1.MetadataScanner());
-        this.middlewaresInjector = new middlewares_injector_1.MiddlewaresInjector(container, config);
+        this.middlewareInjector = new middleware_injector_1.MiddlewareInjector(container, config);
     }
@@ -47,8 +46,8 @@ hookGatewayIntoServer(instance, metatype, module) {
         const observableServer = this.socketServerProvider.scanForSocketServer(options, port);
-        this.injectMiddlewares(observableServer, instance, module);
+        this.injectMiddleware(observableServer, instance, module);
         this.hookServerToProperties(instance, observableServer.server);
         this.subscribeEvents(instance, messageHandlers, observableServer);
     }
-    injectMiddlewares({ server }, instance, module) {
-        this.middlewaresInjector.inject(server, instance, module);
+    injectMiddleware({ server }, instance, module) {
+        this.middlewareInjector.inject(server, instance, module);
     }
@@ -96,3 +95,3 @@ subscribeEvents(instance, messageHandlers, observableServer) {
         }));
-        adapter.bindMessageHandlers(client, handlers, data => fromPromise_1.fromPromise(this.pickResult(data)).pipe(operators_1.mergeMap(stream => stream)));
+        adapter.bindMessageHandlers(client, handlers, data => rxjs_1.from(this.pickResult(data)).pipe(operators_1.mergeMap(stream => stream)));
     }
@@ -106,5 +105,5 @@ pickResult(defferedResult) {
             if (result instanceof Promise) {
-                return fromPromise_1.fromPromise(result);
+                return rxjs_1.from(result);
             }
-            return of_1.of(result);
+            return rxjs_1.of(result);
         });
@@ -111,0 +110,0 @@ }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

64630

increased by4.45%

Dependency count

5

decreased by-16.67%

Number of package files

69

increased by2.99%

Lines of code

1113

increased by6%

Dependency changes

• + Addedreflect-metadata@0.1.14(transitive)

• - Removedreflect-metadata@0.1.12

• - Removedreflect-metadata@0.1.12(transitive)

• - Removedrxjs@5.5.12(transitive)

• - Removedsymbol-observable@1.0.1(transitive)