from ._winconsole import _get_windows_console_stream, _wrap_std_stream
ImportError: cannot import name '_wrap_std_stream' from 'asyncclick._winconsole' (d:\python envs\kasatest\lib\site-packages\asyncclick\_winconsole.py)

~> kasa --host 192.168.1.43 --plug --debug
DEBUG:kasa.smartdevice:Initializing 192.168.1.43
DEBUG:asyncio:Using selector: KqueueSelector
Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/kasa/smartdevice.py", line 136, in _query_helper
    response = await self.protocol.query(host=self.host, request=request)
  File "/usr/local/lib/python3.7/site-packages/kasa/protocol.py", line 47, in query
    reader, writer = await asyncio.wait_for(task, timeout=timeout)
  File "/usr/local/Cellar/python/3.7.7/Frameworks/Python.framework/Versions/3.7/lib/python3.7/asyncio/tasks.py", line 449, in wait_for
    raise futures.TimeoutError()
concurrent.futures._base.TimeoutError

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/usr/local/bin/kasa", line 8, in <module>
    sys.exit(cli())
  File "/usr/local/lib/python3.7/site-packages/click/core.py", line 829, in __call__
    return self.main(*args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/click/core.py", line 782, in main
    rv = self.invoke(ctx)
  File "/usr/local/lib/python3.7/site-packages/click/core.py", line 1236, in invoke
    return Command.invoke(self, ctx)
  File "/usr/local/lib/python3.7/site-packages/click/core.py", line 1066, in invoke
    return ctx.invoke(self.callback, **ctx.params)
  File "/usr/local/lib/python3.7/site-packages/click/core.py", line 610, in invoke
    return callback(*args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/click/decorators.py", line 21, in new_func
    return f(get_current_context(), *args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/kasa/cli.py", line 81, in cli
    ctx.invoke(state)
  File "/usr/local/lib/python3.7/site-packages/click/core.py", line 610, in invoke
    return callback(*args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/click/decorators.py", line 73, in new_func
    return ctx.invoke(f, obj, *args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/click/core.py", line 610, in invoke
    return callback(*args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/click/decorators.py", line 21, in new_func
    return f(get_current_context(), *args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/kasa/cli.py", line 183, in state
    asyncio.run(dev.update())
  File "/usr/local/Cellar/python/3.7.7/Frameworks/Python.framework/Versions/3.7/lib/python3.7/asyncio/runners.py", line 43, in run
    return loop.run_until_complete(main)
  File "/usr/local/Cellar/python/3.7.7/Frameworks/Python.framework/Versions/3.7/lib/python3.7/asyncio/base_events.py", line 587, in run_until_complete
    return future.result()
  File "/usr/local/lib/python3.7/site-packages/kasa/smartdevice.py", line 184, in update
    self._sys_info = await self.get_sys_info()
  File "/usr/local/lib/python3.7/site-packages/kasa/smartdevice.py", line 177, in get_sys_info
    return await self._query_helper("system", "get_sysinfo")
  File "/usr/local/lib/python3.7/site-packages/kasa/smartdevice.py", line 138, in _query_helper
    raise SmartDeviceException(f"Communication error on {target}:{cmd}") from ex
kasa.smartdevice.SmartDeviceException: Communication error on system:get_sysinfo

import socket
import asyncio
from smartplug import SmartPlug

PORT = xxxx
BUFFER_SIZE = 1024
HOST = '192.xxx.x.xx'

sock = socket.socket(socket.AF_INET, type=socket.SOCK_DGRAM)
locaddr = (HOST, PORT)
sock.bind(locaddr)

plug = SmartPlug("192.xxx.x.xx") 
                                                          
async def uv_plug_init():
    await plug.update()

async def uv_plug_on():
    await plug.turn_on()

async def uv_plug_off():
    await plug.turn_off()

asyncio.run(uv_plug_init())

def uvlight():
    asyncio.run(uv_plug_off())
    data, addr = sock.recvfrom(1024)
    print("data: {}".format(data))
    plug_init = data[-1]
    while True:      
        data, addr = sock.recvfrom(1024)
        print("data: {}".format(data))
        if data[-1] == plug_init:
            asyncio.run(uv_plug_off())
        
        else:
            asyncio.run(uv_plug_on()) 

uvlight()

   if year:
        click.echo(f"== For year {year.year} ==")
        emeter_status = await dev.get_emeter_monthly(year.year)
    elif month:
        click.echo(f"== For month {month.month} of {month.year} ==")
        emeter_status = await dev.get_emeter_daily(year=month.year, month=month.month)
    else:
        emeter_status = dev.emeter_realtime

    if isinstance(emeter_status, list):
        for plug in emeter_status:
            index = emeter_status.index(plug) + 1
            click.echo(f"Plug {index}: {plug}")
    else:
        click.echo("Current: %s A" % emeter_status["current"])
        click.echo("Voltage: %s V" % emeter_status["voltage"])
        click.echo("Power: %s W" % emeter_status["power"])
        click.echo("Total consumption: %s kWh" % emeter_status["total"])

        click.echo("Today: %s kWh" % dev.emeter_today)
        click.echo("This month: %s kWh" % dev.emeter_this_month)

    if year:
        click.echo(f"== For year {year.year} ==")
        click.echo(await dev.get_emeter_monthly(year.year))
        return
    elif month:
        click.echo(f"== For month {month.month} of {month.year} ==")
        click.echo(await dev.get_emeter_daily(year=month.year, month=month.month))
        return
    else:
        emeter_status = dev.emeter_realtime

No host name given, trying discovery..
Discovering devices for 3 seconds
== hs100a - HS100(US) ==
    Host: 192.168.10.127
    Device state: ON

    == Generic information ==
    Time:         2020-06-11 17:13:12
    Hardware:     2.0
    Software:     1.5.6 Build 191118 Rel.140307
    MAC (rssi):   XX:XX:XX:XX:XX:XX (-48)
    Location:     {'latitude': 304306, 'longitude': -978273}

    == Device specific information ==
    LED state: True
    On since: 2020-06-11 16:58:33.087466


Traceback (most recent call last):
  File "/home/userx/tmp/python/venv8/bin/kasa", line 8, in <module>
    sys.exit(cli())
  File "/home/userx/tmp/python/venv8/lib/python3.8/site-packages/asyncclick/core.py", line 799, in __call__
    return anyio.run(self._main, main, args, kwargs, backend=_anyio_backend)
  File "/home/userx/tmp/python/venv8/lib/python3.8/site-packages/anyio/__init__.py", line 68, in run
    return asynclib.run(func, *args, **backend_options)  # type: ignore
  File "/home/userx/tmp/python/venv8/lib/python3.8/site-packages/anyio/_backends/_asyncio.py", line 99, in run
    raise exception
  File "/home/userx/tmp/python/venv8/lib/python3.8/site-packages/anyio/_backends/_asyncio.py", line 67, in wrapper
    retval = await func(*args)
  File "/home/userx/tmp/python/venv8/lib/python3.8/site-packages/asyncclick/core.py", line 802, in _main
    return await main(*args, **kwargs)
  File "/home/userx/tmp/python/venv8/lib/python3.8/site-packages/asyncclick/core.py", line 748, in main
    rv = await self.invoke(ctx)
  File "/home/userx/tmp/python/venv8/lib/python3.8/site-packages/asyncclick/core.py", line 1175, in invoke
    return await _process_result(await sub_ctx.command.invoke(sub_ctx))
  File "/home/userx/tmp/python/venv8/lib/python3.8/site-packages/asyncclick/core.py", line 994, in invoke
    return await ctx.invoke(self.callback, **ctx.params)
  File "/home/userx/tmp/python/venv8/lib/python3.8/site-packages/asyncclick/core.py", line 586, in invoke
    rv = callback(*args, **kwargs)
  File "/home/userx/tmp/python/venv8/lib/python3.8/site-packages/asyncclick/decorators.py", line 60, in new_func
    raise RuntimeError('Managed to invoke callback without a '
RuntimeError: Managed to invoke callback without a context object of type 'SmartDevice' existing

Traceback (most recent call last):
  File "test.py", line 2, in <module>
    from kasa import Discover
  File "/tmp/TerrariumPI/python-kasa/kasa/__init__.py", line 15, in <module>
    from kasa.discover import Discover
  File "/tmp/TerrariumPI/python-kasa/kasa/discover.py", line 9, in <module>
    from kasa.smartbulb import SmartBulb
  File "/tmp/TerrariumPI/python-kasa/kasa/smartbulb.py", line 5, in <module>
    from kasa.smartdevice import (
  File "/tmp/TerrariumPI/python-kasa/kasa/smartdevice.py", line 17, in <module>
    from dataclasses import dataclass
ModuleNotFoundError: No module named 'dataclasses'

DEBUG:kasa.protocol:> (33) {"system": {"get_sysinfo": null}}
DEBUG:kasa.protocol:< (705) {"system":{"get_sysinfo":{"sw_ver":"1.0.8 Build 190103 Rel.163436","hw_ver":"1.0","model":"HS107(US)","deviceId":"XXX","oemId":"XXX","hwId":"XX","rssi":-56,"longitude_i":XX,"latitude_i":XXX,"alias":"TP-LINK_Smart Plug_C119","mic_type":"IOT.SMARTPLUGSWITCH","feature":"TIM","mac":"XXX","updating":0,"led_off":0,"children":[{"id":"XXX","state":0,"alias":"Two head","on_time":0,"next_action":{"type":-1}},{"id":"XXX","state":0,"alias":"Tree","on_time":0,"next_action":{"type":-1}}],"child_num":2,"err_code":0}}}
DEBUG:kasa.smartstrip:Initializing 2 child sockets
DEBUG:kasa.smartdevice:Initializing XXX with cache ttl 0:00:03
DEBUG:kasa.smartdevice:Initializing XXX with cache ttl 0:00:03
DEBUG:asyncio:Using selector: EpollSelector
DEBUG:kasa.smartdevice:Checking cache for system get_sysinfo
DEBUG:kasa.smartdevice:Got cached system get_sysinfo
== TP-LINK_Smart Plug_C119 - HS107(US) ==
Device state: OFF
DEBUG:asyncio:Using selector: EpollSelector
WARNING:kasa.smartstrip:You called update() on a child device, which has no effect.Call update() on the parent device instead.
  * Two head state: OFF
DEBUG:asyncio:Using selector: EpollSelector
WARNING:kasa.smartstrip:You called update() on a child device, which has no effect.Call update() on the parent device instead.
  * Tree state: OFF
Host/IP: XXXXXXXXX
LED state: True
== Generic information ==
DEBUG:asyncio:Using selector: EpollSelector
DEBUG:kasa.smartdevice:Checking cache for time get_time
DEBUG:kasa.smartdevice:Got no result from cache, querying the device.
DEBUG:kasa.protocol:> (28) {"time": {"get_time": null}}
DEBUG:kasa.protocol:< (96) {"time":{"get_time":{"year":2020,"month":4,"mday":10,"hour":14,"min":49,"sec":49,"err_code":0}}}
Time:         2020-04-10 14:49:49
Hardware:     1.0
Software:     1.0.8 Build 190103 Rel.163436
MAC (rssi):   XXXXXX (XX)
Location:     {'latitude': XXXXXXX, 'longitude': XXXXXXXX}
== Emeter ==
DEBUG:asyncio:Using selector: EpollSelector
DEBUG:kasa.smartdevice:Checking cache for system get_sysinfo
DEBUG:kasa.smartdevice:Got cached system get_sysinfo
DEBUG:asyncio:Using selector: EpollSelector
DEBUG:kasa.smartdevice:Checking cache for emeter get_realtime
DEBUG:kasa.smartdevice:Got no result from cache, querying the device.
DEBUG:kasa.protocol:> (34) {"emeter": {"get_realtime": null}}
DEBUG:kasa.protocol:< (57) {"emeter":{"err_code":-1,"err_msg":"module not support"}}
Traceback (most recent call last):
  File "kasa/cli.py", line 390, in <module>
    cli()
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 829, in __call__
    return self.main(*args, **kwargs)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 782, in main
    rv = self.invoke(ctx)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 1236, in invoke
    return Command.invoke(self, ctx)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 1066, in invoke
    return ctx.invoke(self.callback, **ctx.params)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 610, in invoke
    return callback(*args, **kwargs)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/decorators.py", line 21, in new_func
    return f(get_current_context(), *args, **kwargs)
  File "kasa/cli.py", line 63, in cli
    ctx.invoke(discover)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 610, in invoke
    return callback(*args, **kwargs)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/decorators.py", line 21, in new_func
    return f(get_current_context(), *args, **kwargs)
  File "kasa/cli.py", line 146, in discover
    ctx.invoke(state)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 610, in invoke
    return callback(*args, **kwargs)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/decorators.py", line 73, in new_func
    return ctx.invoke(f, obj, *args, **kwargs)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 610, in invoke
    return callback(*args, **kwargs)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/decorators.py", line 21, in new_func
    return f(get_current_context(), *args, **kwargs)
  File "kasa/cli.py", line 214, in state
    ctx.invoke(emeter)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 610, in invoke
    return callback(*args, **kwargs)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/decorators.py", line 73, in new_func
    return ctx.invoke(f, obj, *args, **kwargs)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 610, in invoke
    return callback(*args, **kwargs)
  File "kasa/cli.py", line 272, in emeter
    emeter_status = asyncio.run(dev.get_emeter_realtime())
  File "/usr/lib/python3.7/asyncio/runners.py", line 43, in run
    return loop.run_until_complete(main)
  File "/usr/lib/python3.7/asyncio/base_events.py", line 584, in run_until_complete
    return future.result()
  File "/home/acmay/src/hass/python-kasa/kasa/smartdevice.py", line 89, in wrapped
    return await f(*args, **kwargs)
  File "/home/acmay/src/hass/python-kasa/kasa/smartdevice.py", line 456, in get_emeter_realtime
    return EmeterStatus(await self._query_helper(self.emeter_type, "get_realtime"))
  File "/home/acmay/src/hass/python-kasa/kasa/smartdevice.py", line 188, in _query_helper
    raise SmartDeviceException(f"Error on {target}.{cmd}: {result}")
kasa.smartdevice.SmartDeviceException: Error on emeter.get_realtime: {'err_code': -1, 'err_msg': 'module not support'}

PS C:\Windows\system32> kasa wifi scan
No host name given, trying discovery..
Discovering devices for 3 seconds
Traceback (most recent call last):
  File "b:\python\python38\lib\runpy.py", line 194, in _run_module_as_main
    return _run_code(code, main_globals, None,
  File "b:\python\python38\lib\runpy.py", line 87, in _run_code
    exec(code, run_globals)
  File "B:\Python\python38\Scripts\kasa.exe\__main__.py", line 7, in <module>
  File "b:\python\python38\lib\site-packages\asyncclick\core.py", line 799, in __call__
    return anyio.run(self._main, main, args, kwargs, backend=_anyio_backend)
  File "b:\python\python38\lib\site-packages\anyio\__init__.py", line 72, in run
    return asynclib.run(func, *args, **backend_options)  # type: ignore
  File "b:\python\python38\lib\site-packages\anyio\_backends\_asyncio.py", line 114, in run
    raise exception
  File "b:\python\python38\lib\site-packages\anyio\_backends\_asyncio.py", line 76, in wrapper
    retval = await func(*args)
  File "b:\python\python38\lib\site-packages\asyncclick\core.py", line 802, in _main
    return await main(*args, **kwargs)
  File "b:\python\python38\lib\site-packages\asyncclick\core.py", line 748, in main
    rv = await self.invoke(ctx)
  File "b:\python\python38\lib\site-packages\asyncclick\core.py", line 1175, in invoke
    return await _process_result(await sub_ctx.command.invoke(sub_ctx))
  File "b:\python\python38\lib\site-packages\asyncclick\core.py", line 1172, in invoke
    await Command.invoke(self, ctx)
  File "b:\python\python38\lib\site-packages\asyncclick\core.py", line 994, in invoke
    return await ctx.invoke(self.callback, **ctx.params)
  File "b:\python\python38\lib\site-packages\asyncclick\core.py", line 586, in invoke
    rv = callback(*args, **kwargs)
  File "b:\python\python38\lib\site-packages\asyncclick\decorators.py", line 60, in new_func
    raise RuntimeError('Managed to invoke callback without a '
RuntimeError: Managed to invoke callback without a context object of type 'SmartDevice' existing

import asyncio
from kasa import SmartPlug
from pprint import pformat as pf

plug = SmartPlug("ip of the device")
asyncio.run(plug.update())
await plug.turn_on()

import asyncio
from kasa import SmartPlug
from pprint import pformat as pf


async def main():
    plug = SmartPlug("ip of the device")
    asyncio.run(plug.update())
    await plug.turn_on()

asyncio.run(main())

Traceback (most recent call last):
  File "d:/Documents/8sem/Project Phase II/new/let's do this/demo.py", line 11, in <module>
    asyncio.run(main())
  File "C:\Users\ReNew\AppData\Local\Programs\Python\Python38-32\lib\asyncio\runners.py", line 43, in run
    return loop.run_until_complete(main)
  File "C:\Users\ReNew\AppData\Local\Programs\Python\Python38-32\lib\asyncio\base_events.py", line 612, in run_until_complete
    return future.result()
  File "d:/Documents/8sem/Project Phase II/new/let's do this/demo.py", line 8, in main
    asyncio.run(plug.update())
  File "C:\Users\ReNew\AppData\Local\Programs\Python\Python38-32\lib\asyncio\runners.py", line 33, in run
    raise RuntimeError(
RuntimeError: asyncio.run() cannot be called from a running event loop
sys:1: RuntimeWarning: coroutine 'SmartDevice.update' was never awaited

+ python3 python-kasa/kasa/cli.py
No host name given, trying discovery..
Discovering devices for 3 seconds
ERROR:kasa.discover:Got exception Communication error on system:get_sysinfo
Traceback (most recent call last):
  File "/home/pi/development/udi-poly-kasa/python-kasa/kasa/smartdevice.py", line 200, in _query_helper
    response = await self.protocol.query(host=self.host, request=request)
  File "/home/pi/development/udi-poly-kasa/python-kasa/kasa/protocol.py", line 67, in query
    await writer.wait_closed()
AttributeError: 'StreamWriter' object has no attribute 'wait_closed'

from kasa import SmartPlug
from pprint import pformat as pf

# Define the connection to the TPLink HS100 smart plug using the kasa module
plug = SmartPlug("192.168.0.99")
#print("Hardware: %s" % pf(plug.hw_info))
#print("Full sysinfo: %s" % pf(plug.get_sysinfo())) # this prints lots of information about the device

print("Alias is", plug.alias)

  File "bla\kasa\smartdevice.py", line 110, in wrapped
    assert self._sys_info is not None

from kasa import SmartDevice, SmartPlug, SmartStrip, SmartDeviceException
async def update_wrapper(smartdevice):
    global logger
    try:
        await smartdevice.update()
    except BaseException as bx:
        logger.error("Unable to initialize SmartDevice {}: {}".format(smartdevice.host,str(bx)))
        print(bx)
        pass

async def klights():
    devices = db(db.devices).select(db.devices.host_ip_addr,db.devices.device_type,distinct=True)
    smartdevs = []
    keys = []
    dev_names = []
    for device in devices:
        if device.device_type == 'plug':
            smartdevs.append(SmartPlug(device.host_ip_addr))
        else:
            smartdevs.append(SmartStrip(device.host_ip_addr))
    sdaws = []
    for sdev in smartdevs:
        sdaws.append(update_wrapper(sdev))
    devs = asyncio.gather(*sdaws)
    return smartdevs

pyHS100:
dev = SmartPlug(ip_addr)
dev.turn_on()
state = dev.is_on

Kasa:
dev = SmartPlug(ip_addr)
asyncio.run(dev.update())
asyncio.run(dev.turn_on())
asyncio.run(devupdate())
state = dev.is_on

2019-12-18T08:07:23.5192675Z 
2019-12-18T08:07:23.5192766Z =================================== FAILURES ===================================
2019-12-18T08:07:23.5192838Z _ test_state_info[/home/vsts/work/1/s/kasa/tests/fixtures/HS300(US)_1.0.json] __
2019-12-18T08:07:23.5193293Z 
2019-12-18T08:07:23.5194008Z dev = <[KeyError('relay_state') raised in repr()] SmartStrip object at 0x7f5dd51ed290>
2019-12-18T08:07:23.5194070Z 
2019-12-18T08:07:23.5194611Z     def test_state_info(dev):
2019-12-18T08:07:23.5194668Z         dev.sync.update()
2019-12-18T08:07:23.5194738Z >       assert isinstance(dev.sync.state_information, dict)
2019-12-18T08:07:23.5194781Z 
2019-12-18T08:07:23.5194830Z kasa/tests/test_fixtures.py:59: 
2019-12-18T08:07:23.5194904Z _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
2019-12-18T08:07:23.5194968Z kasa/smartdevice.py:674: in __getattr__
2019-12-18T08:07:23.5195381Z     method = getattr(self.async_device, attr)
2019-12-18T08:07:23.5195440Z kasa/smartdevice.py:98: in wrapped
2019-12-18T08:07:23.5195599Z     return f(*args, **kwargs)
2019-12-18T08:07:23.5195668Z kasa/smartstrip.py:120: in state_information
2019-12-18T08:07:23.5195725Z     if plug.is_on:
2019-12-18T08:07:23.5195786Z kasa/smartdevice.py:98: in wrapped
2019-12-18T08:07:23.5195842Z     return f(*args, **kwargs)
2019-12-18T08:07:23.5195906Z _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
2019-12-18T08:07:23.5195959Z 
2019-12-18T08:07:23.5198186Z self = <[KeyError('relay_state') raised in repr()] SmartPlug object at 0x7f5dd51ed1d0>
2019-12-18T08:07:23.5198257Z 
2019-12-18T08:07:23.5198322Z     @property  # type: ignore
2019-12-18T08:07:23.5198369Z     @requires_update
2019-12-18T08:07:23.5198606Z     def is_on(self) -> bool:
2019-12-18T08:07:23.5198660Z         """Return whether device is on.
2019-12-18T08:07:23.5198707Z     
2019-12-18T08:07:23.5198775Z         :return: True if device is on, False otherwise
2019-12-18T08:07:23.5198825Z         """
2019-12-18T08:07:23.5198883Z         sys_info = self.sys_info
2019-12-18T08:07:23.5198933Z >       return bool(sys_info["relay_state"])
2019-12-18T08:07:23.5199132Z E       KeyError: 'relay_state'

diff --git a/kasa/protocol.py b/kasa/protocol.py
index f29b4be..60368f0 100755
--- a/kasa/protocol.py
+++ b/kasa/protocol.py
@@ -57,6 +57,10 @@ class TPLinkSmartHomeProtocol:
             while True:
                 chunk = await reader.read(4096)
                 if length == -1:
+                    if len(chunk) < 4:
+                        _LOGGER.error("Request %s:%s Failed to get response",
+                                      host, request)
+                        break
                     length = struct.unpack(">I", chunk[0:4])[0]
                 buffer += chunk
                 if (length > 0 and len(buffer) >= length + 4) or not chunk:
@@ -66,7 +70,10 @@ class TPLinkSmartHomeProtocol:
                 writer.close()
                 await writer.wait_closed()
 
-        response = TPLinkSmartHomeProtocol.decrypt(buffer[4:])
+        if len(buffer) > 4:
+            response = TPLinkSmartHomeProtocol.decrypt(buffer[4:])
+        else:
+            response = ""
         _LOGGER.debug("< (%i) %s", len(response), response)
 
         return json.loads(response)

acmay@mud:~/src/hass/python-kasa$ PYTHONPATH=`pwd` python3 kasa/cli.py --host 192.168.1.28 sysinfo
No --strip nor --bulb nor --plug given, discovering..
== System info ==
{'alias': 'TP-LINK_Smart Plug_2ECE',
 'child_num': 2,
 'children': [{'alias': 'Rope',
               'id': 'XXXX',
               'next_action': {'action': 1, 'schd_sec': 69240, 'type': 1},
               'on_time': 0,
               'state': 0},
              {'alias': 'Plug 2',
               'id': 'XXXX',
               'next_action': {'type': -1},
               'on_time': 0,
               'state': 0}],
 'deviceId': 'XXX',
 'feature': 'TIM',
 'hwId': 'XXXX',
 'hw_ver': '1.0',
 'latitude_i': XXXX,
 'led_off': 0,
 'longitude_i': XXXXX,
 'mac': 'XXXX',
 'mic_type': 'IOT.SMARTPLUGSWITCH',
 'model': 'KP400(US)',
 'ntc_state': 0,
 'oemId': 'XXXX',
 'rssi': -78,
 'status': 'new',
 'sw_ver': '1.0.10 Build 190716 Rel.095026',
 'updating': 0}
acmay@mud:~/src/hass/python-kasa$ PYTHONPATH=`pwd` python3 kasa/cli.py --host 192.168.1.28 sysinfo
No --strip nor --bulb nor --plug given, discovering..
ERROR:kasa.protocol:Request 192.168.1.28:{"system": {"get_sysinfo": null}, "emeter": {"get_realtime": null}, "smartlife.iot.dimmer": {"get_dimmer_parameters": null}, "smartlife.iot.common.emeter": {"get_realtime": null}, "smartlife.iot.smartbulb.lightingservice": {"get_light_state": null}} Failed to get response
Traceback (most recent call last):
  File "kasa/cli.py", line 391, in <module>
    cli()
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 829, in __call__
    return self.main(*args, **kwargs)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 782, in main
    rv = self.invoke(ctx)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 1256, in invoke
    Command.invoke(self, ctx)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 1066, in invoke
    return ctx.invoke(self.callback, **ctx.params)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/core.py", line 610, in invoke
    return callback(*args, **kwargs)
  File "/home/acmay/.local/lib/python3.7/site-packages/click/decorators.py", line 21, in new_func
    return f(get_current_context(), *args, **kwargs)
  File "kasa/cli.py", line 68, in cli
    dev = asyncio.run(Discover.discover_single(host))
  File "/usr/lib/python3.7/asyncio/runners.py", line 43, in run
    return loop.run_until_complete(main)
  File "/usr/lib/python3.7/asyncio/base_events.py", line 584, in run_until_complete
    return future.result()
  File "/home/acmay/src/hass/python-kasa/kasa/discover.py", line 176, in discover_single
    info = await protocol.query(host, Discover.DISCOVERY_QUERY)
  File "/home/acmay/src/hass/python-kasa/kasa/protocol.py", line 79, in query
    return json.loads(response)
  File "/usr/lib/python3.7/json/__init__.py", line 348, in loads
    return _default_decoder.decode(s)
  File "/usr/lib/python3.7/json/decoder.py", line 337, in decode
    obj, end = self.raw_decode(s, idx=_w(s, 0).end())
  File "/usr/lib/python3.7/json/decoder.py", line 355, in raw_decode
    raise JSONDecodeError("Expecting value", s, err.value) from None
json.decoder.JSONDecodeError: Expecting value: line 1 column 1 (char 0)

$ kasa --host 10.0.0.98 --bulb hsv 100 100 100
Setting HSV: 100 100 100
Traceback (most recent call last):
  File "/usr/local/bin/kasa", line 11, in <module>
    load_entry_point('python-kasa==0.4.0.dev0', 'console_scripts', 'kasa')()
  File "/home/ethan/.local/lib/python3.7/site-packages/click/core.py", line 829, in __call__
    return self.main(*args, **kwargs)
  File "/home/ethan/.local/lib/python3.7/site-packages/click/core.py", line 782, in main
    rv = self.invoke(ctx)
  File "/home/ethan/.local/lib/python3.7/site-packages/click/core.py", line 1259, in invoke
    return _process_result(sub_ctx.command.invoke(sub_ctx))
  File "/home/ethan/.local/lib/python3.7/site-packages/click/core.py", line 1066, in invoke
    return ctx.invoke(self.callback, **ctx.params)
  File "/home/ethan/.local/lib/python3.7/site-packages/click/core.py", line 610, in invoke
    return callback(*args, **kwargs)
  File "/home/ethan/.local/lib/python3.7/site-packages/click/decorators.py", line 21, in new_func
    return f(get_current_context(), *args, **kwargs)
  File "/home/ethan/.local/lib/python3.7/site-packages/click/decorators.py", line 73, in new_func
    return ctx.invoke(f, obj, *args, **kwargs)
  File "/home/ethan/.local/lib/python3.7/site-packages/click/core.py", line 610, in invoke
    return callback(*args, **kwargs)
  File "/home/ethan/.local/lib/python3.7/site-packages/kasa/cli.py", line 334, in hsv
    asyncio.run(dev.set_hsv(h, s, v))
  File "/usr/lib/python3.7/asyncio/runners.py", line 43, in run
    return loop.run_until_complete(main)
  File "/usr/lib/python3.7/asyncio/base_events.py", line 583, in run_until_complete
    return future.result()
  File "/home/ethan/.local/lib/python3.7/site-packages/kasa/smartdevice.py", line 88, in wrapped
    assert self._sys_info is not None
AssertionError