pub fn mysql_user_completer(current: &std::ffi::OsStr) -> Vec<CompletionCandidate> {

    match tokio::runtime::Builder::new_current_thread()

        .enable_all()

        .build()

        Ok(runtime) => match runtime.block_on(mysql_user_completer_(current)) {

            Ok(completions) => completions,

            Err(err) => {

                eprintln!("Error getting MySQL user completions: {err}");

                Vec::new()

        Err(err) => {

            eprintln!("Error starting Tokio runtime: {err}");

            Vec::new()

}

async fn mysql_user_completer_(

    current: &std::ffi::OsStr,

) -> anyhow::Result<Vec<CompletionCandidate>> {

    let server_connection =

        bootstrap_server_connection_and_drop_privileges(None, None, Verbosity::new(0, 1))?;

    let tokio_socket = TokioUnixStream::from_std(server_connection)?;

    let mut server_connection = create_client_to_server_message_stream(tokio_socket);

    while let Some(Ok(message)) = server_connection.next().await {

        match message {

            Response::Error(err) => {

                anyhow::bail!("{err}");

            Response::Ready => break,

            message => {

                eprintln!("Unexpected message from server: {message:?}");

            }

    let message = Request::CompleteUserName(current.to_string_lossy().to_string());

    if let Err(err) = server_connection.send(message).await {

        server_connection.close().await.ok();

        anyhow::bail!(anyhow::Error::from(err).context("Failed to communicate with server"));

    }

    let result = match server_connection.next().await {

        Some(Ok(Response::CompleteUserName(suggestions))) => suggestions,

        response => return erroneous_server_response(response).map(|()| vec![]),

    server_connection.send(Request::Exit).await?;

    let result = result.into_iter().map(CompletionCandidate::new).collect();

    Ok(result)

}