{/* Copy Link Option */}
-
+ {isProxied ? (
+ <>
+
+
+
+ ) : (
+
+ )}
diff --git a/components/player/mobile/controls/RightControls.tsx b/components/player/mobile/controls/RightControls.tsx
index 382c75c..29abee4 100644
--- a/components/player/mobile/controls/RightControls.tsx
+++ b/components/player/mobile/controls/RightControls.tsx
@@ -11,10 +11,11 @@ interface RightControlsProps {
speeds: number[];
onSpeedChange: (speed: number) => void;
isPiPSupported: boolean;
+ isProxied?: boolean;
onTogglePiP: () => void;
onToggleMoreMenu: () => void;
onToggleVolumeMenu: () => void;
- onCopyLink: () => void;
+ onCopyLink: (type?: 'original' | 'proxy') => void;
isMuted: boolean;
volume: number;
isFullscreen: boolean;
@@ -33,6 +34,7 @@ export function RightControls({
speeds,
onSpeedChange,
isPiPSupported,
+ isProxied,
onTogglePiP,
onToggleMoreMenu,
onToggleVolumeMenu,
@@ -108,9 +110,10 @@ export function RightControls({
volume={volume}
playbackRate={playbackRate}
isPiPSupported={isPiPSupported}
- onCopyLink={() => {
+ isProxied={isProxied}
+ onCopyLink={(type) => {
onToggleMoreMenu();
- onCopyLink();
+ onCopyLink(type);
}}
onToggleVolumeMenu={() => {
onToggleMoreMenu();
diff --git a/lib/utils/hls-downloader.ts b/lib/utils/hls-downloader.ts
new file mode 100644
index 0000000..7a8674a
--- /dev/null
+++ b/lib/utils/hls-downloader.ts
@@ -0,0 +1,85 @@
+import { Segment } from '@/lib/utils/hlsManifestParser';
+import { downloadSegmentQueue } from '@/lib/utils/segmentDownloader';
+
+interface PreloadParams {
+ currentTime: number;
+ segments: Segment[];
+ videoRef: React.RefObject
;
+ lastStartIndexRef: React.MutableRefObject;
+ isInitializedRef: React.MutableRefObject;
+ abortControllerRef: React.MutableRefObject;
+ videoUrl: string;
+}
+
+export function preloadSegments({
+ currentTime,
+ segments,
+ videoRef,
+ lastStartIndexRef,
+ isInitializedRef,
+ abortControllerRef,
+ videoUrl
+}: PreloadParams) {
+ // Find segment index for currentTime
+ let startIndex = 0;
+ for (let i = 0; i < segments.length; i++) {
+ if (currentTime < segments[i].startTime + segments[i].duration) {
+ startIndex = i;
+ break;
+ }
+ }
+
+ // Check browser buffer health
+ if (videoRef.current) {
+ const buffered = videoRef.current.buffered;
+ let bufferEnd = 0;
+ for (let i = 0; i < buffered.length; i++) {
+ if (buffered.start(i) <= currentTime && buffered.end(i) >= currentTime) {
+ bufferEnd = buffered.end(i);
+ break;
+ }
+ }
+
+ // If browser buffer is less than 30s ahead, let browser handle it
+ if (bufferEnd - currentTime < 30) {
+ return;
+ }
+ }
+
+ // Offset start index by 3 segments to avoid competing with browser playback
+ startIndex = Math.min(startIndex + 3, segments.length - 1);
+
+ if (startIndex >= segments.length) return;
+
+ // Check if this is sequential playback or a seek
+ const diff = startIndex - lastStartIndexRef.current;
+ const isSequential = diff >= 0 && diff < 3;
+
+ // Skip if already downloading sequentially
+ if (isSequential && isInitializedRef.current && abortControllerRef.current) {
+ return;
+ }
+
+ // Only log on significant seeks or initial start
+ if (!isInitializedRef.current) {
+ console.log(`[Preloader] Initial start at segment ${startIndex} (${currentTime.toFixed(2)}s)`);
+ isInitializedRef.current = true;
+ } else if (!isSequential) {
+ console.log(`[Preloader] Seek detected. Current Time: ${currentTime.toFixed(2)}s. Starting from segment ${startIndex}.`);
+ }
+
+ lastStartIndexRef.current = startIndex;
+
+ // Abort previous queue and start new one
+ if (abortControllerRef.current) {
+ abortControllerRef.current.abort();
+ }
+ abortControllerRef.current = new AbortController();
+
+ downloadSegmentQueue({
+ segments: segments,
+ startIndex,
+ signal: abortControllerRef.current.signal,
+ videoUrl: videoUrl
+ });
+}
diff --git a/lib/utils/proxy-utils.ts b/lib/utils/proxy-utils.ts
new file mode 100644
index 0000000..cda4a6d
--- /dev/null
+++ b/lib/utils/proxy-utils.ts
@@ -0,0 +1,28 @@
+import { NextRequest } from 'next/server';
+
+export async function processM3u8Content(
+ content: string,
+ baseUrl: string,
+ origin: string
+): Promise {
+ const lines = content.split('\n');
+ const base = new URL(baseUrl);
+
+ const processedLines = lines.map(line => {
+ // Skip comments and empty lines
+ if (line.trim().startsWith('#') || !line.trim()) {
+ return line;
+ }
+
+ // Resolve relative URLs
+ try {
+ const absoluteUrl = new URL(line.trim(), base).toString();
+ // Wrap in proxy
+ return `${origin}/api/proxy?url=${encodeURIComponent(absoluteUrl)}`;
+ } catch (e) {
+ return line;
+ }
+ });
+
+ return processedLines.join('\n');
+}