import threading
import time
import os
from src.backend.PluginManager.ActionBase import ActionBase
from src.backend.PluginManager.EventAssigner import EventAssigner
from src.backend.DeckManagement.InputIdentifier import Input

class VolumeRepeatAction(ActionBase):
    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)
        self.repeating = False
        self.repeat_thread = None

    def on_ready(self):
        # Register hold events
        self.add_event_assigner(EventAssigner(
            id="volume_hold_start",
            ui_label="Volume Hold Start",
            default_events=[Input.Key.Events.HOLD_START],
            callback=self.start_repeat
        ))
        self.add_event_assigner(EventAssigner(
            id="volume_hold_stop",
            ui_label="Volume Hold Stop",
            default_events=[Input.Key.Events.HOLD_STOP],
            callback=self.stop_repeat
        ))

    def start_repeat(self, data):
        self.repeating = True
        self.repeat_thread = threading.Thread(target=self._repeat_volume)
        self.repeat_thread.daemon = True
        self.repeat_thread.start()

    def _repeat_volume(self):
        while self.repeating:
            # For volume up - change to -5% for volume down
            os.system("pactl set-sink-volume @DEFAULT_SINK@ +5%")
            time.sleep(0.1)  # 100ms repeat rate

    def stop_repeat(self, data):
        self.repeating = False