sample(@nestjs) update gateways and graphql sample

Author: kamilmysliwiec

sample/02-gateways/client/index.html

@@ -6,7 +6,9 @@
         const socket = io('http://localhost:3000');
         socket.on('connect', function () {
             console.log('Connected');
+
             socket.emit('events', { test: 'test' });
+            socket.emit('identity', 0, (response) => console.log('Identity:', response));
         });
         socket.on('events', function (data) {
             console.log('event', data);

sample/02-gateways/src/adapters/redis-io.adapter.ts

@@ -0,0 +1,12 @@
+import { IoAdapter } from '@nestjs/websockets';
+import * as redisIoAdapter from 'socket.io-redis';
+
+const redisAdapter = redisIoAdapter({ host: 'localhost', port: 6379 });
+
+export class RedisIoAdapter extends IoAdapter {
+  createIOServer(port: number, options?: any): any {
+    const server = super.createIOServer(port, options);
+    server.adapter(redisAdapter);
+    return server;
+  }
+}

sample/02-gateways/src/events/events.gateway.ts

@@ -12,10 +12,12 @@ export class EventsGateway {
   @WebSocketServer() server;
 
   @SubscribeMessage('events')
-  onEvent(client, data): Observable<WsResponse<number>> {
-    const event = 'events';
-    const response = [1, 2, 3];
+  findAll(client, data): Observable<WsResponse<number>> {
+    return from([1, 2, 3]).pipe(map(item => ({ event: 'events', data: item })));
+  }
 
-    return from(response).pipe(map(res => ({ event, data: res })));
+  @SubscribeMessage('identity')
+  async identity(client, data: number): Promise<number> {
+    return data;
   }
 }

sample/12-graphql-apollo/package-lock.json

@@ -16,6 +16,7 @@
     "graphql": "^0.13.2",
     "graphql-subscriptions": "^0.5.6",
     "graphql-tools": "^2.11.0",
+    "graphql-type-json": "^0.2.1",
     "reflect-metadata": "^0.1.12",
     "rxjs": "^6.0.0",
     "subscriptions-transport-ws": "^0.9.5",

sample/12-graphql-apollo/package.json

@@ -1,6 +1,6 @@
 import { Module } from '@nestjs/common';
-import { CatsService } from './cats.service';
 import { CatsResolvers } from './cats.resolvers';
+import { CatsService } from './cats.service';
 
 @Module({
   providers: [CatsService, CatsResolvers],

sample/12-graphql-apollo/src/cats/cats.module.ts

@@ -1,4 +1,4 @@
-import { Scalar } from '@nestjs/graphql/dist/decorators/resolvers.decorators';
+import { Scalar } from '@nestjs/graphql';
 import { Kind } from 'graphql';
 
 @Scalar('Date')

sample/12-graphql-apollo/src/common/scalars/date.scalar.ts

@@ -1,5 +1,10 @@
-import { SubscribeMessage, WebSocketGateway, WebSocketServer, WsResponse } from '@nestjs/websockets';
-import { Observable, from } from 'rxjs';
+import {
+  SubscribeMessage,
+  WebSocketGateway,
+  WebSocketServer,
+  WsResponse,
+} from '@nestjs/websockets';
+import { from, Observable } from 'rxjs';
 import { map } from 'rxjs/operators';
 
 @WebSocketGateway(8080)
@@ -8,9 +13,6 @@ export class EventsGateway {
 
   @SubscribeMessage('events')
   onEvent(client, data): Observable<WsResponse<number>> {
-    const event = 'events';
-    const response = [1, 2, 3];
-
-    return from(response).pipe(map(res => ({ event, data: res })));
+    return from([1, 2, 3]).pipe(map(item => ({ event: 'events', data: item })));
   }
 }

sample/16-gateways-ws/src/events/events.gateway.ts

@@ -1,15 +1,8 @@
 import { CacheModule, Module } from '@nestjs/common';
-import * as redisStore from 'cache-manager-redis-store';
 import { AppController } from './app.controller';
 
 @Module({
-  imports: [
-    CacheModule.register({
-      store: redisStore,
-      host: 'localhost',
-      port: 6379,
-    }),
-  ],
+  imports: [CacheModule.register()],
   controllers: [AppController],
 })
 export class ApplicationModule {}

sample/20-cache/src/app.module.ts

@@ -2,7 +2,6 @@ import {
   ClassSerializerInterceptor,
   Controller,
   Get,
-  SerializeOptions,
   UseInterceptors,
 } from '@nestjs/common';
 import { RoleEntity } from './entities/role.entity';
@@ -12,9 +11,6 @@ import { UserEntity } from './entities/user.entity';
 @UseInterceptors(ClassSerializerInterceptor)
 export class AppController {
   @Get()
-  @SerializeOptions({
-    excludePrefixes: 'excludeAll',
-  })
   findOne(): UserEntity {
     return new UserEntity({
       id: 1,