Method connectToPostgres

lib/interfaces/database.ts:37–89

()

  }

  protected async connectToPostgres() {
    if (this.db) {
      return this.db;
    }

    try {
      const postgresClient = new Client({
        user: POSTGRESQL_USER,
        password: POSTGRESQL_PASSWORD,
        database: POSTGRESQL_DBNAME,
        hostname: POSTGRESQL_HOST,
        port: POSTGRESQL_PORT,
        tls,
      });

      await postgresClient.connect();

      this.db = postgresClient;
    } catch (error) {
      // Try to connect without TLS, if the connection type is socket
      if ((error as Error).toString().includes('No TLS options are allowed when host type is set to "socket"')) {
        const postgresClient = new Client({
          user: POSTGRESQL_USER,
          password: POSTGRESQL_PASSWORD,
          database: POSTGRESQL_DBNAME,
          hostname: POSTGRESQL_HOST,
          port: POSTGRESQL_PORT,
        });

        await postgresClient.connect();

        this.db = postgresClient;
      } else {
        console.log('Failed to connect to Postgres!');
        console.error(error);

        if (this.throwOnConnectionError) {
          throw error;
        }

        // This allows tests (and the app) to work even if Postgres is not available
        const mockPostgresClient = {
          queryObject: () => {
            return {
              rows: [],
            };
          },
        } as unknown as Client;

        this.db = mockPostgresClient;
      }
    }
  }

  protected async disconnectFromPostgres() {
    if (!this.db) {