PbDbFixer/src/main.rs

199 lines
6.9 KiB
Rust
Raw Normal View History

2021-01-29 12:47:33 +01:00
mod pocketbook;
2021-01-28 17:52:09 +01:00
use rusqlite::{named_params, Connection, Result, NO_PARAMS};
use std::error::Error;
use std::fs::File;
use std::io::BufReader;
2021-01-29 10:44:07 +01:00
use xml::reader::{EventReader, ParserConfig, XmlEvent};
2021-01-28 17:52:09 +01:00
use zip::{read::ZipFile, ZipArchive};
fn get_root_file(container: ZipFile) -> Result<Option<String>, Box<dyn Error>> {
let parser = EventReader::new(container);
for e in parser {
match e {
Ok(XmlEvent::StartElement {
name, attributes, ..
}) if name.local_name == "rootfile" => {
for attr in attributes {
if attr.name.local_name == "full-path" {
return Ok(Some(attr.value));
}
}
}
Err(e) => {
return Err(Box::new(e));
}
_ => {}
}
}
Ok(None)
}
fn get_attribute_file_as(opf: ZipFile) -> Option<String> {
2021-01-29 10:44:07 +01:00
let parser = ParserConfig::new()
.trim_whitespace(true)
.ignore_comments(true)
.coalesce_characters(true)
.create_reader(opf);
let mut refines_found = false;
2021-01-29 13:51:36 +01:00
let mut refines_entries = Vec::new();
2021-01-29 10:44:07 +01:00
let mut is_epub3 = false;
2021-01-29 13:51:36 +01:00
let mut creator_ids = Vec::new();
2021-01-28 17:52:09 +01:00
for e in parser {
match e {
Ok(XmlEvent::StartElement {
name, attributes, ..
}) if name.local_name == "package" => {
for attr in attributes {
if attr.name.local_name == "version" {
2021-01-29 10:44:07 +01:00
if attr.value.starts_with("3") == true {
is_epub3 = true;
2021-01-28 17:52:09 +01:00
}
}
}
}
Ok(XmlEvent::StartElement {
name, attributes, ..
}) if name.local_name == "creator" => {
for attr in attributes {
if attr.name.local_name == "file-as" {
2021-01-29 10:44:07 +01:00
println!("File-as: {}", &attr.value);
2021-01-28 17:52:09 +01:00
return Some(attr.value);
}
2021-01-29 10:44:07 +01:00
if is_epub3 && attr.name.local_name == "id" {
2021-01-29 13:51:36 +01:00
creator_ids.push("#".to_owned() + attr.value.as_str());
2021-01-29 10:44:07 +01:00
}
}
}
Ok(XmlEvent::StartElement {
name, attributes, ..
}) if name.local_name == "meta" => {
if attributes.iter().any(|attr| {
2021-01-29 13:51:36 +01:00
attr.name.local_name == "refines" && creator_ids.contains(&attr.value)
2021-01-29 10:44:07 +01:00
}) && attributes
.iter()
.any(|attr| attr.name.local_name == "property" && attr.value == "file-as")
{
refines_found = true;
}
}
Ok(XmlEvent::Characters(value)) => {
if refines_found == true {
2021-01-29 13:51:36 +01:00
refines_entries.push(value);
refines_found = false;
2021-01-29 10:44:07 +01:00
}
}
Ok(XmlEvent::StartElement { .. }) => {
if refines_found == true {
refines_found = false;
2021-01-28 17:52:09 +01:00
}
}
Err(_e) => {
break;
}
_ => {}
}
}
2021-01-29 13:51:36 +01:00
if refines_entries.len() == 1 {
return Some(refines_entries.remove(0));
} else if refines_entries.len() >= 2 {
return Some(refines_entries.join(" & "));
}
2021-01-28 17:52:09 +01:00
None
}
struct BookEntry {
id: i32,
filepath: String,
}
fn main() {
2021-01-29 12:47:33 +01:00
let mut authors_fixed = 0;
2021-01-28 17:52:09 +01:00
let mut conn = Connection::open("/mnt/ext1/system/explorer-3/explorer-3.db").unwrap();
let tx = conn.transaction().unwrap();
{
2021-01-29 13:51:36 +01:00
// Get book ids from entries where we have something like "firstname lastname" in author
// but no "lastname, firstname" in fistauthor
let mut stmt = tx.prepare("SELECT id FROM books_impl WHERE ext LIKE 'epub' AND author LIKE '% %' AND (firstauthor NOT LIKE '%\\,%' ESCAPE '\\' OR firstauthor LIKE '%&amp;%')").unwrap();
2021-01-28 17:52:09 +01:00
let mut rows = stmt.query(NO_PARAMS).unwrap();
let mut book_ids: Vec<i32> = Vec::new();
while let Some(row) = rows.next().unwrap() {
book_ids.push(row.get(0).unwrap());
}
2021-01-29 13:51:36 +01:00
// Get also book ids from the special case where we have multiple authors (separated by ", " in authors)
// but no ampersand ("&") in firstauthor
let mut stmt = tx.prepare("SELECT id FROM books_impl WHERE ext LIKE 'epub' AND author LIKE '%\\, %' ESCAPE '\\' AND firstauthor NOT LIKE '%&%'").unwrap();
let mut rows = stmt.query(NO_PARAMS).unwrap();
while let Some(row) = rows.next().unwrap() {
book_ids.push(row.get(0).unwrap());
}
book_ids.sort();
book_ids.dedup();
2021-01-28 17:52:09 +01:00
let mut bookentries = Vec::new();
for book_id in book_ids {
let mut stmt = tx.prepare("SELECT folders.name,files.filename FROM files,folders WHERE files.book_id = :book_id AND files.storageid = 1 AND files.folder_id = folders.id").unwrap();
let mut rows = stmt
.query_named(named_params! { ":book_id": book_id })
.unwrap();
while let Some(row) = rows.next().unwrap() {
let prefix: String = row.get(0).unwrap();
let filename: String = row.get(1).unwrap();
let filepath = format!("{}/{}", prefix, filename);
bookentries.push(BookEntry {
id: book_id,
filepath: filepath,
});
}
}
for entry in bookentries {
let file = File::open(entry.filepath.as_str());
let file = match file {
Err(_) => continue,
Ok(file) => file,
};
let mut archive = ZipArchive::new(BufReader::new(file)).unwrap();
let container = archive.by_name("META-INF/container.xml").unwrap();
if let Some(opf_file) = get_root_file(container).unwrap() {
let opf = archive.by_name(opf_file.as_str()).unwrap();
if let Some(file_as) = get_attribute_file_as(opf) {
let mut stmt = tx
.prepare("UPDATE books_impl SET firstauthor = :file_as WHERE id = :book_id")
.unwrap();
stmt.execute_named(named_params![":file_as": file_as, ":book_id": entry.id])
.unwrap();
2021-01-29 12:47:33 +01:00
authors_fixed = authors_fixed + 1;
2021-01-28 17:52:09 +01:00
}
}
}
}
tx.commit().unwrap();
2021-01-29 12:47:33 +01:00
if cfg!(target_arch = "arm") {
if authors_fixed == 0 {
pocketbook::dialog(
pocketbook::Icon::Info,
"The database seems to be ok.\nNothing had to be fixed.",
);
} else {
pocketbook::dialog(
pocketbook::Icon::Info,
&format!("Authors fixed: {}", &authors_fixed),
);
}
}
2021-01-28 17:52:09 +01:00
}