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

test: add microservice generic type explicitly

Browse Source
This commit is contained in:
Jake Son
2023-03-11 09:44:48 +09:00
parent e63f5c0ff5
commit 56b0c57729
16 changed files with 47 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
integration/inspector/e2e/graph-inspector.spec.ts
View File

@@ -1,7 +1,7 @@
import { ValidationPipe } from '@nestjs/common';
import { Injector } from '@nestjs/core/injector/injector';
import { SerializedGraph } from '@nestjs/core/inspector/serialized-graph';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test, TestingModule } from '@nestjs/testing';
import { expect } from 'chai';
import { readFileSync, writeFileSync } from 'fs';
@@ -45,7 +45,10 @@ describe('Graph inspector', () => {
app.useGlobalFilters(new HttpExceptionFilter());
app.useGlobalInterceptors(new TimeoutInterceptor());
app.enableVersioning();
app.connectMicroservice({ transport: Transport.TCP, options: {} });
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.TCP,
options: {},
});
await app.init();
const graph = testingModule.get(SerializedGraph);

6
integration/microservices/e2e/broadcast-mqtt.spec.ts
View File

@@ -1,5 +1,5 @@
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import * as request from 'supertest';
import { MqttBroadcastController } from '../src/mqtt/mqtt-broadcast.controller';
@@ -16,13 +16,13 @@ describe('MQTT transport', () => {
app = module.createNestApplication();
server = app.getHttpAdapter().getInstance();
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.MQTT,
options: {
host: '0.0.0.0',
},
});
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.MQTT,
options: {
host: '0.0.0.0',

6
integration/microservices/e2e/broadcast-nats.spec.ts
View File

@@ -1,5 +1,5 @@
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import * as request from 'supertest';
import { NatsBroadcastController } from '../src/nats/nats-broadcast.controller';
@@ -16,13 +16,13 @@ describe('NATS transport', () => {
app = module.createNestApplication();
server = app.getHttpAdapter().getInstance();
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.NATS,
options: {
servers: 'nats://0.0.0.0:4222',
},
});
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.NATS,
options: {
servers: 'servers://0.0.0.0:4222',

12
integration/microservices/e2e/broadcast-redis.spec.ts
View File

@@ -1,5 +1,5 @@
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import * as request from 'supertest';
import { RedisBroadcastController } from '../src/redis/redis-broadcast.controller';
@@ -16,16 +16,18 @@ describe('REDIS transport', () => {
app = module.createNestApplication();
server = app.getHttpAdapter().getInstance();
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.REDIS,
options: {
url: 'redis://0.0.0.0:6379',
host: '0.0.0.0',
port: 6379,
},
});
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.REDIS,
options: {
url: 'redis://0.0.0.0:6379',
host: '0.0.0.0',
port: 6379,
},
});
await app.startAllMicroservices();

4
integration/microservices/e2e/concurrent-kafka.spec.ts
View File

