add tests for close and listen for kafka server.

Author: Hexenon

integration/microservices/src/kafka/kafka.messages.controller.ts

@@ -7,6 +7,7 @@ import { UserEntity } from './entities/user.entity';
 import { BusinessEntity } from './entities/business.entity';
 import * as util from 'util';
 import { UserDto } from './dtos/user.dto';
+import { KafkaClient } from 'kafka-node';
 
 @Controller()
 export class KafkaMessagesController {
@@ -44,4 +45,7 @@ export class KafkaMessagesController {
   async createBusiness(params: {value: {business: BusinessDto}}) {
     return new BusinessEntity(params.value.business);
   }
+
+  async doSomething() {
+  }
 }

packages/microservices/server/server-kafka.ts

@@ -31,9 +31,9 @@ let kafkaPackage: any = {};
 
 export class ServerKafka extends Server implements CustomTransportStrategy {
   protected readonly logger = new Logger(ServerKafka.name);
-  private client: Kafka = null;
-  private consumer: Consumer = null;
-  private producer: Producer = null;
+  public client: Kafka = null;
+  public consumer: Consumer = null;
+  public producer: Producer = null;
   private readonly brokers: string[];
   private readonly clientId: string;
   private readonly groupId: string;

packages/microservices/test/server/server-kafka.spec.ts

@@ -0,0 +1,39 @@
+import { expect } from 'chai';
+import * as sinon from 'sinon';
+import { NO_MESSAGE_HANDLER } from '../../constants';
+import { ServerTCP } from '../../server/server-tcp';
+import { ServerKafka } from '../../server';
+import { Consumer, IHeaders, KafkaMessage } from '../../external/kafka.interface';
+
+describe('ServerKafka', () => {
+  let server: ServerKafka;
+
+  beforeEach(() => {
+    server = new ServerKafka({});
+  });
+
+  afterEach(() => {
+    server.close();
+  });
+  describe('close', () => {
+    it('should close server', () => {
+      server.close();
+      expect(server.consumer).to.be.null;
+      expect(server.producer).to.be.null;
+      expect(server.client).to.be.null;
+    });
+  });
+  describe('listen', () => {
+    it('should start server', async () => {
+      const callback = sinon.spy();
+      await server.listen(callback);
+      expect(callback.called).to.be.true;
+    });
+    it('should have kafka, producer and consumer connected', async () => {
+      await server.listen(() => {});
+      expect(server.client).to.be.not.null;
+      expect(server.producer).to.be.not.null;
+      expect(server.consumer).to.be.not.null;
+    });
+  });
+});