mirror of
https://github.com/onyx-and-iris/gobs-cli.git
synced 2026-04-18 07:03:37 +00:00
Compare commits
37 Commits
v0.13.2
...
add-media-
| Author | SHA1 | Date | |
|---|---|---|---|
| ccf863c29a | |||
| fe8ac320ed | |||
| 7adf807d46 | |||
| dca8bc5ffc | |||
| b0437b1656 | |||
| 30f40aee2e | |||
| 6eb8a5ffed | |||
| 6e37c2c6c7 | |||
| bc6cf46b98 | |||
| 51224583c8 | |||
| 6cdc12790a | |||
| 8a5ce67ba0 | |||
| 474693e0f7 | |||
| a960c9ffa5 | |||
| 8ce8727a0a | |||
|
|
fba7c4ce20 | ||
| 1cf983a647 | |||
| dbc26bf6ff | |||
|
|
c5e7bb4e1a | ||
|
|
e087fdefe3 | ||
|
|
bd4a6cad4b | ||
|
|
72fc7d4092 | ||
|
|
cb735cd666 | ||
|
|
db70f8766d | ||
| 101c7552b2 | |||
| 1c0ef025c1 | |||
| 2b7b8e0bd5 | |||
| 040ece840c | |||
| c6406888a9 | |||
| f65af8298d | |||
| 1dfb6f87ac | |||
| 866aedde7c | |||
| 9eb6c8a282 | |||
| eb30cae5b7 | |||
| e6c03a2c92 | |||
| f6b82383f9 | |||
| 55f3b0c981 |
25
CHANGELOG.md
25
CHANGELOG.md
@@ -5,13 +5,36 @@ 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.13.2] - 2025-06-26
|
# [0.17.0] - 2026-01-09
|
||||||
|
|
||||||
|
### Added
|
||||||
|
|
||||||
|
- media command group, see [MediaCmd](https://github.com/onyx-and-iris/gobs-cli?tab=readme-ov-file#mediacmd)
|
||||||
|
|
||||||
|
# [0.16.2] - 2026-01-08
|
||||||
|
|
||||||
|
### 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
|
||||||
|
|
||||||
|
### Added
|
||||||
|
|
||||||
|
- text command group, see [TextCmd](https://github.com/onyx-and-iris/gobs-cli?tab=readme-ov-file#textcmd)
|
||||||
|
|
||||||
|
# [0.13.3] - 2025-06-27
|
||||||
|
|
||||||
### Changed
|
### Changed
|
||||||
|
|
||||||
- usage is now printed on errors.
|
- usage is now printed on errors.
|
||||||
- help is printed in compact mode. This should make it easier to page through help on the root command.
|
- help is printed in compact mode. This should make it easier to page through help on the root command.
|
||||||
|
|
||||||
|
### Fixed
|
||||||
|
|
||||||
|
- Item ID alignment in sceneitem list table.
|
||||||
|
|
||||||
# [0.13.0] - 2025-06-23
|
# [0.13.0] - 2025-06-23
|
||||||
|
|
||||||
### Added
|
### Added
|
||||||
|
|||||||
217
README.md
217
README.md
@@ -4,6 +4,16 @@ A command line interface for OBS Websocket v5
|
|||||||
|
|
||||||
For an outline of past/future changes refer to: [CHANGELOG](CHANGELOG.md)
|
For an outline of past/future changes refer to: [CHANGELOG](CHANGELOG.md)
|
||||||
|
|
||||||
|
-----
|
||||||
|
|
||||||
|
## Table of Contents
|
||||||
|
|
||||||
|
- [Installation](#installation)
|
||||||
|
- [Configuration](#configuration)
|
||||||
|
- [Style](#style)
|
||||||
|
- [Commands](#commands)
|
||||||
|
- [License](#license)
|
||||||
|
|
||||||
## Installation
|
## Installation
|
||||||
|
|
||||||
```console
|
```console
|
||||||
@@ -40,6 +50,36 @@ OBS_PASSWORD=<websocket password>
|
|||||||
OBS_TIMEOUT=5
|
OBS_TIMEOUT=5
|
||||||
```
|
```
|
||||||
|
|
||||||
|
## Style
|
||||||
|
|
||||||
|
Styling is opt-in, by default you will get a colourless output:
|
||||||
|
|
||||||
|

|
||||||
|
|
||||||
|
You may enable styling with the --style/-s flag:
|
||||||
|
|
||||||
|
```console
|
||||||
|
gobs-cli --style="red" sceneitem list
|
||||||
|
```
|
||||||
|
|
||||||
|
Available styles: _red, magenta, purple, blue, cyan, green, yellow, orange, white, grey, navy, black_
|
||||||
|
|
||||||
|

|
||||||
|
|
||||||
|
Optionally you may disable border colouring with the --no-border flag:
|
||||||
|
|
||||||
|

|
||||||
|
|
||||||
|
```console
|
||||||
|
gobs-cli --style="red" --no-border sceneitem list
|
||||||
|
```
|
||||||
|
|
||||||
|
Or with environment variables:
|
||||||
|
|
||||||
|
```env
|
||||||
|
GOBS_STYLE=red
|
||||||
|
GOBS_STYLE_NO_BORDER=true
|
||||||
|
```
|
||||||
|
|
||||||
## Commands
|
## Commands
|
||||||
|
|
||||||
@@ -224,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:
|
||||||
|
|
||||||
@@ -241,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
|
||||||
|
|
||||||
@@ -262,6 +322,50 @@ 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
|
||||||
|
|
||||||
|
- current: Display current text for a text input.
|
||||||
|
- args: InputName
|
||||||
|
|
||||||
|
```console
|
||||||
|
gobs-cli text current "My Text Input"
|
||||||
|
```
|
||||||
|
|
||||||
|
- update: Update the text of a text input.
|
||||||
|
- args: InputName NewText
|
||||||
|
|
||||||
|
```console
|
||||||
|
gobs-cli text update "My Text Input" "hi OBS!"
|
||||||
|
```
|
||||||
|
|
||||||
### RecordCmd
|
### RecordCmd
|
||||||
|
|
||||||
- start: Start recording.
|
- start: Start recording.
|
||||||
@@ -621,34 +725,103 @@ 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"
|
||||||
```
|
```
|
||||||
|
|
||||||
## Style
|
### SettingsCmd
|
||||||
|
|
||||||
By default styling is disabled but you may enable and configure it in the following ways:
|
- show: Show settings.
|
||||||
|
- flags:
|
||||||
|
|
||||||
- --style/-s: Style used in output.
|
*optional*
|
||||||
- GOBS_STYLE
|
- --video: Show video settings.
|
||||||
- --no-border/-b: Disable table border styling in output.
|
- --record: Show record directory.
|
||||||
- GOBS_STYLE_NO_BORDER
|
- --profile: Show profile parameters.
|
||||||
|
|
||||||
Available styles:
|
|
||||||
|
|
||||||
- red
|
|
||||||
- magenta
|
|
||||||
- purple
|
|
||||||
- blue
|
|
||||||
- cyan
|
|
||||||
- green
|
|
||||||
- yellow
|
|
||||||
- orange
|
|
||||||
- white
|
|
||||||
- grey
|
|
||||||
- navy
|
|
||||||
- black
|
|
||||||
|
|
||||||
```console
|
```console
|
||||||
gobs-cli --style=cyan --no-border scene list
|
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.
|
||||||
|
- flags:
|
||||||
|
- --key: Stream key.
|
||||||
|
- --server: Stream server URL.
|
||||||
|
|
||||||
|
*optional*
|
||||||
|
- args: Type
|
||||||
|
|
||||||
|
```console
|
||||||
|
gobs-cli settings stream-service
|
||||||
|
|
||||||
|
gobs-cli settings stream-service --key='live_xyzxyzxyzxyz' rtmp_common
|
||||||
|
```
|
||||||
|
|
||||||
|
- video: Get/Set video setting.
|
||||||
|
- flags:
|
||||||
|
|
||||||
|
*optional*
|
||||||
|
- --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
|
||||||
|
|
||||||
|
gobs-cli settings video --base-width=1920 --base-height=1080
|
||||||
|
```
|
||||||
|
|
||||||
|
### MediaCmd
|
||||||
|
|
||||||
|
- set-cursor: Get/set the cursor position of a media input.
|
||||||
|
- args: InputName
|
||||||
|
|
||||||
|
*optional*
|
||||||
|
- TimeString
|
||||||
|
|
||||||
|
```console
|
||||||
|
gobs-cli media cursor "Media"
|
||||||
|
|
||||||
|
gobs-cli media cursor "Media" "00:08:30"
|
||||||
|
```
|
||||||
|
|
||||||
|
- play: Plays a media input.
|
||||||
|
|
||||||
|
```console
|
||||||
|
gobs-cli media play "Media"
|
||||||
|
```
|
||||||
|
|
||||||
|
- pause: Pauses a media input.
|
||||||
|
|
||||||
|
```console
|
||||||
|
gobs-cli media pause "Media"
|
||||||
|
```
|
||||||
|
|
||||||
|
- stop: Stops a media input.
|
||||||
|
|
||||||
|
```console
|
||||||
|
gobs-cli media stop "Media"
|
||||||
|
```
|
||||||
|
|
||||||
|
- restart: Restarts a media input.
|
||||||
|
|
||||||
|
```console
|
||||||
|
gobs-cli media restart "Media"
|
||||||
|
```
|
||||||
|
|
||||||
|
|
||||||
|
## License
|
||||||
|
|
||||||
|
`gobs-cli` is distributed under the terms of the [MIT](https://spdx.org/licenses/MIT.html) license.
|
||||||
|
|
||||||
|
|
||||||
[userconfigdir]: https://pkg.go.dev/os#UserConfigDir
|
[userconfigdir]: https://pkg.go.dev/os#UserConfigDir
|
||||||
[obs-keyids]: https://github.com/obsproject/obs-studio/blob/master/libobs/obs-hotkeys.h
|
[obs-keyids]: https://github.com/obsproject/obs-studio/blob/master/libobs/obs-hotkeys.h
|
||||||
|
|||||||
@@ -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:
|
||||||
|
|||||||
@@ -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 {
|
||||||
|
|||||||
@@ -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()
|
||||||
|
|
||||||
|
|||||||
BIN
img/coloured-border.png
Executable file
BIN
img/coloured-border.png
Executable file
Binary file not shown.
|
After Width: | Height: | Size: 6.1 KiB |
BIN
img/coloured-no-border.png
Executable file
BIN
img/coloured-no-border.png
Executable file
Binary file not shown.
|
After Width: | Height: | Size: 6.1 KiB |
BIN
img/colourless.png
Executable file
BIN
img/colourless.png
Executable file
Binary file not shown.
|
After Width: | Height: | Size: 4.6 KiB |
373
input.go
373
input.go
@@ -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 {
|
||||||
List InputListCmd `cmd:"" help:"List all inputs." aliases:"ls"`
|
Create InputCreateCmd `cmd:"" help:"Create input." aliases:"c"`
|
||||||
Mute InputMuteCmd `cmd:"" help:"Mute input." aliases:"m"`
|
Remove InputRemoveCmd `cmd:"" help:"Remove input." aliases:"d"`
|
||||||
Unmute InputUnmuteCmd `cmd:"" help:"Unmute input." aliases:"um"`
|
List InputListCmd `cmd:"" help:"List all inputs." aliases:"ls"`
|
||||||
Toggle InputToggleCmd `cmd:"" help:"Toggle input." aliases:"tg"`
|
ListKinds InputListKindsCmd `cmd:"" help:"List input kinds." aliases:"k"`
|
||||||
|
Mute InputMuteCmd `cmd:"" help:"Mute input." aliases:"m"`
|
||||||
|
Unmute InputUnmuteCmd `cmd:"" help:"Unmute input." aliases:"um"`
|
||||||
|
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
|
||||||
|
}
|
||||||
|
|||||||
@@ -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) {
|
||||||
|
|||||||
3
main.go
3
main.go
@@ -59,6 +59,7 @@ type CLI struct {
|
|||||||
Sceneitem SceneItemCmd `help:"Manage scene items." cmd:"" aliases:"si" group:"Scene Item"`
|
Sceneitem SceneItemCmd `help:"Manage scene items." cmd:"" aliases:"si" group:"Scene Item"`
|
||||||
Group GroupCmd `help:"Manage groups." cmd:"" aliases:"g" group:"Group"`
|
Group GroupCmd `help:"Manage groups." cmd:"" aliases:"g" group:"Group"`
|
||||||
Input InputCmd `help:"Manage inputs." cmd:"" aliases:"i" group:"Input"`
|
Input InputCmd `help:"Manage inputs." cmd:"" aliases:"i" group:"Input"`
|
||||||
|
Text TextCmd `help:"Manage text inputs." cmd:"" aliases:"t" group:"Text Input"`
|
||||||
Record RecordCmd `help:"Manage recording." cmd:"" aliases:"rec" group:"Recording"`
|
Record RecordCmd `help:"Manage recording." cmd:"" aliases:"rec" group:"Recording"`
|
||||||
Stream StreamCmd `help:"Manage streaming." cmd:"" aliases:"st" group:"Streaming"`
|
Stream StreamCmd `help:"Manage streaming." cmd:"" aliases:"st" group:"Streaming"`
|
||||||
Scenecollection SceneCollectionCmd `help:"Manage scene collections." cmd:"" aliases:"scn" group:"Scene Collection"`
|
Scenecollection SceneCollectionCmd `help:"Manage scene collections." cmd:"" aliases:"scn" group:"Scene Collection"`
|
||||||
@@ -70,6 +71,8 @@ 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"`
|
||||||
|
Media MediaCmd `help:"Manage media inputs." cmd:"" aliases:"mi" group:"Media Input"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type context struct {
|
type context struct {
|
||||||
|
|||||||
64
main_test.go
64
main_test.go
@@ -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()
|
||||||
|
|||||||
140
media.go
Normal file
140
media.go
Normal file
@@ -0,0 +1,140 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
|
||||||
|
"github.com/andreykaipov/goobs/api/requests/mediainputs"
|
||||||
|
)
|
||||||
|
|
||||||
|
// MediaCmd represents a collection of commands to control media inputs.
|
||||||
|
type MediaCmd struct {
|
||||||
|
Cursor MediaCursorCmd `cmd:"" help:"Get/set the cursor position of a media input."`
|
||||||
|
Play MediaPlayCmd `cmd:"" help:"Plays a media input."`
|
||||||
|
Pause MediaPauseCmd `cmd:"" help:"Pauses a media input."`
|
||||||
|
Stop MediaStopCmd `cmd:"" help:"Stops a media input."`
|
||||||
|
Restart MediaRestartCmd `cmd:"" help:"Restarts a media input."`
|
||||||
|
}
|
||||||
|
|
||||||
|
// MediaCursorCmd represents the command to get or set the cursor position of a media input.
|
||||||
|
type MediaCursorCmd struct {
|
||||||
|
InputName string `arg:"" help:"Name of the media input."`
|
||||||
|
TimeString string `arg:"" help:"Time position to set the cursor to (e.g., '00:01:30' for 1 minute 30 seconds). If not provided, the current cursor position will be displayed." optional:""`
|
||||||
|
}
|
||||||
|
|
||||||
|
// Run executes the command to set the cursor position of the media input.
|
||||||
|
func (cmd *MediaCursorCmd) Run(ctx *context) error {
|
||||||
|
if cmd.TimeString == "" {
|
||||||
|
resp, err := ctx.Client.MediaInputs.GetMediaInputStatus(
|
||||||
|
mediainputs.NewGetMediaInputStatusParams().
|
||||||
|
WithInputName(cmd.InputName))
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to get media input cursor: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Fprintf(
|
||||||
|
ctx.Out,
|
||||||
|
"%s cursor position: %s\n",
|
||||||
|
ctx.Style.Highlight(cmd.InputName),
|
||||||
|
formatMillisecondsToTimeString(resp.MediaCursor),
|
||||||
|
)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
position, err := parseTimeStringToMilliseconds(cmd.TimeString)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to parse time string: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
_, err = ctx.Client.MediaInputs.SetMediaInputCursor(
|
||||||
|
mediainputs.NewSetMediaInputCursorParams().
|
||||||
|
WithInputName(cmd.InputName).
|
||||||
|
WithMediaCursor(position))
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to set media input cursor: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Fprintf(
|
||||||
|
ctx.Out,
|
||||||
|
"Set %s cursor to %s (%.0f ms)\n",
|
||||||
|
ctx.Style.Highlight(cmd.InputName),
|
||||||
|
ctx.Style.Highlight(cmd.TimeString),
|
||||||
|
position,
|
||||||
|
)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// MediaPlayCmd represents the command to play a media input.
|
||||||
|
type MediaPlayCmd struct {
|
||||||
|
InputName string `arg:"" help:"Name of the media input."`
|
||||||
|
}
|
||||||
|
|
||||||
|
// Run executes the command to play the media input.
|
||||||
|
func (cmd *MediaPlayCmd) Run(ctx *context) error {
|
||||||
|
_, err := ctx.Client.MediaInputs.TriggerMediaInputAction(
|
||||||
|
mediainputs.NewTriggerMediaInputActionParams().
|
||||||
|
WithInputName(cmd.InputName).
|
||||||
|
WithMediaAction("OBS_WEBSOCKET_MEDIA_INPUT_ACTION_PLAY"))
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to play media input: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Fprintln(ctx.Out, "Playing media input:", cmd.InputName)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// MediaPauseCmd represents the command to pause a media input.
|
||||||
|
type MediaPauseCmd struct {
|
||||||
|
InputName string `arg:"" help:"Name of the media input."`
|
||||||
|
}
|
||||||
|
|
||||||
|
// Run executes the command to pause the media input.
|
||||||
|
func (cmd *MediaPauseCmd) Run(ctx *context) error {
|
||||||
|
_, err := ctx.Client.MediaInputs.TriggerMediaInputAction(
|
||||||
|
mediainputs.NewTriggerMediaInputActionParams().
|
||||||
|
WithInputName(cmd.InputName).
|
||||||
|
WithMediaAction("OBS_WEBSOCKET_MEDIA_INPUT_ACTION_PAUSE"))
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to pause media input: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Fprintln(ctx.Out, "Pausing media input:", cmd.InputName)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// MediaStopCmd represents the command to stop a media input.
|
||||||
|
type MediaStopCmd struct {
|
||||||
|
InputName string `arg:"" help:"Name of the media input."`
|
||||||
|
}
|
||||||
|
|
||||||
|
// Run executes the command to stop the media input.
|
||||||
|
func (cmd *MediaStopCmd) Run(ctx *context) error {
|
||||||
|
_, err := ctx.Client.MediaInputs.TriggerMediaInputAction(
|
||||||
|
mediainputs.NewTriggerMediaInputActionParams().
|
||||||
|
WithInputName(cmd.InputName).
|
||||||
|
WithMediaAction("OBS_WEBSOCKET_MEDIA_INPUT_ACTION_STOP"))
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to stop media input: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Fprintln(ctx.Out, "Stopping media input:", cmd.InputName)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// MediaRestartCmd represents the command to restart a media input.
|
||||||
|
type MediaRestartCmd struct {
|
||||||
|
InputName string `arg:"" help:"Name of the media input."`
|
||||||
|
}
|
||||||
|
|
||||||
|
// Run executes the command to restart the media input.
|
||||||
|
func (cmd *MediaRestartCmd) Run(ctx *context) error {
|
||||||
|
_, err := ctx.Client.MediaInputs.TriggerMediaInputAction(
|
||||||
|
mediainputs.NewTriggerMediaInputActionParams().
|
||||||
|
WithInputName(cmd.InputName).
|
||||||
|
WithMediaAction("OBS_WEBSOCKET_MEDIA_INPUT_ACTION_RESTART"))
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to restart media input: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Fprintln(ctx.Out, "Restarting media input:", cmd.InputName)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
@@ -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
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -59,7 +59,7 @@ func (cmd *SceneItemListCmd) Run(ctx *context) error {
|
|||||||
style := lipgloss.NewStyle().Padding(0, 3)
|
style := lipgloss.NewStyle().Padding(0, 3)
|
||||||
switch col {
|
switch col {
|
||||||
case 0:
|
case 0:
|
||||||
style = style.Align(lipgloss.Left)
|
style = style.Align(lipgloss.Center)
|
||||||
case 1:
|
case 1:
|
||||||
style = style.Align(lipgloss.Left)
|
style = style.Align(lipgloss.Left)
|
||||||
case 2:
|
case 2:
|
||||||
|
|||||||
@@ -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
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)." optional:""`
|
||||||
|
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.Type == "" {
|
||||||
|
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", resp.StreamServiceType)
|
||||||
|
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 {
|
||||||
|
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.BaseWidth == 0 && cmd.BaseHeight == 0 && cmd.OutputWidth == 0 &&
|
||||||
|
cmd.OutputHeight == 0 && cmd.FPSNum == 0 && cmd.FPSDen == 0 {
|
||||||
|
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" {
|
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
|
||||||
}
|
}
|
||||||
|
|||||||
85
text.go
Normal file
85
text.go
Normal file
@@ -0,0 +1,85 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"github.com/andreykaipov/goobs/api/requests/inputs"
|
||||||
|
)
|
||||||
|
|
||||||
|
// TextCmd provides commands for managing text inputs in OBS.
|
||||||
|
type TextCmd struct {
|
||||||
|
Current TextCurrentCmd `cmd:"current" help:"Display current text for a text input." aliases:"c"`
|
||||||
|
Update TextUpdateCmd `cmd:"update" help:"Update the text of a text input." aliases:"u"`
|
||||||
|
}
|
||||||
|
|
||||||
|
// TextCurrentCmd provides a command to display the current text of a text input.
|
||||||
|
type TextCurrentCmd struct {
|
||||||
|
InputName string `arg:"" help:"Name of the text source."`
|
||||||
|
}
|
||||||
|
|
||||||
|
// Run executes the command to display the current text of a text input.
|
||||||
|
func (cmd *TextCurrentCmd) Run(ctx *context) error {
|
||||||
|
resp, err := ctx.Client.Inputs.GetInputSettings(
|
||||||
|
inputs.NewGetInputSettingsParams().WithInputName(cmd.InputName),
|
||||||
|
)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to get input settings: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check if the input is a text input
|
||||||
|
kind := resp.InputKind
|
||||||
|
if !strings.HasPrefix(kind, "text_") {
|
||||||
|
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(
|
||||||
|
ctx.Out,
|
||||||
|
"Current text for source %s: %s\n",
|
||||||
|
ctx.Style.Highlight(cmd.InputName),
|
||||||
|
currentText,
|
||||||
|
)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// TextUpdateCmd provides a command to update the text of a text input.
|
||||||
|
type TextUpdateCmd struct {
|
||||||
|
InputName string `arg:"" help:"Name of the text source."`
|
||||||
|
NewText string `arg:"" help:"New text to set for the source." default:""`
|
||||||
|
}
|
||||||
|
|
||||||
|
// Run executes the command to update the text of a text input.
|
||||||
|
func (cmd *TextUpdateCmd) Run(ctx *context) error {
|
||||||
|
resp, err := ctx.Client.Inputs.GetInputSettings(
|
||||||
|
inputs.NewGetInputSettingsParams().WithInputName(cmd.InputName),
|
||||||
|
)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to get input settings: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check if the input is a text input
|
||||||
|
kind := resp.InputKind
|
||||||
|
if !strings.HasPrefix(kind, "text_") {
|
||||||
|
return fmt.Errorf("input %s is of %s", cmd.InputName, kind)
|
||||||
|
}
|
||||||
|
|
||||||
|
if _, err := ctx.Client.Inputs.SetInputSettings(&inputs.SetInputSettingsParams{
|
||||||
|
InputName: &cmd.InputName,
|
||||||
|
InputSettings: map[string]any{"text": &cmd.NewText},
|
||||||
|
}); err != nil {
|
||||||
|
return fmt.Errorf("failed to update text for source %s: %w", cmd.InputName, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if cmd.NewText == "" {
|
||||||
|
cmd.NewText = "(empty)"
|
||||||
|
}
|
||||||
|
fmt.Fprintf(ctx.Out, "Updated text for source %s to: %s\n", ctx.Style.Highlight(cmd.InputName), cmd.NewText)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
40
util.go
40
util.go
@@ -3,8 +3,10 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"strings"
|
"strings"
|
||||||
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
func snakeCaseToTitleCase(snake string) string {
|
func snakeCaseToTitleCase(snake string) string {
|
||||||
@@ -36,3 +38,41 @@ func trimPrefix(s, prefix string) string {
|
|||||||
}
|
}
|
||||||
return s
|
return s
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func parseTimeStringToMilliseconds(timeStr string) (float64, error) {
|
||||||
|
parts := strings.Split(timeStr, ":")
|
||||||
|
var durationStr string
|
||||||
|
|
||||||
|
switch len(parts) {
|
||||||
|
case 1:
|
||||||
|
// Format: SS -> "SSs"
|
||||||
|
durationStr = parts[0] + "s"
|
||||||
|
case 2:
|
||||||
|
// Format: MM:SS -> "MMmSSs"
|
||||||
|
durationStr = parts[0] + "m" + parts[1] + "s"
|
||||||
|
case 3:
|
||||||
|
// Format: HH:MM:SS -> "HHhMMmSSs"
|
||||||
|
durationStr = parts[0] + "h" + parts[1] + "m" + parts[2] + "s"
|
||||||
|
default:
|
||||||
|
return 0, fmt.Errorf("invalid time format: %s", timeStr)
|
||||||
|
}
|
||||||
|
|
||||||
|
duration, err := time.ParseDuration(durationStr)
|
||||||
|
if err != nil {
|
||||||
|
return 0, fmt.Errorf("failed to parse duration: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return duration.Seconds() * 1000, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func formatMillisecondsToTimeString(ms float64) string {
|
||||||
|
totalSeconds := int(ms / 1000)
|
||||||
|
hours := totalSeconds / 3600
|
||||||
|
minutes := (totalSeconds % 3600) / 60
|
||||||
|
seconds := totalSeconds % 60
|
||||||
|
|
||||||
|
if hours > 0 {
|
||||||
|
return fmt.Sprintf("%02d:%02d:%02d", hours, minutes, seconds)
|
||||||
|
}
|
||||||
|
return fmt.Sprintf("%02d:%02d", minutes, seconds)
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user