import { DataSource } from 'typeorm';

import { getDbDataSourceAsync } from '../../src/getDbDataSourceAsync';
import { POSTGRES_PORT } from '../constants';

/**
 * Get the DB connection and initialize it by installing extension and synchronize schemas
 * @returns db connection
 */
// $eslint-fix-me https://github.com/rhinodavid/eslint-fix-me
// eslint-disable-next-line @typescript-eslint/no-inferrable-types
export async function initDbDataSourceAsync(port: number = POSTGRES_PORT): Promise<DataSource> {
    const dataSource = await getDbDataSourceAsync(`postgres://api:api@localhost:${port}/api`);
    await dataSource.query(`CREATE EXTENSION IF NOT EXISTS pgcrypto`); // used by view `rfq_maker_pairs_update_time_hashes`
    await dataSource.query(`CREATE EXTENSION IF NOT EXISTS "uuid-ossp"`); // used by `meta_transaction_jobs` to generate uuid
    await dataSource.synchronize(true);
    return dataSource;
}