integration of grpc

Signed-off-by: Manik2708 <[email protected]>
Manik2708 · Dec 28, 2024 · dfbc00d · dfbc00d
1 parent bae5186
commit dfbc00d
Show file tree

Hide file tree

Showing 16 changed files with 652 additions and 141 deletions.
diff --git a/.gitignore b/.gitignore
@@ -4,6 +4,8 @@
 src/hichat-1c68d-firebase-adminsdk-ov8j7-0df3df5a5e.json
 /.env
 /QueueService/.idea
+/.vscode
+/.idea
 # Logs
 logs
 *.log

diff --git a/.vscode/settings.json b/.vscode/settings.json
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -22,6 +22,8 @@
     "docs": "typedoc"
   },
   "dependencies": {
+    "@grpc/grpc-js": "^1.12.5",
+    "@grpc/proto-loader": "^0.7.13",
     "@nestjs/common": "^10.0.0",
     "@nestjs/core": "^10.0.0",
     "@nestjs/platform-express": "^10.0.0",
@@ -74,6 +76,7 @@
     "ts-jest": "^29.1.2",
     "ts-loader": "^9.4.3",
     "ts-node": "^10.9.1",
+    "ts-proto": "^2.6.1",
     "tsconfig-paths": "^4.2.0",
     "typescript": "^5.1.3"
   },

diff --git a/QueueService/pkg/grpc/server.proto → server.proto b/QueueService/pkg/grpc/server.proto → server.proto
diff --git a/src/Constants/injection_tokens.ts b/src/Constants/injection_tokens.ts
@@ -1,6 +1,6 @@
 export class InjectionTokens {
   static RedisClient: string = 'RedisClient';
   static CasClient: string = 'CasClient';
-  static IoServer: string = 'IoServer';
+  static GRPClientAddress: string = 'GRPClientAddress';
   static CreateQueue: string = 'CreateQueue';
 }
diff --git a/src/Controllers/Chats/chats_controllers.ts b/src/Controllers/Chats/chats_controllers.ts
@@ -12,13 +12,9 @@ import { ConflictError, ConflictErrorTypes } from '../../Errors/conflict_error';
 
 @Controller(ControllerPaths.CHATS_CONTROLLER)
 export class ChatsController {
-  private createQueue: CreateQueue;
   constructor(
     private readonly chatMessageService: ChatMessageForUserService,
-    @Inject(InjectionTokens.CreateQueue) createQueue: CreateQueue,
-  ) {
-    this.createQueue = createQueue;
-  }
+  ) {}
 
   @Post(ChatRoutes.SEND_CHAT_MESSAGE)
   async sendChatMessage(
-Original file line number
+Diff line change
@@ Expand Up / @@ -4,6 +4,8 @@ @@
     src/hichat-1c68d-firebase-adminsdk-ov8j7-0df3df5a5e.json
     /.env
     /QueueService/.idea
+    /.vscode
+    /.idea
     # Logs
     logs
     *.log
@@ Expand Down @@