apis 0.4.3

//! This is an interactive program example in which a graphical rendering
//! context is passed between sessions. The program cycles through three modes
//! (sessions) by pressing the 'Tab' key. These sessions are simple (they only
//! contain a single process and no channels). The transitions are defined such
//! that the rendering context is passed from the previous session to the next
//! session.
//!
//! - In 'Bgr' mode, the keys 'B', 'G', and 'R' will change the clear color.
//! - In 'Cym' mode, the keys 'C', 'Y', and 'M' will change the clear color.
//! - In 'Wsk' mode, the keys 'W', 'S', and 'K' will change the clear color.
//!
//! Note that generally this example should not generate any warnings or errors.
//!
//! Running this example will produce a DOT file representing the program state
//! transition diagram. To create a PNG image from the generated DOT file:
//!
//! ```bash
//! make -f MakefileDot graphical
//! ```

#![feature(const_fn)]
#![feature(core_intrinsics)]
#![feature(fnbox)]
#![feature(try_from)]

#[macro_use] extern crate unwrap;
extern crate colored;
extern crate glium;
extern crate simplelog;

extern crate macro_machines;
#[macro_use] extern crate apis;

use glium::glutin;

///////////////////////////////////////////////////////////////////////////////
//  constants                                                                //
///////////////////////////////////////////////////////////////////////////////

//  Off, Error, Warn, Info, Debug, Trace
pub const LOG_LEVEL : simplelog::LevelFilter =
  simplelog::LevelFilter::Info;

///////////////////////////////////////////////////////////////////////////////
//  statics                                                                  //
///////////////////////////////////////////////////////////////////////////////

pub static CONTEXT_ALIVE : std::sync::atomic::AtomicBool =
  std::sync::atomic::ATOMIC_BOOL_INIT;

///////////////////////////////////////////////////////////////////////////////
//  datatypes                                                                //
///////////////////////////////////////////////////////////////////////////////

pub struct GlutinGliumContext {
  pub events_loop   : glutin::EventsLoop,
  pub glium_display : glium::Display
}

impl std::fmt::Debug for GlutinGliumContext {
  fn fmt (&self, f : &mut std::fmt::Formatter) -> std::fmt::Result {
    write!(f, "GlutinGliumContext")
  }
}

#[derive(Clone, Debug)]
pub enum ModeControl {
  Next,
  Quit
}

impl Default for ModeControl {
  fn default () -> Self {
    ModeControl::Quit
  }
}

///////////////////////////////////////////////////////////////////////////////
//  program                                                                  //
///////////////////////////////////////////////////////////////////////////////

def_program! {
  program Graphical where
    let results = session.run()
  {
    MODES [
      mode bgr::Bgr {
        use apis::Process;
        println!("results: {:?}", results);
        let mode_control
          = bgr::InputRender::extract_result (&mut results).unwrap();
        match mode_control {
          ModeControl::Next => Some (EventId::ToCym),
          ModeControl::Quit => None
        }
      }
      mode cym::Cym {
        use apis::Process;
        println!("results: {:?}", results);
        let mode_control
          = cym::InputRender::extract_result (&mut results).unwrap();
        match mode_control {
          ModeControl::Next => Some (EventId::ToWsk),
          ModeControl::Quit => None
        }
      }
      mode wsk::Wsk {
        use apis::Process;
        println!("results: {:?}", results);
        let mode_control
          = wsk::InputRender::extract_result (&mut results).unwrap();
        match mode_control {
          ModeControl::Next => Some (EventId::ToBgr),
          ModeControl::Quit => None
        }
      }
    ]
    TRANSITIONS  [
      transition ToCym <bgr::Bgr> => <cym::Cym> [
        InputRender (bgr) => InputRender (cym) {
          cym.glutin_glium_context = bgr.glutin_glium_context.take();
        }
      ]
      transition ToWsk <cym::Cym> => <wsk::Wsk> [
        InputRender (cym) => InputRender (wsk) {
          wsk.glutin_glium_context = cym.glutin_glium_context.take();
        }
      ]
      transition ToBgr <wsk::Wsk> => <bgr::Bgr> [
        InputRender (wsk) => InputRender (bgr) {
          bgr.glutin_glium_context = wsk.glutin_glium_context.take();
        }
      ]
    ]
    initial_mode: Bgr
  }
}

///////////////////////////////////////////////////////////////////////////////
//  mode Bgr                                                                 //
///////////////////////////////////////////////////////////////////////////////

pub mod bgr {
  use {std, glium, glium::glutin};
  use apis;
  use {CONTEXT_ALIVE, GlutinGliumContext, ModeControl};

