Function parseOptionsFromUri

connection/connection_params.ts:310–385

(connection_string: string)

}

function parseOptionsFromUri(connection_string: string): ClientOptions {
  let postgres_uri: PostgresUri;
  try {
    const uri = parseConnectionUri(connection_string);
    postgres_uri = {
      application_name: uri.params.application_name,
      dbname: uri.path || uri.params.dbname,
      driver: uri.driver,
      host: uri.host || uri.params.host,
      options: uri.params.options,
      password: uri.password || uri.params.password,
      port: uri.port || uri.params.port,
      // Compatibility with JDBC, not standard
      // Treat as sslmode=require
      sslmode: uri.params.ssl === "true"
        ? "require"
        : (uri.params.sslmode as TLSModes),
      user: uri.user || uri.params.user,
    };
  } catch (e) {
    throw new ConnectionParamsError("Could not parse the connection string", e);
  }

  if (!["postgres", "postgresql"].includes(postgres_uri.driver)) {
    throw new ConnectionParamsError(
      `Supplied DSN has invalid driver: ${postgres_uri.driver}.`,
    );
  }

  // No host by default means socket connection
  const host_type = postgres_uri.host
    ? isAbsolute(postgres_uri.host) ? "socket" : "tcp"
    : "socket";

  const options = postgres_uri.options
    ? parseOptionsArgument(postgres_uri.options)
    : {};

  let tls: TLSOptions | undefined;
  switch (postgres_uri.sslmode) {
    case undefined: {
      break;
    }
    case "disable": {
      tls = { enabled: false, enforce: false, caCertificates: [] };
      break;
    }
    case "prefer": {
      tls = { enabled: true, enforce: false, caCertificates: [] };
      break;
    }
    case "require":
    case "verify-ca":
    case "verify-full": {
      tls = { enabled: true, enforce: true, caCertificates: [] };
      break;
    }
    default: {