Database Manager

Clase DatabaseManager

El archivo mas importante de la creación y configuración de la base de datos esta en esta clase.(Cambio que se coloco en la versión 2.6)

connectToPostgres(shouldConnect = true) {
    if (shouldConnect && !this.pgPool) {
        this.pgPool = new Pool({
            user: process.env.DATABASEUSER,
            password: process.env.DATABASEPASS,
            host: process.env.DATABASEHOST,
            port: process.env.DATABASEPORT,
            database: process.env.DATABASENAME,
            ssl: {
                rejectUnauthorized: false,
            }
        });
        console.log('Connected to PostgreSQL');
    }
    return this.pgPool;
}

Aquí conectaremos la base de datos mediante las variables de entorno que están en env o nuestro servidor ya configurados. Si la conexión fue exitosa devolverá true.

Por otra parte conectaremos supabase para poder realizar la creación de buckets de ser necesario.

connectToSupabase(shouldConnect = true) {
    if (shouldConnect && !this.supabaseClient) {
        this.supabaseClient = createClient(
            process.env.SUPABASE_URL, 
            process.env.SUPABASE_ANON_KEY
        );
        console.log('Connected to Supabase');
    }
    return this.supabaseClient;
}

En este caso pasa exactamente lo mismo obtiene los datos de las variables de entorno y conecta, si fue exitoso devuelve true.

En caso de que se descaonecte postgres entra en funcionamiento:

disconnectFromPostgres() {
if (this.pgPool) {
        this.pgPool.end();
        this.pgPool = null;
        console.log('Disconnected from PostgreSQL');
    }
}

Luego se verifican si las conexiones son correctas con:

isPostgresConnected() {
    return this.pgPool != null;
}

isSupabaseConnected() {
    return this.supabaseClient != null;
}

Devolverá true si esta conectado o false si fallo la conexión.

Por ultimo esta sección se encarga de realizar las consultas de los archivos correspondientes en el pool de conexiones, lo que ahorra recursos ya que se deriva todo por esta parte y no se tiene que usar en todas las consultas de manera manual.

async query(sql, params) {
    const client = await this.pgPool.connect();
    try {
        const res = await client.query(sql, params);
        return res;
    } catch (err) {
        console.error('Error in the query to the data base: ', err);
        throw err;
    } finally {
        client.release();
    }
}

Lo único que solicita es que se le pase la consulta a realizar y los parámetros o valores que se quieren consultar.