Merge remote-tracking branch 'Nest/master' into 2984-kafka-reply-partitions

Author: mkaufmaner

integration/docker-compose.yml

@@ -1,50 +1,50 @@
 version: "3"
 
 services:
-  redis:
-    container_name: test-redis
-    image: redis
-    ports:
-      - "6379:6379"
-    restart: always
-  nats:
-    container_name: test-nats
-    image: nats
-    ports:
-      - "8222:8222"
-      - "4222:4222"
-      - "6222:6222"
-    restart: always
-  mqtt:
-    container_name: test-mqtt
-    image: toke/mosquitto
-    ports:
-      - "1883:1883"
-      - "9001:9001"
-    restart: always
-  mysql:
-    image: mysql:5.7.31
-    environment:
-      MYSQL_ROOT_PASSWORD: root
-      MYSQL_DATABASE: test
-    ports:
-      - "3306:3306"
-    restart: always
-  mongodb:
-    container_name: test-mongodb
-    image: mongo:latest
-    environment:
-      - MONGODB_DATABASE="test"
-    ports:
-      - 27017:27017
-  rabbit:
-    container_name: test-rabbit
-    hostname: rabbit
-    image: "rabbitmq:management"
-    ports:
-      - "15672:15672"
-      - "5672:5672"
-    tty: true
+  # redis:
+  #   container_name: test-redis
+  #   image: redis
+  #   ports:
+  #     - "6379:6379"
+  #   restart: always
+  # nats:
+  #   container_name: test-nats
+  #   image: nats
+  #   ports:
+  #     - "8222:8222"
+  #     - "4222:4222"
+  #     - "6222:6222"
+  #   restart: always
+  # mqtt:
+  #   container_name: test-mqtt
+  #   image: toke/mosquitto
+  #   ports:
+  #     - "1883:1883"
+  #     - "9001:9001"
+  #   restart: always
+  # mysql:
+  #   image: mysql:5.7.31
+  #   environment:
+  #     MYSQL_ROOT_PASSWORD: root
+  #     MYSQL_DATABASE: test
+  #   ports:
+  #     - "3306:3306"
+  #   restart: always
+  # mongodb:
+  #   container_name: test-mongodb
+  #   image: mongo:latest
+  #   environment:
+  #     - MONGODB_DATABASE="test"
+  #   ports:
+  #     - 27017:27017
+  # rabbit:
+  #   container_name: test-rabbit
+  #   hostname: rabbit
+  #   image: "rabbitmq:management"
+  #   ports:
+  #     - "15672:15672"
+  #     - "5672:5672"
+  #   tty: true
   zookeeper:
     container_name: test-zookeeper
     hostname: zookeeper
@@ -70,3 +70,4 @@ services:
       KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092
       KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
       KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
+      KAFKA_DELETE_TOPIC_ENABLE: 'true'

integration/hello-world/e2e/fastify-adapter.spec.ts

@@ -63,6 +63,14 @@ describe('Hello world (fastify adapter)', () => {
       });
   });
 
+  it(`/GET inject with LightMyRequest chaining API`, () => {
+    return app
+      .inject()
+      .get('/hello')
+      .end()
+      .then(({ payload }) => expect(payload).to.be.eql('Hello world!'));
+  });
+
   afterEach(async () => {
     await app.close();
   });

integration/microservices/e2e/orders-grpc.spec.ts

@@ -113,6 +113,11 @@ describe('Advanced GRPC transport', () => {
   it('GRPC Sending and receiving Stream from RX handler', async () => {
     const callHandler = client.sync();
 
+    // Get Set-Cookie from Metadata
+    callHandler.on('metadata', (metadata: GRPC.Metadata) => {
+      expect(metadata.get('Set-Cookie')[0]).to.eq('test_cookie=abcd');
+    });
+
     callHandler.on('data', (msg: number) => {
       // Do deep comparison (to.eql)
       expect(msg).to.eql({

integration/microservices/src/grpc-advanced/advanced.grpc.controller.ts

@@ -9,6 +9,7 @@ import {
 } from '@nestjs/microservices';
 import { join } from 'path';
 import { Observable, of, ReplaySubject, Subject } from 'rxjs';
+import { Metadata } from 'grpc';
 
 @Controller()
 export class AdvancedGrpcController {
@@ -84,7 +85,16 @@ export class AdvancedGrpcController {
    * @param messages
    */
   @GrpcStreamMethod('orders.OrderService')
-  async sync(messages: Observable<any>): Promise<any> {
+  async sync(
+    messages: Observable<any>,
+    metadata: Metadata,
+    call: any,
+  ): Promise<any> {
+    // Set Set-Cookie from Metadata
+    const srvMetadata = new Metadata();
+    srvMetadata.add('Set-Cookie', 'test_cookie=abcd');
+    call.sendMetadata(srvMetadata);
+
     const s = new Subject();
     const o = s.asObservable();
     messages.subscribe(msg => {

lerna.json

@@ -3,5 +3,5 @@
   "packages": [
     "packages/*"
   ],
-  "version": "7.4.4"
+  "version": "7.5.0"
 }

notes.tmp

@@ -0,0 +1,7 @@
+nyc --require ts-node/register mocha packages/microservices/test/helpers/kafka-round-robin-by-time-partition-assigner.spec.ts --reporter spec --retries 3 --require 'node_modules/reflect-metadata/Reflect.js' --exit
+
+
+./node_modules/.bin/nyc --require ts-node/register ./node_modules/.bin/mocha packages/microservices/test/helpers/kafka-round-robin-by-time-partition-assigner.spec.ts --reporter spec --retries 3 --require './node_modules/reflect-metadata/Reflect.js' --exit
+
+
+./node_modules/.bin/mocha \"integration/microservices/e2e/sum-kafka.spec.ts\" --reporter spec --require ts-node/register --require './node_modules/reflect-metadata/Reflect.js' --exit