adapt to awscrt.mqtt on-message callbacks taking additional args (#156)

Also update awscrt version

Author: graebm

awsiot/__init__.py

@@ -132,7 +132,7 @@ def on_suback(suback_future):
                 except Exception as e:
                     future.set_exception(e)
 
-            def callback_wrapper(topic, payload, **kwargs):
+            def callback_wrapper(topic, payload, dup, qos, retain, **kwargs):
                 try:
                     payload_obj = json.loads(payload.decode())
                     event = payload_to_class_fn(payload_obj)

samples/basic_discovery.py

@@ -98,7 +98,7 @@ def try_iot_endpoints():
 
 if args.mode == 'both' or args.mode == 'subscribe':
 
-    def on_publish(topic, payload, **kwargs):
+    def on_publish(topic, payload, dup, qos, retain, **kwargs):
         print('Publish received on topic {}'.format(topic))
         print(payload)
 

samples/pubsub.py

@@ -76,7 +76,7 @@ def on_resubscribe_complete(resubscribe_future):
 
 
 # Callback when the subscribed topic receives a message
-def on_message_received(topic, payload, **kwargs):
+def on_message_received(topic, payload, dup, qos, retain, **kwargs):
     print("Received message from topic '{}': {}".format(topic, payload))
     global received_count
     received_count += 1

setup.py

@@ -19,7 +19,7 @@
         "Operating System :: OS Independent",
     ],
     install_requires=[
-        'awscrt==0.9.15',
+        'awscrt==0.10.6',
     ],
     python_requires='>=3.5',
 )