R3944Realms/srs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Proxy: Add SRT E2E test; placeholder for WebRTC verification

Browse Source 
- New `proxy-e2e-srt-test.sh`: publishes SRT through the proxy and
  verifies SRT, RTMP, HTTP-FLV, and HLS playback (origin's `srt_to_rtmp`
  + HTTP remux + HLS). WebRTC WHEP is intentionally a placeholder.
  Pre-check requires an ffmpeg with libsrt and prints the exact
  homebrew-ffmpeg `--with-srt` recipe when missing, since the default
  `brew install ffmpeg` does not include SRT support.
- `proxy-e2e-transmux-test.sh`: drop the srs-bench `srs_test` dependency
  and the `PROXY_TRANSMUX_TEST_RTC` env. WebRTC WHEP step becomes a
  placeholder, matching the SRT script style. Removes the now-unused
  Step 3 build of the WebRTC regression tool and renumbers the
  remaining steps.
- `.openclaw/memory/srs-codebase-map.md`: register the new SRT script.
- `.openclaw/skills/srs-develop/SKILL.md`: list the SRT script in the
  proxy verification flow and update the transmux description so it no
  longer mentions WebRTC verification or the dropped env var.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
winlin 2026-05-10 18:39:21 -04:00
parent 8db8f8d9b4
commit 7b8981d8b9
4 changed files with 286 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.openclaw/memory/srs-codebase-map.md
View File

@ -352,6 +352,7 @@ How to verify SRS works correctly.
- `proxy-e2e-cluster-test.sh` — Multi-origin memory load-balancer E2E test. - `proxy-e2e-cluster-test.sh` — Multi-origin memory load-balancer E2E test.
- `proxy-e2e-redis-test.sh` — Multi-proxy Redis load-balancer E2E test. - `proxy-e2e-redis-test.sh` — Multi-proxy Redis load-balancer E2E test.
- `proxy-e2e-transmux-test.sh` — RTMP publish through proxy, then verify RTMP, HTTP-FLV, HLS, and WebRTC playback. - `proxy-e2e-transmux-test.sh` — RTMP publish through proxy, then verify RTMP, HTTP-FLV, HLS, and WebRTC playback.
- `proxy-e2e-srt-test.sh` — SRT publish through proxy, then verify SRT, RTMP, HTTP-FLV, and HLS playback (WebRTC WHEP is a placeholder).
**Summary: The Key Differences** **Summary: The Key Differences**

6
.openclaw/skills/srs-develop/SKILL.md
View File

