mirror of
https://github.com/onyx-and-iris/gobs-cli.git
synced 2026-04-18 07:03:37 +00:00
Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 6e37c2c6c7 | |||
| bc6cf46b98 | |||
| 51224583c8 | |||
| 6cdc12790a | |||
| 1cf983a647 | |||
| dbc26bf6ff | |||
| 101c7552b2 | |||
| 1c0ef025c1 | |||
| 2b7b8e0bd5 | |||
| 040ece840c |
@@ -5,11 +5,12 @@ All notable changes to this project will be documented in this file.
|
||||
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
|
||||
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
|
||||
|
||||
# [0.15.0] - 2026-01-26
|
||||
# [0.16.0] - 2026-01-26
|
||||
|
||||
### Added
|
||||
|
||||
- new subcommands added to input, see [InputCmd](https://github.com/onyx-and-iris/gobs-cli?tab=readme-ov-file#inputcmd)
|
||||
- settings command group, see [SettingsCmd](https://github.com/onyx-and-iris/gobs-cli?tab=readme-ov-file#settingscmd)
|
||||
|
||||
# [0.14.1] - 2025-07-14
|
||||
|
||||
|
||||
52
README.md
52
README.md
@@ -725,6 +725,58 @@ gobs-cli projector open --monitor-index=1 "test_group"
|
||||
gobs-cli screenshot save --width=2560 --height=1440 "Scene" "C:\Users\me\Videos\screenshot.png"
|
||||
```
|
||||
|
||||
### SettingsCmd
|
||||
|
||||
- show: Show settings.
|
||||
- flags:
|
||||
|
||||
*optional*
|
||||
- --video: Show video settings.
|
||||
- --record: Show record directory.
|
||||
- --profile: Show profile parameters.
|
||||
|
||||
```console
|
||||
gobs-cli settings show --video --record
|
||||
```
|
||||
|
||||
- profile: Get/Set profile parameter setting.
|
||||
- args: Category Name Value
|
||||
|
||||
```console
|
||||
gobs-cli settings profile SimpleOutput VBitrate
|
||||
|
||||
gobs-cli settings profile SimpleOutput VBitrate 6000
|
||||
```
|
||||
|
||||
- stream-service: Get/Set stream service setting.
|
||||
- args: Type
|
||||
- flags:
|
||||
- --key: Stream key.
|
||||
- --server: Stream server URL.
|
||||
|
||||
```console
|
||||
gobs-cli settings stream-service
|
||||
|
||||
gobs-cli settings stream-service rtmp_common --key='live_xyzxyzxyzxyz'
|
||||
```
|
||||
|
||||
- video: Get/Set video setting.
|
||||
- flags:
|
||||
- --show: Show video settings.
|
||||
- --base-width: Base (canvas) width.
|
||||
- --base-height: Base (canvas) height.
|
||||
- --output-width: Output (scaled) width.
|
||||
- --output-height: Output (scaled) height.
|
||||
- --fps-num: Frames per second numerator.
|
||||
- --fps-den: Frames per second denominator.
|
||||
|
||||
```console
|
||||
gobs-cli settings video --show
|
||||
|
||||
gobs-cli settings video --base-width=1920 --base-height=1080
|
||||
```
|
||||
|
||||
|
||||
## License
|
||||
|
||||
`gobs-cli` is distributed under the terms of the [MIT](https://spdx.org/licenses/MIT.html) license.
|
||||
|
||||
@@ -22,6 +22,7 @@ tasks:
|
||||
cmds:
|
||||
- task: build-windows
|
||||
- task: build-linux
|
||||
- task: build-macos
|
||||
|
||||
vet:
|
||||
desc: Vet the code
|
||||
@@ -46,6 +47,12 @@ tasks:
|
||||
- GOOS=linux GOARCH=amd64 go build -ldflags "-X 'main.version={{.VERSION}}'" -o {{.BIN_DIR}}/{{.PROGRAM}}_linux_amd64
|
||||
internal: true
|
||||
|
||||
build-macos:
|
||||
desc: Build the gobs-cli project for macOS
|
||||
cmds:
|
||||
- GOOS=darwin GOARCH=amd64 go build -ldflags "-X 'main.version={{.VERSION}}'" -o {{.BIN_DIR}}/{{.PROGRAM}}_darwin_amd64
|
||||
internal: true
|
||||
|
||||
test:
|
||||
desc: Run tests
|
||||
cmds:
|
||||
|
||||
@@ -33,7 +33,7 @@ func TestFilterListScene(t *testing.T) {
|
||||
context := newContext(client, &out, StyleConfig{})
|
||||
|
||||
cmd := &FilterListCmd{
|
||||
SourceName: "gobs-test",
|
||||
SourceName: "gobs-test-scene",
|
||||
}
|
||||
err := cmd.Run(context)
|
||||
if err != nil {
|
||||
|
||||
@@ -2,11 +2,20 @@ package main
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"os"
|
||||
"strings"
|
||||
"testing"
|
||||
)
|
||||
|
||||
func skipIfSkipGroupTests(t *testing.T) {
|
||||
if os.Getenv("GOBS_TEST_SKIP_GROUP_TESTS") != "" {
|
||||
t.Skip("Skipping group tests due to GOBS_TEST_SKIP_GROUP_TESTS environment variable")
|
||||
}
|
||||
}
|
||||
|
||||
func TestGroupList(t *testing.T) {
|
||||
skipIfSkipGroupTests(t)
|
||||
|
||||
client, disconnect := getClient(t)
|
||||
defer disconnect()
|
||||
|
||||
@@ -26,6 +35,8 @@ func TestGroupList(t *testing.T) {
|
||||
}
|
||||
|
||||
func TestGroupShow(t *testing.T) {
|
||||
skipIfSkipGroupTests(t)
|
||||
|
||||
client, disconnect := getClient(t)
|
||||
defer disconnect()
|
||||
|
||||
@@ -46,6 +57,8 @@ func TestGroupShow(t *testing.T) {
|
||||
}
|
||||
|
||||
func TestGroupToggle(t *testing.T) {
|
||||
skipIfSkipGroupTests(t)
|
||||
|
||||
client, disconnect := getClient(t)
|
||||
defer disconnect()
|
||||
|
||||
@@ -87,6 +100,8 @@ func TestGroupToggle(t *testing.T) {
|
||||
}
|
||||
|
||||
func TestGroupStatus(t *testing.T) {
|
||||
skipIfSkipGroupTests(t)
|
||||
|
||||
client, disconnect := getClient(t)
|
||||
defer disconnect()
|
||||
|
||||
|
||||
@@ -22,9 +22,8 @@ func TestInputList(t *testing.T) {
|
||||
expectedInputs := []string{
|
||||
"Desktop Audio",
|
||||
"Mic/Aux",
|
||||
"Colour Source",
|
||||
"Colour Source 2",
|
||||
"Colour Source 3",
|
||||
"gobs-test-input",
|
||||
"gobs-test-input-2",
|
||||
}
|
||||
output := out.String()
|
||||
for _, input := range expectedInputs {
|
||||
@@ -52,9 +51,8 @@ func TestInputListFilterInput(t *testing.T) {
|
||||
}
|
||||
expectedFilteredOut := []string{
|
||||
"Desktop Audio",
|
||||
"Colour Source",
|
||||
"Colour Source 2",
|
||||
"Colour Source 3",
|
||||
"gobs-test-input",
|
||||
"gobs-test-input-2",
|
||||
}
|
||||
for _, input := range expectedInputs {
|
||||
if !strings.Contains(out.String(), input) {
|
||||
@@ -86,9 +84,8 @@ func TestInputListFilterOutput(t *testing.T) {
|
||||
}
|
||||
expectedFilteredOut := []string{
|
||||
"Mic/Aux",
|
||||
"Colour Source",
|
||||
"Colour Source 2",
|
||||
"Colour Source 3",
|
||||
"gobs-test-input",
|
||||
"gobs-test-input-2",
|
||||
}
|
||||
for _, input := range expectedInputs {
|
||||
if !strings.Contains(out.String(), input) {
|
||||
@@ -116,9 +113,8 @@ func TestInputListFilterColour(t *testing.T) {
|
||||
}
|
||||
|
||||
expectedInputs := []string{
|
||||
"Colour Source",
|
||||
"Colour Source 2",
|
||||
"Colour Source 3",
|
||||
"gobs-test-input",
|
||||
"gobs-test-input-2",
|
||||
}
|
||||
for _, input := range expectedInputs {
|
||||
if !strings.Contains(out.String(), input) {
|
||||
|
||||
1
main.go
1
main.go
@@ -71,6 +71,7 @@ type CLI struct {
|
||||
Filter FilterCmd `help:"Manage filters." cmd:"" aliases:"f" group:"Filter"`
|
||||
Projector ProjectorCmd `help:"Manage projectors." cmd:"" aliases:"prj" group:"Projector"`
|
||||
Screenshot ScreenshotCmd `help:"Take screenshots." cmd:"" aliases:"ss" group:"Screenshot"`
|
||||
Settings SettingsCmd `help:"Manage video and profile settings." cmd:"" aliases:"set" group:"Settings"`
|
||||
}
|
||||
|
||||
type context struct {
|
||||
|
||||
64
main_test.go
64
main_test.go
@@ -2,7 +2,9 @@ package main
|
||||
|
||||
import (
|
||||
"os"
|
||||
"runtime"
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/andreykaipov/goobs"
|
||||
"github.com/andreykaipov/goobs/api/requests/config"
|
||||
@@ -62,13 +64,23 @@ func setup(client *goobs.Client) {
|
||||
Key: os.Getenv("OBS_STREAM_KEY"),
|
||||
}))
|
||||
|
||||
client.Config.SetCurrentSceneCollection(config.NewSetCurrentSceneCollectionParams().
|
||||
WithSceneCollectionName("test-collection"))
|
||||
client.Config.CreateProfile(config.NewCreateProfileParams().
|
||||
WithProfileName("gobs-test-profile"))
|
||||
time.Sleep(100 * time.Millisecond) // Wait for the profile to be created
|
||||
client.Config.SetProfileParameter(config.NewSetProfileParameterParams().
|
||||
WithParameterCategory("SimpleOutput").
|
||||
WithParameterName("RecRB").
|
||||
WithParameterValue("true"))
|
||||
// hack to ensure the Replay Buffer setting is applied
|
||||
client.Config.SetCurrentProfile(config.NewSetCurrentProfileParams().
|
||||
WithProfileName("Untitled"))
|
||||
client.Config.SetCurrentProfile(config.NewSetCurrentProfileParams().
|
||||
WithProfileName("gobs-test-profile"))
|
||||
|
||||
client.Scenes.CreateScene(scenes.NewCreateSceneParams().
|
||||
WithSceneName("gobs-test"))
|
||||
WithSceneName("gobs-test-scene"))
|
||||
client.Inputs.CreateInput(inputs.NewCreateInputParams().
|
||||
WithSceneName("gobs-test").
|
||||
WithSceneName("gobs-test-scene").
|
||||
WithInputName("gobs-test-input").
|
||||
WithInputKind("color_source_v3").
|
||||
WithInputSettings(map[string]any{
|
||||
@@ -79,7 +91,7 @@ func setup(client *goobs.Client) {
|
||||
}).
|
||||
WithSceneItemEnabled(true))
|
||||
client.Inputs.CreateInput(inputs.NewCreateInputParams().
|
||||
WithSceneName("gobs-test").
|
||||
WithSceneName("gobs-test-scene").
|
||||
WithInputName("gobs-test-input-2").
|
||||
WithInputKind("color_source_v3").
|
||||
WithInputSettings(map[string]any{
|
||||
@@ -90,6 +102,37 @@ func setup(client *goobs.Client) {
|
||||
}).
|
||||
WithSceneItemEnabled(true))
|
||||
|
||||
// ensure Desktop Audio input is created
|
||||
desktopAudioKinds := map[string]string{
|
||||
"windows": "wasapi_output_capture",
|
||||
"linux": "pulse_output_capture",
|
||||
"darwin": "coreaudio_output_capture",
|
||||
}
|
||||
platform := os.Getenv("GOBS_TEST_PLATFORM")
|
||||
if platform == "" {
|
||||
platform = runtime.GOOS
|
||||
}
|
||||
client.Inputs.CreateInput(inputs.NewCreateInputParams().
|
||||
WithSceneName("gobs-test-scene").
|
||||
WithInputName("Desktop Audio").
|
||||
WithInputKind(desktopAudioKinds[platform]).
|
||||
WithInputSettings(map[string]any{
|
||||
"device_id": "default",
|
||||
}))
|
||||
// ensure Mic/Aux input is created
|
||||
micKinds := map[string]string{
|
||||
"windows": "wasapi_input_capture",
|
||||
"linux": "pulse_input_capture",
|
||||
"darwin": "coreaudio_input_capture",
|
||||
}
|
||||
client.Inputs.CreateInput(inputs.NewCreateInputParams().
|
||||
WithSceneName("gobs-test-scene").
|
||||
WithInputName("Mic/Aux").
|
||||
WithInputKind(micKinds[platform]).
|
||||
WithInputSettings(map[string]any{
|
||||
"device_id": "default",
|
||||
}))
|
||||
|
||||
// Create source filter on an audio input
|
||||
client.Filters.CreateSourceFilter(filters.NewCreateSourceFilterParams().
|
||||
WithSourceName("Mic/Aux").
|
||||
@@ -106,7 +149,7 @@ func setup(client *goobs.Client) {
|
||||
|
||||
// Create source filter on a scene
|
||||
client.Filters.CreateSourceFilter(filters.NewCreateSourceFilterParams().
|
||||
WithSourceName("gobs-test").
|
||||
WithSourceName("gobs-test-scene").
|
||||
WithFilterName("test_filter").
|
||||
WithFilterKind("luma_key_filter_v2").
|
||||
WithFilterSettings(map[string]any{
|
||||
@@ -115,18 +158,21 @@ func setup(client *goobs.Client) {
|
||||
}
|
||||
|
||||
func teardown(client *goobs.Client) {
|
||||
client.Config.RemoveProfile(config.NewRemoveProfileParams().
|
||||
WithProfileName("gobs-test-profile"))
|
||||
|
||||
client.Filters.RemoveSourceFilter(filters.NewRemoveSourceFilterParams().
|
||||
WithSourceName("Mic/Aux").
|
||||
WithFilterName("test_filter"))
|
||||
client.Filters.RemoveSourceFilter(filters.NewRemoveSourceFilterParams().
|
||||
WithSourceName("gobs-test").
|
||||
WithSourceName("gobs-test-scene").
|
||||
WithFilterName("test_filter"))
|
||||
|
||||
client.Scenes.RemoveScene(scenes.NewRemoveSceneParams().
|
||||
WithSceneName("gobs-test"))
|
||||
WithSceneName("gobs-test-scene"))
|
||||
|
||||
client.Config.SetCurrentSceneCollection(config.NewSetCurrentSceneCollectionParams().
|
||||
WithSceneCollectionName("default"))
|
||||
WithSceneCollectionName("Untitled"))
|
||||
|
||||
client.Stream.StopStream()
|
||||
client.Record.StopRecord()
|
||||
|
||||
@@ -44,7 +44,7 @@ func TestRecordStart(t *testing.T) {
|
||||
if out.String() != "Recording started successfully.\n" {
|
||||
t.Fatalf("Expected output to contain 'Recording started successfully.', got '%s'", out.String())
|
||||
}
|
||||
time.Sleep(1 * time.Second) // Wait for the recording to start
|
||||
time.Sleep(500 * time.Millisecond) // Wait for the recording to start
|
||||
}
|
||||
|
||||
func TestRecordStop(t *testing.T) {
|
||||
@@ -84,7 +84,7 @@ func TestRecordStop(t *testing.T) {
|
||||
if !strings.Contains(out.String(), "Recording stopped successfully. Output file: ") {
|
||||
t.Fatalf("Expected output to contain 'Recording stopped successfully. Output file: ', got '%s'", out.String())
|
||||
}
|
||||
time.Sleep(1 * time.Second) // Wait for the recording to stop
|
||||
time.Sleep(500 * time.Millisecond) // Wait for the recording to stop
|
||||
}
|
||||
|
||||
func TestRecordToggle(t *testing.T) {
|
||||
@@ -112,8 +112,6 @@ func TestRecordToggle(t *testing.T) {
|
||||
t.Fatalf("Failed to toggle recording: %v", err)
|
||||
}
|
||||
|
||||
time.Sleep(1 * time.Second) // Wait for a second to ensure toggle has taken effect
|
||||
|
||||
if active {
|
||||
if out.String() != "Recording stopped successfully.\n" {
|
||||
t.Fatalf("Expected output to be 'Recording stopped successfully.', got '%s'", out.String())
|
||||
@@ -123,4 +121,5 @@ func TestRecordToggle(t *testing.T) {
|
||||
t.Fatalf("Expected output to be 'Recording started successfully.', got '%s'", out.String())
|
||||
}
|
||||
}
|
||||
time.Sleep(500 * time.Millisecond) // Wait for the toggle to take effect
|
||||
}
|
||||
|
||||
@@ -2,11 +2,21 @@ package main
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"os"
|
||||
"strings"
|
||||
"testing"
|
||||
"time"
|
||||
)
|
||||
|
||||
func skipIfSkipReplayBufferTests(t *testing.T) {
|
||||
if os.Getenv("GOBS_TEST_SKIP_REPLAYBUFFER_TESTS") != "" {
|
||||
t.Skip("Skipping replay buffer tests due to GOBS_TEST_SKIP_REPLAYBUFFER_TESTS environment variable")
|
||||
}
|
||||
}
|
||||
|
||||
func TestReplayBufferStart(t *testing.T) {
|
||||
skipIfSkipReplayBufferTests(t)
|
||||
|
||||
client, disconnect := getClient(t)
|
||||
defer disconnect()
|
||||
|
||||
@@ -21,9 +31,12 @@ func TestReplayBufferStart(t *testing.T) {
|
||||
if out.String() != "Replay buffer started.\n" {
|
||||
t.Fatalf("Expected output to be 'Replay buffer started', got '%s'", out.String())
|
||||
}
|
||||
time.Sleep(500 * time.Millisecond) // Wait for the replay buffer to start
|
||||
}
|
||||
|
||||
func TestReplayBufferStop(t *testing.T) {
|
||||
skipIfSkipReplayBufferTests(t)
|
||||
|
||||
client, disconnect := getClient(t)
|
||||
defer disconnect()
|
||||
|
||||
@@ -38,9 +51,12 @@ func TestReplayBufferStop(t *testing.T) {
|
||||
if out.String() != "Replay buffer stopped.\n" {
|
||||
t.Fatalf("Expected output to be 'Replay buffer stopped.', got '%s'", out.String())
|
||||
}
|
||||
time.Sleep(500 * time.Millisecond) // Wait for the replay buffer to stop
|
||||
}
|
||||
|
||||
func TestReplayBufferToggle(t *testing.T) {
|
||||
skipIfSkipReplayBufferTests(t)
|
||||
|
||||
client, disconnect := getClient(t)
|
||||
defer disconnect()
|
||||
|
||||
@@ -73,4 +89,5 @@ func TestReplayBufferToggle(t *testing.T) {
|
||||
t.Fatalf("Expected output to be 'Replay buffer started.', got '%s'", out.String())
|
||||
}
|
||||
}
|
||||
time.Sleep(500 * time.Millisecond) // Wait for the toggle to take effect
|
||||
}
|
||||
|
||||
@@ -17,8 +17,8 @@ func TestSceneList(t *testing.T) {
|
||||
if err != nil {
|
||||
t.Fatalf("Failed to list scenes: %v", err)
|
||||
}
|
||||
if out.String() == "Current program scene: gobs-test\n" {
|
||||
t.Fatalf("Expected output to be 'Current program scene: gobs-test', got '%s'", out.String())
|
||||
if out.String() == "Current program scene: gobs-test-scene\n" {
|
||||
t.Fatalf("Expected output to be 'Current program scene: gobs-test-scene', got '%s'", out.String())
|
||||
}
|
||||
}
|
||||
|
||||
@@ -29,9 +29,9 @@ func TestSceneCurrent(t *testing.T) {
|
||||
var out bytes.Buffer
|
||||
context := newContext(client, &out, StyleConfig{})
|
||||
|
||||
// Set the current scene to "gobs-test"
|
||||
// Set the current scene to "gobs-test-scene"
|
||||
cmdSwitch := &SceneSwitchCmd{
|
||||
NewScene: "gobs-test",
|
||||
NewScene: "gobs-test-scene",
|
||||
}
|
||||
err := cmdSwitch.Run(context)
|
||||
if err != nil {
|
||||
@@ -45,7 +45,7 @@ func TestSceneCurrent(t *testing.T) {
|
||||
if err != nil {
|
||||
t.Fatalf("Failed to get current scene: %v", err)
|
||||
}
|
||||
if out.String() != "Current program scene: gobs-test\n" {
|
||||
t.Fatalf("Expected output to be 'Current program scene: gobs-test', got '%s'", out.String())
|
||||
if out.String() != "Current program scene: gobs-test-scene\n" {
|
||||
t.Fatalf("Expected output to be 'Current program scene: gobs-test-scene', got '%s'", out.String())
|
||||
}
|
||||
}
|
||||
|
||||
@@ -14,7 +14,7 @@ func TestSceneItemList(t *testing.T) {
|
||||
context := newContext(client, &out, StyleConfig{})
|
||||
|
||||
cmd := &SceneItemListCmd{
|
||||
SceneName: "gobs-test",
|
||||
SceneName: "gobs-test-scene",
|
||||
}
|
||||
err := cmd.Run(context)
|
||||
if err != nil {
|
||||
|
||||
334
settings.go
Normal file
334
settings.go
Normal file
@@ -0,0 +1,334 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
|
||||
"github.com/andreykaipov/goobs/api/requests/config"
|
||||
"github.com/andreykaipov/goobs/api/typedefs"
|
||||
"github.com/charmbracelet/lipgloss"
|
||||
"github.com/charmbracelet/lipgloss/table"
|
||||
)
|
||||
|
||||
// SettingsCmd handles settings management.
|
||||
type SettingsCmd struct {
|
||||
Show SettingsShowCmd `help:"Show settings." cmd:"" aliases:"s"`
|
||||
Profile SettingsProfileCmd `help:"Get/Set profile parameter setting." cmd:"" aliases:"p"`
|
||||
StreamService SettingsStreamServiceCmd `help:"Get/Set stream service setting." cmd:"" aliases:"ss"`
|
||||
Video SettingsVideoCmd `help:"Get/Set video setting." cmd:"" aliases:"v"`
|
||||
}
|
||||
|
||||
// SettingsShowCmd shows the video settings.
|
||||
type SettingsShowCmd struct {
|
||||
Video bool `flag:"" help:"Show video settings."`
|
||||
Record bool `flag:"" help:"Show record directory."`
|
||||
Profile bool `flag:"" help:"Show profile parameters."`
|
||||
}
|
||||
|
||||
// Run executes the show command.
|
||||
// nolint: misspell
|
||||
func (cmd *SettingsShowCmd) Run(ctx *context) error {
|
||||
if !cmd.Video && !cmd.Record && !cmd.Profile {
|
||||
cmd.Video = true
|
||||
cmd.Record = true
|
||||
cmd.Profile = true
|
||||
}
|
||||
|
||||
// Get video settings
|
||||
videoResp, err := ctx.Client.Config.GetVideoSettings()
|
||||
if err != nil {
|
||||
return fmt.Errorf("failed to get video settings: %w", err)
|
||||
}
|
||||
|
||||
vt := table.New().Border(lipgloss.RoundedBorder()).
|
||||
BorderStyle(lipgloss.NewStyle().Foreground(ctx.Style.border)).
|
||||
Headers("Video Setting", "Value").
|
||||
StyleFunc(func(row, _ int) lipgloss.Style {
|
||||
style := lipgloss.NewStyle().Padding(0, 3)
|
||||
switch {
|
||||
case row == table.HeaderRow:
|
||||
style = style.Bold(true).Align(lipgloss.Center)
|
||||
case row%2 == 0:
|
||||
style = style.Foreground(ctx.Style.evenRows)
|
||||
default:
|
||||
style = style.Foreground(ctx.Style.oddRows)
|
||||
}
|
||||
return style
|
||||
})
|
||||
|
||||
vt.Row("Base Width", fmt.Sprintf("%.0f", videoResp.BaseWidth))
|
||||
vt.Row("Base Height", fmt.Sprintf("%.0f", videoResp.BaseHeight))
|
||||
vt.Row("Output Width", fmt.Sprintf("%.0f", videoResp.OutputWidth))
|
||||
vt.Row("Output Height", fmt.Sprintf("%.0f", videoResp.OutputHeight))
|
||||
vt.Row("FPS Numerator", fmt.Sprintf("%.0f", videoResp.FpsNumerator))
|
||||
vt.Row("FPS Denominator", fmt.Sprintf("%.0f", videoResp.FpsDenominator))
|
||||
|
||||
// Get record directory
|
||||
dirResp, err := ctx.Client.Config.GetRecordDirectory()
|
||||
if err != nil {
|
||||
return fmt.Errorf("failed to get record directory: %w", err)
|
||||
}
|
||||
|
||||
rt := table.New().Border(lipgloss.RoundedBorder()).
|
||||
BorderStyle(lipgloss.NewStyle().Foreground(ctx.Style.border)).
|
||||
Headers("Record Setting", "Value").
|
||||
StyleFunc(func(row, _ int) lipgloss.Style {
|
||||
style := lipgloss.NewStyle().Padding(0, 3)
|
||||
switch {
|
||||
case row == table.HeaderRow:
|
||||
style = style.Bold(true).Align(lipgloss.Center)
|
||||
case row%2 == 0:
|
||||
style = style.Foreground(ctx.Style.evenRows)
|
||||
default:
|
||||
style = style.Foreground(ctx.Style.oddRows)
|
||||
}
|
||||
return style
|
||||
})
|
||||
|
||||
rt.Row("Directory", dirResp.RecordDirectory)
|
||||
|
||||
// Get profile prameters
|
||||
pt := table.New().Border(lipgloss.RoundedBorder()).
|
||||
BorderStyle(lipgloss.NewStyle().Foreground(ctx.Style.border)).
|
||||
Headers("Profile Parameter", "Value").
|
||||
StyleFunc(func(row, _ int) lipgloss.Style {
|
||||
style := lipgloss.NewStyle().Padding(0, 3)
|
||||
switch {
|
||||
case row == table.HeaderRow:
|
||||
style = style.Bold(true).Align(lipgloss.Center)
|
||||
case row%2 == 0:
|
||||
style = style.Foreground(ctx.Style.evenRows)
|
||||
default:
|
||||
style = style.Foreground(ctx.Style.oddRows)
|
||||
}
|
||||
return style
|
||||
})
|
||||
|
||||
// Common profile parameters to display
|
||||
params := []struct {
|
||||
category string
|
||||
name string
|
||||
label string
|
||||
}{
|
||||
{"Output", "Mode", "Output Mode"},
|
||||
|
||||
{"SimpleOutput", "StreamEncoder", "Simple Streaming Encoder"},
|
||||
{"SimpleOutput", "RecEncoder", "Simple Recording Encoder"},
|
||||
{"SimpleOutput", "RecFormat2", "Simple Recording Video Format"},
|
||||
{"SimpleOutput", "RecAudioEncoder", "Simple Recording Audio Format"},
|
||||
{"SimpleOutput", "RecQuality", "Simple Recording Quality"},
|
||||
|
||||
{"AdvOut", "Encoder", "Advanced Streaming Encoder"},
|
||||
{"AdvOut", "RecEncoder", "Advanced Recording Encoder"},
|
||||
{"AdvOut", "RecType", "Advanced Recording Type"},
|
||||
{"AdvOut", "RecFormat2", "Advanced Recording Video Format"},
|
||||
{"AdvOut", "RecAudioEncoder", "Advanced Recording Audio Format"},
|
||||
}
|
||||
|
||||
for _, param := range params {
|
||||
resp, err := ctx.Client.Config.GetProfileParameter(
|
||||
config.NewGetProfileParameterParams().
|
||||
WithParameterCategory(param.category).
|
||||
WithParameterName(param.name),
|
||||
)
|
||||
if err == nil && resp.ParameterValue != "" {
|
||||
pt.Row(param.label, resp.ParameterValue)
|
||||
}
|
||||
}
|
||||
|
||||
if cmd.Video {
|
||||
fmt.Fprintln(ctx.Out, vt.Render())
|
||||
}
|
||||
|
||||
if cmd.Record {
|
||||
fmt.Fprintln(ctx.Out, rt.Render())
|
||||
}
|
||||
|
||||
if cmd.Profile {
|
||||
fmt.Fprintln(ctx.Out, pt.Render())
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
// SettingsProfileCmd gets/ sets a profile parameter.
|
||||
type SettingsProfileCmd struct {
|
||||
Category string `arg:"" help:"Parameter category (e.g., AdvOut, SimpleOutput, Output)." required:""`
|
||||
Name string `arg:"" help:"Parameter name (e.g., RecFormat2, RecEncoder)." required:""`
|
||||
Value string `arg:"" help:"Parameter value to set." optional:""`
|
||||
}
|
||||
|
||||
// Run executes the set command.
|
||||
func (cmd *SettingsProfileCmd) Run(ctx *context) error {
|
||||
if cmd.Value == "" {
|
||||
resp, err := ctx.Client.Config.GetProfileParameter(
|
||||
config.NewGetProfileParameterParams().
|
||||
WithParameterCategory(cmd.Category).
|
||||
WithParameterName(cmd.Name),
|
||||
)
|
||||
if err != nil {
|
||||
return fmt.Errorf("failed to get parameter %s.%s: %w", cmd.Category, cmd.Name, err)
|
||||
}
|
||||
|
||||
fmt.Fprintf(ctx.Out, "%s.%s = %s\n", cmd.Category, cmd.Name, resp.ParameterValue)
|
||||
return nil
|
||||
}
|
||||
|
||||
_, err := ctx.Client.Config.SetProfileParameter(
|
||||
config.NewSetProfileParameterParams().
|
||||
WithParameterCategory(cmd.Category).
|
||||
WithParameterName(cmd.Name).
|
||||
WithParameterValue(cmd.Value),
|
||||
)
|
||||
if err != nil {
|
||||
return fmt.Errorf("failed to set parameter %s.%s: %w", cmd.Category, cmd.Name, err)
|
||||
}
|
||||
|
||||
fmt.Fprintf(ctx.Out, "Set %s.%s = %s\n", cmd.Category, cmd.Name, cmd.Value)
|
||||
return nil
|
||||
}
|
||||
|
||||
// SettingsStreamServiceCmd gets/ sets stream service settings.
|
||||
type SettingsStreamServiceCmd struct {
|
||||
Type string `arg:"" help:"Stream type (e.g., rtmp_common, rtmp_custom)." required:""`
|
||||
Key string ` help:"Stream key." flag:""`
|
||||
Server string ` help:"Stream server URL." flag:""`
|
||||
}
|
||||
|
||||
// Run executes the set stream service command.
|
||||
// nolint: misspell
|
||||
func (cmd *SettingsStreamServiceCmd) Run(ctx *context) error {
|
||||
resp, err := ctx.Client.Config.GetStreamServiceSettings()
|
||||
if err != nil {
|
||||
return fmt.Errorf("failed to get stream service settings: %w", err)
|
||||
}
|
||||
|
||||
if cmd.Key == "" && cmd.Server == "" {
|
||||
t := table.New().Border(lipgloss.RoundedBorder()).
|
||||
BorderStyle(lipgloss.NewStyle().Foreground(ctx.Style.border)).
|
||||
Headers("Stream Service Setting", "Value").
|
||||
StyleFunc(func(row, _ int) lipgloss.Style {
|
||||
style := lipgloss.NewStyle().Padding(0, 3)
|
||||
switch {
|
||||
case row == table.HeaderRow:
|
||||
style = style.Bold(true).Align(lipgloss.Center)
|
||||
case row%2 == 0:
|
||||
style = style.Foreground(ctx.Style.evenRows)
|
||||
default:
|
||||
style = style.Foreground(ctx.Style.oddRows)
|
||||
}
|
||||
return style
|
||||
})
|
||||
|
||||
t.Row("Type", cmd.Type)
|
||||
t.Row("Key", resp.StreamServiceSettings.Key)
|
||||
t.Row("Server", resp.StreamServiceSettings.Server)
|
||||
|
||||
fmt.Fprintln(ctx.Out, t.Render())
|
||||
return nil
|
||||
}
|
||||
|
||||
if cmd.Key == "" {
|
||||
cmd.Key = resp.StreamServiceSettings.Key
|
||||
}
|
||||
if cmd.Server == "" {
|
||||
cmd.Server = resp.StreamServiceSettings.Server
|
||||
}
|
||||
|
||||
_, err = ctx.Client.Config.SetStreamServiceSettings(
|
||||
config.NewSetStreamServiceSettingsParams().
|
||||
WithStreamServiceSettings(&typedefs.StreamServiceSettings{
|
||||
Key: cmd.Key,
|
||||
Server: cmd.Server,
|
||||
}).
|
||||
WithStreamServiceType(cmd.Type),
|
||||
)
|
||||
if err != nil {
|
||||
return fmt.Errorf("failed to set stream service settings: %w", err)
|
||||
}
|
||||
|
||||
fmt.Fprintln(ctx.Out, "Stream service settings updated successfully.")
|
||||
return nil
|
||||
}
|
||||
|
||||
// SettingsVideoCmd gets/ sets video settings.
|
||||
type SettingsVideoCmd struct {
|
||||
Show bool `flag:"" help:"Show video settings."`
|
||||
BaseWidth int `flag:"" help:"Base (canvas) width." min:"8"`
|
||||
BaseHeight int `flag:"" help:"Base (canvas) height." min:"8"`
|
||||
OutputWidth int `flag:"" help:"Output (scaled) width." min:"8"`
|
||||
OutputHeight int `flag:"" help:"Output (scaled) height." min:"8"`
|
||||
FPSNum int `flag:"" help:"Frames per second numerator." min:"1"`
|
||||
FPSDen int `flag:"" help:"Frames per second denominator." min:"1"`
|
||||
}
|
||||
|
||||
// Run executes the gets/ set video command.
|
||||
// nolint: misspell
|
||||
func (cmd *SettingsVideoCmd) Run(ctx *context) error {
|
||||
resp, err := ctx.Client.Config.GetVideoSettings()
|
||||
if err != nil {
|
||||
return fmt.Errorf("failed to get video settings: %w", err)
|
||||
}
|
||||
|
||||
if cmd.Show {
|
||||
t := table.New().Border(lipgloss.RoundedBorder()).
|
||||
BorderStyle(lipgloss.NewStyle().Foreground(ctx.Style.border)).
|
||||
Headers("Video Setting", "Value").
|
||||
StyleFunc(func(row, _ int) lipgloss.Style {
|
||||
style := lipgloss.NewStyle().Padding(0, 3)
|
||||
switch {
|
||||
case row == table.HeaderRow:
|
||||
style = style.Bold(true).Align(lipgloss.Center)
|
||||
case row%2 == 0:
|
||||
style = style.Foreground(ctx.Style.evenRows)
|
||||
default:
|
||||
style = style.Foreground(ctx.Style.oddRows)
|
||||
}
|
||||
return style
|
||||
})
|
||||
|
||||
t.Row("Base Width", fmt.Sprintf("%.0f", resp.BaseWidth))
|
||||
t.Row("Base Height", fmt.Sprintf("%.0f", resp.BaseHeight))
|
||||
t.Row("Output Width", fmt.Sprintf("%.0f", resp.OutputWidth))
|
||||
t.Row("Output Height", fmt.Sprintf("%.0f", resp.OutputHeight))
|
||||
t.Row("FPS Numerator", fmt.Sprintf("%.0f", resp.FpsNumerator))
|
||||
t.Row("FPS Denominator", fmt.Sprintf("%.0f", resp.FpsDenominator))
|
||||
|
||||
fmt.Fprintln(ctx.Out, t.Render())
|
||||
return nil
|
||||
}
|
||||
|
||||
if cmd.BaseWidth == 0 {
|
||||
cmd.BaseWidth = int(resp.BaseWidth)
|
||||
}
|
||||
if cmd.BaseHeight == 0 {
|
||||
cmd.BaseHeight = int(resp.BaseHeight)
|
||||
}
|
||||
if cmd.OutputWidth == 0 {
|
||||
cmd.OutputWidth = int(resp.OutputWidth)
|
||||
}
|
||||
if cmd.OutputHeight == 0 {
|
||||
cmd.OutputHeight = int(resp.OutputHeight)
|
||||
}
|
||||
if cmd.FPSNum == 0 {
|
||||
cmd.FPSNum = int(resp.FpsNumerator)
|
||||
}
|
||||
if cmd.FPSDen == 0 {
|
||||
cmd.FPSDen = int(resp.FpsDenominator)
|
||||
}
|
||||
|
||||
_, err = ctx.Client.Config.SetVideoSettings(
|
||||
config.NewSetVideoSettingsParams().
|
||||
WithBaseWidth(float64(cmd.BaseWidth)).
|
||||
WithBaseHeight(float64(cmd.BaseHeight)).
|
||||
WithOutputWidth(float64(cmd.OutputWidth)).
|
||||
WithOutputHeight(float64(cmd.OutputHeight)).
|
||||
WithFpsNumerator(float64(cmd.FPSNum)).
|
||||
WithFpsDenominator(float64(cmd.FPSDen)),
|
||||
)
|
||||
if err != nil {
|
||||
return fmt.Errorf("failed to set video settings: %w", err)
|
||||
}
|
||||
|
||||
fmt.Fprintln(ctx.Out, "Video settings updated successfully.")
|
||||
return nil
|
||||
}
|
||||
@@ -43,7 +43,7 @@ func TestStreamStart(t *testing.T) {
|
||||
if out.String() != "Stream started successfully.\n" {
|
||||
t.Fatalf("Expected output to contain 'Stream started successfully.', got '%s'", out.String())
|
||||
}
|
||||
time.Sleep(2 * time.Second) // Wait for the stream to start
|
||||
time.Sleep(500 * time.Millisecond) // Wait for the stream to start
|
||||
}
|
||||
|
||||
func TestStreamStop(t *testing.T) {
|
||||
@@ -82,7 +82,7 @@ func TestStreamStop(t *testing.T) {
|
||||
if out.String() != "Stream stopped successfully.\n" {
|
||||
t.Fatalf("Expected output to contain 'Stream stopped successfully.', got '%s'", out.String())
|
||||
}
|
||||
time.Sleep(2 * time.Second) // Wait for the stream to stop
|
||||
time.Sleep(500 * time.Millisecond) // Wait for the stream to stop
|
||||
}
|
||||
|
||||
func TestStreamToggle(t *testing.T) {
|
||||
@@ -119,5 +119,5 @@ func TestStreamToggle(t *testing.T) {
|
||||
t.Fatalf("Expected 'Stream started successfully.', got: %s", out.String())
|
||||
}
|
||||
}
|
||||
time.Sleep(2 * time.Second) // Wait for the stream to toggle
|
||||
time.Sleep(500 * time.Millisecond) // Wait for the stream to toggle
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user