@@ -1,5 +1,5 @@
import { INestApplication, Logger } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import { Admin, ITopicMetadata, Kafka } from 'kafkajs';
import * as request from 'supertest';
@@ -37,7 +37,7 @@ describe.skip('Kafka concurrent', function () {
const server = app.getHttpAdapter().getInstance();
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.KAFKA,
options: {
client: {

4
integration/microservices/e2e/mqtt-record-builder.spec.ts
View File

@@ -1,5 +1,5 @@
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import * as request from 'supertest';
import { MqttController } from '../src/mqtt/mqtt.controller';
@@ -16,7 +16,7 @@ describe('MQTT transport', () => {
app = module.createNestApplication();
server = app.getHttpAdapter().getInstance();
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.MQTT,
options: {
url: 'mqtt://0.0.0.0:1883',

4
integration/microservices/e2e/orders-grpc.spec.ts
View File

@@ -1,7 +1,7 @@
import * as GRPC from '@grpc/grpc-js';
import * as ProtoLoader from '@grpc/proto-loader';
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { ExpressAdapter } from '@nestjs/platform-express';
import { Test } from '@nestjs/testing';
import { fail } from 'assert';
@@ -26,7 +26,7 @@ describe('Advanced GRPC transport', () => {
/*
* Create microservice configuration
*/
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.GRPC,
options: {
url: 'localhost:5001',

4
integration/microservices/e2e/sum-grpc.spec.ts
View File

@@ -1,7 +1,7 @@
import * as GRPC from '@grpc/grpc-js';
import * as ProtoLoader from '@grpc/proto-loader';
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import { fail } from 'assert';
import { expect } from 'chai';
@@ -22,7 +22,7 @@ describe('GRPC transport', () => {
app = module.createNestApplication();
server = app.getHttpAdapter().getInstance();
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.GRPC,
options: {
package: ['math', 'math2'],

4
integration/microservices/e2e/sum-kafka.spec.ts
View File

@@ -1,5 +1,5 @@
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import { expect } from 'chai';
import * as request from 'supertest';
@@ -29,7 +29,7 @@ describe.skip('Kafka transport', function () {
app = module.createNestApplication();
server = app.getHttpAdapter().getInstance();
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.KAFKA,
options: {
client: {

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

@@ -1,5 +1,5 @@
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import { expect } from 'chai';
import * as request from 'supertest';
@@ -17,7 +17,7 @@ describe('MQTT transport', () => {
app = module.createNestApplication();
server = app.getHttpAdapter().getInstance();
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.MQTT,
options: {
url: 'mqtt://0.0.0.0:1883',

4
integration/microservices/e2e/sum-nats.spec.ts
View File

@@ -1,5 +1,5 @@
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import { expect } from 'chai';
import * as request from 'supertest';
@@ -19,7 +19,7 @@ describe('NATS transport', () => {
app = module.createNestApplication();
server = app.getHttpAdapter().getInstance();
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.NATS,
options: {
servers: 'nats://0.0.0.0:4222',

7
integration/microservices/e2e/sum-redis.spec.ts
View File

@@ -1,5 +1,5 @@
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import { expect } from 'chai';
import * as request from 'supertest';
@@ -17,10 +17,11 @@ describe('REDIS transport', () => {
app = module.createNestApplication();
server = app.getHttpAdapter().getInstance();
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.REDIS,
options: {
url: 'redis://0.0.0.0:6379',
host: '0.0.0.0',
port: 6379,
},
});
await app.startAllMicroservices();

4
integration/microservices/e2e/sum-rmq.spec.ts
View File

@@ -1,5 +1,5 @@
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import { expect } from 'chai';
import * as request from 'supertest';
@@ -17,7 +17,7 @@ describe('RabbitMQ transport', () => {
app = module.createNestApplication();
server = app.getHttpAdapter().getInstance();
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.RMQ,
options: {
urls: [`amqp://0.0.0.0:5672`],

4
integration/microservices/e2e/sum-rpc.spec.ts
View File

@@ -1,5 +1,5 @@
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import { expect } from 'chai';
import * as request from 'supertest';
@@ -18,7 +18,7 @@ describe('RPC transport', () => {
app = module.createNestApplication();
server = app.getHttpAdapter().getInstance();
app.connectMicroservice({
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.TCP,
options: {
host: '0.0.0.0',

4
integration/scopes/e2e/msvc-request-scope.spec.ts
View File

@@ -1,5 +1,5 @@
import { INestApplication } from '@nestjs/common';
import { Transport } from '@nestjs/microservices';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { Test } from '@nestjs/testing';
import { expect } from 'chai';
import * as request from 'supertest';
@@ -31,7 +31,7 @@ describe('Request scope (microservices)', () => {
}).compile();
app = module.createNestApplication();
app.connectMicroservice({ transport: Transport.TCP });
app.connectMicroservice<MicroserviceOptions>({ transport: Transport.TCP });
server = app.getHttpServer();
await app.init();

7
packages/core/test/nest-application.spec.ts
View File

@@ -6,6 +6,7 @@ import { GraphInspector } from '../inspector/graph-inspector';
import { NestApplication } from '../nest-application';
import { mapToExcludeRoute } from './../middleware/utils';
import { NoopHttpAdapter } from './utils/noop-adapter.spec';
import { MicroserviceOptions } from '@nestjs/microservices';
describe('NestApplication', () => {
describe('Hybrid Application', () => {
@@ -25,7 +26,9 @@ describe('NestApplication', () => {
{},
);
instance.useGlobalInterceptors(new Interceptor());
const microservice = instance.connectMicroservice({});
const microservice = instance.connectMicroservice<MicroserviceOptions>(
{},
);
expect((instance as any).config.getGlobalInterceptors().length).to.equal(
1,
);
@@ -44,7 +47,7 @@ describe('NestApplication', () => {
{},
);
instance.useGlobalInterceptors(new Interceptor());
const microservice = instance.connectMicroservice(
const microservice = instance.connectMicroservice<MicroserviceOptions>(
{},
{ inheritAppConfig: true },
);