Method _establishConnection

src/utils/postgresDatabase.js:28–138

()

    }

    async _establishConnection() {
        const retries = Number.isFinite(pgConfig.options.retries) ? pgConfig.options.retries : 0;
        const baseDelay = Number.isFinite(pgConfig.options.backoffBase) ? pgConfig.options.backoffBase : 100;
        const multiplier = Number.isFinite(pgConfig.options.backoffMultiplier) ? pgConfig.options.backoffMultiplier : 2;
        const attempts = Math.max(1, retries + 1);

        for (let attempt = 1; attempt <= attempts; attempt += 1) {
            try {
                await new Promise(resolve => setTimeout(resolve, 100));

                this.pool = new pg.Pool(resolvePostgresPoolConfig());

                this.pool.on('error', (error, client) => {
                    logger.error('PostgreSQL pool error:', error);
                });

                const client = await this.pool.connect();
                await client.query('SELECT NOW()');
                client.release();

                this.lastFailureReason = null;
                this.lastFailureMessage = null;

                this.isConnected = true;
                logger.info('PostgreSQL Database initialized successfully');

                if (pgConfig.features.autoCreateTables) {
                    await this.createTables();

                    try {
                        const columnCheck = await this.pool.query(`
                            SELECT column_name 
                            FROM information_schema.columns 
                            WHERE table_name = 'guilds' AND column_name = 'counters'
                        `);

                        if (columnCheck.rows.length === 0) {
                            await this.pool.query(`
                                ALTER TABLE ${pgConfig.tables.guilds} 
                                ADD COLUMN counters JSONB DEFAULT '[]'
                            `);
                            logger.info('Added counters column to guilds table');
                        }
                    } catch (error) {
                        logger.warn('Could not add counters column to guilds table:', error.message);
                    }
                }

                if (pgConfig.migration.enabled) {
                    const migrationCheck = await this.verifySchemaVersion();
                    if (!migrationCheck.ok) {
                        const shouldBootstrapSchema =
                            migrationCheck.reason === 'MISSING_MIGRATION_VERSION'
                            && pgConfig.features.autoMigrate;

                        if (shouldBootstrapSchema) {
                            await this.setSchemaVersion(
                                pgConfig.migration.expectedVersion,