Database Manager

DatabaseManager Class

The most important file of the creation and configuration of the database is in this class (change that was placed in version 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;
}

Here we will connect the database using the environment variables that are in env or our server already configured. If the connection was successful it will return true.

On the other hand we will connect supabase to be able to create buckets if necessary.

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;
}

In this case exactly the same thing happens, it gets the data from the environment variables and connects, if it was successful it returns true.

In case it disconnects postgres starts working:

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

The connections are then checked for correctness with:

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

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

It will return true if connected or false if the connection failed.

Finally this section is in charge of making the queries of the corresponding files in the connection pool, which saves resources since everything is derived by this part and does not have to be used in all the queries manually.

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();
    }
}

The only thing it requests is that you pass it the query to be performed and the parameters or values to be queried.