Merge pull request #12 from alexbondar92/alexb/IG-18457

assaf758 · web-flow · commit 55c159e4055b · 2021-05-13T18:50:48.000+03:00
IG-18457: bugfix put records error response check - fix
diff --git a/pkg/v3ctl/stream/createrecord.go b/pkg/v3ctl/stream/createrecord.go
@@ -60,8 +60,8 @@ func newCreateRecordCommandeer(createStreamCommandeer *createStreamCommandeer) (
 				return errors.Wrap(err, "Failed to get create stream")
 			}
 
-			putRecordsResponse, ok := response.Output.(v3io.PutRecordsOutput)
-			if ok && putRecordsResponse.FailedRecordCount != 0 {
+			putRecordsResponse := response.Output.(*v3io.PutRecordsOutput)
+			if putRecordsResponse.FailedRecordCount != 0 {
 				return errors.Errorf("Failed to put all records, FailedRecordCount: %d",
 					putRecordsResponse.FailedRecordCount)
 			}

Original file line number	Diff line number	Diff line change
`@@ -60,8 +60,8 @@ func newCreateRecordCommandeer(createStreamCommandeer *createStreamCommandeer) (`
`60`	`60`	`return errors.Wrap(err, "Failed to get create stream")`
`61`	`61`	`}`
`62`	`62`
`63`		`- putRecordsResponse, ok := response.Output.(v3io.PutRecordsOutput)`
`64`		`- if ok && putRecordsResponse.FailedRecordCount != 0 {`
	`63`	`+ putRecordsResponse := response.Output.(*v3io.PutRecordsOutput)`
	`64`	`+ if putRecordsResponse.FailedRecordCount != 0 {`
`65`	`65`	`return errors.Errorf("Failed to put all records, FailedRecordCount: %d",`
`66`	`66`	`putRecordsResponse.FailedRecordCount)`
`67`	`67`	`}`