use super::common::*;
use super::config::*;
use super::model::*;
use super::progress::*;
use super::util::*;
use anyhow::{Context, Result};
use chrono::prelude::*;
use clap::value_parser;
use clap::{Arg, ArgMatches, Command};
use indicatif::ProgressBar;
use quick_xml::se;
use serde::Serialize;
use sqlx::sqlite::SqliteConnection;
use std::path::Path;
use std::path::PathBuf;
use std::str;
use tokio::io::AsyncWriteExt;
use walkdir::WalkDir;
pub const DOCTYPE: &[&str] = &[
"<?xml version=\"1.0\"?>\n",
"<!DOCTYPE datafile PUBLIC \"-//Logiqx//DTD ROM Management Datafile//EN\" \"http://www.logiqx.com/Dats/datafile.dtd\">\n",
];
pub fn subcommand() -> Command {
Command::new("create-dats")
.about("Create DAT files from directories")
.arg(
Arg::new("DIRECTORIES")
.help("Set the directories to process")
.required(true)
.num_args(1..)
.index(1)
.value_parser(value_parser!(PathBuf)),
)
.arg(
Arg::new("NAME")
.short('n')
.long("name")
.help("Customize the DAT name")
.required(false)
.num_args(1),
)
.arg(
Arg::new("DESCRIPTION")
.short('d')
.long("description")
.help("Customize the DAT description")
.required(false)
.num_args(1),
)
.arg(
Arg::new("VERSION")
.short('v')
.long("version")
.help("Customize the DAT version")
.required(false)
.num_args(1),
)
.arg(
Arg::new("AUTHOR")
.short('a')
.long("author")
.help("Customize the DAT author")
.required(false)
.num_args(1),
)
.arg(
Arg::new("URL")
.short('u')
.long("url")
.help("Customize the DAT URL")
.required(false)
.num_args(1),
)
.arg(
Arg::new("OUTPUT")
.short('o')
.long("output")
.help("Customize the output directory")
.required(false)
.num_args(1),
)
}
pub async fn main(
connection: &mut SqliteConnection,
matches: &ArgMatches,
progress_bar: &ProgressBar,
) -> Result<()> {
let directories = matches
.get_many::<PathBuf>("DIRECTORIES")
.unwrap()
.cloned()
.collect::<Vec<PathBuf>>();
for directory in directories {
print_header(
progress_bar,
&format!(
"Processing \"{}\"",
directory.file_name().unwrap().to_str().unwrap()
),
);
create_dat(
connection,
progress_bar,
directory,
matches.get_one::<PathBuf>("OUTPUT"),
matches.get_one::<String>("NAME"),
matches.get_one::<String>("DESCRIPTION"),
matches.get_one::<String>("VERSION"),
matches.get_one::<String>("AUTHOR"),
matches.get_one::<String>("URL"),
)
.await?;
print_separator(progress_bar);
}
Ok(())
}
#[allow(clippy::too_many_arguments)]
pub async fn create_dat<P: AsRef<Path>, Q: AsRef<Path>>(
connection: &mut SqliteConnection,
progress_bar: &ProgressBar,
input_directory: P,
output_directory: Option<Q>,
name: Option<&String>,
description: Option<&String>,
version: Option<&String>,
author: Option<&String>,
url: Option<&String>,
) -> Result<()> {
let system_name = input_directory
.as_ref()
.file_name()
.unwrap()
.to_str()
.unwrap()
.to_string();
let system_date = format!("{}", Local::now().format("%Y%m%d-%H%M%S"));
let system_version = version.map(String::to_owned).unwrap_or(system_date.clone());
let system_xml = SystemXml {
name: name.map(String::to_owned).unwrap_or(system_name.clone()),
description: description
.map(String::to_owned)
.unwrap_or(system_name.clone()),
version: system_version.clone(),
date: Some(system_date.clone()),
author: author.map(String::to_owned),
url: url.map(String::to_owned),
clrmamepros: vec![],
};
let mut games_xml: Vec<GameXml> = vec![];
let walker = WalkDir::new(&input_directory).into_iter();
for entry in walker.filter_map(|e| e.ok()) {
if entry.path().is_file() {
let romfile = CommonRomfile::from_path(&entry.path())?;
let rom_name = romfile
.path
.file_name()
.unwrap()
.to_str()
.unwrap()
.to_string();
print_subheader(progress_bar, &format!("Processing \"{}\"", rom_name));
let rom_xml = RomXml {
name: rom_name,
size: romfile.get_size(connection, progress_bar).await? as i64,
crc: Some(
romfile
.get_hash_and_size(connection, progress_bar, 1, 1, &HashAlgorithm::Crc)
.await?
.0,
),
md5: Some(
romfile
.get_hash_and_size(connection, progress_bar, 1, 1, &HashAlgorithm::Md5)
.await?
.0,
),
sha1: Some(
romfile
.get_hash_and_size(connection, progress_bar, 1, 1, &HashAlgorithm::Sha1)
.await?
.0,
),
merge: None,
status: None,
};
let game_name = romfile
.path
.file_stem()
.unwrap()
.to_str()
.unwrap()
.to_string();
let game_xml = GameXml {
name: game_name.clone(),
description: game_name.clone(),
roms: vec![rom_xml],
disks: vec![],
isbios: false,
isdevice: false,
cloneof: None,
romof: None,
comment: None,
};
games_xml.push(game_xml);
}
}
let datfile_xml = DatfileXml {
system: system_xml,
games: games_xml,
machines: vec![],
};
let mut buffer = String::new();
let mut serializer = se::Serializer::new(&mut buffer);
serializer.indent(' ', 2);
datfile_xml
.serialize(serializer)
.context("Failed to serialize DAT file")?;
let output_directory = match output_directory {
Some(directory) => {
if !directory.as_ref().is_dir() {
create_directory(progress_bar, &directory.as_ref(), true).await?;
}
get_canonicalized_path(&directory.as_ref()).await?
}
None => input_directory.as_ref().parent().unwrap().to_path_buf(),
};
let mut dat_file = create_file(
progress_bar,
&output_directory.join(format!("{} ({}).dat", system_name, system_version)),
false,
)
.await?;
for doctype in DOCTYPE {
dat_file
.write_all(doctype.as_bytes())
.await
.context("Failed to write DAT file")?;
}
dat_file
.write_all(buffer.as_bytes())
.await
.context("Failed to write DAT file")?;
Ok(())
}
#[cfg(test)]
mod test_dat;