Revert changes back to 0.16.0 (#227)

Author: teharris1

insteonplm/__init__.py

@@ -446,7 +446,7 @@ async def _async_write(self, url):
                         self._write_last_read(0)
                     else:
                         self._log_error(response.status)
-                        await self._stop_reader(True)
+                        await self._stop_reader(False)
         except aiohttp.client_exceptions.ServerDisconnectedError:
             _LOGGER.error("Reconnect to Hub (ServerDisconnectedError)")
             await self._stop_reader(True)
@@ -507,7 +507,7 @@ async def _ensure_reader(self):
                                 buffer = self._parse_buffer_v1(html)
                         else:
                             self._log_error(response.status)
-                            await self._stop_reader(True)
+                            await self._stop_reader(False)
                 if self._read_write_lock.locked():
                     self._read_write_lock.release()
                 if buffer:
@@ -532,8 +532,8 @@ async def _ensure_reader(self):
                 _LOGGER.error("Reconnect to Hub (TimeoutError)")
                 await self._stop_reader(True)
             except Exception as e:
-                _LOGGER.error("Restarting reading due to %s", str(e))
-                await self._stop_reader(True)
+                _LOGGER.error("Stop reading due to %s", str(e))
+                await self._stop_reader(False)
         _LOGGER.info("Insteon Hub reader stopped")
         return
 
@@ -591,7 +591,7 @@ def _find_message(raw_text):
         if raw_text == "0" * len_raw_text:
             print("Likely the buffer was cleared")
             return msg, None, False
-        while pos < (len_raw_text - 2) and raw_text[pos:pos + 2] != "02":
+        while pos < (len_raw_text - 2) and raw_text[pos : pos + 2] != "02":
             pos = pos + 2
         print("pos is: ", pos)
         print("len_raw_text is: ", len_raw_text)
@@ -614,7 +614,7 @@ def _find_message(raw_text):
             raw_text = None
         else:
             if pos > 0 and raw_text:
-                raw_text = raw_text[len(raw_text) - pos:] + raw_text[:-pos]
+                raw_text = raw_text[len(raw_text) - pos :] + raw_text[:-pos]
         return (msg, raw_text)
 
     def _write_last_read(self, val):
@@ -646,7 +646,7 @@ async def _stop_reader(self, reconnect=False):
         #     await self._close()
         if reconnect:
             _LOGGER.debug("We want to reconnect so we do...")
-            self._protocol.connection_lost(False)
+            self._protocol.connection_lost(True)
 
     def _log_error(self, status):
         if status == 401: