dedicated url for say vs send

src/config.rs

@@ -37,22 +37,17 @@ pub struct Device {
 #[derive(Serialize, Deserialize, Debug)]
 pub struct GUI {
    pub buttons: Buttons,
-   pub press: PreSufFix,
-   pub release: PreSufFix,
-   pub format: Option<String>,
+   pub release_prefix: String,
+   pub format_keys: Option<String>,
    pub user: String,
    pub feedback: GUIFeedback,
 }
 
 #[derive(Serialize, Deserialize, Debug, Clone)]
 pub struct GUIFeedback {
-   pub url: Option<String>,
-}
-
-#[derive(Serialize, Deserialize, Debug)]
-pub struct PreSufFix {
-   pub prefix: String,
-   pub suffix: String,
+   pub url_read: Option<String>,
+   pub url_say: Option<String>,
+   pub url_send: Option<String>,
 }
 
 #[derive(Serialize, Deserialize, Debug)]
@@ -128,16 +123,9 @@ fn build_config_std() -> Config {
                      l: env::var("INPUT_GUI_BUTTON_L").unwrap_or(String::from("q")),
                      r: env::var("INPUT_GUI_BUTTON_R").unwrap_or(String::from("e")),
                   },
-                  press: PreSufFix{
-                     prefix: env::var("INPUT_GUI_PRESS_PREFIX").unwrap_or(String::from("")),
-                     suffix: env::var("INPUT_GUI_PRESS_SUFFIX").unwrap_or(String::from("")),
-                  },
-                  release: PreSufFix{
-                     prefix: env::var("INPUT_GUI_RELEASE_PREFIX").unwrap_or(String::from("")),
-                     suffix: env::var("INPUT_GUI_RELEASE_SUFFIX").unwrap_or(String::from("")),
-                  },
+                  release_prefix: env::var("INPUT_GUI_RELEASE_PREFIX").unwrap_or(String::from("")),
                   user: env::var("INPUT_GUI_USER").unwrap_or(String::from("me")),
-                  format: match env::var("INPUT_GUI_FORMAT") {
+                  format_keys: match env::var("INPUT_GUI_FORMAT") {
                      Ok(x) => Some(x),
                      Err(_) => match env::var("INPUT_GUI_FORMAT_V01").unwrap_or(String::from("false")) == String::from("true") {
                         true => Some(String::from("{\"T\":{{ms}},\"U\":\"{{user}}\",\"Y\":\"{{pressed}}\",\"N\":\"{{released}}\"}")),
@@ -145,7 +133,15 @@ fn build_config_std() -> Config {
                      },
                   },
                   feedback: GUIFeedback{
-                     url: match env::var("INPUT_GUI_FEEDBACK_URL") {
+                     url_read: match env::var("INPUT_GUI_FEEDBACK_URL_READ") {
+                        Ok(url) => Some(url),
+                        Err(_) => None,
+                     },
+                     url_say: match env::var("INPUT_GUI_FEEDBACK_URL_SAY") {
+                        Ok(url) => Some(url),
+                        Err(_) => None,
+                     },
+                     url_send: match env::var("INPUT_GUI_FEEDBACK_URL_SEND") {
                         Ok(url) => Some(url),
                         Err(_) => None,
                      },

src/gui.rs

@@ -1,11 +1,12 @@
-use iced::widget::{button, column, text};
+use iced::widget::{button, column, row, text};
+use iced::widget::text_input;
 use iced::executor;
 use iced::keyboard;
 use iced::subscription;
 use iced::{Alignment, Element, Application, Settings, Subscription, Theme, Command};
 use iced_futures::backend::native::async_std::time::every;
 use handlebars::Handlebars;
-use serde_json::json;
+use serde_json::{json, Value};
 use std::time::{SystemTime, UNIX_EPOCH};
 use std::thread;
 use reqwest;
@@ -27,21 +28,28 @@ pub fn main(cfg: GUI, output_stream: Box<dyn OutputStream>) -> iced::Result {
       id: def.id,
       text_multithreading: def.text_multithreading,
       try_opengles_first: def.try_opengles_first,
-      window: def.window,
+      window: iced::window::Settings{
+         size: (300, 720),
+         position: iced::window::Position::Specific(0, 0),
+         ..iced::window::Settings::default()
+      },
    };
    Main::run(settings)
 }
 
 struct Main {
-   c: std::sync::mpsc::Receiver<String>,
-   ntfy1: String,
-   ntfy2: String,
+   feedback_recv_c: std::sync::mpsc::Receiver<Feedback>,
+   feedback_send_c: std::sync::mpsc::Sender<Feedback>,
+   ntfy_from_client: String,
+   ntfy_from_server: String,
    configuring: Option<Message>,
    inputs: Inputs,
    keys_newly_down: Vec<iced::keyboard::KeyCode>,
    keys_already_down: Vec<iced::keyboard::KeyCode>,
    keys_up: Vec<iced::keyboard::KeyCode>,
    flags: Flags,
+   input_text_entry_instruction: String,
+   input_text_entry_value: String,
 }
 
 struct Flags {
@@ -70,6 +78,9 @@ struct Stick {
 enum Message {
    EventOccurred(iced_native::Event),
    Tick,
+   InputTextEntryUpdate(String),
+   InputTextEntrySubmitSay,
+   InputTextEntrySubmitSend,
    Up,
    Down,
    Left,
@@ -82,6 +93,13 @@ enum Message {
    R,
 }
 
+#[derive(Debug, Clone)]
+enum Feedback {
+   Heard(String),
+   Say(String),
+   Send(String),
+}
+
 fn controller_button_to_string(btn: Message, cur: iced::keyboard::KeyCode) -> String {
    return format!("{:?} => {:?}", cur, btn);
 }
@@ -103,16 +121,34 @@ impl Main {
       }
    }
 
+   fn send_from_client(&mut self, text: Feedback) {
+      match text.clone() {
+         Feedback::Say(s) | Feedback::Send(s) if s.len() > 0 && s.len() < 1000 => {},
+         _ => return,
+      };
+      match self.feedback_send_c.send(text) {
+         Ok(_) => {},
+         Err(err) => eprintln!("main.send_say() failed to enqueue: {}", err),
+      };
+   }
+
    fn exchange(&mut self) {
       self.exchange_send();
       self.exchange_recv();
    }
 
    fn exchange_recv(&mut self) {
-      match self.c.try_recv() {
-         Ok(msg) => self.ntfy2 = msg,
-         _ => {},
-      };
+      loop {
+         match self.feedback_recv_c.try_recv() {
+            Ok(msg) => {
+               match msg {
+                  Feedback::Heard(msg) => self.ntfy_from_server = msg,
+                  _ => break,
+               };
+            },
+            _ => break,
+         };
+      }
    }
 
    fn exchange_send(&mut self) {
@@ -120,15 +156,9 @@ impl Main {
       for key_code in self.keys_newly_down.iter() {
          match self.key_code_to_string(key_code) {
             Some(x) => {
-               for c in self.flags.cfg.press.prefix.chars() {
-                  s.push(c);
-               }
                for c in x.chars() {
                   s.push(c);
                }
-               for c in self.flags.cfg.press.suffix.chars() {
-                  s.push(c);
-               }
                self.keys_already_down.push(*key_code);
             },
             None => {},
@@ -140,34 +170,34 @@ impl Main {
          match self.key_code_to_string(key_code) {
             Some(x) => {
                for c in x.chars() {
-                  for c in self.flags.cfg.release.prefix.chars() {
+                  for c in self.flags.cfg.release_prefix.chars() {
                      t.push(c);
                   }
                   t.push(c);
-                  for c in self.flags.cfg.release.suffix.chars() {
-                     t.push(c);
-                  }
                }
             },
             None => {},
          };
       }
       if t.len() + s.len() > 0 {
-         self.flags.output_stream.put(self.sprintf(s, t));
+         self.flags.output_stream.put(self.sprintf_pressed_released(s, t));
       }
       self.keys_up.clear();
    }
 
-   fn sprintf(&self, pressed: Vec<char>, released: Vec<char>) -> Vec<char> {
-      match self.flags.cfg.format.clone() {
+   fn sprintf(&self, format: &String, content: &Value) -> Vec<char> {
+      return Handlebars::new().render_template(format, content).unwrap().chars().collect();
+   }
+
+   fn sprintf_pressed_released(&self, pressed: Vec<char>, released: Vec<char>) -> Vec<char> {
+      match self.flags.cfg.format_keys.clone() {
          Some(x) => {
-            let reg = Handlebars::new();
-            return reg.render_template(&x, &json!({
+            return self.sprintf(&x, &json!({
                "pressed": pressed.iter().collect::<String>(),
                "released": released.iter().collect::<String>(),
                "ms": SystemTime::now().duration_since(UNIX_EPOCH).unwrap().as_millis(),
                "user": self.flags.cfg.user,
-            })).unwrap().chars().collect();
+            }));
          },
          None => {
             let mut combo = vec![];
@@ -186,18 +216,21 @@ impl Application for Main {
    type Executor = executor::Default;
 
    fn new(flags: Self::Flags) -> (Self, Command<Message>) {
-      let (sender, receiver) = std::sync::mpsc::channel();
+      let (sender1, receiver1) = std::sync::mpsc::channel();
+      let (sender2, receiver2) = std::sync::mpsc::channel();
       let feedback_cfg = flags.cfg.feedback.clone();
       thread::spawn(move || {
-         Feedback{
-            c: sender,
+         Feedbacker{
+            send_c: sender1,
+            recv_c: receiver2,
             cfg: feedback_cfg,
          }.listen()
       });
       return (Self {
-         c: receiver,
-         ntfy1: String::from(":wave:"),
-         ntfy2: String::from(""),
+         feedback_send_c: sender2,
+         feedback_recv_c: receiver1,
+         ntfy_from_client: String::from(" "),
+         ntfy_from_server: String::from(" "),
          configuring: None,
          inputs: Inputs{
             stick: Stick {
@@ -217,6 +250,8 @@ impl Application for Main {
          keys_newly_down: vec![],
          keys_already_down: vec![],
          keys_up: vec![],
+         input_text_entry_instruction: String::from(""),
+         input_text_entry_value: String::from(""),
       }, Command::none())
    }
 
@@ -229,6 +264,17 @@ impl Application for Main {
          Message::Tick => {
             self.exchange();
          },
+         Message::InputTextEntryUpdate(payload) => {
+            self.input_text_entry_value = payload;
+         },
+         Message::InputTextEntrySubmitSend => {
+            self.send_from_client(Feedback::Send(self.input_text_entry_value.clone()));
+            self.input_text_entry_value = String::from("");
+         },
+         Message::InputTextEntrySubmitSay => {
+            self.send_from_client(Feedback::Say(self.input_text_entry_value.clone()));
+            self.input_text_entry_value = String::from("");
+         },
          Message::EventOccurred(event) if self.configuring.is_some() => {
             match event {
                iced::event::Event::Keyboard(keyboard::Event::KeyPressed{
@@ -249,7 +295,7 @@ impl Application for Main {
                      Message::R => { self.inputs.r = key_code },
                      _ => {},
                   };
-                  self.ntfy1 = format!("{:?} => {:?}", key_code.clone(), self.configuring.as_ref().unwrap());
+                  self.ntfy_from_client = format!("{:?} => {:?}", key_code.clone(), self.configuring.as_ref().unwrap());
                   self.configuring = None;
                },
                _ => {},
@@ -296,7 +342,7 @@ impl Application for Main {
          },
          _ => {
             self.configuring = Some(msg.clone());
-            self.ntfy1 = format!("push a key to bind to {:?}", msg.clone());
+            self.ntfy_from_client = format!("push a key to bind to {:?}", msg.clone());
          },
       }
       return Command::none();
@@ -304,8 +350,11 @@ impl Application for Main {
 
    fn subscription(&self) -> Subscription<Message> {
       return subscription::Subscription::batch(vec![
-         subscription::events_with(|event, _| match event {
-            iced::Event::Keyboard(_) => Some(Message::EventOccurred(event)),
+         subscription::events_with(|event, status| match status {
+            iced::event::Status::Ignored => match event {
+               iced::Event::Keyboard(_) => Some(Message::EventOccurred(event)),
+               _ => None,
+            },
             _ => None,
          }),
          every(std::time::Duration::from_millis(5000)).map(|_| Message::Tick),
@@ -313,59 +362,130 @@ impl Application for Main {
    }
 
    fn view(&self) -> Element<Message> {
+      let new_cfg_button = |msg: Message, s| button(text(controller_button_to_string(msg.clone(), s))).on_press(msg.clone());
       return column![
-               button(text(controller_button_to_string(Message::Up, self.inputs.stick.up))).on_press(Message::Up),
-               button(text(controller_button_to_string(Message::Down, self.inputs.stick.down))).on_press(Message::Down),
-               button(text(controller_button_to_string(Message::Left, self.inputs.stick.left))).on_press(Message::Left),
-               button(text(controller_button_to_string(Message::Right, self.inputs.stick.right))).on_press(Message::Right),
-               button(text(controller_button_to_string(Message::A, self.inputs.a))).on_press(Message::A),
-               button(text(controller_button_to_string(Message::B, self.inputs.b))).on_press(Message::B),
-               button(text(controller_button_to_string(Message::X, self.inputs.x))).on_press(Message::X),
-               button(text(controller_button_to_string(Message::Y, self.inputs.y))).on_press(Message::Y),
-               button(text(controller_button_to_string(Message::L, self.inputs.l))).on_press(Message::L),
-               button(text(controller_button_to_string(Message::R, self.inputs.r))).on_press(Message::R),
-               text(self.ntfy1.clone()).size(50),
-               text(self.ntfy2.clone()).size(50),
-         ]
-         .padding(20)
-         .align_items(Alignment::Center)
-         .into();
+         text(String::from("= MAYHEM PARTY =")).size(32),
+         column![
+            column![
+               text(String::from("Button Mapping")).size(24),
+               text(String::from("--------------")).size(24),
+               new_cfg_button(Message::Up, self.inputs.stick.up),
+               new_cfg_button(Message::Down, self.inputs.stick.down),
+               new_cfg_button(Message::Left, self.inputs.stick.left),
+               new_cfg_button(Message::Right, self.inputs.stick.right),
+               new_cfg_button(Message::A, self.inputs.a),
+               new_cfg_button(Message::B, self.inputs.b),
+               new_cfg_button(Message::X, self.inputs.x),
+               new_cfg_button(Message::Y, self.inputs.y),
+               new_cfg_button(Message::L, self.inputs.l),
+               new_cfg_button(Message::R, self.inputs.r),
+               text(String::from("--------------")).size(24),
+               text(self.ntfy_from_client.clone()).size(18),
+            ].padding(20).align_items(Alignment::Center),
+            column![
+               text_input(
+                  &self.input_text_entry_instruction,
+                  &self.input_text_entry_value,
+                  Message::InputTextEntryUpdate
+               ),
+               row![
+                  button(text("Say")).on_press(Message::InputTextEntrySubmitSay).padding(20),
+                  button(text("Send")).on_press(Message::InputTextEntrySubmitSend).padding(20),
+               ].padding(20).align_items(Alignment::Center),
+               text(self.ntfy_from_server.clone()).size(18),
+            ].padding(20).align_items(Alignment::Center),
+         ].padding(0).align_items(Alignment::Center),
+      ].padding(0).align_items(Alignment::Center).into();
     }
 }
 
-struct Feedback {
-   c: std::sync::mpsc::Sender<String>,
+struct Feedbacker {
+   send_c: std::sync::mpsc::Sender<Feedback>,
+   recv_c: std::sync::mpsc::Receiver<Feedback>,
    cfg: GUIFeedback,
 }
 
-impl Feedback {
+impl Feedbacker {
    fn listen(&mut self) {
       loop {
          std::thread::sleep(std::time::Duration::from_secs(2));
-         match self.read() {
-            Some(msg) if msg.len() > 0 => self.write(msg),
+         match self.read_from_server() {
+            Some(msg) if msg.len() > 0 => {
+               self.write_from_server(msg.clone());
+            },
+            _ => {},
+         };
+         match self.read_from_client() {
+            Some(msg) => self.write_from_client(msg.clone()),
             _ => {},
          };
       }
    }
 
-   fn read(&mut self) -> Option<String> {
-      return match &self.cfg.url {
-         Some(url) => match reqwest::blocking::get(url) {
-            Ok(resp) => match resp.text() {
-               Ok(text) => Some(text),
-               _ => None,
-            },
-            _ => None,
+   fn read_from_server(&mut self) -> Option<String> {
+      return match &self.cfg.url_read {
+         Some(url) => {
+            match reqwest::blocking::get(url) {
+               Ok(resp) => match resp.text() {
+                  Ok(text) => Some(text),
+                  _ => None,
+               },
+               Err(err) => {
+                  eprintln!("feedback.read: cannot fetch: {}", err);
+                  None
+               },
+            }
          },
          _ => None,
       };
    }
 
-   fn write(&mut self, msg: String) {
-      match self.c.send(msg.clone()) {
+   fn write_from_server(&mut self, msg: String) {
+      match self.send_c.send(Feedback::Heard(msg.clone())) {
          Ok(_) => {},
          Err(err) => eprintln!("feedback.listen() failed to display {}: {}", msg, err),
       };
    }
+
+   fn read_from_client(&mut self) -> Option<Feedback> {
+      let mut last: Option<Feedback> = None;
+      loop {
+         match self.recv_c.try_recv() {
+            Ok(msg) => {
+               last = Some(msg);
+            },
+            _ => break,
+         };
+      }
+      return last;
+   }
+
+   fn write_from_client(&mut self, msg: Feedback) {
+      match msg {
+         Feedback::Send(send) if send.len() > 0 => match &self.cfg.url_send {
+            Some(url) => {
+               match reqwest::blocking::get(format!("{}{}", url, send)) {
+                  Err(err) => {
+                     eprintln!("feedback.write_from_client: cannot send: {}", err);
+                  },
+                  _ => {},
+               };
+            },
+            _ => {},
+         },
+         Feedback::Say(say) if say.len() > 0 => match &self.cfg.url_say {
+            Some(url) => {
+               match reqwest::blocking::get(format!("{}{}", url, say)) {
+                  Err(err) => {
+                     eprintln!("feedback.write_from_client: cannot say: {}", err);
+                  },
+                  _ => {},
+               };
+            },
+            _ => {},
+         },
+         _ => {},
+      };
+   }
 }
+

src/testdata/http.go

@@ -1,6 +1,8 @@
 package main
 
 import (
+	"io"
+	"log"
 	"net/http"
 	"os"
 )
@@ -8,7 +10,13 @@ import (
 func main() {
 	p := os.Getenv("PORT")
 	if err := http.ListenAndServe(":"+p, http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-		w.Write([]byte(os.Getenv("BODY")))
+		b, _ := io.ReadAll(r.Body)
+		log.Printf("> %s (%+v) %s", r.URL, r.Header, b)
+		body := os.Getenv("BODY")
+		if body == "-" {
+			body = string(b)
+		}
+		w.Write([]byte(body))
 	})); err != nil {
 		panic(err)
 	}