Function server_it_works

redis-server/src/main.rs:350–426

()

    #[tokio::test]
    async fn server_it_works() {
        let _ = tracing_subscriber::fmt::try_init();

        let port = PORT_ALLOC.fetch_add(1, Ordering::SeqCst);

        let localhost_v4 = IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1));
        let addr = SocketAddr::new(localhost_v4, port);

        let (shutdown_tx, shutdown_rx) = oneshot::channel();
        let cache_path = PathBuf::from(format!(
            "{}/redis-test/{}/",
            option_env!("CARGO_TARGET_TMPDIR").unwrap_or("/tmp"),
            port
        ));
        let cache_size = 1048576;

        info!(?cache_path);
        fs::remove_dir_all(&cache_path);
        fs::create_dir_all(&cache_path).unwrap();

        let mut handle = tokio::spawn(async move {
            run_server(cache_size, cache_path, false, addr, shutdown_rx).await;
        });

        // Do the test
        let blocking_task = tokio::task::spawn_blocking(move || {
            let client = redis::Client::open(
                format!("redis://username:password@127.0.0.1:{}/", port).as_str(),
            )
            .expect("failed to launch redis client");

            let mut con = client.get_connection().expect("failed to get connection");

            let v: InfoDict = cmd("INFO").query(&mut con).expect("Failed to get info");

            let r = v.get::<u64>("used_memory");
            error!(?r, "used memory");

            let h: HashMap<String, usize> = cmd("CONFIG")
                .arg("GET")
                .arg("maxmemory")
                .query(&mut con)
                .expect("Failed to get config");

            let mm = h
                .get("maxmemory")
                .and_then(|&s| if s != 0 { Some(s as u64) } else { None })
                .expect("Failed to get maxmemory");

            let key = b"test_key";
            let d = b"test_data";

            let d1: Vec<u8> = cmd("GET")
                .arg(key)
                .query(&mut con)
                .expect("Failed to get key");

            let d2: Vec<u8> = cmd("SET")