+3 -1

go.mod

··· 8 8 9 9 replace github.com/AxisCommunications/go-dpop => github.com/streamplace/go-dpop v0.0.0-20250510031900-c897158a8ad4 10 10 11 11 + //replace github.com/livepeer/go-livepeer => ../go-livepeer 12 12 + 11 13 tool github.com/bluesky-social/indigo/cmd/lexgen 12 14 13 15 require ( ··· 48 50 github.com/multiformats/go-multihash v0.2.3 49 51 github.com/orandin/slog-gorm v1.4.0 50 52 github.com/patrickmn/go-cache v2.1.0+incompatible 51 51 - github.com/peterbourgon/ff/v3 v3.4.0 52 53 github.com/pion/interceptor v0.1.37 53 54 github.com/pion/rtcp v1.2.16 54 55 github.com/pion/webrtc/v4 v4.0.11 ··· 64 65 github.com/streamplace/oatproxy v0.0.0-20260130124113-420429019d3b 65 66 github.com/stretchr/testify v1.11.1 66 67 github.com/tdewolff/canvas v0.0.0-20250728095813-50d4cb1eee71 68 68 + github.com/urfave/cli/v3 v3.6.2 67 69 github.com/whyrusleeping/cbor-gen v0.3.1 68 70 github.com/whyrusleeping/go-did v0.0.0-20230824162731-404d1707d5d6 69 71 gitlab.com/gitlab-org/release-cli v0.18.0

+2 -4

go.sum

··· 1080 1080 github.com/perimeterx/marshmallow v1.1.5/go.mod h1:dsXbUu8CRzfYP5a87xpp0xq9S3u0Vchtcl8we9tYaXw= 1081 1081 github.com/petar/GoLLRB v0.0.0-20210522233825-ae3b015fd3e9 h1:1/WtZae0yGtPq+TI6+Tv1WTxkukpXeMlviSxvL7SRgk= 1082 1082 github.com/petar/GoLLRB v0.0.0-20210522233825-ae3b015fd3e9/go.mod h1:x3N5drFsm2uilKKuuYo6LdyD8vZAW55sH/9w+pbo1sw= 1083 1083 - github.com/peterbourgon/ff/v3 v3.4.0 h1:QBvM/rizZM1cB0p0lGMdmR7HxZeI/ZrBWB4DqLkMUBc= 1084 1084 - github.com/peterbourgon/ff/v3 v3.4.0/go.mod h1:zjJVUhx+twciwfDl0zBcFzl4dW8axCRyXE/eKY9RztQ= 1085 1083 github.com/peterh/liner v1.1.1-0.20190123174540-a2c9a5303de7 h1:oYW+YCJ1pachXTQmzR3rNLYGGz4g/UgFcjb28p/viDM= 1086 1084 github.com/peterh/liner v1.1.1-0.20190123174540-a2c9a5303de7/go.mod h1:CRroGNssyjTd/qIG2FyxByd2S8JEAZXBl4qUrZf8GS0= 1087 1085 github.com/pierrec/lz4 v2.6.1+incompatible h1:9UY3+iC23yxF0UfGaYrGplQ+79Rg+h/q9FV9ix19jjM= ··· 1317 1315 github.com/streamplace/atproto-oauth-golang v0.0.0-20250619231223-a9c04fb888ac/go.mod h1:9LlKkqciiO5lRfbX0n4Wn5KNY9nvFb4R3by8FdW2TWc= 1318 1316 github.com/streamplace/go-dpop v0.0.0-20250510031900-c897158a8ad4 h1:L1fS4HJSaAyNnkwfuZubgfeZy8rkWmA0cMtH5Z0HqNc= 1319 1317 github.com/streamplace/go-dpop v0.0.0-20250510031900-c897158a8ad4/go.mod h1:bGUXY9Wd4mnd+XUrOYZr358J2f6z9QO/dLhL1SsiD+0= 1320 1320 - github.com/streamplace/oatproxy v0.0.0-20260112011721-d74b4913c93f h1:hhbQ8CtcAZVlLit/r7b9QDK7qEgOth4hgE13xV6ViBI= 1321 1321 - github.com/streamplace/oatproxy v0.0.0-20260112011721-d74b4913c93f/go.mod h1:pXi24hA7xBHj8eEywX6wGqJOR9FaEYlGwQ/72rN6okw= 1322 1318 github.com/streamplace/oatproxy v0.0.0-20260130124113-420429019d3b h1:BB/R1egvkEqZhGeKL3tqAlTn0mkoOaaMY6r6s18XJYA= 1323 1319 github.com/streamplace/oatproxy v0.0.0-20260130124113-420429019d3b/go.mod h1:pXi24hA7xBHj8eEywX6wGqJOR9FaEYlGwQ/72rN6okw= 1324 1320 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= ··· 1389 1385 github.com/urfave/cli v1.22.10/go.mod h1:Gos4lmkARVdJ6EkW0WaNv/tZAAMe9V7XWyB60NtXRu0= 1390 1386 github.com/urfave/cli/v2 v2.27.7 h1:bH59vdhbjLv3LAvIu6gd0usJHgoTTPhCFib8qqOwXYU= 1391 1387 github.com/urfave/cli/v2 v2.27.7/go.mod h1:CyNAG/xg+iAOg0N4MPGZqVmv2rCoP267496AOXUZjA4= 1388 1388 + github.com/urfave/cli/v3 v3.6.2 h1:lQuqiPrZ1cIz8hz+HcrG0TNZFxU70dPZ3Yl+pSrH9A8= 1389 1389 + github.com/urfave/cli/v3 v3.6.2/go.mod h1:ysVLtOEmg2tOy6PknnYVhDoouyC/6N42TMeoMzskhso= 1392 1390 github.com/uudashr/gocognit v1.2.0 h1:3BU9aMr1xbhPlvJLSydKwdLN3tEUUrzPSSM8S4hDYRA= 1393 1391 github.com/uudashr/gocognit v1.2.0/go.mod h1:k/DdKPI6XBZO1q7HgoV2juESI2/Ofj9AcHPZhBBdrTU= 1394 1392 github.com/uudashr/iface v1.3.1 h1:bA51vmVx1UIhiIsQFSNq6GZ6VPTk3WNMZgRiCe9R29U=

-1

js/app/components/login/login.tsx

··· 27 27 28 28 // check for stored return route on mount 29 29 useEffect(() => { 30 30 - if (Platform.OS !== "web") return; 31 30 storage.getItem("returnRoute").then((stored) => { 32 31 if (stored) { 33 32 try {

+1 -6

js/app/features/bluesky/blueskyProvider.tsx

··· 2 2 import { storage } from "@streamplace/components"; 3 3 import { useURL } from "expo-linking"; 4 4 import { useEffect, useState } from "react"; 5 5 - import { Platform } from "react-native"; 6 5 import { useStore } from "store"; 7 6 import { useIsReady, useOAuthSession, useUserProfile } from "store/hooks"; 8 7 import { navigateToRoute } from "utils/navigation"; ··· 24 23 loadOAuthClient(); 25 24 26 25 // load return route from storage on mount 27 27 - if (Platform.OS !== "web") { 28 28 - return; 29 29 - } 30 26 storage.getItem("returnRoute").then((stored) => { 31 27 if (stored) { 32 28 try { ··· 86 82 if ( 87 83 lastAuthStatus !== "loggedIn" && 88 84 authStatus === "loggedIn" && 89 89 - returnRoute && 90 90 - Platform.OS === "web" 85 85 + returnRoute 91 86 ) { 92 87 console.log( 93 88 "Login successful, navigating back to returnRoute:",

+3 -8

js/app/hooks/useBlueskyNotifications.tsx

