Compare commits

...

21 Commits

Author SHA1 Message Date
bc6cf46b98 add Settings section to README 2026-01-08 18:20:37 +00:00
51224583c8 implement settings command group
show and profile set were prototyped in:
https://github.com/nzoschke/gobs-cli/blob/config/settings.go
2026-01-08 18:20:22 +00:00
6cdc12790a Merge branch 'input' 2026-01-08 15:41:07 +00:00
8a5ce67ba0 add 0.15.0 to CHANGELOG 2026-01-08 15:36:12 +00:00
474693e0f7 add new input subcommands to README 2026-01-08 15:33:56 +00:00
a960c9ffa5 reorder commands
add input kind-defaults
2026-01-08 15:31:02 +00:00
8ce8727a0a rename input kinds to input list-kinds
rename input delete to input remove

add input volume
2026-01-08 14:14:40 +00:00
Noah Zoschke
fba7c4ce20 format 2025-07-30 07:02:27 -07:00
1cf983a647 add 500ms delays to tests 2025-07-30 08:40:41 +01:00
dbc26bf6ff upd delays to 500ms 2025-07-30 08:40:26 +01:00
Noah Zoschke
c5e7bb4e1a delete 2025-07-29 16:35:10 -07:00
Noah Zoschke
e087fdefe3 update 2025-07-29 16:29:52 -07:00
Noah Zoschke
bd4a6cad4b show verbose 2025-07-29 16:18:56 -07:00
Noah Zoschke
72fc7d4092 kinds 2025-07-29 15:55:44 -07:00
Noah Zoschke
cb735cd666 show 2025-07-29 15:33:22 -07:00
Noah Zoschke
db70f8766d create input 2025-07-29 14:30:49 -07:00
101c7552b2 ensure Mic/Aux is created as well as Desktop Audio
add option to read the OBS platform from env var
2025-07-29 06:54:23 +01:00
1c0ef025c1 add mac build to Taskfile 2025-07-24 00:15:53 +01:00
2b7b8e0bd5 set inputKind for each platform 2025-07-24 00:15:00 +01:00
040ece840c allow skip group tests
enable replay buffer in test setup()
create Desktop Audio input if it doesn't exist.
2025-07-21 14:33:00 +01:00
c6406888a9 display (empty) if no text is set 2025-07-14 03:44:12 +01:00
16 changed files with 935 additions and 42 deletions

View File

@@ -5,7 +5,13 @@ 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/), 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). and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
# [0.14.0] - 2025-07-14 # [0.15.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)
# [0.14.1] - 2025-07-14
### Added ### Added

100
README.md
View File