  def_session! {
    context Bgr {
      PROCESSES where
        let process    = self,
        let message_in = message_in
      [
        process InputRender (
          frame                : u64 = 0,
          clear_color          : (f32, f32, f32, f32) = (0.0, 0.0, 1.0, 1.0),
          glutin_glium_context : Option <GlutinGliumContext> = {
            if !CONTEXT_ALIVE.swap (true, std::sync::atomic::Ordering::SeqCst) {
              let events_loop = glutin::EventsLoop::new();
              let glium_display = glium::Display::new (
                glutin::WindowBuilder::new(),
                glutin::ContextBuilder::new(),
                &events_loop).unwrap();
              Some (GlutinGliumContext { events_loop, glium_display })
            } else {
              None
            }
          }
        ) -> (ModeControl) {
          kind           { apis::process::Kind::Anisochronous }
          sourcepoints   [ ]
          endpoints      [ ]
          initialize     { println!("...BGR initialize..."); }
          handle_message { unreachable!() }
          update         { process.input_render_update() }
        }
      ]
      CHANNELS [ ]
      MESSAGES [ ]
      main: InputRender
    }
  }

  impl InputRender {
    fn input_render_update (&mut self) -> apis::process::ControlFlow {
      trace!("input_render update...");

      trace!("input_render frame: {}", self.frame);

      let mut result      = apis::process::ControlFlow::Continue;
      let mut clear_color = self.clear_color;
      let mut presult = self.result.clone();
      { // glutin_glium_context scope
        use glium::Surface;

        let glutin_glium_context = self.glutin_glium_context.as_mut().unwrap();

        // poll events
        glutin_glium_context.events_loop.poll_events (|event| {
          //println!("frame[{}] event: {:?}", frame, event);
          match event {
            glutin::Event::DeviceEvent { event, .. } => {
              match event {
                glutin::DeviceEvent::Key (keyboard_input) => {
                  if keyboard_input.state == glutin::ElementState::Pressed {
                    match keyboard_input.virtual_keycode {
                      Some (glutin::VirtualKeyCode::Tab) => {
                        result  = apis::process::ControlFlow::Break;
                        presult = ModeControl::Next;
                      }
                      Some (glutin::VirtualKeyCode::Q) => {
                        result  = apis::process::ControlFlow::Break;
                        presult = ModeControl::Quit;
                      }
                      Some (glutin::VirtualKeyCode::B) => {
                        clear_color = (0.0, 0.0, 1.0, 1.0);
                      }
                      Some (glutin::VirtualKeyCode::G) => {
                        clear_color = (0.0, 1.0, 0.0, 1.0);
                      }
                      Some (glutin::VirtualKeyCode::R) => {
                        clear_color = (1.0, 0.0, 0.0, 1.0);
                      }
                      _ => {}
                    }
                  }
                }
                _ => {}
              }
            }
            _ => {}
          }
        });

        // draw frame
        let mut glium_frame
          = glutin_glium_context.glium_display.draw();
        glium_frame.clear_all (clear_color, 0.0, 0);
        glium_frame.finish().unwrap();
      } // end glutin_glium_context scope
      self.clear_color = clear_color;
      self.frame += 1;

      trace!("...input_render update");

      self.result = presult;
      result
    } // end fn input_render_update
  } // end impl InputRender

} // end mod bgr

///////////////////////////////////////////////////////////////////////////////
//  mode Cym                                                                 //
///////////////////////////////////////////////////////////////////////////////

pub mod cym {
  use glium::glutin;
  use apis;
  use {GlutinGliumContext, ModeControl};

  def_session! {
    context Cym {
      PROCESSES where
        let process    = self,
        let message_in = message_in
      [
        process InputRender (
          frame                : u64 = 0,
          clear_color          : (f32, f32, f32, f32) = (0.0, 1.0, 1.0, 1.0),
          glutin_glium_context : Option <GlutinGliumContext> = None
        ) -> (ModeControl) {
          kind           { apis::process::Kind::Anisochronous }
          sourcepoints   []
          endpoints      []
          terminate      { println!("...CYM terminate..."); }
          handle_message { unreachable!() }
          update         { process.input_render_update() }
        }
      ]
      CHANNELS [ ]
      MESSAGES [ ]
      main: InputRender
    }
  }

  impl InputRender {
    fn input_render_update (&mut self) -> apis::process::ControlFlow {
      trace!("input_render update...");

      trace!("input_render frame: {}", self.frame);

      let mut result      = apis::process::ControlFlow::Continue;
      let mut presult     = self.result.clone();
      let mut clear_color = self.clear_color;
      { // glutin_glium_context scope
        use glium::Surface;

        let glutin_glium_context = self.glutin_glium_context.as_mut().unwrap();

        // poll events
        glutin_glium_context.events_loop.poll_events (|event| {
          //println!("frame[{}] event: {:?}", frame, event);
          match event {
            glutin::Event::DeviceEvent { event, .. } => {
              match event {
                glutin::DeviceEvent::Key (keyboard_input) => {
                  if keyboard_input.state == glutin::ElementState::Pressed {
                    match keyboard_input.virtual_keycode {
                      Some (glutin::VirtualKeyCode::Tab) => {
                        result  = apis::process::ControlFlow::Break;
                        presult = ModeControl::Next;
                      }
                      Some (glutin::VirtualKeyCode::Q) => {
                        result  = apis::process::ControlFlow::Break;
                        presult = ModeControl::Quit;
                      }
                      Some (glutin::VirtualKeyCode::C) => {
                        clear_color = (0.0, 1.0, 1.0, 1.0);
                      }
                      Some (glutin::VirtualKeyCode::Y) => {
                        clear_color = (1.0, 1.0, 0.0, 1.0);
                      }
                      Some (glutin::VirtualKeyCode::M) => {
                        clear_color = (1.0, 0.0, 1.0, 1.0);
                      }
                      _ => {}
                    }
                  }
                }
                _ => {}
              }
            }
            _ => {}
          }
        });

        // draw frame
        let mut glium_frame
          = glutin_glium_context.glium_display.draw();
        glium_frame.clear_all (clear_color, 0.0, 0);
        glium_frame.finish().unwrap();
      } // end glutin_glium_context scope
      self.clear_color = clear_color;
      self.frame += 1;

      trace!("...input_render update");

      self.result = presult;
      result
    } // end fn input_render_update
  } // end impl InputRender
} // end mod cym

