Fix warnings from rustc 1.65.0 am: 8bf8097d

//! Various utility functions used in tests.

// This file is included directly into integration tests in the

// `tests/` directory. These tests are compiled without access to the

// rest of the `pdl` crate. To make this work, avoid `use crate::`

// statements below.

use quote::quote;

use std::fs;

use std::io::Write;

use std::path::Path;

use std::process::{Command, Stdio};

use tempfile::NamedTempFile;

/// Search for a binary in `$PATH` or as a sibling to the current

/// executable (typically the test binary).

pub fn find_binary(name: &str) -> Result<std::path::PathBuf, String> {

    let mut current_exe = std::env::current_exe().unwrap();

    current_exe.pop();

    let paths = std::env::var_os("PATH").unwrap();

    for mut path in std::iter::once(current_exe.clone()).chain(std::env::split_paths(&paths)) {

        path.push(name);

        if path.exists() {

            return Ok(path);

        }

    }

    Err(format!(

        "could not find '{}' in the directory of the binary ({}) or in $PATH ({})",

        name,

        current_exe.to_string_lossy(),

        paths.to_string_lossy(),

    ))

}

/// Run `input` through `rustfmt`.

///

/// # Panics

///

/// Panics if `rustfmt` cannot be found in the same directory as the

/// test executable or if it returns a non-zero exit code.

pub fn rustfmt(input: &str) -> String {

    let rustfmt_path = find_binary("rustfmt").expect("cannot find rustfmt");

    let mut rustfmt = Command::new(&rustfmt_path)

        .stdin(Stdio::piped())

        .stdout(Stdio::piped())

        .spawn()

        .unwrap_or_else(|_| panic!("failed to start {:?}", &rustfmt_path));

    let mut stdin = rustfmt.stdin.take().unwrap();

    // Owned copy which we can move into the writing thread.

    let input = String::from(input);

    std::thread::spawn(move || {

        stdin.write_all(input.as_bytes()).expect("could not write to stdin");

    });

    let output = rustfmt.wait_with_output().expect("error executing rustfmt");

    assert!(output.status.success(), "rustfmt failed: {}", output.status);

    String::from_utf8(output.stdout).expect("rustfmt output was not UTF-8")

}

/// Find the unified diff between two strings using `diff`.

///

/// # Panics

///

/// Panics if `diff` cannot be found on `$PATH` or if it returns an

/// error.

pub fn diff(left_label: &str, left: &str, right_label: &str, right: &str) -> String {

    let mut temp_left = NamedTempFile::new().unwrap();

    temp_left.write_all(left.as_bytes()).unwrap();

    let mut temp_right = NamedTempFile::new().unwrap();

    temp_right.write_all(right.as_bytes()).unwrap();

    // We expect `diff` to be available on PATH.

    let output = Command::new("diff")

        .arg("--unified")

        .arg("--color=always")

        .arg("--label")

        .arg(left_label)

        .arg("--label")

        .arg(right_label)

        .arg(temp_left.path())

        .arg(temp_right.path())

        .output()

        .expect("failed to run diff");

    let diff_trouble_exit_code = 2; // from diff(1)

    assert_ne!(

        output.status.code().unwrap(),

        diff_trouble_exit_code,

        "diff failed: {}",

        output.status

    );

    String::from_utf8(output.stdout).expect("diff output was not UTF-8")

}

/// Compare two strings and output a diff if they are not equal.

#[track_caller]

pub fn assert_eq_with_diff(left_label: &str, left: &str, right_label: &str, right: &str) {

    assert!(

        left == right,

        "texts did not match, diff:\n{}\n",

        diff(left_label, left, right_label, right)

    );

}

// Assert that an expression equals the given expression.

//

// Both expressions are wrapped in a `main` function (so we can format

// it with `rustfmt`) and a diff is be shown if they differ.

#[track_caller]

