Client Refactor

src/modules/connector/client.config.ts

@@ -1,31 +1,36 @@
 import { credentials } from '@grpc/grpc-js';
-import { ClientOptions, Transport } from '@nestjs/microservices';
+import {
+  ClientsProviderAsyncOptions,
+  GrpcOptions,
+  Transport,
+} from '@nestjs/microservices';
 import { ConnectorManager } from '@dadosfera/protospack-v2';
 
 export class ConnectorClientConfiguration {
-  config(): ClientOptions {
-    return {
-      transport: Transport.GRPC,
-      options: {
-        url: process.env.INFACTORY_URL,
-        package: [
-          ConnectorManager.ProtoPackages.WritePackage,
-          ConnectorManager.ProtoPackages.ReadPackage,
-        ],
-        credentials: process.env.LOCAL_ENV
-          ? undefined
-          : credentials.createSsl(),
-        protoPath: [
-          ConnectorManager.ProtoPaths.WriteFilePath,
-          ConnectorManager.ProtoPaths.ReadFilePath,
-        ],
-        loader: {
-          keepCase: true,
-          enums: String,
-          objects: true,
-          arrays: true,
-        },
+  public name = 'ConnectorClientConfiguration';
+  private config: GrpcOptions = {
+    transport: Transport.GRPC,
+    options: {
+      url: process.env.INFACTORY_URL,
+      package: [
+        ConnectorManager.ProtoPackages.WritePackage,
+        ConnectorManager.ProtoPackages.ReadPackage,
+      ],
+      credentials: process.env.LOCAL_ENV ? undefined : credentials.createSsl(),
+      protoPath: [
+        ConnectorManager.ProtoPaths.WriteFilePath,
+        ConnectorManager.ProtoPaths.ReadFilePath,
+      ],
+      loader: {
+        keepCase: true,
+        enums: String,
+        objects: true,
+        arrays: true,
       },
-    };
-  }
+    },
+  };
+  providerOptions: ClientsProviderAsyncOptions = {
+    name: this.name,
+    ...this.config,
+  };
 }

src/modules/connector/client.service.ts

@@ -8,12 +8,14 @@ import {
 import { ClientGrpc } from '@nestjs/microservices';
 import { ConnectorManager } from '@dadosfera/protospack-v2';
 import { lastValueFrom } from 'rxjs';
+import { ConnectorClientConfiguration } from './client.config';
 
 export class ConnectorClientService implements OnModuleInit {
   private connectorServiceRead: ConnectorManager.ReadService.ConnectorManagerReadServices;
   private connectorServiceWrite: ConnectorManager.WriteService.ConnectorManagerWriteServices;
   constructor(
-    @Inject('CONNECTOR_PACKAGE') private readonly grpcClient: ClientGrpc,
+    @Inject(ConnectorClientConfiguration.name)
+    private readonly grpcClient: ClientGrpc,
   ) {}
 
   onModuleInit() {

src/modules/connector/connector.module.ts

@@ -5,18 +5,11 @@ import { ConnectorClientConfiguration } from './client.config';
 import { ConnectorController } from './connector.controller';
 import { DadosferaLogger } from '@dadosfera/dadosfera-logs';
 
-const connectorClient = new ConnectorClientConfiguration();
+const client = new ConnectorClientConfiguration();
 
 @Module({
   controllers: [ConnectorController],
   providers: [ConnectorClientService, DadosferaLogger],
-  imports: [
-    ClientsModule.register([
-      {
-        name: 'CONNECTOR_PACKAGE',
-        ...connectorClient.config(),
-      },
-    ]),
-  ],
+  imports: [ClientsModule.register([client.providerOptions])],
 })
 export class ConnectorModule {}