Function newPostgresClient

src/lib/connectors/postgres/index.ts:10–51

(connection: Connection)

const systemTables = "'_prisma_migrations'";

const newPostgresClient = async (connection: Connection) => {
  const clientConfig: ClientConfig = {
    host: connection.host,
    port: Number(connection.port),
    user: connection.username,
    password: connection.password,
    database: connection.database,
    application_name: "sqlchat",
  };
  if (connection.ssl) {
    clientConfig.ssl = {
      ca: connection.ssl?.ca,
      cert: connection.ssl?.cert,
      key: connection.ssl?.key,
    };
  } else {
    clientConfig.ssl = {
      rejectUnauthorized: false,
    };
  }

  let client = new Client(clientConfig);

  if (connection.ssl) {
    await client.connect();
  } else {
    try {
      await client.connect();
    } catch (error) {
      // Because node-postgres didn't implement `sslmode: preferred`. So first try to connect via SSL, otherwise connect via non-SSL.
      // Connecting postgres via non-ssl requires `clientConfig.ssl` is undefined. ref: https://github.com/sqlchat/sqlchat/issues/108
      if (error instanceof Error && error.message.includes("The server does not support SSL connections")) {
        clientConfig.ssl = undefined;
        client = new Client(clientConfig);
        await client.connect();
      } else {
        throw error;
      }
    }
  }
  return client;
};

const testConnection = async (connection: Connection): Promise<boolean> => {
  const client = await newPostgresClient(connection);