diff --git a/dist-import/autenticacao/_codigoContaSite.js b/dist-import/autenticacao/_codigoContaSite.js index 48ceb5c..43fbee3 100644 --- a/dist-import/autenticacao/_codigoContaSite.js +++ b/dist-import/autenticacao/_codigoContaSite.js @@ -10,7 +10,7 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge import { respostaComuns } from "p-respostas"; import { urlAutenticacao } from "./_urlAutenticacao"; import node_fetch from "cross-fetch"; -export const codigoContaSite = ({ ambiente, post, }) => __awaiter(void 0, void 0, void 0, function* () { +export const codigoContaSite = (_a) => __awaiter(void 0, [_a], void 0, function* ({ ambiente, post, }) { const url = `${urlAutenticacao(ambiente)}/api/codigo_prefeitura_site`; try { const resp = yield node_fetch(url, { diff --git a/dist-import/autenticacao/_usuarios_quipo_governo.js b/dist-import/autenticacao/_usuarios_quipo_governo.js index 4423f56..a357deb 100644 --- a/dist-import/autenticacao/_usuarios_quipo_governo.js +++ b/dist-import/autenticacao/_usuarios_quipo_governo.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 { urlAutenticacao } from "./_urlAutenticacao"; -export const usuarios_quipo_governo = ({ token_produto, ambiente, }) => __awaiter(void 0, void 0, void 0, function* () { +export const usuarios_quipo_governo = (_a) => __awaiter(void 0, [_a], void 0, function* ({ token_produto, ambiente, }) { const url = `${urlAutenticacao(ambiente)}/api/usuarios_quipo_governo`; if (!token_produto) return respostaComuns.erro("token_produto não informado"); diff --git a/dist-import/autenticacao/_usuarios_quipo_vincular.d.ts b/dist-import/autenticacao/_usuarios_quipo_vincular.d.ts index 3aa424c..565f11c 100644 --- a/dist-import/autenticacao/_usuarios_quipo_vincular.d.ts +++ b/dist-import/autenticacao/_usuarios_quipo_vincular.d.ts @@ -6,6 +6,6 @@ export declare const usuarios_quipo_vincular: ({ token_produto, ambiente, conta, token_produto: string; conta: string; vinculo: string; - codigo_usuario?: string | undefined; + codigo_usuario?: string; email: string; }) => Promise>; diff --git a/dist-import/autenticacao/_usuarios_quipo_vincular.js b/dist-import/autenticacao/_usuarios_quipo_vincular.js index 1658e9a..23ee790 100644 --- a/dist-import/autenticacao/_usuarios_quipo_vincular.js +++ b/dist-import/autenticacao/_usuarios_quipo_vincular.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 { urlAutenticacao } from "./_urlAutenticacao"; -export const usuarios_quipo_vincular = ({ token_produto, ambiente, conta, vinculo, codigo_usuario, email, }) => __awaiter(void 0, void 0, void 0, function* () { +export const usuarios_quipo_vincular = (_a) => __awaiter(void 0, [_a], void 0, function* ({ token_produto, ambiente, conta, vinculo, codigo_usuario, email, }) { const url = `${urlAutenticacao(ambiente)}/api/vinculos__criar`; if (!token_produto) return respostaComuns.erro("token_produto não informado"); diff --git a/dist-import/autenticacao/_validarToken.js b/dist-import/autenticacao/_validarToken.js index e4cc5ef..2dc27be 100644 --- a/dist-import/autenticacao/_validarToken.js +++ b/dist-import/autenticacao/_validarToken.js @@ -10,7 +10,7 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge import { urlAutenticacao } from "./_urlAutenticacao"; import node_fetch from "cross-fetch"; /** faz a validação do token */ -export const validarToken = ({ ambiente, post, }) => __awaiter(void 0, void 0, void 0, function* () { +export const validarToken = (_a) => __awaiter(void 0, [_a], void 0, function* ({ ambiente, post, }) { const url = `${urlAutenticacao(ambiente)}/api/validar_token`; try { const resposta = yield node_fetch(url, { diff --git a/dist-import/autenticacao/index.d.ts b/dist-import/autenticacao/index.d.ts index 5371040..03cb0c9 100644 --- a/dist-import/autenticacao/index.d.ts +++ b/dist-import/autenticacao/index.d.ts @@ -3,29 +3,28 @@ export type { tipoUsuarioExterno }; /** todas as rotas de comunicação com autenticador partem dessa variável */ export declare const pAutenticacao: { validarToken: ({ ambiente, post, }: { - /** todas as rotas de comunicação com autenticador partem dessa variável */ - ambiente: "desenvolvimento" | "producao"; + ambiente: import("zod").TypeOf; post: { token: string; }; }) => Promise<"valido" | "erro">; - urlAutenticacao: (ambiente: "desenvolvimento" | "producao") => string; + urlAutenticacao: (ambiente: import("zod").TypeOf) => string; codigoContaSite: ({ ambiente, post, }: { - ambiente: "desenvolvimento" | "producao"; + ambiente: import("zod").TypeOf; post: { site: string; }; }) => Promise>; usuarios_quipo_governo: ({ token_produto, ambiente, }: { - ambiente: "desenvolvimento" | "producao"; + ambiente: import("zod").TypeOf; token_produto: string; }) => Promise>; usuarios_quipo_vincular: ({ token_produto, ambiente, conta, vinculo, codigo_usuario, email, }: { - ambiente: "desenvolvimento" | "producao"; + ambiente: import("zod").TypeOf; token_produto: string; conta: string; vinculo: string; - codigo_usuario?: string | undefined; + codigo_usuario?: string; email: string; }) => Promise>; }; diff --git a/dist-import/pilao-de-dados/_deletar_registros.js b/dist-import/pilao-de-dados/_deletar_registros.js index 261a777..7108ad2 100644 --- a/dist-import/pilao-de-dados/_deletar_registros.js +++ b/dist-import/pilao-de-dados/_deletar_registros.js @@ -16,7 +16,7 @@ export const zp_deletar_registros = z.object({ tabela: z.string(), codigos: z.array(z.string()), }); -export const deletar_registros = ({ conta, produto, emDesenvolvimento }) => ({ codigos, tabela, }) => __awaiter(void 0, void 0, void 0, function* () { +export const deletar_registros = ({ conta, produto, emDesenvolvimento }) => (_a) => __awaiter(void 0, [_a], void 0, function* ({ codigos, tabela, }) { 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.js b/dist-import/pilao-de-dados/_enviar_registros.js index e86d002..ca70a8c 100644 --- a/dist-import/pilao-de-dados/_enviar_registros.js +++ b/dist-import/pilao-de-dados/_enviar_registros.js @@ -26,7 +26,7 @@ export const zp_enviar_registros = z.object({ tipo: z_tipo_coluna_base_dados.optional().nullable(), }))), }); -export const enviar_registros = ({ conta, produto, emDesenvolvimento }) => ({ registros, tabela, }) => __awaiter(void 0, void 0, void 0, function* () { +export const enviar_registros = ({ conta, produto, emDesenvolvimento }) => (_a) => __awaiter(void 0, [_a], void 0, function* ({ registros, tabela, }) { 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-import/pilao-de-dados/index.d.ts b/dist-import/pilao-de-dados/index.d.ts index 4a9cec2..dc7c4f3 100644 --- a/dist-import/pilao-de-dados/index.d.ts +++ b/dist-import/pilao-de-dados/index.d.ts @@ -1,4 +1,7 @@ -import { tiposSeriesAgregacoes } from "./variaveis"; +import { zp_deletar_registros } from "./_deletar_registros"; +import { zp_enviar_registros } from "./_enviar_registros"; +import { tiposSeriesAgregacoes, zp_produto_conta } from "./variaveis"; +import { zp_serie_registrar } from "./_serie_consultar"; export { tiposSeriesAgregacoes }; export declare const pPilao: { zp_registrar_base_dados: import("zod").ZodObject<{ @@ -26,17 +29,7 @@ export declare const pPilao: { tipo: "texto" | "numero" | "confirmacao" | "lista_texto" | "lista_numero" | "data" | "mes"; }[]; }>; - enviar_registros: ({ conta, produto, emDesenvolvimento }: { - conta: string; - produto: string; - emDesenvolvimento?: boolean | undefined; - }) => ({ registros, tabela, }: { - tabela: string; - registros: Record[]; - }) => Promise>; + enviar_registros: ({ conta, produto, emDesenvolvimento }: import("zod").TypeOf) => ({ registros, tabela, }: import("zod").TypeOf) => Promise>; zp_enviar_registros: import("zod").ZodObject<{ tabela: import("zod").ZodString; registros: import("zod").ZodArray; - serie_consultar: (cliente: { - conta: string; - produto: string; - emDesenvolvimento?: boolean | undefined; - }) => (parametros: { - tabela: string; - colanuEixoX: string; - agregacao: "contagem" | "somatoria"; - colunaAgrupamento?: string[] | undefined; - }) => { + serie_consultar: (cliente: import("zod").TypeOf) => (parametros: import("zod").TypeOf) => { dados: () => Promise; }>>; url: () => string; }; @@ -113,15 +92,8 @@ export declare const pPilao: { produto: string; emDesenvolvimento?: boolean | undefined; }>; - validarZ: (zodType: import("zod").ZodType, objeto: any, mensagem: string) => import("p-respostas").tipoRespostaErro | import("p-respostas").tipoRespostaSucesso; - deletar_registros: ({ conta, produto, emDesenvolvimento }: { - conta: string; - produto: string; - emDesenvolvimento?: boolean | undefined; - }) => ({ codigos, tabela, }: { - tabela: string; - codigos: string[]; - }) => Promise>; + validarZ: (zodType: import("zod").ZodType, objeto: any, mensagem: string) => import("p-respostas").tipoRespostaErro | import("p-respostas").tipoRespostaSucesso; + deletar_registros: ({ conta, produto, emDesenvolvimento }: import("zod").TypeOf) => ({ codigos, tabela, }: import("zod").TypeOf) => Promise>; zp_deletar_registros: import("zod").ZodObject<{ tabela: import("zod").ZodString; codigos: import("zod").ZodArray; diff --git a/dist-import/pilao-de-dados/variaveis.d.ts b/dist-import/pilao-de-dados/variaveis.d.ts index 1902f1e..5a1227b 100644 --- a/dist-import/pilao-de-dados/variaveis.d.ts +++ b/dist-import/pilao-de-dados/variaveis.d.ts @@ -1,7 +1,7 @@ import { z } from "zod"; export declare const zAmbiente: z.ZodEnum<["desenvolvimento", "producao"]>; export declare const PREFIXO = "/pilao-de-dados"; -export declare const validarZ: (zodType: z.ZodType, objeto: any, mensagem: string) => import("p-respostas").tipoRespostaErro | import("p-respostas").tipoRespostaSucesso; +export declare const validarZ: (zodType: z.ZodType, objeto: any, mensagem: string) => import("p-respostas").tipoRespostaErro | import("p-respostas").tipoRespostaSucesso; export declare const zp_produto_conta: z.ZodObject<{ produto: z.ZodString; conta: z.ZodString; diff --git a/dist-require/autenticacao/_codigoContaSite.js b/dist-require/autenticacao/_codigoContaSite.js index d14920b..8a909eb 100644 --- a/dist-require/autenticacao/_codigoContaSite.js +++ b/dist-require/autenticacao/_codigoContaSite.js @@ -43,36 +43,34 @@ exports.codigoContaSite = void 0; var p_respostas_1 = require("p-respostas"); var _urlAutenticacao_1 = require("./_urlAutenticacao"); var cross_fetch_1 = __importDefault(require("cross-fetch")); -var codigoContaSite = function (_a) { - var ambiente = _a.ambiente, post = _a.post; - return __awaiter(void 0, void 0, void 0, function () { - var url, resp, e_1; - return __generator(this, function (_b) { - switch (_b.label) { - case 0: - url = "".concat((0, _urlAutenticacao_1.urlAutenticacao)(ambiente), "/api/codigo_prefeitura_site"); - _b.label = 1; - case 1: - _b.trys.push([1, 3, , 4]); - return [4 /*yield*/, (0, cross_fetch_1.default)(url, { - method: "POST", - body: JSON.stringify(post), - 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(); - return [2 /*return*/, resp]; - case 3: - e_1 = _b.sent(); - return [2 /*return*/, p_respostas_1.respostaComuns.erro("erro ao buscar c\u00F3digo do site: ".concat(e_1))]; - case 4: return [2 /*return*/]; - } - }); +var codigoContaSite = function (_a) { return __awaiter(void 0, [_a], void 0, function (_b) { + var url, resp, e_1; + var ambiente = _b.ambiente, post = _b.post; + return __generator(this, function (_c) { + switch (_c.label) { + case 0: + url = "".concat((0, _urlAutenticacao_1.urlAutenticacao)(ambiente), "/api/codigo_prefeitura_site"); + _c.label = 1; + case 1: + _c.trys.push([1, 3, , 4]); + return [4 /*yield*/, (0, cross_fetch_1.default)(url, { + method: "POST", + body: JSON.stringify(post), + 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 = _c.sent(); + return [2 /*return*/, resp]; + case 3: + e_1 = _c.sent(); + return [2 /*return*/, p_respostas_1.respostaComuns.erro("erro ao buscar c\u00F3digo do site: ".concat(e_1))]; + case 4: return [2 /*return*/]; + } }); -}; +}); }; exports.codigoContaSite = codigoContaSite; diff --git a/dist-require/autenticacao/_usuarios_quipo_governo.js b/dist-require/autenticacao/_usuarios_quipo_governo.js index f3517cb..61399a9 100644 --- a/dist-require/autenticacao/_usuarios_quipo_governo.js +++ b/dist-require/autenticacao/_usuarios_quipo_governo.js @@ -43,26 +43,24 @@ exports.usuarios_quipo_governo = void 0; var cross_fetch_1 = __importDefault(require("cross-fetch")); var p_respostas_1 = require("p-respostas"); var _urlAutenticacao_1 = require("./_urlAutenticacao"); -var usuarios_quipo_governo = function (_a) { - var token_produto = _a.token_produto, ambiente = _a.ambiente; - return __awaiter(void 0, void 0, void 0, function () { - var url, headers; - return __generator(this, function (_b) { - url = "".concat((0, _urlAutenticacao_1.urlAutenticacao)(ambiente), "/api/usuarios_quipo_governo"); - if (!token_produto) - return [2 /*return*/, p_respostas_1.respostaComuns.erro("token_produto não informado")]; - headers = { - token: token_produto, - }; - return [2 /*return*/, (0, cross_fetch_1.default)(url, { - headers: headers, - }) - .then(function (r) { return r.json(); }) - .catch(function (e) { - return p_respostas_1.respostaComuns.erro("Erro ao buscar usu\u00E1rios quipo governo ".concat(e.message)); - }) - .then(function (r) { return r; })]; - }); +var usuarios_quipo_governo = function (_a) { return __awaiter(void 0, [_a], void 0, function (_b) { + var url, headers; + var token_produto = _b.token_produto, ambiente = _b.ambiente; + return __generator(this, function (_c) { + url = "".concat((0, _urlAutenticacao_1.urlAutenticacao)(ambiente), "/api/usuarios_quipo_governo"); + if (!token_produto) + return [2 /*return*/, p_respostas_1.respostaComuns.erro("token_produto não informado")]; + headers = { + token: token_produto, + }; + return [2 /*return*/, (0, cross_fetch_1.default)(url, { + headers: headers, + }) + .then(function (r) { return r.json(); }) + .catch(function (e) { + return p_respostas_1.respostaComuns.erro("Erro ao buscar usu\u00E1rios quipo governo ".concat(e.message)); + }) + .then(function (r) { return r; })]; }); -}; +}); }; exports.usuarios_quipo_governo = usuarios_quipo_governo; diff --git a/dist-require/autenticacao/_usuarios_quipo_vincular.d.ts b/dist-require/autenticacao/_usuarios_quipo_vincular.d.ts index 3aa424c..565f11c 100644 --- a/dist-require/autenticacao/_usuarios_quipo_vincular.d.ts +++ b/dist-require/autenticacao/_usuarios_quipo_vincular.d.ts @@ -6,6 +6,6 @@ export declare const usuarios_quipo_vincular: ({ token_produto, ambiente, conta, token_produto: string; conta: string; vinculo: string; - codigo_usuario?: string | undefined; + codigo_usuario?: string; email: string; }) => Promise>; diff --git a/dist-require/autenticacao/_usuarios_quipo_vincular.js b/dist-require/autenticacao/_usuarios_quipo_vincular.js index 84bf77c..7955c29 100644 --- a/dist-require/autenticacao/_usuarios_quipo_vincular.js +++ b/dist-require/autenticacao/_usuarios_quipo_vincular.js @@ -43,41 +43,39 @@ exports.usuarios_quipo_vincular = void 0; var cross_fetch_1 = __importDefault(require("cross-fetch")); var p_respostas_1 = require("p-respostas"); var _urlAutenticacao_1 = require("./_urlAutenticacao"); -var usuarios_quipo_vincular = function (_a) { - var token_produto = _a.token_produto, ambiente = _a.ambiente, conta = _a.conta, vinculo = _a.vinculo, codigo_usuario = _a.codigo_usuario, email = _a.email; - return __awaiter(void 0, void 0, void 0, function () { - var url, headers, parametros; - return __generator(this, function (_b) { - switch (_b.label) { - case 0: - url = "".concat((0, _urlAutenticacao_1.urlAutenticacao)(ambiente), "/api/vinculos__criar"); - if (!token_produto) - return [2 /*return*/, p_respostas_1.respostaComuns.erro("token_produto não informado")]; - headers = { - token: token_produto, - "Content-Type": "application/json", - }; - parametros = { - vinculos: { codigo_conta: conta, codigo_usuario: codigo_usuario, vinculo: vinculo }, - email: email, - }; - return [4 /*yield*/, (0, cross_fetch_1.default)(url, { - headers: headers, - body: JSON.stringify(parametros), - method: "POST", - }) - .then(function (r) { return __awaiter(void 0, void 0, void 0, function () { return __generator(this, function (_a) { - switch (_a.label) { - case 0: return [4 /*yield*/, r.json()]; - case 1: return [2 /*return*/, _a.sent()]; - } - }); }); }) - .catch(function (e) { - return p_respostas_1.respostaComuns.erro("Erro ao criar vinculo de usuario ".concat(e.message)); - })]; - case 1: return [2 /*return*/, _b.sent()]; - } - }); +var usuarios_quipo_vincular = function (_a) { return __awaiter(void 0, [_a], void 0, function (_b) { + var url, headers, parametros; + var token_produto = _b.token_produto, ambiente = _b.ambiente, conta = _b.conta, vinculo = _b.vinculo, codigo_usuario = _b.codigo_usuario, email = _b.email; + return __generator(this, function (_c) { + switch (_c.label) { + case 0: + url = "".concat((0, _urlAutenticacao_1.urlAutenticacao)(ambiente), "/api/vinculos__criar"); + if (!token_produto) + return [2 /*return*/, p_respostas_1.respostaComuns.erro("token_produto não informado")]; + headers = { + token: token_produto, + "Content-Type": "application/json", + }; + parametros = { + vinculos: { codigo_conta: conta, codigo_usuario: codigo_usuario, vinculo: vinculo }, + email: email, + }; + return [4 /*yield*/, (0, cross_fetch_1.default)(url, { + headers: headers, + body: JSON.stringify(parametros), + method: "POST", + }) + .then(function (r) { return __awaiter(void 0, void 0, void 0, function () { return __generator(this, function (_a) { + switch (_a.label) { + case 0: return [4 /*yield*/, r.json()]; + case 1: return [2 /*return*/, _a.sent()]; + } + }); }); }) + .catch(function (e) { + return p_respostas_1.respostaComuns.erro("Erro ao criar vinculo de usuario ".concat(e.message)); + })]; + case 1: return [2 /*return*/, _c.sent()]; + } }); -}; +}); }; exports.usuarios_quipo_vincular = usuarios_quipo_vincular; diff --git a/dist-require/autenticacao/_validarToken.js b/dist-require/autenticacao/_validarToken.js index 010dc94..5a00e0d 100644 --- a/dist-require/autenticacao/_validarToken.js +++ b/dist-require/autenticacao/_validarToken.js @@ -43,37 +43,35 @@ exports.validarToken = void 0; var _urlAutenticacao_1 = require("./_urlAutenticacao"); var cross_fetch_1 = __importDefault(require("cross-fetch")); /** faz a validação do token */ -var validarToken = function (_a) { - var ambiente = _a.ambiente, post = _a.post; - return __awaiter(void 0, void 0, void 0, function () { - var url, resposta, e_1; - return __generator(this, function (_b) { - switch (_b.label) { - case 0: - url = "".concat((0, _urlAutenticacao_1.urlAutenticacao)(ambiente), "/api/validar_token"); - _b.label = 1; - case 1: - _b.trys.push([1, 3, , 4]); - return [4 /*yield*/, (0, cross_fetch_1.default)(url, { - method: "POST", - body: JSON.stringify(post), - headers: { "Content-Type": "application/json" }, - }) - .then(function (r) { return r.json(); }) - .then(function (r) { return r; }) - .then(function (resposta) { - return resposta.eCerto ? "valido" : "erro"; - }) - .catch(function () { return "erro"; })]; - case 2: - resposta = _b.sent(); - return [2 /*return*/, resposta]; - case 3: - e_1 = _b.sent(); - return [2 /*return*/, "erro"]; - case 4: return [2 /*return*/]; - } - }); +var validarToken = function (_a) { return __awaiter(void 0, [_a], void 0, function (_b) { + var url, resposta, e_1; + var ambiente = _b.ambiente, post = _b.post; + return __generator(this, function (_c) { + switch (_c.label) { + case 0: + url = "".concat((0, _urlAutenticacao_1.urlAutenticacao)(ambiente), "/api/validar_token"); + _c.label = 1; + case 1: + _c.trys.push([1, 3, , 4]); + return [4 /*yield*/, (0, cross_fetch_1.default)(url, { + method: "POST", + body: JSON.stringify(post), + headers: { "Content-Type": "application/json" }, + }) + .then(function (r) { return r.json(); }) + .then(function (r) { return r; }) + .then(function (resposta) { + return resposta.eCerto ? "valido" : "erro"; + }) + .catch(function () { return "erro"; })]; + case 2: + resposta = _c.sent(); + return [2 /*return*/, resposta]; + case 3: + e_1 = _c.sent(); + return [2 /*return*/, "erro"]; + case 4: return [2 /*return*/]; + } }); -}; +}); }; exports.validarToken = validarToken; diff --git a/dist-require/autenticacao/index.d.ts b/dist-require/autenticacao/index.d.ts index 5371040..03cb0c9 100644 --- a/dist-require/autenticacao/index.d.ts +++ b/dist-require/autenticacao/index.d.ts @@ -3,29 +3,28 @@ export type { tipoUsuarioExterno }; /** todas as rotas de comunicação com autenticador partem dessa variável */ export declare const pAutenticacao: { validarToken: ({ ambiente, post, }: { - /** todas as rotas de comunicação com autenticador partem dessa variável */ - ambiente: "desenvolvimento" | "producao"; + ambiente: import("zod").TypeOf; post: { token: string; }; }) => Promise<"valido" | "erro">; - urlAutenticacao: (ambiente: "desenvolvimento" | "producao") => string; + urlAutenticacao: (ambiente: import("zod").TypeOf) => string; codigoContaSite: ({ ambiente, post, }: { - ambiente: "desenvolvimento" | "producao"; + ambiente: import("zod").TypeOf; post: { site: string; }; }) => Promise>; usuarios_quipo_governo: ({ token_produto, ambiente, }: { - ambiente: "desenvolvimento" | "producao"; + ambiente: import("zod").TypeOf; token_produto: string; }) => Promise>; usuarios_quipo_vincular: ({ token_produto, ambiente, conta, vinculo, codigo_usuario, email, }: { - ambiente: "desenvolvimento" | "producao"; + ambiente: import("zod").TypeOf; token_produto: string; conta: string; vinculo: string; - codigo_usuario?: string | undefined; + codigo_usuario?: string; email: string; }) => Promise>; }; diff --git a/dist-require/pilao-de-dados/_deletar_registros.js b/dist-require/pilao-de-dados/_deletar_registros.js index b1638fa..390dcbc 100644 --- a/dist-require/pilao-de-dados/_deletar_registros.js +++ b/dist-require/pilao-de-dados/_deletar_registros.js @@ -51,39 +51,37 @@ exports.zp_deletar_registros = zod_1.z.object({ }); var deletar_registros = function (_a) { 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)]; - } - }); + return function (_a) { return __awaiter(void 0, [_a], void 0, function (_b) { + var url, tamanhoBlocos, bloco, resp; + var codigos = _b.codigos, tabela = _b.tabela; + return __generator(this, function (_c) { + switch (_c.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; + _c.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 = _c.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.js b/dist-require/pilao-de-dados/_enviar_registros.js index d95660c..c21756c 100644 --- a/dist-require/pilao-de-dados/_enviar_registros.js +++ b/dist-require/pilao-de-dados/_enviar_registros.js @@ -77,46 +77,44 @@ exports.zp_enviar_registros = zod_1.z.object({ }); var enviar_registros = function (_a) { 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) - .map(function (r) { - return Object.fromEntries(Object.entries(r).map(function (_a) { - var _b = __read(_a, 2), k = _b[0], v = _b[1]; - return [k, v === undefined ? null : v]; - })); - }); - 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)]; - } - }); + return function (_a) { return __awaiter(void 0, [_a], void 0, function (_b) { + var url, tamanhoBlocos, bloco, resp; + var registros = _b.registros, tabela = _b.tabela; + return __generator(this, function (_c) { + switch (_c.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; + _c.label = 1; + case 1: + if (!(registros.length > 0)) return [3 /*break*/, 3]; + bloco = registros + .splice(0, tamanhoBlocos) + .map(function (r) { + return Object.fromEntries(Object.entries(r).map(function (_a) { + var _b = __read(_a, 2), k = _b[0], v = _b[1]; + return [k, v === undefined ? null : v]; + })); + }); + 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 = _c.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-require/pilao-de-dados/index.d.ts b/dist-require/pilao-de-dados/index.d.ts index 4a9cec2..dc7c4f3 100644 --- a/dist-require/pilao-de-dados/index.d.ts +++ b/dist-require/pilao-de-dados/index.d.ts @@ -1,4 +1,7 @@ -import { tiposSeriesAgregacoes } from "./variaveis"; +import { zp_deletar_registros } from "./_deletar_registros"; +import { zp_enviar_registros } from "./_enviar_registros"; +import { tiposSeriesAgregacoes, zp_produto_conta } from "./variaveis"; +import { zp_serie_registrar } from "./_serie_consultar"; export { tiposSeriesAgregacoes }; export declare const pPilao: { zp_registrar_base_dados: import("zod").ZodObject<{ @@ -26,17 +29,7 @@ export declare const pPilao: { tipo: "texto" | "numero" | "confirmacao" | "lista_texto" | "lista_numero" | "data" | "mes"; }[]; }>; - enviar_registros: ({ conta, produto, emDesenvolvimento }: { - conta: string; - produto: string; - emDesenvolvimento?: boolean | undefined; - }) => ({ registros, tabela, }: { - tabela: string; - registros: Record[]; - }) => Promise>; + enviar_registros: ({ conta, produto, emDesenvolvimento }: import("zod").TypeOf) => ({ registros, tabela, }: import("zod").TypeOf) => Promise>; zp_enviar_registros: import("zod").ZodObject<{ tabela: import("zod").ZodString; registros: import("zod").ZodArray; - serie_consultar: (cliente: { - conta: string; - produto: string; - emDesenvolvimento?: boolean | undefined; - }) => (parametros: { - tabela: string; - colanuEixoX: string; - agregacao: "contagem" | "somatoria"; - colunaAgrupamento?: string[] | undefined; - }) => { + serie_consultar: (cliente: import("zod").TypeOf) => (parametros: import("zod").TypeOf) => { dados: () => Promise; }>>; url: () => string; }; @@ -113,15 +92,8 @@ export declare const pPilao: { produto: string; emDesenvolvimento?: boolean | undefined; }>; - validarZ: (zodType: import("zod").ZodType, objeto: any, mensagem: string) => import("p-respostas").tipoRespostaErro | import("p-respostas").tipoRespostaSucesso; - deletar_registros: ({ conta, produto, emDesenvolvimento }: { - conta: string; - produto: string; - emDesenvolvimento?: boolean | undefined; - }) => ({ codigos, tabela, }: { - tabela: string; - codigos: string[]; - }) => Promise>; + validarZ: (zodType: import("zod").ZodType, objeto: any, mensagem: string) => import("p-respostas").tipoRespostaErro | import("p-respostas").tipoRespostaSucesso; + deletar_registros: ({ conta, produto, emDesenvolvimento }: import("zod").TypeOf) => ({ codigos, tabela, }: import("zod").TypeOf) => Promise>; zp_deletar_registros: import("zod").ZodObject<{ tabela: import("zod").ZodString; codigos: import("zod").ZodArray; diff --git a/dist-require/pilao-de-dados/variaveis.d.ts b/dist-require/pilao-de-dados/variaveis.d.ts index 1902f1e..5a1227b 100644 --- a/dist-require/pilao-de-dados/variaveis.d.ts +++ b/dist-require/pilao-de-dados/variaveis.d.ts @@ -1,7 +1,7 @@ import { z } from "zod"; export declare const zAmbiente: z.ZodEnum<["desenvolvimento", "producao"]>; export declare const PREFIXO = "/pilao-de-dados"; -export declare const validarZ: (zodType: z.ZodType, objeto: any, mensagem: string) => import("p-respostas").tipoRespostaErro | import("p-respostas").tipoRespostaSucesso; +export declare const validarZ: (zodType: z.ZodType, objeto: any, mensagem: string) => import("p-respostas").tipoRespostaErro | import("p-respostas").tipoRespostaSucesso; export declare const zp_produto_conta: z.ZodObject<{ produto: z.ZodString; conta: z.ZodString; diff --git a/package.json b/package.json index 29e4625..678ab14 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "p-drives", - "version": "0.99.0", + "version": "0.100.0", "description": "", "main": "src/index.ts", "exports": { @@ -24,7 +24,7 @@ "check-node-version": "^4.2.1", "p-comuns": "git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_comuns.git#producao", "p-respostas": "git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_respostas.git#producao", - "typescript": "^4.9.5" + "typescript": "^5" }, "keywords": [], "author": { diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml index 33b9139..3b7a591 100644 --- a/pnpm-lock.yaml +++ b/pnpm-lock.yaml @@ -26,13 +26,13 @@ importers: version: 4.2.1 p-comuns: specifier: git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_comuns.git#producao - version: git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_comuns.git#b01ceca6b840e3a30ee85a2dd98015ab0e8f298d(typescript@4.9.5) + version: git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_comuns.git#1813ad10fdf0c1024cca1d399c7cd2902044e38b(typescript@5.5.2) p-respostas: specifier: git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_respostas.git#producao version: git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_respostas.git#c10a2584e6f6ec5c87462c810cafb1dad243067d typescript: - specifier: ^4.9.5 - version: 4.9.5 + specifier: ^5 + version: 5.5.2 packages: @@ -137,11 +137,11 @@ packages: object-filter@1.0.2: resolution: {integrity: sha512-NahvP2vZcy1ZiiYah30CEPw0FpDcSkSePJBMpzl5EQgCmISijiGuJm3SPYp7U+Lf2TljyaIw3E5EgkEx/TNEVA==} - p-comuns@git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_comuns.git#b01ceca6b840e3a30ee85a2dd98015ab0e8f298d: - resolution: {commit: b01ceca6b840e3a30ee85a2dd98015ab0e8f298d, repo: http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_comuns.git, type: git} - version: 0.31.0 + p-comuns@git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_comuns.git#1813ad10fdf0c1024cca1d399c7cd2902044e38b: + resolution: {commit: 1813ad10fdf0c1024cca1d399c7cd2902044e38b, repo: http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_comuns.git, type: git} + version: 0.32.0 peerDependencies: - typescript: ^5.0.0 + typescript: ^5 p-respostas@git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_respostas.git#c10a2584e6f6ec5c87462c810cafb1dad243067d: resolution: {commit: c10a2584e6f6ec5c87462c810cafb1dad243067d, repo: http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_respostas.git, type: git} @@ -164,9 +164,9 @@ packages: tr46@0.0.3: resolution: {integrity: sha512-N3WMsuqV66lT30CrXNbEjx4GEwlow3v6rr4mCcv6prnfwhS01rkgyFdjPNBYd9br7LpXV1+Emh01fHnq2Gdgrw==} - typescript@4.9.5: - resolution: {integrity: sha512-1FXk9E2Hm+QzZQ7z+McJiHL4NW1F2EzMu9Nq9i3zAaGqibafqYwCVU6WyWAuyQRRzOlxou8xZSyXLEN8oKj24g==} - engines: {node: '>=4.2.0'} + typescript@5.5.2: + resolution: {integrity: sha512-NcRtPEOsPFFWjobJEtfihkLCZCXZt/os3zf8nTxjVH3RvTSxjrCamJpbExGvYOF+tFHc3pA65qpdwPbzjohhew==} + engines: {node: '>=14.17'} hasBin: true undici-types@5.26.5: @@ -264,9 +264,9 @@ snapshots: object-filter@1.0.2: {} - p-comuns@git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_comuns.git#b01ceca6b840e3a30ee85a2dd98015ab0e8f298d(typescript@4.9.5): + p-comuns@git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_comuns.git#1813ad10fdf0c1024cca1d399c7cd2902044e38b(typescript@5.5.2): dependencies: - typescript: 4.9.5 + typescript: 5.5.2 zod: 3.23.8 p-respostas@git+http://leitura:eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTQ3NTA1NzYsImlzcyI6IkdpdG5lc3MiLCJwaWQiOjgsInRrbiI6eyJ0eXAiOiJwYXQiLCJpZCI6MzJ9fQ.OYdExOVQm5UI3wfeTaWjmD0o65Y1hrjFz5EvMB1a__U@git.idz.one:3000/git/multi-modulos-ambientais/_respostas.git#c10a2584e6f6ec5c87462c810cafb1dad243067d: @@ -287,7 +287,7 @@ snapshots: tr46@0.0.3: {} - typescript@4.9.5: {} + typescript@5.5.2: {} undici-types@5.26.5: {}