pixeldike 0.1.0

pixel drawing game for programmers inspired by reddits r/place
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

//! A sink for drawing on an X or Wayland window

use crate::pixmap::SharedPixmap;
use crate::DaemonResult;
use anyhow::anyhow;
use minifb::{Window, WindowOptions};
use std::mem;
use std::time::Duration;
use tokio::task::{AbortHandle, JoinSet};
use tokio::time::MissedTickBehavior;

/// Start the window in the background.
///
/// Note that handles to X/Wayland windows are not Send so the background task must always be scheduled on the same thread.
/// This is achieved by passing an existing `LocalSet` in which the background task will execute.
pub fn start(join_set: &mut JoinSet<DaemonResult>, pixmap: SharedPixmap) -> anyhow::Result<AbortHandle> {
    let (width, height) = pixmap.get_size();
    let mut window = Window::new("pixelflut", width, height, WindowOptions::default())?;

    window.set_title("Pixelflut Server");

    let handle = join_set
        .build_task()
        .name("window_renderer")
        .spawn_local(async move { render(pixmap, window).await })?;
    Ok(handle)
}

async fn render(pixmap: SharedPixmap, mut window: Window) -> anyhow::Result<!> {
    let (width, height) = pixmap.get_size();
    let mut interval = tokio::time::interval(Duration::from_millis(1000 / 60));
    interval.set_missed_tick_behavior(MissedTickBehavior::Skip);
    loop {
        if !window.is_open() {
            return Err(anyhow!(
                "rendering window has been closed, assuming server should exit"
            ));
        }

        let buffer = unsafe { mem::transmute::<_, &[u32]>(pixmap.get_color_data()) };
        window
            .update_with_buffer(buffer, width, height)
            .expect("Could not update window data");

        interval.tick().await;
    }
}