# Python MPD client library
-# Copyright (C) 2008 J. Alexander Treuman <jat@spatialrift.net>
+# Copyright (C) 2008-2010 J. Alexander Treuman <jat@spatialrift.net>
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
class PendingCommandError(MPDError):
pass
+class IteratingError(MPDError):
+ pass
+
class _NotConnected(object):
def __getattr__(self, attr):
if self._command_list is not None:
raise CommandListError("Cannot use fetch_%s in a command list" %
command)
+ if self._iterating:
+ raise IteratingError("Cannot use fetch_%s while iterating" %
+ command)
if not self._pending:
raise PendingCommandError("No pending commands to fetch")
if self._pending[0] != command:
return retval()
def _execute(self, command, args):
+ if self._iterating:
+ raise IteratingError("Cannot execute %s while iterating" % command)
if self._pending:
raise PendingCommandError("Cannot execute %s with "
"pending commands" % command)
while pair:
yield pair
pair = self._read_pair(separator)
- raise StopIteration
def _read_list(self):
seen = None
(seen, key))
seen = key
yield value
- raise StopIteration
def _read_playlist(self):
for key, value in self._read_pairs(":"):
yield value
- raise StopIteration
def _read_objects(self, delimiters=[]):
obj = {}
obj[key] = value
if obj:
yield obj
- raise StopIteration
def _read_command_list(self):
- for retval in self._command_list:
- yield retval()
- self._command_list = None
+ try:
+ for retval in self._command_list:
+ yield retval()
+ finally:
+ self._command_list = None
self._fetch_nothing()
- raise StopIteration
+
+ def _iterator_wrapper(self, iterator):
+ try:
+ for item in iterator:
+ yield item
+ finally:
+ self._iterating = False
def _wrap_iterator(self, iterator):
if not self.iterate:
return list(iterator)
- return iterator
+ self._iterating = True
+ return self._iterator_wrapper(iterator)
def _fetch_nothing(self):
line = self._read_line()
def _reset(self):
self.mpd_version = None
+ self._iterating = False
self._pending = []
self._command_list = None
self._sock = None
self._sock.close()
self._reset()
+ def fileno(self):
+ if not self._sock:
+ raise ConnectionError("Not connected")
+ return self._sock.fileno()
+
def command_list_ok_begin(self):
if self._command_list is not None:
raise CommandListError("Already in command list")
+ if self._iterating:
+ raise IteratingError("Cannot begin command list while iterating")
if self._pending:
raise PendingCommandError("Cannot begin command list "
"with pending commands")
def command_list_end(self):
if self._command_list is None:
raise CommandListError("Not in command list")
+ if self._iterating:
+ raise IteratingError("Already iterating over a command list")
self._write_command("command_list_end")
return self._fetch_command_list()