@ -156,10 +156,14 @@ Only after the user confirms the routing do you proceed to Step 2.
``` ```
bash scripts/proxy-e2e-redis-test.sh bash scripts/proxy-e2e-redis-test.sh
``` ```
- RTMP transmuxing test (starts proxy + one SRS origin, publishes RTMP, verifies RTMP/HTTP-FLV/HLS playback, and verifies WebRTC WHEP playback when `PROXY_TRANSMUX_TEST_RTC=on`): - RTMP transmuxing test (starts proxy + one SRS origin, publishes RTMP, verifies RTMP/HTTP-FLV/HLS playback; WebRTC WHEP is a placeholder):
``` ```
bash scripts/proxy-e2e-transmux-test.sh bash scripts/proxy-e2e-transmux-test.sh
``` ```
- SRT proxy + transmuxing test (starts proxy + one SRS origin, publishes SRT, verifies SRT/RTMP/HTTP-FLV/HLS playback; WebRTC WHEP is a placeholder). Requires an ffmpeg built with libsrt — the default `brew install ffmpeg` does NOT include it; install via the homebrew-ffmpeg tap with `--with-srt` (see the script's pre-check error for the exact commands):
```
bash scripts/proxy-e2e-srt-test.sh
```
5. If any tests fail, fix the issues and re-run until all tests pass. 5. If any tests fail, fix the issues and re-run until all tests pass.
All script paths are relative to this skill's directory. All script paths are relative to this skill's directory.

261
.openclaw/skills/srs-develop/scripts/proxy-e2e-srt-test.sh Executable file
View File

@ -0,0 +1,261 @@
#!/bin/bash
# E2E test for SRT proxy: starts proxy + SRS origin, publishes an SRT stream
# through the proxy, then verifies playback through the proxy in every form
# the origin can transmux from SRT (srt_to_rtmp + rtmp_to_rtc):
# - SRT play (passthrough)
# - RTMP play (via srt_to_rtmp on origin)
# - HTTP-FLV (HTTP remux of the bridged RTMP)
# - HLS (m3u8 + TS segments)
# - WebRTC WHEP (placeholder only, not actually verified here)
set -e
SCRIPT_DIR="$(cd -P "$(dirname "$0")" && pwd)"
# Navigate: scripts/ -> srs-develop/ -> skills/ -> .openclaw/ -> srs
WORKSPACE="$(cd -P "$SCRIPT_DIR/../../../.." && pwd)"
if [[ ! -f "$WORKSPACE/go.mod" ]]; then
echo "Error: go.mod not found in WORKSPACE: $WORKSPACE" >&2
exit 1
fi
# Proxy ports — same layout as proxy-e2e-test.sh / proxy-e2e-transmux-test.sh.
PROXY_RTMP_PORT=11935
PROXY_HTTP_API_PORT=11985
PROXY_HTTP_SERVER_PORT=18080
PROXY_WEBRTC_PORT=18000
PROXY_SRT_PORT=20080
PROXY_SYSTEM_API_PORT=12025
# Origin ports (from origin1-for-proxy.conf).
ORIGIN_RTMP_PORT=19351
ORIGIN_HTTP_PORT=8081
ORIGIN_API_PORT=19851
ORIGIN_RTC_PORT=8001
ORIGIN_SRT_PORT=10081
SOURCE_FLV="$WORKSPACE/trunk/doc/source.flv"
SRS_BINARY="$WORKSPACE/trunk/objs/srs"
STREAM_URL="live/livestream"
# SRT streamid format used by SRS: "#!::r=<app>/<stream>,m=publish|request".
# @see trunk/3rdparty/srs-docs/doc/srt.md and internal/proxy/srt.go.
SRT_PUBLISH_URL="srt://localhost:$PROXY_SRT_PORT?streamid=#!::r=$STREAM_URL,m=publish"
SRT_PLAY_URL="srt://localhost:$PROXY_SRT_PORT?streamid=#!::r=$STREAM_URL,m=request"
# PIDs to clean up on exit.
PROXY_PID=""
ORIGIN_PID=""
FFMPEG_PID=""
cleanup() {
echo ""
echo "=== Cleaning up ==="
for pid in $PROXY_PID $ORIGIN_PID $FFMPEG_PID; do
if [[ -n "$pid" ]] && kill -0 "$pid" 2>/dev/null; then
kill "$pid" 2>/dev/null || true
fi
done
sleep 1
for pid in $PROXY_PID $ORIGIN_PID $FFMPEG_PID; do
if [[ -n "$pid" ]] && kill -0 "$pid" 2>/dev/null; then
kill -9 "$pid" 2>/dev/null || true
fi
done
echo "Cleanup done."
}
trap cleanup EXIT
probe_has_audio_video() {
local name="$1"
local url="$2"
echo "Verifying $name playback: $url"
local output
output=$(ffprobe -v error -show_streams "$url" 2>&1 || true)
if echo "$output" | grep -q "codec_type=video"; then
echo "PASS: $name video stream detected."
else
echo "FAIL: $name no video stream detected." >&2
echo "ffprobe output:" >&2
echo "$output" >&2
exit 1
fi
if echo "$output" | grep -q "codec_type=audio"; then
echo "PASS: $name audio stream detected."
else
echo "FAIL: $name no audio stream detected." >&2
echo "ffprobe output:" >&2
echo "$output" >&2
exit 1
fi
}
wait_for_hls_playlist() {
local url="$1"
local deadline=45
echo "Waiting for HLS playlist to be generated (up to ${deadline}s): $url"
for ((i = 1; i <= deadline; i++)); do
if curl -fsS "$url" 2>/dev/null | grep -q "#EXTM3U"; then
echo "HLS playlist is ready."
return
fi
sleep 1
done
echo "FAIL: HLS playlist was not generated in ${deadline}s." >&2
echo "Last HLS response:" >&2
curl -v "$url" 2>&1 || true
exit 1
}
echo "=== E2E SRT Proxy Test ==="
echo "Workspace: $WORKSPACE"
echo "Stream: $STREAM_URL"
echo ""
# --- Pre-checks ---
if [[ ! -f "$SOURCE_FLV" ]]; then
echo "Error: test source not found: $SOURCE_FLV" >&2
exit 1
fi
if ! command -v ffmpeg &>/dev/null; then
echo "Error: ffmpeg not found in PATH" >&2
exit 1
fi
if ! command -v ffprobe &>/dev/null; then
echo "Error: ffprobe not found in PATH" >&2
exit 1
fi
if ! command -v curl &>/dev/null; then
echo "Error: curl not found in PATH" >&2
exit 1
fi
# SRT URLs need libsrt compiled into ffmpeg/ffprobe. The default Homebrew
# ffmpeg formula does NOT include libsrt — install the homebrew-ffmpeg tap
# build with the explicit --with-srt option instead:
# brew tap homebrew-ffmpeg/ffmpeg
# brew uninstall ffmpeg # if vanilla ffmpeg is already installed
# brew install homebrew-ffmpeg/ffmpeg/ffmpeg --with-srt
if ! ffmpeg -hide_banner -protocols 2>/dev/null | grep -qw srt; then
echo "Error: ffmpeg was built without SRT protocol support." >&2
echo "The default 'brew install ffmpeg' does NOT include libsrt." >&2
echo "Install the homebrew-ffmpeg tap build with --with-srt instead:" >&2
echo " brew tap homebrew-ffmpeg/ffmpeg" >&2
echo " brew uninstall ffmpeg # if vanilla ffmpeg is already installed" >&2
echo " brew install homebrew-ffmpeg/ffmpeg/ffmpeg --with-srt" >&2
exit 1
fi
# --- Step 0: Clean up stale state ---
rm -f "$WORKSPACE/trunk/objs/origin1.pid"
ALL_PORTS="$PROXY_RTMP_PORT $PROXY_HTTP_API_PORT $PROXY_HTTP_SERVER_PORT $PROXY_WEBRTC_PORT $PROXY_SRT_PORT $PROXY_SYSTEM_API_PORT $ORIGIN_RTMP_PORT $ORIGIN_HTTP_PORT $ORIGIN_API_PORT $ORIGIN_RTC_PORT $ORIGIN_SRT_PORT"
for port in $ALL_PORTS; do
lsof -ti :"$port" 2>/dev/null | xargs kill 2>/dev/null || true
done
sleep 1
# --- Step 1: Build proxy ---
echo "=== Step 1: Building proxy ==="
cd "$WORKSPACE"
make -s 2>&1
echo "Proxy built: $WORKSPACE/bin/srs-proxy"
# --- Step 2: Build SRS origin (if not already built) ---
if [[ ! -f "$SRS_BINARY" ]]; then
echo "=== Step 2: Building SRS origin ==="
cd "$WORKSPACE/trunk"
./configure && make 2>&1 | tail -3
echo "SRS origin built: $SRS_BINARY"
else
echo "=== Step 2: SRS origin already built ==="
fi
# --- Step 3: Start proxy ---
echo "=== Step 3: Starting proxy (SRT :$PROXY_SRT_PORT, System API :$PROXY_SYSTEM_API_PORT) ==="
cd "$WORKSPACE"
env PROXY_RTMP_SERVER=$PROXY_RTMP_PORT \
PROXY_HTTP_API=$PROXY_HTTP_API_PORT \
PROXY_HTTP_SERVER=$PROXY_HTTP_SERVER_PORT \
PROXY_WEBRTC_SERVER=$PROXY_WEBRTC_PORT \
PROXY_SRT_SERVER=$PROXY_SRT_PORT \
PROXY_SYSTEM_API=$PROXY_SYSTEM_API_PORT \
PROXY_LOAD_BALANCER_TYPE=memory \
./bin/srs-proxy >/tmp/srs-proxy-srt-e2e.log 2>&1 &
PROXY_PID=$!
echo "Proxy PID: $PROXY_PID"
sleep 1
if ! kill -0 "$PROXY_PID" 2>/dev/null; then
echo "Error: proxy failed to start. Logs:" >&2
cat /tmp/srs-proxy-srt-e2e.log >&2
exit 1
fi
echo "Proxy started."
# --- Step 4: Start SRS origin ---
echo "=== Step 4: Starting SRS origin ==="
ulimit -n 10000 2>/dev/null || true
cd "$WORKSPACE/trunk"
./objs/srs -c conf/origin1-for-proxy.conf >/tmp/srs-origin-srt-e2e.log 2>&1 &
ORIGIN_PID=$!
echo "SRS origin PID: $ORIGIN_PID"
# Wait for SRS to start and register with proxy (heartbeat interval is 9s).
echo "Waiting for SRS origin to register with proxy (up to 15s)..."
sleep 12
if ! kill -0 "$ORIGIN_PID" 2>/dev/null; then
echo "Error: SRS origin failed to start. Logs:" >&2
cat /tmp/srs-origin-srt-e2e.log >&2
exit 1
fi
echo "SRS origin started and registered."
# --- Step 5: Publish SRT stream ---
echo "=== Step 5: Publishing SRT stream to proxy ==="
echo "Publish URL: $SRT_PUBLISH_URL"
ffmpeg -stream_loop -1 -re -i "$SOURCE_FLV" -c copy -f mpegts \
"$SRT_PUBLISH_URL" >/tmp/srs-ffmpeg-srt-e2e.log 2>&1 &
FFMPEG_PID=$!
echo "FFmpeg publisher PID: $FFMPEG_PID"
# Wait for the SRT handshake, the proxy<->backend bridge, and the
# origin's srt_to_rtmp pipeline to spin up the derived streams.
sleep 5
if ! kill -0 "$FFMPEG_PID" 2>/dev/null; then
echo "Error: FFmpeg publisher failed. Logs:" >&2
cat /tmp/srs-ffmpeg-srt-e2e.log >&2
exit 1
fi
echo "Stream publishing."
# --- Step 6: Verify SRT playback (passthrough) ---
echo "=== Step 6: Verifying SRT playback via proxy ==="
probe_has_audio_video "SRT" "$SRT_PLAY_URL"
# --- Step 7: Verify RTMP playback (srt_to_rtmp) ---
echo "=== Step 7: Verifying RTMP playback via proxy ==="
probe_has_audio_video "RTMP" "rtmp://localhost:$PROXY_RTMP_PORT/$STREAM_URL"
# --- Step 8: Verify HTTP-FLV playback ---
echo "=== Step 8: Verifying HTTP-FLV playback via proxy ==="
probe_has_audio_video "HTTP-FLV" "http://localhost:$PROXY_HTTP_SERVER_PORT/$STREAM_URL.flv"
# --- Step 9: Verify HLS playback ---
echo "=== Step 9: Verifying HLS playback via proxy ==="
HLS_URL="http://localhost:$PROXY_HTTP_SERVER_PORT/$STREAM_URL.m3u8"
wait_for_hls_playlist "$HLS_URL"
probe_has_audio_video "HLS" "$HLS_URL"
# --- Step 10: WebRTC WHEP playback (placeholder) ---
echo "=== Step 10: WebRTC WHEP playback (placeholder) ==="
echo "SKIP: WebRTC WHEP playback is not verified by this script."
echo " The origin has rtmp_to_rtc enabled, so SRT->RTMP->RTC should work end-to-end,"
echo " but actual playback verification is intentionally left as a TODO here."
echo ""
echo "=== E2E SRT Proxy Test PASSED ==="

66
.openclaw/skills/srs-develop/scripts/proxy-e2e-transmux-test.sh
View File

@ -1,8 +1,8 @@
#!/bin/bash #!/bin/bash
# E2E test for RTMP-to-multiple-protocol transmuxing through the proxy: # E2E test for RTMP-to-multiple-protocol transmuxing through the proxy:
# starts one proxy with memory load balancer + one SRS origin, publishes one # starts one proxy with memory load balancer + one SRS origin, publishes one
# RTMP stream, then verifies RTMP, HTTP-FLV, HLS, and optional WebRTC WHEP # RTMP stream, then verifies RTMP, HTTP-FLV, and HLS playback through the
# playback through the proxy. # proxy. WebRTC WHEP verification is intentionally a placeholder (not run).
set -e set -e
SCRIPT_DIR="$(cd -P "$(dirname "$0")" && pwd)" SCRIPT_DIR="$(cd -P "$(dirname "$0")" && pwd)"
@ -32,13 +32,8 @@ ORIGIN_SRT_PORT=10081
SOURCE_FLV="$WORKSPACE/trunk/doc/source.flv" SOURCE_FLV="$WORKSPACE/trunk/doc/source.flv"
SRS_BINARY="$WORKSPACE/trunk/objs/srs" SRS_BINARY="$WORKSPACE/trunk/objs/srs"
SRS_TEST_BINARY="$WORKSPACE/trunk/3rdparty/srs-bench/objs/srs_test"
STREAM_URL="live/livestream" STREAM_URL="live/livestream"
# WebRTC requires the srs-bench regression test binary. Keep it enabled by
# default because it exercises the proxy WHEP API path; set to "off" to skip.
PROXY_TRANSMUX_TEST_RTC="${PROXY_TRANSMUX_TEST_RTC:-on}"
# PIDs to clean up on exit. # PIDs to clean up on exit.
PROXY_PID="" PROXY_PID=""
ORIGIN_PID="" ORIGIN_PID=""
@ -155,18 +150,8 @@ else
echo "=== Step 2: SRS origin already built ===" echo "=== Step 2: SRS origin already built ==="
fi fi
# --- Step 3: Build WebRTC regression tool (if enabled and needed) --- # --- Step 3: Start proxy ---
if [[ "$PROXY_TRANSMUX_TEST_RTC" == "on" && ! -x "$SRS_TEST_BINARY" ]]; then echo "=== Step 3: Starting proxy (memory LB) ==="
echo "=== Step 3: Building WebRTC regression tool ==="
cd "$WORKSPACE/trunk/3rdparty/srs-bench"
make ./objs/srs_test
echo "WebRTC regression tool built: $SRS_TEST_BINARY"
else
echo "=== Step 3: WebRTC regression tool build skipped ==="
fi
# --- Step 4: Start proxy ---
echo "=== Step 4: Starting proxy (memory LB) ==="
cd "$WORKSPACE" cd "$WORKSPACE"
env PROXY_RTMP_SERVER=$PROXY_RTMP_PORT \ env PROXY_RTMP_SERVER=$PROXY_RTMP_PORT \
PROXY_HTTP_API=$PROXY_HTTP_API_PORT \ PROXY_HTTP_API=$PROXY_HTTP_API_PORT \
@ -187,8 +172,8 @@ if ! kill -0 "$PROXY_PID" 2>/dev/null; then
fi fi
echo "Proxy started." echo "Proxy started."
# --- Step 5: Start SRS origin --- # --- Step 4: Start SRS origin ---
echo "=== Step 5: Starting SRS origin ===" echo "=== Step 4: Starting SRS origin ==="
ulimit -n 10000 2>/dev/null || true ulimit -n 10000 2>/dev/null || true
cd "$WORKSPACE/trunk" cd "$WORKSPACE/trunk"
./objs/srs -c conf/origin1-for-proxy.conf >/tmp/srs-origin-transmux-e2e.log 2>&1 & ./objs/srs -c conf/origin1-for-proxy.conf >/tmp/srs-origin-transmux-e2e.log 2>&1 &
@ -206,8 +191,8 @@ if ! kill -0 "$ORIGIN_PID" 2>/dev/null; then
fi fi
echo "SRS origin started and registered." echo "SRS origin started and registered."
# --- Step 6: Publish RTMP stream --- # --- Step 5: Publish RTMP stream ---
echo "=== Step 6: Publishing RTMP stream to proxy ===" echo "=== Step 5: Publishing RTMP stream to proxy ==="
ffmpeg -stream_loop -1 -re -i "$SOURCE_FLV" -c copy -f flv \ ffmpeg -stream_loop -1 -re -i "$SOURCE_FLV" -c copy -f flv \
"rtmp://localhost:$PROXY_RTMP_PORT/$STREAM_URL" >/tmp/srs-ffmpeg-transmux-e2e.log 2>&1 & "rtmp://localhost:$PROXY_RTMP_PORT/$STREAM_URL" >/tmp/srs-ffmpeg-transmux-e2e.log 2>&1 &
FFMPEG_PID=$! FFMPEG_PID=$!
@ -223,38 +208,25 @@ if ! kill -0 "$FFMPEG_PID" 2>/dev/null; then
fi fi
echo "Stream publishing." echo "Stream publishing."
# --- Step 7: Verify RTMP playback --- # --- Step 6: Verify RTMP playback ---
echo "=== Step 7: Verifying RTMP playback via proxy ===" echo "=== Step 6: Verifying RTMP playback via proxy ==="
probe_has_audio_video "RTMP" "rtmp://localhost:$PROXY_RTMP_PORT/$STREAM_URL" probe_has_audio_video "RTMP" "rtmp://localhost:$PROXY_RTMP_PORT/$STREAM_URL"
# --- Step 8: Verify HTTP-FLV playback --- # --- Step 7: Verify HTTP-FLV playback ---
echo "=== Step 8: Verifying HTTP-FLV playback via proxy ===" echo "=== Step 7: Verifying HTTP-FLV playback via proxy ==="
probe_has_audio_video "HTTP-FLV" "http://localhost:$PROXY_HTTP_SERVER_PORT/$STREAM_URL.flv" probe_has_audio_video "HTTP-FLV" "http://localhost:$PROXY_HTTP_SERVER_PORT/$STREAM_URL.flv"
# --- Step 9: Verify HLS playback --- # --- Step 8: Verify HLS playback ---
echo "=== Step 9: Verifying HLS playback via proxy ===" echo "=== Step 8: Verifying HLS playback via proxy ==="
HLS_URL="http://localhost:$PROXY_HTTP_SERVER_PORT/$STREAM_URL.m3u8" HLS_URL="http://localhost:$PROXY_HTTP_SERVER_PORT/$STREAM_URL.m3u8"
wait_for_hls_playlist "$HLS_URL" wait_for_hls_playlist "$HLS_URL"
probe_has_audio_video "HLS" "$HLS_URL" probe_has_audio_video "HLS" "$HLS_URL"
# --- Step 10: Verify WebRTC WHEP signaling via proxy --- # --- Step 9: WebRTC WHEP playback (placeholder) ---
echo "=== Step 10: Verifying WebRTC WHEP signaling via proxy ===" echo "=== Step 9: WebRTC WHEP playback (placeholder) ==="
if [[ "$PROXY_TRANSMUX_TEST_RTC" == "on" ]]; then echo "SKIP: WebRTC WHEP playback is not verified by this script."
if [[ ! -x "$SRS_TEST_BINARY" ]]; then echo " The origin has rtmp_to_rtc enabled, so RTMP->RTC should work end-to-end,"
echo "FAIL: WebRTC regression tool not found: $SRS_TEST_BINARY" >&2 echo " but actual playback verification is intentionally left as a TODO here."
exit 1
fi
cd "$WORKSPACE/trunk/3rdparty/srs-bench"
"$SRS_TEST_BINARY" \
-test.run '^TestBugfix2371_RTMP2RTC_PlayWithNack$' \
-srs-server "127.0.0.1:$PROXY_HTTP_API_PORT" \
-srs-stream "/$STREAM_URL" \
-srs-timeout 10000
echo "PASS: WebRTC WHEP signaling succeeded."
else
echo "SKIP: WebRTC WHEP test disabled by PROXY_TRANSMUX_TEST_RTC=$PROXY_TRANSMUX_TEST_RTC."
fi
echo "" echo ""
echo "NOTE: RTSP is not tested here because the Go proxy currently has no RTSP listener." echo "NOTE: RTSP is not tested here because the Go proxy currently has no RTSP listener."