z_validar_colunna_base_dados

src/pilao-de-dados/_variaveis.ts

@@ -26,7 +26,7 @@ export const zp_produto_conta = z.object({
   conta: z.string(),
 })
 
-export const tiposColunasBasedados = z.enum([
+export const z_tipo_coluna_base_dados = z.enum([
   "texto",
   "numero",
   "confirmacao",
@@ -36,7 +36,7 @@ export const tiposColunasBasedados = z.enum([
 
 export const tiposSeriesAgregacoes = z.enum(["contagem", "somatoria"])
 
-export const validarColuna = {
+export const z_validar_colunna_base_dados = {
   texto: z.string().nullable(),
   numero: z.number().nullable(),
   confirmacao: z.boolean().nullable(),

src/pilao-de-dados/enviar_registros.ts

@@ -1,12 +1,33 @@
 import type { tipoResposta } from "p-respostas"
 import { respostaComuns } from "p-respostas"
 import { z } from "zod"
-import { PREFIXO, baseUrlPilao, type zp_produto_conta } from "./_variaveis"
+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.any()),
+  registros: z.array(
+    z.object({
+      coluna: z.string(),
+      valor: z.any(),
+      tipo: z_tipo_coluna_base_dados,
+    }),
+  ),
 })
 
 export const enviar_registros = async ({

src/pilao-de-dados/index.ts

@@ -1,17 +1,17 @@
 import { tiposSeriesAgregacoes, validarZ, zp_produto_conta } from "./_variaveis"
 import { deletar_registros, zp_deletar_registros } from "./deletar_registros"
-import { enviar_registros, zp_enviar_registros } from "./enviar_registros"
 import {
-  registrar_base_dados,
+  enviar_registros,
+  zp_enviar_registros,
   zp_registrar_base_dados,
-} from "./registrar_base_dados"
+} from "./enviar_registros"
+
 import { serie_consultar, zp_serie_consultar } from "./serie_consultar"
 import { serie_registrar, zp_serie_registrar } from "./serie_registrar"
 
 export { tiposSeriesAgregacoes }
 
 export const pPilao = {
-  registrar_base_dados,
   zp_registrar_base_dados,
 
   enviar_registros,

src/pilao-de-dados/registrar_base_dados.ts

@@ -1,50 +0,0 @@
-import type { tipoResposta } from "p-respostas"
-import { respostaComuns } from "p-respostas"
-import { z } from "zod"
-import {
-  PREFIXO,
-  baseUrlPilao,
-  tiposColunasBasedados,
-  type zp_produto_conta,
-} from "./_variaveis"
-
-/** Faz o registro de uma nova base de dados configurado a  estrutura de colunas */
-
-export const zp_registrar_base_dados = z.object({
-  tabela: z.string(),
-  colunas: z.array(
-    z.object({
-      coluna: z.string(),
-      tipo: tiposColunasBasedados,
-    }),
-  ),
-})
-
-export const registrar_base_dados = async ({
-  emDesenvolvimento,
-  cliente: { conta, produto },
-  parametros: { colunas, tabela },
-}: {
-  emDesenvolvimento?: boolean | undefined | null
-  /** Identificação do cliente */
-  cliente: z.infer<typeof zp_produto_conta>
-  /** parametros da função */
-  parametros: z.infer<typeof zp_registrar_base_dados>
-}): Promise<tipoResposta<true>> => {
-  const url = new URL(
-    `${baseUrlPilao(
-      emDesenvolvimento,
-    )}${`${PREFIXO}/${Object.keys({ registrar_base_dados })[0]}/${produto}/${conta}`}`,
-  )
-
-  const resp = await fetch(url.toString(), {
-    method: "POST",
-    body: JSON.stringify({ tabela, colunas }),
-    headers: { "Content-Type": "application/json" },
-  })
-    .then((r) => r.json())
-    .catch((e) => respostaComuns.erro("Erro ao enviar registros", [e.message]))
-    .then((r) => r as tipoResposta<true>)
-
-  return resp
-}