From afa28a06996d5e641b22ebf5b6d8f67e0d7424f2 Mon Sep 17 00:00:00 2001 From: "Luiz H. R. Silva" Date: Thu, 20 Jun 2024 08:11:17 -0300 Subject: [PATCH] melhorias de tipagem --- README.md | 2 + .../pilao-de-dados/_deletar_registros.d.ts | 14 ++++ ...tar_registros.js => _deletar_registros.js} | 4 +- ..._registros.d.ts => _enviar_registros.d.ts} | 10 +-- ...viar_registros.js => _enviar_registros.js} | 4 +- .../pilao-de-dados/_serie_consultar.d.ts | 9 +-- ...serie_consultar.js => _serie_consultar.js} | 8 +- .../pilao-de-dados/deletar_registros.d.ts | 20 ----- dist-import/pilao-de-dados/index.d.ts | 66 +++++++-------- dist-import/pilao-de-dados/index.js | 8 +- .../{_variaveis.d.ts => variaveis.d.ts} | 3 + .../{_variaveis.js => variaveis.js} | 1 + .../pilao-de-dados/_deletar_registros.d.ts | 14 ++++ ...tar_registros.js => _deletar_registros.js} | 67 ++++++++-------- ..._registros.d.ts => _enviar_registros.d.ts} | 10 +-- ...viar_registros.js => _enviar_registros.js} | 71 ++++++++-------- .../pilao-de-dados/_serie_consultar.d.ts | 9 +-- ...serie_consultar.js => _serie_consultar.js} | 79 +++++++++--------- .../pilao-de-dados/deletar_registros.d.ts | 20 ----- dist-require/pilao-de-dados/index.d.ts | 66 +++++++-------- dist-require/pilao-de-dados/index.js | 28 +++---- .../{_variaveis.d.ts => variaveis.d.ts} | 3 + .../{_variaveis.js => variaveis.js} | 1 + package.json | 2 +- src/pilao-de-dados/_deletar_registros.ts | 44 ++++++++++ src/pilao-de-dados/_enviar_registros.ts | 69 ++++++++++++++++ src/pilao-de-dados/_serie_consultar.ts | 72 +++++++++++++++++ src/pilao-de-dados/deletar_registros.ts | 52 ------------ src/pilao-de-dados/enviar_registros.ts | 76 ------------------ src/pilao-de-dados/index.ts | 8 +- src/pilao-de-dados/serie_consultar.ts | 80 ------------------- .../{_variaveis.ts => variaveis.ts} | 1 + 32 files changed, 435 insertions(+), 486 deletions(-) create mode 100644 dist-import/pilao-de-dados/_deletar_registros.d.ts rename dist-import/pilao-de-dados/{deletar_registros.js => _deletar_registros.js} (88%) rename dist-import/pilao-de-dados/{enviar_registros.d.ts => _enviar_registros.d.ts} (82%) rename dist-import/pilao-de-dados/{enviar_registros.js => _enviar_registros.js} (91%) rename dist-require/pilao-de-dados/serie_consultar.d.ts => dist-import/pilao-de-dados/_serie_consultar.d.ts (69%) rename dist-import/pilao-de-dados/{serie_consultar.js => _serie_consultar.js} (86%) delete mode 100644 dist-import/pilao-de-dados/deletar_registros.d.ts rename dist-import/pilao-de-dados/{_variaveis.d.ts => variaveis.d.ts} (89%) rename dist-import/pilao-de-dados/{_variaveis.js => variaveis.js} (96%) create mode 100644 dist-require/pilao-de-dados/_deletar_registros.d.ts rename dist-require/pilao-de-dados/{deletar_registros.js => _deletar_registros.js} (61%) rename dist-require/pilao-de-dados/{enviar_registros.d.ts => _enviar_registros.d.ts} (82%) rename dist-require/pilao-de-dados/{enviar_registros.js => _enviar_registros.js} (61%) rename dist-import/pilao-de-dados/serie_consultar.d.ts => dist-require/pilao-de-dados/_serie_consultar.d.ts (69%) rename dist-require/pilao-de-dados/{serie_consultar.js => _serie_consultar.js} (59%) delete mode 100644 dist-require/pilao-de-dados/deletar_registros.d.ts rename dist-require/pilao-de-dados/{_variaveis.d.ts => variaveis.d.ts} (89%) rename dist-require/pilao-de-dados/{_variaveis.js => variaveis.js} (96%) create mode 100644 src/pilao-de-dados/_deletar_registros.ts create mode 100644 src/pilao-de-dados/_enviar_registros.ts create mode 100644 src/pilao-de-dados/_serie_consultar.ts delete mode 100644 src/pilao-de-dados/deletar_registros.ts delete mode 100644 src/pilao-de-dados/enviar_registros.ts delete mode 100644 src/pilao-de-dados/serie_consultar.ts rename src/pilao-de-dados/{_variaveis.ts => variaveis.ts} (96%) diff --git a/README.md b/README.md index 6896378..8359e31 100644 --- a/README.md +++ b/README.md @@ -1 +1,3 @@ # drivers + +`pnpm config set fetch-timeout 60000` diff --git a/dist-import/pilao-de-dados/_deletar_registros.d.ts b/dist-import/pilao-de-dados/_deletar_registros.d.ts new file mode 100644 index 0000000..ee9ff98 --- /dev/null +++ b/dist-import/pilao-de-dados/_deletar_registros.d.ts @@ -0,0 +1,14 @@ +import type { tipoResposta } from "p-respostas"; +import { z } from "zod"; +import { type zp_produto_conta } from "./variaveis"; +export declare const zp_deletar_registros: z.ZodObject<{ + tabela: z.ZodString; + codigos: z.ZodArray; +}, "strip", z.ZodTypeAny, { + tabela: string; + codigos: string[]; +}, { + tabela: string; + codigos: string[]; +}>; +export declare const deletar_registros: ({ conta, produto, emDesenvolvimento }: z.infer) => ({ codigos, tabela, }: z.infer) => Promise>; diff --git a/dist-import/pilao-de-dados/deletar_registros.js b/dist-import/pilao-de-dados/_deletar_registros.js similarity index 88% rename from dist-import/pilao-de-dados/deletar_registros.js rename to dist-import/pilao-de-dados/_deletar_registros.js index ca0add0..261a777 100644 --- a/dist-import/pilao-de-dados/deletar_registros.js +++ b/dist-import/pilao-de-dados/_deletar_registros.js @@ -10,13 +10,13 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge import node_fetch from "cross-fetch"; import { respostaComuns } from "p-respostas"; import { z } from "zod"; -import { PREFIXO, baseUrlPilao } from "./_variaveis"; +import { PREFIXO, baseUrlPilao } from "./variaveis"; //enviar registros para base de dados export const zp_deletar_registros = z.object({ tabela: z.string(), codigos: z.array(z.string()), }); -export const deletar_registros = ({ emDesenvolvimento, cliente: { conta, produto }, parametros: { codigos, tabela }, }) => __awaiter(void 0, void 0, void 0, function* () { +export const deletar_registros = ({ conta, produto, emDesenvolvimento }) => ({ codigos, tabela, }) => __awaiter(void 0, void 0, void 0, function* () { const url = new URL(`${baseUrlPilao(emDesenvolvimento)}${PREFIXO}/${Object.keys({ deletar_registros })[0]}/${produto}/${conta}`); const tamanhoBlocos = 1000; while (codigos.length > 0) { diff --git a/dist-import/pilao-de-dados/enviar_registros.d.ts b/dist-import/pilao-de-dados/_enviar_registros.d.ts similarity index 82% rename from dist-import/pilao-de-dados/enviar_registros.d.ts rename to dist-import/pilao-de-dados/_enviar_registros.d.ts index 34878a4..6145dab 100644 --- a/dist-import/pilao-de-dados/enviar_registros.d.ts +++ b/dist-import/pilao-de-dados/_enviar_registros.d.ts @@ -1,6 +1,6 @@ import type { tipoResposta } from "p-respostas"; import { z } from "zod"; -import { type zp_produto_conta } from "./_variaveis"; +import { type zp_produto_conta } from "./variaveis"; export declare const zp_registrar_base_dados: z.ZodObject<{ tabela: z.ZodString; colunas: z.ZodArray[]; }>; -export declare const enviar_registros: ({ emDesenvolvimento, cliente: { conta, produto }, parametros: { registros, tabela }, }: { - emDesenvolvimento?: boolean | undefined | null; - /** Identificação do cliente */ - cliente: z.infer; - /** Parametros da função */ - parametros: z.infer; -}) => Promise>; +export declare const enviar_registros: ({ conta, produto, emDesenvolvimento }: z.infer) => ({ registros, tabela, }: z.infer) => Promise>; diff --git a/dist-import/pilao-de-dados/enviar_registros.js b/dist-import/pilao-de-dados/_enviar_registros.js similarity index 91% rename from dist-import/pilao-de-dados/enviar_registros.js rename to dist-import/pilao-de-dados/_enviar_registros.js index dd441a9..8b20029 100644 --- a/dist-import/pilao-de-dados/enviar_registros.js +++ b/dist-import/pilao-de-dados/_enviar_registros.js @@ -10,7 +10,7 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge import node_fetch from "cross-fetch"; import { respostaComuns } from "p-respostas"; import { z } from "zod"; -import { PREFIXO, baseUrlPilao, z_tipo_coluna_base_dados, } from "./_variaveis"; +import { PREFIXO, baseUrlPilao, z_tipo_coluna_base_dados, } from "./variaveis"; export const zp_registrar_base_dados = z.object({ tabela: z.string(), colunas: z.array(z.object({ @@ -26,7 +26,7 @@ export const zp_enviar_registros = z.object({ tipo: z_tipo_coluna_base_dados.optional().nullable(), }))), }); -export const enviar_registros = ({ emDesenvolvimento, cliente: { conta, produto }, parametros: { registros, tabela }, }) => __awaiter(void 0, void 0, void 0, function* () { +export const enviar_registros = ({ conta, produto, emDesenvolvimento }) => ({ registros, tabela, }) => __awaiter(void 0, void 0, void 0, function* () { const url = new URL(`${baseUrlPilao(emDesenvolvimento)}${PREFIXO}/${Object.keys({ enviar_registros })[0]}/${produto}/${conta}`); const tamanhoBlocos = 1000; while (registros.length > 0) { diff --git a/dist-require/pilao-de-dados/serie_consultar.d.ts b/dist-import/pilao-de-dados/_serie_consultar.d.ts similarity index 69% rename from dist-require/pilao-de-dados/serie_consultar.d.ts rename to dist-import/pilao-de-dados/_serie_consultar.d.ts index 27d6367..c763ce5 100644 --- a/dist-require/pilao-de-dados/serie_consultar.d.ts +++ b/dist-import/pilao-de-dados/_serie_consultar.d.ts @@ -1,6 +1,6 @@ import type { tipoResposta } from "p-respostas"; import { z } from "zod"; -import { type zp_produto_conta } from "./_variaveis"; +import { type zp_produto_conta } from "./variaveis"; export declare const zp_serie_registrar: z.ZodObject<{ tabela: z.ZodString; colanuEixoX: z.ZodString; @@ -17,12 +17,7 @@ export declare const zp_serie_registrar: z.ZodObject<{ agregacao: "contagem" | "somatoria"; colunaAgrupamento?: string[] | undefined; }>; -export declare const serie_consultar: ({ emDesenvolvimento, cliente, parametros, }: { - emDesenvolvimento?: boolean | undefined | null; - /** Identificação do cliente */ - cliente: z.infer; - parametros: z.infer; -}) => { +export declare const serie_consultar: (cliente: z.infer) => (parametros: z.infer) => { dados: () => Promise { +export const serie_consultar = (cliente) => (parametros) => { const dados = () => __awaiter(void 0, void 0, void 0, function* () { - const url = new URL(`${baseUrlPilao(emDesenvolvimento)}${`${PREFIXO}/${tiposSeriesAgregacoes.enum.contagem}/${cliente.produto}/${cliente.conta}`}`); + const url = new URL(`${baseUrlPilao(cliente.emDesenvolvimento)}${`${PREFIXO}/${tiposSeriesAgregacoes.enum.contagem}/${cliente.produto}/${cliente.conta}`}`); const resp = yield node_fetch(url.toString(), { method: "POST", body: JSON.stringify(parametros), @@ -35,7 +35,7 @@ export const serie_consultar = ({ emDesenvolvimento, cliente, parametros, }) => cliente, parametros, }; - const vUrl = new URL(`${emDesenvolvimento + const vUrl = new URL(`${cliente.emDesenvolvimento ? "http://127.0.0.1:5081" : "https://carro-de-boi.idz.one"}${PREFIXO}/${tiposSeriesAgregacoes.enum.contagem}`); const serie = encodeURIComponent(JSON.stringify(pr, null, 2)); diff --git a/dist-import/pilao-de-dados/deletar_registros.d.ts b/dist-import/pilao-de-dados/deletar_registros.d.ts deleted file mode 100644 index 5b036e0..0000000 --- a/dist-import/pilao-de-dados/deletar_registros.d.ts +++ /dev/null @@ -1,20 +0,0 @@ -import type { tipoResposta } from "p-respostas"; -import { z } from "zod"; -import { type zp_produto_conta } from "./_variaveis"; -export declare const zp_deletar_registros: z.ZodObject<{ - tabela: z.ZodString; - codigos: z.ZodArray; -}, "strip", z.ZodTypeAny, { - tabela: string; - codigos: string[]; -}, { - tabela: string; - codigos: string[]; -}>; -export declare const deletar_registros: ({ emDesenvolvimento, cliente: { conta, produto }, parametros: { codigos, tabela }, }: { - emDesenvolvimento?: boolean | undefined | null; - /** Identificação do cliente */ - cliente: z.infer; - /** Parametros da função */ - parametros: z.infer; -}) => Promise>; diff --git a/dist-import/pilao-de-dados/index.d.ts b/dist-import/pilao-de-dados/index.d.ts index e7be596..67e5d81 100644 --- a/dist-import/pilao-de-dados/index.d.ts +++ b/dist-import/pilao-de-dados/index.d.ts @@ -1,4 +1,4 @@ -import { tiposSeriesAgregacoes } from "./_variaveis"; +import { tiposSeriesAgregacoes } from "./variaveis"; export { tiposSeriesAgregacoes }; export declare const pPilao: { zp_registrar_base_dados: import("zod").ZodObject<{ @@ -26,19 +26,16 @@ export declare const pPilao: { tipo: "texto" | "numero" | "confirmacao" | "lista_texto" | "lista_numero" | "data" | "mes"; }[]; }>; - enviar_registros: ({ emDesenvolvimento, cliente: { conta, produto }, parametros: { registros, tabela }, }: { - emDesenvolvimento?: boolean | null | undefined; - cliente: { - produto: string; - conta: string; - }; - parametros: { - tabela: string; - registros: Record[]; - }; + enviar_registros: ({ conta, produto, emDesenvolvimento }: { + produto: string; + conta: string; + emDesenvolvimento?: boolean | undefined; + }) => ({ registros, tabela, }: { + tabela: string; + registros: Record[]; }) => Promise>; zp_enviar_registros: import("zod").ZodObject<{ tabela: import("zod").ZodString; @@ -81,18 +78,15 @@ export declare const pPilao: { agregacao: "contagem" | "somatoria"; colunaAgrupamento?: string[] | undefined; }>; - serie_consultar: ({ emDesenvolvimento, cliente, parametros, }: { - emDesenvolvimento?: boolean | null | undefined; - cliente: { - produto: string; - conta: string; - }; - parametros: { - tabela: string; - colanuEixoX: string; - agregacao: "contagem" | "somatoria"; - colunaAgrupamento?: string[] | undefined; - }; + serie_consultar: (cliente: { + produto: string; + conta: string; + emDesenvolvimento?: boolean | undefined; + }) => (parametros: { + tabela: string; + colanuEixoX: string; + agregacao: "contagem" | "somatoria"; + colunaAgrupamento?: string[] | undefined; }) => { dados: () => Promise; }, "strip", import("zod").ZodTypeAny, { produto: string; conta: string; + emDesenvolvimento?: boolean | undefined; }, { produto: string; conta: string; + emDesenvolvimento?: boolean | undefined; }>; validarZ: (zodType: import("zod").ZodType, objeto: any, mensagem: string) => import("p-respostas").tipoRespostaErro | import("p-respostas").tipoRespostaSucesso; - deletar_registros: ({ emDesenvolvimento, cliente: { conta, produto }, parametros: { codigos, tabela }, }: { - emDesenvolvimento?: boolean | null | undefined; - cliente: { - produto: string; - conta: string; - }; - parametros: { - tabela: string; - codigos: string[]; - }; + deletar_registros: ({ conta, produto, emDesenvolvimento }: { + produto: string; + conta: string; + emDesenvolvimento?: boolean | undefined; + }) => ({ codigos, tabela, }: { + tabela: string; + codigos: string[]; }) => Promise>; zp_deletar_registros: import("zod").ZodObject<{ tabela: import("zod").ZodString; diff --git a/dist-import/pilao-de-dados/index.js b/dist-import/pilao-de-dados/index.js index 9637fdc..270c282 100644 --- a/dist-import/pilao-de-dados/index.js +++ b/dist-import/pilao-de-dados/index.js @@ -1,7 +1,7 @@ -import { tiposSeriesAgregacoes, validarZ, zp_produto_conta } from "./_variaveis"; -import { deletar_registros, zp_deletar_registros } from "./deletar_registros"; -import { enviar_registros, zp_enviar_registros, zp_registrar_base_dados, } from "./enviar_registros"; -import { serie_consultar, zp_serie_registrar } from "./serie_consultar"; +import { deletar_registros, zp_deletar_registros } from "./_deletar_registros"; +import { enviar_registros, zp_enviar_registros, zp_registrar_base_dados, } from "./_enviar_registros"; +import { tiposSeriesAgregacoes, validarZ, zp_produto_conta } from "./variaveis"; +import { serie_consultar, zp_serie_registrar } from "./_serie_consultar"; export { tiposSeriesAgregacoes }; export const pPilao = { zp_registrar_base_dados, diff --git a/dist-import/pilao-de-dados/_variaveis.d.ts b/dist-import/pilao-de-dados/variaveis.d.ts similarity index 89% rename from dist-import/pilao-de-dados/_variaveis.d.ts rename to dist-import/pilao-de-dados/variaveis.d.ts index c36213c..350e148 100644 --- a/dist-import/pilao-de-dados/_variaveis.d.ts +++ b/dist-import/pilao-de-dados/variaveis.d.ts @@ -5,12 +5,15 @@ export declare const validarZ: (zodType: z.ZodType, objeto: any, m export declare const zp_produto_conta: z.ZodObject<{ produto: z.ZodString; conta: z.ZodString; + emDesenvolvimento: z.ZodOptional; }, "strip", z.ZodTypeAny, { produto: string; conta: string; + emDesenvolvimento?: boolean | undefined; }, { produto: string; conta: string; + emDesenvolvimento?: boolean | undefined; }>; export declare const z_tipo_coluna_base_dados: z.ZodEnum<["texto", "numero", "confirmacao", "lista_texto", "lista_numero", "data", "mes"]>; export declare const tiposSeriesAgregacoes: z.ZodEnum<["contagem", "somatoria"]>; diff --git a/dist-import/pilao-de-dados/_variaveis.js b/dist-import/pilao-de-dados/variaveis.js similarity index 96% rename from dist-import/pilao-de-dados/_variaveis.js rename to dist-import/pilao-de-dados/variaveis.js index e6e436f..90bbd8e 100644 --- a/dist-import/pilao-de-dados/_variaveis.js +++ b/dist-import/pilao-de-dados/variaveis.js @@ -13,6 +13,7 @@ export const validarZ = (zodType, objeto, mensagem) => { export const zp_produto_conta = z.object({ produto: z.string(), conta: z.string(), + emDesenvolvimento: z.boolean().optional(), }); export const z_tipo_coluna_base_dados = z.enum([ "texto", diff --git a/dist-require/pilao-de-dados/_deletar_registros.d.ts b/dist-require/pilao-de-dados/_deletar_registros.d.ts new file mode 100644 index 0000000..ee9ff98 --- /dev/null +++ b/dist-require/pilao-de-dados/_deletar_registros.d.ts @@ -0,0 +1,14 @@ +import type { tipoResposta } from "p-respostas"; +import { z } from "zod"; +import { type zp_produto_conta } from "./variaveis"; +export declare const zp_deletar_registros: z.ZodObject<{ + tabela: z.ZodString; + codigos: z.ZodArray; +}, "strip", z.ZodTypeAny, { + tabela: string; + codigos: string[]; +}, { + tabela: string; + codigos: string[]; +}>; +export declare const deletar_registros: ({ conta, produto, emDesenvolvimento }: z.infer) => ({ codigos, tabela, }: z.infer) => Promise>; diff --git a/dist-require/pilao-de-dados/deletar_registros.js b/dist-require/pilao-de-dados/_deletar_registros.js similarity index 61% rename from dist-require/pilao-de-dados/deletar_registros.js rename to dist-require/pilao-de-dados/_deletar_registros.js index 3c0c9df..b1638fa 100644 --- a/dist-require/pilao-de-dados/deletar_registros.js +++ b/dist-require/pilao-de-dados/_deletar_registros.js @@ -43,44 +43,47 @@ exports.deletar_registros = exports.zp_deletar_registros = void 0; var cross_fetch_1 = __importDefault(require("cross-fetch")); var p_respostas_1 = require("p-respostas"); var zod_1 = require("zod"); -var _variaveis_1 = require("./_variaveis"); +var variaveis_1 = require("./variaveis"); //enviar registros para base de dados exports.zp_deletar_registros = zod_1.z.object({ tabela: zod_1.z.string(), codigos: zod_1.z.array(zod_1.z.string()), }); var deletar_registros = function (_a) { - var emDesenvolvimento = _a.emDesenvolvimento, _b = _a.cliente, conta = _b.conta, produto = _b.produto, _c = _a.parametros, codigos = _c.codigos, tabela = _c.tabela; - return __awaiter(void 0, void 0, void 0, function () { - var url, tamanhoBlocos, bloco, resp; - return __generator(this, function (_d) { - switch (_d.label) { - case 0: - url = new URL("".concat((0, _variaveis_1.baseUrlPilao)(emDesenvolvimento)).concat(_variaveis_1.PREFIXO, "/").concat(Object.keys({ deletar_registros: exports.deletar_registros })[0], "/").concat(produto, "/").concat(conta)); - tamanhoBlocos = 1000; - _d.label = 1; - case 1: - if (!(codigos.length > 0)) return [3 /*break*/, 3]; - bloco = codigos.splice(0, tamanhoBlocos); - return [4 /*yield*/, (0, cross_fetch_1.default)(url.toString(), { - method: "POST", - body: JSON.stringify({ tabela: tabela, codigos: bloco }), - headers: { "Content-Type": "application/json" }, - }) - .then(function (r) { return r.json(); }) - .catch(function (e) { - return p_respostas_1.respostaComuns.erro("Erro ao enviar registros", [e.message]); - }) - .then(function (r) { return r; })]; - case 2: - resp = _d.sent(); - if (resp.eErro) { - return [2 /*return*/, resp]; - } - return [3 /*break*/, 1]; - case 3: return [2 /*return*/, p_respostas_1.respostaComuns.valor(true)]; - } + var conta = _a.conta, produto = _a.produto, emDesenvolvimento = _a.emDesenvolvimento; + return function (_a) { + var codigos = _a.codigos, tabela = _a.tabela; + return __awaiter(void 0, void 0, void 0, function () { + var url, tamanhoBlocos, bloco, resp; + return __generator(this, function (_b) { + switch (_b.label) { + case 0: + url = new URL("".concat((0, variaveis_1.baseUrlPilao)(emDesenvolvimento)).concat(variaveis_1.PREFIXO, "/").concat(Object.keys({ deletar_registros: exports.deletar_registros })[0], "/").concat(produto, "/").concat(conta)); + tamanhoBlocos = 1000; + _b.label = 1; + case 1: + if (!(codigos.length > 0)) return [3 /*break*/, 3]; + bloco = codigos.splice(0, tamanhoBlocos); + return [4 /*yield*/, (0, cross_fetch_1.default)(url.toString(), { + method: "POST", + body: JSON.stringify({ tabela: tabela, codigos: bloco }), + headers: { "Content-Type": "application/json" }, + }) + .then(function (r) { return r.json(); }) + .catch(function (e) { + return p_respostas_1.respostaComuns.erro("Erro ao enviar registros", [e.message]); + }) + .then(function (r) { return r; })]; + case 2: + resp = _b.sent(); + if (resp.eErro) { + return [2 /*return*/, resp]; + } + return [3 /*break*/, 1]; + case 3: return [2 /*return*/, p_respostas_1.respostaComuns.valor(true)]; + } + }); }); - }); + }; }; exports.deletar_registros = deletar_registros; diff --git a/dist-require/pilao-de-dados/enviar_registros.d.ts b/dist-require/pilao-de-dados/_enviar_registros.d.ts similarity index 82% rename from dist-require/pilao-de-dados/enviar_registros.d.ts rename to dist-require/pilao-de-dados/_enviar_registros.d.ts index 34878a4..6145dab 100644 --- a/dist-require/pilao-de-dados/enviar_registros.d.ts +++ b/dist-require/pilao-de-dados/_enviar_registros.d.ts @@ -1,6 +1,6 @@ import type { tipoResposta } from "p-respostas"; import { z } from "zod"; -import { type zp_produto_conta } from "./_variaveis"; +import { type zp_produto_conta } from "./variaveis"; export declare const zp_registrar_base_dados: z.ZodObject<{ tabela: z.ZodString; colunas: z.ZodArray[]; }>; -export declare const enviar_registros: ({ emDesenvolvimento, cliente: { conta, produto }, parametros: { registros, tabela }, }: { - emDesenvolvimento?: boolean | undefined | null; - /** Identificação do cliente */ - cliente: z.infer; - /** Parametros da função */ - parametros: z.infer; -}) => Promise>; +export declare const enviar_registros: ({ conta, produto, emDesenvolvimento }: z.infer) => ({ registros, tabela, }: z.infer) => Promise>; diff --git a/dist-require/pilao-de-dados/enviar_registros.js b/dist-require/pilao-de-dados/_enviar_registros.js similarity index 61% rename from dist-require/pilao-de-dados/enviar_registros.js rename to dist-require/pilao-de-dados/_enviar_registros.js index f88f131..3d598e2 100644 --- a/dist-require/pilao-de-dados/enviar_registros.js +++ b/dist-require/pilao-de-dados/_enviar_registros.js @@ -43,12 +43,12 @@ exports.enviar_registros = exports.zp_enviar_registros = exports.zp_registrar_ba var cross_fetch_1 = __importDefault(require("cross-fetch")); var p_respostas_1 = require("p-respostas"); var zod_1 = require("zod"); -var _variaveis_1 = require("./_variaveis"); +var variaveis_1 = require("./variaveis"); exports.zp_registrar_base_dados = zod_1.z.object({ tabela: zod_1.z.string(), colunas: zod_1.z.array(zod_1.z.object({ coluna: zod_1.z.string(), - tipo: _variaveis_1.z_tipo_coluna_base_dados, + tipo: variaveis_1.z_tipo_coluna_base_dados, })), }); //enviar registros para base de dados @@ -56,41 +56,44 @@ exports.zp_enviar_registros = zod_1.z.object({ tabela: zod_1.z.string(), registros: zod_1.z.array(zod_1.z.record(zod_1.z.string(), zod_1.z.object({ valor: zod_1.z.any(), - tipo: _variaveis_1.z_tipo_coluna_base_dados.optional().nullable(), + tipo: variaveis_1.z_tipo_coluna_base_dados.optional().nullable(), }))), }); var enviar_registros = function (_a) { - var emDesenvolvimento = _a.emDesenvolvimento, _b = _a.cliente, conta = _b.conta, produto = _b.produto, _c = _a.parametros, registros = _c.registros, tabela = _c.tabela; - return __awaiter(void 0, void 0, void 0, function () { - var url, tamanhoBlocos, bloco, resp; - return __generator(this, function (_d) { - switch (_d.label) { - case 0: - url = new URL("".concat((0, _variaveis_1.baseUrlPilao)(emDesenvolvimento)).concat(_variaveis_1.PREFIXO, "/").concat(Object.keys({ enviar_registros: exports.enviar_registros })[0], "/").concat(produto, "/").concat(conta)); - tamanhoBlocos = 1000; - _d.label = 1; - case 1: - if (!(registros.length > 0)) return [3 /*break*/, 3]; - bloco = registros.splice(0, tamanhoBlocos); - return [4 /*yield*/, (0, cross_fetch_1.default)(url.toString(), { - method: "POST", - body: JSON.stringify({ tabela: tabela, registros: bloco }), - headers: { "Content-Type": "application/json" }, - }) - .then(function (r) { return r.json(); }) - .catch(function (e) { - return p_respostas_1.respostaComuns.erro("Erro ao enviar registros", [e.message]); - }) - .then(function (r) { return r; })]; - case 2: - resp = _d.sent(); - if (resp.eErro) { - return [2 /*return*/, resp]; - } - return [3 /*break*/, 1]; - case 3: return [2 /*return*/, p_respostas_1.respostaComuns.valor(true)]; - } + var conta = _a.conta, produto = _a.produto, emDesenvolvimento = _a.emDesenvolvimento; + return function (_a) { + var registros = _a.registros, tabela = _a.tabela; + return __awaiter(void 0, void 0, void 0, function () { + var url, tamanhoBlocos, bloco, resp; + return __generator(this, function (_b) { + switch (_b.label) { + case 0: + url = new URL("".concat((0, variaveis_1.baseUrlPilao)(emDesenvolvimento)).concat(variaveis_1.PREFIXO, "/").concat(Object.keys({ enviar_registros: exports.enviar_registros })[0], "/").concat(produto, "/").concat(conta)); + tamanhoBlocos = 1000; + _b.label = 1; + case 1: + if (!(registros.length > 0)) return [3 /*break*/, 3]; + bloco = registros.splice(0, tamanhoBlocos); + return [4 /*yield*/, (0, cross_fetch_1.default)(url.toString(), { + method: "POST", + body: JSON.stringify({ tabela: tabela, registros: bloco }), + headers: { "Content-Type": "application/json" }, + }) + .then(function (r) { return r.json(); }) + .catch(function (e) { + return p_respostas_1.respostaComuns.erro("Erro ao enviar registros", [e.message]); + }) + .then(function (r) { return r; })]; + case 2: + resp = _b.sent(); + if (resp.eErro) { + return [2 /*return*/, resp]; + } + return [3 /*break*/, 1]; + case 3: return [2 /*return*/, p_respostas_1.respostaComuns.valor(true)]; + } + }); }); - }); + }; }; exports.enviar_registros = enviar_registros; diff --git a/dist-import/pilao-de-dados/serie_consultar.d.ts b/dist-require/pilao-de-dados/_serie_consultar.d.ts similarity index 69% rename from dist-import/pilao-de-dados/serie_consultar.d.ts rename to dist-require/pilao-de-dados/_serie_consultar.d.ts index 27d6367..c763ce5 100644 --- a/dist-import/pilao-de-dados/serie_consultar.d.ts +++ b/dist-require/pilao-de-dados/_serie_consultar.d.ts @@ -1,6 +1,6 @@ import type { tipoResposta } from "p-respostas"; import { z } from "zod"; -import { type zp_produto_conta } from "./_variaveis"; +import { type zp_produto_conta } from "./variaveis"; export declare const zp_serie_registrar: z.ZodObject<{ tabela: z.ZodString; colanuEixoX: z.ZodString; @@ -17,12 +17,7 @@ export declare const zp_serie_registrar: z.ZodObject<{ agregacao: "contagem" | "somatoria"; colunaAgrupamento?: string[] | undefined; }>; -export declare const serie_consultar: ({ emDesenvolvimento, cliente, parametros, }: { - emDesenvolvimento?: boolean | undefined | null; - /** Identificação do cliente */ - cliente: z.infer; - parametros: z.infer; -}) => { +export declare const serie_consultar: (cliente: z.infer) => (parametros: z.infer) => { dados: () => Promise; -}, "strip", z.ZodTypeAny, { - tabela: string; - codigos: string[]; -}, { - tabela: string; - codigos: string[]; -}>; -export declare const deletar_registros: ({ emDesenvolvimento, cliente: { conta, produto }, parametros: { codigos, tabela }, }: { - emDesenvolvimento?: boolean | undefined | null; - /** Identificação do cliente */ - cliente: z.infer; - /** Parametros da função */ - parametros: z.infer; -}) => Promise>; diff --git a/dist-require/pilao-de-dados/index.d.ts b/dist-require/pilao-de-dados/index.d.ts index e7be596..67e5d81 100644 --- a/dist-require/pilao-de-dados/index.d.ts +++ b/dist-require/pilao-de-dados/index.d.ts @@ -1,4 +1,4 @@ -import { tiposSeriesAgregacoes } from "./_variaveis"; +import { tiposSeriesAgregacoes } from "./variaveis"; export { tiposSeriesAgregacoes }; export declare const pPilao: { zp_registrar_base_dados: import("zod").ZodObject<{ @@ -26,19 +26,16 @@ export declare const pPilao: { tipo: "texto" | "numero" | "confirmacao" | "lista_texto" | "lista_numero" | "data" | "mes"; }[]; }>; - enviar_registros: ({ emDesenvolvimento, cliente: { conta, produto }, parametros: { registros, tabela }, }: { - emDesenvolvimento?: boolean | null | undefined; - cliente: { - produto: string; - conta: string; - }; - parametros: { - tabela: string; - registros: Record[]; - }; + enviar_registros: ({ conta, produto, emDesenvolvimento }: { + produto: string; + conta: string; + emDesenvolvimento?: boolean | undefined; + }) => ({ registros, tabela, }: { + tabela: string; + registros: Record[]; }) => Promise>; zp_enviar_registros: import("zod").ZodObject<{ tabela: import("zod").ZodString; @@ -81,18 +78,15 @@ export declare const pPilao: { agregacao: "contagem" | "somatoria"; colunaAgrupamento?: string[] | undefined; }>; - serie_consultar: ({ emDesenvolvimento, cliente, parametros, }: { - emDesenvolvimento?: boolean | null | undefined; - cliente: { - produto: string; - conta: string; - }; - parametros: { - tabela: string; - colanuEixoX: string; - agregacao: "contagem" | "somatoria"; - colunaAgrupamento?: string[] | undefined; - }; + serie_consultar: (cliente: { + produto: string; + conta: string; + emDesenvolvimento?: boolean | undefined; + }) => (parametros: { + tabela: string; + colanuEixoX: string; + agregacao: "contagem" | "somatoria"; + colunaAgrupamento?: string[] | undefined; }) => { dados: () => Promise; }, "strip", import("zod").ZodTypeAny, { produto: string; conta: string; + emDesenvolvimento?: boolean | undefined; }, { produto: string; conta: string; + emDesenvolvimento?: boolean | undefined; }>; validarZ: (zodType: import("zod").ZodType, objeto: any, mensagem: string) => import("p-respostas").tipoRespostaErro | import("p-respostas").tipoRespostaSucesso; - deletar_registros: ({ emDesenvolvimento, cliente: { conta, produto }, parametros: { codigos, tabela }, }: { - emDesenvolvimento?: boolean | null | undefined; - cliente: { - produto: string; - conta: string; - }; - parametros: { - tabela: string; - codigos: string[]; - }; + deletar_registros: ({ conta, produto, emDesenvolvimento }: { + produto: string; + conta: string; + emDesenvolvimento?: boolean | undefined; + }) => ({ codigos, tabela, }: { + tabela: string; + codigos: string[]; }) => Promise>; zp_deletar_registros: import("zod").ZodObject<{ tabela: import("zod").ZodString; diff --git a/dist-require/pilao-de-dados/index.js b/dist-require/pilao-de-dados/index.js index 6f89463..1f75be0 100644 --- a/dist-require/pilao-de-dados/index.js +++ b/dist-require/pilao-de-dados/index.js @@ -1,19 +1,19 @@ "use strict"; Object.defineProperty(exports, "__esModule", { value: true }); exports.pPilao = exports.tiposSeriesAgregacoes = void 0; -var _variaveis_1 = require("./_variaveis"); -Object.defineProperty(exports, "tiposSeriesAgregacoes", { enumerable: true, get: function () { return _variaveis_1.tiposSeriesAgregacoes; } }); -var deletar_registros_1 = require("./deletar_registros"); -var enviar_registros_1 = require("./enviar_registros"); -var serie_consultar_1 = require("./serie_consultar"); +var _deletar_registros_1 = require("./_deletar_registros"); +var _enviar_registros_1 = require("./_enviar_registros"); +var variaveis_1 = require("./variaveis"); +Object.defineProperty(exports, "tiposSeriesAgregacoes", { enumerable: true, get: function () { return variaveis_1.tiposSeriesAgregacoes; } }); +var _serie_consultar_1 = require("./_serie_consultar"); exports.pPilao = { - zp_registrar_base_dados: enviar_registros_1.zp_registrar_base_dados, - enviar_registros: enviar_registros_1.enviar_registros, - zp_enviar_registros: enviar_registros_1.zp_enviar_registros, - zp_serie_registrar: serie_consultar_1.zp_serie_registrar, - serie_consultar: serie_consultar_1.serie_consultar, - zp_produto_conta: _variaveis_1.zp_produto_conta, - validarZ: _variaveis_1.validarZ, - deletar_registros: deletar_registros_1.deletar_registros, - zp_deletar_registros: deletar_registros_1.zp_deletar_registros, + zp_registrar_base_dados: _enviar_registros_1.zp_registrar_base_dados, + enviar_registros: _enviar_registros_1.enviar_registros, + zp_enviar_registros: _enviar_registros_1.zp_enviar_registros, + zp_serie_registrar: _serie_consultar_1.zp_serie_registrar, + serie_consultar: _serie_consultar_1.serie_consultar, + zp_produto_conta: variaveis_1.zp_produto_conta, + validarZ: variaveis_1.validarZ, + deletar_registros: _deletar_registros_1.deletar_registros, + zp_deletar_registros: _deletar_registros_1.zp_deletar_registros, }; diff --git a/dist-require/pilao-de-dados/_variaveis.d.ts b/dist-require/pilao-de-dados/variaveis.d.ts similarity index 89% rename from dist-require/pilao-de-dados/_variaveis.d.ts rename to dist-require/pilao-de-dados/variaveis.d.ts index c36213c..350e148 100644 --- a/dist-require/pilao-de-dados/_variaveis.d.ts +++ b/dist-require/pilao-de-dados/variaveis.d.ts @@ -5,12 +5,15 @@ export declare const validarZ: (zodType: z.ZodType, objeto: any, m export declare const zp_produto_conta: z.ZodObject<{ produto: z.ZodString; conta: z.ZodString; + emDesenvolvimento: z.ZodOptional; }, "strip", z.ZodTypeAny, { produto: string; conta: string; + emDesenvolvimento?: boolean | undefined; }, { produto: string; conta: string; + emDesenvolvimento?: boolean | undefined; }>; export declare const z_tipo_coluna_base_dados: z.ZodEnum<["texto", "numero", "confirmacao", "lista_texto", "lista_numero", "data", "mes"]>; export declare const tiposSeriesAgregacoes: z.ZodEnum<["contagem", "somatoria"]>; diff --git a/dist-require/pilao-de-dados/_variaveis.js b/dist-require/pilao-de-dados/variaveis.js similarity index 96% rename from dist-require/pilao-de-dados/_variaveis.js rename to dist-require/pilao-de-dados/variaveis.js index fa25aee..967633f 100644 --- a/dist-require/pilao-de-dados/_variaveis.js +++ b/dist-require/pilao-de-dados/variaveis.js @@ -17,6 +17,7 @@ exports.validarZ = validarZ; exports.zp_produto_conta = zod_1.z.object({ produto: zod_1.z.string(), conta: zod_1.z.string(), + emDesenvolvimento: zod_1.z.boolean().optional(), }); exports.z_tipo_coluna_base_dados = zod_1.z.enum([ "texto", diff --git a/package.json b/package.json index 32df20d..8c4a9ec 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "p-drives", - "version": "0.83.0", + "version": "0.84.0", "description": "", "main": "src/index.ts", "exports": { diff --git a/src/pilao-de-dados/_deletar_registros.ts b/src/pilao-de-dados/_deletar_registros.ts new file mode 100644 index 0000000..8b65623 --- /dev/null +++ b/src/pilao-de-dados/_deletar_registros.ts @@ -0,0 +1,44 @@ +import node_fetch from "cross-fetch" +import type { tipoResposta } from "p-respostas" +import { respostaComuns } from "p-respostas" +import { z } from "zod" +import { PREFIXO, baseUrlPilao, type zp_produto_conta } from "./variaveis" +//enviar registros para base de dados +export const zp_deletar_registros = z.object({ + tabela: z.string(), + codigos: z.array(z.string()), +}) + +export const deletar_registros = + ({ conta, produto, emDesenvolvimento }: z.infer) => + async ({ + codigos, + tabela, + }: z.infer): Promise> => { + const url = new URL( + `${baseUrlPilao( + emDesenvolvimento, + )}${PREFIXO}/${Object.keys({ deletar_registros })[0]}/${produto}/${conta}`, + ) + const tamanhoBlocos = 1000 + + while (codigos.length > 0) { + const bloco = codigos.splice(0, tamanhoBlocos) + const resp = await node_fetch(url.toString(), { + method: "POST", + body: JSON.stringify({ tabela, codigos: bloco }), + headers: { "Content-Type": "application/json" }, + }) + .then((r) => r.json()) + .catch((e) => + respostaComuns.erro("Erro ao enviar registros", [e.message]), + ) + .then((r) => r as tipoResposta) + + if (resp.eErro) { + return resp + } + } + + return respostaComuns.valor(true) + } diff --git a/src/pilao-de-dados/_enviar_registros.ts b/src/pilao-de-dados/_enviar_registros.ts new file mode 100644 index 0000000..b315b94 --- /dev/null +++ b/src/pilao-de-dados/_enviar_registros.ts @@ -0,0 +1,69 @@ +import node_fetch from "cross-fetch" +import type { tipoResposta } from "p-respostas" +import { respostaComuns } from "p-respostas" +import { z } from "zod" +import { + PREFIXO, + baseUrlPilao, + z_tipo_coluna_base_dados, + type zp_produto_conta, +} from "./variaveis" + +export const zp_registrar_base_dados = z.object({ + tabela: z.string(), + colunas: z.array( + z.object({ + coluna: z.string(), + tipo: z_tipo_coluna_base_dados, + }), + ), +}) + +//enviar registros para base de dados +export const zp_enviar_registros = z.object({ + tabela: z.string(), + registros: z.array( + z.record( + z.string(), + z.object({ + valor: z.any(), + tipo: z_tipo_coluna_base_dados.optional().nullable(), + }), + ), + ), +}) + +export const enviar_registros = + ({ conta, produto, emDesenvolvimento }: z.infer) => + async ({ + registros, + tabela, + }: z.infer): Promise> => { + const url = new URL( + `${baseUrlPilao( + emDesenvolvimento, + )}${PREFIXO}/${Object.keys({ enviar_registros })[0]}/${produto}/${conta}`, + ) + + const tamanhoBlocos = 1000 + + while (registros.length > 0) { + const bloco = registros.splice(0, tamanhoBlocos) + const resp = await node_fetch(url.toString(), { + method: "POST", + body: JSON.stringify({ tabela, registros: bloco }), + headers: { "Content-Type": "application/json" }, + }) + .then((r) => r.json()) + .catch((e) => + respostaComuns.erro("Erro ao enviar registros", [e.message]), + ) + .then((r) => r as tipoResposta) + + if (resp.eErro) { + return resp + } + } + + return respostaComuns.valor(true) + } diff --git a/src/pilao-de-dados/_serie_consultar.ts b/src/pilao-de-dados/_serie_consultar.ts new file mode 100644 index 0000000..c9da4d8 --- /dev/null +++ b/src/pilao-de-dados/_serie_consultar.ts @@ -0,0 +1,72 @@ +import node_fetch from "cross-fetch" +import type { tipoResposta } from "p-respostas" +import { respostaComuns } from "p-respostas" +import { z } from "zod" +import { + PREFIXO, + baseUrlPilao, + tiposSeriesAgregacoes, + type zp_produto_conta, +} from "./variaveis" + +export const zp_serie_registrar = z.object({ + tabela: z.string(), + colanuEixoX: z.string(), + colunaAgrupamento: z.string().array().optional(), + agregacao: tiposSeriesAgregacoes, +}) + +export const serie_consultar = + (cliente: z.infer) => + (parametros: z.infer) => { + const dados = async (): Promise< + tipoResposta<{ + registros: any[] + legenda: string + serie: z.infer + }> + > => { + const url = new URL( + `${baseUrlPilao(cliente.emDesenvolvimento)}${`${PREFIXO}/${ + tiposSeriesAgregacoes.enum.contagem + }/${cliente.produto}/${cliente.conta}`}`, + ) + + const resp = await node_fetch(url.toString(), { + method: "POST", + body: JSON.stringify(parametros), + headers: { "Content-Type": "application/json" }, + }) + .then((r) => r.json()) + .catch((e) => + respostaComuns.erro("Erro ao enviar registros", [e.message]), + ) + .then((r) => r as tipoResposta) + + return resp + } + + const url = (): string => { + const pr = { + cliente, + parametros, + } + + const vUrl = new URL( + `${ + cliente.emDesenvolvimento + ? "http://127.0.0.1:5081" + : "https://carro-de-boi.idz.one" + }${PREFIXO}/${tiposSeriesAgregacoes.enum.contagem}`, + ) + + const serie = encodeURIComponent(JSON.stringify(pr, null, 2)) + + return `${vUrl.href}?serie=${serie}` + } + + return { + dados, + url, + } + } diff --git a/src/pilao-de-dados/deletar_registros.ts b/src/pilao-de-dados/deletar_registros.ts deleted file mode 100644 index 1326ecb..0000000 --- a/src/pilao-de-dados/deletar_registros.ts +++ /dev/null @@ -1,52 +0,0 @@ -import node_fetch from "cross-fetch" -import type { tipoResposta } from "p-respostas" -import { respostaComuns } from "p-respostas" -import { z } from "zod" -import { PREFIXO, baseUrlPilao, type zp_produto_conta } from "./_variaveis" -//enviar registros para base de dados -export const zp_deletar_registros = z.object({ - tabela: z.string(), - codigos: z.array(z.string()), -}) - -export const deletar_registros = async ({ - emDesenvolvimento, - cliente: { conta, produto }, - parametros: { codigos, tabela }, -}: { - emDesenvolvimento?: boolean | undefined | null - - /** Identificação do cliente */ - cliente: z.infer - /** Parametros da função */ - - parametros: z.infer -}): Promise> => { - const url = new URL( - `${baseUrlPilao( - emDesenvolvimento, - )}${PREFIXO}/${Object.keys({ deletar_registros })[0]}/${produto}/${conta}`, - ) - - const tamanhoBlocos = 1000 - - while (codigos.length > 0) { - const bloco = codigos.splice(0, tamanhoBlocos) - const resp = await node_fetch(url.toString(), { - method: "POST", - body: JSON.stringify({ tabela, codigos: bloco }), - headers: { "Content-Type": "application/json" }, - }) - .then((r) => r.json()) - .catch((e) => - respostaComuns.erro("Erro ao enviar registros", [e.message]), - ) - .then((r) => r as tipoResposta) - - if (resp.eErro) { - return resp - } - } - - return respostaComuns.valor(true) -} diff --git a/src/pilao-de-dados/enviar_registros.ts b/src/pilao-de-dados/enviar_registros.ts deleted file mode 100644 index cc8200d..0000000 --- a/src/pilao-de-dados/enviar_registros.ts +++ /dev/null @@ -1,76 +0,0 @@ -import node_fetch from "cross-fetch" -import type { tipoResposta } from "p-respostas" -import { respostaComuns } from "p-respostas" -import { z } from "zod" -import { - PREFIXO, - baseUrlPilao, - z_tipo_coluna_base_dados, - type zp_produto_conta, -} from "./_variaveis" - -export const zp_registrar_base_dados = z.object({ - tabela: z.string(), - colunas: z.array( - z.object({ - coluna: z.string(), - tipo: z_tipo_coluna_base_dados, - }), - ), -}) - -//enviar registros para base de dados -export const zp_enviar_registros = z.object({ - tabela: z.string(), - registros: z.array( - z.record( - z.string(), - z.object({ - valor: z.any(), - tipo: z_tipo_coluna_base_dados.optional().nullable(), - }), - ), - ), -}) - -export const enviar_registros = async ({ - emDesenvolvimento, - cliente: { conta, produto }, - parametros: { registros, tabela }, -}: { - emDesenvolvimento?: boolean | undefined | null - - /** Identificação do cliente */ - cliente: z.infer - /** Parametros da função */ - - parametros: z.infer -}): Promise> => { - const url = new URL( - `${baseUrlPilao( - emDesenvolvimento, - )}${PREFIXO}/${Object.keys({ enviar_registros })[0]}/${produto}/${conta}`, - ) - - const tamanhoBlocos = 1000 - - while (registros.length > 0) { - const bloco = registros.splice(0, tamanhoBlocos) - const resp = await node_fetch(url.toString(), { - method: "POST", - body: JSON.stringify({ tabela, registros: bloco }), - headers: { "Content-Type": "application/json" }, - }) - .then((r) => r.json()) - .catch((e) => - respostaComuns.erro("Erro ao enviar registros", [e.message]), - ) - .then((r) => r as tipoResposta) - - if (resp.eErro) { - return resp - } - } - - return respostaComuns.valor(true) -} diff --git a/src/pilao-de-dados/index.ts b/src/pilao-de-dados/index.ts index 5848368..d202b01 100644 --- a/src/pilao-de-dados/index.ts +++ b/src/pilao-de-dados/index.ts @@ -1,12 +1,12 @@ -import { tiposSeriesAgregacoes, validarZ, zp_produto_conta } from "./_variaveis" -import { deletar_registros, zp_deletar_registros } from "./deletar_registros" +import { deletar_registros, zp_deletar_registros } from "./_deletar_registros" import { enviar_registros, zp_enviar_registros, zp_registrar_base_dados, -} from "./enviar_registros" +} from "./_enviar_registros" +import { tiposSeriesAgregacoes, validarZ, zp_produto_conta } from "./variaveis" -import { serie_consultar, zp_serie_registrar } from "./serie_consultar" +import { serie_consultar, zp_serie_registrar } from "./_serie_consultar" export { tiposSeriesAgregacoes } diff --git a/src/pilao-de-dados/serie_consultar.ts b/src/pilao-de-dados/serie_consultar.ts deleted file mode 100644 index 10331ae..0000000 --- a/src/pilao-de-dados/serie_consultar.ts +++ /dev/null @@ -1,80 +0,0 @@ -import node_fetch from "cross-fetch" -import type { tipoResposta } from "p-respostas" -import { respostaComuns } from "p-respostas" -import { z } from "zod" -import { - PREFIXO, - baseUrlPilao, - tiposSeriesAgregacoes, - type zp_produto_conta, -} from "./_variaveis" - -export const zp_serie_registrar = z.object({ - tabela: z.string(), - colanuEixoX: z.string(), - colunaAgrupamento: z.string().array().optional(), - agregacao: tiposSeriesAgregacoes, -}) - -export const serie_consultar = ({ - emDesenvolvimento, - cliente, - parametros, -}: { - emDesenvolvimento?: boolean | undefined | null - - /** Identificação do cliente */ - cliente: z.infer - parametros: z.infer -}) => { - const dados = async (): Promise< - tipoResposta<{ - registros: any[] - legenda: string - serie: z.infer - }> - > => { - const url = new URL( - `${baseUrlPilao(emDesenvolvimento)}${`${PREFIXO}/${ - tiposSeriesAgregacoes.enum.contagem - }/${cliente.produto}/${cliente.conta}`}`, - ) - - const resp = await node_fetch(url.toString(), { - method: "POST", - body: JSON.stringify(parametros), - headers: { "Content-Type": "application/json" }, - }) - .then((r) => r.json()) - .catch((e) => - respostaComuns.erro("Erro ao enviar registros", [e.message]), - ) - .then((r) => r as tipoResposta) - - return resp - } - - const url = (): string => { - const pr = { - cliente, - parametros, - } - - const vUrl = new URL( - `${ - emDesenvolvimento - ? "http://127.0.0.1:5081" - : "https://carro-de-boi.idz.one" - }${PREFIXO}/${tiposSeriesAgregacoes.enum.contagem}`, - ) - - const serie = encodeURIComponent(JSON.stringify(pr, null, 2)) - - return `${vUrl.href}?serie=${serie}` - } - - return { - dados, - url, - } -} diff --git a/src/pilao-de-dados/_variaveis.ts b/src/pilao-de-dados/variaveis.ts similarity index 96% rename from src/pilao-de-dados/_variaveis.ts rename to src/pilao-de-dados/variaveis.ts index d941ccc..2e16511 100644 --- a/src/pilao-de-dados/_variaveis.ts +++ b/src/pilao-de-dados/variaveis.ts @@ -24,6 +24,7 @@ export const validarZ = ( export const zp_produto_conta = z.object({ produto: z.string(), conta: z.string(), + emDesenvolvimento: z.boolean().optional(), }) export const z_tipo_coluna_base_dados = z.enum([