fix(sqs): set httpRequest.params in queryCompatibility mode in JSON protocol (#4405)

Author: kuhe

.changes/next-release/bugfix-SQS-e1c1ffea.json

@@ -0,0 +1,5 @@
+{
+ "type": "bugfix",
+ "category": "SQS",
+ "description": "add queryCompatibility fix to JSON protocol"
+}

lib/protocol/json.js

@@ -12,6 +12,15 @@ function buildRequest(req) {
  var builder = new JsonBuilder();
 
  if (version === 1) version = '1.0';
+
+ if (api.awsQueryCompatible) {
+ if (!httpRequest.params) {
+ httpRequest.params = {};
+ }
+ // because Query protocol does this.
+ Object.assign(httpRequest.params, req.params);
+ }
+
  httpRequest.body = builder.build(req.params || {}, input);
  httpRequest.headers['Content-Type'] = 'application/x-amz-json-' + version;
  httpRequest.headers['X-Amz-Target'] = target;

lib/services/sqs.js

@@ -5,7 +5,7 @@ AWS.util.update(AWS.SQS.prototype, {
  * @api private
  */
  setupRequestListeners: function setupRequestListeners(request) {
- request.addListener('build', this.buildEndpoint.bind(this));
+ request.addListener('build', this.buildEndpoint);
 
  if (request.service.config.computeChecksums) {
  if (request.operation === 'sendMessage') {
@@ -118,8 +118,7 @@ AWS.util.update(AWS.SQS.prototype, {
  * @api private
  */
  buildEndpoint: function buildEndpoint(request) {
- var params = request.httpRequest.params || this.config.params;
- var url = params.QueueUrl;
+ var url = request.httpRequest.params.QueueUrl;
  if (url) {
  request.httpRequest.endpoint = new AWS.Endpoint(url);