mirror of
https://github.com/dadosfera/maestro.git
synced 2026-11-15 23:19:08 +00:00
update node version
This commit is contained in:
@@ -1,12 +1,15 @@
|
||||
import { OnModuleInit, Inject } from '@nestjs/common';
|
||||
import { ClientGrpc } from '@nestjs/microservices';
|
||||
import {
|
||||
DecodeGrpcStruct,
|
||||
EncodeJsonToGrpcStruct,
|
||||
InputCreateS3Request,
|
||||
InputNewCreateRequest,
|
||||
InputService,
|
||||
TestConnectionGetColumnsRequest,
|
||||
TestConnectionRequest,
|
||||
} from '@victorradael/protospack';
|
||||
import { lastValueFrom } from 'rxjs';
|
||||
import {
|
||||
objectCamelToSnake,
|
||||
objectSnakeToCamel,
|
||||
@@ -49,6 +52,15 @@ export class InputsClientService implements OnModuleInit {
|
||||
return createInputResponse;
|
||||
}
|
||||
|
||||
async createGeneric(createInputGeneric) {
|
||||
console.log('InputClientService', 'Create');
|
||||
const grpcPayload = EncodeJsonToGrpcStruct(createInputGeneric);
|
||||
const structPayload = await lastValueFrom(
|
||||
this.inputService.Create(objectSnakeToCamel(grpcPayload)),
|
||||
);
|
||||
return DecodeGrpcStruct(structPayload.input);
|
||||
}
|
||||
|
||||
async createS3Inputs(createInputDto: InputCreateS3Request) {
|
||||
console.log('InputClientService', 'Create');
|
||||
|
||||
|
||||
Reference in New Issue
Block a user