code: def connection_made(self, transport):
          
          self.transport = transport
          self.loop = transport.loop
          self._cmd_lock = asyncio.Lock(loop=self.loop)
          self._wd_lock = asyncio.Lock(loop=self.loop)
          self._cmdq = asyncio.Queue(loop=self.loop)
          self._msgq = asyncio.Queue(loop=self.loop)
          self._updateq = asyncio.Queue(loop=self.loop)
          self._readbuf = b''
          self._update_cb = None
          self._received_lines = 0
          self._msg_task = self.loop.create_task(self._process_msgs())
          self._report_task = None
          self._watchdog_task = None
          self.status = {}
          self.connected = True
docs: Gets called when a connection to the gateway is established.
          Initialise the protocol object.