import os import datetime from PyQt6.QtWidgets import ( QWidget, QVBoxLayout, QHBoxLayout, QLabel, QLineEdit, QPushButton, QFrame, QSlider, QTextEdit, QApplication, QToolTip ) from PyQt6.QtCore import Qt, pyqtSignal, QTimer from PyQt6.QtGui import QIcon import uuid from vlc_player import VLCSyncPlayer class ClickableSlider(QSlider): def __init__(self, *args, **kwargs): super().__init__(*args, **kwargs) self._get_tooltip_text = None def set_tooltip_provider(self, provider_func): self._get_tooltip_text = provider_func def mousePressEvent(self, event): super().mousePressEvent(event) if event.button() == Qt.MouseButton.LeftButton: val = 0 if self.orientation() == Qt.Orientation.Horizontal: if self.width() > 0: val = self.minimum() + ((self.maximum() - self.minimum()) * event.pos().x()) / self.width() else: if self.height() > 0: val = self.minimum() + ((self.maximum() - self.minimum()) * (self.height() - event.pos().y())) / self.height() val = max(self.minimum(), min(self.maximum(), int(val))) self.setValue(val) self.sliderMoved.emit(val) if self._get_tooltip_text: text = self._get_tooltip_text(val) if text: QToolTip.showText(event.globalPosition().toPoint(), text, self) def mouseMoveEvent(self, event): super().mouseMoveEvent(event) if event.buttons() & Qt.MouseButton.LeftButton: if self._get_tooltip_text: text = self._get_tooltip_text(self.value()) if text: QToolTip.showText(event.globalPosition().toPoint(), text, self) def mouseReleaseEvent(self, event): super().mouseReleaseEvent(event) if event.button() == Qt.MouseButton.LeftButton: # Explicitly emit sliderReleased on mouse release # to ensure single clicks on the track also trigger the release logic self.sliderReleased.emit() class ExpectedVlcEvent: def __init__(self, action: str, req_id: str, target_val=None): self.action = action self.req_id = req_id self.target_val = target_val self.timestamp = datetime.datetime.now() class RoomWidget(QWidget): leave_requested = pyqtSignal() sync_action_requested = pyqtSignal(str, float, str) # action, position_s, req_id chat_message_ready = pyqtSignal(str) # raw message text def __init__(self): super().__init__() self.username = "" self.room_code = "" self.expected_vlc_events = [] self.last_reported_time_ms = 0 self.current_users = [] self._is_first_user_update = True self._setup_ui() def _setup_ui(self): layout = QHBoxLayout(self) layout.setContentsMargins(0, 0, 0, 0) layout.setSpacing(0) # --- Left Side: Video --- video_container = QWidget() video_layout = QVBoxLayout(video_container) video_layout.setContentsMargins(0, 0, 0, 0) video_layout.setSpacing(0) # Topbar self.topbar = QFrame() self.topbar.setObjectName("topbar") self.topbar.setFixedHeight(50) topbar_layout = QHBoxLayout(self.topbar) self.room_code_display = QLabel("Room: XXXX") self.copy_code_btn = QPushButton() self.copy_code_btn.setObjectName("iconBtn") self.copy_icon = QIcon(os.path.join(os.path.dirname(__file__), "copy.svg")) self.check_icon = QIcon(os.path.join(os.path.dirname(__file__), "check.svg")) self.copy_code_btn.setIcon(self.copy_icon) self.copy_code_btn.setFixedSize(30, 30) self.copy_code_btn.setToolTip("Copy Room Code") self.copy_code_btn.clicked.connect(self.copy_room_code) self.room_file_badge = QLabel("📄 No file") self.room_file_badge.setObjectName("fileBadge") self.leave_btn = QPushButton("Leave Room") self.leave_btn.setObjectName("dangerBtn") self.leave_btn.clicked.connect(self.leave_requested.emit) topbar_layout.addWidget(self.room_code_display) topbar_layout.addWidget(self.copy_code_btn) topbar_layout.addStretch() topbar_layout.addWidget(self.room_file_badge) topbar_layout.addWidget(self.leave_btn) # Video Frame Placeholder self.video_frame = QFrame() self.video_frame.setStyleSheet("background-color: black;") self.video_frame.setAttribute(Qt.WidgetAttribute.WA_NativeWindow, True) # Controls Bar controls = QFrame() controls.setObjectName("controlsBar") controls.setFixedHeight(60) controls_layout = QHBoxLayout(controls) self.play_btn = QPushButton("▶") self.play_btn.setFixedSize(40, 40) self.play_btn.setObjectName("playBtn") # Time and SeekBar self.seekbar = ClickableSlider(Qt.Orientation.Horizontal) self.seekbar.setRange(0, 1000) self.seekbar.setObjectName("seekBar") self.seekbar.sliderMoved.connect(self.on_seekbar_dragged) self.seekbar.sliderReleased.connect(self.on_seekbar_released) self.seekbar.set_tooltip_provider(self.get_seekbar_tooltip) self.time_lbl = QLabel("00:00:00 / 00:00:00") # Volume self.vol_icon = QLabel("🔊") self.vol_icon.setObjectName("volIcon") self.volume_slider = ClickableSlider(Qt.Orientation.Horizontal) self.volume_slider.setRange(0, 100) self.volume_slider.setValue(100) self.volume_slider.setFixedWidth(100) self.volume_slider.setObjectName("volumeSlider") self.volume_slider.valueChanged.connect(self.on_volume_changed) self.volume_slider.set_tooltip_provider(lambda v: f"{v}%") # Fullscreen self.fullscreen_btn = QPushButton("⛶") self.fullscreen_btn.setFixedSize(40, 40) self.fullscreen_btn.setObjectName("iconBtn") self.fullscreen_btn.clicked.connect(self.toggle_fullscreen) controls_layout.addWidget(self.play_btn) controls_layout.addWidget(self.seekbar, 1) controls_layout.addWidget(self.time_lbl) controls_layout.addSpacing(15) controls_layout.addWidget(self.vol_icon) controls_layout.addWidget(self.volume_slider) controls_layout.addSpacing(10) controls_layout.addWidget(self.fullscreen_btn) video_layout.addWidget(self.topbar) video_layout.addWidget(self.video_frame) video_layout.addWidget(controls) # --- Right Side: Chat --- self.chat_container = QFrame() self.chat_container.setObjectName("chatContainer") self.chat_container.setFixedWidth(320) chat_layout = QVBoxLayout(self.chat_container) chat_header = QLabel("Live Chat") chat_header.setObjectName("chatHeader") self.users_lbl = QLabel("0 watching") self.users_lbl.setObjectName("usersLbl") self.chat_messages = QTextEdit() self.chat_messages.setObjectName("chatMessages") self.chat_messages.setReadOnly(True) self.chat_messages.setHtml("Welcome to the room! 👋") chat_input_layout = QHBoxLayout() self.chat_input = QLineEdit() self.chat_input.setPlaceholderText("Send a message...") self.chat_send_btn = QPushButton("Send") chat_input_layout.addWidget(self.chat_input) chat_input_layout.addWidget(self.chat_send_btn) # Chat actions self.chat_send_btn.clicked.connect(self.send_chat) self.chat_input.returnPressed.connect(self.send_chat) chat_layout.addWidget(chat_header) chat_layout.addWidget(self.users_lbl) chat_layout.addWidget(self.chat_messages, 1) chat_layout.addLayout(chat_input_layout) layout.addWidget(video_container, 1) layout.addWidget(self.chat_container) # Instantiate the VLC Player Wrapper self.vlc_player = VLCSyncPlayer(self.video_frame) self.vlc_player.signals.time_changed.connect(self.on_vlc_time) self.vlc_player.signals.state_changed.connect(self.on_vlc_state) self.vlc_player.set_volume(self.volume_slider.value()) self.play_btn.clicked.connect(self.toggle_playback) def get_seekbar_tooltip(self, value): length_ms = self.vlc_player.get_length() if length_ms > 0: target_ms = int((value / 1000.0) * length_ms) s = max(0, target_ms) // 1000 return f"{s//3600:02d}:{(s%3600)//60:02d}:{s%60:02d}" return "" def setup_room(self, room_code: str, username: str, file_name: str, file_path: str, start_time_s: float = 0.0): self.room_code = room_code self.username = username self.set_room_code_display(room_code) self.room_file_badge.setText(f"📄 {file_name}") self.chat_messages.setHtml("Welcome to the room! 👋") self.current_users = [] self._is_first_user_update = True if file_path: self.vlc_player.load_media(file_path, start_time_s) self.vlc_player.set_volume(self.volume_slider.value()) def cleanup(self): self.vlc_player.stop() self.current_users = [] self._is_first_user_update = True def set_room_code_display(self, text: str): self.room_code_display.setText(f"Room: {text}") def toggle_fullscreen(self): top_window = self.window() if top_window.isFullScreen(): top_window.showNormal() self.fullscreen_btn.setText("⛶") self.chat_container.show() self.topbar.show() else: top_window.showFullScreen() self.fullscreen_btn.setText("🗗") self.chat_container.hide() self.topbar.hide() def copy_room_code(self): if self.room_code: QApplication.clipboard().setText(self.room_code) self.copy_code_btn.setIcon(self.check_icon) toast = QLabel("Copied!", self) toast.setStyleSheet("background-color: #4BB543; color: white; padding: 4px 8px; border-radius: 4px; font-weight: bold;") toast.setWindowFlags(Qt.WindowType.ToolTip | Qt.WindowType.FramelessWindowHint) pos = self.copy_code_btn.mapToGlobal(self.copy_code_btn.rect().bottomLeft()) toast.move(pos.x(), pos.y() + 5) toast.show() def reset(): self.copy_code_btn.setIcon(self.copy_icon) toast.deleteLater() QTimer.singleShot(1500, reset) def _tell_vlc_and_expect(self, action: str, position_s: float): req_id = str(uuid.uuid4())[:8] target_ms = int(position_s * 1000) # Clean up old expectations (e.g. VLC dropped the event or we missed it) now = datetime.datetime.now() self.expected_vlc_events = [e for e in self.expected_vlc_events if (now - e.timestamp).total_seconds() < 3.0] self.expected_vlc_events.append(ExpectedVlcEvent(action, req_id, target_ms)) if action == "play": self.vlc_player.seek(target_ms) self.vlc_player.play() self.play_btn.setText("⏸") elif action == "pause": self.vlc_player.seek(target_ms) self.vlc_player.pause() self.play_btn.setText("▶") elif action == "seek": self.vlc_player.seek(target_ms) return req_id def toggle_playback(self): position_s = self.vlc_player.current_time_ms / 1000.0 if self.vlc_player.is_playing: req = self._tell_vlc_and_expect("pause", position_s) self.sync_action_requested.emit("pause", position_s, req) else: req = self._tell_vlc_and_expect("play", position_s) self.sync_action_requested.emit("play", position_s, req) def on_vlc_time(self, time_ms: int): length_ms = self.vlc_player.get_length() if length_ms > 0: def fmt(ms): s = max(0, ms) // 1000 return f"{s//3600:02d}:{(s%3600)//60:02d}:{s%60:02d}" if not self.seekbar.isSliderDown(): self.time_lbl.setText(f"{fmt(time_ms)} / {fmt(length_ms)}") progress = int((time_ms / length_ms) * 1000) self.seekbar.blockSignals(True) self.seekbar.setValue(progress) self.seekbar.blockSignals(False) if self.last_reported_time_ms is not None: diff = abs(time_ms - self.last_reported_time_ms) if diff > 1500: # Look for a pending seek expectation matched = False for i, expected in enumerate(self.expected_vlc_events): if expected.action == "seek" and (expected.target_val is None or abs(expected.target_val - time_ms) < 2000): matched = True self.expected_vlc_events.pop(i) break if not matched: # Genuine user scrub! req = str(uuid.uuid4())[:8] self.sync_action_requested.emit("seek", time_ms / 1000.0, req) self.last_reported_time_ms = time_ms def on_vlc_state(self, playing: bool, time_ms: int): action = "play" if playing else "pause" # Look for a pending state change expectation matched = False for i, expected in enumerate(self.expected_vlc_events): if expected.action == action: matched = True self.expected_vlc_events.pop(i) break if not matched: req = str(uuid.uuid4())[:8] self.sync_action_requested.emit(action, time_ms / 1000.0, req) def on_seekbar_dragged(self, value): length_ms = self.vlc_player.get_length() if length_ms > 0: target_ms = int((value / 1000.0) * length_ms) def fmt(ms): s = max(0, ms) // 1000 return f"{s//3600:02d}:{(s%3600)//60:02d}:{s%60:02d}" self.time_lbl.setText(f"{fmt(target_ms)} / {fmt(length_ms)}") # Scrub the video locally in real-time self._tell_vlc_and_expect("seek", target_ms / 1000.0) def on_seekbar_released(self): length_ms = self.vlc_player.get_length() if length_ms > 0: target_ms = int((self.seekbar.value() / 1000.0) * length_ms) req = self._tell_vlc_and_expect("seek", target_ms / 1000.0) self.sync_action_requested.emit("seek", target_ms / 1000.0, req) def on_volume_changed(self, value): self.vlc_player.set_volume(value) # --- Incoming Sync Logic --- def handle_sync_event(self, msg: dict): action = msg.get("action") if not action: if msg.get("playing", False): action = "play" elif msg.get("playing") is False: action = "pause" position_s = msg.get("position", 0) if action in ["play", "pause", "seek"]: self._tell_vlc_and_expect(action, position_s) username = msg.get("username") if username and username != self.username: if action == "play": self.add_system_message(f"{username} pressed play") elif action == "pause": self.add_system_message(f"{username} paused") elif action == "seek": def fmt(s): return f"{int(s)//3600:02d}:{(int(s)%3600)//60:02d}:{int(s)%60:02d}" self.add_system_message(f"{username} seeked to {fmt(position_s)}") def update_users(self, users: list): if self._is_first_user_update: self._is_first_user_update = False else: joined = set(users) - set(self.current_users) left = set(self.current_users) - set(users) for user in joined: if user != self.username: self.add_system_message(f"👋 {user} joined the room") for user in left: if user != self.username: self.add_system_message(f"🚪 {user} left the room") self.current_users = users self.users_lbl.setText(f"{len(users)} watching: {', '.join(users)}") def add_chat_message(self, author: str, text: str, timestamp: int): try: dt = datetime.datetime.fromtimestamp(timestamp / 1000.0) except (ValueError, OSError, TypeError): dt = datetime.datetime.now() time_str = dt.strftime("%I:%M %p") new_msg = f"{author}: {text} {time_str}" self.chat_messages.append(new_msg) def add_system_message(self, text: str): new_msg = f"{text}" self.chat_messages.append(new_msg) def send_chat(self): text = self.chat_input.text().strip() if not text: return if text.startswith("/"): parts = text.split() cmd = parts[0].lower() if cmd == "/play": self.chat_input.setText("") if not self.vlc_player.is_playing: self.toggle_playback() self.add_system_message(text) return elif cmd == "/pause": self.chat_input.setText("") if self.vlc_player.is_playing: self.toggle_playback() self.add_system_message(text) return elif cmd == "/seek": self.chat_input.setText("") if len(parts) > 1: if self._handle_seek_command(parts[1]): self.add_system_message(text) else: self.add_system_message("Invalid time format. Use: 1:23, +30s, -1m") else: self.add_system_message("Usage: /seek [time]") return elif cmd == "/help": self.chat_input.setText("") self.add_system_message("Available commands:
/play - Resume playback
/pause - Pause playback
/seek [time] - Seek to specific time (e.g., 1:23) or offset (e.g., +30s, -1m)
/help - Show this message") return self.chat_message_ready.emit(text) self.chat_input.setText("") def _handle_seek_command(self, arg: str) -> bool: current_ms = self.vlc_player.current_time_ms length_ms = self.vlc_player.get_length() if length_ms <= 0: return False try: target_ms = 0 if arg.startswith('+') or arg.startswith('-'): modifier = 1 if arg.startswith('+') else -1 num_str = arg[1:] if num_str.endswith('s'): val = float(num_str[:-1]) * 1000 elif num_str.endswith('m'): val = float(num_str[:-1]) * 60 * 1000 elif num_str.endswith('h'): val = float(num_str[:-1]) * 3600 * 1000 else: val = float(num_str) * 1000 target_ms = current_ms + (val * modifier) elif ":" in arg: parts = arg.split(":") parts.reverse() if len(parts) > 0: target_ms += float(parts[0]) * 1000 if len(parts) > 1: target_ms += float(parts[1]) * 60 * 1000 if len(parts) > 2: target_ms += float(parts[2]) * 3600 * 1000 else: if arg.endswith('s'): target_ms = float(arg[:-1]) * 1000 elif arg.endswith('m'): target_ms = float(arg[:-1]) * 60 * 1000 elif arg.endswith('h'): target_ms = float(arg[:-1]) * 3600 * 1000 else: target_ms = float(arg) * 1000 target_ms = max(0, min(target_ms, length_ms)) req = self._tell_vlc_and_expect("seek", target_ms / 1000.0) self.sync_action_requested.emit("seek", target_ms / 1000.0, req) return True except ValueError: return False