amirho/nest
1
0
Fork 0
mirror of https://github.com/nestjs/nest.git synced 2026-02-21 23:11:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore(): resolve conflicts, minor changes

Browse Source
This commit is contained in:
Kamil Myśliwiec
2022-03-01 13:55:07 +01:00
parent 16531d47d9 111d84e25e
commit 8ce0cf1bc9
7 changed files with 1033 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
integration/microservices/e2e/sum-mqtt.spec.ts
View File

@@ -124,6 +124,44 @@ describe('MQTT transport', () => {
.expect(201, '15');
});
it(`/POST (shared wildcard EVENT #)`, done => {
request(server)
.post('/shared-wildcard-event')
.send([1, 2, 3, 4, 5])
.end(() => {
setTimeout(() => {
expect(MqttController.IS_SHARED_WILDCARD_EVENT_RECEIVED).to.be.true;
done();
}, 1000);
});
});
it(`/POST (shared wildcard MESSAGE #)`, () => {
return request(server)
.post('/shared-wildcard-message')
.send([1, 2, 3, 4, 5])
.expect(201, '15');
});
it(`/POST (shared wildcard EVENT +)`, done => {
request(server)
.post('/shared-wildcard-event2')
.send([1, 2, 3, 4, 5])
.end(() => {
setTimeout(() => {
expect(MqttController.IS_SHARED_WILDCARD2_EVENT_RECEIVED).to.be.true;
done();
}, 1000);
});
});
it(`/POST (shared wildcard MESSAGE +)`, () => {
return request(server)
.post('/shared-wildcard-message2')
.send([1, 2, 3, 4, 5])
.expect(201, '15');
});
afterEach(async () => {
await app.close();
});

52
integration/microservices/src/mqtt/mqtt.controller.ts
View File

@@ -18,6 +18,8 @@ export class MqttController {
static IS_NOTIFIED = false;
static IS_WILDCARD_EVENT_RECEIVED = false;
static IS_WILDCARD2_EVENT_RECEIVED = false;
static IS_SHARED_WILDCARD_EVENT_RECEIVED = false;
static IS_SHARED_WILDCARD2_EVENT_RECEIVED = false;
@Client({ transport: Transport.MQTT })
client: ClientProxy;
@@ -90,6 +92,7 @@ export class MqttController {
return this.client.send<number>('wildcard-message2/test/test', data);
}
<<<<<<< HEAD
@Post('record-builder-duplex')
@HttpCode(200)
useRecordBuilderDuplex(@Body() data: Record<string, any>) {
@@ -107,6 +110,32 @@ export class MqttController {
data,
qos,
};
=======
@Post('shared-wildcard-event')
async sendSharedWildcardEvent(): Promise<any> {
return this.client.emit<number>('shared-wildcard-event/test', true);
}
@Post('shared-wildcard-message')
async sendSharedWildcardMessage(
@Body() data: number[],
): Promise<Observable<number>> {
await this.client.connect();
return this.client.send<number>('shared-wildcard-message/test', data);
}
@Post('shared-wildcard-event2')
async sendSharedWildcardEvent2(): Promise<any> {
return this.client.emit<number>('shared-wildcard-event2/test/test', true);
}
@Post('shared-wildcard-message2')
async sendSharedWildcardMessage2(
@Body() data: number[],
): Promise<Observable<number>> {
await this.client.connect();
return this.client.send<number>('shared-wildcard-message2/test/test', data);
>>>>>>> 111d84e25eb29e0ffccdab5cfa6272162cb979ab
}
@MessagePattern('wildcard-message/#')
@@ -156,4 +185,27 @@ export class MqttController {
streaming(data: number[]): Observable<number> {
return from(data);
}
@MessagePattern('$share/test-group/shared-wildcard-message/#')
sharedWildcardMessageHandler(data: number[]): number {
if ((data as any).response) {
return;
}
return (data || []).reduce((a, b) => a + b);
}
@EventPattern('$share/test-group/shared-wildcard-event/#')
sharedWildcardEventHandler(data: boolean) {
MqttController.IS_SHARED_WILDCARD_EVENT_RECEIVED = data;
}
@MessagePattern('$share/test-group/shared-wildcard-message2/+/test')
sharedWildcardMessageHandler2(data: number[]): number {
return (data || []).reduce((a, b) => a + b);
}
@EventPattern('$share/test-group/shared-wildcard-event2/+/test')
sharedWildcardEventHandler2(data: boolean) {
MqttController.IS_SHARED_WILDCARD2_EVENT_RECEIVED = data;
}
}