Skip to content

Commit b094ac9

Browse files
Alex Bondarassaf758
authored andcommitted
fix lint in getItems
1 parent c522705 commit b094ac9

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

pkg/dataplane/http/context.go

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1462,17 +1462,20 @@ func (c *context) getItemsParseJSONResponse(response *v3io.Response, getItemsInp
14621462
return nil, err
14631463
}
14641464

1465+
lastItemIncluded, _ := strconv.ParseBool(getItemsResponse.LastItemIncluded)
1466+
scattered, _ := strconv.ParseBool(getItemsResponse.Scattered)
1467+
14651468
//validate getItems response to avoid infinite loop
1466-
if getItemsResponse.LastItemIncluded != "TRUE" && (getItemsResponse.NextMarker == "" || getItemsResponse.NextMarker == getItemsInput.Marker) {
1469+
if !lastItemIncluded && (getItemsResponse.NextMarker == "" || getItemsResponse.NextMarker == getItemsInput.Marker) {
14671470
errMsg := fmt.Sprintf("Invalid getItems response: lastItemIncluded=false and nextMarker='%s', "+
14681471
"startMarker='%s', probably due to object size bigger than 2M. Query is: %+v", getItemsResponse.NextMarker, getItemsInput.Marker, getItemsInput)
14691472
c.logger.Warn(errMsg)
14701473
}
14711474

14721475
getItemsOutput := v3io.GetItemsOutput{
14731476
NextMarker: getItemsResponse.NextMarker,
1474-
Last: getItemsResponse.LastItemIncluded == "TRUE",
1475-
Scattered: getItemsResponse.Scattered == "TRUE",
1477+
Last: lastItemIncluded,
1478+
Scattered: scattered,
14761479
}
14771480

14781481
// iterate through the items and decode them

0 commit comments

Comments
 (0)