X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=helpers%2Faction.py;h=ec8fcb6f0b43748873eb2e8568589c62cfd36f58;hb=205861936ca55357beea6a8af7c0c9ed5a61f484;hp=8a69fae3a967f4dd020f7d037e89415a7de072e3;hpb=0e5d59f77586134da457ed7a3c57fc99649be590;p=perso%2FImmae%2FProjets%2FPython%2FMusicSampler.git

diff --git a/helpers/action.py b/helpers/action.py
index 8a69fae..ec8fcb6 100644
--- a/helpers/action.py
+++ b/helpers/action.py
@@ -1,13 +1,18 @@
-import pygame
+import threading
 import time
 
+from . import debug_print
+
 class Action:
     action_types = [
         'command',
+        'interrupt_wait',
         'pause',
         'play',
+        'seek',
         'stop',
         'stop_all_actions',
+        'unpause',
         'volume',
         'wait',
     ]
@@ -19,79 +24,138 @@ class Action:
             raise Exception("Unknown action {}".format(action))
 
         self.key = key
+        self.mapping = key.parent
         self.arguments = kwargs
+        self.sleep_event = None
 
     def ready(self):
         if 'music' in self.arguments:
-            return self.arguments['music'].loaded
+            return self.arguments['music'].is_loaded(allow_substates=True)
         else:
             return True
 
     def run(self):
-        print(getattr(self, self.action + "_print")(**self.arguments))
-        return getattr(self, self.action)(**self.arguments)
+        debug_print(self.description())
+        getattr(self, self.action)(**self.arguments)
 
-    def command(self, command = "", **kwargs):
-        pass
+    def description(self):
+        return getattr(self, self.action + "_print")(**self.arguments)
+
+    def interrupt(self):
+        if getattr(self, self.action + "_interrupt", None):
+            return getattr(self, self.action + "_interrupt")(**self.arguments)
 
-    def pause(self, music = None, **kwargs):
+    def music_list(self, music):
         if music is not None:
-            music.pause()
+            return [music]
         else:
-            pygame.mixer.pause()
+            return self.mapping.open_files.values()
 
-    def play(self, music = None, fade_in = 0, start_at = 0,
-            restart_if_running = False, volume = 100, **kwargs):
-        if music is not None:
+    # 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_playing():
+                if music.is_in_use():
                     music.stop()
-                music.play(volume = volume, fade_in = fade_in, start_at = start_at)
-            else:
-                if not music.is_playing():
-                    music.play(volume = volume, fade_in = fade_in, start_at = start_at)
-        else:
-            pygame.mixer.unpause()
+                music.play(
+                        volume=volume,
+                        fade_in=fade_in,
+                        start_at=start_at,
+                        loop=loop)
+            elif not music.is_in_use():
+                music.play(
+                        volume=volume,
+                        fade_in=fade_in,
+                        start_at=start_at,
+                        loop=loop)
 
-    def stop(self, music = None, fade_out = 0, **kwargs):
-        if music is not None:
-            music.stop(fade_out = fade_out)
-        else:
-            if fade_out > 0:
-                pygame.fadeout(fade_out * 1000)
+    def seek(self, music=None, value=0, delta=False, **kwargs):
+        for music in self.music_list(music):
+            music.seek(value=value, delta=delta)
+
+    def interrupt_wait(self, wait_id=None):
+        self.mapping.interrupt_wait(wait_id)
+
+    def stop(self, music=None, fade_out=0, wait=False,
+            set_wait_id=None, **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
             else:
-                pygame.mixer.stop()
+                music.stop(fade_out=fade_out)
+
+        if previous is not None:
+            previous.stop(
+                    fade_out=fade_out,
+                    wait=wait,
+                    set_wait_id=set_wait_id)
 
     def stop_all_actions(self, **kwargs):
-        self.key.mapping.stop_all_running()
+        self.mapping.stop_all_running()
 
-    def volume(self, music = None, value = 100, **kwargs):
+    def volume(self, music=None, value=100, fade=0, delta=False, **kwargs):
         if music is not None:
-            music.set_volume(value)
+            music.set_volume(value, delta=delta, fade=fade)
         else:
-            pass
+            self.mapping.set_master_volume(value, delta=delta, fade=fade)
 
-    def wait(self, duration = 0, **kwargs):
-        # FIXME: Make it stoppable
-        # http://stackoverflow.com/questions/29082268/python-time-sleep-vs-event-wait
-        time.sleep(duration)
+    def wait(self, duration=0, music=None, set_wait_id=None, **kwargs):
+        if set_wait_id is not None:
+            self.mapping.add_wait_id(set_wait_id, self)
+
+        self.sleep_event = threading.Event()
+
+        if music is not None:
+            music.wait_end()
 
-    def command_print(self, command = "", **kwargs):
+        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):
+    def interrupt_wait_print(self, wait_id=None, **kwargs):
+        return "interrupt wait with id {}".format(wait_id)
+
+    def pause_print(self, music=None, **kwargs):
         if music is not None:
