// struct SequentialSorter {}

//! This crate implements an external sort for arbitrary
//! iterators of any size, assuming they fit on disk.
//! ```
//! # #[cfg(not(miri))]
//! # fn main() -> Result<(), Box<dyn std::error::Error>> {
//! use extsort_iter::*;
//!
//! let sequence = [3,21,42,9,5];
//!
//! // the default configuration will sort with up to 10M in buffered in Memory
//! // and place the files under /tmp
//! //
//! // you will most likely want to change at least the location.
//! let config = ExtsortConfig::default();
//!
//! let data = sequence
//!     .iter()
//!     .cloned()
//!     .external_sort(config)?
//!     .collect::<Vec<_>>();
//! assert_eq!(&data, &[3,5,9,21,42]);
//!
//! // you if you enable the compression_lz4_flex feature, the runs will be transparently compressed
//! // using lz4 before being written to disk. This can help if you have a slow/small disk.
//! # #[cfg(compression_lz4_flex)]
//! let config = ExtsortConfig::default().compress_lz4_flex();
//! # #[cfg(not(compression_lz4_flex))]
//! # let config = ExtsortConfig::default();
//!
//! let data = sequence
//!     .iter()
//!     .cloned()
//!     .external_sort(config)?
//!     .collect::<Vec<_>>();
//! assert_eq!(&data, &[3,5,9,21,42]);
//!
//! # Ok(())
//! # }
//! # #[cfg(miri)]
//! # fn main() {}
//! ```
//!
//! ## When not to use this crate
//!
//! When your source iterator is big because each item owns large amounts of heap memory.
//! That means the following case will result in memory exhaustion:
//! ```no_run
//! # use extsort_iter::*;
//! let data = "somestring".to_owned();
//! let iterator = std::iter::from_fn(|| Some(data.clone())).take(1_000_000);
//! let sorted  = iterator.external_sort(ExtsortConfig::default());
//! ```
//!
//! The reason for that is that we are not dropping the values from the source iterator until they are
//! yielded by the result iterator.
//!
//! You can think of it as buffering the entire input iterator, with the values
//! themselves living on disk but all memory the values point to still living on the heap.

#[cfg(windows)]
extern crate winapi;

#[warn(clippy::all, clippy::pedantic)]
#[allow(clippy::module_name_repetitions)]
pub mod extension_trait;
mod merge;
mod orderer;
mod run;
mod sorter;
mod tape;

pub use extension_trait::*;
pub use sorter::ExtsortConfig;

#[cfg(not(miri))]
#[cfg(test)]
mod tests {
    use crate::{extension_trait::ExtSortOrdExtension, sorter::ExtsortConfig, ExtSortByExtension};

    const TEST_SEQUENCE: [i32; 100] = [
        2, 82, 29, 86, 100, 67, 44, 19, 25, 10, 84, 47, 65, 42, 11, 24, 53, 92, 69, 49, 70, 36, 8,
        48, 16, 91, 62, 58, 55, 18, 27, 79, 76, 40, 22, 95, 99, 28, 17, 7, 59, 30, 97, 80, 34, 33,
        54, 45, 31, 52, 56, 1, 57, 38, 61, 6, 23, 94, 85, 51, 35, 68, 41, 15, 90, 14, 74, 75, 32,
        73, 83, 64, 77, 89, 4, 72, 71, 21, 63, 5, 39, 12, 20, 3, 43, 88, 26, 78, 93, 60, 50, 13,
        37, 87, 46, 96, 66, 98, 81, 9,
    ];

    #[test]
    fn integration() {
        let data = TEST_SEQUENCE
            .iter()
            .external_sort(ExtsortConfig::with_buffer_size(32))
            .unwrap();

        let is_sorted = data.into_iter().zip(1..).all(|(l, r)| *l == r);

        assert!(is_sorted);
    }

    #[test]
    fn sort_zst() {
        let data = [(), (), ()];
        let sorted = data
            .into_iter()
            .external_sort_by_key(ExtsortConfig::new(), |_a| 1)
            .unwrap()
            .collect::<Vec<_>>();
        assert_eq!(3, sorted.len())
    }

    #[test]
    fn integration_sortby() {
        let data = TEST_SEQUENCE
            .iter()
            .external_sort_by(ExtsortConfig::with_buffer_size(4096), |a, b| a.cmp(b))
            .unwrap();
        let data = data.collect::<Vec<_>>();

        let is_sorted = data.into_iter().zip(1..).all(|(l, r)| *l == r);

        assert!(is_sorted);
    }

    #[test]
    fn integration_sortby_key() {
        let data = TEST_SEQUENCE
            .iter()
            .external_sort_by_key(ExtsortConfig::new(), |a| *a)
            .unwrap();
        let data = data.collect::<Vec<_>>();

        let is_sorted = data.into_iter().zip(1..).all(|(l, r)| *l == r);

        assert!(is_sorted);
    }

    fn roundtrip_sequence(sequence: Vec<i32>, buffer_size: usize) {
        let roundtripped = sequence
            .iter()
            .cloned()
            .external_sort(
                ExtsortConfig::with_buffer_size(buffer_size).temp_file_folder("/dev/shm"),
            )
            .unwrap()
            .collect::<Vec<_>>();

        assert_eq!(sequence, roundtripped);
    }

    #[test]
    fn test_single_run() {
        let sequence = (1..100).collect();
        roundtrip_sequence(sequence, 80000);
    }

    #[test]
    fn test_many_runs() {
        let sequence = (0..1000).collect();
        roundtrip_sequence(sequence, 16);
    }

    #[test]
    fn test_tiny_buffer() {
        let sequence = (0..1000).collect();
        roundtrip_sequence(sequence, 1);
    }

    #[test]
    fn test_sort_in_mem() {
        let sequence = (0..10).collect();
        roundtrip_sequence(sequence, 4096);
    }

    #[test]
    fn test_remaining_len() {
        let data = (0..500).collect::<Vec<_>>();
        let mut sorted = data
            .into_iter()
            .external_sort(ExtsortConfig::with_buffer_size(8))
            .unwrap();
        let mut result = vec![];
        assert_eq!(500, sorted.len());
        while let Some(next) = sorted.next() {
            result.push(next);
            assert_eq!(500 - result.len(), sorted.len());
        }
    }
}