mirror of
https://github.com/onyx-and-iris/gobs-cli.git
synced 2026-04-21 00:23:41 +00:00
Compare commits
2 Commits
v0.4.1
...
8aeb7cb183
| Author | SHA1 | Date | |
|---|---|---|---|
| 8aeb7cb183 | |||
| 6e25927bc1 |
28
stream.go
28
stream.go
@@ -17,10 +17,22 @@ type StreamStartCmd struct{} // size = 0x0
|
|||||||
|
|
||||||
// Run executes the command to start streaming.
|
// Run executes the command to start streaming.
|
||||||
func (cmd *StreamStartCmd) Run(ctx *context) error {
|
func (cmd *StreamStartCmd) Run(ctx *context) error {
|
||||||
_, err := ctx.Client.Stream.StartStream()
|
// Check if the stream is already active
|
||||||
|
status, err := ctx.Client.Stream.GetStreamStatus()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
if status.OutputActive {
|
||||||
|
fmt.Fprintln(ctx.Out, "Stream is already active.")
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
_, err = ctx.Client.Stream.StartStream()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Fprintln(ctx.Out, "Streaming started successfully.")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -29,10 +41,22 @@ type StreamStopCmd struct{} // size = 0x0
|
|||||||
|
|
||||||
// Run executes the command to stop streaming.
|
// Run executes the command to stop streaming.
|
||||||
func (cmd *StreamStopCmd) Run(ctx *context) error {
|
func (cmd *StreamStopCmd) Run(ctx *context) error {
|
||||||
_, err := ctx.Client.Stream.StopStream()
|
// Check if the stream is already inactive
|
||||||
|
status, err := ctx.Client.Stream.GetStreamStatus()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
if !status.OutputActive {
|
||||||
|
fmt.Fprintln(ctx.Out, "Stream is already inactive.")
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
_, err = ctx.Client.Stream.StopStream()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Fprintln(ctx.Out, "Streaming stopped successfully.")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -23,6 +23,8 @@ func (cmd *StudioModeEnableCmd) Run(ctx *context) error {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("failed to enable studio mode: %w", err)
|
return fmt.Errorf("failed to enable studio mode: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fmt.Fprintln(ctx.Out, "Studio mode is now enabled")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -35,6 +37,8 @@ func (cmd *StudioModeDisableCmd) Run(ctx *context) error {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("failed to disable studio mode: %w", err)
|
return fmt.Errorf("failed to disable studio mode: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fmt.Fprintln(ctx.Out, "Studio mode is now disabled")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user