GitHub/olcrtc
1
0
Fork 0
mirror of https://github.com/openlibrecommunity/olcrtc.git synced 2026-05-26 07:08:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(mage): add TestFull, Soak, and LocalSoak targets

Browse Source
This commit is contained in:
zarazaex69
2026-05-26 01:16:19 +03:00
parent 1f26687c48
commit 78bb27670d
1 changed files with 59 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
magefile.go
View File

@@ -85,16 +85,23 @@ func Lint() error {
return sh.RunV("golangci-lint", "run", "./...")
}
// Test runs all tests.
// Test runs all unit tests (short mode, skips long-running chaos/throughput tests).
func Test() error {
return sh.RunV(goexe, "test", "-race", "-count=1", "./...")
return sh.RunV(goexe, "test", "-race", "-count=1", "-short", "./...")
}
// E2E runs end-to-end tests from internal/e2e.
// TestFull runs all tests including chaos and throughput baselines (no real providers).
func TestFull() error {
return sh.RunV(goexe, "test", "-race", "-count=1", "-timeout", "10m", "./...")
}
// E2E runs the real-provider e2e matrix plus stress tests.
// Configure via env: E2E_CARRIERS, E2E_TRANSPORTS, E2E_TIMEOUT, E2E_STRESS.
func E2E() error {
args := []string{"test", "-race", "-count=1", "-v", "-timeout", "120s"}
args := []string{"test", "-race", "-count=1", "-v", "-timeout", "30m"}
args = append(args, "-olcrtc.real-e2e=true")
if carriers := os.Getenv("E2E_CARRIERS"); carriers != "" {
args = append(args, "-olcrtc.real-e2e=true", "-olcrtc.real-carriers="+carriers)
args = append(args, "-olcrtc.real-carriers="+carriers)
}
if transports := os.Getenv("E2E_TRANSPORTS"); transports != "" {
args = append(args, "-olcrtc.real-transports="+transports)
@@ -102,6 +109,53 @@ func E2E() error {
if timeout := os.Getenv("E2E_TIMEOUT"); timeout != "" {
args = append(args, "-olcrtc.real-timeout="+timeout)
}
if os.Getenv("E2E_STRESS") != "" {
args = append(args, "-olcrtc.stress=true")
if d := os.Getenv("E2E_STRESS_DURATION"); d != "" {
args = append(args, "-olcrtc.stress-duration="+d)
}
}
args = append(args, "./internal/e2e/...")
return sh.RunV(goexe, args...)
}
// Soak runs the real-provider throughput soak test.
// Configure via env: SOAK_CARRIERS, SOAK_TRANSPORTS, SOAK_DURATION.
func Soak() error {
carriers := envOr("SOAK_CARRIERS", "telemost,jitsi,wbstream")
transports := envOr("SOAK_TRANSPORTS", "datachannel,vp8channel")
duration := envOr("SOAK_DURATION", "10m")
args := []string{"test", "-count=1", "-v",
"-timeout", "4h",
"-olcrtc.real-e2e=true",
"-olcrtc.real-soak=true",
"-olcrtc.real-soak-carrier=" + carriers,
"-olcrtc.real-soak-transport=" + transports,
"-olcrtc.real-soak-duration=" + duration,
"-run", "^TestRealThroughputSoak$",
"./internal/e2e/...",
}
return sh.RunV(goexe, args...)
}
// LocalSoak runs the local (in-memory) throughput soak.
// Configure via env: SOAK_TRANSPORTS, SOAK_DURATION, SOAK_CHAOS.
func LocalSoak() error {
transports := envOr("SOAK_TRANSPORTS", "all")
duration := envOr("SOAK_DURATION", "6m")
chaos := os.Getenv("SOAK_CHAOS")
args := []string{"test", "-count=1", "-v",
"-timeout", "4h",
"-olcrtc.local-soak=true",
"-olcrtc.local-soak-transport=" + transports,
"-olcrtc.local-soak-duration=" + duration,
"-run", "^TestLocalThroughputSoak$",
}
if chaos != "" {
args = append(args, "-olcrtc.local-soak-chaos="+chaos)
}
args = append(args, "./internal/e2e/...")
return sh.RunV(goexe, args...)
}