extern crate wiremock;
use super::super::config::*;
use super::*;
use std::path::{Path, PathBuf};
use tempfile::{NamedTempFile, TempDir};
use tokio::io::AsyncReadExt;
use wiremock::matchers::{method, path_regex};
use wiremock::{Mock, MockServer, ResponseTemplate};
#[tokio::test]
async fn test() {
let _guard = MUTEX.lock().await;
let test_directory = Path::new("tests");
let progress_bar = ProgressBar::hidden();
let db_file = NamedTempFile::new().unwrap();
let pool = establish_connection(db_file.path().to_str().unwrap()).await;
let mut connection = pool.acquire().await.unwrap();
let rom_directory = TempDir::new_in(test_directory).unwrap();
set_rom_directory(&mut connection, PathBuf::from(rom_directory.path())).await;
let tmp_directory = TempDir::new_in(test_directory).unwrap();
set_tmp_directory(&mut connection, PathBuf::from(tmp_directory.path())).await;
let zip_path = test_directory.join("Test System (20200721).zip");
let mut zip_data = vec![];
open_file(&zip_path)
.await
.unwrap()
.read_to_end(&mut zip_data)
.await
.unwrap();
let mock_server = MockServer::start().await;
Mock::given(method("GET"))
.and(path_regex(r"^/datfile/[a-z0-9-]+/$"))
.respond_with(ResponseTemplate::new(200).set_body_bytes(zip_data))
.mount(&mock_server)
.await;
download_redump_dats(
&mut connection,
&progress_bar,
&mock_server.uri(),
true,
tmp_directory.path().to_str(),
)
.await
.unwrap();
let systems = find_systems(&mut connection).await;
assert_eq!(systems.len(), 1);
let system = systems.first().unwrap();
assert_eq!(system.name, "Test System");
assert_eq!(find_games(&mut connection).await.len(), 6);
assert_eq!(find_roms(&mut connection).await.len(), 8);
assert!(
tmp_directory
.path()
.join("Test System (20200721).dat")
.exists()
);
}