From 4fb37da707279faf92cc8a054c646336f23dfdbe Mon Sep 17 00:00:00 2001
From: tv <tv@xso>
Date: Thu, 1 Sep 2011 02:20:34 +0200
Subject: //god/Reaktor/index: initial commit

This wrapper script downloads and configures jsonbot as necessary.
---
 god/Reaktor                 | 50 ---------------------------------------------
 god/Reaktor/index           | 36 ++++++++++++++++++++++++++++++++
 god/Reaktor/lib/listener.py | 50 +++++++++++++++++++++++++++++++++++++++++++++
 3 files changed, 86 insertions(+), 50 deletions(-)
 delete mode 100755 god/Reaktor
 create mode 100755 god/Reaktor/index
 create mode 100755 god/Reaktor/lib/listener.py

(limited to 'god')

diff --git a/god/Reaktor b/god/Reaktor
deleted file mode 100755
index 9708d9bc..00000000
--- a/god/Reaktor
+++ /dev/null
@@ -1,50 +0,0 @@
-#! /usr/bin/env python2
-# coding=UTF-8
-
-location = 'shackspace'
-host = '0.0.0.0'
-port = 2342
-
-map = {
-  'shackspace': {
-    'device': {
-      0: 'Licht0, Zickenzone; Fenster',
-      1: 'Licht1, Sofaecke; Fenster', 
-      2: 'Licht2, Zickenzone; Ghetto',
-      3: 'Licht3, Sofaecke; Ghetto',
-      4: 'Licht4, Richtung Getränkelager',
-      5: 'Licht5, Porschekonsole',
-      6: 'Licht6, Tomatenecke',
-      7: 'Licht7, Ghetto',
-      10: 'Hauptschalter'
-    },
-    'state': {
-      0: 'aus',
-      1: 'an',
-      2: 'aus in T-10s'
-    },
-    '->': 'ist'
-  }
-}
-
-import socket
-from string import join
-from struct import unpack
-
-# create udp socket
-mysocket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
-
-# allow send/recieve from broacast address
-mysocket.setsockopt(socket.SOL_SOCKET,socket.SO_BROADCAST,1)
-
-# allow the socket to be re-used
-mysocket.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
-mysocket.bind((host, port))
-
-map = map[location]
-
-while True:
-  did, sid = unpack('BB', mysocket.recv(2))
-  device, state = map['device'][did], map['state'][sid]
-  arrow = map['->']
-  print join([device, arrow, state], ' ')
diff --git a/god/Reaktor/index b/god/Reaktor/index
new file mode 100755
index 00000000..6470298e
--- /dev/null
+++ b/god/Reaktor/index
@@ -0,0 +1,36 @@
+#! /bin/sh
+#
+# //god/Reaktor - listen to UDP events and forward them to IRC
+#
+# export host passwd printto to configure jsb-udp
+#
+set -euf
+cd $(readlink -f $(dirname $0))
+
+listener=$(readlink -f lib/listener.py)
+
+jsb_version=0.7.1.2
+distdir=jsb-$jsb_version.tar.gz
+
+host=${host-91.206.142.247}
+passwd=${passwd-h4x0r}
+printto=${printto-#shackspace}
+
+if ! test -x tmp/jsb-$jsb_version; then
+  mkdir -p tmp
+  cd tmp
+  curl -f http://jsonbot.googlecode.com/files/jsb-$jsb_version.tar.gz | tar zx
+  cd jsb-$jsb_version
+  bin/jsb-udp -s </dev/null
+  cd ../..
+fi
+cd tmp/jsb-$jsb_version
+
+# TODO only if it is not already configured properly
+sed -i '
+  s/^host *=.*/host="'$host'"/
+  s/^passwd *=.*/passwd="'$passwd'"/
+  s/^printto *=.*/printto="'$printto'"/
+' config/udp-send
+
+PYTHONUNBUFFERED=y $listener | tee /dev/stderr | bin/jsb-udp
diff --git a/god/Reaktor/lib/listener.py b/god/Reaktor/lib/listener.py
new file mode 100755
index 00000000..9708d9bc
--- /dev/null
+++ b/god/Reaktor/lib/listener.py
@@ -0,0 +1,50 @@
+#! /usr/bin/env python2
+# coding=UTF-8
+
+location = 'shackspace'
+host = '0.0.0.0'
+port = 2342
+
+map = {
+  'shackspace': {
+    'device': {
+      0: 'Licht0, Zickenzone; Fenster',
+      1: 'Licht1, Sofaecke; Fenster', 
+      2: 'Licht2, Zickenzone; Ghetto',
+      3: 'Licht3, Sofaecke; Ghetto',
+      4: 'Licht4, Richtung Getränkelager',
+      5: 'Licht5, Porschekonsole',
+      6: 'Licht6, Tomatenecke',
+      7: 'Licht7, Ghetto',
+      10: 'Hauptschalter'
+    },
+    'state': {
+      0: 'aus',
+      1: 'an',
+      2: 'aus in T-10s'
+    },
+    '->': 'ist'
+  }
+}
+
+import socket
+from string import join
+from struct import unpack
+
+# create udp socket
+mysocket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+
+# allow send/recieve from broacast address
+mysocket.setsockopt(socket.SOL_SOCKET,socket.SO_BROADCAST,1)
+
+# allow the socket to be re-used
+mysocket.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
+mysocket.bind((host, port))
+
+map = map[location]
+
+while True:
+  did, sid = unpack('BB', mysocket.recv(2))
+  device, state = map['device'][did], map['state'][sid]
+  arrow = map['->']
+  print join([device, arrow, state], ' ')
-- 
cgit v1.2.3