Skip to content

Commit 22cb73c

Browse files
Merge pull request nestjs#3067 from nestjs/6.8.0
chore() 6.8.0 minor release
2 parents a9ea216 + b693d13 commit 22cb73c

93 files changed

Lines changed: 1796 additions & 591 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

integration/microservices/src/nats/nats.controller.ts

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,11 @@ import { Body, Controller, Get, HttpCode, Post, Query } from '@nestjs/common';
22
import {
33
Client,
44
ClientProxy,
5+
Ctx,
56
EventPattern,
67
MessagePattern,
8+
NatsContext,
9+
Payload,
710
RpcException,
811
Transport,
912
} from '@nestjs/microservices';
@@ -57,7 +60,7 @@ export class NatsController {
5760
}
5861

5962
@MessagePattern('math.*')
60-
sum(data: number[]): number {
63+
sum(@Payload() data: number[], @Ctx() context: NatsContext): number {
6164
return (data || []).reduce((a, b) => a + b);
6265
}
6366

@@ -94,7 +97,7 @@ export class NatsController {
9497
}
9598

9699
@EventPattern('notification')
97-
eventHandler(data: boolean) {
100+
eventHandler(@Payload() data: boolean) {
98101
NatsController.IS_NOTIFIED = data;
99102
}
100103
}

integration/websockets/src/app.gateway.ts

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,13 @@
1-
import { WebSocketGateway, SubscribeMessage } from '@nestjs/websockets';
1+
import {
2+
MessageBody,
3+
SubscribeMessage,
4+
WebSocketGateway,
5+
} from '@nestjs/websockets';
26

37
@WebSocketGateway(8080)
48
export class ApplicationGateway {
59
@SubscribeMessage('push')
6-
onPush(client, data) {
10+
onPush(@MessageBody() data) {
711
return {
812
event: 'pop',
913
data,

integration/websockets/src/core.gateway.ts

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,14 @@
1-
import { SubscribeMessage, WebSocketGateway } from '@nestjs/websockets';
1+
import {
2+
ConnectedSocket,
3+
MessageBody,
4+
SubscribeMessage,
5+
WebSocketGateway,
6+
} from '@nestjs/websockets';
27

38
@WebSocketGateway(8090)
49
export class CoreGateway {
510
@SubscribeMessage('push')
6-
onPush(client, data) {
11+
onPush(@ConnectedSocket() client, @MessageBody() data) {
712
return {
813
event: 'pop',
914
data,

integration/websockets/src/server.gateway.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import { WebSocketGateway, SubscribeMessage } from '@nestjs/websockets';
1+
import { SubscribeMessage, WebSocketGateway } from '@nestjs/websockets';
22

33
@WebSocketGateway()
44
export class ServerGateway {

0 commit comments

Comments
 (0)