var.cache.free_and_delete(id)
var.playlist.remove_by_id(id)
else:
- if var.playlist.current_item().type == 'url':
+ if var.playlist.current_item() and var.playlist.current_item().type == 'url':
item = var.playlist.current_item().item()
bot.mumble.users[text.actor].send_text_message(util.url_ban(util.get_url_from_input(item.url)))
var.cache.free_and_delete(item.id)
self.version += 1
super().append(item)
self.pending_items.append(item)
- self.start_async_validating()
+ self.async_validate()
return item
self.current_index += 1
self.pending_items.append(item)
- self.start_async_validating()
+ self.async_validate()
return item
self.version += 1
super().extend(items)
self.pending_items.extend(items)
- self.start_async_validating()
+ self.async_validate()
return items
def next(self):
print("%d %s" % (index, item_wrapper.format_debug_string()))
print("===== End =====")
- def start_async_validating(self):
+ def async_validate(self):
if not self.validating_thread_lock.locked():
time.sleep(0.1) # Just avoid validation finishes too fast and delete songs while something is reading it.
th = threading.Thread(target=self._check_valid, name="Validating")
while len(self.pending_items) > 0:
item = self.pending_items.pop()
self.log.debug("playlist: validating %s" % item.format_debug_string())
+ ver = item.version
if not item.validate() or item.is_failed():
self.log.debug("playlist: validating failed.")
var.cache.free_and_delete(item.id)
self.remove_by_id(item.id)
+ continue
+ if item.version > ver:
+ self.version += 1
self.log.debug("playlist: validating finished.")
self.validating_thread_lock.release()
+ def async_prepare(self, index):
+ th = threading.Thread(
+ target=self._prepare, name="Prepare-" + self[index].id[:7], args=(index,))
+ self.log.info(
+ "%s: start preparing item in thread: " % self[index].item().type + self[index].format_debug_string())
+ th.daemon = True
+ th.start()
+ return th
+
+ def _prepare(self, index):
+ item = self[index]
+ ver = item.version
+ item.prepare()
+ if item.version > ver:
+ self.version += 1
+
class OneshotPlaylist(BasePlaylist):
def __init__(self):
next = var.playlist.next_item()
if next.validate():
if not next.is_ready():
- next.async_prepare()
+ var.playlist.async_prepare(var.playlist.next_index())
break
else:
var.playlist.remove_by_id(next.id)
else:
self.log.info("bot: current music isn't ready, start downloading.")
self.wait_for_downloading = True
- current.async_prepare()
+ var.playlist.async_prepare(var.playlist.current_index)
self.send_msg(constants.strings('download_in_progress', item=current.format_short_string()))
else:
var.playlist.remove_by_id(current.id)
if current:
if current.is_ready():
self.wait_for_downloading = False
+ var.playlist.version += 1
self.launch_music()
self.async_download_next()
elif current.is_failed():