-            return "pausing {}".format(music.filename)
+            return "pausing « {} »".format(music.name)
         else:
             return "pausing all musics"
 
-    def play_print(self, music = None, fade_in = 0, start_at = 0,
-            restart_if_running = False, volume = 100, **kwargs):
+    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 += music.filename
+            message += "« {} »".format(music.name)
         else:
-            message += "music"
+            message += "all musics"
 
         if start_at != 0:
             message += " at {}s".format(start_at)
@@ -101,33 +165,99 @@ class Action:
 
         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, **kwargs):
+    def stop_print(self, music=None, fade_out=0, wait=False,
+            set_wait_id=None, **kwargs):
+
+        message = "stopping "
         if music is not None:
-            if fade_out == 0:
-                return "stopping music {}".format(music.filename)
-            else:
-                return "stopping music {} with {}s fadeout".format(music.filename, fade_out)
+            message += "music « {} »".format(music.name)
         else:
-            if fade_out == 0:
-                return "stopping all musics"
-            else:
-                return "stopping all musics with {}s fadeout".format(fade_out)
+            message += "all musics"
+
+        if fade_out > 0:
+            message += " with {}s fadeout".format(fade_out)
+            if wait:
+                if set_wait_id is not None:
+                    message += " (waiting the end of fadeout, with id {})"\
+                            .format(set_wait_id)
+                else:
+                    message += " (waiting the end of fadeout)"
+
+        return message
 
     def stop_all_actions_print(self, **kwargs):
         return "stopping all actions"
 
-    def volume_print(self, music = None, value = 100, **kwargs):
-        if music is not None:
-            return "setting volume of {} to {}%".format(music.filename, value)
+    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, fade=0, **kwargs):
+        message = ""
+        if delta:
+            if music is not None:
+                message += "{:+d}% to volume of « {} »" \
+                        .format(value, music.name)
+            else:
+                message += "{:+d}% to volume" \
+                        .format(value)
         else:
-            return "setting volume to {}%".format(value)
+            if music is not None:
+                message += "setting volume of « {} » to {}%" \
+                        .format(music.name, value)
+            else:
+                message += "setting volume to {}%" \
+                        .format(value)
 
-    def wait_print(self, duration, **kwargs):
-        return "waiting {}s".format(duration)
+        if fade > 0:
+            message += " with {}s fade".format(fade)
 
+        return message
+
+    def wait_print(self, duration=0, music=None, set_wait_id=None, **kwargs):
+        message = ""
+        if music is None:
+            message += "waiting {}s" \
+                    .format(duration)
+        elif duration == 0:
+            message += "waiting the end of « {} »" \
+                    .format(music.name)
+        else:
+            message += "waiting the end of « {} » + {}s" \
+                    .format(music.name, duration)
+
+        if set_wait_id is not None:
+            message += " (setting id = {})".format(set_wait_id)
+
+        return message
+
+    # 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()