This commit is contained in:
Luiz H. R. Silva 2024-06-28 14:03:35 -03:00
parent a8e9f47e7b
commit 5011034f75
20 changed files with 67 additions and 49 deletions

View file

@ -10,14 +10,14 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge
import node_fetch from "cross-fetch"; import node_fetch from "cross-fetch";
import { respostaComuns } from "p-respostas"; import { respostaComuns } from "p-respostas";
import { z } from "zod"; import { z } from "zod";
import { PREFIXO_PILAO, baseUrlPilao } from "./variaveis"; import { urlPilao } from "./variaveis";
//enviar registros para base de dados //enviar registros para base de dados
export const zp_deletar_registros = z.object({ export const zp_deletar_registros = z.object({
tabela: z.string(), tabela: z.string(),
codigos: z.array(z.string()), codigos: z.array(z.string()),
}); });
export const deletar_registros = ({ conta, produto, emDesenvolvimento }) => (_a) => __awaiter(void 0, [_a], void 0, function* ({ codigos, tabela, }) { export const deletar_registros = ({ conta, produto, emDesenvolvimento }) => (_a) => __awaiter(void 0, [_a], void 0, function* ({ codigos, tabela, }) {
const url = new URL(`${baseUrlPilao(emDesenvolvimento)}${PREFIXO_PILAO}/${Object.keys({ deletar_registros })[0]}/${produto}/${conta}`); const url = new URL(`${urlPilao(emDesenvolvimento).api}/${Object.keys({ deletar_registros })[0]}/${produto}/${conta}`);
const tamanhoBlocos = 1000; const tamanhoBlocos = 1000;
while (codigos.length > 0) { while (codigos.length > 0) {
const bloco = codigos.splice(0, tamanhoBlocos); const bloco = codigos.splice(0, tamanhoBlocos);

View file

@ -10,7 +10,7 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge
import node_fetch from "cross-fetch"; import node_fetch from "cross-fetch";
import { respostaComuns } from "p-respostas"; import { respostaComuns } from "p-respostas";
import { z } from "zod"; import { z } from "zod";
import { PREFIXO_PILAO, baseUrlPilao, z_tipo_coluna_base_dados, } from "./variaveis"; import { urlPilao, z_tipo_coluna_base_dados, } from "./variaveis";
export const zp_registrar_base_dados = z.object({ export const zp_registrar_base_dados = z.object({
tabela: z.string(), tabela: z.string(),
colunas: z.array(z.object({ colunas: z.array(z.object({
@ -27,7 +27,7 @@ export const zp_enviar_registros = z.object({
}))), }))),
}); });
export const enviar_registros = ({ conta, produto, emDesenvolvimento }) => (_a) => __awaiter(void 0, [_a], void 0, function* ({ registros, tabela, }) { export const enviar_registros = ({ conta, produto, emDesenvolvimento }) => (_a) => __awaiter(void 0, [_a], void 0, function* ({ registros, tabela, }) {
const url = new URL(`${baseUrlPilao(emDesenvolvimento)}${PREFIXO_PILAO}/${Object.keys({ enviar_registros })[0]}/${produto}/${conta}`); const url = new URL(`${urlPilao(emDesenvolvimento).api}/${Object.keys({ enviar_registros })[0]}/${produto}/${conta}`);
const tamanhoBlocos = 1000; const tamanhoBlocos = 1000;
while (registros.length > 0) { while (registros.length > 0) {
const bloco = registros const bloco = registros

View file

@ -10,7 +10,7 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge
import node_fetch from "cross-fetch"; import node_fetch from "cross-fetch";
import { respostaComuns } from "p-respostas"; import { respostaComuns } from "p-respostas";
import { z } from "zod"; import { z } from "zod";
import { PREFIXO_PILAO, baseUrlPilao, tiposSeriesAgregacoes, } from "./variaveis"; import { tiposSeriesAgregacoes, urlPilao, } from "./variaveis";
export const zp_serie_registrar = z.object({ export const zp_serie_registrar = z.object({
tabela: z.string(), tabela: z.string(),
colanuEixoX: z.string(), colanuEixoX: z.string(),
@ -19,7 +19,7 @@ export const zp_serie_registrar = z.object({
}); });
export const serie_consultar = (cliente) => (parametros) => { export const serie_consultar = (cliente) => (parametros) => {
const dados = () => __awaiter(void 0, void 0, void 0, function* () { const dados = () => __awaiter(void 0, void 0, void 0, function* () {
const url = new URL(`${baseUrlPilao(cliente.emDesenvolvimento)}${`${PREFIXO_PILAO}/${tiposSeriesAgregacoes.enum.contagem}/${cliente.produto}/${cliente.conta}`}`); const url = new URL(`${urlPilao(cliente.emDesenvolvimento).api}${tiposSeriesAgregacoes.enum.contagem}/${cliente.produto}/${cliente.conta}`);
const resp = yield node_fetch(url.toString(), { const resp = yield node_fetch(url.toString(), {
method: "POST", method: "POST",
body: JSON.stringify(parametros), body: JSON.stringify(parametros),
@ -31,9 +31,7 @@ export const serie_consultar = (cliente) => (parametros) => {
return resp; return resp;
}); });
const url = () => { const url = () => {
const vUrl = new URL(`${cliente.emDesenvolvimento const vUrl = new URL(`${urlPilao(cliente.emDesenvolvimento).api}/${tiposSeriesAgregacoes.enum.contagem}/${cliente.produto}/${cliente.conta}`);
? "http://127.0.0.1:5081"
: "https://carro-de-boi.idz.one"}${PREFIXO_PILAO}/${tiposSeriesAgregacoes.enum.contagem}/${cliente.produto}/${cliente.conta}`);
const serie = encodeURIComponent(JSON.stringify(parametros, null, 2)); const serie = encodeURIComponent(JSON.stringify(parametros, null, 2));
return `${vUrl.href}?serie=${serie}`; return `${vUrl.href}?serie=${serie}`;
}; };

View file

@ -1,5 +1,5 @@
import { zp_deletar_registros } from "./_deletar_registros"; import { zp_deletar_registros } from "./_deletar_registros";
export { PREFIXO_PILAO } from "./variaveis"; export { PREFIXO_PILAO, urlPilao } from "./variaveis";
import { zp_enviar_registros } from "./_enviar_registros"; import { zp_enviar_registros } from "./_enviar_registros";
import { tiposSeriesAgregacoes, zp_produto_conta } from "./variaveis"; import { tiposSeriesAgregacoes, zp_produto_conta } from "./variaveis";
import { zp_serie_registrar } from "./_serie_consultar"; import { zp_serie_registrar } from "./_serie_consultar";

View file

@ -1,5 +1,5 @@
import { deletar_registros, zp_deletar_registros } from "./_deletar_registros"; import { deletar_registros, zp_deletar_registros } from "./_deletar_registros";
export { PREFIXO_PILAO } from "./variaveis"; export { PREFIXO_PILAO, urlPilao } from "./variaveis";
import { enviar_registros, zp_enviar_registros, zp_registrar_base_dados, } from "./_enviar_registros"; import { enviar_registros, zp_enviar_registros, zp_registrar_base_dados, } from "./_enviar_registros";
import { tiposSeriesAgregacoes, validarZ, zp_produto_conta } from "./variaveis"; 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";

View file

@ -24,4 +24,7 @@ export declare const z_validar_colunna_base_dados: {
lista_texto: z.ZodNullable<z.ZodArray<z.ZodString, "many">>; lista_texto: z.ZodNullable<z.ZodArray<z.ZodString, "many">>;
lista_numero: z.ZodNullable<z.ZodArray<z.ZodNumber, "many">>; lista_numero: z.ZodNullable<z.ZodArray<z.ZodNumber, "many">>;
}; };
export declare const baseUrlPilao: (emDesenvolvimento?: boolean | null | undefined) => "https://carro-de-boi.idz.one" | "http://127.0.0.1:5080"; export declare const urlPilao: (emDesenvolvimento?: boolean | null | undefined) => {
api: string;
site: string;
};

View file

@ -31,4 +31,11 @@ export const z_validar_colunna_base_dados = {
lista_texto: z.array(z.string()).nullable(), lista_texto: z.array(z.string()).nullable(),
lista_numero: z.array(z.number()).nullable(), lista_numero: z.array(z.number()).nullable(),
}; };
export const baseUrlPilao = (emDesenvolvimento) => emDesenvolvimento ? "http://127.0.0.1:5080" : "https://carro-de-boi.idz.one"; export const urlPilao = (emDesenvolvimento) => ({
api: (emDesenvolvimento
? "http://127.0.0.1:5080"
: "https://carro-de-boi.idz.one") + PREFIXO_PILAO,
site: (emDesenvolvimento
? "http://127.0.0.1:5081"
: "https://carro-de-boi.idz.one") + PREFIXO_PILAO,
});

View file

@ -57,7 +57,7 @@ var deletar_registros = function (_a) {
return __generator(this, function (_c) { return __generator(this, function (_c) {
switch (_c.label) { switch (_c.label) {
case 0: case 0:
url = new URL("".concat((0, variaveis_1.baseUrlPilao)(emDesenvolvimento)).concat(variaveis_1.PREFIXO_PILAO, "/").concat(Object.keys({ deletar_registros: exports.deletar_registros })[0], "/").concat(produto, "/").concat(conta)); url = new URL("".concat((0, variaveis_1.urlPilao)(emDesenvolvimento).api, "/").concat(Object.keys({ deletar_registros: exports.deletar_registros })[0], "/").concat(produto, "/").concat(conta));
tamanhoBlocos = 1000; tamanhoBlocos = 1000;
_c.label = 1; _c.label = 1;
case 1: case 1:

View file

@ -83,7 +83,7 @@ var enviar_registros = function (_a) {
return __generator(this, function (_c) { return __generator(this, function (_c) {
switch (_c.label) { switch (_c.label) {
case 0: case 0:
url = new URL("".concat((0, variaveis_1.baseUrlPilao)(emDesenvolvimento)).concat(variaveis_1.PREFIXO_PILAO, "/").concat(Object.keys({ enviar_registros: exports.enviar_registros })[0], "/").concat(produto, "/").concat(conta)); url = new URL("".concat((0, variaveis_1.urlPilao)(emDesenvolvimento).api, "/").concat(Object.keys({ enviar_registros: exports.enviar_registros })[0], "/").concat(produto, "/").concat(conta));
tamanhoBlocos = 1000; tamanhoBlocos = 1000;
_c.label = 1; _c.label = 1;
case 1: case 1:

View file

@ -57,7 +57,7 @@ var serie_consultar = function (cliente) {
return __generator(this, function (_a) { return __generator(this, function (_a) {
switch (_a.label) { switch (_a.label) {
case 0: case 0:
url = new URL("".concat((0, variaveis_1.baseUrlPilao)(cliente.emDesenvolvimento)).concat("".concat(variaveis_1.PREFIXO_PILAO, "/").concat(variaveis_1.tiposSeriesAgregacoes.enum.contagem, "/").concat(cliente.produto, "/").concat(cliente.conta))); url = new URL("".concat((0, variaveis_1.urlPilao)(cliente.emDesenvolvimento).api).concat(variaveis_1.tiposSeriesAgregacoes.enum.contagem, "/").concat(cliente.produto, "/").concat(cliente.conta));
return [4 /*yield*/, (0, cross_fetch_1.default)(url.toString(), { return [4 /*yield*/, (0, cross_fetch_1.default)(url.toString(), {
method: "POST", method: "POST",
body: JSON.stringify(parametros), body: JSON.stringify(parametros),
@ -75,9 +75,7 @@ var serie_consultar = function (cliente) {
}); });
}); }; }); };
var url = function () { var url = function () {
var vUrl = new URL("".concat(cliente.emDesenvolvimento var vUrl = new URL("".concat((0, variaveis_1.urlPilao)(cliente.emDesenvolvimento).api, "/").concat(variaveis_1.tiposSeriesAgregacoes.enum.contagem, "/").concat(cliente.produto, "/").concat(cliente.conta));
? "http://127.0.0.1:5081"
: "https://carro-de-boi.idz.one").concat(variaveis_1.PREFIXO_PILAO, "/").concat(variaveis_1.tiposSeriesAgregacoes.enum.contagem, "/").concat(cliente.produto, "/").concat(cliente.conta));
var serie = encodeURIComponent(JSON.stringify(parametros, null, 2)); var serie = encodeURIComponent(JSON.stringify(parametros, null, 2));
return "".concat(vUrl.href, "?serie=").concat(serie); return "".concat(vUrl.href, "?serie=").concat(serie);
}; };

View file

@ -1,5 +1,5 @@
import { zp_deletar_registros } from "./_deletar_registros"; import { zp_deletar_registros } from "./_deletar_registros";
export { PREFIXO_PILAO } from "./variaveis"; export { PREFIXO_PILAO, urlPilao } from "./variaveis";
import { zp_enviar_registros } from "./_enviar_registros"; import { zp_enviar_registros } from "./_enviar_registros";
import { tiposSeriesAgregacoes, zp_produto_conta } from "./variaveis"; import { tiposSeriesAgregacoes, zp_produto_conta } from "./variaveis";
import { zp_serie_registrar } from "./_serie_consultar"; import { zp_serie_registrar } from "./_serie_consultar";

View file

@ -1,9 +1,10 @@
"use strict"; "use strict";
Object.defineProperty(exports, "__esModule", { value: true }); Object.defineProperty(exports, "__esModule", { value: true });
exports.pPilao = exports.tiposSeriesAgregacoes = exports.PREFIXO_PILAO = void 0; exports.pPilao = exports.tiposSeriesAgregacoes = exports.urlPilao = exports.PREFIXO_PILAO = void 0;
var _deletar_registros_1 = require("./_deletar_registros"); var _deletar_registros_1 = require("./_deletar_registros");
var variaveis_1 = require("./variaveis"); var variaveis_1 = require("./variaveis");
Object.defineProperty(exports, "PREFIXO_PILAO", { enumerable: true, get: function () { return variaveis_1.PREFIXO_PILAO; } }); Object.defineProperty(exports, "PREFIXO_PILAO", { enumerable: true, get: function () { return variaveis_1.PREFIXO_PILAO; } });
Object.defineProperty(exports, "urlPilao", { enumerable: true, get: function () { return variaveis_1.urlPilao; } });
var _enviar_registros_1 = require("./_enviar_registros"); var _enviar_registros_1 = require("./_enviar_registros");
var variaveis_2 = require("./variaveis"); var variaveis_2 = require("./variaveis");
Object.defineProperty(exports, "tiposSeriesAgregacoes", { enumerable: true, get: function () { return variaveis_2.tiposSeriesAgregacoes; } }); Object.defineProperty(exports, "tiposSeriesAgregacoes", { enumerable: true, get: function () { return variaveis_2.tiposSeriesAgregacoes; } });

View file

@ -24,4 +24,7 @@ export declare const z_validar_colunna_base_dados: {
lista_texto: z.ZodNullable<z.ZodArray<z.ZodString, "many">>; lista_texto: z.ZodNullable<z.ZodArray<z.ZodString, "many">>;
lista_numero: z.ZodNullable<z.ZodArray<z.ZodNumber, "many">>; lista_numero: z.ZodNullable<z.ZodArray<z.ZodNumber, "many">>;
}; };
export declare const baseUrlPilao: (emDesenvolvimento?: boolean | null | undefined) => "https://carro-de-boi.idz.one" | "http://127.0.0.1:5080"; export declare const urlPilao: (emDesenvolvimento?: boolean | null | undefined) => {
api: string;
site: string;
};

View file

@ -1,6 +1,6 @@
"use strict"; "use strict";
Object.defineProperty(exports, "__esModule", { value: true }); Object.defineProperty(exports, "__esModule", { value: true });
exports.baseUrlPilao = exports.z_validar_colunna_base_dados = exports.tiposSeriesAgregacoes = exports.z_tipo_coluna_base_dados = exports.zp_produto_conta = exports.validarZ = exports.PREFIXO_PILAO = exports.zAmbiente = void 0; exports.urlPilao = exports.z_validar_colunna_base_dados = exports.tiposSeriesAgregacoes = exports.z_tipo_coluna_base_dados = exports.zp_produto_conta = exports.validarZ = exports.PREFIXO_PILAO = exports.zAmbiente = void 0;
var p_respostas_1 = require("p-respostas"); var p_respostas_1 = require("p-respostas");
var zod_1 = require("zod"); var zod_1 = require("zod");
exports.zAmbiente = zod_1.z.enum(["desenvolvimento", "producao"]); exports.zAmbiente = zod_1.z.enum(["desenvolvimento", "producao"]);
@ -35,7 +35,12 @@ exports.z_validar_colunna_base_dados = {
lista_texto: zod_1.z.array(zod_1.z.string()).nullable(), lista_texto: zod_1.z.array(zod_1.z.string()).nullable(),
lista_numero: zod_1.z.array(zod_1.z.number()).nullable(), lista_numero: zod_1.z.array(zod_1.z.number()).nullable(),
}; };
var baseUrlPilao = function (emDesenvolvimento) { var urlPilao = function (emDesenvolvimento) { return ({
return emDesenvolvimento ? "http://127.0.0.1:5080" : "https://carro-de-boi.idz.one"; api: (emDesenvolvimento
}; ? "http://127.0.0.1:5080"
exports.baseUrlPilao = baseUrlPilao; : "https://carro-de-boi.idz.one") + exports.PREFIXO_PILAO,
site: (emDesenvolvimento
? "http://127.0.0.1:5081"
: "https://carro-de-boi.idz.one") + exports.PREFIXO_PILAO,
}); };
exports.urlPilao = urlPilao;

View file

@ -1,6 +1,6 @@
{ {
"name": "p-drives", "name": "p-drives",
"version": "0.106.0", "version": "0.110.0",
"description": "", "description": "",
"main": "src/index.ts", "main": "src/index.ts",
"exports": { "exports": {

View file

@ -2,7 +2,7 @@ import node_fetch from "cross-fetch"
import type { tipoResposta } from "p-respostas" import type { tipoResposta } from "p-respostas"
import { respostaComuns } from "p-respostas" import { respostaComuns } from "p-respostas"
import { z } from "zod" import { z } from "zod"
import { PREFIXO_PILAO, baseUrlPilao, type zp_produto_conta } from "./variaveis" import { urlPilao, type zp_produto_conta } from "./variaveis"
//enviar registros para base de dados //enviar registros para base de dados
export const zp_deletar_registros = z.object({ export const zp_deletar_registros = z.object({
tabela: z.string(), tabela: z.string(),
@ -16,9 +16,9 @@ export const deletar_registros =
tabela, tabela,
}: z.infer<typeof zp_deletar_registros>): Promise<tipoResposta<true>> => { }: z.infer<typeof zp_deletar_registros>): Promise<tipoResposta<true>> => {
const url = new URL( const url = new URL(
`${baseUrlPilao( `${
emDesenvolvimento, urlPilao(emDesenvolvimento).api
)}${PREFIXO_PILAO}/${Object.keys({ deletar_registros })[0]}/${produto}/${conta}`, }/${Object.keys({ deletar_registros })[0]}/${produto}/${conta}`,
) )
const tamanhoBlocos = 1000 const tamanhoBlocos = 1000

View file

@ -3,8 +3,7 @@ import type { tipoResposta } from "p-respostas"
import { respostaComuns } from "p-respostas" import { respostaComuns } from "p-respostas"
import { z } from "zod" import { z } from "zod"
import { import {
PREFIXO_PILAO, urlPilao,
baseUrlPilao,
z_tipo_coluna_base_dados, z_tipo_coluna_base_dados,
type zp_produto_conta, type zp_produto_conta,
} from "./variaveis" } from "./variaveis"
@ -40,9 +39,9 @@ export const enviar_registros =
tabela, tabela,
}: z.infer<typeof zp_enviar_registros>): Promise<tipoResposta<true>> => { }: z.infer<typeof zp_enviar_registros>): Promise<tipoResposta<true>> => {
const url = new URL( const url = new URL(
`${baseUrlPilao( `${
emDesenvolvimento, urlPilao(emDesenvolvimento).api
)}${PREFIXO_PILAO}/${Object.keys({ enviar_registros })[0]}/${produto}/${conta}`, }/${Object.keys({ enviar_registros })[0]}/${produto}/${conta}`,
) )
const tamanhoBlocos = 1000 const tamanhoBlocos = 1000

View file

@ -3,9 +3,8 @@ import type { tipoResposta } from "p-respostas"
import { respostaComuns } from "p-respostas" import { respostaComuns } from "p-respostas"
import { z } from "zod" import { z } from "zod"
import { import {
PREFIXO_PILAO,
baseUrlPilao,
tiposSeriesAgregacoes, tiposSeriesAgregacoes,
urlPilao,
type zp_produto_conta, type zp_produto_conta,
} from "./variaveis" } from "./variaveis"
@ -27,9 +26,9 @@ export const serie_consultar =
}> }>
> => { > => {
const url = new URL( const url = new URL(
`${baseUrlPilao(cliente.emDesenvolvimento)}${`${PREFIXO_PILAO}/${ `${urlPilao(cliente.emDesenvolvimento).api}${
tiposSeriesAgregacoes.enum.contagem tiposSeriesAgregacoes.enum.contagem
}/${cliente.produto}/${cliente.conta}`}`, }/${cliente.produto}/${cliente.conta}`,
) )
const resp = await node_fetch(url.toString(), { const resp = await node_fetch(url.toString(), {
@ -48,11 +47,7 @@ export const serie_consultar =
const url = (): string => { const url = (): string => {
const vUrl = new URL( const vUrl = new URL(
`${ `${urlPilao(cliente.emDesenvolvimento).api}/${tiposSeriesAgregacoes.enum.contagem}/${cliente.produto}/${cliente.conta}`,
cliente.emDesenvolvimento
? "http://127.0.0.1:5081"
: "https://carro-de-boi.idz.one"
}${PREFIXO_PILAO}/${tiposSeriesAgregacoes.enum.contagem}/${cliente.produto}/${cliente.conta}`,
) )
const serie = encodeURIComponent(JSON.stringify(parametros, null, 2)) const serie = encodeURIComponent(JSON.stringify(parametros, null, 2))

View file

@ -1,5 +1,5 @@
import { deletar_registros, zp_deletar_registros } from "./_deletar_registros" import { deletar_registros, zp_deletar_registros } from "./_deletar_registros"
export { PREFIXO_PILAO } from "./variaveis" export { PREFIXO_PILAO, urlPilao } from "./variaveis"
import { import {
enviar_registros, enviar_registros,
zp_enviar_registros, zp_enviar_registros,

View file

@ -46,5 +46,14 @@ export const z_validar_colunna_base_dados = {
lista_numero: z.array(z.number()).nullable(), lista_numero: z.array(z.number()).nullable(),
} }
export const baseUrlPilao = (emDesenvolvimento?: boolean | null | undefined) => export const urlPilao = (emDesenvolvimento?: boolean | null | undefined) => ({
emDesenvolvimento ? "http://127.0.0.1:5080" : "https://carro-de-boi.idz.one" api:
(emDesenvolvimento
? "http://127.0.0.1:5080"
: "https://carro-de-boi.idz.one") + PREFIXO_PILAO,
site:
(emDesenvolvimento
? "http://127.0.0.1:5081"
: "https://carro-de-boi.idz.one") + PREFIXO_PILAO,
})