pub fn assert_expr_eq(left: proc_macro2::TokenStream, right: proc_macro2::TokenStream) {

    let left = quote! {

        fn main() { #left }

    };

    let right = quote! {

        fn main() { #right }

    };

    assert_eq_with_diff("left", &rustfmt(&left.to_string()), "right", &rustfmt(&right.to_string()));

}

/// Check that `haystack` contains `needle`.

///

/// Panic with a nice message if not.

#[track_caller]

pub fn assert_contains(haystack: &str, needle: &str) {

    assert!(haystack.contains(needle), "Could not find {:?} in {:?}", needle, haystack);

}

/// Compare a string with a snapshot file.

///

/// The `snapshot_path` is relative to the current working directory

/// of the test binary. This depends on how you execute the tests:

///

/// * When using `atest`: The current working directory is a random

///   temporary directory. You need to ensure that the snapshot file

///   is installed into this directory. You do this by adding the

///   snapshot to the `data` attribute of your test rule

///

/// * When using Cargo: The current working directory is set to

///   `CARGO_MANIFEST_DIR`, which is where the `Cargo.toml` file is

///   found.

///

/// If you run the test with Cargo and the `UPDATE_SNAPSHOTS`

/// environment variable is set, then the `actual_content` will be

/// written to `snapshot_path`. Otherwise the content is compared and

/// a panic is triggered if they differ.

#[track_caller]

pub fn assert_snapshot_eq<P: AsRef<Path>>(snapshot_path: P, actual_content: &str) {

    let snapshot = snapshot_path.as_ref();

    let snapshot_content = fs::read(snapshot).unwrap_or_else(|err| {

        panic!("Could not read snapshot from {}: {}", snapshot.display(), err)

    });

    let snapshot_content = String::from_utf8(snapshot_content).expect("Snapshot was not UTF-8");

    // Normal comparison if UPDATE_SNAPSHOTS is unset.

    if std::env::var("UPDATE_SNAPSHOTS").is_err() {

        return assert_eq_with_diff(

            snapshot.to_str().unwrap(),

            &snapshot_content,

            "actual",

            actual_content,

        );

    }

    // Bail out if we are not using Cargo.

    if std::env::var("CARGO_MANIFEST_DIR").is_err() {

        panic!("Please unset UPDATE_SNAPSHOTS if you are not using Cargo");

    }

    if actual_content != snapshot_content {

        eprintln!(

            "Updating snapshot {}: {} -> {} bytes",

            snapshot.display(),

            snapshot_content.len(),

            actual_content.len()

        );

        fs::write(&snapshot_path, actual_content).unwrap_or_else(|err| {

            panic!("Could not write snapshot to {}: {}", snapshot.display(), err)

        });

    }

}

#[cfg(test)]

mod tests {

    use super::*;

    #[test]

    fn test_diff_labels_with_special_chars() {

        // Check that special characters in labels are passed

        // correctly to diff.

        let patch = diff("left 'file'", "foo\nbar\n", "right ~file!", "foo\nnew line\nbar\n");

        assert_contains(&patch, "left 'file'");

        assert_contains(&patch, "right ~file!");

    }

    #[test]

    #[should_panic]

    fn test_assert_eq_with_diff_on_diff() {

        // We use identical labels to check that we haven't

        // accidentally mixed up the labels with the file content.

        assert_eq_with_diff("", "foo\nbar\n", "", "foo\nnew line\nbar\n");

    }

    #[test]

    fn test_assert_eq_with_diff_on_eq() {

        // No panic when there is no diff.

        assert_eq_with_diff("left", "foo\nbar\n", "right", "foo\nbar\n");

    }

}

    fn send_hci_event<E: Into<hci::EventPacket>>(&self, event: E) {

        if let Some(manager) = self.manager.upgrade() {

            manager.ops.send_hci_event(&*event.into().to_vec())

            manager.ops.send_hci_event(&event.into().to_vec())

        }

    }

    fn send_lmp_packet<P: Into<lmp::PacketPacket>>(&self, packet: P) {

        if let Some(manager) = self.manager.upgrade() {

            manager.ops.send_lmp_packet(self.peer_address(), &*packet.into().to_vec())

            manager.ops.send_lmp_packet(self.peer_address(), &packet.into().to_vec())

        }

    }