311 lines
9.3 KiB
Python
311 lines
9.3 KiB
Python
# -*- coding: utf-8 -*-
|
|
from util import hook
|
|
import re
|
|
import time
|
|
import requests
|
|
import urllib
|
|
from subprocess import check_output
|
|
import json
|
|
import socket
|
|
import struct
|
|
|
|
#def run_ecmd(cmd):
|
|
## baseuri = "http://netio.chch.lan.ffc/ecmd?"
|
|
## baseuri = "http://10.8.128.35/ecmd?"
|
|
# baseuri = "http://127.0.0.1:4280/ecmd?"
|
|
# cmds = "%20".join(cmd)
|
|
# req = requests.get("%s%s" % (baseuri, cmds))
|
|
# return req.text.strip()
|
|
|
|
#def run_udp(cmd):
|
|
# ip="127.0.0.1"
|
|
# port=49152
|
|
# s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
# # 100 ms timeout
|
|
# s.settimeout(0.1)
|
|
# s.connect((ip, port))
|
|
# s.send(cmd)
|
|
# try:
|
|
# rec = s.recv(1024)
|
|
# except:
|
|
# rec = ""
|
|
# s.close()
|
|
# return rec
|
|
|
|
## lamp_lounge handling
|
|
#@hook.command("lamp_lounge", autohelp=True)
|
|
#def cmd_lamp_lounge(inp, reply=None):
|
|
# """lamp_lounge color - set the lamp color"""
|
|
# args = inp.split(" ")
|
|
# if len(args) < 1:
|
|
# reply("lamp_lounge color - set the lamp color")
|
|
# return
|
|
#
|
|
# if len(args[0]) != 6:
|
|
# reply("lamp_lounge color - set the lamp color")
|
|
# return
|
|
#
|
|
# c = "a\x00\x03" + struct.pack('BBB', int(args[0][2:4], 16), int(args[0][0:2], 16), int(args[0][4:6], 16))
|
|
#
|
|
# rep = run_tcp(c)
|
|
#
|
|
# if len(rep) < 3:
|
|
# reply("Error: no reply")
|
|
# return
|
|
#
|
|
# if rep[0] == 'a':
|
|
# reply("OK")
|
|
# elif rep[0] == 'e':
|
|
# reply("error: " + rep[3:])
|
|
# else:
|
|
# reply("fatal error")
|
|
|
|
@hook.command("corridor_light_toggle", autohelp=False)
|
|
def cmd_corridor_light_toggle(inp, reply=None):
|
|
"""toggle corridor light modes"""
|
|
reply(check_output("echo corridor_light_toggle | ssh -q -p 2322 command@127.0.0.1", shell=True).strip("\n").decode("utf-8"))
|
|
|
|
@hook.command("corridor_light", autohelp=False)
|
|
def cmd_corridor_light(inp, reply=None):
|
|
"""set corridor light color"""
|
|
args = inp.split(" ")
|
|
if len(args) < 1:
|
|
reply("corridor_light color - set the light color")
|
|
return
|
|
|
|
if len(args[0]) != 6:
|
|
reply("corridor_light color - set the light color")
|
|
return
|
|
|
|
reply(check_output("echo corridor_light " + args[0] + " | ssh -q -p 2322 command@127.0.0.1", shell=True).strip("\n").decode("utf-8"))
|
|
|
|
@hook.command("lounge_light_toggle", autohelp=False)
|
|
def cmd_lounge_light_toggle(inp, reply=None):
|
|
"""toggle lounge light modes"""
|
|
reply(check_output("echo lounge_light_toggle | ssh -q -p 2322 command@127.0.0.1", shell=True).strip("\n").decode("utf-8"))
|
|
|
|
@hook.command("lounge_light", autohelp=False)
|
|
def cmd_lounge_light(inp, reply=None):
|
|
"""set lounge light color"""
|
|
args = inp.split(" ")
|
|
if len(args) < 1:
|
|
reply("lounge_light color - set the light color")
|
|
return
|
|
|
|
if len(args[0]) != 6:
|
|
reply("lounge_light color - set the light color")
|
|
return
|
|
|
|
reply(check_output("echo lounge_light " + args[0] + " | ssh -q -p 2322 command@127.0.0.1", shell=True).strip("\n").decode("utf-8"))
|
|
|
|
@hook.command("elab_light_toggle", autohelp=False)
|
|
def cmd_elab_light_toggle(inp, reply=None):
|
|
"""toggle e-lab light modes"""
|
|
reply(check_output("echo e-lab_light_toggle | ssh -q -p 2322 command@127.0.0.1", shell=True).strip("\n").decode("utf-8"))
|
|
|
|
@hook.command("elab_light", autohelp=False)
|
|
def cmd_elab_light(inp, reply=None):
|
|
"""set e-lab light color"""
|
|
args = inp.split(" ")
|
|
if len(args) < 1:
|
|
reply("e-lab_light color - set the light color")
|
|
return
|
|
|
|
if len(args[0]) != 6:
|
|
reply("e-lab_light color - set the light color")
|
|
return
|
|
|
|
reply(check_output("echo e-lab_light " + args[0] + " | ssh -q -p 2322 command@127.0.0.1", shell=True).strip("\n").decode("utf-8"))
|
|
|
|
## Lamp handling
|
|
#@hook.command("lamp", autohelp=True)
|
|
#def cmd_lamp(inp, reply=None):
|
|
# """lamp color [mode] - set the lamp color"""
|
|
# args = inp.split(" ")
|
|
# if len(args) < 1:
|
|
# reply("""lamp color [mode] - set the lamp color""")
|
|
# return
|
|
#
|
|
# if len(args[0]) != 6:
|
|
# reply("""lamp color [mode] - set the lamp color""")
|
|
# return
|
|
#
|
|
# cmode = "s"
|
|
# if len(args) > 1:
|
|
# if args[1] == "s" or args[1] == "y" or args[1] == "f":
|
|
# cmode = args[1]
|
|
#
|
|
# c = []
|
|
# c.append([5, int(args[0][0:2], 16)])
|
|
# c.append([4, int(args[0][2:4], 16)])
|
|
# c.append([3, int(args[0][4:6], 16)])
|
|
#
|
|
# for ce in c:
|
|
# res = run_ecmd(["channel", str(ce[0]), str(ce[1]), cmode])
|
|
# if res != "OK":
|
|
# return
|
|
# reply("OK")
|
|
|
|
#@hook.command("lamp_fadestep", autohelp=True)
|
|
#def cmd_lamp_fadestep(inp, reply=None):
|
|
# """lamp_fadestep step - set the lamp fadestep"""
|
|
# args = inp.split(" ")
|
|
#
|
|
# if len(args) < 1:
|
|
# reply("""lamp_fadestep step - set the lamp fadestep""")
|
|
# return
|
|
#
|
|
# reply(run_ecmd(["fadestep", args[0]]))
|
|
|
|
#@hook.command("lamp_fadestep_get", autohelp=False)
|
|
#def cmd_lamp_fadestep_get(inp, reply=None):
|
|
# """lamp_fadestep_get - get the lamp fadestep"""
|
|
# reply(run_ecmd(["fadestep"]))
|
|
#
|
|
#@hook.command("lamp_channels", autohelp=False)
|
|
#def cmd_lamp_channels(inp, reply=None):
|
|
# """lamp_chanels - get the lamp channel count"""
|
|
# reply(run_ecmd(["channels"]))
|
|
|
|
# Wiki handling
|
|
def wiki_changes(cmd=False):
|
|
tmpfile = "/tmp/wikichanges.timestamp.txt"
|
|
basewikiuri = "https://www.chaoschemnitz.de/index.php?title=%s"
|
|
wikiapiuri = "https://www.chaoschemnitz.de/api.php?"\
|
|
"action=query&list=recentchanges&format=json&"\
|
|
"rcprop=user|userid|comment|parsedcomment|timestamp|"\
|
|
"title|sha1|sizes|redirect|loginfo|tags|flags"\
|
|
"&rclist=edit|external|new|log"
|
|
|
|
try:
|
|
fdch = open(tmpfile, "rw")
|
|
timestamp = fdch.read()
|
|
fdch.close()
|
|
except IOError:
|
|
timestamp = None
|
|
|
|
try:
|
|
r = requests.get(wikiapiuri, verify=False)
|
|
except:
|
|
return []
|
|
|
|
rarr = []
|
|
changes = r.json()["query"]["recentchanges"]
|
|
ntimestamp = changes[0]["timestamp"]
|
|
for change in changes:
|
|
if change["timestamp"] == timestamp:
|
|
break
|
|
uri = basewikiuri % (urllib.quote(change["title"].encode("utf-8"), safe=""))
|
|
rarr.append("wiki: %s changed '%s' ( %s ) comment: %s" %\
|
|
(change["user"], change["title"], uri,\
|
|
change["comment"].strip("\r\n\t")))
|
|
|
|
if cmd == False:
|
|
fdch = open(tmpfile, "w+")
|
|
fdch.write("%s" % (ntimestamp))
|
|
fdch.close()
|
|
|
|
return rarr
|
|
|
|
def print_wiki_changes(info, conn=None, chan=None):
|
|
"""print_wiki_changes - print wiki changes, when the worker calls"""
|
|
ch = wiki_changes(cmd=False)
|
|
if len(ch) == 0:
|
|
return
|
|
for c in ch[::-1]:
|
|
conn.msg("#chaoschemnitz", c)
|
|
time.sleep(0.5)
|
|
|
|
@hook.command("wikichanges", autohelp=False)
|
|
def cmd_wikichanges(inp, reply=None):
|
|
"""wikichanges - Return new recent wiki changes"""
|
|
ch = wiki_changes(cmd=True)
|
|
if len(ch) == 0:
|
|
reply("No changes since the last call were made to the wiki.")
|
|
else:
|
|
for c in ch[::-1][-4:]:
|
|
reply(c)
|
|
time.sleep(0.5)
|
|
|
|
# Status handling
|
|
def getstatus():
|
|
# try:
|
|
fd = requests.get('http://www.chaoschemnitz.de/chch.json')
|
|
chch_info = fd.json()
|
|
if 'message' in chch_info['state']:
|
|
message = chch_info['state']['message']
|
|
if " | " in message:
|
|
message = message.split(" | ", 1)[0]
|
|
else:
|
|
message = ""
|
|
|
|
if chch_info['state']['open']:
|
|
state = "geöffnet".decode("utf-8")
|
|
else:
|
|
state = "geschlossen"
|
|
|
|
return "%s (%s)" % (state, message)
|
|
# return check_output("sudo /bin/chch-status", shell=True).strip("\n").decode("utf-8")
|
|
# except:
|
|
# return "unbekannt"
|
|
|
|
@hook.command("status", autohelp=False)
|
|
def cmd_status(inp, reply=None):
|
|
"""status - Return the door status"""
|
|
reply("Chaostreff Status: %s" % (getstatus()))
|
|
|
|
@hook.event("TOPIC")
|
|
def topic_update(info, conn=None, chan=None):
|
|
print("topic update")
|
|
"""topic_update -- Update the topic on TOPIC command"""
|
|
if chan != "#ChaosChemnitz":
|
|
return
|
|
|
|
status = getstatus()
|
|
print("status: %s" % (status.encode('utf8')))
|
|
|
|
topic = info[-1].split(" | ")
|
|
print("topic: %s" % ([ elem.encode('utf8') for elem in topic ]))
|
|
|
|
sstr = "Status: %s" % (status)
|
|
print("sstr: %s" % (sstr.encode('utf8')))
|
|
didset = False
|
|
i = 0
|
|
while i < len(topic):
|
|
if sstr in topic[i]:
|
|
print("Found current status in topic.")
|
|
didset = True
|
|
break
|
|
if 'Status: ' in topic[i]:
|
|
print("Found Status field in topic.")
|
|
didset = True
|
|
topic[i] = sstr
|
|
i += 1
|
|
if didset == False:
|
|
print("No topic fiel was found, appending.")
|
|
topic.append(sstr)
|
|
|
|
newtopic = " | ".join(topic)
|
|
if newtopic != info[-1]:
|
|
conn.send("TOPIC %s :%s" % (chan, newtopic))
|
|
|
|
@hook.event("332")
|
|
def e332_update(info, conn=None, chan=None):
|
|
"""e332_update -- run after current topic was requested, runs worker tasks too"""
|
|
chan = info[1]
|
|
topic_update(info, conn=conn, chan=chan)
|
|
print_wiki_changes(info, conn=conn, chan=chan)
|
|
|
|
@hook.singlethread
|
|
@hook.event("353")
|
|
def e353_update(info, conn=None, chan=None):
|
|
"""e353_update -- runs after a channel (#chaoschemnitz) was joined"""
|
|
chan = info[2]
|
|
if chan.lower() == "#chaoschemnitz":
|
|
conn.send("PRIVMSG Chanserv :op #chaoschemnitz")
|
|
|
|
while True:
|
|
time.sleep(60)
|
|
conn.send("TOPIC %s" % (chan))
|
|
|