lofty 0.25.4

use super::Frame;
use super::header::parse::{parse_header, parse_v2_header};
use crate::config::{ParseOptions, ParsingMode};
use crate::id3::v2::error::FrameParseError;
use crate::id3::v2::frame::content::parse_content;
use crate::id3::v2::header::Id3v2Version;
use crate::id3::v2::tag::ATTACHED_PICTURE_ID;
use crate::id3::v2::util::synchsafe::{SynchsafeInteger, UnsynchronizedStream};
use crate::id3::v2::{BinaryFrame, FrameFlags, FrameHeader, FrameId, Id3v2TagFlags};
use crate::macros::try_vec;

use std::borrow::Cow;
use std::io::Read;

use byteorder::{BigEndian, ReadBytesExt};

pub(crate) enum ParsedFrame<'a> {
	Next(Frame<'a>),
	Skip,
	Eof,
}

impl ParsedFrame<'static> {
	pub(crate) fn read<R>(
		reader: &mut R,
		version: Id3v2Version,
		tag_flags: Id3v2TagFlags,
		parse_options: ParseOptions,
	) -> Result<Self, FrameParseError>
	where
		R: Read + ?Sized,
	{
		let mut size = 0u32;

		// The header will be upgraded to ID3v2.4 past this point, so they can all be treated the same
		let parse_header_result = match version {
			Id3v2Version::V2 => parse_v2_header(reader, &mut size),
			Id3v2Version::V3 => parse_header(reader, &mut size, false, parse_options),
			Id3v2Version::V4 => parse_header(reader, &mut size, true, parse_options),
		};
		let (id, mut flags) = match parse_header_result {
			Ok(None) => {
				// Stop reading
				return Ok(Self::Eof);
			},
			Ok(Some(some)) => some,
			Err(err) => {
				match parse_options.parsing_mode {
					ParsingMode::Strict => return Err(err),
					ParsingMode::BestAttempt | ParsingMode::Relaxed => {
						log::warn!("Failed to read frame header, skipping: {}", err);

						// Skip this frame and continue reading
						skip_frame(None, reader, size)?;
						return Ok(Self::Skip);
					},
				}
			},
		};

		if !parse_options.read_cover_art && id == ATTACHED_PICTURE_ID {
			skip_frame(Some(id), reader, size)?;
			return Ok(Self::Skip);
		}

		// See `parse_id3v2()`
		if tag_flags.unsynchronisation && version > Id3v2Version::V3 {
			flags.unsynchronisation = true;
		}

		if size == 0 {
			if parse_options.parsing_mode == ParsingMode::Strict {
				return Err(FrameParseError::undersized(id));
			}

			log::debug!("Encountered a zero length frame, skipping");

			skip_frame(Some(id), reader, size)?;
			return Ok(Self::Skip);
		}

		// Get the encryption method symbol
		if let Some(enc) = flags.encryption.as_mut() {
			log::trace!("Reading encryption method symbol");

			if size < 1 {
				return Err(FrameParseError::undersized(id));
			}

			match reader.read_u8() {
				Ok(sym) => *enc = sym,
				Err(e) => {
					return Err(FrameParseError::io(Some(id), e));
				},
			}

			size -= 1;
		}

		// Get the group identifier
		if let Some(group) = flags.grouping_identity.as_mut() {
			log::trace!("Reading group identifier");

			if size < 1 {
				return Err(FrameParseError::undersized(id));
			}

			match reader.read_u8() {
				Ok(sym) => *group = sym,
				Err(e) => {
					return Err(FrameParseError::io(Some(id), e));
				},
			}

			size -= 1;
		}

		// Get the real data length
		if flags.data_length_indicator.is_some() || flags.compression {
			log::trace!("Reading data length indicator");

			if size < 4 {
				return Err(FrameParseError::undersized(id));
			}

			// For some reason, no one can follow the spec, so while a data length indicator is *written*
			// the flag **isn't always set**
			let len = match reader.read_u32::<BigEndian>() {
				Ok(len) => len.unsynch(),
				Err(e) => {
					return Err(FrameParseError::io(Some(id), e));
				},
			};
			flags.data_length_indicator = Some(len);
			size -= 4;
		}

		// Frames must have at least 1 byte, *after* all of the additional data flags can provide
		if size == 0 {
			return Err(FrameParseError::undersized(id));
		}

		// Restrict the reader to the frame content
		let mut reader = reader.take(u64::from(size));

		// It seems like the flags are applied in the order:
		//
		// unsynchronization -> compression -> encryption
		//
		// Which all have their own needs, so this gets a little messy...
		match flags {
			// Possible combinations:
			//
			// * unsynchronized + compressed + encrypted
			// * unsynchronized + compressed
			// * unsynchronized + encrypted
			// * unsynchronized
			FrameFlags {
				unsynchronisation: true,
				..
			} => {
				let mut unsynchronized_reader = UnsynchronizedStream::new(reader);

				if flags.compression {
					let mut compression_reader = handle_compression(unsynchronized_reader)?;

					if flags.encryption.is_some() {
						return handle_encryption(&mut compression_reader, size, id, flags);
					}

					return parse_frame(
						&mut compression_reader,
						size,
						id,
						flags,
						version,
						parse_options,
					);
				}

				if flags.encryption.is_some() {
					return handle_encryption(&mut unsynchronized_reader, size, id, flags);
				}

				return parse_frame(
					&mut unsynchronized_reader,
					size,
					id,
					flags,
					version,
					parse_options,
				);
			},
			// Possible combinations:
			//
			// * compressed + encrypted
			// * compressed
			FrameFlags {
				compression: true, ..
			} => {
				let mut compression_reader = handle_compression(reader)?;

				if flags.encryption.is_some() {
					return handle_encryption(&mut compression_reader, size, id, flags);
				}

				return parse_frame(
					&mut compression_reader,
					size,
					id,
					flags,
					version,
					parse_options,
				);
			},
			// Possible combinations:
			//
			// * encrypted
			FrameFlags {
				encryption: Some(_),
				..
			} => {
				return handle_encryption(&mut reader, size, id, flags);
			},
			// Everything else that doesn't have special flags
			_ => {
				return parse_frame(&mut reader, size, id, flags, version, parse_options);
			},
		}
	}
}

