diff --git a/.nvmrc b/.nvmrc index 25bf17f..1667c1a 100644 --- a/.nvmrc +++ b/.nvmrc @@ -1 +1 @@ -18 \ No newline at end of file +18.3.0 \ No newline at end of file diff --git a/Dockerfile b/Dockerfile index f80c060..6f073d4 100644 --- a/Dockerfile +++ b/Dockerfile @@ -1,7 +1,8 @@ -FROM node:14.15.4-alpine3.12 as packages +FROM node:18.3.0-alpine3.15 as packages WORKDIR /packages ARG NPM_TOKEN COPY package.json . +COPY package-lock.json . COPY .npmrc . RUN npm install RUN rm -f ./.npmrc diff --git a/package-lock.json b/package-lock.json index 0ab3ab4..169589b 100644 --- a/package-lock.json +++ b/package-lock.json @@ -19,7 +19,7 @@ "@nestjs/platform-express": "^8.4.3", "@nestjs/schedule": "^1.1.0", "@nestjs/swagger": "^5.2.1", - "@victorradael/protospack": "2.4.2-1", + "@victorradael/protospack": "2.4.5", "axios": "^0.25.0", "cron-parser": "^4.4.0", "dotenv": "^14.2.0", @@ -2357,9 +2357,9 @@ } }, "node_modules/@victorradael/protospack": { - "version": "2.4.2-1", - "resolved": "https://registry.npmjs.org/@victorradael/protospack/-/protospack-2.4.2-1.tgz", - "integrity": "sha512-wdcGaK0DIEJeOHga1br11kq264JNdhdB1G2toy/u6TvAk90wwBKHNs/cZko0p9WFVuqHQOVehoHj7WJbJ3K25Q==", + "version": "2.4.5", + "resolved": "https://registry.npmjs.org/@victorradael/protospack/-/protospack-2.4.5.tgz", + "integrity": "sha512-yYitBEvWOIhJytwYuPvwOqysgyAK6awHAdEUeRH7s4emlqtY57Vpr0/p9snRQK5ytnxa9PbrgF5AewSe2/VkNA==", "dependencies": { "rxjs": "^7.5.5" } @@ -10932,9 +10932,9 @@ } }, "@victorradael/protospack": { - "version": "2.4.2-1", - "resolved": "https://registry.npmjs.org/@victorradael/protospack/-/protospack-2.4.2-1.tgz", - "integrity": "sha512-wdcGaK0DIEJeOHga1br11kq264JNdhdB1G2toy/u6TvAk90wwBKHNs/cZko0p9WFVuqHQOVehoHj7WJbJ3K25Q==", + "version": "2.4.5", + "resolved": "https://registry.npmjs.org/@victorradael/protospack/-/protospack-2.4.5.tgz", + "integrity": "sha512-yYitBEvWOIhJytwYuPvwOqysgyAK6awHAdEUeRH7s4emlqtY57Vpr0/p9snRQK5ytnxa9PbrgF5AewSe2/VkNA==", "requires": { "rxjs": "^7.5.5" } diff --git a/package.json b/package.json index 5889917..70b5a2e 100644 --- a/package.json +++ b/package.json @@ -5,6 +5,9 @@ "author": "", "private": true, "license": "UNLICENSED", + "engines": { + "node": "18.3.0" + }, "scripts": { "prebuild": "rimraf dist", "build": "nest build", @@ -31,7 +34,7 @@ "@nestjs/platform-express": "^8.4.3", "@nestjs/schedule": "^1.1.0", "@nestjs/swagger": "^5.2.1", - "@victorradael/protospack": "2.4.2-1", + "@victorradael/protospack": "2.4.5", "axios": "^0.25.0", "cron-parser": "^4.4.0", "dotenv": "^14.2.0", diff --git a/src/clients/inputs/client.service.ts b/src/clients/inputs/client.service.ts index 0ec746d..33f2e63 100644 --- a/src/clients/inputs/client.service.ts +++ b/src/clients/inputs/client.service.ts @@ -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');