.

dist-import/pilao-de-dados/enviar_registros.js

@@ -19,13 +19,20 @@ export const enviar_registros = ({ emDesenvolvimento, cliente: { conta, produto
     const url = new URL(`${emDesenvolvimento
         ? "http://127.0.0.1:5080"
         : "https://carro-de-boi.idz.one"}${PREFIXO}/enviar-registro/${produto}/${conta}`);
+    const tamanhoBlocos = 1000;
+    while (registros.length > 0) {
+        const bloco = registros.splice(0, tamanhoBlocos);
         const resp = yield fetch(url.toString(), {
             method: "POST",
-        body: JSON.stringify({ tabela, registros }),
+            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);
+        if (resp.eErro) {
             return resp;
+        }
+    }
+    return respostaComuns.valor(true);
 });

dist-require/pilao-de-dados/enviar_registros.js

@@ -48,25 +48,36 @@ exports.zp_enviar_registros = zod_1.z.object({
 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, resp;
+        var url, tamanhoBlocos, bloco, resp;
         return __generator(this, function (_d) {
             switch (_d.label) {
                 case 0:
                     url = new URL("".concat(emDesenvolvimento
                         ? "http://127.0.0.1:5080"
                         : "https://carro-de-boi.idz.one").concat(_variaveis_1.PREFIXO, "/enviar-registro/").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*/, fetch(url.toString(), {
                             method: "POST",
-                            body: JSON.stringify({ tabela: tabela, registros: registros }),
+                            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]); })
+                            .catch(function (e) {
+                            return p_respostas_1.respostaComuns.erro("Erro ao enviar registros", [e.message]);
+                        })
                             .then(function (r) { return r; })];
-                case 1:
+                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)];
+            }
         });
     });
 };

package.json

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

src/pilao-de-dados/enviar_registros.ts

@@ -30,14 +30,25 @@ export const enviar_registros = async ({
     }${PREFIXO}/enviar-registro/${produto}/${conta}`,
   )
 
+  const tamanhoBlocos = 1000
+
+  while (registros.length > 0) {
+    const bloco = registros.splice(0, tamanhoBlocos)
     const resp = await fetch(url.toString(), {
       method: "POST",
-    body: JSON.stringify({ tabela, registros }),
+      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]))
+      .catch((e) =>
+        respostaComuns.erro("Erro ao enviar registros", [e.message]),
+      )
       .then((r) => r as tipoResposta<true>)
 
+    if (resp.eErro) {
       return resp
     }
+  }
+
+  return respostaComuns.valor(true)
+}