@@ -264,6 +264,20 @@ gobs-cli group status START "test_group"
### InputCmd ### InputCmd
- create: Create input.
- args: Name Kind
```console
gobs-cli input create 'stream mix' 'wasapi_input_capture'
```
- remove: Remove input.
- args: Name
```console
gobs-cli input remove 'stream mix'
```
- list: List all inputs. - list: List all inputs.
- flags: - flags:
@@ -281,6 +295,12 @@ gobs-cli input list
gobs-cli input list --input --colour gobs-cli input list --input --colour
``` ```
- list-kinds: List input kinds.
```console
gobs-cli input list-kinds
```
- mute: Mute input. - mute: Mute input.
- args: InputName - args: InputName
@@ -302,6 +322,34 @@ gobs-cli input unmute "Mic/Aux"
gobs-cli input toggle "Mic/Aux" gobs-cli input toggle "Mic/Aux"
``` ```
- volume: Set input volume.
- args: InputName Volume
```console
gobs-cli input volume -- 'Mic/Aux' -30.6
```
- show: Show input details.
- args: Name
- flags:
*optional*
- --verbose: List all available input devices.
- update: Update input settings.
- args: InputName DeviceName
```console
gobs-cli input update 'Mic/Aux' 'Voicemeeter Out B1 (VB-Audio Voicemeeter VAIO)'
```
- kind-defaults: Get default settings for an input kind.
- args: Kind
```console
gobs-cli input kind-defaults 'wasapi_input_capture'
```
### TextCmd ### TextCmd
- current: Display current text for a text input. - current: Display current text for a text input.
@@ -677,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" gobs-cli screenshot save --width=2560 --height=1440 "Scene" "C:\Users\me\Videos\screenshot.png"
``` ```
### Settings
- 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 ## License
`gobs-cli` is distributed under the terms of the [MIT](https://spdx.org/licenses/MIT.html) license. `gobs-cli` is distributed under the terms of the [MIT](https://spdx.org/licenses/MIT.html) license.

View File

@@ -22,6 +22,7 @@ tasks:
cmds: cmds:
- task: build-windows - task: build-windows
- task: build-linux - task: build-linux
- task: build-macos
vet: vet:
desc: Vet the code 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 - GOOS=linux GOARCH=amd64 go build -ldflags "-X 'main.version={{.VERSION}}'" -o {{.BIN_DIR}}/{{.PROGRAM}}_linux_amd64
internal: true 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: test:
desc: Run tests desc: Run tests
cmds: cmds:

View File

@@ -33,7 +33,7 @@ func TestFilterListScene(t *testing.T) {
context := newContext(client, &out, StyleConfig{}) context := newContext(client, &out, StyleConfig{})
cmd := &FilterListCmd{ cmd := &FilterListCmd{
SourceName: "gobs-test", SourceName: "gobs-test-scene",
} }
err := cmd.Run(context) err := cmd.Run(context)
if err != nil { if err != nil {

View File

@@ -2,11 +2,20 @@ package main
import ( import (
"bytes" "bytes"
"os"
"strings" "strings"
"testing" "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) { func TestGroupList(t *testing.T) {
skipIfSkipGroupTests(t)
client, disconnect := getClient(t) client, disconnect := getClient(t)
defer disconnect() defer disconnect()
@@ -26,6 +35,8 @@ func TestGroupList(t *testing.T) {
} }
func TestGroupShow(t *testing.T) { func TestGroupShow(t *testing.T) {
skipIfSkipGroupTests(t)
client, disconnect := getClient(t) client, disconnect := getClient(t)
defer disconnect() defer disconnect()
@@ -46,6 +57,8 @@ func TestGroupShow(t *testing.T) {
} }
func TestGroupToggle(t *testing.T) { func TestGroupToggle(t *testing.T) {
skipIfSkipGroupTests(t)
client, disconnect := getClient(t) client, disconnect := getClient(t)
defer disconnect() defer disconnect()
@@ -87,6 +100,8 @@ func TestGroupToggle(t *testing.T) {
} }
func TestGroupStatus(t *testing.T) { func TestGroupStatus(t *testing.T) {
skipIfSkipGroupTests(t)
client, disconnect := getClient(t) client, disconnect := getClient(t)
defer disconnect() defer disconnect()

365
input.go
View File

@@ -3,6 +3,7 @@ package main
import ( import (
"fmt" "fmt"
"maps"
"sort" "sort"
"strings" "strings"
@@ -13,10 +14,63 @@ import (
// InputCmd provides commands to manage inputs in OBS Studio. // InputCmd provides commands to manage inputs in OBS Studio.
type InputCmd struct { type InputCmd struct {
Create InputCreateCmd `cmd:"" help:"Create input." aliases:"c"`
Remove InputRemoveCmd `cmd:"" help:"Remove input." aliases:"d"`
List InputListCmd `cmd:"" help:"List all inputs." aliases:"ls"` List InputListCmd `cmd:"" help:"List all inputs." aliases:"ls"`
ListKinds InputListKindsCmd `cmd:"" help:"List input kinds." aliases:"k"`
Mute InputMuteCmd `cmd:"" help:"Mute input." aliases:"m"` Mute InputMuteCmd `cmd:"" help:"Mute input." aliases:"m"`
Unmute InputUnmuteCmd `cmd:"" help:"Unmute input." aliases:"um"` Unmute InputUnmuteCmd `cmd:"" help:"Unmute input." aliases:"um"`
Toggle InputToggleCmd `cmd:"" help:"Toggle input." aliases:"tg"` Toggle InputToggleCmd `cmd:"" help:"Toggle input." aliases:"tg"`
Volume InputVolumeCmd `cmd:"" help:"Set input volume." aliases:"v"`
Show InputShowCmd `cmd:"" help:"Show input details." aliases:"s"`
Update InputUpdateCmd `cmd:"" help:"Update input settings." aliases:"up"`
KindDefaults InputKindDefaultsCmd `cmd:"" help:"Get default settings for an input kind." aliases:"df"`
}
// InputCreateCmd provides a command to create an input.
type InputCreateCmd struct {
Name string `arg:"" help:"Name for the input." required:""`
Kind string `arg:"" help:"Input kind (e.g., coreaudio_input_capture, macos-avcapture)." required:""`
}
// Run executes the command to create an input.
func (cmd *InputCreateCmd) Run(ctx *context) error {
currentScene, err := ctx.Client.Scenes.GetCurrentProgramScene()
if err != nil {
return err
}
_, err = ctx.Client.Inputs.CreateInput(
inputs.NewCreateInputParams().
WithInputKind(cmd.Kind).
WithInputName(cmd.Name).
WithSceneName(currentScene.CurrentProgramSceneName),
)
if err != nil {
return err
}
fmt.Fprintf(ctx.Out, "Created input: %s (%s) in scene %s\n",
ctx.Style.Highlight(cmd.Name), cmd.Kind, ctx.Style.Highlight(currentScene.CurrentProgramSceneName))
return nil
}
// InputRemoveCmd provides a command to remove an input.
type InputRemoveCmd struct {
Name string `arg:"" help:"Name of the input to remove." required:""`
}
// Run executes the command to remove an input.
func (cmd *InputRemoveCmd) Run(ctx *context) error {
_, err := ctx.Client.Inputs.RemoveInput(
inputs.NewRemoveInputParams().WithInputName(cmd.Name),
)
if err != nil {
return fmt.Errorf("failed to delete input: %w", err)
}
fmt.Fprintf(ctx.Out, "Deleted %s\n", ctx.Style.Highlight(cmd.Name))
return nil
} }
// InputListCmd provides a command to list all inputs. // InputListCmd provides a command to list all inputs.
@@ -122,6 +176,47 @@ func (cmd *InputListCmd) Run(ctx *context) error {
return nil return nil
} }
// InputListKindsCmd provides a command to list all input kinds.
type InputListKindsCmd struct{}
// Run executes the command to list all input kinds.
func (cmd *InputListKindsCmd) Run(ctx *context) error {
resp, err := ctx.Client.Inputs.GetInputKindList(
inputs.NewGetInputKindListParams().WithUnversioned(false),
)
if err != nil {
return fmt.Errorf("failed to get input kinds: %w", err)
}
t := table.New().Border(lipgloss.RoundedBorder()).
BorderStyle(lipgloss.NewStyle().Foreground(ctx.Style.border))
t.Headers("Kind")
t.StyleFunc(func(row, col int) lipgloss.Style {
style := lipgloss.NewStyle().Padding(0, 3)
switch col {
case 0:
style = style.Align(lipgloss.Left)
}
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
})
for _, kind := range resp.InputKinds {
t.Row(kind)
}
fmt.Fprintln(ctx.Out, t.Render())
return nil
}
// InputMuteCmd provides a command to mute an input. // InputMuteCmd provides a command to mute an input.
type InputMuteCmd struct { type InputMuteCmd struct {
InputName string `arg:"" help:"Name of the input to mute."` InputName string `arg:"" help:"Name of the input to mute."`
@@ -188,3 +283,273 @@ func (cmd *InputToggleCmd) Run(ctx *context) error {
} }
return nil return nil
} }
// InputVolumeCmd provides a command to set the volume of an input.
type InputVolumeCmd struct {
InputName string `arg:"" help:"Name of the input to set volume for." required:""`
Volume float64 `arg:"" help:"Volume level (-90.0 to 0.0)." required:""`
}
// Run executes the command to set the volume of an input.
// accepts values between -90.0 and 0.0 representing decibels (dB).
func (cmd *InputVolumeCmd) Run(ctx *context) error {
if cmd.Volume < -90.0 || cmd.Volume > 0.0 {
return fmt.Errorf("volume must be between -90.0 and 0.0 dB")
}
_, err := ctx.Client.Inputs.SetInputVolume(
inputs.NewSetInputVolumeParams().
WithInputName(cmd.InputName).
WithInputVolumeDb(cmd.Volume),
)
if err != nil {
return fmt.Errorf("failed to set input volume: %w", err)
}
fmt.Fprintf(ctx.Out, "Set volume of input %s to %.1f dB\n",
ctx.Style.Highlight(cmd.InputName), cmd.Volume)
return nil
}
// InputShowCmd provides a command to show input details.
type InputShowCmd struct {
Name string `arg:"" help:"Name of the input to show." required:""`
Verbose bool ` help:"List all available input devices." flag:""`
}
// Run executes the command to show input details.
func (cmd *InputShowCmd) Run(ctx *context) error {
lresp, err := ctx.Client.Inputs.GetInputList(inputs.NewGetInputListParams())
if err != nil {
return fmt.Errorf("failed to get input list: %w", err)
}
var inputKind string
var found bool
for _, input := range lresp.Inputs {
if input.InputName == cmd.Name {
inputKind = input.InputKind
found = true
break
}
}
if !found {
return fmt.Errorf("input '%s' not found", cmd.Name)
}
prop, name := device(ctx, cmd.Name)
if prop == "" {
return fmt.Errorf("no device property found for input '%s'", cmd.Name)
}
t := table.New().Border(lipgloss.RoundedBorder()).
BorderStyle(lipgloss.NewStyle().Foreground(ctx.Style.border))
t.Headers("Input Name", "Kind", "Device")
t.StyleFunc(func(row, col int) lipgloss.Style {
style := lipgloss.NewStyle().Padding(0, 3)
switch col {
case 0:
style = style.Align(lipgloss.Left)
case 1:
style = style.Align(lipgloss.Left)
case 2:
style = style.Align(lipgloss.Center)
}
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(cmd.Name, snakeCaseToTitleCase(inputKind), name)
fmt.Fprintln(ctx.Out, t.Render())
if cmd.Verbose {
deviceListResp, err := ctx.Client.Inputs.GetInputPropertiesListPropertyItems(
inputs.NewGetInputPropertiesListPropertyItemsParams().
WithInputName(cmd.Name).
WithPropertyName(prop),
)
if err != nil {
return fmt.Errorf("failed to get device list: %w", err)
}
t := table.New().Border(lipgloss.RoundedBorder()).
BorderStyle(lipgloss.NewStyle().Foreground(ctx.Style.border))
t.StyleFunc(func(row, col int) lipgloss.Style {
style := lipgloss.NewStyle().Padding(0, 3)
switch col {
case 0:
style = style.Align(lipgloss.Left)
}
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.Headers("Devices")
for _, item := range deviceListResp.PropertyItems {
if item.ItemName != "" {
t.Row(item.ItemName)
}
}
fmt.Fprintln(ctx.Out, t.Render())
}
return nil
}
func device(ctx *context, inputName string) (string, string) {
settings, err := ctx.Client.Inputs.GetInputSettings(
inputs.NewGetInputSettingsParams().WithInputName(inputName),
)
if err != nil {
return "", ""
}
for _, propName := range []string{"device", "device_id"} {
deviceListResp, err := ctx.Client.Inputs.GetInputPropertiesListPropertyItems(
inputs.NewGetInputPropertiesListPropertyItemsParams().
WithInputName(inputName).
WithPropertyName(propName),
)
if err == nil && len(deviceListResp.PropertyItems) > 0 {
for _, item := range deviceListResp.PropertyItems {
if item.ItemValue == settings.InputSettings[propName] {
return propName, item.ItemName
}
}
}
}
return "", ""
}
// InputUpdateCmd provides a command to update input settings.
type InputUpdateCmd struct {
InputName string `arg:"" help:"Name of the input to update." required:""`
DeviceName string `arg:"" help:"Name of the device to set." required:""`
}
// Run executes the command to update input settings.
func (cmd *InputUpdateCmd) Run(ctx *context) error {
// Use the device helper to find the correct device property name
prop, _ := device(ctx, cmd.InputName)
if prop == "" {
return fmt.Errorf("no device property found for input '%s'", cmd.InputName)
}
resp, err := ctx.Client.Inputs.GetInputPropertiesListPropertyItems(
inputs.NewGetInputPropertiesListPropertyItemsParams().
WithInputName(cmd.InputName).
WithPropertyName(prop),
)
if err != nil {
return err
}
var deviceValue any
var found bool
for _, item := range resp.PropertyItems {
if item.ItemName == cmd.DeviceName {
deviceValue = item.ItemValue
found = true
break
}
}
if !found {
return fmt.Errorf("device '%s' not found for input '%s'", cmd.DeviceName, cmd.InputName)
}
sresp, err := ctx.Client.Inputs.GetInputSettings(
inputs.NewGetInputSettingsParams().WithInputName(cmd.InputName),
)
if err != nil {
return err
}
settings := make(map[string]any)
maps.Copy(settings, sresp.InputSettings)
settings[prop] = deviceValue
_, err = ctx.Client.Inputs.SetInputSettings(
inputs.NewSetInputSettingsParams().
WithInputName(cmd.InputName).
WithInputSettings(settings),
)
if err != nil {
return fmt.Errorf("failed to update input settings: %w", err)
}
fmt.Fprintf(ctx.Out, "Input %s %s set to %s\n",
ctx.Style.Highlight(cmd.InputName), prop, ctx.Style.Highlight(cmd.DeviceName))
return nil
}
// InputKindDefaultsCmd provides a command to get default settings for an input kind.
type InputKindDefaultsCmd struct {
Kind string `arg:"" help:"Input kind to get default settings for." required:""`
}
// Run executes the command to get default settings for an input kind.
func (cmd *InputKindDefaultsCmd) Run(ctx *context) error {
resp, err := ctx.Client.Inputs.GetInputDefaultSettings(
inputs.NewGetInputDefaultSettingsParams().
WithInputKind(cmd.Kind),
)
if err != nil {
return fmt.Errorf("failed to get default settings for input kind '%s': %w", cmd.Kind, err)
}
t := table.New().Border(lipgloss.RoundedBorder()).
BorderStyle(lipgloss.NewStyle().Foreground(ctx.Style.border))
t.Headers("Setting", "Value")
t.StyleFunc(func(row, col int) lipgloss.Style {
style := lipgloss.NewStyle().Padding(0, 3)
switch col {
case 0:
style = style.Align(lipgloss.Left)
case 1:
style = style.Align(lipgloss.Center)
}
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
})
keys := make([]string, 0, len(resp.DefaultInputSettings))
for k := range resp.DefaultInputSettings {
keys = append(keys, k)
}
sort.Strings(keys)
for _, key := range keys {
value := resp.DefaultInputSettings[key]
t.Row(key, fmt.Sprintf("%v", value))
}
fmt.Fprintln(ctx.Out, t.Render())
return nil
}

View File

@@ -22,9 +22,8 @@ func TestInputList(t *testing.T) {
expectedInputs := []string{ expectedInputs := []string{
"Desktop Audio", "Desktop Audio",
"Mic/Aux", "Mic/Aux",
"Colour Source", "gobs-test-input",
"Colour Source 2", "gobs-test-input-2",
"Colour Source 3",
} }
output := out.String() output := out.String()
for _, input := range expectedInputs { for _, input := range expectedInputs {
@@ -52,9 +51,8 @@ func TestInputListFilterInput(t *testing.T) {
} }
expectedFilteredOut := []string{ expectedFilteredOut := []string{
"Desktop Audio", "Desktop Audio",
"Colour Source", "gobs-test-input",
"Colour Source 2", "gobs-test-input-2",
"Colour Source 3",
} }
for _, input := range expectedInputs { for _, input := range expectedInputs {
if !strings.Contains(out.String(), input) { if !strings.Contains(out.String(), input) {
@@ -86,9 +84,8 @@ func TestInputListFilterOutput(t *testing.T) {
} }
expectedFilteredOut := []string{ expectedFilteredOut := []string{
"Mic/Aux", "Mic/Aux",
"Colour Source", "gobs-test-input",
"Colour Source 2", "gobs-test-input-2",
"Colour Source 3",
} }
for _, input := range expectedInputs { for _, input := range expectedInputs {
if !strings.Contains(out.String(), input) { if !strings.Contains(out.String(), input) {
@@ -116,9 +113,8 @@ func TestInputListFilterColour(t *testing.T) {
} }
expectedInputs := []string{ expectedInputs := []string{
"Colour Source", "gobs-test-input",
"Colour Source 2", "gobs-test-input-2",
"Colour Source 3",
} }
for _, input := range expectedInputs { for _, input := range expectedInputs {
if !strings.Contains(out.String(), input) { if !strings.Contains(out.String(), input) {

View File

@@ -71,6 +71,7 @@ type CLI struct {
Filter FilterCmd `help:"Manage filters." cmd:"" aliases:"f" group:"Filter"` Filter FilterCmd `help:"Manage filters." cmd:"" aliases:"f" group:"Filter"`
Projector ProjectorCmd `help:"Manage projectors." cmd:"" aliases:"prj" group:"Projector"` Projector ProjectorCmd `help:"Manage projectors." cmd:"" aliases:"prj" group:"Projector"`
Screenshot ScreenshotCmd `help:"Take screenshots." cmd:"" aliases:"ss" group:"Screenshot"` 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 { type context struct {

View File

@@ -2,7 +2,9 @@ package main
import ( import (
"os" "os"
"runtime"
"testing" "testing"
"time"
"github.com/andreykaipov/goobs" "github.com/andreykaipov/goobs"
"github.com/andreykaipov/goobs/api/requests/config" "github.com/andreykaipov/goobs/api/requests/config"
@@ -62,13 +64,23 @@ func setup(client *goobs.Client) {
Key: os.Getenv("OBS_STREAM_KEY"), Key: os.Getenv("OBS_STREAM_KEY"),
})) }))
client.Config.SetCurrentSceneCollection(config.NewSetCurrentSceneCollectionParams(). client.Config.CreateProfile(config.NewCreateProfileParams().
WithSceneCollectionName("test-collection")) 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(). client.Scenes.CreateScene(scenes.NewCreateSceneParams().
WithSceneName("gobs-test")) WithSceneName("gobs-test-scene"))
client.Inputs.CreateInput(inputs.NewCreateInputParams(). client.Inputs.CreateInput(inputs.NewCreateInputParams().
WithSceneName("gobs-test"). WithSceneName("gobs-test-scene").
WithInputName("gobs-test-input"). WithInputName("gobs-test-input").
WithInputKind("color_source_v3"). WithInputKind("color_source_v3").
WithInputSettings(map[string]any{ WithInputSettings(map[string]any{
@@ -79,7 +91,7 @@ func setup(client *goobs.Client) {
}). }).
WithSceneItemEnabled(true)) WithSceneItemEnabled(true))
client.Inputs.CreateInput(inputs.NewCreateInputParams(). client.Inputs.CreateInput(inputs.NewCreateInputParams().
WithSceneName("gobs-test"). WithSceneName("gobs-test-scene").
WithInputName("gobs-test-input-2"). WithInputName("gobs-test-input-2").
WithInputKind("color_source_v3"). WithInputKind("color_source_v3").
WithInputSettings(map[string]any{ WithInputSettings(map[string]any{
@@ -90,6 +102,37 @@ func setup(client *goobs.Client) {
}). }).
WithSceneItemEnabled(true)) 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 // Create source filter on an audio input
client.Filters.CreateSourceFilter(filters.NewCreateSourceFilterParams(). client.Filters.CreateSourceFilter(filters.NewCreateSourceFilterParams().
WithSourceName("Mic/Aux"). WithSourceName("Mic/Aux").
@@ -106,7 +149,7 @@ func setup(client *goobs.Client) {
// Create source filter on a scene // Create source filter on a scene
client.Filters.CreateSourceFilter(filters.NewCreateSourceFilterParams(). client.Filters.CreateSourceFilter(filters.NewCreateSourceFilterParams().
WithSourceName("gobs-test"). WithSourceName("gobs-test-scene").
WithFilterName("test_filter"). WithFilterName("test_filter").
WithFilterKind("luma_key_filter_v2"). WithFilterKind("luma_key_filter_v2").
WithFilterSettings(map[string]any{ WithFilterSettings(map[string]any{
@@ -115,18 +158,21 @@ func setup(client *goobs.Client) {
} }
func teardown(client *goobs.Client) { func teardown(client *goobs.Client) {
client.Config.RemoveProfile(config.NewRemoveProfileParams().
WithProfileName("gobs-test-profile"))
client.Filters.RemoveSourceFilter(filters.NewRemoveSourceFilterParams(). client.Filters.RemoveSourceFilter(filters.NewRemoveSourceFilterParams().
WithSourceName("Mic/Aux"). WithSourceName("Mic/Aux").
WithFilterName("test_filter")) WithFilterName("test_filter"))
client.Filters.RemoveSourceFilter(filters.NewRemoveSourceFilterParams(). client.Filters.RemoveSourceFilter(filters.NewRemoveSourceFilterParams().
WithSourceName("gobs-test"). WithSourceName("gobs-test-scene").
WithFilterName("test_filter")) WithFilterName("test_filter"))
client.Scenes.RemoveScene(scenes.NewRemoveSceneParams(). client.Scenes.RemoveScene(scenes.NewRemoveSceneParams().
WithSceneName("gobs-test")) WithSceneName("gobs-test-scene"))
client.Config.SetCurrentSceneCollection(config.NewSetCurrentSceneCollectionParams(). client.Config.SetCurrentSceneCollection(config.NewSetCurrentSceneCollectionParams().
WithSceneCollectionName("default")) WithSceneCollectionName("Untitled"))
client.Stream.StopStream() client.Stream.StopStream()
client.Record.StopRecord() client.Record.StopRecord()

View File

@@ -44,7 +44,7 @@ func TestRecordStart(t *testing.T) {
if out.String() != "Recording started successfully.\n" { if out.String() != "Recording started successfully.\n" {
t.Fatalf("Expected output to contain 'Recording started successfully.', got '%s'", out.String()) 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) { func TestRecordStop(t *testing.T) {
@@ -84,7 +84,7 @@ func TestRecordStop(t *testing.T) {
if !strings.Contains(out.String(), "Recording stopped successfully. Output file: ") { 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()) 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) { func TestRecordToggle(t *testing.T) {
@@ -112,8 +112,6 @@ func TestRecordToggle(t *testing.T) {
t.Fatalf("Failed to toggle recording: %v", err) 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 active {
if out.String() != "Recording stopped successfully.\n" { if out.String() != "Recording stopped successfully.\n" {
t.Fatalf("Expected output to be 'Recording stopped successfully.', got '%s'", out.String()) 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()) 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
} }

View File

@@ -2,11 +2,21 @@ package main
import ( import (
"bytes" "bytes"
"os"
"strings" "strings"
"testing" "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) { func TestReplayBufferStart(t *testing.T) {
skipIfSkipReplayBufferTests(t)
client, disconnect := getClient(t) client, disconnect := getClient(t)
defer disconnect() defer disconnect()
@@ -21,9 +31,12 @@ func TestReplayBufferStart(t *testing.T) {
if out.String() != "Replay buffer started.\n" { if out.String() != "Replay buffer started.\n" {
t.Fatalf("Expected output to be 'Replay buffer started', got '%s'", out.String()) 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) { func TestReplayBufferStop(t *testing.T) {
skipIfSkipReplayBufferTests(t)
client, disconnect := getClient(t) client, disconnect := getClient(t)
defer disconnect() defer disconnect()
@@ -38,9 +51,12 @@ func TestReplayBufferStop(t *testing.T) {
if out.String() != "Replay buffer stopped.\n" { if out.String() != "Replay buffer stopped.\n" {
t.Fatalf("Expected output to be 'Replay buffer stopped.', got '%s'", out.String()) 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) { func TestReplayBufferToggle(t *testing.T) {
skipIfSkipReplayBufferTests(t)
client, disconnect := getClient(t) client, disconnect := getClient(t)
defer disconnect() defer disconnect()
@@ -73,4 +89,5 @@ func TestReplayBufferToggle(t *testing.T) {
t.Fatalf("Expected output to be 'Replay buffer started.', got '%s'", out.String()) 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
} }

View File

@@ -17,8 +17,8 @@ func TestSceneList(t *testing.T) {
if err != nil { if err != nil {
t.Fatalf("Failed to list scenes: %v", err) t.Fatalf("Failed to list scenes: %v", err)
} }
if out.String() == "Current program scene: gobs-test\n" { if out.String() == "Current program scene: gobs-test-scene\n" {
t.Fatalf("Expected output to be 'Current program scene: gobs-test', got '%s'", out.String()) 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 var out bytes.Buffer
context := newContext(client, &out, StyleConfig{}) context := newContext(client, &out, StyleConfig{})
// Set the current scene to "gobs-test" // Set the current scene to "gobs-test-scene"
cmdSwitch := &SceneSwitchCmd{ cmdSwitch := &SceneSwitchCmd{
NewScene: "gobs-test", NewScene: "gobs-test-scene",
} }
err := cmdSwitch.Run(context) err := cmdSwitch.Run(context)
if err != nil { if err != nil {
@@ -45,7 +45,7 @@ func TestSceneCurrent(t *testing.T) {
if err != nil { if err != nil {
t.Fatalf("Failed to get current scene: %v", err) t.Fatalf("Failed to get current scene: %v", err)
} }
if out.String() != "Current program scene: gobs-test\n" { if out.String() != "Current program scene: gobs-test-scene\n" {
t.Fatalf("Expected output to be 'Current program scene: gobs-test', got '%s'", out.String()) t.Fatalf("Expected output to be 'Current program scene: gobs-test-scene', got '%s'", out.String())
} }
} }

View File

@@ -14,7 +14,7 @@ func TestSceneItemList(t *testing.T) {
context := newContext(client, &out, StyleConfig{}) context := newContext(client, &out, StyleConfig{})
cmd := &SceneItemListCmd{ cmd := &SceneItemListCmd{
SceneName: "gobs-test", SceneName: "gobs-test-scene",
} }
err := cmd.Run(context) err := cmd.Run(context)
if err != nil { if err != nil {

334
settings.go Normal file
View 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
}

View File

@@ -43,7 +43,7 @@ func TestStreamStart(t *testing.T) {
if out.String() != "Stream started successfully.\n" { if out.String() != "Stream started successfully.\n" {
t.Fatalf("Expected output to contain 'Stream started successfully.', got '%s'", out.String()) 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) { func TestStreamStop(t *testing.T) {
@@ -82,7 +82,7 @@ func TestStreamStop(t *testing.T) {
if out.String() != "Stream stopped successfully.\n" { if out.String() != "Stream stopped successfully.\n" {
t.Fatalf("Expected output to contain 'Stream stopped successfully.', got '%s'", out.String()) 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) { func TestStreamToggle(t *testing.T) {
@@ -119,5 +119,5 @@ func TestStreamToggle(t *testing.T) {
t.Fatalf("Expected 'Stream started successfully.', got: %s", out.String()) 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
} }

View File

@@ -33,11 +33,18 @@ func (cmd *TextCurrentCmd) Run(ctx *context) error {
return fmt.Errorf("input %s is of %s", cmd.InputName, kind) return fmt.Errorf("input %s is of %s", cmd.InputName, kind)
} }
currentText, ok := resp.InputSettings["text"]
if !ok {
return fmt.Errorf("input %s does not have a 'text' setting", cmd.InputName)
}
if currentText == "" {
currentText = "(empty)"
}
fmt.Fprintf( fmt.Fprintf(
ctx.Out, ctx.Out,
"Current text for source %s: %s\n", "Current text for source %s: %s\n",
ctx.Style.Highlight(cmd.InputName), ctx.Style.Highlight(cmd.InputName),
resp.InputSettings["text"], currentText,
) )
return nil return nil
} }