Merge pull request #12 from Bandwidth/recording-pause-resume

feat(recording): add pause and resume subcommands

Author: kshahbw

cmd/recording/golden_test.go

@@ -44,3 +44,49 @@ func TestRecordingListPlainOutput(t *testing.T) {
 		t.Fatalf("golden mismatch:\n got: %q\nwant: %q", out, want)
 	}
 }
+
+func TestRecordingPauseOutput(t *testing.T) {
+	// No t.Parallel(): these tests mutate the global cmdutil.VoiceClient.
+	orig := cmdutil.VoiceClient
+	t.Cleanup(func() { cmdutil.VoiceClient = orig })
+	cmdutil.VoiceClient = func(string) (api.Requester, string, error) {
+		return &testutil.FakeClient{}, "acct-123", nil
+	}
+
+	root := testutil.NewTestRoot(pauseCmd)
+	root.SetArgs([]string{"pause", "c-abc123"})
+
+	out := testutil.CaptureStdout(t, func() {
+		if err := root.Execute(); err != nil {
+			t.Fatalf("execute: %v", err)
+		}
+	})
+
+	want := "Recording paused on call c-abc123.\n"
+	if out != want {
+		t.Fatalf("golden mismatch:\n got: %q\nwant: %q", out, want)
+	}
+}
+
+func TestRecordingResumeOutput(t *testing.T) {
+	// No t.Parallel(): these tests mutate the global cmdutil.VoiceClient.
+	orig := cmdutil.VoiceClient
+	t.Cleanup(func() { cmdutil.VoiceClient = orig })
+	cmdutil.VoiceClient = func(string) (api.Requester, string, error) {
+		return &testutil.FakeClient{}, "acct-123", nil
+	}
+
+	root := testutil.NewTestRoot(resumeCmd)
+	root.SetArgs([]string{"resume", "c-abc123"})
+
+	out := testutil.CaptureStdout(t, func() {
+		if err := root.Execute(); err != nil {
+			t.Fatalf("execute: %v", err)
+		}
+	})
+
+	want := "Recording resumed on call c-abc123.\n"
+	if out != want {
+		t.Fatalf("golden mismatch:\n got: %q\nwant: %q", out, want)
+	}
+}

cmd/recording/pause.go

@@ -0,0 +1,42 @@
+package recording
+
+import (
+	"fmt"
+	"net/url"
+
+	"github.com/spf13/cobra"
+
+	"github.com/Bandwidth/cli/internal/cmdutil"
+)
+
+func init() {
+	Cmd.AddCommand(pauseCmd)
+}
+
+var pauseCmd = &cobra.Command{
+	Use:   "pause <callId>",
+	Short: "Pause the active recording on a live call",
+	Args:  cobra.ExactArgs(1),
+	RunE:  runPause,
+}
+
+func runPause(cmd *cobra.Command, args []string) error {
+	if err := cmdutil.ValidateID(args[0]); err != nil {
+		return err
+	}
+	client, acctID, err := cmdutil.VoiceClient(cmdutil.AccountIDFlag(cmd))
+	if err != nil {
+		return err
+	}
+
+	reqBody := map[string]string{
+		"state": "paused",
+	}
+
+	if err := client.Put(fmt.Sprintf("/accounts/%s/calls/%s/recording", acctID, url.PathEscape(args[0])), reqBody, nil); err != nil {
+		return fmt.Errorf("pausing recording: %w", err)
+	}
+
+	fmt.Printf("Recording paused on call %s.\n", args[0])
+	return nil
+}

cmd/recording/recording_test.go

@@ -13,7 +13,7 @@ func TestCmdStructure(t *testing.T) {
 	for _, c := range Cmd.Commands() {
 		subs[c.Use] = true
 	}
-	for _, name := range []string{"get <callId> <recordingId>", "list <callId>", "delete <callId> <recordingId>", "download <callId> <recordingId>"} {
+	for _, name := range []string{"get <callId> <recordingId>", "list <callId>", "delete <callId> <recordingId>", "download <callId> <recordingId>", "pause <callId>", "resume <callId>"} {
 		if !subs[name] {
 			t.Errorf("missing subcommand %q", name)
 		}
@@ -38,3 +38,15 @@ func TestDownloadRequiredFlags(t *testing.T) {
 		t.Error("missing flag \"output\"")
 	}
 }
+
+func TestPauseArgs(t *testing.T) {
+	if pauseCmd.Args == nil {
+		t.Fatal("pause command should have arg validation")
+	}
+}
+
+func TestResumeArgs(t *testing.T) {
+	if resumeCmd.Args == nil {
+		t.Fatal("resume command should have arg validation")
+	}
+}

cmd/recording/resume.go

@@ -0,0 +1,42 @@
+package recording
+
+import (
+	"fmt"
+	"net/url"
+
+	"github.com/spf13/cobra"
+
+	"github.com/Bandwidth/cli/internal/cmdutil"
+)
+
+func init() {
+	Cmd.AddCommand(resumeCmd)
+}
+
+var resumeCmd = &cobra.Command{
+	Use:   "resume <callId>",
+	Short: "Resume a paused recording on a live call",
+	Args:  cobra.ExactArgs(1),
+	RunE:  runResume,
+}
+
+func runResume(cmd *cobra.Command, args []string) error {
+	if err := cmdutil.ValidateID(args[0]); err != nil {
+		return err
+	}
+	client, acctID, err := cmdutil.VoiceClient(cmdutil.AccountIDFlag(cmd))
+	if err != nil {
+		return err
+	}
+
+	reqBody := map[string]string{
+		"state": "recording",
+	}
+
+	if err := client.Put(fmt.Sprintf("/accounts/%s/calls/%s/recording", acctID, url.PathEscape(args[0])), reqBody, nil); err != nil {
+		return fmt.Errorf("resuming recording: %w", err)
+	}
+
+	fmt.Printf("Recording resumed on call %s.\n", args[0])
+	return nil
+}