··· 1 1 import { useToast } from "@streamplace/components"; 2 2 import { CircleX } from "lucide-react-native"; 3 3 import { useEffect } from "react"; 4 4 - import { Platform } from "react-native"; 5 5 - import clearQueryParams from "utils/clear-query-params"; 6 4 import { useStore } from "../store"; 7 5 8 6 function titleCase(str: string) { ··· 20 18 let toast = useToast(); 21 19 const notification = useStore((state) => state.notification); 22 20 const clearNotification = useStore((state) => state.clearNotification); 23 23 - 24 24 - // we've already saved the notif to the store 25 25 - clearQueryParams(["error", "error_description"]); 26 21 27 22 useEffect(() => { 28 23 if (notification) { ··· 46 41 { 47 42 duration: 100, 48 43 variant: notification.type, 49 49 - actionLabel: Platform.OS === "web" ? "Copy message" : undefined, 44 44 + actionLabel: "Copy message", 50 45 iconLeft: CircleX, 51 46 onAction: () => { 52 47 navigator.clipboard.writeText( ··· 64 59 notification.message, 65 60 { 66 61 variant: notification.type, 67 67 - actionLabel: Platform.OS === "web" ? "Copy message" : undefined, 62 62 + actionLabel: "Copy message", 68 63 onAction: () => { 69 64 navigator.clipboard.writeText(notification.message); 70 65 }, ··· 79 74 notification.message, 80 75 { 81 76 variant: notification.type, 82 82 - actionLabel: Platform.OS === "web" ? "Copy message" : undefined, 77 77 + actionLabel: "Copy message", 83 78 onAction: () => { 84 79 navigator.clipboard.writeText(notification.message); 85 80 },

+16 -2

js/app/store/slices/blueskySlice.ts

··· 19 19 PlaceStreamServerSettings, 20 20 StreamplaceAgent, 21 21 } from "streamplace"; 22 22 - import clearQueryParams from "utils/clear-query-params"; 23 22 import { privateKeyToAccount } from "viem/accounts"; 24 23 import { StateCreator } from "zustand"; 25 24 import createOAuthClient, { ··· 118 117 createServerSettingsRecord: (debugRecording: boolean) => Promise<void>; 119 118 } 120 119 120 120 + const clearQueryParams = () => { 121 121 + if (Platform.OS !== "web") { 122 122 + return; 123 123 + } 124 124 + const u = new URL(document.location.href); 125 125 + const params = new URLSearchParams(u.search); 126 126 + if (u.search === "") { 127 127 + return; 128 128 + } 129 129 + params.delete("iss"); 130 130 + params.delete("state"); 131 131 + params.delete("code"); 132 132 + u.search = params.toString(); 133 133 + window.history.replaceState(null, "", u.toString()); 134 134 + }; 135 135 + 121 136 const uploadThumbnail = async ( 122 137 handle: string, 123 138 u: URL, ··· 202 217 notification: null, 203 218 204 219 clearNotification: () => { 205 205 - clearQueryParams(); 206 220 set({ notification: null }); 207 221 }, 208 222

-15

js/app/utils/clear-query-params.ts

··· 1 1 - import { Platform } from "react-native"; 2 2 - 3 3 - export default function clearQueryParams(par = ["iss", "state", "code"]) { 4 4 - if (Platform.OS !== "web") { 5 5 - return; 6 6 - } 7 7 - const u = new URL(document.location.href); 8 8 - const params = new URLSearchParams(u.search); 9 9 - if (u.search === "") { 10 10 - return; 11 11 - } 12 12 - par.forEach((p) => params.delete(p)); 13 13 - u.search = params.toString(); 14 14 - window.history.replaceState(null, "", u.toString()); 15 15 - }

+1 -1

js/docs/src/content/docs/guides/start-contributing/streamplace-dev-setup.md

··· 57 57 frontend, you can override the pertinent command line argument: 58 58 59 59 ```shell 60 60 - make dev && ./build-darwin-arm64/streamplace --dev-frontend-proxy="" 60 60 + make dev && ./build-darwin-arm64/streamplace --dev-frontend-proxy=false 61 61 ``` 62 62 63 63 If you're using a proxy server, you may want to set your tunnel URL as the

+6 -15

pkg/cmd/combine.go

··· 14 14 "stream.place/streamplace/pkg/media" 15 15 ) 16 16 17 17 - func Combine(ctx context.Context, build *config.BuildFlags, allArgs []string) error { 17 17 + func Combine(ctx context.Context, cli *config.CLI, debugDir string, outFile string, inputs []string) error { 18 18 gstinit.InitGST() 19 19 - cli := &config.CLI{Build: build} 20 20 - fs := cli.NewFlagSet("streamplace combine") 21 21 - debugDir := fs.String("debug-dir", "", "directory to write debug files to") 22 19 23 23 - err := cli.Parse(fs, allArgs) 24 24 - if err != nil { 25 25 - return err 26 26 - } 27 27 - if *debugDir != "" { 28 28 - err := os.MkdirAll(*debugDir, 0755) 20 20 + if debugDir != "" { 21 21 + err := os.MkdirAll(debugDir, 0755) 29 22 if err != nil { 30 23 return fmt.Errorf("failed to create debug directory: %w", err) 31 24 } 32 25 } 33 33 - log.Debug(context.Background(), "combine command: starting", "args", fs.Args()) 26 26 + log.Debug(context.Background(), "combine command: starting", "outFile", outFile, "inputs", inputs) 34 27 ctx = log.WithDebugValue(ctx, cli.Debug) 35 28 cryptoSigner, err := createSigner(ctx, cli) 36 29 if err != nil { ··· 40 33 if err != nil { 41 34 return err 42 35 } 43 43 - args := fs.Args() 44 44 - outFile := args[0] 45 45 - inputs := args[1:] 36 36 + 46 37 log.Log(ctx, "combining segments", "outFile", outFile, "inputs", inputs) 47 38 outFd, err := os.Create(outFile) 48 39 if err != nil { ··· 62 53 if err != nil { 63 54 return err 64 55 } 65 65 - err = CheckCombined(ctx, cli, outFd, *debugDir) 56 56 + err = CheckCombined(ctx, cli, outFd, debugDir) 66 57 if err != nil { 67 58 return err 68 59 }

+2 -31

pkg/cmd/go_livepeer.go

··· 3 3 import ( 4 4 "context" 5 5 "flag" 6 6 - "strings" 7 6 8 8 - "github.com/golang/glog" 9 7 "github.com/livepeer/go-livepeer/cmd/livepeer/starter" 10 8 "stream.place/streamplace/pkg/config" 11 9 ) 12 10 13 11 func GoLivepeer(ctx context.Context, fs *flag.FlagSet) error { 14 14 - lpfs := flag.NewFlagSet("livepeer", flag.ExitOnError) 15 15 - cfg := starter.NewLivepeerConfig(lpfs) 16 16 - fs.VisitAll(func(f *flag.Flag) { 17 17 - if !strings.HasPrefix(f.Name, "livepeer.") { 18 18 - return 19 19 - } 20 20 - name := strings.TrimPrefix(f.Name, "livepeer.") 21 21 - adapted := config.LivepeerFlags.SnakeToCamel[name] 22 22 - 23 23 - if adapted == "" { 24 24 - panic("unknown livepeer flag: " + name) 25 25 - } 26 26 - err := lpfs.Set(adapted, f.Value.String()) 27 27 - if err != nil { 28 28 - panic(err) 29 29 - } 30 30 - }) 31 31 - 32 12 err := flag.Set("logtostderr", "true") 33 13 if err != nil { 34 14 return err ··· 39 19 return err 40 20 } 41 21 42 42 - // Config file 43 43 - // err = ff.Parse(fs, args, 44 44 - // ff.WithConfigFileFlag("config"), 45 45 - // ff.WithEnvVarPrefix("SP_LIVEPEER"), 46 46 - // ) 47 47 - if err != nil { 48 48 - glog.Exit("Error parsing config: ", err) 49 49 - } 50 50 - 51 51 - cfg = starter.UpdateNilsForUnsetFlags(cfg) 22 22 + config.LivepeerConfig = starter.UpdateNilsForUnsetFlags(config.LivepeerConfig) 52 23 53 53 - starter.StartLivepeer(ctx, cfg) 24 24 + starter.StartLivepeer(ctx, config.LivepeerConfig) 54 25 55 26 return nil 56 27 }

+13 -25

pkg/cmd/sign.go

··· 4 4 "bytes" 5 5 "context" 6 6 "crypto/ecdsa" 7 7 - "flag" 8 7 "fmt" 9 8 "io" 10 9 "os" ··· 16 15 "stream.place/streamplace/pkg/media" 17 16 ) 18 17 19 19 - func Sign(ctx context.Context) error { 20 20 - fs := flag.NewFlagSet("streamplace", flag.ExitOnError) 21 21 - certPath := fs.String("cert", "", "path to the certificate file") 22 22 - key := fs.String("key", "", "base58-encoded secp256k1 private key") 23 23 - streamerName := fs.String("streamer", "", "streamer name") 24 24 - taURL := fs.String("ta-url", "http://timestamp.digicert.com", "timestamp authority server for signing") 25 25 - startTime := fs.Int64("start-time", 0, "start time of the stream") 26 26 - manifestJSON := fs.String("manifest", "", "JSON manifest to use for signing") 27 27 - if err := fs.Parse(os.Args[2:]); err != nil { 28 28 - return err 29 29 - } 30 30 - 18 18 + func Sign(ctx context.Context, certPath string, key string, streamerName string, taURL string, startTime int64, manifestJSON string) error { 31 19 log.Debug(ctx, "Sign command: starting", 32 32 - "streamer", *streamerName, 33 33 - "startTime", *startTime, 34 34 - "hasManifest", len(*manifestJSON) > 0) 20 20 + "streamer", streamerName, 21 21 + "startTime", startTime, 22 22 + "hasManifest", len(manifestJSON) > 0) 35 23 36 36 - keyBs, err := base58.Decode(*key) 24 24 + keyBs, err := base58.Decode(key) 37 25 if err != nil { 38 26 return err 39 27 } 40 28 41 41 - if *streamerName == "" { 29 29 + if streamerName == "" { 42 30 return fmt.Errorf("streamer name is required") 43 31 } 44 32 ··· 48 36 } 49 37 signer := secpSigner.ToECDSA() 50 38 51 51 - certBs, err := os.ReadFile(*certPath) 39 39 + certBs, err := os.ReadFile(certPath) 52 40 if err != nil { 53 41 return err 54 42 } ··· 61 49 ms := &media.MediaSignerLocal{ 62 50 Signer: signer, 63 51 Cert: certBs, 64 64 - StreamerName: *streamerName, 65 65 - TAURL: *taURL, 52 52 + StreamerName: streamerName, 53 53 + TAURL: taURL, 66 54 AQPub: pub, 67 67 - PrebuiltManifest: []byte(*manifestJSON), // Pass the manifest from parent process 55 55 + PrebuiltManifest: []byte(manifestJSON), // Pass the manifest from parent process 68 56 } 69 57 70 70 - if len(*manifestJSON) > 0 { 71 71 - log.Debug(ctx, "Sign command: using provided manifest", "manifestLength", len(*manifestJSON)) 58 58 + if len(manifestJSON) > 0 { 59 59 + log.Debug(ctx, "Sign command: using provided manifest", "manifestLength", len(manifestJSON)) 72 60 } 73 61 74 62 inputBs, err := io.ReadAll(os.Stdin) ··· 76 64 return err 77 65 } 78 66 79 79 - mp4, err := ms.SignMP4(ctx, bytes.NewReader(inputBs), *startTime) 67 67 + mp4, err := ms.SignMP4(ctx, bytes.NewReader(inputBs), startTime) 80 68 if err != nil { 81 69 return err 82 70 }

+319 -142

pkg/cmd/streamplace.go

··· 21 21 "github.com/bluesky-social/indigo/carstore" 22 22 "github.com/ethereum/go-ethereum/common/hexutil" 23 23 "github.com/livepeer/go-livepeer/cmd/livepeer/starter" 24 24 - "github.com/peterbourgon/ff/v3" 25 24 "github.com/streamplace/oatproxy/pkg/oatproxy" 25 25 + urfavecli "github.com/urfave/cli/v3" 26 26 "stream.place/streamplace/pkg/aqhttp" 27 27 "stream.place/streamplace/pkg/atproto" 28 28 "stream.place/streamplace/pkg/bus" ··· 54 54 // parse the CLI and fire up an streamplace node! 55 55 func start(build *config.BuildFlags, platformJobs []jobFunc) error { 56 56 iroh_streamplace.InitLogging() 57 57 - selfTest := len(os.Args) > 1 && os.Args[1] == "self-test" 58 58 - err := media.RunSelfTest(context.Background()) 59 59 - if err != nil { 60 60 - if selfTest { 61 61 - fmt.Println(err.Error()) 62 62 - os.Exit(1) 63 63 - } else { 64 64 - retryCount, _ := strconv.Atoi(os.Getenv("STREAMPLACE_SELFTEST_RETRY")) 65 65 - if retryCount >= 3 { 66 66 - log.Error(context.Background(), "gstreamer self-test failed 3 times, giving up", "error", err) 67 67 - return err 68 68 - } 69 69 - log.Log(context.Background(), "error in gstreamer self-test, attempting recovery", "error", err, "retry", retryCount+1) 70 70 - os.Setenv("STREAMPLACE_SELFTEST_RETRY", strconv.Itoa(retryCount+1)) 71 71 - err := syscall.Exec(os.Args[0], os.Args[1:], os.Environ()) 72 72 - if err != nil { 73 73 - log.Error(context.Background(), "error in gstreamer self-test, could not restart", "error", err) 74 74 - return err 75 75 - } 76 76 - panic("invalid code path: exec succeeded but we're still here???") 77 77 - } 78 78 - } 79 79 - if selfTest { 80 80 - runtime.GC() 81 81 - if err := pprof.Lookup("goroutine").WriteTo(os.Stderr, 2); err != nil { 82 82 - log.Error(context.Background(), "error creating pprof", "error", err) 83 83 - } 84 84 - fmt.Println("self-test successful!") 85 85 - os.Exit(0) 86 86 - } 87 57 88 88 - if len(os.Args) > 1 && os.Args[1] == "stream" { 89 89 - if len(os.Args) != 3 { 90 90 - fmt.Println("usage: streamplace stream [user]") 91 91 - os.Exit(1) 92 92 - } 93 93 - return Stream(os.Args[2]) 58 58 + cli := config.CLI{Build: build} 59 59 + app := cli.NewCommand("streamplace") 60 60 + app.Usage = "decentralized live streaming platform" 61 61 + app.Version = build.Version 62 62 + app.Commands = []*urfavecli.Command{ 63 63 + makeSelfTestCommand(build), 64 64 + makeStreamCommand(build), 65 65 + makeLiveCommand(build), 66 66 + makeSignCommand(build), 67 67 + makeWhepCommand(build), 68 68 + makeWhipCommand(build), 69 69 + makeCombineCommand(build), 70 70 + makeSplitCommand(build), 71 71 + makeLivepeerCommand(build), 72 72 + makeMigrateCommand(build), 94 73 } 95 95 - 96 96 - if len(os.Args) > 1 && os.Args[1] == "live" { 97 97 - cli := config.CLI{Build: build} 98 98 - fs := cli.NewFlagSet("streamplace live") 99 99 - 100 100 - err := cli.Parse(fs, os.Args[2:]) 74 74 + // Add the verbosity flag 75 75 + // app.Flags = append(app.Flags, &urfavecli.StringFlag{ 76 76 + // Name: "v", 77 77 + // Usage: "log verbosity level", 78 78 + // Value: "3", 79 79 + // }) 80 80 + app.Before = func(ctx context.Context, cmd *urfavecli.Command) (context.Context, error) { 81 81 + // Run self-test before starting 82 82 + selfTest := cmd.Name == "self-test" 83 83 + err := media.RunSelfTest(ctx) 101 84 if err != nil { 102 102 - return err 103 103 - } 104 104 - 105 105 - args := fs.Args() 106 106 - if len(args) != 1 { 107 107 - fmt.Println("usage: streamplace live [flags] [stream-key]") 108 108 - os.Exit(1) 85 85 + if selfTest { 86 86 + fmt.Println(err.Error()) 87 87 + os.Exit(1) 88 88 + } else { 89 89 + retryCount, _ := strconv.Atoi(os.Getenv("STREAMPLACE_SELFTEST_RETRY")) 90 90 + if retryCount >= 3 { 91 91 + log.Error(ctx, "gstreamer self-test failed 3 times, giving up", "error", err) 92 92 + return ctx, err 93 93 + } 94 94 + log.Log(ctx, "error in gstreamer self-test, attempting recovery", "error", err, "retry", retryCount+1) 95 95 + os.Setenv("STREAMPLACE_SELFTEST_RETRY", strconv.Itoa(retryCount+1)) 96 96 + err := syscall.Exec(os.Args[0], os.Args[1:], os.Environ()) 97 97 + if err != nil { 98 98 + log.Error(ctx, "error in gstreamer self-test, could not restart", "error", err) 99 99 + return ctx, err 100 100 + } 101 101 + panic("invalid code path: exec succeeded but we're still here???") 102 102 + } 109 103 } 110 110 - 111 111 - return Live(args[0], cli.HTTPInternalAddr) 104 104 + return ctx, nil 112 105 } 113 113 - 114 114 - if len(os.Args) > 1 && os.Args[1] == "sign" { 115 115 - return Sign(context.Background()) 106 106 + app.Action = func(ctx context.Context, cmd *urfavecli.Command) error { 107 107 + return runMain(ctx, build, platformJobs, cmd, &cli) 116 108 } 117 109 118 118 - if len(os.Args) > 1 && os.Args[1] == "whep" { 119 119 - return WHEP(os.Args[2:]) 120 120 - } 121 121 - if len(os.Args) > 1 && os.Args[1] == "whip" { 122 122 - return WHIP(os.Args[2:]) 123 123 - } 124 124 - 125 125 - if len(os.Args) > 1 && os.Args[1] == "combine" { 126 126 - return Combine(context.Background(), build, os.Args[2:]) 127 127 - } 110 110 + return app.Run(context.Background(), os.Args) 111 111 + } 128 112 129 129 - if len(os.Args) > 1 && os.Args[1] == "split" { 130 130 - cli := config.CLI{Build: build} 131 131 - fs := cli.NewFlagSet("streamplace split") 132 132 - 133 133 - err := cli.Parse(fs, os.Args[2:]) 134 134 - if err != nil { 135 135 - return err 136 136 - } 137 137 - ctx := context.Background() 138 138 - ctx = log.WithDebugValue(ctx, cli.Debug) 139 139 - if len(fs.Args()) != 2 { 140 140 - fmt.Println("usage: streamplace split [flags] [input file] [output directory]") 141 141 - os.Exit(1) 142 142 - } 143 143 - gstinit.InitGST() 144 144 - return Split(ctx, fs.Args()[0], fs.Args()[1]) 145 145 - } 146 146 - 147 147 - if len(os.Args) > 1 && os.Args[1] == "self-test" { 148 148 - err := media.RunSelfTest(context.Background()) 149 149 - if err != nil { 150 150 - fmt.Println(err.Error()) 151 151 - os.Exit(1) 152 152 - } 153 153 - fmt.Println("self-test successful!") 154 154 - os.Exit(0) 155 155 - } 156 156 - 157 157 - if len(os.Args) > 1 && os.Args[1] == "livepeer" { 158 158 - lpfs := flag.NewFlagSet("livepeer", flag.ExitOnError) 159 159 - _ = starter.NewLivepeerConfig(lpfs) 160 160 - err = ff.Parse(lpfs, os.Args[2:], 161 161 - ff.WithConfigFileFlag("config"), 162 162 - ff.WithEnvVarPrefix("LP"), 163 163 - ) 164 164 - if err != nil { 165 165 - return err 166 166 - } 167 167 - err = GoLivepeer(context.Background(), lpfs) 168 168 - if err != nil { 169 169 - log.Error(context.Background(), "error in livepeer", "error", err) 170 170 - os.Exit(1) 171 171 - } 172 172 - os.Exit(0) 173 173 - } 174 174 - 113 113 + func runMain(ctx context.Context, build *config.BuildFlags, platformJobs []jobFunc, cmd *urfavecli.Command, cli *config.CLI) error { 175 114 _ = flag.Set("logtostderr", "true") 176 115 vFlag := flag.Lookup("v") 177 177 - cli := config.CLI{Build: build} 178 178 - fs := cli.NewFlagSet("streamplace") 179 179 - verbosity := fs.String("v", "3", "log verbosity level") 180 180 - version := fs.Bool("version", false, "print version and exit") 181 116 182 182 - err = cli.Parse( 183 183 - fs, os.Args[1:], 184 184 - ) 117 117 + err := cli.Validate(cmd) 185 118 if err != nil { 186 119 return err 187 120 } ··· 190 123 if err != nil { 191 124 return err 192 125 } 193 193 - _ = vFlag.Value.Set(*verbosity) 126 126 + verbosity := cmd.String("v") 127 127 + _ = vFlag.Value.Set(verbosity) 194 128 log.SetColorLogger(cli.Color) 195 195 - ctx := context.Background() 196 129 ctx = log.WithDebugValue(ctx, cli.Debug) 197 130 198 131 log.Log(ctx, ··· 203 136 "runtime.GOOS", runtime.GOOS, 204 137 "runtime.GOARCH", runtime.GOARCH, 205 138 "runtime.Version", runtime.Version()) 206 206 - if *version { 207 207 - return nil 208 208 - } 209 209 - signer, err := createSigner(ctx, &cli) 139 139 + 140 140 + signer, err := createSigner(ctx, cli) 210 141 if err != nil { 211 142 return err 212 143 } 213 144 214 145 if len(os.Args) > 1 && os.Args[1] == "migrate" { 215 215 - return statedb.Migrate(&cli) 146 146 + return statedb.Migrate(cli) 216 147 } 217 148 218 149 spmetrics.Version.WithLabelValues(build.Version).Inc() ··· 262 193 if err != nil { 263 194 return err 264 195 } 265 265 - state, err := statedb.MakeDB(ctx, &cli, noter, mod) 196 196 + state, err := statedb.MakeDB(ctx, cli, noter, mod) 266 197 if err != nil { 267 198 return err 268 199 } 269 269 - handle, err := atproto.MakeLexiconRepo(ctx, &cli, mod, state) 200 200 + handle, err := atproto.MakeLexiconRepo(ctx, cli, mod, state) 270 201 if err != nil { 271 202 return err 272 203 } ··· 286 217 287 218 b := bus.NewBus() 288 219 atsync := &atproto.ATProtoSynchronizer{ 289 289 - CLI: &cli, 220 220 + CLI: cli, 290 221 Model: mod, 291 222 StatefulDB: state, 292 223 Noter: noter, ··· 297 228 return fmt.Errorf("failed to migrate: %w", err) 298 229 } 299 230 300 300 - mm, err := media.MakeMediaManager(ctx, &cli, signer, mod, b, atsync, ldb) 231 231 + mm, err := media.MakeMediaManager(ctx, cli, signer, mod, b, atsync, ldb) 301 232 if err != nil { 302 233 return err 303 234 } 304 235 305 305 - ms, err := media.MakeMediaSigner(ctx, &cli, cli.StreamerName, signer, mod) 236 236 + ms, err := media.MakeMediaSigner(ctx, cli, cli.StreamerName, signer, mod) 306 237 if err != nil { 307 238 return err 308 239 } ··· 365 296 return err 366 297 } 367 298 } 368 368 - replicator, err = iroh_replicator.NewSwarm(ctx, &cli, secret, topic, mm, b, mod) 299 299 + replicator, err = iroh_replicator.NewSwarm(ctx, cli, secret, topic, mm, b, mod) 369 300 if err != nil { 370 301 return err 371 302 } ··· 387 318 Public: cli.PublicOAuth, 388 319 HTTPClient: &aqhttp.Client, 389 320 }) 390 390 - d := director.NewDirector(mm, mod, &cli, b, op, state, replicator, ldb) 391 391 - a, err := api.MakeStreamplaceAPI(&cli, mod, state, noter, mm, ms, b, atsync, d, op, ldb) 321 321 + d := director.NewDirector(mm, mod, cli, b, op, state, replicator, ldb) 322 322 + a, err := api.MakeStreamplaceAPI(cli, mod, state, noter, mm, ms, b, atsync, d, op, ldb) 392 323 if err != nil { 393 324 return err 394 325 } ··· 418 349 }) 419 350 if cli.RTMPServerAddon != "" { 420 351 group.Go(func() error { 421 421 - return rtmps.ServeRTMPSAddon(ctx, &cli) 352 352 + return rtmps.ServeRTMPSAddon(ctx, cli) 422 353 }) 423 354 } 424 355 group.Go(func() error { 425 425 - return a.ServeRTMPS(ctx, &cli) 356 356 + return a.ServeRTMPS(ctx, cli) 426 357 }) 427 358 } else { 428 359 group.Go(func() error { ··· 453 384 }) 454 385 455 386 group.Go(func() error { 456 456 - return storage.StartSegmentCleaner(ctx, ldb, &cli) 387 387 + return storage.StartSegmentCleaner(ctx, ldb, cli) 457 388 }) 458 389 459 390 group.Go(func() error { ··· 461 392 }) 462 393 463 394 group.Go(func() error { 464 464 - return replicator.Start(ctx, &cli) 395 395 + return replicator.Start(ctx, cli) 465 396 }) 466 397 467 398 if cli.LivepeerGateway { ··· 475 406 return err 476 407 } 477 408 group.Go(func() error { 478 478 - err := GoLivepeer(ctx, fs) 409 409 + err = GoLivepeer(ctx, config.LivepeerFlagSet) 479 410 if err != nil { 480 411 return err 481 412 } ··· 497 428 return err 498 429 } 499 430 did := atkey.DIDKey() 500 500 - testMediaSigner, err := media.MakeMediaSigner(ctx, &cli, did, signer, mod) 431 431 + testMediaSigner, err := media.MakeMediaSigner(ctx, cli, did, signer, mod) 501 432 if err != nil { 502 433 return err 503 434 } ··· 524 455 return err 525 456 } 526 457 did2 := atkey2.DIDKey() 527 527 - intermittentMediaSigner, err := media.MakeMediaSigner(ctx, &cli, did2, signer, mod) 458 458 + intermittentMediaSigner, err := media.MakeMediaSigner(ctx, cli, did2, signer, mod) 528 459 if err != nil { 529 460 return err 530 461 } ··· 561 492 562 493 for _, job := range platformJobs { 563 494 group.Go(func() error { 564 564 - return job(ctx, &cli) 495 495 + return job(ctx, cli) 565 496 }) 566 497 } 567 498 568 499 if cli.WHIPTest != "" { 569 500 group.Go(func() error { 570 570 - err := WHIP(strings.Split(cli.WHIPTest, " ")) 501 501 + // Parse WHIPTest string using the whip command's flag parser 502 502 + whipCmd := makeWhipCommand(build) 503 503 + args := strings.Split(cli.WHIPTest, " ") 504 504 + err := whipCmd.Run(ctx, append([]string{"streamplace", "whip"}, args...)) 571 505 log.Warn(ctx, "WHIP test complete, sleeping for 3 seconds and shutting down gstreamer") 572 506 time.Sleep(time.Second * 3) 573 507 // gst.Deinit() ··· 599 533 } 600 534 } 601 535 } 536 536 + 537 537 + func makeSelfTestCommand(build *config.BuildFlags) *urfavecli.Command { 538 538 + return &urfavecli.Command{ 539 539 + Name: "self-test", 540 540 + Usage: "run gstreamer self-test", 541 541 + Action: func(ctx context.Context, cmd *urfavecli.Command) error { 542 542 + err := media.RunSelfTest(ctx) 543 543 + if err != nil { 544 544 + fmt.Println(err.Error()) 545 545 + os.Exit(1) 546 546 + } 547 547 + runtime.GC() 548 548 + if err := pprof.Lookup("goroutine").WriteTo(os.Stderr, 2); err != nil { 549 549 + log.Error(ctx, "error creating pprof", "error", err) 550 550 + } 551 551 + fmt.Println("self-test successful!") 552 552 + return nil 553 553 + }, 554 554 + } 555 555 + } 556 556 + 557 557 + func makeStreamCommand(build *config.BuildFlags) *urfavecli.Command { 558 558 + return &urfavecli.Command{ 559 559 + Name: "stream", 560 560 + Usage: "stream command", 561 561 + ArgsUsage: "[user]", 562 562 + Action: func(ctx context.Context, cmd *urfavecli.Command) error { 563 563 + args := cmd.Args() 564 564 + if args.Len() != 1 { 565 565 + return fmt.Errorf("usage: streamplace stream [user]") 566 566 + } 567 567 + return Stream(args.First()) 568 568 + }, 569 569 + } 570 570 + } 571 571 + 572 572 + func makeLiveCommand(build *config.BuildFlags) *urfavecli.Command { 573 573 + cli := config.CLI{Build: build} 574 574 + liveCmd := cli.NewCommand("live") 575 575 + liveCmd.Usage = "start live stream" 576 576 + liveCmd.ArgsUsage = "[stream-key]" 577 577 + liveCmd.Action = func(ctx context.Context, cmd *urfavecli.Command) error { 578 578 + args := cmd.Args() 579 579 + if args.Len() != 1 { 580 580 + return fmt.Errorf("usage: streamplace live [flags] [stream-key]") 581 581 + } 582 582 + return Live(args.First(), cli.HTTPInternalAddr) 583 583 + } 584 584 + return liveCmd 585 585 + } 586 586 + 587 587 + func makeSignCommand(build *config.BuildFlags) *urfavecli.Command { 588 588 + return &urfavecli.Command{ 589 589 + Name: "sign", 590 590 + Usage: "sign command", 591 591 + Flags: []urfavecli.Flag{ 592 592 + &urfavecli.StringFlag{ 593 593 + Name: "cert", 594 594 + Usage: "path to the certificate file", 595 595 + }, 596 596 + &urfavecli.StringFlag{ 597 597 + Name: "key", 598 598 + Usage: "base58-encoded secp256k1 private key", 599 599 + }, 600 600 + &urfavecli.StringFlag{ 601 601 + Name: "streamer", 602 602 + Usage: "streamer name", 603 603 + }, 604 604 + &urfavecli.StringFlag{ 605 605 + Name: "ta-url", 606 606 + Usage: "timestamp authority server for signing", 607 607 + Value: "http://timestamp.digicert.com", 608 608 + }, 609 609 + &urfavecli.IntFlag{ 610 610 + Name: "start-time", 611 611 + Usage: "start time of the stream", 612 612 + }, 613 613 + &urfavecli.StringFlag{ 614 614 + Name: "manifest", 615 615 + Usage: "JSON manifest to use for signing", 616 616 + }, 617 617 + }, 618 618 + Action: func(ctx context.Context, cmd *urfavecli.Command) error { 619 619 + return Sign( 620 620 + ctx, 621 621 + cmd.String("cert"), 622 622 + cmd.String("key"), 623 623 + cmd.String("streamer"), 624 624 + cmd.String("ta-url"), 625 625 + int64(cmd.Int("start-time")), 626 626 + cmd.String("manifest"), 627 627 + ) 628 628 + }, 629 629 + } 630 630 + } 631 631 + 632 632 + func makeWhepCommand(build *config.BuildFlags) *urfavecli.Command { 633 633 + return &urfavecli.Command{ 634 634 + Name: "whep", 635 635 + Usage: "WHEP client", 636 636 + Flags: []urfavecli.Flag{ 637 637 + &urfavecli.IntFlag{ 638 638 + Name: "count", 639 639 + Usage: "number of concurrent streams (for load testing)", 640 640 + Value: 1, 641 641 + }, 642 642 + &urfavecli.DurationFlag{ 643 643 + Name: "duration", 644 644 + Usage: "stop after this long", 645 645 + }, 646 646 + &urfavecli.StringFlag{ 647 647 + Name: "endpoint", 648 648 + Usage: "endpoint to send the WHEP request to", 649 649 + }, 650 650 + }, 651 651 + Action: func(ctx context.Context, cmd *urfavecli.Command) error { 652 652 + return WHEP( 653 653 + ctx, 654 654 + cmd.Int("count"), 655 655 + cmd.Duration("duration"), 656 656 + cmd.String("endpoint"), 657 657 + ) 658 658 + }, 659 659 + } 660 660 + } 661 661 + 662 662 + func makeWhipCommand(build *config.BuildFlags) *urfavecli.Command { 663 663 + return &urfavecli.Command{ 664 664 + Name: "whip", 665 665 + Usage: "WHIP client", 666 666 + Flags: []urfavecli.Flag{ 667 667 + &urfavecli.StringFlag{ 668 668 + Name: "stream-key", 669 669 + Usage: "stream key", 670 670 + }, 671 671 + &urfavecli.IntFlag{ 672 672 + Name: "count", 673 673 + Usage: "number of concurrent streams (for load testing)", 674 674 + Value: 1, 675 675 + }, 676 676 + &urfavecli.IntFlag{ 677 677 + Name: "viewers", 678 678 + Usage: "number of viewers to simulate per stream", 679 679 + }, 680 680 + &urfavecli.DurationFlag{ 681 681 + Name: "duration", 682 682 + Usage: "duration of the stream", 683 683 + }, 684 684 + &urfavecli.StringFlag{ 685 685 + Name: "file", 686 686 + Usage: "file to stream (needs to be an MP4 containing H264 video and Opus audio)", 687 687 + Required: true, 688 688 + }, 689 689 + &urfavecli.StringFlag{ 690 690 + Name: "endpoint", 691 691 + Usage: "endpoint to send the WHIP request to", 692 692 + Value: "http://127.0.0.1:38080", 693 693 + }, 694 694 + &urfavecli.DurationFlag{ 695 695 + Name: "freeze-after", 696 696 + Usage: "freeze the stream after the given duration", 697 697 + }, 698 698 + }, 699 699 + Action: func(ctx context.Context, cmd *urfavecli.Command) error { 700 700 + return WHIP( 701 701 + ctx, 702 702 + cmd.String("stream-key"), 703 703 + cmd.Int("count"), 704 704 + cmd.Int("viewers"), 705 705 + cmd.Duration("duration"), 706 706 + cmd.String("file"), 707 707 + cmd.String("endpoint"), 708 708 + cmd.Duration("freeze-after"), 709 709 + ) 710 710 + }, 711 711 + } 712 712 + } 713 713 + 714 714 + func makeCombineCommand(build *config.BuildFlags) *urfavecli.Command { 715 715 + cli := config.CLI{Build: build} 716 716 + combineCmd := cli.NewCommand("combine") 717 717 + combineCmd.Usage = "combine segments" 718 718 + combineCmd.ArgsUsage = "[output] [input1] [input2...]" 719 719 + combineCmd.Flags = []urfavecli.Flag{ 720 720 + &urfavecli.StringFlag{ 721 721 + Name: "debug-dir", 722 722 + Usage: "directory to write debug output", 723 723 + }, 724 724 + } 725 725 + combineCmd.Action = func(ctx context.Context, cmd *urfavecli.Command) error { 726 726 + args := cmd.Args() 727 727 + if args.Len() < 2 { 728 728 + return fmt.Errorf("usage: streamplace combine [--debug-dir dir] [output] [input1] [input2...]") 729 729 + } 730 730 + ctx = log.WithDebugValue(ctx, cli.Debug) 731 731 + return Combine( 732 732 + ctx, 733 733 + &cli, 734 734 + cmd.String("debug-dir"), 735 735 + args.Get(0), 736 736 + args.Slice()[1:], 737 737 + ) 738 738 + } 739 739 + return combineCmd 740 740 + } 741 741 + 742 742 + func makeSplitCommand(build *config.BuildFlags) *urfavecli.Command { 743 743 + cli := config.CLI{Build: build} 744 744 + splitCmd := cli.NewCommand("split") 745 745 + splitCmd.Usage = "split video file" 746 746 + splitCmd.ArgsUsage = "[input file] [output directory]" 747 747 + splitCmd.Action = func(ctx context.Context, cmd *urfavecli.Command) error { 748 748 + args := cmd.Args() 749 749 + if args.Len() != 2 { 750 750 + return fmt.Errorf("usage: streamplace split [flags] [input file] [output directory]") 751 751 + } 752 752 + ctx = log.WithDebugValue(ctx, cli.Debug) 753 753 + gstinit.InitGST() 754 754 + return Split(ctx, args.Get(0), args.Get(1)) 755 755 + } 756 756 + return splitCmd 757 757 + } 758 758 + 759 759 + func makeLivepeerCommand(build *config.BuildFlags) *urfavecli.Command { 760 760 + return &urfavecli.Command{ 761 761 + Name: "livepeer", 762 762 + Usage: "run livepeer gateway", 763 763 + Action: func(ctx context.Context, cmd *urfavecli.Command) error { 764 764 + return GoLivepeer(ctx, config.LivepeerFlagSet) 765 765 + }, 766 766 + } 767 767 + } 768 768 + 769 769 + func makeMigrateCommand(build *config.BuildFlags) *urfavecli.Command { 770 770 + cli := config.CLI{Build: build} 771 771 + return &urfavecli.Command{ 772 772 + Name: "migrate", 773 773 + Usage: "run database migrations", 774 774 + Action: func(ctx context.Context, cmd *urfavecli.Command) error { 775 775 + return statedb.Migrate(&cli) 776 776 + }, 777 777 + } 778 778 + }

+5 -17

pkg/cmd/whep.go

··· 2 2 3 3 import ( 4 4 "context" 5 5 - "flag" 6 5 "fmt" 7 6 "io" 8 7 "net/http" ··· 15 14 "stream.place/streamplace/pkg/log" 16 15 ) 17 16 18 18 - func WHEP(args []string) error { 19 19 - fs := flag.NewFlagSet("whep", flag.ExitOnError) 20 20 - count := fs.Int("count", 1, "number of concurrent streams (for load testing)") 21 21 - duration := fs.Duration("duration", 0, "stop after this long") 22 22 - endpoint := fs.String("endpoint", "", "endpoint to send the WHEP request to") 23 23 - err := fs.Parse(args) 24 24 - 25 25 - if err != nil { 26 26 - return err 27 27 - } 28 28 - 29 29 - ctx := context.Background() 30 30 - if *duration > 0 { 17 17 + func WHEP(ctx context.Context, count int, duration time.Duration, endpoint string) error { 18 18 + if duration > 0 { 31 19 var cancel context.CancelFunc 32 32 - ctx, cancel = context.WithTimeout(ctx, *duration) 20 20 + ctx, cancel = context.WithTimeout(ctx, duration) 33 21 defer cancel() 34 22 } 35 23 36 24 w := &WHEPClient{ 37 37 - Endpoint: *endpoint, 38 38 - Count: *count, 25 25 + Endpoint: endpoint, 26 26 + Count: count, 39 27 } 40 28 41 29 return w.WHEP(ctx)

+10 -24

pkg/cmd/whip.go

··· 2 2 3 3 import ( 4 4 "context" 5 5 - "flag" 6 5 "fmt" 7 6 "io" 8 7 "net/http" ··· 20 19 "stream.place/streamplace/pkg/media" 21 20 ) 22 21 23 23 - func WHIP(args []string) error { 24 24 - fs := flag.NewFlagSet("whip", flag.ExitOnError) 25 25 - streamKey := fs.String("stream-key", "", "stream key") 26 26 - count := fs.Int("count", 1, "number of concurrent streams (for load testing)") 27 27 - viewers := fs.Int("viewers", 0, "number of viewers to simulate per stream") 28 28 - duration := fs.Duration("duration", 0, "duration of the stream") 29 29 - file := fs.String("file", "", "file to stream (needs to be an MP4 containing H264 video and Opus audio)") 30 30 - endpoint := fs.String("endpoint", "http://127.0.0.1:38080", "endpoint to send the WHIP request to") 31 31 - freezeAfter := fs.Duration("freeze-after", 0, "freeze the stream after the given duration") 32 32 - err := fs.Parse(args) 33 33 - if *file == "" { 22 22 + func WHIP(ctx context.Context, streamKey string, count int, viewers int, duration time.Duration, file string, endpoint string, freezeAfter time.Duration) error { 23 23 + if file == "" { 34 24 return fmt.Errorf("file is required") 35 35 - } 36 36 - if err != nil { 37 37 - return err 38 25 } 39 26 gstinit.InitGST() 40 27 41 41 - ctx := context.Background() 42 42 - if *duration > 0 { 28 28 + if duration > 0 { 43 29 var cancel context.CancelFunc 44 44 - ctx, cancel = context.WithTimeout(ctx, *duration) 30 30 + ctx, cancel = context.WithTimeout(ctx, duration) 45 31 defer cancel() 46 32 } 47 33 48 34 w := &WHIPClient{ 49 49 - StreamKey: *streamKey, 50 50 - File: *file, 51 51 - Endpoint: *endpoint, 52 52 - Count: *count, 53 53 - FreezeAfter: *freezeAfter, 54 54 - Viewers: *viewers, 35 35 + StreamKey: streamKey, 36 36 + File: file, 37 37 + Endpoint: endpoint, 38 38 + Count: count, 39 39 + FreezeAfter: freezeAfter, 40 40 + Viewers: viewers, 55 41 } 56 42 57 43 return w.WHIP(ctx)

+727 -231

pkg/config/config.go

··· 14 14 "os" 15 15 "path/filepath" 16 16 "runtime" 17 17 + "slices" 17 18 "strconv" 18 19 "strings" 19 20 "time" ··· 24 25 "github.com/livepeer/go-livepeer/cmd/livepeer/starter" 25 26 "github.com/lmittmann/tint" 26 27 slogGorm "github.com/orandin/slog-gorm" 27 27 - "github.com/peterbourgon/ff/v3" 28 28 + urfavecli "github.com/urfave/cli/v3" 28 29 "stream.place/streamplace/pkg/aqtime" 29 30 "stream.place/streamplace/pkg/constants" 30 31 "stream.place/streamplace/pkg/crypto/aqpub" ··· 160 161 ReplicatorIroh string = "iroh" 161 162 ) 162 163 163 163 - func (cli *CLI) NewFlagSet(name string) *flag.FlagSet { 164 164 - fs := flag.NewFlagSet("streamplace", flag.ExitOnError) 165 165 - fs.StringVar(&cli.DataDir, "data-dir", DefaultDataDir(), "directory for keeping all streamplace data") 166 166 - fs.StringVar(&cli.HTTPAddr, "http-addr", ":38080", "Public HTTP address") 167 167 - fs.StringVar(&cli.HTTPInternalAddr, "http-internal-addr", "127.0.0.1:39090", "Private, admin-only HTTP address") 168 168 - fs.StringVar(&cli.HTTPSAddr, "https-addr", ":38443", "Public HTTPS address") 169 169 - fs.BoolVar(&cli.Secure, "secure", false, "Run with HTTPS. Required for WebRTC output") 170 170 - cli.DataDirFlag(fs, &cli.TLSCertPath, "tls-cert", filepath.Join("tls", "tls.crt"), "Path to TLS certificate") 171 171 - cli.DataDirFlag(fs, &cli.TLSKeyPath, "tls-key", filepath.Join("tls", "tls.key"), "Path to TLS key") 172 172 - fs.StringVar(&cli.SigningKeyPath, "signing-key", "", "Path to signing key for pushing OTA updates to the app") 173 173 - fs.StringVar(&cli.DBURL, "db-url", "sqlite://$SP_DATA_DIR/state.sqlite", "URL of the database to use for storing private streamplace state") 174 174 - cli.dataDirFlags = append(cli.dataDirFlags, &cli.DBURL) 175 175 - fs.StringVar(&cli.AdminAccount, "admin-account", "", "ethereum account that administrates this streamplace node") 176 176 - fs.StringVar(&cli.FirebaseServiceAccount, "firebase-service-account", "", "Base64-encoded JSON string of a firebase service account key") 177 177 - fs.StringVar(&cli.FirebaseServiceAccountFile, "firebase-service-account-file", "", "Path to a JSON file containing a firebase service account key") 178 178 - fs.StringVar(&cli.GitLabURL, "gitlab-url", "https://git.stream.place/api/v4/projects/1", "gitlab url for generating download links") 179 179 - cli.DataDirFlag(fs, &cli.EthKeystorePath, "eth-keystore-path", "keystore", "path to ethereum keystore") 180 180 - fs.StringVar(&cli.EthAccountAddr, "eth-account-addr", "", "ethereum account address to use (if keystore contains more than one)") 181 181 - fs.StringVar(&cli.EthPassword, "eth-password", "", "password for encrypting keystore") 182 182 - fs.StringVar(&cli.TAURL, "ta-url", "http://timestamp.digicert.com", "timestamp authority server for signing") 183 183 - fs.StringVar(&cli.PKCS11ModulePath, "pkcs11-module-path", "", "path to a PKCS11 module for HSM signing, for example /usr/lib/x86_64-linux-gnu/opensc-pkcs11.so") 184 184 - fs.StringVar(&cli.PKCS11Pin, "pkcs11-pin", "", "PIN for logging into PKCS11 token. if not provided, will be prompted interactively") 185 185 - fs.StringVar(&cli.PKCS11TokenSlot, "pkcs11-token-slot", "", "slot number of PKCS11 token (only use one of slot, label, or serial)") 186 186 - fs.StringVar(&cli.PKCS11TokenLabel, "pkcs11-token-label", "", "label of PKCS11 token (only use one of slot, label, or serial)") 187 187 - fs.StringVar(&cli.PKCS11TokenSerial, "pkcs11-token-serial", "", "serial number of PKCS11 token (only use one of slot, label, or serial)") 188 188 - fs.StringVar(&cli.PKCS11KeypairLabel, "pkcs11-keypair-label", "", "label of signing keypair on PKCS11 token") 189 189 - fs.StringVar(&cli.PKCS11KeypairID, "pkcs11-keypair-id", "", "id of signing keypair on PKCS11 token") 190 190 - fs.StringVar(&cli.AppBundleID, "app-bundle-id", "", "bundle id of an app that we facilitate oauth login for") 191 191 - fs.StringVar(&cli.StreamerName, "streamer-name", "", "name of the person streaming from this streamplace node") 192 192 - fs.StringVar(&cli.FrontendProxy, "dev-frontend-proxy", "", "(FOR DEVELOPMENT ONLY) proxy frontend requests to this address instead of using the bundled frontend") 193 193 - fs.BoolVar(&cli.PublicOAuth, "dev-public-oauth", false, "(FOR DEVELOPMENT ONLY) enable public oauth login for http://127.0.0.1 development") 194 194 - fs.StringVar(&cli.LivepeerGatewayURL, "livepeer-gateway-url", "", "URL of the Livepeer Gateway to use for transcoding") 195 195 - fs.BoolVar(&cli.LivepeerGateway, "livepeer-gateway", false, "enable embedded Livepeer Gateway") 196 196 - fs.BoolVar(&cli.WideOpen, "wide-open", false, "allow ALL streams to be uploaded to this node (not recommended for production)") 197 197 - cli.StringSliceFlag(fs, &cli.AllowedStreams, "allowed-streams", []string{}, "if set, only allow these addresses or atproto DIDs to upload to this node") 198 198 - cli.StringSliceFlag(fs, &cli.Peers, "peers", []string{}, "other streamplace nodes to replicate to") 199 199 - cli.StringSliceFlag(fs, &cli.Redirects, "redirects", []string{}, "http 302s /path/one:/path/two,/path/three:/path/four") 200 200 - cli.DebugFlag(fs, &cli.Debug, "debug", "", "modified log verbosity for specific functions or files in form func=ToHLS:3,file=gstreamer.go:4") 201 201 - fs.BoolVar(&cli.TestStream, "test-stream", false, "run a built-in test stream on boot") 202 202 - fs.BoolVar(&cli.NoFirehose, "no-firehose", false, "disable the bluesky firehose") 203 203 - fs.BoolVar(&cli.PrintChat, "print-chat", false, "print chat messages to stdout") 204 204 - fs.StringVar(&cli.WHIPTest, "whip-test", "", "run a WHIP self-test with the given parameters") 205 205 - fs.StringVar(&cli.RelayHost, "relay-host", "wss://bsky.network", "websocket url for relay firehose") 206 206 - fs.StringVar(&cli.Color, "color", "", "'true' to enable colorized logging, 'false' to disable") 207 207 - fs.StringVar(&cli.BroadcasterHost, "broadcaster-host", "", "public host for the broadcaster group that this node is a part of (excluding https:// e.g. stream.place)") 208 208 - fs.StringVar(&cli.XXDeprecatedPublicHost, "public-host", "", "deprecated, use broadcaster-host or server-host instead as appropriate") 209 209 - fs.StringVar(&cli.ServerHost, "server-host", "", "public host for this particular physical streamplace node. defaults to broadcaster-host and only must be set for multi-node broadcasters") 210 210 - fs.BoolVar(&cli.Thumbnail, "thumbnail", true, "enable thumbnail generation") 211 211 - fs.BoolVar(&cli.SmearAudio, "smear-audio", false, "enable audio smearing to create 'perfect' segment timestamps") 164 164 + var LivepeerFlagSet *flag.FlagSet 165 165 + var LivepeerConfig starter.LivepeerConfig 212 166 213 213 - fs.StringVar(&cli.TracingEndpoint, "tracing-endpoint", "", "gRPC endpoint to send traces to") 214 214 - fs.IntVar(&cli.RateLimitPerSecond, "rate-limit-per-second", 0, "rate limit for requests per second per ip") 215 215 - fs.IntVar(&cli.RateLimitBurst, "rate-limit-burst", 0, "rate limit burst for requests per ip") 216 216 - fs.IntVar(&cli.RateLimitWebsocket, "rate-limit-websocket", 10, "number of concurrent websocket connections allowed per ip") 217 217 - fs.StringVar(&cli.RTMPServerAddon, "rtmp-server-addon", "", "address of external RTMP server to forward streams to") 218 218 - fs.StringVar(&cli.RTMPSAddonAddr, "rtmps-addon-addr", ":1936", "address to listen for RTMPS on the addon server") 219 219 - fs.StringVar(&cli.RTMPSAddr, "rtmps-addr", ":1935", "address to listen for RTMPS connections (when --secure=true)") 220 220 - fs.StringVar(&cli.RTMPAddr, "rtmp-addr", ":1935", "address to listen for RTMP connections (when --secure=false)") 221 221 - cli.JSONFlag(fs, &cli.DiscordWebhooks, "discord-webhooks", "[]", "JSON array of Discord webhooks to send notifications to") 222 222 - fs.BoolVar(&cli.NewWebRTCPlayback, "new-webrtc-playback", true, "enable new webrtc playback") 223 223 - fs.StringVar(&cli.AppleTeamID, "apple-team-id", "", "apple team id for deep linking") 224 224 - fs.StringVar(&cli.AndroidCertFingerprint, "android-cert-fingerprint", "", "android cert fingerprint for deep linking") 225 225 - cli.StringSliceFlag(fs, &cli.Labelers, "labelers", []string{}, "did of labelers that this instance should subscribe to") 226 226 - fs.StringVar(&cli.AtprotoDID, "atproto-did", "", "atproto did to respond to on /.well-known/atproto-did (default did:web:PUBLIC_HOST)") 227 227 - cli.JSONFlag(fs, &cli.ContentFilters, "content-filters", "{}", "JSON content filtering rules") 228 228 - cli.StringSliceFlag(fs, &cli.DefaultRecommendedStreamers, "default-recommended-streamers", []string{}, "comma-separated list of streamer DIDs to recommend by default when no other recommendations are available") 229 229 - fs.BoolVar(&cli.LivepeerHelp, "livepeer-help", false, "print help for livepeer flags and exit") 230 230 - fs.StringVar(&cli.PLCURL, "plc-url", "https://plc.directory", "url of the plc directory") 231 231 - fs.BoolVar(&cli.SQLLogging, "sql-logging", false, "enable sql logging") 232 232 - fs.StringVar(&cli.SentryDSN, "sentry-dsn", "", "sentry dsn for error reporting") 233 233 - fs.BoolVar(&cli.LivepeerDebug, "livepeer-debug", false, "log livepeer segments to $SP_DATA_DIR/livepeer-debug") 234 234 - fs.StringVar(&cli.SegmentDebugDir, "segment-debug-dir", "", "directory to log segment validation to") 235 235 - cli.StringSliceFlag(fs, &cli.Tickets, "tickets", []string{}, "tickets to join the swarm with") 236 236 - fs.StringVar(&cli.IrohTopic, "iroh-topic", "", "topic to use for the iroh swarm (must be 32 bytes in hex)") 237 237 - fs.BoolVar(&cli.DisableIrohRelay, "disable-iroh-relay", false, "disable the iroh relay") 238 238 - cli.KVSliceFlag(fs, &cli.DevAccountCreds, "dev-account-creds", "", "(FOR DEVELOPMENT ONLY) did=password pairs for logging into test accounts without oauth") 239 239 - fs.DurationVar(&cli.StreamSessionTimeout, "stream-session-timeout", 60*time.Second, "how long to wait before considering a stream inactive on this node?") 240 240 - cli.StringSliceFlag(fs, &cli.Replicators, "replicators", []string{ReplicatorWebsocket}, "list of replication protocols to use (http, iroh)") 241 241 - fs.StringVar(&cli.WebsocketURL, "websocket-url", "", "override the websocket (ws:// or wss://) url to use for replication (normally not necessary, used for testing)") 242 242 - fs.BoolVar(&cli.BehindHTTPSProxy, "behind-https-proxy", false, "set to true if this node is behind an https proxy and we should report https URLs even though the node isn't serving HTTPS") 243 243 - cli.StringSliceFlag(fs, &cli.AdminDIDs, "admin-dids", []string{}, "comma-separated list of DIDs that are authorized to modify branding and other admin operations") 244 244 - cli.StringSliceFlag(fs, &cli.Syndicate, "syndicate", []string{}, "list of DIDs that we should rebroadcast ('*' for everybody)") 245 245 - fs.BoolVar(&cli.PlayerTelemetry, "player-telemetry", true, "enable player telemetry") 246 246 - fs.StringVar(&cli.LocalDBURL, "local-db-url", "sqlite://$SP_DATA_DIR/localdb.sqlite", "URL of the local database to use for storing local data") 167 167 + func (cli *CLI) NewCommand(name string) *urfavecli.Command { 168 168 + cmd := &urfavecli.Command{ 169 169 + Name: name, 170 170 + Usage: "streamplace server", 171 171 + Flags: []urfavecli.Flag{ 172 172 + &urfavecli.StringFlag{ 173 173 + Name: "data-dir", 174 174 + Usage: "directory for keeping all streamplace data", 175 175 + Value: DefaultDataDir(), 176 176 + Destination: &cli.DataDir, 177 177 + Sources: urfavecli.EnvVars("SP_DATA_DIR"), 178 178 + }, 179 179 + &urfavecli.StringFlag{ 180 180 + Name: "http-addr", 181 181 + Usage: "Public HTTP address", 182 182 + Value: ":38080", 183 183 + Destination: &cli.HTTPAddr, 184 184 + Sources: urfavecli.EnvVars("SP_HTTP_ADDR"), 185 185 + }, 186 186 + &urfavecli.StringFlag{ 187 187 + Name: "http-internal-addr", 188 188 + Usage: "Private, admin-only HTTP address", 189 189 + Value: "127.0.0.1:39090", 190 190 + Destination: &cli.HTTPInternalAddr, 191 191 + Sources: urfavecli.EnvVars("SP_HTTP_INTERNAL_ADDR"), 192 192 + }, 193 193 + &urfavecli.StringFlag{ 194 194 + Name: "https-addr", 195 195 + Usage: "Public HTTPS address", 196 196 + Value: ":38443", 197 197 + Destination: &cli.HTTPSAddr, 198 198 + Sources: urfavecli.EnvVars("SP_HTTPS_ADDR"), 199 199 + }, 200 200 + &urfavecli.BoolFlag{ 201 201 + Name: "secure", 202 202 + Usage: "Run with HTTPS. Required for WebRTC output", 203 203 + Value: false, 204 204 + Destination: &cli.Secure, 205 205 + Sources: urfavecli.EnvVars("SP_SECURE"), 206 206 + }, 207 207 + &urfavecli.StringFlag{ 208 208 + Name: "tls-cert", 209 209 + Usage: fmt.Sprintf(`Path to TLS certificate (default: "%s")`, filepath.Join(SPDataDir, "tls", "tls.crt")), 210 210 + Destination: &cli.TLSCertPath, 211 211 + Value: filepath.Join(SPDataDir, "tls", "tls.crt"), 212 212 + Sources: urfavecli.EnvVars("SP_TLS_CERT"), 213 213 + }, 214 214 + &urfavecli.StringFlag{ 215 215 + Name: "tls-key", 216 216 + Usage: fmt.Sprintf(`Path to TLS key (default: "%s")`, filepath.Join(SPDataDir, "tls", "tls.key")), 217 217 + Destination: &cli.TLSKeyPath, 218 218 + Value: filepath.Join(SPDataDir, "tls", "tls.key"), 219 219 + Sources: urfavecli.EnvVars("SP_TLS_KEY"), 220 220 + }, 221 221 + &urfavecli.StringFlag{ 222 222 + Name: "signing-key", 223 223 + Usage: "Path to signing key for pushing OTA updates to the app", 224 224 + Destination: &cli.SigningKeyPath, 225 225 + Sources: urfavecli.EnvVars("SP_SIGNING_KEY"), 226 226 + }, 227 227 + &urfavecli.StringFlag{ 228 228 + Name: "db-url", 229 229 + Usage: "URL of the database to use for storing private streamplace state", 230 230 + Value: "sqlite://$SP_DATA_DIR/state.sqlite", 231 231 + Destination: &cli.DBURL, 232 232 + Sources: urfavecli.EnvVars("SP_DB_URL"), 233 233 + }, 234 234 + &urfavecli.StringFlag{ 235 235 + Name: "admin-account", 236 236 + Usage: "ethereum account that administrates this streamplace node", 237 237 + Destination: &cli.AdminAccount, 238 238 + Sources: urfavecli.EnvVars("SP_ADMIN_ACCOUNT"), 239 239 + }, 240 240 + &urfavecli.StringFlag{ 241 241 + Name: "firebase-service-account", 242 242 + Usage: "Base64-encoded JSON string of a firebase service account key", 243 243 + Destination: &cli.FirebaseServiceAccount, 244 244 + Sources: urfavecli.EnvVars("SP_FIREBASE_SERVICE_ACCOUNT"), 245 245 + }, 246 246 + &urfavecli.StringFlag{ 247 247 + Name: "firebase-service-account-file", 248 248 + Usage: "Path to a JSON file containing a firebase service account key", 249 249 + Destination: &cli.FirebaseServiceAccountFile, 250 250 + Sources: urfavecli.EnvVars("SP_FIREBASE_SERVICE_ACCOUNT_FILE"), 251 251 + }, 252 252 + &urfavecli.StringFlag{ 253 253 + Name: "gitlab-url", 254 254 + Usage: "gitlab url for generating download links", 255 255 + Value: "https://git.stream.place/api/v4/projects/1", 256 256 + Destination: &cli.GitLabURL, 257 257 + Sources: urfavecli.EnvVars("SP_GITLAB_URL"), 258 258 + }, 259 259 + &urfavecli.StringFlag{ 260 260 + Name: "eth-keystore-path", 261 261 + Usage: fmt.Sprintf(`path to ethereum keystore (default: "%s")`, filepath.Join(SPDataDir, "keystore")), 262 262 + Destination: &cli.EthKeystorePath, 263 263 + Value: filepath.Join(SPDataDir, "keystore"), 264 264 + Sources: urfavecli.EnvVars("SP_ETH_KEYSTORE_PATH"), 265 265 + }, 266 266 + &urfavecli.StringFlag{ 267 267 + Name: "eth-account-addr", 268 268 + Usage: "ethereum account address to use (if keystore contains more than one)", 269 269 + Destination: &cli.EthAccountAddr, 270 270 + Sources: urfavecli.EnvVars("SP_ETH_ACCOUNT_ADDR"), 271 271 + }, 272 272 + &urfavecli.StringFlag{ 273 273 + Name: "eth-password", 274 274 + Usage: "password for encrypting keystore", 275 275 + Destination: &cli.EthPassword, 276 276 + Sources: urfavecli.EnvVars("SP_ETH_PASSWORD"), 277 277 + }, 278 278 + &urfavecli.StringFlag{ 279 279 + Name: "ta-url", 280 280 + Usage: "timestamp authority server for signing", 281 281 + Value: "http://timestamp.digicert.com", 282 282 + Destination: &cli.TAURL, 283 283 + Sources: urfavecli.EnvVars("SP_TA_URL"), 284 284 + }, 285 285 + &urfavecli.StringFlag{ 286 286 + Name: "pkcs11-module-path", 287 287 + Usage: "path to a PKCS11 module for HSM signing, for example /usr/lib/x86_64-linux-gnu/opensc-pkcs11.so", 288 288 + Destination: &cli.PKCS11ModulePath, 289 289 + Sources: urfavecli.EnvVars("SP_PKCS11_MODULE_PATH"), 290 290 + }, 291 291 + &urfavecli.StringFlag{ 292 292 + Name: "pkcs11-pin", 293 293 + Usage: "PIN for logging into PKCS11 token. if not provided, will be prompted interactively", 294 294 + Destination: &cli.PKCS11Pin, 295 295 + Sources: urfavecli.EnvVars("SP_PKCS11_PIN"), 296 296 + }, 297 297 + &urfavecli.StringFlag{ 298 298 + Name: "pkcs11-token-slot", 299 299 + Usage: "slot number of PKCS11 token (only use one of slot, label, or serial)", 300 300 + Destination: &cli.PKCS11TokenSlot, 301 301 + Sources: urfavecli.EnvVars("SP_PKCS11_TOKEN_SLOT"), 302 302 + }, 303 303 + &urfavecli.StringFlag{ 304 304 + Name: "pkcs11-token-label", 305 305 + Usage: "label of PKCS11 token (only use one of slot, label, or serial)", 306 306 + Destination: &cli.PKCS11TokenLabel, 307 307 + Sources: urfavecli.EnvVars("SP_PKCS11_TOKEN_LABEL"), 308 308 + }, 309 309 + &urfavecli.StringFlag{ 310 310 + Name: "pkcs11-token-serial", 311 311 + Usage: "serial number of PKCS11 token (only use one of slot, label, or serial)", 312 312 + Destination: &cli.PKCS11TokenSerial, 313 313 + Sources: urfavecli.EnvVars("SP_PKCS11_TOKEN_SERIAL"), 314 314 + }, 315 315 + &urfavecli.StringFlag{ 316 316 + Name: "pkcs11-keypair-label", 317 317 + Usage: "label of signing keypair on PKCS11 token", 318 318 + Destination: &cli.PKCS11KeypairLabel, 319 319 + Sources: urfavecli.EnvVars("SP_PKCS11_KEYPAIR_LABEL"), 320 320 + }, 321 321 + &urfavecli.StringFlag{ 322 322 + Name: "pkcs11-keypair-id", 323 323 + Usage: "id of signing keypair on PKCS11 token", 324 324 + Destination: &cli.PKCS11KeypairID, 325 325 + Sources: urfavecli.EnvVars("SP_PKCS11_KEYPAIR_ID"), 326 326 + }, 327 327 + &urfavecli.StringFlag{ 328 328 + Name: "app-bundle-id", 329 329 + Usage: "bundle id of an app that we facilitate oauth login for", 330 330 + Destination: &cli.AppBundleID, 331 331 + Sources: urfavecli.EnvVars("SP_APP_BUNDLE_ID"), 332 332 + }, 333 333 + &urfavecli.StringFlag{ 334 334 + Name: "streamer-name", 335 335 + Usage: "name of the person streaming from this streamplace node", 336 336 + Destination: &cli.StreamerName, 337 337 + Sources: urfavecli.EnvVars("SP_STREAMER_NAME"), 338 338 + }, 339 339 + &urfavecli.StringFlag{ 340 340 + Name: "dev-frontend-proxy", 341 341 + Usage: "(FOR DEVELOPMENT ONLY) proxy frontend requests to this address instead of using the bundled frontend", 342 342 + Destination: &cli.FrontendProxy, 343 343 + Sources: urfavecli.EnvVars("SP_DEV_FRONTEND_PROXY"), 344 344 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 345 345 + if s == "false" { 346 346 + cli.FrontendProxy = "" 347 347 + return nil 348 348 + } 349 349 + cli.FrontendProxy = s 350 350 + return nil 351 351 + }, 352 352 + }, 353 353 + &urfavecli.BoolFlag{ 354 354 + Name: "dev-public-oauth", 355 355 + Usage: "(FOR DEVELOPMENT ONLY) enable public oauth login for http://127.0.0.1 development", 356 356 + Value: false, 357 357 + Destination: &cli.PublicOAuth, 358 358 + Sources: urfavecli.EnvVars("SP_DEV_PUBLIC_OAUTH"), 359 359 + }, 360 360 + &urfavecli.StringFlag{ 361 361 + Name: "livepeer-gateway-url", 362 362 + Usage: "URL of the Livepeer Gateway to use for transcoding", 363 363 + Destination: &cli.LivepeerGatewayURL, 364 364 + Sources: urfavecli.EnvVars("SP_LIVEPEER_GATEWAY_URL"), 365 365 + }, 366 366 + &urfavecli.BoolFlag{ 367 367 + Name: "livepeer-gateway", 368 368 + Usage: "enable embedded Livepeer Gateway", 369 369 + Value: false, 370 370 + Destination: &cli.LivepeerGateway, 371 371 + Sources: urfavecli.EnvVars("SP_LIVEPEER_GATEWAY"), 372 372 + }, 373 373 + &urfavecli.BoolFlag{ 374 374 + Name: "wide-open", 375 375 + Usage: "allow ALL streams to be uploaded to this node (not recommended for production)", 376 376 + Value: false, 377 377 + Destination: &cli.WideOpen, 378 378 + Sources: urfavecli.EnvVars("SP_WIDE_OPEN"), 379 379 + }, 380 380 + &urfavecli.StringFlag{ 381 381 + Name: "allowed-streams", 382 382 + Usage: `if set, only allow these addresses or atproto DIDs to upload to this node (default: "")`, 383 383 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 384 384 + if s == "" { 385 385 + return nil 386 386 + } 387 387 + cli.AllowedStreams = strings.Split(s, ",") 388 388 + return nil 389 389 + }, 390 390 + Sources: urfavecli.EnvVars("SP_ALLOWED_STREAMS"), 391 391 + }, 392 392 + &urfavecli.StringFlag{ 393 393 + Name: "peers", 394 394 + Usage: `other streamplace nodes to replicate to (default: "")`, 395 395 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 396 396 + if s == "" { 397 397 + return nil 398 398 + } 399 399 + cli.Peers = strings.Split(s, ",") 400 400 + return nil 401 401 + }, 402 402 + Sources: urfavecli.EnvVars("SP_PEERS"), 403 403 + }, 404 404 + &urfavecli.StringFlag{ 405 405 + Name: "redirects", 406 406 + Usage: `http 302s /path/one:/path/two,/path/three:/path/four (default: "")`, 407 407 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 408 408 + if s == "" { 409 409 + return nil 410 410 + } 411 411 + cli.Redirects = strings.Split(s, ",") 412 412 + return nil 413 413 + }, 414 414 + Sources: urfavecli.EnvVars("SP_REDIRECTS"), 415 415 + }, 416 416 + &urfavecli.StringFlag{ 417 417 + Name: "debug", 418 418 + Usage: "modified log verbosity for specific functions or files in form func=ToHLS:3,file=gstreamer.go:4", 419 419 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 420 420 + if s == "" { 421 421 + return nil 422 422 + } 423 423 + cli.Debug = map[string]map[string]int{} 424 424 + pairs := strings.SplitSeq(s, ",") 425 425 + for pair := range pairs { 426 426 + scoreSplit := strings.Split(pair, ":") 427 427 + if len(scoreSplit) != 2 { 428 428 + return fmt.Errorf("invalid debug flag: %s", pair) 429 429 + } 430 430 + score, err := strconv.Atoi(scoreSplit[1]) 431 431 + if err != nil { 432 432 + return fmt.Errorf("invalid debug flag: %s", pair) 433 433 + } 434 434 + selectorSplit := strings.Split(scoreSplit[0], "=") 435 435 + if len(selectorSplit) != 2 { 436 436 + return fmt.Errorf("invalid debug flag: %s", pair) 437 437 + } 438 438 + _, ok := cli.Debug[selectorSplit[0]] 439 439 + if !ok { 440 440 + cli.Debug[selectorSplit[0]] = map[string]int{} 441 441 + } 442 442 + cli.Debug[selectorSplit[0]][selectorSplit[1]] = score 443 443 + } 444 444 + return nil 445 445 + }, 446 446 + Sources: urfavecli.EnvVars("SP_DEBUG"), 447 447 + }, 448 448 + &urfavecli.BoolFlag{ 449 449 + Name: "test-stream", 450 450 + Usage: "run a built-in test stream on boot", 451 451 + Value: false, 452 452 + Destination: &cli.TestStream, 453 453 + Sources: urfavecli.EnvVars("SP_TEST_STREAM"), 454 454 + }, 455 455 + &urfavecli.BoolFlag{ 456 456 + Name: "no-firehose", 457 457 + Usage: "disable the bluesky firehose", 458 458 + Value: false, 459 459 + Destination: &cli.NoFirehose, 460 460 + Sources: urfavecli.EnvVars("SP_NO_FIREHOSE"), 461 461 + }, 462 462 + &urfavecli.BoolFlag{ 463 463 + Name: "print-chat", 464 464 + Usage: "print chat messages to stdout", 465 465 + Value: false, 466 466 + Destination: &cli.PrintChat, 467 467 + Sources: urfavecli.EnvVars("SP_PRINT_CHAT"), 468 468 + }, 469 469 + &urfavecli.StringFlag{ 470 470 + Name: "whip-test", 471 471 + Usage: "run a WHIP self-test with the given parameters", 472 472 + Destination: &cli.WHIPTest, 473 473 + Sources: urfavecli.EnvVars("SP_WHIP_TEST"), 474 474 + }, 475 475 + &urfavecli.StringFlag{ 476 476 + Name: "relay-host", 477 477 + Usage: "websocket url for relay firehose", 478 478 + Value: "wss://bsky.network", 479 479 + Destination: &cli.RelayHost, 480 480 + Sources: urfavecli.EnvVars("SP_RELAY_HOST"), 481 481 + }, 482 482 + &urfavecli.StringFlag{ 483 483 + Name: "color", 484 484 + Usage: "'true' to enable colorized logging, 'false' to disable", 485 485 + Destination: &cli.Color, 486 486 + Sources: urfavecli.EnvVars("SP_COLOR"), 487 487 + }, 488 488 + &urfavecli.StringFlag{ 489 489 + Name: "broadcaster-host", 490 490 + Usage: "public host for the broadcaster group that this node is a part of (excluding https:// e.g. stream.place)", 491 491 + Destination: &cli.BroadcasterHost, 492 492 + Sources: urfavecli.EnvVars("SP_BROADCASTER_HOST"), 493 493 + }, 494 494 + &urfavecli.StringFlag{ 495 495 + Name: "public-host", 496 496 + Usage: "deprecated, use broadcaster-host or server-host instead as appropriate", 497 497 + Destination: &cli.XXDeprecatedPublicHost, 498 498 + Sources: urfavecli.EnvVars("SP_PUBLIC_HOST"), 499 499 + }, 500 500 + &urfavecli.StringFlag{ 501 501 + Name: "server-host", 502 502 + Usage: "public host for this particular physical streamplace node. defaults to broadcaster-host and only must be set for multi-node broadcasters", 503 503 + Destination: &cli.ServerHost, 504 504 + Sources: urfavecli.EnvVars("SP_SERVER_HOST"), 505 505 + }, 506 506 + &urfavecli.BoolFlag{ 507 507 + Name: "thumbnail", 508 508 + Usage: "enable thumbnail generation", 509 509 + Value: true, 510 510 + Destination: &cli.Thumbnail, 511 511 + Sources: urfavecli.EnvVars("SP_THUMBNAIL"), 512 512 + }, 513 513 + &urfavecli.BoolFlag{ 514 514 + Name: "smear-audio", 515 515 + Usage: "enable audio smearing to create 'perfect' segment timestamps", 516 516 + Value: false, 517 517 + Destination: &cli.SmearAudio, 518 518 + Sources: urfavecli.EnvVars("SP_SMEAR_AUDIO"), 519 519 + }, 520 520 + &urfavecli.StringFlag{ 521 521 + Name: "tracing-endpoint", 522 522 + Usage: "gRPC endpoint to send traces to", 523 523 + Destination: &cli.TracingEndpoint, 524 524 + Sources: urfavecli.EnvVars("SP_TRACING_ENDPOINT"), 525 525 + }, 526 526 + &urfavecli.IntFlag{ 527 527 + Name: "rate-limit-per-second", 528 528 + Usage: "rate limit for requests per second per ip", 529 529 + Value: 0, 530 530 + Destination: &cli.RateLimitPerSecond, 531 531 + Sources: urfavecli.EnvVars("SP_RATE_LIMIT_PER_SECOND"), 532 532 + }, 533 533 + &urfavecli.IntFlag{ 534 534 + Name: "rate-limit-burst", 535 535 + Usage: "rate limit burst for requests per ip", 536 536 + Value: 0, 537 537 + Destination: &cli.RateLimitBurst, 538 538 + Sources: urfavecli.EnvVars("SP_RATE_LIMIT_BURST"), 539 539 + }, 540 540 + &urfavecli.IntFlag{ 541 541 + Name: "rate-limit-websocket", 542 542 + Usage: "number of concurrent websocket connections allowed per ip", 543 543 + Value: 10, 544 544 + Destination: &cli.RateLimitWebsocket, 545 545 + Sources: urfavecli.EnvVars("SP_RATE_LIMIT_WEBSOCKET"), 546 546 + }, 547 547 + &urfavecli.StringFlag{ 548 548 + Name: "rtmp-server-addon", 549 549 + Usage: "address of external RTMP server to forward streams to", 550 550 + Destination: &cli.RTMPServerAddon, 551 551 + Sources: urfavecli.EnvVars("SP_RTMP_SERVER_ADDON"), 552 552 + }, 553 553 + &urfavecli.StringFlag{ 554 554 + Name: "rtmps-addon-addr", 555 555 + Usage: "address to listen for RTMPS on the addon server", 556 556 + Value: ":1936", 557 557 + Destination: &cli.RTMPSAddonAddr, 558 558 + Sources: urfavecli.EnvVars("SP_RTMPS_ADDON_ADDR"), 559 559 + }, 560 560 + &urfavecli.StringFlag{ 561 561 + Name: "rtmps-addr", 562 562 + Usage: "address to listen for RTMPS connections (when --secure=true)", 563 563 + Value: ":1935", 564 564 + Destination: &cli.RTMPSAddr, 565 565 + Sources: urfavecli.EnvVars("SP_RTMPS_ADDR"), 566 566 + }, 567 567 + &urfavecli.StringFlag{ 568 568 + Name: "rtmp-addr", 569 569 + Usage: "address to listen for RTMP connections (when --secure=false)", 570 570 + Value: ":1935", 571 571 + Destination: &cli.RTMPAddr, 572 572 + Sources: urfavecli.EnvVars("SP_RTMP_ADDR"), 573 573 + }, 574 574 + &urfavecli.StringFlag{ 575 575 + Name: "discord-webhooks", 576 576 + Usage: `JSON array of Discord webhooks to send notifications to (default: "[]")`, 577 577 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 578 578 + if s == "" { 579 579 + return nil 580 580 + } 581 581 + return json.Unmarshal([]byte(s), &cli.DiscordWebhooks) 582 582 + }, 583 583 + Sources: urfavecli.EnvVars("SP_DISCORD_WEBHOOKS"), 584 584 + }, 585 585 + &urfavecli.BoolFlag{ 586 586 + Name: "new-webrtc-playback", 587 587 + Usage: "enable new webrtc playback", 588 588 + Value: true, 589 589 + Destination: &cli.NewWebRTCPlayback, 590 590 + Sources: urfavecli.EnvVars("SP_NEW_WEBRTC_PLAYBACK"), 591 591 + }, 592 592 + &urfavecli.StringFlag{ 593 593 + Name: "apple-team-id", 594 594 + Usage: "apple team id for deep linking", 595 595 + Destination: &cli.AppleTeamID, 596 596 + Sources: urfavecli.EnvVars("SP_APPLE_TEAM_ID"), 597 597 + }, 598 598 + &urfavecli.StringFlag{ 599 599 + Name: "android-cert-fingerprint", 600 600 + Usage: "android cert fingerprint for deep linking", 601 601 + Destination: &cli.AndroidCertFingerprint, 602 602 + Sources: urfavecli.EnvVars("SP_ANDROID_CERT_FINGERPRINT"), 603 603 + }, 604 604 + &urfavecli.StringFlag{ 605 605 + Name: "labelers", 606 606 + Usage: `did of labelers that this instance should subscribe to (default: "")`, 607 607 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 608 608 + if s == "" { 609 609 + return nil 610 610 + } 611 611 + cli.Labelers = strings.Split(s, ",") 612 612 + return nil 613 613 + }, 614 614 + Sources: urfavecli.EnvVars("SP_LABELERS"), 615 615 + }, 616 616 + &urfavecli.StringFlag{ 617 617 + Name: "atproto-did", 618 618 + Usage: "atproto did to respond to on /.well-known/atproto-did (default did:web:PUBLIC_HOST)", 619 619 + Destination: &cli.AtprotoDID, 620 620 + Sources: urfavecli.EnvVars("SP_ATPROTO_DID"), 621 621 + }, 622 622 + &urfavecli.StringFlag{ 623 623 + Name: "content-filters", 624 624 + Usage: `JSON content filtering rules (default: "{}")`, 625 625 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 626 626 + if s == "" { 627 627 + return nil 628 628 + } 629 629 + return json.Unmarshal([]byte(s), &cli.ContentFilters) 630 630 + }, 631 631 + Sources: urfavecli.EnvVars("SP_CONTENT_FILTERS"), 632 632 + }, 633 633 + &urfavecli.StringFlag{ 634 634 + Name: "default-recommended-streamers", 635 635 + Usage: `comma-separated list of streamer DIDs to recommend by default when no other recommendations are available (default: "")`, 636 636 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 637 637 + if s == "" { 638 638 + return nil 639 639 + } 640 640 + cli.DefaultRecommendedStreamers = strings.Split(s, ",") 641 641 + return nil 642 642 + }, 643 643 + Sources: urfavecli.EnvVars("SP_DEFAULT_RECOMMENDED_STREAMERS"), 644 644 + }, 645 645 + &urfavecli.BoolFlag{ 646 646 + Name: "livepeer-help", 647 647 + Usage: "print help for livepeer flags and exit", 648 648 + Value: false, 649 649 + Destination: &cli.LivepeerHelp, 650 650 + Sources: urfavecli.EnvVars("SP_LIVEPEER_HELP"), 651 651 + }, 652 652 + &urfavecli.StringFlag{ 653 653 + Name: "plc-url", 654 654 + Usage: "url of the plc directory", 655 655 + Value: "https://plc.directory", 656 656 + Destination: &cli.PLCURL, 657 657 + Sources: urfavecli.EnvVars("SP_PLC_URL"), 658 658 + }, 659 659 + &urfavecli.BoolFlag{ 660 660 + Name: "sql-logging", 661 661 + Usage: "enable sql logging", 662 662 + Value: false, 663 663 + Destination: &cli.SQLLogging, 664 664 + Sources: urfavecli.EnvVars("SP_SQL_LOGGING"), 665 665 + }, 666 666 + &urfavecli.StringFlag{ 667 667 + Name: "sentry-dsn", 668 668 + Usage: "sentry dsn for error reporting", 669 669 + Destination: &cli.SentryDSN, 670 670 + Sources: urfavecli.EnvVars("SP_SENTRY_DSN"), 671 671 + }, 672 672 + &urfavecli.BoolFlag{ 673 673 + Name: "livepeer-debug", 674 674 + Usage: "log livepeer segments to $SP_DATA_DIR/livepeer-debug", 675 675 + Value: false, 676 676 + Destination: &cli.LivepeerDebug, 677 677 + Sources: urfavecli.EnvVars("SP_LIVEPEER_DEBUG"), 678 678 + }, 679 679 + &urfavecli.StringFlag{ 680 680 + Name: "segment-debug-dir", 681 681 + Usage: "directory to log segment validation to", 682 682 + Destination: &cli.SegmentDebugDir, 683 683 + Sources: urfavecli.EnvVars("SP_SEGMENT_DEBUG_DIR"), 684 684 + }, 685 685 + &urfavecli.StringFlag{ 686 686 + Name: "tickets", 687 687 + Usage: `tickets to join the swarm with (default: "")`, 688 688 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 689 689 + if s == "" { 690 690 + return nil 691 691 + } 692 692 + cli.Tickets = strings.Split(s, ",") 693 693 + return nil 694 694 + }, 695 695 + Sources: urfavecli.EnvVars("SP_TICKETS"), 696 696 + }, 697 697 + &urfavecli.StringFlag{ 698 698 + Name: "iroh-topic", 699 699 + Usage: "topic to use for the iroh swarm (must be 32 bytes in hex)", 700 700 + Destination: &cli.IrohTopic, 701 701 + Sources: urfavecli.EnvVars("SP_IROH_TOPIC"), 702 702 + }, 703 703 + &urfavecli.BoolFlag{ 704 704 + Name: "disable-iroh-relay", 705 705 + Usage: "disable the iroh relay", 706 706 + Value: false, 707 707 + Destination: &cli.DisableIrohRelay, 708 708 + Sources: urfavecli.EnvVars("SP_DISABLE_IROH_RELAY"), 709 709 + }, 710 710 + &urfavecli.StringFlag{ 711 711 + Name: "dev-account-creds", 712 712 + Usage: `(FOR DEVELOPMENT ONLY) did=password pairs for logging into test accounts without oauth (default: "")`, 713 713 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 714 714 + if s == "" { 715 715 + return nil 716 716 + } 717 717 + cli.DevAccountCreds = map[string]string{} 718 718 + pairs := strings.Split(s, ",") 719 719 + for _, pair := range pairs { 720 720 + parts := strings.Split(pair, "=") 721 721 + if len(parts) != 2 { 722 722 + return fmt.Errorf("invalid kv flag: %s", pair) 723 723 + } 724 724 + cli.DevAccountCreds[parts[0]] = parts[1] 725 725 + } 726 726 + return nil 727 727 + }, 728 728 + Sources: urfavecli.EnvVars("SP_DEV_ACCOUNT_CREDS"), 729 729 + }, 730 730 + &urfavecli.DurationFlag{ 731 731 + Name: "stream-session-timeout", 732 732 + Usage: "how long to wait before considering a stream inactive on this node?", 733 733 + Value: 60 * time.Second, 734 734 + Destination: &cli.StreamSessionTimeout, 735 735 + Sources: urfavecli.EnvVars("SP_STREAM_SESSION_TIMEOUT"), 736 736 + }, 737 737 + &urfavecli.StringFlag{ 738 738 + Name: "replicators", 739 739 + Usage: "comma-separated list of replication protocols to use (websocket, iroh)", 740 740 + Value: ReplicatorWebsocket, 741 741 + Sources: urfavecli.EnvVars("SP_REPLICATORS"), 742 742 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 743 743 + if s != "" { 744 744 + cli.Replicators = strings.Split(s, ",") 745 745 + } 746 746 + return nil 747 747 + }, 748 748 + }, 749 749 + &urfavecli.StringFlag{ 750 750 + Name: "websocket-url", 751 751 + Usage: "override the websocket (ws:// or wss://) url to use for replication (normally not necessary, used for testing)", 752 752 + Destination: &cli.WebsocketURL, 753 753 + Sources: urfavecli.EnvVars("SP_WEBSOCKET_URL"), 754 754 + }, 755 755 + &urfavecli.BoolFlag{ 756 756 + Name: "behind-https-proxy", 757 757 + Usage: "set to true if this node is behind an https proxy and we should report https URLs even though the node isn't serving HTTPS", 758 758 + Value: false, 759 759 + Destination: &cli.BehindHTTPSProxy, 760 760 + Sources: urfavecli.EnvVars("SP_BEHIND_HTTPS_PROXY"), 761 761 + }, 762 762 + &urfavecli.StringFlag{ 763 763 + Name: "admin-dids", 764 764 + Usage: `comma-separated list of DIDs that are authorized to modify branding and other admin operations (default: "")`, 765 765 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 766 766 + if s == "" { 767 767 + return nil 768 768 + } 769 769 + cli.AdminDIDs = strings.Split(s, ",") 770 770 + return nil 771 771 + }, 772 772 + Sources: urfavecli.EnvVars("SP_ADMIN_DIDS"), 773 773 + }, 774 774 + &urfavecli.StringFlag{ 775 775 + Name: "syndicate", 776 776 + Usage: `list of DIDs that we should rebroadcast ('*' for everybody) (default: "")`, 777 777 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 778 778 + if s == "" { 779 779 + return nil 780 780 + } 781 781 + cli.Syndicate = strings.Split(s, ",") 782 782 + return nil 783 783 + }, 784 784 + Sources: urfavecli.EnvVars("SP_SYNDICATE"), 785 785 + }, 786 786 + &urfavecli.BoolFlag{ 787 787 + Name: "player-telemetry", 788 788 + Usage: "enable player telemetry", 789 789 + Value: true, 790 790 + Destination: &cli.PlayerTelemetry, 791 791 + Sources: urfavecli.EnvVars("SP_PLAYER_TELEMETRY"), 792 792 + }, 793 793 + &urfavecli.StringFlag{ 794 794 + Name: "local-db-url", 795 795 + Usage: "URL of the local database to use for storing local data", 796 796 + Value: "sqlite://$SP_DATA_DIR/localdb.sqlite", 797 797 + Destination: &cli.LocalDBURL, 798 798 + Sources: urfavecli.EnvVars("SP_LOCAL_DB_URL"), 799 799 + }, 800 800 + &urfavecli.BoolFlag{ 801 801 + Name: "external-signing", 802 802 + Usage: "DEPRECATED, does nothing.", 803 803 + Value: true, 804 804 + }, 805 805 + &urfavecli.BoolFlag{ 806 806 + Name: "insecure", 807 807 + Usage: "DEPRECATED, does nothing.", 808 808 + Value: false, 809 809 + }, 810 810 + }, 811 811 + Before: func(ctx context.Context, cmd *urfavecli.Command) (context.Context, error) { 812 812 + return ctx, cli.Validate(cmd) 813 813 + }, 814 814 + } 815 815 + 816 816 + // Add data dir flags 817 817 + cli.dataDirFlags = append(cli.dataDirFlags, &cli.DBURL) 247 818 cli.dataDirFlags = append(cli.dataDirFlags, &cli.LocalDBURL) 819 819 + cli.dataDirFlags = append(cli.dataDirFlags, &cli.TLSCertPath) 820 820 + cli.dataDirFlags = append(cli.dataDirFlags, &cli.TLSKeyPath) 821 821 + cli.dataDirFlags = append(cli.dataDirFlags, &cli.EthKeystorePath) 248 822 249 249 - fs.Bool("external-signing", true, "DEPRECATED, does nothing.") 250 250 - fs.Bool("insecure", false, "DEPRECATED, does nothing.") 823 823 + if runtime.GOOS == "linux" { 824 824 + cmd.Flags = append(cmd.Flags, &urfavecli.BoolFlag{ 825 825 + Name: "no-mist", 826 826 + Usage: "Disable MistServer", 827 827 + Value: true, 828 828 + Destination: &cli.NoMist, 829 829 + Sources: urfavecli.EnvVars("SP_NO_MIST"), 830 830 + }) 831 831 + cmd.Flags = append(cmd.Flags, &urfavecli.IntFlag{ 832 832 + Name: "mist-admin-port", 833 833 + Usage: "MistServer admin port (internal use only)", 834 834 + Value: 14242, 835 835 + Destination: &cli.MistAdminPort, 836 836 + Sources: urfavecli.EnvVars("SP_MIST_ADMIN_PORT"), 837 837 + }) 838 838 + cmd.Flags = append(cmd.Flags, &urfavecli.IntFlag{ 839 839 + Name: "mist-rtmp-port", 840 840 + Usage: "MistServer RTMP port (internal use only)", 841 841 + Value: 11935, 842 842 + Destination: &cli.MistRTMPPort, 843 843 + Sources: urfavecli.EnvVars("SP_MIST_RTMP_PORT"), 844 844 + }) 845 845 + cmd.Flags = append(cmd.Flags, &urfavecli.IntFlag{ 846 846 + Name: "mist-http-port", 847 847 + Usage: "MistServer HTTP port (internal use only)", 848 848 + Value: 18080, 849 849 + Destination: &cli.MistHTTPPort, 850 850 + Sources: urfavecli.EnvVars("SP_MIST_HTTP_PORT"), 851 851 + }) 852 852 + } 251 853 252 252 - lpFlags := flag.NewFlagSet("livepeer", flag.ContinueOnError) 253 253 - _ = starter.NewLivepeerConfig(lpFlags) 254 254 - lpFlags.VisitAll(func(f *flag.Flag) { 854 854 + LivepeerFlagSet = flag.NewFlagSet("livepeer", flag.ContinueOnError) 855 855 + LivepeerConfig = starter.NewLivepeerConfig(LivepeerFlagSet) 856 856 + LivepeerFlagSet.VisitAll(func(f *flag.Flag) { 255 857 adapted := LivepeerFlags.CamelToSnake[f.Name] 256 256 - fs.Var(f.Value, fmt.Sprintf("livepeer.%s", adapted), f.Usage) 858 858 + cmd.Flags = append(cmd.Flags, &urfavecli.StringFlag{ 859 859 + Name: fmt.Sprintf("livepeer.%s", adapted), 860 860 + Usage: f.Usage, 861 861 + Sources: urfavecli.EnvVars(fmt.Sprintf("SP_LIVEPEER_%s", adapted)), 862 862 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 863 863 + return LivepeerFlagSet.Set(f.Name, s) 864 864 + }, 865 865 + }) 257 866 }) 258 867 259 259 - if runtime.GOOS == "linux" { 260 260 - fs.BoolVar(&cli.NoMist, "no-mist", true, "Disable MistServer") 261 261 - fs.IntVar(&cli.MistAdminPort, "mist-admin-port", 14242, "MistServer admin port (internal use only)") 262 262 - fs.IntVar(&cli.MistRTMPPort, "mist-rtmp-port", 11935, "MistServer RTMP port (internal use only)") 263 263 - fs.IntVar(&cli.MistHTTPPort, "mist-http-port", 18080, "MistServer HTTP port (internal use only)") 264 264 - } 265 265 - return fs 868 868 + return cmd 266 869 } 267 870 268 871 var StreamplaceSchemePrefix = "streamplace://" ··· 350 953 ) 351 954 } 352 955 353 353 - func (cli *CLI) Parse(fs *flag.FlagSet, args []string) error { 354 354 - err := ff.Parse( 355 355 - fs, args, 356 356 - ff.WithEnvVarPrefix("SP"), 357 357 - ) 358 358 - if err != nil { 359 359 - return err 360 360 - } 956 956 + func (cli *CLI) Validate(cmd *urfavecli.Command) error { 361 957 if cli.DataDir == "" { 362 958 return fmt.Errorf("could not determine default data dir (no $HOME) and none provided, please set --data-dir") 363 959 } ··· 366 962 } 367 963 if cli.LivepeerGateway { 368 964 log.MonkeypatchStderr() 369 369 - gatewayPath := cli.DataFilePath([]string{"livepeer", "gateway"}) 370 370 - err = fs.Set("livepeer.rtmp-addr", "127.0.0.1:0") 371 371 - if err != nil { 372 372 - return err 373 373 - } 374 374 - err = fs.Set("livepeer.data-dir", gatewayPath) 375 375 - if err != nil { 376 376 - return err 377 377 - } 378 378 - err = fs.Set("livepeer.gateway", "true") 379 379 - if err != nil { 380 380 - return err 381 381 - } 382 382 - httpAddrFlag := fs.Lookup("livepeer.http-addr") 383 383 - if httpAddrFlag == nil { 384 384 - return fmt.Errorf("livepeer.http-addr not found") 385 385 - } 386 386 - httpAddr := httpAddrFlag.Value.String() 387 387 - if httpAddr == "" { 388 388 - httpAddr = "127.0.0.1:8935" 389 389 - err = fs.Set("livepeer.http-addr", httpAddr) 390 390 - if err != nil { 391 391 - return err 392 392 - } 393 393 - } 394 394 - cli.LivepeerGatewayURL = fmt.Sprintf("http://%s", httpAddr) 965 965 + // Livepeer gateway configuration will be handled in the caller 966 966 + cli.LivepeerGatewayURL = "http://127.0.0.1:8935" 395 967 } 396 968 for _, dest := range cli.dataDirFlags { 397 969 *dest = strings.Replace(*dest, SPDataDir, cli.DataDir, 1) ··· 420 992 return err 421 993 } 422 994 cli.FirebaseServiceAccount = string(bs) 995 995 + } 996 996 + // Set default replicator if none specified 997 997 + if len(cli.Replicators) == 0 { 998 998 + cli.Replicators = []string{ReplicatorWebsocket} 423 999 } 424 1000 return nil 425 1001 } ··· 529 1105 return nil 530 1106 } 531 1107 532 532 - func (cli *CLI) DataDirFlag(fs *flag.FlagSet, dest *string, name, defaultValue, usage string) { 533 533 - cli.dataDirFlags = append(cli.dataDirFlags, dest) 534 534 - *dest = filepath.Join(SPDataDir, defaultValue) 535 535 - usage = fmt.Sprintf(`%s (default: "%s")`, usage, *dest) 536 536 - fs.Func(name, usage, func(s string) error { 537 537 - *dest = s 538 538 - return nil 539 539 - }) 540 540 - } 541 541 - 542 1108 func (cli *CLI) HasMist() bool { 543 1109 return runtime.GOOS == "linux" 544 1110 } 545 1111 546 1112 // type for comma-separated ethereum addresses 547 547 - func (cli *CLI) AddressSliceFlag(fs *flag.FlagSet, dest *[]aqpub.Pub, name, defaultValue, usage string) { 1113 1113 + func (cli *CLI) AddressSliceFlag(name, defaultValue, usage string, dest *[]aqpub.Pub) urfavecli.Flag { 548 1114 *dest = []aqpub.Pub{} 549 549 - usage = fmt.Sprintf(`%s (default: "%s")`, usage, *dest) 550 550 - fs.Func(name, usage, func(s string) error { 551 551 - if s == "" { 552 552 - return nil 553 553 - } 554 554 - strs := strings.Split(s, ",") 555 555 - for _, str := range strs { 556 556 - pub, err := aqpub.FromHexString(str) 557 557 - if err != nil { 558 558 - return err 559 559 - } 560 560 - *dest = append(*dest, pub) 561 561 - } 562 562 - return nil 563 563 - }) 564 564 - } 565 565 - 566 566 - func (cli *CLI) StringSliceFlag(fs *flag.FlagSet, dest *[]string, name string, defaultValue []string, usage string) { 567 567 - *dest = defaultValue 568 568 - usage = fmt.Sprintf(`%s (default: "%s")`, usage, *dest) 569 569 - fs.Func(name, usage, func(s string) error { 570 570 - if s == "" { 571 571 - return nil 572 572 - } 573 573 - strs := strings.Split(s, ",") 574 574 - *dest = append([]string{}, strs...) 575 575 - return nil 576 576 - }) 577 577 - } 578 578 - 579 579 - func (cli *CLI) KVSliceFlag(fs *flag.FlagSet, dest *map[string]string, name, defaultValue, usage string) { 580 580 - *dest = map[string]string{} 581 581 - usage = fmt.Sprintf(`%s (default: "%s")`, usage, *dest) 582 582 - fs.Func(name, usage, func(s string) error { 583 583 - if s == "" { 584 584 - return nil 585 585 - } 586 586 - pairs := strings.Split(s, ",") 587 587 - for _, pair := range pairs { 588 588 - parts := strings.Split(pair, "=") 589 589 - if len(parts) != 2 { 590 590 - return fmt.Errorf("invalid kv flag: %s", pair) 591 591 - } 592 592 - (*dest)[parts[0]] = parts[1] 593 593 - } 594 594 - return nil 595 595 - }) 596 596 - } 597 597 - 598 598 - func (cli *CLI) JSONFlag(fs *flag.FlagSet, dest any, name, defaultValue, usage string) { 599 1115 usage = fmt.Sprintf(`%s (default: "%s")`, usage, defaultValue) 600 600 - fs.Func(name, usage, func(s string) error { 601 601 - if s == "" { 602 602 - return nil 603 603 - } 604 604 - return json.Unmarshal([]byte(s), dest) 605 605 - }) 606 606 - } 607 1116 608 608 - // debug flag for turning func=ToHLS:3,file=gstreamer.go:4 into {"func": {"ToHLS": 3}, "file": {"gstreamer.go": 4}} 609 609 - func (cli *CLI) DebugFlag(fs *flag.FlagSet, dest *map[string]map[string]int, name, defaultValue, usage string) { 610 610 - *dest = map[string]map[string]int{} 611 611 - fs.Func(name, usage, func(s string) error { 612 612 - if s == "" { 613 613 - return nil 614 614 - } 615 615 - pairs := strings.Split(s, ",") 616 616 - for _, pair := range pairs { 617 617 - scoreSplit := strings.Split(pair, ":") 618 618 - if len(scoreSplit) != 2 { 619 619 - return fmt.Errorf("invalid debug flag: %s", pair) 1117 1117 + return &urfavecli.StringFlag{ 1118 1118 + Name: name, 1119 1119 + Usage: usage, 1120 1120 + Action: func(ctx context.Context, cmd *urfavecli.Command, s string) error { 1121 1121 + if s == "" { 1122 1122 + return nil 620 1123 } 621 621 - score, err := strconv.Atoi(scoreSplit[1]) 622 622 - if err != nil { 623 623 - return fmt.Errorf("invalid debug flag: %s", pair) 1124 1124 + strs := strings.Split(s, ",") 1125 1125 + for _, str := range strs { 1126 1126 + pub, err := aqpub.FromHexString(str) 1127 1127 + if err != nil { 1128 1128 + return err 1129 1129 + } 1130 1130 + *dest = append(*dest, pub) 624 1131 } 625 625 - selectorSplit := strings.Split(scoreSplit[0], "=") 626 626 - if len(selectorSplit) != 2 { 627 627 - return fmt.Errorf("invalid debug flag: %s", pair) 628 628 - } 629 629 - _, ok := (*dest)[selectorSplit[0]] 630 630 - if !ok { 631 631 - (*dest)[selectorSplit[0]] = map[string]int{} 632 632 - } 633 633 - (*dest)[selectorSplit[0]][selectorSplit[1]] = score 634 634 - } 635 635 - 636 636 - return nil 637 637 - }) 1132 1132 + return nil 1133 1133 + }, 1134 1134 + Sources: urfavecli.EnvVars(fmt.Sprintf("SP_%s", strings.ToUpper(strings.ReplaceAll(name, "-", "_")))), 1135 1135 + } 638 1136 } 639 1137 640 1138 func (cli *CLI) StreamIsAllowed(did string) error { ··· 648 1146 if openServer && !isDIDKey { 649 1147 return nil 650 1148 } 651 651 - for _, a := range cli.AllowedStreams { 652 652 - if a == did { 653 653 - return nil 654 654 - } 1149 1149 + if slices.Contains(cli.AllowedStreams, did) { 1150 1150 + return nil 655 1151 } 656 1152 return fmt.Errorf("user is not allowed to stream") 657 1153 }

+5 -3

pkg/media/segment_roundtrip_test.go

··· 87 87 require.NoError(t, err) 88 88 89 89 signedSplitSegDir := makeTestSubdir(t, tempDir, "signed-split-segments") 90 90 - cli := &config.CLI{} 91 91 - fs := cli.NewFlagSet("rtcrec-test") 92 92 - err = cli.Parse(fs, []string{}) 90 90 + cli := &config.CLI{ 91 91 + DataDir: tempDir, // Set data dir for test 92 92 + } 93 93 + cmd := cli.NewCommand("rtcrec-test") 94 94 + err = cli.Validate(cmd) 93 95 require.NoError(t, err) 94 96 err = SplitSegments(context.Background(), cli, rws, func(fname string) ReadWriteSeekCloser { 95 97 fd, err := os.Create(filepath.Join(signedSplitSegDir, fname))