X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=helpers%2Faction.py;h=4b5a71d3806275b5bf16198be985fda052f7b61f;hb=201d8411d7e1f70f13ced3fc797a696e6593f3a0;hp=1b8fc5ff53381f60fcf6bb0d0e590af3777819d0;hpb=c80ff6dc4579ab28c4064576db5a4859e639c504;p=perso%2FImmae%2FProjets%2FPython%2FMusicSampler.git diff --git a/helpers/action.py b/helpers/action.py index 1b8fc5f..4b5a71d 100644 --- a/helpers/action.py +++ b/helpers/action.py @@ -1,210 +1,113 @@ -import threading -import time +from transitions.extensions import HierarchicalMachine as Machine +from . import debug_print, error_print +from . import actions class Action: - action_types = [ - 'command', - 'pause', - 'play', - 'seek', - 'stop', - 'stop_all_actions', - 'unpause', - 'volume', - 'wait', + STATES = [ + 'initial', + 'loading', + 'failed', + { + 'name': 'loaded', + 'children': ['running'] + } + ] + + TRANSITIONS = [ + { + 'trigger': 'load', + 'source': 'initial', + 'dest': 'loading' + }, + { + 'trigger': 'fail', + 'source': 'loading', + 'dest': 'failed', + 'after': 'poll_loaded' + }, + { + 'trigger': 'success', + 'source': 'loading', + 'dest': 'loaded', + 'after': 'poll_loaded' + }, + { + 'trigger': 'run', + 'source': 'loaded', + 'dest': 'loaded_running', + 'after': 'finish_action', + # if a child has no transitions, then it is bubbled to the parent, + # and we don't want that. Not useful in that machine precisely. + 'conditions': ['is_loaded'] + }, + { + 'trigger': 'finish_action', + 'source': 'loaded_running', + 'dest': 'loaded' + } ] def __init__(self, action, key, **kwargs): - if action in self.action_types: - self.action = action - else: - raise Exception("Unknown action {}".format(action)) + Machine(model=self, states=self.STATES, + transitions=self.TRANSITIONS, initial='initial', + ignore_invalid_triggers=True, queued=True) + self.action = action self.key = key self.mapping = key.parent self.arguments = kwargs self.sleep_event = None + self.waiting_music = None + + def is_loaded_or_failed(self): + return self.is_loaded(allow_substates=True) or self.is_failed() - def ready(self): - if 'music' in self.arguments: - return self.arguments['music'].check_is_loaded() + def callback_music_loaded(self, success): + if success: + self.success() else: - return True + self.fail() + + # Machine states / events + def on_enter_loading(self): + if hasattr(actions, self.action): + if 'music' in self.arguments: + self.arguments['music'].subscribe_loaded( + self.callback_music_loaded) + else: + self.success() + else: + error_print("Unknown action {}".format(self.action)) + self.fail() - def run(self): - print(self.description()) - getattr(self, self.action)(**self.arguments) + def on_enter_loaded_running(self, key_start_time): + debug_print(self.description()) + if hasattr(actions, self.action): + getattr(actions, self.action).run(self, + key_start_time=key_start_time, **self.arguments) - def description(self): - return getattr(self, self.action + "_print")(**self.arguments) + def poll_loaded(self): + self.key.callback_action_ready(self, + self.is_loaded(allow_substates=True)) + # This one cannot be in the Machine state since it would be queued to run + # *after* the wait is ended... def interrupt(self): - if getattr(self, self.action + "_interrupt", None): - return getattr(self, self.action + "_interrupt")(**self.arguments) + if getattr(actions, self.action, None) and\ + hasattr(getattr(actions, self.action), 'interrupt'): + return getattr(getattr(actions, self.action), 'interrupt')( + self, **self.arguments) + # Helpers def music_list(self, music): if music is not None: return [music] else: return self.mapping.open_files.values() - # Actions - def command(self, command = "", **kwargs): - # FIXME: todo - pass - - def pause(self, music = None, **kwargs): - for music in self.music_list(music): - if music.is_loaded_playing(): - music.pause() - - def unpause(self, music = None, **kwargs): - for music in self.music_list(music): - if music.is_loaded_paused(): - music.unpause() - - def play(self, music = None, fade_in = 0, start_at = 0, - restart_if_running = False, volume = 100, - loop = 0, - **kwargs): - for music in self.music_list(music): - if restart_if_running: - if music.is_not_stopped(): - music.stop() - music.play(volume = volume, fade_in = fade_in, start_at = start_at, loop = loop) - else: - if not music.is_not_stopped(): - music.play(volume = volume, fade_in = fade_in, start_at = start_at, loop = loop) - - def seek(self, music = None, value = 0, delta = False, **kwargs): - for music in self.music_list(music): - music.seek(value = value, delta = delta) - - def stop(self, music = None, fade_out = 0, wait = False, **kwargs): - previous = None - for music in self.music_list(music): - if music.is_loaded_paused() or music.is_loaded_playing(): - if previous is not None: - previous.stop(fade_out = fade_out) - previous = music - - if previous is not None: - previous.stop(fade_out = fade_out, wait = wait) - - def stop_all_actions(self, **kwargs): - self.mapping.stop_all_running() - - def volume(self, music = None, value = 100, delta = False, **kwargs): - if music is not None: - music.set_volume(value, delta = delta) - else: - self.mapping.set_master_volume(value, delta = delta) - - def wait(self, duration = 0, music = None, **kwargs): - self.sleep_event = threading.Event() - - if music is not None: - music.wait_end() - - threading.Timer(duration, self.sleep_event.set).start() - self.sleep_event.wait() - - # Action messages - def command_print(self, command = "", **kwargs): - return "running command {}".format(command) - - def pause_print(self, music = None, **kwargs): - if music is not None: - return "pausing « {} »".format(music.name) - else: - return "pausing all musics" - - def unpause_print(self, music = None, **kwargs): - if music is not None: - return "unpausing « {} »".format(music.name) - else: - return "unpausing all musics" - - def play_print(self, music = None, fade_in = 0, start_at = 0, - restart_if_running = False, volume = 100, loop = 0, **kwargs): - message = "starting " - if music is not None: - message += "« {} »".format(music.name) - else: - message += "all musics" - - if start_at != 0: - message += " at {}s".format(start_at) - - if fade_in != 0: - message += " with {}s fade_in".format(fade_in) - - message += " at volume {}%".format(volume) - - if loop > 0: - message += " {} times".format(loop + 1) - elif loop < 0: - message += " in loop" - - if restart_if_running: - message += " (restarting if already running)" - - return message - - def stop_print(self, music = None, fade_out = 0, wait = False, **kwargs): - message = "stopping " - if music is not None: - message += "music « {} »".format(music.name) - else: - message += "all musics" - - if fade_out > 0: - message += " with {}s fadeout".format(fade_out) - if wait: - message += " (waiting the end of fadeout)" - - return message - - def stop_all_actions_print(self, **kwargs): - return "stopping all actions" - - def seek_print(self, music = None, value = 0, delta = False, **kwargs): - if delta: - if music is not None: - return "moving music « {} » by {:+d}s".format(music.name, value) - else: - return "moving all musics by {:+d}s".format(value) - else: - if music is not None: - return "moving music « {} » to position {}s".format(music.name, value) - else: - return "moving all musics to position {}s".format(value) - - def volume_print(self, music = None, value = 100, delta = False, **kwargs): - if delta: - if music is not None: - return "{:+d}% to volume of « {} »".format(value, music.name) - else: - return "{:+d}% to volume".format(value) - else: - if music is not None: - return "setting volume of « {} » to {}%".format(music.name, value) - else: - return "setting volume to {}%".format(value) - - def wait_print(self, duration = 0, music = None, **kwargs): - if music is None: - return "waiting {}s".format(duration) - elif duration == 0: - return "waiting the end of « {} »".format(music.name) + def description(self): + if hasattr(actions, self.action): + return getattr(actions, self.action)\ + .description(self, **self.arguments) else: - return "waiting the end of « {} » + {}s".format(music.name, duration) - - - # Interruptions - def wait_interrupt(self, duration = 0, music = None, **kwargs): - if self.sleep_event is not None: - self.sleep_event.set() - if music is not None: - music.wait_event.set() - + return "unknown action {}".format(self.action)