Function test_http_cache_interface_analyze_request

http-cache/src/test.rs:607–641

()

        let db_path = cache_dir.path().join("cache.redb");
        let key = "GET:http://example.com/corrupt";

        // Initialize the database + table via the manager, then drop it to
        // release redb's exclusive file lock.
        drop(RedbManager::new(&db_path)?);

        // Write undecodable bytes for the key directly into the same table the
        // manager reads from.
        {
            let db = Database::create(&db_path)?;
            let write_txn = db.begin_write()?;
            {
                let mut table =
                    write_txn.open_table(crate::managers::redb::TABLE)?;
                table.insert(key, b"not valid postcard data".as_slice())?;
            }
            write_txn.commit()?;
        }

        let manager = RedbManager::new(&db_path)?;
        let result = manager.get(key).await?;
        assert!(result.is_none());
        Ok(())
    }

    // The manager needs no tokio reactor: drive it on a non-tokio executor
    // (smol, as used by http-cache-ureq / Bevy) with no tokio runtime present.
    #[test]
    fn redb_works_without_tokio_runtime() -> Result<()> {
        smol::block_on(async {
            let url = url_parse("http://example.com/smol")?;
            let cache_dir = tempfile::tempdir().unwrap();
            let manager =
                RedbManager::new(cache_dir.path().join("cache.redb"))?;
            let key = format!("{}:{}", GET, url);
            let req = http::Request::get("http://example.com/smol").body(())?;
            let res = http::Response::builder()
                .status(200)
                .body(TEST_BODY.to_vec())?;