From 7bd7f060dfceac021b225d9f3e03032e5f2b109b Mon Sep 17 00:00:00 2001
From: Yves Fischer <yvesf-git@xapek.org>
Date: Thu, 5 Jan 2017 18:33:13 +0100
Subject: UI Example

---
 examples/mp-gtk-remote/mp-gtk-remote.py | 38 +++++++++++++++++++++++++++++++++
 mp_tool/web.py                          |  9 ++++++--
 2 files changed, 45 insertions(+), 2 deletions(-)
 create mode 100755 examples/mp-gtk-remote/mp-gtk-remote.py

diff --git a/examples/mp-gtk-remote/mp-gtk-remote.py b/examples/mp-gtk-remote/mp-gtk-remote.py
new file mode 100755
index 0000000..c478728
--- /dev/null
+++ b/examples/mp-gtk-remote/mp-gtk-remote.py
@@ -0,0 +1,38 @@
+#!/usr/bin/env python3
+from mp_tool import web
+
+import gi
+gi.require_version('Gtk', '3.0')
+from gi.repository import Gtk
+
+
+def send_signal(sender):
+    value = int(entry_number.get_value())
+    web.eval(entry_host.get_text(),
+            entry_password.get_text(),
+	    "set_value({})\r\n".format(repr(value)))
+
+
+win = Gtk.Dialog(default_width=1100, default_height=200)
+win.connect("delete-event", Gtk.main_quit)
+vbox = win.get_content_area()
+
+entry_host = Gtk.Entry(text='ws://esp_licht:8266')
+vbox.pack_start(entry_host, True, False, 0)
+
+entry_password = Gtk.Entry(text='password')
+vbox.pack_start(entry_password, True, False, 0)
+
+entry_number = Gtk.Scale(
+	orientation=Gtk.Orientation.HORIZONTAL, 
+	adjustment=Gtk.Adjustment(0, 0, 63, 1, 10, 0),
+	digits=0)
+vbox.pack_start(entry_number, True, True, 0)
+
+button = Gtk.Button("Sende Signal")
+button.connect("clicked", send_signal)
+vbox.pack_start(button, True, True, 0)
+
+win.show_all()
+Gtk.main()
+
diff --git a/mp_tool/web.py b/mp_tool/web.py
index 39e3010..6891aa5 100644
--- a/mp_tool/web.py
+++ b/mp_tool/web.py
@@ -129,6 +129,8 @@ def eval(url: str, password: str, code: str):
     ws = _connect_and_auth(url, password)
     ws.send(Constants.ENTER_REPL_MODE)
     stdout.write(read_until_eval_or_timeout(ws))
+
+    ws.settimeout(5)
     ws.send(code + "\r\n")
 
     result = read_until_eval_or_timeout(ws)
@@ -139,8 +141,11 @@ def eval(url: str, password: str, code: str):
 
 def read_until_eval_or_timeout(ws: websocket.WebSocket):
     buf = ""
-    while not buf.endswith("\r\n>>> "):
-        buf += ws.recv()
+    try:
+        while not buf.endswith("\r\n>>> "):
+            buf += ws.recv()
+    except websocket.WebSocketTimeoutException:
+        pass
     return buf
 
 
-- 
cgit v1.2.1