Fix error swallowing behavior

Author: tstirrat15

internal/cmd/backup.go

@@ -42,10 +42,20 @@ const (
 // cobraRunEFunc is the signature of a cobra.Command.RunE function.
 type cobraRunEFunc = func(cmd *cobra.Command, args []string) (err error)
 
+// TODO: apply these to other cmds as well
+var errorHandlers = []func(error) error{
+	addPermissionDeniedErrInfo,
+	addSizeErrInfo,
+}
+
 // withErrorHandling is a wrapper that centralizes error handling, instead of having to scatter it around the command logic.
 func withErrorHandling(f cobraRunEFunc) cobraRunEFunc {
 	return func(cmd *cobra.Command, args []string) (err error) {
-		return addSizeErrInfo(f(cmd, args))
+		cmdErr := f(cmd, args)
+		for _, handler := range errorHandlers {
+			cmdErr = handler(cmdErr)
+		}
+		return cmdErr
 	}
 }
 
@@ -398,6 +408,9 @@ func backupCreateCmdFunc(cmd *cobra.Command, args []string) (err error) {
 		}
 		return nil
 	})
+	if err != nil {
+		return err
+	}
 
 	backupCompleted = true
 	return nil
@@ -902,3 +915,15 @@ func addSizeErrInfo(err error) error {
 
 	return fmt.Errorf("%w: set flag --max-message-size=%d to increase the maximum allowable size", err, 2*necessaryByteCount)
 }
+
+func addPermissionDeniedErrInfo(err error) error {
+	if err == nil {
+		return nil
+	}
+
+	code := status.Code(err)
+	if code != codes.PermissionDenied {
+		return err
+	}
+	return fmt.Errorf("%w: ensure that the token used for this call has all requisite permissions", err)
+}

internal/cmd/backup_test.go

@@ -281,9 +281,13 @@ func TestBackupCreateCmdFunc(t *testing.T) {
 
 	ctx := t.Context()
 	srv := zedtesting.NewTestServer(ctx, t)
+	runErrs := make(chan error, 1)
 	go func() {
-		require.NoError(t, srv.Run(ctx))
+		err := srv.Run(ctx)
+		runErrs <- err
 	}()
+	err := <-runErrs
+	require.NoError(t, err)
 	conn, err := srv.GRPCDialContext(ctx)
 	require.NoError(t, err)
 
@@ -518,9 +522,13 @@ func TestBackupRestoreCmdFunc(t *testing.T) {
 
 	ctx := t.Context()
 	srv := zedtesting.NewTestServer(ctx, t)
+	runErrs := make(chan error, 1)
 	go func() {
-		require.NoError(t, srv.Run(ctx))
+		err := srv.Run(ctx)
+		runErrs <- err
 	}()
+	err := <-runErrs
+	require.NoError(t, err)
 	conn, err := srv.GRPCDialContext(ctx)
 	require.NoError(t, err)