#[cfg(feature = "id3v2_compression_support")]
#[allow(clippy::unnecessary_wraps)]
fn handle_compression<R: Read>(reader: R) -> Result<flate2::read::ZlibDecoder<R>, FrameParseError> {
	Ok(flate2::read::ZlibDecoder::new(reader))
}

#[cfg(not(feature = "id3v2_compression_support"))]
#[allow(clippy::unnecessary_wraps)]
fn handle_compression<R>(_: R) -> Result<std::io::Empty, FrameParseError> {
	Err(Id3v2Error::new(Id3v2ErrorKind::CompressedFrameEncountered).into())
}

fn handle_encryption<R: Read>(
	reader: &mut R,
	size: u32,
	id: FrameId<'static>,
	flags: FrameFlags,
) -> Result<ParsedFrame<'static>, FrameParseError> {
	if flags.data_length_indicator.is_none() {
		return Err(FrameParseError::missing_data_length_indicator(id));
	}

	let mut content = try_vec![0; size as usize]?;
	if let Err(e) = reader.read_exact(&mut content) {
		return Err(FrameParseError::io(Some(id), e));
	}

	let encrypted_frame = Frame::Binary(BinaryFrame {
		header: FrameHeader::new(id, flags),
		data: Cow::Owned(content),
	});

	// Nothing further we can do with encrypted frames
	Ok(ParsedFrame::Next(encrypted_frame))
}

fn parse_frame<R: Read>(
	reader: &mut R,
	size: u32,
	id: FrameId<'static>,
	flags: FrameFlags,
	version: Id3v2Version,
	parse_options: ParseOptions,
) -> Result<ParsedFrame<'static>, FrameParseError> {
	match parse_content(reader, id, flags, version, parse_options) {
		Some(result) => result.map(ParsedFrame::Next),
		None => {
			skip_frame(None, reader, size)?;
			Ok(ParsedFrame::Skip)
		},
	}
}

// Note that this is only ever given the full frame size.
//
// In the context of `ParsedFrame::read`, the reader is restricted to the frame content, so this
// is a safe operation, regardless of where we are in parsing the frame.
//
// This assumption *CANNOT* be made in other contexts.
fn skip_frame(
	id: Option<FrameId<'static>>,
	reader: &mut (impl Read + ?Sized),
	size: u32,
) -> Result<(), FrameParseError> {
	log::trace!("Skipping frame of size {}", size);

	let size = u64::from(size);
	let mut reader = reader.take(size);
	let skipped = match std::io::copy(&mut reader, &mut std::io::sink()) {
		Ok(skipped) => skipped,
		Err(e) => return Err(FrameParseError::io(id, e)),
	};
	debug_assert!(skipped <= size);

	Ok(())
}