summaryrefslogtreecommitdiff
path: root/plugins
diff options
context:
space:
mode:
authormathieui <mathieui@mathieui.net>2013-03-31 18:30:18 +0200
committermathieui <mathieui@mathieui.net>2013-03-31 18:30:18 +0200
commit1797043464b2f1b5f0974edd489bc6aceb1bf95c (patch)
tree3a5ce5a24e4f75a5c4673bada07121b839495d4b /plugins
parente8fae6f24cf783de7f17f85084d53a55d14e9f89 (diff)
downloadpoezio-1797043464b2f1b5f0974edd489bc6aceb1bf95c.tar.gz
poezio-1797043464b2f1b5f0974edd489bc6aceb1bf95c.tar.bz2
poezio-1797043464b2f1b5f0974edd489bc6aceb1bf95c.tar.xz
poezio-1797043464b2f1b5f0974edd489bc6aceb1bf95c.zip
Remove the thread from the mpd_client
(it should be in an external tool, not _inside_ poezio)
Diffstat (limited to 'plugins')
-rw-r--r--plugins/mpd_client.py57
1 files changed, 0 insertions, 57 deletions
diff --git a/plugins/mpd_client.py b/plugins/mpd_client.py
index 52bd1c17..09a2e5d2 100644
--- a/plugins/mpd_client.py
+++ b/plugins/mpd_client.py
@@ -5,54 +5,6 @@ from common import shell_split
from os.path import basename as base
import tabs
import mpd
-import threading
-from select import select
-from time import sleep
-
-class UpdateThread(threading.Thread):
- """
- Background thread that awaits mpd changes
- """
-
- def __init__(self, plugin, xmpp):
- threading.Thread.__init__(self)
- self.plugin = plugin
- self.xmpp = xmpp
- self.alive = False
- self.c = mpd.MPDClient()
-
- def run(self, *args, **kwargs):
- self.alive = True
- current = None
- while self.alive:
- try:
- self.c.connect(host=self.plugin.config.get('host', 'localhost'), port=self.plugin.config.get('port', '6600'))
- password = self.plugin.config.get('password', '')
- if password:
- self.c.password(password)
- self.c.send_idle()
- select([self.c], [], [], timeout=600)
- self.c.fetch_idle()
- status = self.c.status()
- if status['state'] == 'play' and self.alive:
- song = self.c.currentsong()
- if current != song:
- self.xmpp.plugin['xep_0118'].publish_tune(artist=song.get('artist'),
- length=song.get('time'), title=song.get('title'),
- track=song.get('track'), block=False)
- current = song
- elif status['state'] != 'play':
- self.xmpp.plugin['xep_0118'].stop(block=False)
- current = None
- self.c.disconnect()
- except:
- pass
- finally:
- try:
- self.c.disconnect()
- except:
- pass
- sleep(8)
class Plugin(BasePlugin):
def init(self):
@@ -62,15 +14,6 @@ class Plugin(BasePlugin):
help='Sends a message showing the current song of an MPD instance. If full is provided, the message is more verbose.',
short='Send the MPD status',
completion=self.completion_mpd)
- if self.config.get('broadcast', 'true').lower() != 'false':
- self.core.xmpp.register_plugin('xep_0118')
- self.thread = UpdateThread(plugin=self, xmpp=self.core.xmpp)
- self.thread.start()
-
- def cleanup(self):
- self.thread.alive = False
- self.thread.c.disconnect()
- self.core.xmpp.plugin['xep_0118'].stop(block=False)
def command_mpd(self, args):
args = shell_split(args)