Cargador de datos asíncrono con reintentos y dependencias

1const lineas = require("fs").readFileSync(0, "utf8").split("\n");
2
3const LIMITE_MS = 100;
4const INTENTOS = 3;
5let peticiones = 0;
6
7/** Petición simulada: tarda «ms» y falla mientras el intento sea menor o igual que «fallos». */
8function peticion(recurso, intento) {
9  peticiones++;
10  return new Promise((resolve, reject) => {
11    setTimeout(() => (intento <= recurso.fallos ? reject(new Error("error del servidor")) : resolve(recurso.nombre)), recurso.ms);
12  });
13}
14
15/** La primera promesa que termine gana: la petición o el temporizador. */
16function conTiempoLimite(promesa, ms) {
17  const limite = new Promise((_, reject) => setTimeout(() => reject(new Error("tiempo agotado")), ms));
18  return Promise.race([promesa, limite]);
19}
20
21async function conReintentos(recurso) {
22  let motivo = "";
23  for (let intento = 1; intento <= INTENTOS; intento++) {
24    try {
25      await conTiempoLimite(peticion(recurso, intento), LIMITE_MS);
26      return { estado: "cargado", intentos: intento };
27    } catch (error) {
28      motivo = error.message;
29    }
30  }
31  return { estado: "error", motivo };
32}
33
34const recursos = new Map();
35lineas.forEach((linea, i) => {
36  const texto = linea.trim();
37  if (!texto) return;
38  const m = texto.match(/^(\S+)\s+(\d+)\s+(\d+)(?:\s+(\S+))?$/);
39  if (!m || recursos.has(m[1])) {
40    console.log(`Aviso: línea ${i + 1} ignorada`);
41    return;
42  }
43  recursos.set(m[1], { nombre: m[1], ms: Number(m[2]), fallos: Number(m[3]), depende: m[4] ? m[4].split(",") : [] });
44});
45
46// Cada recurso se carga una sola vez: se guarda su promesa y quien dependa de él la espera
47const cargas = new Map();
48function cargar(nombre) {
49  if (!cargas.has(nombre)) {
50    cargas.set(nombre, (async () => {
51      const recurso = recursos.get(nombre);
52      const deps = await Promise.all(recurso.depende.map((d) => (recursos.has(d) ? cargar(d) : { estado: "no existe" })));
53      const i = deps.findIndex((r) => r.estado !== "cargado");
54      if (i >= 0) {
55        const razon = deps[i].estado === "no existe" ? "que no existe" : "que no se ha podido cargar";
56        return { estado: "omitido", motivo: `depende de ${recurso.depende[i]}, ${razon}` };
57      }
58      return conReintentos(recurso);
59    })());
60  }
61  return cargas.get(nombre);
62}
63
64async function main() {
65  // Todas las cargas empiezan a la vez; Promise.all espera a que terminen todas
66  const resultados = await Promise.all([...recursos.keys()].map(cargar));
67  [...recursos.keys()].forEach((nombre, i) => {
68    const r = resultados[i];
69    if (r.estado === "cargado") console.log(`${nombre}: cargado (${r.intentos} ${r.intentos === 1 ? "intento" : "intentos"})`);
70    else if (r.estado === "error") console.log(`${nombre}: error tras ${INTENTOS} intentos (${r.motivo})`);
71    else console.log(`${nombre}: omitido (${r.motivo})`);
72  });
73  const cargados = resultados.filter((r) => r.estado === "cargado").length;
74  console.log(`Cargados: ${cargados} de ${resultados.length} · Peticiones: ${peticiones}`);
75}
76
77main();