Initial Commit/ gateway-input-microservice-implementation

src/inputs/input-grpc-client.controller.ts

@@ -0,0 +1,62 @@
+import {
+  Get,
+  Post,
+  Controller,
+  Delete,
+  OnModuleInit,
+  Put,
+  Param
+} from '@nestjs/common';
+import { Client, ClientGrpc, Payload } from '@nestjs/microservices';
+import { CreateInputGrpcClientDto } from './dto/create-input-grpc-client.dto';
+import { UpdateInputGrpcClientDto } from './dto/update-input-grpc-client.dto';
+import { InputGrpcClientService } from './input-grpc-client.service';
+import { GrpcClientConfiguration } from './config/grpc-client';
+import { TestConnectionDTO } from './dto/test-connection-grpc-client.dto';
+
+@Controller('input-grpc-client')
+export class InputGrpcClientController implements OnModuleInit {
+  @Client(GrpcClientConfiguration)
+  private inputServiceClient: ClientGrpc;
+
+  private inputService: InputGrpcClientService;
+
+  onModuleInit() {
+    this.inputService =
+      this.inputServiceClient.getService<InputGrpcClientService>('InputService');
+  }
+
+  @Post()
+  async create(@Payload() createInputDto: CreateInputGrpcClientDto) {
+    return this.inputService.create(createInputDto);
+  }
+
+  @Get()
+  list() {
+    return this.inputService.list();
+  }
+
+  @Get(':id')
+  show(@Param() id: string) {
+    return this.inputService.show(id);
+  }
+
+  @Put(':id')
+  update(
+    @Payload() updateInputDto: UpdateInputGrpcClientDto,
+    @Param() id: string,
+  ) {
+    return this.inputService.update(id, updateInputDto);
+  }
+
+  @Delete(':id')
+  remove(@Param() id: string) {
+    return this.inputService.remove(id);
+  }
+
+  @Get('/test-connection')
+  testConnection(@Payload() testConnectionDTO:TestConnectionDTO){
+
+    return this.inputService.testConnection(testConnectionDTO)
+  }
+}