codde_protocol 0.1.6

Multi Communication protocol in heart of the C.O.D.D.E. Pi framework
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

use anyhow::{Ok, Result};

use pyo3::Python;

use crate::{base::error::ServerStateError, server::models::widget_registry::Action};

use crate::base::frame::{Frame, ResultFrame};

use super::models::widget_registry::WidgetAction;

pub trait ServerCom {
    fn open(&mut self) -> Result<(), ServerStateError>;
    fn register_action(&mut self, id: u8, widget: &str, action: Action) -> Result<()>;

    fn callback_result(&mut self, data: ResultFrame) -> Result<()>;

    fn listen(&mut self) -> Result<Option<Frame>>;

    fn serve(&mut self) -> Result<()>; // TODO

    fn close(&mut self) -> Result<()>;
}

pub fn execute_action(acts: &WidgetAction, frame: Frame) -> Result<()> {
    // TODO: create custom error for actions

    if acts.contains_key(frame.identity().as_str()) {
        println!("Found frame ! {}", frame.id);
        match acts.get(frame.identity().as_str()) {
            Some(a) => match a {
                Action::RustFn(a) => a(frame.data),
                Action::PythonFn(a) => Python::with_gil(|py| {
                    println!("running action");
                    a.call1(py, (frame.data,))?;
                    println!("after function");
                    Ok(())
                }),
            },
            None => panic!("Action not found !"),
        }
    } else {
        println!("No key {} found", frame.identity());
        Ok(())
    }
}