Function canConnectToDatabase

packages/internals/src/schemaEngineCommands.ts:68–105

(
  connectionString: string,
  cwd = process.cwd(),
  schemaEnginePath?: string,
)

// could be refactored with engines using JSON RPC instead and just passing the schema
export async function canConnectToDatabase(
  connectionString: string,
  cwd = process.cwd(),
  schemaEnginePath?: string,
): Promise<ConnectionResult> {
  if (!connectionString) {
    throw new Error('Connection url is empty. See https://pris.ly/d/config-url')
  }

  try {
    await execaCommand({
      connectionString,
      cwd,
      schemaEnginePath: schemaEnginePath,
      engineCommandName: 'can-connect-to-database',
    })
  } catch (_e) {
    const e = _e as ExecaError

    if (e.stderr) {
      const logs = parseJsonFromStderr(e.stderr)
      const error = logs.find((it) => it.level === 'ERROR' && it.target === 'schema_engine::logger')

      if (error && error.fields.error_code && error.fields.message) {
        return {
          code: error.fields.error_code as DatabaseErrorCodes,
          message: error.fields.message,
        }
      } else {
        throw new Error(`Schema engine error:\n${logs.map((log) => log.fields.message).join('\n')}`)
      }
    } else {
      throw new Error(`Schema engine exited. ${_e}`)
    }
  }

  return true
}

// could be refactored with engines using JSON RPC instead and just passing the schema
export async function createDatabase(connectionString: string, cwd = process.cwd(), schemaEnginePath?: string) {