#![cfg(feature = "thread_local")]
#![feature(thread_local)]

use static_init::{dynamic, Phase};
use std::panic::catch_unwind;
use std::sync::atomic::{AtomicU32, Ordering};
use std::thread::spawn;

#[dynamic(lazy,prime)]
#[thread_local]
static mut NORMAL: Vec<i32> = match INIT {
    PRIME => vec![],
    DYN => vec![1, 2],
};
#[dynamic(lazy,prime)]
#[thread_local]
static mut NORMAL1: Vec<i32> = match INIT {
    PRIME => vec![],
    DYN => vec![1, 2],
};
#[dynamic(lazy,prime)]
#[thread_local]
static mut NORMAL2: Vec<i32> = match INIT {
    PRIME => vec![],
    DYN => vec![1, 2],
};
#[dynamic(lazy,prime)]
#[thread_local]
static mut NORMAL3: Vec<i32> = match INIT {
    PRIME => vec![],
    DYN => vec![1, 2],
};
#[thread_local]
#[dynamic(lazy,prime)]
static mut NORMAL4: Vec<i32> = match INIT {
    PRIME => vec![],
    DYN => vec![1, 2],
};
#[thread_local]
#[dynamic(lazy,prime)]
static mut NORMAL5: Vec<i32> = match INIT {
    PRIME => vec![],
    DYN => vec![1, 2],
};
#[thread_local]
#[dynamic(lazy,prime)]
static mut NORMAL6: Vec<i32> = match INIT {
    PRIME => vec![],
    DYN => vec![1, 2],
};

#[test]
fn normal() {
    assert!(NORMAL.phase().is_empty());

    assert!(NORMAL.try_read().is_err());

    assert!(NORMAL.try_write().is_err());

    assert!(NORMAL.fast_try_read().unwrap().is_err());

    assert!(NORMAL.fast_try_write().unwrap().is_err());

    assert_eq!(NORMAL.primed_read_non_initializing().unwrap_err().len(), 0);

    assert_eq!(NORMAL.primed_write_non_initializing().unwrap_err().len(), 0);

    assert!(NORMAL.phase().is_empty());

    assert_eq!(NORMAL.read().len(), 2);

    assert_eq!(NORMAL.write().len(), 2);

    assert_eq!(NORMAL.primed_read().unwrap().len(), 2);

    assert_eq!(NORMAL.primed_write().unwrap().len(), 2);

    assert_eq!(NORMAL.fast_read().unwrap().len(), 2);

    assert_eq!(NORMAL.fast_write().unwrap().len(), 2);

    assert_eq!(NORMAL1.write().len(), 2);

    assert_eq!(NORMAL2.fast_read().unwrap().len(), 2);

    assert_eq!(NORMAL3.fast_write().unwrap().len(), 2);

    NORMAL4.init();

    assert_eq!(NORMAL5.primed_read().unwrap().len(), 2);

    assert_eq!(NORMAL6.primed_write().unwrap().len(), 2);

    assert!(NORMAL.phase() == Phase::INITIALIZED);

    assert!(NORMAL.try_read().unwrap().len() == 2);

    assert!(NORMAL.try_write().unwrap().len() == 2);

    assert!(NORMAL.fast_try_write().unwrap().unwrap().len() == 2);

    assert!(NORMAL.fast_try_read().unwrap().unwrap().len() == 2);

    assert_eq!(NORMAL.primed_read_non_initializing().unwrap().len(), 2);

    assert_eq!(NORMAL.primed_write_non_initializing().unwrap().len(), 2);

    assert!(NORMAL.phase() == Phase::INITIALIZED);

    assert_eq!(*NORMAL.read(), vec![1, 2]);

    NORMAL.write().push(3);

    assert_eq!(*NORMAL.read(), vec![1, 2, 3]);

    spawn(|| assert_eq!(*NORMAL.read(), vec![1,2])).join().unwrap();
}

static UNINIT_COUNT: AtomicU32 = AtomicU32::new(0);

#[dynamic(lazy,prime)]
static mut INIT_MAY_PANICK: Vec<i32> = match INIT {
    PRIME => vec![],
    DYN => {
        if UNINIT_COUNT.fetch_add(1, Ordering::Relaxed) < 2 {
            panic!("Should not be seen");
        }
        vec![1, 2]
    }
};

