#5 wishId Generated in bookingProcess instead of ItineraryDispatcher #22 Bookingprocess connected to redis

Author: SylvainMasia

bookingProcessAPI/package-lock.json

@@ -25,7 +25,9 @@
     "@nestjs/core": "^7.0.0",
     "@nestjs/microservices": "^7.6.7",
     "@nestjs/platform-express": "^7.0.0",
+    "@types/redis": "^2.8.28",
     "kafkajs": "^1.15.0",
+    "redis": "^3.0.2",
     "reflect-metadata": "^0.1.13",
     "rimraf": "^3.0.2",
     "rxjs": "^6.5.4"

bookingProcessAPI/package.json

@@ -2,9 +2,10 @@ import { Module } from '@nestjs/common';
 import { AppController } from './app.controller';
 import { AppService } from './app.service';
 import { OffersModule } from './offers/offers.module';
+import { RedisModule } from './redis/redis.module';
 
 @Module({
-  imports: [OffersModule],
+  imports: [OffersModule, RedisModule],
   controllers: [AppController],
   providers: [AppService],
 })

bookingProcessAPI/src/app.module.ts

@@ -1,2 +1,3 @@
 export const PORT = process.env.PORT ? process.env.PORT : 80;
-export const KAFKA = process.env.KAFKA ? process.env.KAFKA : "localhost:9092";
+export const KAFKA = process.env.KAFKA ? process.env.KAFKA : "localhost:9092";
+export const REDIS_HOST = process.env.REDIS ? process.env.REDIS : "localhost:6379";

bookingProcessAPI/src/env_variable.ts

@@ -14,10 +14,10 @@ export class OffersController {
 
     @Get()
     getOffers(@Body() wishes: WishDTO[]): string {
-        Logger.log(`Searching request`);
+        Logger.log(`Starting new search request`);
         console.dir(wishes);
-        this.offersService.startSearchingProcess(wishes);
-        return `Search initiated`;
+        let startedWish = this.offersService.startSearchingProcess(wishes);
+        return `Search initiated, wishId generated : ${startedWish}`;
     }
 
     @Get('/payment')

bookingProcessAPI/src/offers/offers.controller.ts

@@ -3,6 +3,7 @@ import { OffersController } from './offers.controller';
 import { OffersService } from './offers.service';
 import { ClientsModule, Transport } from "@nestjs/microservices";
 import { KAFKA } from "../env_variable";
+import { RedisModule } from 'src/redis/redis.module';
 
 @Module({
   imports: [ClientsModule.register([
@@ -19,7 +20,7 @@ import { KAFKA } from "../env_variable";
         }
       }
     },
-  ]),],
+  ]), RedisModule],
   controllers: [OffersController],
   providers: [OffersService]
 })

bookingProcessAPI/src/offers/offers.module.ts

@@ -1,13 +1,16 @@
 import { Inject, Injectable } from '@nestjs/common';
 import { ClientKafka } from "@nestjs/microservices";
+import { RedisClient } from 'redis';
 import { WishDTO } from 'src/models/wish_dto';
 
 @Injectable()
 export class OffersService {
-    constructor(@Inject("BOOKINGPROCESS_SERVICE") private readonly kafkaClient: ClientKafka) { }
+    constructor(@Inject("BOOKINGPROCESS_SERVICE") private readonly kafkaClient: ClientKafka, @Inject("redis") private readonly redisClient: RedisClient) { }
 
     startSearchingProcess(wishes: WishDTO[]) {
-        this.kafkaClient.emit(`wish-requested`, wishes);
+        let wishRequest = { wishId: `${Date.now()}`, wishes: wishes };
+        this.kafkaClient.emit(`wish-requested`, wishRequest);
+        return wishRequest.wishId
     }
 
 }

bookingProcessAPI/src/offers/offers.service.ts

@@ -0,0 +1,14 @@
+import { Module } from '@nestjs/common';
+import * as redis from 'redis';
+import { REDIS_HOST } from '../env_variable';
+
+const RedisProvider = {
+    provide: "redis",
+    useFactory: () => redis.createClient(`redis://${REDIS_HOST}`)
+}
+
+@Module({
+    exports: ["redis"],
+    providers: [RedisProvider]
+})
+export class RedisModule { }

bookingProcessAPI/src/redis/redis.module.ts

@@ -21,6 +21,8 @@ services:
       - CAR_BOOKING_PORT=80
       - CAR_BOOKING_HOST=car-booking
       - KAFKA=kafka-service:9092
+      - REDIS=redis:6379
+
     volumes:
       - ./bookingProcessAPI/src/:/app/src/ # FOR HOT RELOAD ONLY
     depends_on: