From 20ac24f66da37cc011e2459c5a347a7083c3272c Mon Sep 17 00:00:00 2001
From: Jules Laplace <julescarbon@gmail.com>
Date: Sun, 20 May 2018 15:05:54 +0200
Subject: move rpc around.. serve html

---
 rpc/__init__.py |  1 +
 rpc/__main__.py |  8 ++++++++
 rpc/rpc.py      | 12 ++++++------
 3 files changed, 15 insertions(+), 6 deletions(-)
 create mode 100644 rpc/__init__.py
 create mode 100644 rpc/__main__.py

(limited to 'rpc')

diff --git a/rpc/__init__.py b/rpc/__init__.py
new file mode 100644
index 0000000..93f5256
--- /dev/null
+++ b/rpc/__init__.py
@@ -0,0 +1 @@
+__init__.py
\ No newline at end of file
diff --git a/rpc/__main__.py b/rpc/__main__.py
new file mode 100644
index 0000000..894f748
--- /dev/null
+++ b/rpc/__main__.py
@@ -0,0 +1,8 @@
+from rpc import CortexRPC
+
+if __name__ == '__main__':
+  def log_param(key, value):
+    print("log param. {}: {}".format(key, value))
+
+  # this will block
+  rpc = CortexRPC(log_param)
diff --git a/rpc/rpc.py b/rpc/rpc.py
index 461ba21..19b405d 100644
--- a/rpc/rpc.py
+++ b/rpc/rpc.py
@@ -27,9 +27,9 @@ class CortexRPC(object):
     val = None
     try:
       val = self.relay.connected("rpc")
-      print("rpc connected...".format(val))
+      print("RPC connected...".format(val))
     except zerorpc.TimeoutExpired:
-      print("rpc timeout :(")
+      print("RPC timeout :(")
     # print("defer sending a file...")
     # gevent.sleep(2)
     # self.send_file("test.png")
@@ -44,20 +44,20 @@ class CortexRPC(object):
     return "ok"
 
   def get_params(self):
-    print("get params call received")
+    print("Get params call received!")
     return "lmao ok"
 
   def send_frame(self, frame):
     if self.relay is not None:
-      print("sending a frame...")
+      print("Sending a frame...")
       frame = '01234567' * 8 * 8 * 8 * 8 * 2
       self.relay.send_frame('frame_00000.png', frame)
     else:
-      print("Relay not ready...")
+      print("Can't send frame, relay not ready...")
 
 if __name__ == '__main__':
   def log_param(key, value):
-    print("log param. {}: {}".format(key, value))
+    print("Log param. {}: {}".format(key, value))
 
   # this will block
   rpc = CortexRPC(log_param)
-- 
cgit v1.2.3-70-g09d2