//! Process window events
use std::sync::{Arc, mpsc};
use std;

use glutin;

use input;
use sync::PriorityMutex;
use term::Term;
use tty::process_should_exit;

/// The event processor
pub struct Processor<'a, W: 'a> {
    writer: &'a mut W,
    input_processor: input::Processor,
    terminal: Arc<PriorityMutex<Term>>,
    resize_tx: mpsc::Sender<(u32, u32)>,
}

impl<'a, W> Processor<'a, W>
    where W: std::io::Write
{
    /// Create a new event processor
    ///
    /// Takes a writer which is expected to be hooked up to the write end of a
    /// pty.
    pub fn new(writer: &mut W,
               terminal: Arc<PriorityMutex<Term>>,
               resize_tx: mpsc::Sender<(u32, u32)>)
               -> Processor<W>
    {
        Processor {
            writer: writer,
            terminal: terminal,
            input_processor: input::Processor::new(),
            resize_tx: resize_tx,
        }
    }

    fn handle_event(&mut self, event: glutin::Event) {
        match event {
            glutin::Event::Closed => panic!("window closed"), // TODO ...
            glutin::Event::ReceivedCharacter(c) => {
                match c {
                    // Ignore BACKSPACE and DEL. These are handled specially.
                    '\u{8}' | '\u{7f}' => (),
                    // OSX arrow keys send invalid characters; ignore.
                    '\u{f700}' | '\u{f701}' | '\u{f702}' | '\u{f703}' => (),
                    _ => {
                        let encoded = c.encode_utf8();
                        self.writer.write(encoded.as_slice()).unwrap();
                    }
                }
            },
            glutin::Event::Resized(w, h) => {
                self.resize_tx.send((w, h)).expect("send new size");
            },
            glutin::Event::KeyboardInput(state, _code, key, mods) => {
                // Acquire term lock
                let terminal = self.terminal.lock_high();

                self.input_processor.process(state, key, mods,
                                             &mut input::WriteNotifier(self.writer),
                                             *terminal.mode());
            },
            _ => (),
        }
    }

    /// Process at least one event and handle any additional queued events.
    pub fn process_events(&mut self, window: &glutin::Window) {
        for event in window.wait_events() {
            self.handle_event(event);
            break;
        }

        for event in window.poll_events() {
            self.handle_event(event);
        }
    }
}