#[test]
fn init_may_panick() {
    assert!(INIT_MAY_PANICK.phase().is_empty());

    assert!(INIT_MAY_PANICK.try_read().is_err());

    assert_eq!(INIT_MAY_PANICK.primed_read_non_initializing().unwrap_err().len(), 0);

    assert!(INIT_MAY_PANICK.phase().is_empty());

    assert!(catch_unwind(|| INIT_MAY_PANICK.write().len()).is_err());

    assert_eq!(UNINIT_COUNT.load(Ordering::Relaxed), 1);

    assert_eq!(
        INIT_MAY_PANICK.phase(),
        Phase::INITIALIZATION_PANICKED | Phase::INITIALIZATION_SKIPED
    );

    assert!(catch_unwind(|| INIT_MAY_PANICK.read().len()).is_err());

    assert_eq!(UNINIT_COUNT.load(Ordering::Relaxed), 2);

    assert_eq!(
        INIT_MAY_PANICK.phase(),
        Phase::INITIALIZATION_PANICKED | Phase::INITIALIZATION_SKIPED
    );

    assert_eq!(INIT_MAY_PANICK.read().len(), 2);

    assert_eq!(UNINIT_COUNT.load(Ordering::Relaxed), 3);

    assert!(INIT_MAY_PANICK.phase() == Phase::INITIALIZED);

    assert!(INIT_MAY_PANICK.try_read().unwrap().len() == 2);

    assert!(INIT_MAY_PANICK.phase() == Phase::INITIALIZED);

    assert_eq!(*INIT_MAY_PANICK.read(), vec![1, 2]);

    assert_eq!(*INIT_MAY_PANICK.primed_read().unwrap(), vec![1, 2]);

    assert_eq!(*INIT_MAY_PANICK.write(), vec![1, 2]);
}

static UNINIT_ONCE_COUNT: AtomicU32 = AtomicU32::new(0);

#[dynamic(lazy,prime, try_init_once)]
static mut UNINITIALIZABLE: Vec<i32> = match INIT {
    PRIME => vec![],
    DYN => {
    UNINIT_ONCE_COUNT.fetch_add(1, Ordering::Relaxed);
    panic!("Panicked on purpose")
    }
};

#[test]
fn init_may_panick_intolerant() {
    assert!(UNINITIALIZABLE.phase().is_empty());

    assert!(UNINITIALIZABLE.try_read().is_err());

    assert_eq!(UNINITIALIZABLE.primed_read_non_initializing().unwrap_err().len(), 0);

    assert!(UNINITIALIZABLE.phase().is_empty());

    assert!(catch_unwind(|| UNINITIALIZABLE.fast_read().unwrap().len()).is_err());

    assert_eq!(UNINIT_ONCE_COUNT.load(Ordering::Relaxed), 1);

    assert_eq!(
        UNINITIALIZABLE.phase(),
        Phase::INITIALIZATION_PANICKED | Phase::INITIALIZATION_SKIPED
    );

    assert!(catch_unwind(|| UNINITIALIZABLE.write().len()).is_err());

    assert_eq!(UNINITIALIZABLE.primed_read_non_initializing().unwrap_err().len(), 0);

    assert_eq!(UNINIT_ONCE_COUNT.load(Ordering::Relaxed), 1);

    assert_eq!(
        UNINITIALIZABLE.phase(),
        Phase::INITIALIZATION_PANICKED | Phase::INITIALIZATION_SKIPED
    );

    assert_eq!(UNINIT_ONCE_COUNT.load(Ordering::Relaxed), 1);
}

#[dynamic(lazy,prime,try_init_once)]
static mut NORMAL_WITH_TOLERANCE: Vec<i32> = match INIT {
    PRIME => vec![],
    DYN => vec![1, 2],
};

#[test]
fn normal_with_tolerance() {
    assert!(NORMAL_WITH_TOLERANCE.phase().is_empty());

    assert!(NORMAL_WITH_TOLERANCE.try_read().is_err());

    assert_eq!(NORMAL_WITH_TOLERANCE.primed_read_non_initializing().unwrap_err().len(), 0);

    assert!(NORMAL_WITH_TOLERANCE.phase().is_empty());

    assert_eq!(NORMAL_WITH_TOLERANCE.read().len(), 2);

    assert!(NORMAL_WITH_TOLERANCE.phase() == Phase::INITIALIZED);

    assert_eq!(NORMAL_WITH_TOLERANCE.try_read().unwrap().len(), 2);

    assert!(NORMAL_WITH_TOLERANCE.phase() == Phase::INITIALIZED);

    assert_eq!(*NORMAL_WITH_TOLERANCE.write(), vec![1, 2]);

    assert_eq!(NORMAL_WITH_TOLERANCE.read().len(), 2);
}