///////////////////////////////////////////////////////////////////////////////
//  mode Wsk                                                                 //
///////////////////////////////////////////////////////////////////////////////

pub mod wsk {
  use glium::glutin;
  use apis;
  use {GlutinGliumContext, ModeControl};

  def_session! {
    context Wsk {
      PROCESSES where
        let process    = self,
        let message_in = message_in
      [
        process InputRender (
          frame                : u64 = 0,
          clear_color          : (f32, f32, f32, f32) = (1.0, 1.0, 1.0, 1.0),
          glutin_glium_context : Option <GlutinGliumContext> = None
        ) -> (ModeControl) {
          kind           { apis::process::Kind::Anisochronous }
          sourcepoints   []
          endpoints      []
          initialize     { println!("...wsk initialize..."); }
          terminate      { println!("...wsk terminate..."); }
          handle_message { unreachable!() }
          update         { process.input_render_update() }
        }
      ]
      CHANNELS [ ]
      MESSAGES [ ]
      main: InputRender
    }
  }

  impl InputRender {
    fn input_render_update (&mut self) -> apis::process::ControlFlow {
      trace!("input_render update...");

      trace!("input_render frame: {}", self.frame);

      let mut result      = apis::process::ControlFlow::Continue;
      let mut presult     = self.result.clone();
      let mut clear_color = self.clear_color;
      { // glutin_glium_context scope
        use glium::Surface;

        let glutin_glium_context = self.glutin_glium_context.as_mut().unwrap();

        // poll events
        glutin_glium_context.events_loop.poll_events (|event| {
          //println!("frame[{}] event: {:?}", frame, event);
          match event {
            glutin::Event::DeviceEvent { event, .. } => {
              match event {
                glutin::DeviceEvent::Key (keyboard_input) => {
                  if keyboard_input.state == glutin::ElementState::Pressed {
                    match keyboard_input.virtual_keycode {
                      Some (glutin::VirtualKeyCode::Tab) => {
                        result  = apis::process::ControlFlow::Break;
                        presult = ModeControl::Next;
                      }
                      Some (glutin::VirtualKeyCode::Q) => {
                        result  = apis::process::ControlFlow::Break;
                        presult = ModeControl::Quit;
                      }
                      Some (glutin::VirtualKeyCode::W) => {
                        clear_color = (1.0, 1.0, 1.0, 1.0);
                      }
                      Some (glutin::VirtualKeyCode::S) => {
                        clear_color = (0.5, 0.5, 0.5, 1.0);
                      }
                      Some (glutin::VirtualKeyCode::K) => {
                        clear_color = (0.0, 0.0, 0.0, 1.0);
                      }
                      _ => {}
                    }
                  }
                }
                _ => {}
              }
            }
            _ => {}
          }
        });

        // draw frame
        let mut glium_frame
          = glutin_glium_context.glium_display.draw();
        glium_frame.clear_all (clear_color, 0.0, 0);
        glium_frame.finish().unwrap();
      } // end glutin_glium_context scope
      self.clear_color = clear_color;
      self.frame += 1;

      trace!("...input_render update");

      self.result = presult;
      result
    } // end fn input_render_update
  } // end impl InputRender
} // end mod wsk

///////////////////////////////////////////////////////////////////////////////
//  main                                                                     //
///////////////////////////////////////////////////////////////////////////////

fn main() {
  use colored::Colorize;

  let example_name = std::path::PathBuf::from (std::env::args().next().unwrap())
    .file_name().unwrap().to_str().unwrap().to_string();

  println!("{}", format!("{} main...", example_name).green().bold());

  unwrap!(simplelog::TermLogger::init (LOG_LEVEL, simplelog::Config::default()));

  // create a dotfile for the program state machine
  use std::io::Write;
  use macro_machines::MachineDotfile;
  let mut f = unwrap!(std::fs::File::create (format!("{}.dot", example_name)));
  unwrap!(f.write_all (Graphical::dotfile().as_bytes()));
  drop (f);

  // report size information
  Graphical::report_sizes();

  // create a program in the initial mode
  use apis::Program;
  let mut myprogram = Graphical::initial();
  //debug!("myprogram: {:#?}", myprogram);
  // run to completion
  myprogram.run();

  println!("{}", format!("...{} main", example_name).green().bold());
}