setap.js

const fs = require('node:fs');
const path = require('node:path');
const pg = require('pg');
const metasql = require('metasql');

const APPLICATION = {
  host: 'dpg-cin9i6p8g3nafl4a2drg-a.oregon-postgres.render.com',
  port: 5432,
  database: 'airline_yz6q',
  user: 'airded',
  password: 'iaPpCGpzxsCSqRcCWkTzv17Pb23ex0ip',
  ssl: {
    rejectUnauthorized: false,
    cert: fs.readFileSync(path.resolve(__dirname, '../certificate.crt')),
    key: fs.readFileSync(path.resolve(__dirname, '../private.key')),
  },
};

const DB = path.join(process.cwd(), './db');
const SCHEMAS = path.join(process.cwd(), './schemas');

const read = (name) => fs.promises.readFile(path.join(DB, name), 'utf8');

const execute = async (client, sql) => {
  try {
    await client.query(sql);
  } catch (err) {
    const { message, detail } = err;
    console.error(`${sql}\n${message}\n${detail}\n`);
  }
};

const notEmpty = (s) => s.trim() !== '';

const executeFile = async (client, name) => {
  console.log(`Execute file: ${name}`);
  const sql = await read(name);
  const commands = sql.split(';\n').filter(notEmpty);
  for (const command of commands) {
    await execute(client, command);
  }
};

(async () => {
  await metasql.create(SCHEMAS, DB);
  const databaseFile = path.join(DB, 'database.sql');
  const structureFile = path.join(DB, 'structure.sql');
  await fs.promises.rename(databaseFile, structureFile);
  console.log('Generate typings domain.d.ts');
  const typesFile = path.join(DB, 'database.d.ts');
  const domainTypes = path.join(DB, 'domain.d.ts');
  await fs.promises.rename(typesFile, domainTypes);

  const db = new pg.Client(APPLICATION);
  await db.connect();
  await executeFile(db, 'structure.sql');
  await executeFile(db, 'data.sql');
  await db.end();

  console.log('Environment is ready');
})().catch((err) => {
  console.error(err);
});