pseudosubs-v1/srv/LinksAnimes/obtenerLinks.ts

class GestorDeTareas {
    tareas: boolean[] = [];
    alCompletar: (() => void);

    constructor(alCompletar: (() => void)) {
        console.log("Lo cree :c");
        this.alCompletar = alCompletar;
    }

    agregarTarea() {
        return (this.tareas.push(false) - 1);
    }

    terminarTarea(num: number) {
        this.tareas[num] = true;
        this.verificarTareas();
    }

    verificarTareas() {
        this.tareas.forEach((x: boolean) => {
            if (!x)
                return;
        });

        this.alCompletar();
    }
}

const YAML = require('yaml');

interface links {
    links_ID: number,
    anime_ID: number,
    aviso: string,
    sigEp: string
}
interface links_opciones {
    opcion_ID: number,
    links_ID: number,
    num_opcion: number,
    formato: string,
    res: string,
    servidor: string,
    color: string
}
interface eps {
    ep_ID: number,
    opcion_ID: number,
    num_ep: number,
    visitas: number,
    link: string,
    peso: string
}

interface LinksEps {
    ep_ID: number,
    visitas: number,
    peso: string,
    link: string
}
interface Links {
    aviso: string,
    sigEp: string
    opciones: {
        [num: number]: {
            formato: string,
            res: string,
            servidor: string,
            color: string,
            eps: {
                [num: number]: LinksEps
            }
        }
    }
}

const obtenerLinks = (req: any, res: any) => {

    const con = require('../mysql').obtenerConexionMySql();
    const animeID = req.body.animeID;

    con.connect((err: any) => {
        if (!err && animeID !== undefined) {

            const data: Links = {aviso: '', sigEp: '', opciones: {}};

            con.query(
                `SELECT * FROM links WHERE anime_ID=${animeID} `,
                (err: Error, response: links[]) => {
                    if (!err && response[0] ) {

                        const subData: links = response[0];
                        data.aviso = subData.aviso;
                        data.sigEp = subData.sigEp;


                        const gestorOpciones = new GestorDeTareas(() => {
                            console.log(YAML.stringify(data));
                            res.send(YAML.stringify(data));
                        });

                        con.query(
                            `SELECT * FROM links_opciones WHERE links_ID=${subData.links_ID}`,
                            (err: Error, response: links_opciones[]) => {
                                if (!err && response[0]) {

                                    for (const opcionID in response) {
                                        const opcion = response[opcionID];

                                        const tareaActualOpcion = gestorOpciones.agregarTarea();

                                        data.opciones[opcion.num_opcion] = {
                                            formato: opcion.formato,
                                            res: opcion.res,
                                            servidor: opcion.servidor,
                                            color: opcion.color,
                                            eps: {}
                                        };


                                        con.query(
                                            `SELECT * FROM eps WHERE opcion_ID=${opcion.opcion_ID}`,
                                            (err: Error, response: eps[]) => {
                                                if (!err && response[0]) {

                                                    for (const epID in response) {
                                                        const ep = response[epID];

                                                        const eps: LinksEps = {
                                                            ep_ID: ep.ep_ID,
                                                            visitas: ep.visitas,
                                                            peso: ep.peso,
                                                            link: ep.link
                                                        };

                                                        data.opciones[opcion.num_opcion].eps[ep.num_ep] = eps;
                                                    }

                                                    gestorOpciones.terminarTarea(tareaActualOpcion);
                                                } else if (!err) {
                                                    console.log("No existen episodios para esta variante");

                                                    res.send(`{ "exito": false }`);
                                                } else {
                                                    console.log("Error al obtener eps:\n" + err);
                                                    res.send(`{ "exito": false }`);
                                                }
                                            }
                                        );

                                    }
                                } else if (!err) {
                                    console.log("No existen links_opciones ");
                                    res.send(`{ "exito": false }`);
                                } else {
                                    console.log("Error al obtener links opciones:\n" + err);
                                    res.send(`{ "exito": false }`);
                                }
                            }
                        );

                    } else if (!err) {
                        console.log("Error: La consulta no dio ningun resultado en obtenerLinks");
                    } else {
                        console.log("Error al ejecutar Query en obtenerLinks.\n" + err);
                        res.send(`{ "exito": false }`);
                    }

                }
            );


        } else {
            console.log("Hubo un error al conectarse a la base de datos :c");
            res.send(`{ "exito": false }`);

        }
    });

};

module.exports.obtenerLinks = obtenerLinks;