From 271a99d6799d9da0cc567f03148ff1d71974e77c Mon Sep 17 00:00:00 2001
From: Bernhard Tittelbach <xro@realraum.at>
Date: Wed, 16 Oct 2013 17:19:09 +0000
Subject: [PATCH] ..

---
 bridge-old-sensors-zmq.py |    4 ++--
 inject_presence.py        |   25 +++++++++++++++++++++++++
 2 files changed, 27 insertions(+), 2 deletions(-)
 create mode 100755 inject_presence.py

diff --git a/bridge-old-sensors-zmq.py b/bridge-old-sensors-zmq.py
index 65e5bc9..459d854 100755
--- a/bridge-old-sensors-zmq.py
+++ b/bridge-old-sensors-zmq.py
@@ -222,7 +222,7 @@ def exitHandler(signum, frame):
     pass
   time.sleep(0.1)
   try:
-    zmqsub.close()
+    zmqpub.close()
     zmqctx.destroy()
   except:
     pass
@@ -250,7 +250,7 @@ zmqpub.connect("tcp://wuzzler.realraum.at:4243")
 #listen for sensor data and forward them
 trackSensorStatus(uwscfg, zmqpub)
 
-zmqsub.close()
+zmqpub.close()
 zmqctx.destroy()
 
 
diff --git a/inject_presence.py b/inject_presence.py
new file mode 100755
index 0000000..731469f
--- /dev/null
+++ b/inject_presence.py
@@ -0,0 +1,25 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-
+from __future__ import with_statement
+import zmq.utils.jsonapi as json
+import zmq
+import time
+
+######## r3 ZMQ ############
+
+def sendR3Message(socket, structname, datadict):
+    socket.send_multipart([structname, json.dumps(datadict)])
+
+#Start zmq connection to publish / forward sensor data
+zmqctx = zmq.Context()
+zmqctx.linger = 0
+zmqpub = zmqctx.socket(zmq.PUB)
+zmqpub.connect("tcp://wuzzler.realraum.at:4243")
+
+#listen for sensor data and forward them
+sendR3Message(zmqpub,"PresenceUpdate",{"Presence":True,"Ts":int(time.time())})
+
+zmqpub.close()
+zmqctx.destroy()
+
+
-- 
1.7.10.4