apimokka 0.8.3

API mock (apimock-rs) based visual mocking helper to handle HTTP/JSON req/res. Mock with mokka ☕️🌄
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118

use std::{io::Read, sync::Arc};

use fltk::{
    button::Button,
    enums::{CallbackTrigger, Color},
    frame::Frame,
    group::{Flex, FlexType},
    output::Output,
    prelude::{DisplayExt, GroupExt, InputExt, WidgetBase, WidgetExt},
    text::{TextBuffer, TextEditor},
};

use tokio::sync::{mpsc::Sender, Mutex};

use crate::app::consts::{
    BUTTON_HEIGHT, BUTTON_WIDTH, CONFIG_EDITOR_HEIGHT, CONTAINER_WIDTH, FLEX_SPACING, LABEL_HEIGHT,
};

/// entry point
pub fn handle(config_filepath: &str, restart_server_tx: Arc<Mutex<Sender<()>>>) -> Flex {
    let tab = Flex::default_fill().with_label("Config\t\t").row();

    let mut vflex = Flex::default_fill();
    vflex.set_spacing(FLEX_SPACING);
    vflex.set_type(FlexType::Column);

    let filepath_label = Frame::default()
        // todo: size
        .with_size(CONTAINER_WIDTH, LABEL_HEIGHT)
        .with_label(config_filepath);
    // let mut filepath_output = Output::default();
    // filepath_output
    //     .append(config_filepath)
    //     .expect("Failed to show file path");

    // let scroll = Scroll::default()
    //     // todo: size
    //     .with_size(CONTAINER_WIDTH, CONFIG_EDITOR_HEIGHT);

    let mut config_buffer = TextBuffer::default();
    let config_content = file_content(config_filepath);
    config_buffer.append(&config_content);

    let mut editor = TextEditor::default()
        // todo: size
        .with_size(CONTAINER_WIDTH, CONFIG_EDITOR_HEIGHT);
    editor.set_color(Color::from_hex(0xffeecc));
    editor.set_linenumber_width(16);
    editor.set_linenumber_size(10);
    editor.set_buffer(config_buffer);

    // todo
    editor.set_trigger(CallbackTrigger::Changed);
    editor.set_callback(move |_| {});

    // scroll.end();

    let mut flex = Flex::default()
        // todo: size
        .with_size(CONTAINER_WIDTH, BUTTON_HEIGHT + FLEX_SPACING);
    flex.set_spacing(FLEX_SPACING);

    let mut save_and_restart_server_button = Button::default()
        // todo: size
        .with_size(BUTTON_WIDTH, BUTTON_HEIGHT)
        .with_label("Save and Restart");

    let mut output = Output::default().with_size(BUTTON_WIDTH * 3, BUTTON_HEIGHT);
    output.set_readonly(true);
    output.set_color(Color::Blue);
    output.set_text_color(Color::White);

    let save_and_restart_server_config_filepath = config_filepath.to_owned();
    save_and_restart_server_button.set_callback(move |_button| {
        let _ = match editor
            .buffer()
            .unwrap()
            .save_file(save_and_restart_server_config_filepath.as_str())
        {
            Ok(_) => (),
            Err(err) => {
                output.set_value(err.to_string().as_str());
                return;
            }
        };

        output.set_value("Config saved. Restarting...");

        let restart_server_tx = restart_server_tx.clone();
        let restart_server_output = output.clone();
        tokio::spawn(async move {
            // todo: how to lock
            let _ = restart_server_tx.lock().await.send(()).await;

            restart_server_output.clone().set_value("");
        });
    });

    flex.end();

    vflex.fixed(&filepath_label, LABEL_HEIGHT);
    vflex.fixed(&flex, BUTTON_HEIGHT);
    vflex.end();
    tab.end();

    tab
}

/// get file content
fn file_content(config_filepath: &str) -> String {
    let mut file = std::fs::File::open(config_filepath).expect("Failed to open file");
    let mut read_buffer = String::new();
    let _ = file
        .read_to_string(&mut read_buffer)
        .expect("Failed to read content in file");

    read_buffer
}