Code formatting and Windows fix in examples

Author: Joel Collins

example/mjpeg-stream.py

@@ -5,6 +5,7 @@
 import logging
 import os
 import pathlib
+import sys
 import time
 import uuid
 from datetime import datetime
@@ -13,6 +14,13 @@
 
 from webthing import Action, Event, Property, Thing, Value, WebThingServer
 
+if (
+    sys.version_info[0] == 3
+    and sys.version_info[1] >= 8
+    and sys.platform.startswith("win")
+):
+    asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())
+
 """
 PIL spams the logger with debug-level information. This is a pain when debugging api.app.
 We override the logging settings in api.app by setting a level for PIL here.
@@ -35,11 +43,7 @@ def _start_runner(self):
 
     def generate_new_dummy_image(self):
         # Create a dummy image to serve in the stream
-        image = Image.new(
-            "RGB",
-            (640, 480),
-            color=(0, 0, 0),
-        )
+        image = Image.new("RGB", (640, 480), color=(0, 0, 0),)
 
         draw = ImageDraw.Draw(image)
         draw.text(

example/single-thing.py

@@ -2,11 +2,19 @@
 
 import asyncio
 import logging
+import sys
 import time
 import uuid
 
 from webthing import Action, Event, Property, Thing, Value, WebThingServer
 
+if (
+    sys.version_info[0] == 3
+    and sys.version_info[1] >= 8
+    and sys.platform.startswith("win")
+):
+    asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())
+
 
 class OverheatedEvent(Event):
     def __init__(self, thing, data):
@@ -64,28 +72,18 @@ async def fade_function(args):
         thing,
         "fade",
         fade_function,
-        metadata={
-            "title": "Fade",
-            "description": "Fade the lamp to a given level",
-        },
+        metadata={"title": "Fade", "description": "Fade the lamp to a given level",},
         input_={
             "type": "object",
-            "required": [
-                "brightness",
-                "duration",
-            ],
+            "required": ["brightness", "duration",],
             "properties": {
                 "brightness": {
                     "type": "integer",
                     "minimum": 0,
                     "maximum": 100,
                     "unit": "percent",
                 },
-                "duration": {
-                    "type": "integer",
-                    "minimum": 1,
-                    "unit": "milliseconds",
-                },
+                "duration": {"type": "integer", "minimum": 1, "unit": "milliseconds",},
             },
         },
         output={"type": "string"},

webthing/event.py

@@ -26,9 +26,7 @@ def as_event_description(self):
         Returns a dictionary describing the event.
         """
         description = {
-            self.name: {
-                "timestamp": self.time,
-            },
+            self.name: {"timestamp": self.time,},
         }
 
         if self.data is not None:

webthing/property.py

@@ -13,12 +13,7 @@ class Property:
     """A Property represents an individual state value of a thing."""
 
     def __init__(
-        self,
-        thing,
-        name,
-        value,
-        metadata=None,
-        content_type="application/json",
+        self, thing, name, value, metadata=None, content_type="application/json",
     ):
         """
         Initialize the object.

webthing/server.py

@@ -163,20 +163,15 @@ def get(self):
 
         description = self.thing.as_thing_description()
         description["links"].append(
-            {
-                "rel": "alternate",
-                "href": "{}{}".format(ws_href, self.thing.get_href()),
-            }
+            {"rel": "alternate", "href": "{}{}".format(ws_href, self.thing.get_href()),}
         )
         description["base"] = "{}://{}{}".format(
             self.request.protocol,
             self.request.headers.get("Host", ""),
             self.thing.get_href(),
         )
         description["securityDefinitions"] = {
-            "nosec_sc": {
-                "scheme": "nosec",
-            },
+            "nosec_sc": {"scheme": "nosec",},
         }
         description["security"] = "nosec_sc"
 
@@ -312,9 +307,7 @@ def update_property(self, property_):
         message = json.dumps(
             {
                 "messageType": "propertyStatus",
-                "data": {
-                    property_.name: property_.get_value(),
-                },
+                "data": {property_.name: property_.get_value(),},
             },
             cls=self.json_encoder,
         )
@@ -328,10 +321,7 @@ def update_action(self, action):
         :param action: Action
         """
         message = json.dumps(
-            {
-                "messageType": "actionStatus",
-                "data": action.as_action_description(),
-            },
+            {"messageType": "actionStatus", "data": action.as_action_description(),},
             cls=self.json_encoder,
         )
 
@@ -344,10 +334,7 @@ def update_event(self, event):
         :param event: Event
         """
         message = json.dumps(
-            {
-                "messageType": "event",
-                "data": event.as_event_description(),
-            },
+            {"messageType": "event", "data": event.as_event_description(),},
             cls=self.json_encoder,
         )
 
@@ -630,19 +617,13 @@ def __init__(
 
         for address in get_addresses():
             self.hosts.extend(
-                [
-                    address,
-                    "{}:{}".format(address, self.port),
-                ]
+                [address, "{}:{}".format(address, self.port),]
             )
 
         if self.hostname is not None:
             self.hostname = self.hostname.lower()
             self.hosts.extend(
-                [
-                    self.hostname,
-                    "{}:{}".format(self.hostname, self.port),
-                ]
+                [self.hostname, "{}:{}".format(self.hostname, self.port),]
             )
 
         self.thing.set_href_prefix(self.base_path)
@@ -724,9 +705,7 @@ def start(self):
         ]
         kwargs = {
             "port": self.port,
-            "properties": {
-                "path": "/",
-            },
+            "properties": {"path": "/",},
             "server": "{}.local.".format(socket.gethostname()),
         }
 

webthing/thing.py

@@ -55,14 +55,8 @@ def as_thing_description(self):
                     "rel": "properties",
                     "href": "{}/properties".format(self.href_prefix),
                 },
-                {
-                    "rel": "actions",
-                    "href": "{}/actions".format(self.href_prefix),
-                },
-                {
-                    "rel": "events",
-                    "href": "{}/events".format(self.href_prefix),
-                },
+                {"rel": "actions", "href": "{}/actions".format(self.href_prefix),},
+                {"rel": "events", "href": "{}/events".format(self.href_prefix),},
             ],
         }
 
@@ -77,11 +71,7 @@ def as_thing_description(self):
 
         if self.ui_href is not None:
             thing["links"].append(
-                {
-                    "rel": "alternate",
-                    "mediaType": "text/html",
-                    "href": self.ui_href,
-                }
+                {"rel": "alternate", "mediaType": "text/html", "href": self.ui_href,}
             )
 
         if self.description:
@@ -190,7 +180,7 @@ def get_action_object_descriptions(self, action_name=None):
 
         Returns the action descriptions.
         """
-        
+
         if action_name is None:
             descriptions = {}
             for name, action in self.actions.items():