Skip to content

Commit 28e6ef9

Browse files
committed
fixed wrong code with shaka-packager
1 parent af2a4d5 commit 28e6ef9

File tree

2 files changed

+9
-26
lines changed

2 files changed

+9
-26
lines changed

pkg/executor_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ func TestShakaExecutorRun(t *testing.T) {
3333
ctx := context.Background()
3434

3535
mockRunner := &MockCommandRunner{}
36-
mockRunner.On("CommandContext", ctx, "mock_binary", []string{}).
36+
mockRunner.On("CommandContext", ctx, "mock_binary", []string{""}).
3737
Return(exec.Command("echo", "hello world"))
3838

3939
shaka := NewShakaPackager("mock_binary")
@@ -48,15 +48,15 @@ func TestShakaExecutorRun(t *testing.T) {
4848

4949
// then
5050
require.NoError(t, err)
51-
mockRunner.AssertCalled(t, "CommandContext", ctx, "mock_binary", []string{})
51+
mockRunner.AssertCalled(t, "CommandContext", ctx, "mock_binary", []string{""})
5252
}
5353

5454
func TestShakaExecutorRunError(t *testing.T) {
5555
// given
5656
ctx := context.Background()
5757

5858
mockRunner := &MockCommandRunner{}
59-
mockRunner.On("CommandContext", ctx, "shaka-packager", []string{}).
59+
mockRunner.On("CommandContext", ctx, "shaka-packager", []string{""}).
6060
Return(exec.Command("false"))
6161

6262
shaka := NewShakaPackager("shaka-packager")

pkg/shaka.go

Lines changed: 6 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -73,32 +73,15 @@ func (r *ShakaPackager) BuildAndValidate() ([]string, error) {
7373
args := []string{}
7474
validationErrors := []string{}
7575

76-
for i, stream := range r.StreamOptions {
77-
streamDescriptor := []string{}
78-
for j, opt := range stream.Options {
79-
if err := opt.Validate(); err != nil {
80-
validationErrors = append(validationErrors, fmt.Sprintf("stream[%d].option[%d]: %v", i, j, err))
81-
continue
82-
}
83-
84-
streamDescriptor = append(streamDescriptor, opt.Parse())
85-
}
86-
87-
args = append(args, strings.Join(streamDescriptor, ","))
88-
}
76+
args, argsError := buildStreamDescriptors(r.StreamOptions...)
77+
flags, flagError := buildFlags(r.Flags)
8978

90-
for i, flag := range r.Flags.Flags {
91-
if err := flag.Validate(); err != nil {
92-
validationErrors = append(validationErrors, fmt.Sprintf("flag[%d]: %v", i, err))
93-
continue
94-
}
79+
if argsError != nil || flagError != nil {
80+
return nil, fmt.Errorf("validation errors: %s", validationErrors)
81+
}
9582

96-
args = append(args, flag.Parse())
97-
}
83+
args = append(args, flags)
9884

99-
if len(validationErrors) > 0 {
100-
return nil, fmt.Errorf("validation errors: %s", validationErrors)
101-
}
10285

10386
return args, nil
10487
}

0 commit comments

Comments
 (0)