summaryrefslogtreecommitdiffstats
path: root/god/streams/streams.py
diff options
context:
space:
mode:
authormakefu <github@syntax-fehler.de>2012-12-20 10:57:19 +0700
committermakefu <github@syntax-fehler.de>2012-12-20 10:57:19 +0700
commit5a3126a9036b898de095776ebe18fe55f6312342 (patch)
tree8b85a49c689b2b67b6b4a3b7dbe4364fb3612529 /god/streams/streams.py
parent21bb561b81d6c395ce0b004ce3b70a02c00360ef (diff)
streams.py is the new streams
the old source code was just too ugly
Diffstat (limited to 'god/streams/streams.py')
-rw-r--r--god/streams/streams.py116
1 files changed, 0 insertions, 116 deletions
diff --git a/god/streams/streams.py b/god/streams/streams.py
deleted file mode 100644
index 65669b2d..00000000
--- a/god/streams/streams.py
+++ /dev/null
@@ -1,116 +0,0 @@
-#!/usr/bin/python
-import os
-import sys
-from subprocess import Popen, PIPE
-
-os.chdir(os.path.dirname(os.path.realpath(sys.argv[0])))
-pidfile = "/tmp/krebs.stream.pid"
-url_file = os.environ.get("STREAM_DB", "stream.db")
-urls = []
-#urls = [ url,f for (url,f) in open(url_file).readline() ]
-for line in open(url_file):
- urls.append(line.split())
-#print urls
-mybin = sys.argv[0]
-cmd = sys.argv[1] if len(sys.argv) > 1 else "you-are-made-of-stupid"
-stream = sys.argv[2] if len(sys.argv) == 3 else "groove"
-
-
-def check_pid(pid):
- """ Check For the existence of a unix pid. """
- try:
- os.kill(pid, 0)
- except OSError:
- return False
- else:
- return True
-
-
-def urlForStream(stream):
- for url, s in urls:
- if s == stream:
- return url
-
-
-def start(stream):
- ret = running()
- if ret:
- print "!! Stream `%s` already running with pid `%s` !" % \
- (ret[1], ret[0])
- else:
- pipe_silent = open('/dev/null', 'w')
- url = urlForStream(stream)
- mpl = Popen(["mplayer", url],
- stdout=pipe_silent, stderr=pipe_silent).pid
- print >> open(pidfile, "w+"), "%d %s" % (mpl, stream)
-
-
-def stop():
- ret = running()
- if not ret:
- print "!! No Stream running!"
- else:
- pid, name = ret
- print "** Killing `%s` with pid %s" % (name, pid)
- os.kill(int(pid), 15)
- #if check_pid(int(pid)):
- # print "!! trying harder to kill process"
- # os.kill(int(pid), 9)
- os.remove(pidfile)
-
-
-def running():
- try:
- pid, currstream = open(pidfile).read().split()
- if check_pid(int(pid)):
- return (pid, currstream)
- else:
- print "!! removing stale pidfile"
- os.remove(pidfile)
- raise Exception("Pidfile stale")
- except Exception as e:
- return ()
-
-
-def slist():
- for url, name in urls:
- print "%s : %s" % (name, url)
-
-
-def shorthelp():
- print "start|stop|restart|status|list [audio stream]"
-
-
-def longhelp():
- print "Usage: %s" % mybin,
- shorthelp
- print """ get all available streams with '/%(fil)s list'
- Examples:
- %(fil)s list
- %(fil)s start groove
- %(fil)s switch deepmix
- %(fil)s status
- %(fil)s stop""" % {'fil': mybin}
-
-if cmd == "start":
- start(stream)
-elif cmd == "stop":
- stop()
-elif cmd == "switch" or cmd == "restart":
- stop()
- start(stream)
-elif cmd == "status":
- ret = running()
- if not ret:
- print "** no stream running" # , e
- else:
- print "%s is running(%s)" % (ret[1], urlForStream(ret[1]))
-elif cmd == "list":
- slist()
-elif cmd == "--help":
- longhelp()
-elif cmd == "-h":
- shorthelp()
-else:
- print "unknown command `%s`" % cmd
- print "try `%s` --help" % os.path.basename(mybin)