#![allow(clippy::bool_assert_comparison)]

use std::io;
use std::io::{Cursor, SeekFrom};

use tokio_bitstream_io::{BigEndian, BitRead, BitReader, Endianness, LittleEndian};

#[tokio::test]
async fn test_reader_pos_be() -> io::Result<()> {
    test_reader_pos::<BigEndian>().await
}

#[tokio::test]
async fn test_reader_pos_le() -> io::Result<()> {
    test_reader_pos::<LittleEndian>().await
}

async fn test_reader_pos<E: Endianness>() -> io::Result<()> {
    let actual_data: [u8; 7] = [
        0b1000_1110,
        0b1000_1110,
        0b1000_1110,
        0b1000_1110,
        0b1000_1110,
        0b1000_1110,
        0b1000_1110,
    ];
    let mut r: BitReader<_, E> = BitReader::new(Cursor::new(&actual_data));

    assert_eq!(r.position_in_bits().await?, 0);
    r.read_bit().await?;
    r.read_bit().await?;
    assert_eq!(r.position_in_bits().await?, 2);
    let _: u32 = r.read(5).await?;
    assert_eq!(r.position_in_bits().await?, 7);
    let _: u32 = r.read(4).await?;
    assert_eq!(r.position_in_bits().await?, 11);
    let mut buf = [0u8; 2];
    r.read_bytes(&mut buf).await?;
    assert_eq!(r.position_in_bits().await?, 27);
    r.read_bit().await?;
    r.read_bit().await?;
    r.read_bit().await?;
    r.read_bit().await?;
    r.read_bit().await?;
    r.read_bit().await?;
    r.read_bit().await?;
    let _: i32 = r.read_signed(9).await?;
    assert_eq!(r.position_in_bits().await?, 43);
    let _: i32 = r.read_signed(5).await?;
    assert_eq!(r.position_in_bits().await?, 48);

    Ok(())
}

#[tokio::test]
pub async fn test_reader_seek_start() -> io::Result<()> {
    let actual_data: [u8; 4] = [0xB1, 0xED, 0x3B, 0xC1];
    let mut r = BitReader::endian(Cursor::new(&actual_data), BigEndian);

    r.seek_bits(SeekFrom::Start(0)).await?;
    assert_eq!(r.position_in_bits().await?, 0);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, false);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, false);
    assert_eq!(r.read_bit().await?, false);
    assert_eq!(r.read_bit().await?, false);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.position_in_bits().await?, 8);

    r.seek_bits(SeekFrom::Start(2)).await?;
    assert_eq!(r.position_in_bits().await?, 2);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, false);
    assert_eq!(r.read_bit().await?, false);
    assert_eq!(r.read_bit().await?, false);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.position_in_bits().await?, 8);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.position_in_bits().await?, 10);

    r.seek_bits(SeekFrom::Start(7)).await?;
    assert_eq!(r.position_in_bits().await?, 7);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, false);

    Ok(())
}

#[tokio::test]
pub async fn test_reader_seek_current() -> io::Result<()> {
    let actual_data: [u8; 4] = [0xB1, 0xED, 0x3B, 0xC1];
    let mut r = BitReader::endian(Cursor::new(&actual_data), BigEndian);

    r.seek_bits(SeekFrom::Current(2)).await?;
    assert_eq!(r.position_in_bits().await?, 2);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, false);
    assert_eq!(r.read_bit().await?, false);
    let _: i32 = r.read_signed(11).await?;
    assert_eq!(r.position_in_bits().await?, 17);

    r.seek_bits(SeekFrom::Current(-3)).await?;
    assert_eq!(r.position_in_bits().await?, 14);
    r.skip(10).await?;
    assert_eq!(r.position_in_bits().await?, 24);
    r.seek_bits(SeekFrom::Current(0)).await?;
    assert_eq!(r.position_in_bits().await?, 24);

    Ok(())
}

#[tokio::test]
pub async fn test_reader_seek_end() -> io::Result<()> {
    let actual_data: [u8; 4] = [0xB1, 0xED, 0x3B, 0xC1];
    let mut r = BitReader::endian(Cursor::new(&actual_data), BigEndian);

    r.seek_bits(SeekFrom::End(7)).await?;
    assert_eq!(r.position_in_bits().await?, 25);
    assert_eq!(r.read_bit().await?, true);
    assert_eq!(r.read_bit().await?, false);
    assert_eq!(r.read_bit().await?, false);
    assert_eq!(r.read_bit().await?, false);
    assert_eq!(r.position_in_bits().await?, 29);
    r.seek_bits(SeekFrom::End(0)).await?;
    assert_eq!(r.position_in_bits().await?, 32);

    Ok(())
}