sleep monitoring done

Author: Clara Richter

getting_started/asyncio/power/sleep_monitoring.py

@@ -40,8 +40,8 @@ async def main():
 
     await rvr.on_did_sleep_notify(on_entered_soft_sleep)
 
-    # Sleep for 5 minutes such that we see the aforementioned events have time to occur
-    await asyncio.sleep(300)
+    # Sleep for 310 seconds such that we see the aforementioned events have time to occur
+    await asyncio.sleep(310)
 
 
 loop.run_until_complete(

getting_started/observer/power/sleep_monitoring.py

@@ -33,8 +33,10 @@ def main():
 
     rvr.on_did_sleep_notify(on_entered_soft_sleep)
 
-    # Sleep for 5 minutes such that we see the aforementioned events have time to occur
-    time.sleep(300)
+    # Sleep for 310 seconds such that we see the aforementioned events have time to occur
+    time.sleep(310)
+
+    rvr.close()
 
 
 main()

sphero_sdk/asyncio/client/dal/serial_async_dal.py

@@ -89,19 +89,22 @@ async def on_command(self, did, cid, target, handler, timeout=None, outputs=[]):
 
         """
         async def wrapper(msg):
-            response_dictionary = {}
-            for param in sorted(outputs, key=lambda x: x.index):
-                response_dictionary[param.name] = msg.unpack(
-                    param.data_type,
-                    count=param.size
-                )
-
-            logger.debug("Command response wrapper invoked, returning: %s", response_dictionary)
-
-            await handler(response_dictionary)
+            if len(outputs) > 0:
+                response_dictionary = {}
+                for param in sorted(outputs, key=lambda x: x.index):
+                    response_dictionary[param.name] = msg.unpack(
+                        param.data_type,
+                        count=param.size
+                    )
+
+                logger.debug("Command response wrapper invoked, returning: {}".format(response_dictionary))
+                await handler(response_dictionary)
+            else:
+                logger.debug("No outputs expected, invoking callback.")
+                await handler()
 
             return ErrorCode.SUCCESS, bytearray()
 
-        logger.debug("Command worker added for %s","did:{} cid:{} target:{}".format(did, cid, target))
+        logger.debug("Command worker added for DID:{} CID:{} Target:{}".format(did, cid, target))
 
-        self.handler.add_command_worker(did, cid, target, wrapper)
+        self.handler.add_command_worker(did, cid, target, wrapper)