Feat: hls manifest import

.gitignore

@@ -25,6 +25,9 @@ node_modules
 *.jwk
 *.jwt
 
+# HLS stream output (just hls-stream)
+dev/hls_*/
+
 # We're using bun (and sometimes deno)
 package-lock.json
 yarn.lock

justfile

@@ -144,8 +144,11 @@ pub name url="http://localhost:4443/anon" *args:
 		-i "dev/{{name}}.fmp4" \
 		-c copy \
 		-f mp4 -movflags cmaf+separate_moof+delay_moov+skip_trailer+frag_every_frame \
-		- | cargo run --bin hang -- publish --url "{{url}}" --name "{{name}}" {{args}}
+		- | cargo run --bin hang -- publish --url "{{url}}" --name "{{name}}" fmp4 {{args}}
 
+# Ingest a live HLS media playlist and publish it via hang (full ladder).
+pub-hls url name="demo" relay="http://localhost:4443/anon":
+	cargo run --bin hang -- publish --url "{{relay}}" --name "{{name}}" hls --playlist "{{url}}"
 
 # Publish a video using H.264 Annex B format to the localhost relay server
 pub-h264 name url="http://localhost:4443/anon" *args:
@@ -287,3 +290,74 @@ update:
 build:
 	bun run --filter='*' build
 	cargo build
+
+# Generate and serve an HLS stream from a video for testing pub-hls
+hls-stream name="bbb" port="8000":
+	#!/usr/bin/env bash
+	set -euo pipefail
+
+	just download "{{name}}"
+
+	INPUT="dev/{{name}}.mp4"
+	OUT_DIR="dev/hls_{{name}}"
+
+	rm -rf "$OUT_DIR"
+	mkdir -p "$OUT_DIR/video_1080p" "$OUT_DIR/video_144p" "$OUT_DIR/audio"
+
+	START_NUMBER=$(date +%s)
+
+	cat > "$OUT_DIR/master.m3u8" << 'EOF'
+	#EXTM3U
+
+	#EXT-X-MEDIA:TYPE=AUDIO,NAME="Stereo",GROUP-ID="audio",DEFAULT=YES,AUTOSELECT=YES,URI="audio/audio.m3u8"
+
+	#EXT-X-STREAM-INF:BANDWIDTH=4500000,CODECS="avc1.640029,mp4a.40.2",RESOLUTION=1920x1080,AUDIO="audio"
+	video_1080p/video.m3u8
+
+	#EXT-X-STREAM-INF:BANDWIDTH=350000,CODECS="avc1.640029,mp4a.40.2",RESOLUTION=256x144,AUDIO="audio"
+	video_144p/video.m3u8
+	EOF
+
+	sed -i 's/^\t//' "$OUT_DIR/master.m3u8"
+
+	echo ">>> Starting HLS stream generation..."
+	echo ">>> Master playlist: http://localhost:{{port}}/master.m3u8"
+
+	cleanup() {
+		echo "Shutting down..."
+		kill $(jobs -p) 2>/dev/null || true
+		exit 0
+	}
+	trap cleanup SIGINT SIGTERM
+
+	ffmpeg -loglevel warning -re -stream_loop -1 -i "$INPUT" \
+		-map 0:v:0 -r 25 -preset veryfast -g 50 -keyint_min 50 -sc_threshold 0 \
+		-c:v libx264 -profile:v high -level 4.1 -pix_fmt yuv420p -tag:v avc1 \
+		-bsf:v dump_extra -b:v 4M -vf "scale=1920:-2" \
+		-f hls -hls_time 2 -hls_list_size 12 \
+		-hls_flags independent_segments+delete_segments \
+		-hls_segment_type fmp4 -hls_fmp4_init_filename init.mp4 \
+		-hls_segment_filename "$OUT_DIR/video_1080p/segment_%09d.m4s" \
+		-start_number "$START_NUMBER" "$OUT_DIR/video_1080p/video.m3u8" &
+
+	ffmpeg -loglevel warning -re -stream_loop -1 -i "$INPUT" \
+		-map 0:v:0 -r 25 -preset veryfast -g 50 -keyint_min 50 -sc_threshold 0 \
+		-c:v libx264 -profile:v high -level 4.1 -pix_fmt yuv420p -tag:v avc1 \
+		-bsf:v dump_extra -b:v 300k -vf "scale=256:-2" \
+		-f hls -hls_time 2 -hls_list_size 12 \
+		-hls_flags independent_segments+delete_segments \
+		-hls_segment_type fmp4 -hls_fmp4_init_filename init.mp4 \
+		-hls_segment_filename "$OUT_DIR/video_144p/segment_%09d.m4s" \
+		-start_number "$START_NUMBER" "$OUT_DIR/video_144p/video.m3u8" &
+
+	ffmpeg -loglevel warning -re -stream_loop -1 -i "$INPUT" \
+		-map 0:a:0 -c:a aac -b:a 128k \
+		-f hls -hls_time 2 -hls_list_size 12 \
+		-hls_flags independent_segments+delete_segments \
+		-hls_segment_type fmp4 -hls_fmp4_init_filename init.mp4 \
+		-hls_segment_filename "$OUT_DIR/audio/segment_%09d.m4s" \
+		-start_number "$START_NUMBER" "$OUT_DIR/audio/audio.m3u8" &
+
+	sleep 2
+	echo ">>> HTTP server: http://localhost:{{port}}/"
+	cd "$OUT_DIR" && python3 -m http.server {{port}}

rs/hang-cli/Cargo.toml

@@ -19,6 +19,7 @@ path = "src/main.rs"
 [dependencies]
 anyhow = { version = "1", features = ["backtrace"] }
 axum = { version = "0.8", features = ["tokio"] }
+bytes = "1.10"
 clap = { version = "4", features = ["derive"] }
 hang = { workspace = true }
 hyper-serve = { version = "0.6", features = ["tls-rustls"] }