Dont overwrite host and change fetch body default

docs/history.rst

@@ -3,6 +3,11 @@
 Version History
 ===============
+0.7.0 (2017-06-02)
+------------------
+ - Don't overwrite the ``Host`` HTTP header if it's set
+ - Change fetch body arg default to None
+
 0.6.0 (2017-04-18)
 ------------------
  - Add support for using ``curl_httpclient.CurlAsyncHTTPClient``

example.py

+import json
+import logging
+import pprint
+
+import tornado_aws
+from tornado import gen, ioloop
+
+HEADERS = {'Content-Type': 'application/x-amz-json-1.0',
+           'x-amz-target': 'DynamoDB_20120810.DescribeTable'}
+PAYLOAD = {'TableName': 'prod-us-east-1-history'}
+
+@gen.coroutine
+def async_request():
+    client = tornado_aws.AsyncAWSClient('dynamodb', use_curl=True)
+    response = yield client.fetch('POST', '/', headers=HEADERS,
+                                  body=json.dumps(PAYLOAD))
+    x = json.loads(response.body.decode('utf-8'))
+    pprint.pprint(x)
+    ioloop.IOLoop.instance().stop()
+
+logging.basicConfig(level=logging.DEBUG)
+_ioloop = ioloop.IOLoop.instance()
+_ioloop.add_callback(async_request)
+_ioloop.start()

setup.py

@@ -39,7 +39,7 @@ def read_requirements(name):
 setuptools.setup(
     name='tornado-aws',
-    version='0.6.0',
+    version='0.7.0',
     description=DESC,
     long_description=open('README.rst').read(),
     author='Gavin M. Roy',

tornado_aws/__init__.py

@@ -6,6 +6,6 @@ from tornado_aws.client import AWSClient
 from tornado_aws.client import AsyncAWSClient
 from tornado_aws.client import exceptions
-__version__ = '0.6.0'
+__version__ = '0.7.0'
 __all__ = ['AWSClient', 'AsyncAWSClient', 'exceptions']

tornado_aws/client.py

@@ -303,10 +303,11 @@ class AWSClient(object):
         headers.update({
             'Content-Length': str(len(body)),
             'Date': amz_date,
-            'Host': self._host,
             'X-Amz-Content-sha256': payload_hash
         })
+        headers.setdefault('Host', self._host)
+
         # Temporary auth security token
         if self._auth_config.security_token:
             headers['X-Amz-Security-Token'] = self._auth_config.security_token
@@ -468,7 +469,7 @@ class AsyncAWSClient(AWSClient):
         return httpclient.AsyncHTTPClient(max_clients=self._max_clients,
                                           force_instance=True)
-    def fetch(self, method, path='/', query_args=None, headers=None, body=b'',
+    def fetch(self, method, path='/', query_args=None, headers=None, body=None,
               _recursed=False):
         """Executes a request, returning an
         :py:class:`HTTPResponse <tornado.httpclient.HTTPResponse>`.