pub(crate) mod item;
pub(crate) mod read;
mod write;
use crate::ape::tag::item::{ApeItem, ApeItemRef};
use crate::error::{LoftyError, Result};
use crate::id3::v2::util::pairs::{format_number_pair, set_number, NUMBER_PAIR_KEYS};
use crate::tag::item::{ItemKey, ItemValue, ItemValueRef, TagItem};
use crate::tag::{try_parse_year, Tag, TagType};
use crate::traits::{Accessor, MergeTag, SplitTag, TagExt};
use std::borrow::Cow;
use std::convert::TryInto;
use std::fs::File;
use std::io::Write;
use std::ops::Deref;
use std::path::Path;
use lofty_attr::tag;
macro_rules! impl_accessor {
($($name:ident => $($key:literal)|+;)+) => {
paste::paste! {
$(
fn $name(&self) -> Option<Cow<'_, str>> {
$(
if let Some(i) = self.get($key) {
if let ItemValue::Text(val) = i.value() {
return Some(Cow::Borrowed(val));
}
}
)+
None
}
fn [<set_ $name>](&mut self, value: String) {
self.insert(ApeItem {
read_only: false,
key: String::from(crate::tag::item::first_key!($($key)|*)),
value: ItemValue::Text(value)
})
}
fn [<remove_ $name>](&mut self) {
$(
self.remove($key);
)+
}
)+
}
}
}
#[derive(Default, Debug, PartialEq, Eq, Clone)]
#[tag(
description = "An `APE` tag",
supported_formats(Ape, Mpeg, Mpc, WavPack)
)]
pub struct ApeTag {
pub read_only: bool,
pub(super) items: Vec<ApeItem>,
}
impl ApeTag {
pub fn new() -> Self {
Self::default()
}
pub fn get(&self, key: &str) -> Option<&ApeItem> {
self.items
.iter()
.find(|i| i.key().eq_ignore_ascii_case(key))
}
pub fn insert(&mut self, value: ApeItem) {
self.remove(value.key());
self.items.push(value);
}
pub fn remove(&mut self, key: &str) {
self.items.retain(|i| !i.key().eq_ignore_ascii_case(key));
}
fn insert_item(&mut self, item: TagItem) {
match item.key() {
ItemKey::TrackNumber => set_number(&item, |number| self.set_track(number)),
ItemKey::TrackTotal => set_number(&item, |number| self.set_track_total(number)),
ItemKey::DiscNumber => set_number(&item, |number| self.set_disk(number)),
ItemKey::DiscTotal => set_number(&item, |number| self.set_disk_total(number)),
_ => {
if let Ok(item) = item.try_into() {
self.insert(item);
}
},
};
}
fn split_num_pair(&self, key: &str) -> (Option<u32>, Option<u32>) {
if let Some(ApeItem {
value: ItemValue::Text(ref text),
..
}) = self.get(key)
{
let mut split = text.split('/').flat_map(str::parse::<u32>);
return (split.next(), split.next());
}
(None, None)
}
fn insert_number_pair(&mut self, key: &'static str, number: Option<u32>, total: Option<u32>) {
if let Some(value) = format_number_pair(number, total) {
self.insert(ApeItem::text(key, value));
} else {
log::warn!("{key} is not set. number: {number:?}, total: {total:?}");
}
}
}
impl IntoIterator for ApeTag {
type Item = ApeItem;
type IntoIter = std::vec::IntoIter<Self::Item>;
fn into_iter(self) -> Self::IntoIter {
self.items.into_iter()
}
}
impl<'a> IntoIterator for &'a ApeTag {
type Item = &'a ApeItem;
type IntoIter = std::slice::Iter<'a, ApeItem>;
fn into_iter(self) -> Self::IntoIter {
self.items.iter()
}
}
impl Accessor for ApeTag {
impl_accessor!(
artist => "Artist";
title => "Title";
album => "Album";
genre => "GENRE";
comment => "Comment";
);
fn track(&self) -> Option<u32> {
self.split_num_pair("Track").0
}
fn set_track(&mut self, value: u32) {
self.insert_number_pair("Track", Some(value), self.track_total());
}
fn remove_track(&mut self) {
self.remove("Track");
}
fn track_total(&self) -> Option<u32> {
self.split_num_pair("Track").1
}
fn set_track_total(&mut self, value: u32) {
self.insert_number_pair("Track", self.track(), Some(value));
}
fn remove_track_total(&mut self) {
let existing_track_number = self.track();
self.remove("Track");
if let Some(track) = existing_track_number {
self.insert(ApeItem::text("Track", track.to_string()));
}
}
fn disk(&self) -> Option<u32> {
self.split_num_pair("Disc").0
}
fn set_disk(&mut self, value: u32) {
self.insert_number_pair("Disc", Some(value), self.disk_total());
}
fn remove_disk(&mut self) {
self.remove("Disc");
}
fn disk_total(&self) -> Option<u32> {
self.split_num_pair("Disc").1
}
fn set_disk_total(&mut self, value: u32) {
self.insert_number_pair("Disc", self.disk(), Some(value));
}
fn remove_disk_total(&mut self) {
let existing_track_number = self.track();
self.remove("Disc");
if let Some(track) = existing_track_number {
self.insert(ApeItem::text("Disc", track.to_string()));
}
}
fn year(&self) -> Option<u32> {
if let Some(ApeItem {
value: ItemValue::Text(ref text),
..
}) = self.get("Year")
{
return try_parse_year(text);
}
None
}
fn set_year(&mut self, value: u32) {
self.insert(ApeItem::text("Year", value.to_string()));
}
fn remove_year(&mut self) {
self.remove("Year");
}
}
impl TagExt for ApeTag {
type Err = LoftyError;
type RefKey<'a> = &'a str;
fn len(&self) -> usize {
self.items.len()
}
fn contains<'a>(&'a self, key: Self::RefKey<'a>) -> bool {
self.items.iter().any(|i| i.key().eq_ignore_ascii_case(key))
}
fn is_empty(&self) -> bool {
self.items.is_empty()
}
fn save_to(&self, file: &mut File) -> std::result::Result<(), Self::Err> {
ApeTagRef {
read_only: self.read_only,
items: self.items.iter().map(Into::into),
}
.write_to(file)
}
fn dump_to<W: Write>(&self, writer: &mut W) -> std::result::Result<(), Self::Err> {
ApeTagRef {
read_only: self.read_only,
items: self.items.iter().map(Into::into),
}
.dump_to(writer)
}
fn remove_from_path<P: AsRef<Path>>(&self, path: P) -> std::result::Result<(), Self::Err> {
TagType::Ape.remove_from_path(path)
}
fn remove_from(&self, file: &mut File) -> std::result::Result<(), Self::Err> {
TagType::Ape.remove_from(file)
}
fn clear(&mut self) {
self.items.clear();
}
}
#[derive(Debug, Clone, Default)]
pub struct SplitTagRemainder(ApeTag);
impl From<SplitTagRemainder> for ApeTag {
fn from(from: SplitTagRemainder) -> Self {
from.0
}
}
impl Deref for SplitTagRemainder {
type Target = ApeTag;
fn deref(&self) -> &Self::Target {
&self.0
}
}
impl SplitTag for ApeTag {
type Remainder = SplitTagRemainder;
fn split_tag(mut self) -> (Self::Remainder, Tag) {
fn split_pair(
content: &str,
tag: &mut Tag,
current_key: ItemKey,
total_key: ItemKey,
) -> Option<()> {
let mut split = content.splitn(2, '/');
let current = split.next()?.to_string();
tag.items
.push(TagItem::new(current_key, ItemValue::Text(current)));
if let Some(total) = split.next() {
tag.items
.push(TagItem::new(total_key, ItemValue::Text(total.to_string())))
}
Some(())
}
let mut tag = Tag::new(TagType::Ape);
for item in std::mem::take(&mut self.items) {
let item_key = ItemKey::from_key(TagType::Ape, item.key());
match (item_key, item.value()) {
(ItemKey::TrackNumber | ItemKey::TrackTotal, ItemValue::Text(val))
if split_pair(val, &mut tag, ItemKey::TrackNumber, ItemKey::TrackTotal)
.is_some() =>
{
continue; },
(ItemKey::DiscNumber | ItemKey::DiscTotal, ItemValue::Text(val))
if split_pair(val, &mut tag, ItemKey::DiscNumber, ItemKey::DiscTotal)
.is_some() =>
{
continue; },
(ItemKey::MovementNumber | ItemKey::MovementTotal, ItemValue::Text(val))
if split_pair(
val,
&mut tag,
ItemKey::MovementNumber,
ItemKey::MovementTotal,
)
.is_some() =>
{
continue; },
(k, _) => {
tag.items.push(TagItem::new(k, item.value));
},
}
}
(SplitTagRemainder(self), tag)
}
}
impl MergeTag for SplitTagRemainder {
type Merged = ApeTag;
fn merge_tag(self, tag: Tag) -> Self::Merged {
let Self(mut merged) = self;
for item in tag.items {
merged.insert_item(item);
}
for pic in tag.pictures {
if let Some(key) = pic.pic_type.as_ape_key() {
if let Ok(item) =
ApeItem::new(key.to_string(), ItemValue::Binary(pic.as_ape_bytes()))
{
merged.insert(item)
}
}
}
merged
}
}
impl From<ApeTag> for Tag {
fn from(input: ApeTag) -> Self {
input.split_tag().1
}
}
impl From<Tag> for ApeTag {
fn from(input: Tag) -> Self {
SplitTagRemainder::default().merge_tag(input)
}
}
pub(crate) struct ApeTagRef<'a, I>
where
I: Iterator<Item = ApeItemRef<'a>>,
{
pub(crate) read_only: bool,
pub(crate) items: I,
}
impl<'a, I> ApeTagRef<'a, I>
where
I: Iterator<Item = ApeItemRef<'a>>,
{
pub(crate) fn write_to(&mut self, file: &mut File) -> Result<()> {
write::write_to(file, self)
}
pub(crate) fn dump_to<W: Write>(&mut self, writer: &mut W) -> Result<()> {
let temp = write::create_ape_tag(self)?;
writer.write_all(&temp)?;
Ok(())
}
}
pub(crate) fn tagitems_into_ape(tag: &Tag) -> impl Iterator<Item = ApeItemRef<'_>> {
fn create_apeitemref_for_number_pair<'a>(
number: Option<&str>,
total: Option<&str>,
key: &'a str,
) -> Option<ApeItemRef<'a>> {
format_number_pair(number, total).map(|value| ApeItemRef {
read_only: false,
key,
value: ItemValueRef::Text(Cow::Owned(value)),
})
}
tag.items()
.filter(|item| !NUMBER_PAIR_KEYS.contains(item.key()))
.filter_map(|i| {
i.key().map_key(TagType::Ape, true).map(|key| ApeItemRef {
read_only: false,
key,
value: (&i.item_value).into(),
})
})
.chain(create_apeitemref_for_number_pair(
tag.get_string(&ItemKey::TrackNumber),
tag.get_string(&ItemKey::TrackTotal),
"Track",
))
.chain(create_apeitemref_for_number_pair(
tag.get_string(&ItemKey::DiscNumber),
tag.get_string(&ItemKey::DiscTotal),
"Disk",
))
}
#[cfg(test)]
mod tests {
use crate::ape::{ApeItem, ApeTag};
use crate::{Accessor, ItemKey, ItemValue, Tag, TagExt, TagItem, TagType};
use crate::id3::v2::util::pairs::DEFAULT_NUMBER_IN_PAIR;
use std::io::Cursor;
#[test]
fn parse_ape() {
let mut expected_tag = ApeTag::default();
let title_item = ApeItem::new(
String::from("TITLE"),
ItemValue::Text(String::from("Foo title")),
)
.unwrap();
let artist_item = ApeItem::new(
String::from("ARTIST"),
ItemValue::Text(String::from("Bar artist")),
)
.unwrap();
let album_item = ApeItem::new(
String::from("ALBUM"),
ItemValue::Text(String::from("Baz album")),
)
.unwrap();
let comment_item = ApeItem::new(
String::from("COMMENT"),
ItemValue::Text(String::from("Qux comment")),
)
.unwrap();
let year_item =
ApeItem::new(String::from("YEAR"), ItemValue::Text(String::from("1984"))).unwrap();
let track_number_item =
ApeItem::new(String::from("TRACK"), ItemValue::Text(String::from("1"))).unwrap();
let genre_item = ApeItem::new(
String::from("GENRE"),
ItemValue::Text(String::from("Classical")),
)
.unwrap();
expected_tag.insert(title_item);
expected_tag.insert(artist_item);
expected_tag.insert(album_item);
expected_tag.insert(comment_item);
expected_tag.insert(year_item);
expected_tag.insert(track_number_item);
expected_tag.insert(genre_item);
let tag = crate::tag::utils::test_utils::read_path("tests/tags/assets/test.apev2");
let mut reader = Cursor::new(tag);
let (parsed_tag, _) = crate::ape::tag::read::read_ape_tag(&mut reader, false)
.unwrap()
.unwrap();
assert_eq!(expected_tag.len(), parsed_tag.len());
for item in &expected_tag.items {
assert!(parsed_tag.items.contains(item));
}
}
#[test]
fn ape_re_read() {
let tag_bytes = crate::tag::utils::test_utils::read_path("tests/tags/assets/test.apev2");
let mut reader = Cursor::new(tag_bytes);
let (parsed_tag, _) = crate::ape::tag::read::read_ape_tag(&mut reader, false)
.unwrap()
.unwrap();
let mut writer = Vec::new();
parsed_tag.dump_to(&mut writer).unwrap();
let mut temp_reader = Cursor::new(writer);
let (temp_parsed_tag, _) = crate::ape::tag::read::read_ape_tag(&mut temp_reader, false)
.unwrap()
.unwrap();
assert_eq!(parsed_tag, temp_parsed_tag);
}
#[test]
fn ape_to_tag() {
let tag_bytes = crate::tag::utils::test_utils::read_path("tests/tags/assets/test.apev2");
let mut reader = Cursor::new(tag_bytes);
let (ape, _) = crate::ape::tag::read::read_ape_tag(&mut reader, false)
.unwrap()
.unwrap();
let tag: Tag = ape.into();
crate::tag::utils::test_utils::verify_tag(&tag, true, true);
}
#[test]
fn tag_to_ape() {
fn verify_key(tag: &ApeTag, key: &str, expected_val: &str) {
assert_eq!(
tag.get(key).map(ApeItem::value),
Some(&ItemValue::Text(String::from(expected_val)))
);
}
let tag = crate::tag::utils::test_utils::create_tag(TagType::Ape);
let ape_tag: ApeTag = tag.into();
verify_key(&ape_tag, "Title", "Foo title");
verify_key(&ape_tag, "Artist", "Bar artist");
verify_key(&ape_tag, "Album", "Baz album");
verify_key(&ape_tag, "Comment", "Qux comment");
verify_key(&ape_tag, "Track", "1");
verify_key(&ape_tag, "Genre", "Classical");
}
#[test]
fn set_track() {
let mut ape = ApeTag::default();
let track = 1;
ape.set_track(track);
assert_eq!(ape.track().unwrap(), track);
assert!(ape.track_total().is_none());
}
#[test]
fn set_track_total() {
let mut ape = ApeTag::default();
let track_total = 2;
ape.set_track_total(track_total);
assert_eq!(ape.track().unwrap(), DEFAULT_NUMBER_IN_PAIR);
assert_eq!(ape.track_total().unwrap(), track_total);
}
#[test]
fn set_track_and_track_total() {
let mut ape = ApeTag::default();
let track = 1;
let track_total = 2;
ape.set_track(track);
ape.set_track_total(track_total);
assert_eq!(ape.track().unwrap(), track);
assert_eq!(ape.track_total().unwrap(), track_total);
}
#[test]
fn set_track_total_and_track() {
let mut ape = ApeTag::default();
let track_total = 2;
let track = 1;
ape.set_track_total(track_total);
ape.set_track(track);
assert_eq!(ape.track_total().unwrap(), track_total);
assert_eq!(ape.track().unwrap(), track);
}
#[test]
fn set_disk() {
let mut ape = ApeTag::default();
let disk = 1;
ape.set_disk(disk);
assert_eq!(ape.disk().unwrap(), disk);
assert!(ape.disk_total().is_none());
}
#[test]
fn set_disk_total() {
let mut ape = ApeTag::default();
let disk_total = 2;
ape.set_disk_total(disk_total);
assert_eq!(ape.disk().unwrap(), DEFAULT_NUMBER_IN_PAIR);
assert_eq!(ape.disk_total().unwrap(), disk_total);
}
#[test]
fn set_disk_and_disk_total() {
let mut ape = ApeTag::default();
let disk = 1;
let disk_total = 2;
ape.set_disk(disk);
ape.set_disk_total(disk_total);
assert_eq!(ape.disk().unwrap(), disk);
assert_eq!(ape.disk_total().unwrap(), disk_total);
}
#[test]
fn set_disk_total_and_disk() {
let mut ape = ApeTag::default();
let disk_total = 2;
let disk = 1;
ape.set_disk_total(disk_total);
ape.set_disk(disk);
assert_eq!(ape.disk_total().unwrap(), disk_total);
assert_eq!(ape.disk().unwrap(), disk);
}
#[test]
fn track_number_tag_to_ape() {
use crate::traits::Accessor;
let track_number = 1;
let mut tag = Tag::new(TagType::Ape);
tag.push(TagItem::new(
ItemKey::TrackNumber,
ItemValue::Text(track_number.to_string()),
));
let tag: ApeTag = tag.into();
assert_eq!(tag.track().unwrap(), track_number);
assert!(tag.track_total().is_none());
}
#[test]
fn track_total_tag_to_ape() {
use crate::traits::Accessor;
let track_total = 2;
let mut tag = Tag::new(TagType::Ape);
tag.push(TagItem::new(
ItemKey::TrackTotal,
ItemValue::Text(track_total.to_string()),
));
let tag: ApeTag = tag.into();
assert_eq!(tag.track().unwrap(), DEFAULT_NUMBER_IN_PAIR);
assert_eq!(tag.track_total().unwrap(), track_total);
}
#[test]
fn track_number_and_track_total_tag_to_ape() {
use crate::traits::Accessor;
let track_number = 1;
let track_total = 2;
let mut tag = Tag::new(TagType::Ape);
tag.push(TagItem::new(
ItemKey::TrackNumber,
ItemValue::Text(track_number.to_string()),
));
tag.push(TagItem::new(
ItemKey::TrackTotal,
ItemValue::Text(track_total.to_string()),
));
let tag: ApeTag = tag.into();
assert_eq!(tag.track().unwrap(), track_number);
assert_eq!(tag.track_total().unwrap(), track_total);
}
#[test]
fn disk_number_tag_to_ape() {
use crate::traits::Accessor;
let disk_number = 1;
let mut tag = Tag::new(TagType::Ape);
tag.push(TagItem::new(
ItemKey::DiscNumber,
ItemValue::Text(disk_number.to_string()),
));
let tag: ApeTag = tag.into();
assert_eq!(tag.disk().unwrap(), disk_number);
assert!(tag.disk_total().is_none());
}
#[test]
fn disk_total_tag_to_ape() {
use crate::traits::Accessor;
let disk_total = 2;
let mut tag = Tag::new(TagType::Ape);
tag.push(TagItem::new(
ItemKey::DiscTotal,
ItemValue::Text(disk_total.to_string()),
));
let tag: ApeTag = tag.into();
assert_eq!(tag.disk().unwrap(), DEFAULT_NUMBER_IN_PAIR);
assert_eq!(tag.disk_total().unwrap(), disk_total);
}
#[test]
fn disk_number_and_disk_total_tag_to_ape() {
use crate::traits::Accessor;
let disk_number = 1;
let disk_total = 2;
let mut tag = Tag::new(TagType::Ape);
tag.push(TagItem::new(
ItemKey::DiscNumber,
ItemValue::Text(disk_number.to_string()),
));
tag.push(TagItem::new(
ItemKey::DiscTotal,
ItemValue::Text(disk_total.to_string()),
));
let tag: ApeTag = tag.into();
assert_eq!(tag.disk().unwrap(), disk_number);
assert_eq!(tag.disk_total().unwrap(), disk_total);
}
}