rollback to python version 3.13.2

CHANGELOG.md

@@ -7,7 +7,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [unreleased]
 
-- add web UI to add-on
 - allow `Y00` serial numbers for GEN3PLUS devices
 
 ## [0.13.0] - 2025-04-13

app/requirements.txt

@@ -1,4 +1,4 @@
     aiomqtt==2.3.2
     schema==0.7.7
     aiocron==2.1
-    quart==0.20
+    aiohttp==3.11.16

app/src/proxy.py

@@ -96,8 +96,8 @@ class Proxy():
             Infos.new_stat_data[key] = False
 
     @classmethod
-    async def class_close(cls, loop) -> None:   # pragma: no cover
+    def class_close(cls, loop) -> None:   # pragma: no cover
         logging.debug('Proxy.class_close')
         logging.info('Close MQTT Task')
-        await cls.mqtt.close()
+        loop.run_until_complete(cls.mqtt.close())
         cls.mqtt = None

app/src/server.py

@@ -1,10 +1,11 @@
 import logging
 import asyncio
 import logging.handlers
+import signal
 import os
 import argparse
 from asyncio import StreamReader, StreamWriter
-from quart import Quart, Response
+from aiohttp import web
 from logging import config  # noqa F401
 from proxy import Proxy
 from inverter_ifc import InverterIfc
@@ -15,51 +16,63 @@ from cnf.config import Config
 from cnf.config_read_env import ConfigReadEnv
 from cnf.config_read_toml import ConfigReadToml
 from cnf.config_read_json import ConfigReadJson
-from web.routes import web_routes
 from modbus_tcp import ModbusTcp
 
-
+routes = web.RouteTableDef()
-class ProxyState:
+proxy_is_up = False
-    _is_up = False
-
-    @staticmethod
-    def is_up() -> bool:
-        return ProxyState._is_up
-
-    @staticmethod
-    def set_up(value: bool):
-        ProxyState._is_up = value
 
 
-app = Quart(__name__)
+@routes.get('/')
-app.register_blueprint(web_routes)
+async def hello(request):
+    return web.Response(text="Hello, world")
 
 
-@app.route('/-/ready')
+@routes.get('/-/ready')
-async def ready():
+async def ready(request):
-    if ProxyState.is_up():
+    if proxy_is_up:
         status = 200
         text = 'Is ready'
     else:
         status = 503
         text = 'Not ready'
-    return Response(status=status, response=text)
+    return web.Response(status=status, text=text)
 
 
-@app.route('/-/healthy')
+@routes.get('/-/healthy')
-async def healthy():
+async def healthy(request):
 
-    if ProxyState.is_up():
+    if proxy_is_up:
         # logging.info('web reqeust healthy()')
         for inverter in InverterIfc:
             try:
                 res = inverter.healthy()
                 if not res:
-                    return Response(status=503, response="I have a problem")
+                    return web.Response(status=503, text="I have a problem")
             except Exception as err:
                 logging.info(f'Exception:{err}')
 
-    return Response(status=200, response="I'm fine")
+    return web.Response(status=200, text="I'm fine")
+
+
+async def webserver(addr, port):
+    '''coro running our webserver'''
+    app = web.Application()
+    app.add_routes(routes)
+    runner = web.AppRunner(app)
+
+    await runner.setup()
+    site = web.TCPSite(runner, addr, port)
+    await site.start()
+    logging.info(f'HTTP server listen on port: {port}')
+
+    try:
+        # Normal interaction with aiohttp
+        while True:
+            await asyncio.sleep(3600)  # sleep forever
+    except asyncio.CancelledError:
+        logging.info('HTTP server cancelled')
+        await runner.cleanup()
+        logging.debug('HTTP cleanup done')
 
 
 async def handle_client(reader: StreamReader, writer: StreamWriter, inv_class):
@@ -69,13 +82,12 @@ async def handle_client(reader: StreamReader, writer: StreamWriter, inv_class):
         await inv.local.ifc.server_loop()
 
 
-@app.after_serving
+async def handle_shutdown(loop, web_task):
-async def handle_shutdown():   # pragma: no cover
     '''Close all TCP connections and stop the event loop'''
 
     logging.info('Shutdown due to SIGTERM')
-    loop = asyncio.get_event_loop()
+    global proxy_is_up
-    ProxyState.set_up(False)
+    proxy_is_up = False
 
     #
     # first, disc all open TCP connections gracefully
@@ -85,16 +97,24 @@ async def handle_shutdown():   # pragma: no cover
 
     logging.info('Proxy disconnecting done')
 
+    #
+    # second, cancel the web server
+    #
+    web_task.cancel()
+    await web_task
+
     #
     # now cancel all remaining (pending) tasks
     #
-    for task in asyncio.all_tasks():
+    pending = asyncio.all_tasks()
-        if task == asyncio.current_task():
+    for task in pending:
-            continue
         task.cancel()
-    logging.info('Proxy cancelling done')
 
-    await Proxy.class_close(loop)
+    #
+    # at last, start a coro for stopping the loop
+    #
+    logging.debug("Stop event loop")
+    loop.stop()
 
 
 def get_log_level() -> int | None:
@@ -194,20 +214,27 @@ def main():   # pragma: no cover
         loop.create_task(asyncio.start_server(lambda r, w, i=inv_class:
                                               handle_client(r, w, i),
                                               '0.0.0.0', port))
+    web_task = loop.create_task(webserver('0.0.0.0', 8127))
+
+    #
+    # Register some UNIX Signal handler for a gracefully server shutdown
+    # on Docker restart and stop
+    #
+    for signame in ('SIGINT', 'SIGTERM'):
+        loop.add_signal_handler(getattr(signal, signame),
+                                lambda loop=loop: asyncio.create_task(
+                                    handle_shutdown(loop, web_task)))
 
     loop.set_debug(log_level == logging.DEBUG)
     try:
-        ProxyState.set_up(True)
+        global proxy_is_up
-        logging.info("Start Quart")
+        proxy_is_up = True
-        app.run(host='0.0.0.0', port=8127, use_reloader=False, loop=loop)
+        loop.run_forever()
-        logging.info("Quart stopped")
-
     except KeyboardInterrupt:
         pass
-    except asyncio.exceptions.CancelledError:
-        logging.info("Quart cancelled")
-
     finally:
+        logging.info("Event loop is stopped")
+        Proxy.class_close(loop)
         logging.debug('Close event loop')
         loop.close()
         logging.info(f'Finally, exit Server "{serv_name}"')

app/src/web/routes.py

@@ -1,9 +0,0 @@
-from quart import Blueprint
-from quart import Response
-
-web_routes = Blueprint('web_routes', __name__)
-
-
-@web_routes.route('/')
-async def hello():
-    return Response(response="Hello, world")

app/tests/test_server.py

@@ -3,9 +3,7 @@ import pytest
 import logging
 import os
 from mock import patch
-from server import get_log_level, app, ProxyState
+from server import get_log_level
-
-pytest_plugins = ('pytest_asyncio',)
 
 def test_get_log_level():
 
@@ -32,37 +30,3 @@ def test_get_log_level():
     with patch.dict(os.environ, {'LOG_LVL': 'UNKNOWN'}):
         log_lvl = get_log_level()
         assert log_lvl == None
-
-@pytest.mark.asyncio
-async def test_ready():
-    """Test the ready route."""
-
-    ProxyState.set_up(False)
-    client = app.test_client()
-    response = await client.get('/-/ready')
-    assert response.status_code == 503
-    result = await response.get_data()
-    assert result == b"Not ready"
-
-    ProxyState.set_up(True)
-    response = await client.get('/-/ready')
-    assert response.status_code == 200
-    result = await response.get_data()
-    assert result == b"Is ready"
-
-@pytest.mark.asyncio
-async def test_healthy():
-    """Test the healthy route."""
-
-    ProxyState.set_up(False)
-    client = app.test_client()
-    response = await client.get('/-/healthy')
-    assert response.status_code == 200
-    result = await response.get_data()
-    assert result == b"I'm fine"
-
-    ProxyState.set_up(True)
-    response = await client.get('/-/healthy')
-    assert response.status_code == 200
-    result = await response.get_data()
-    assert result == b"I'm fine"

app/tests/test_web_route.py

@@ -1,15 +0,0 @@
-# test_with_pytest.py
-import pytest
-from server import app
-
-pytest_plugins = ('pytest_asyncio',)
-
-
-@pytest.mark.asyncio
-async def test_home():
-    """Test the home route."""
-    client = app.test_client()
-    response = await client.get('/')
-    assert response.status_code == 200
-    result = await response.get_data()
-    assert result == b"Hello, world"

ha_addons/Makefile

@@ -83,8 +83,7 @@ SRC_FILES := $(wildcard $(SRC_PROXY)/*.py)\
  $(wildcard $(SRC_PROXY)/cnf/*.py)\
  $(wildcard $(SRC_PROXY)/cnf/*.toml)\
  $(wildcard $(SRC_PROXY)/gen3/*.py)\
- $(wildcard $(SRC_PROXY)/gen3plus/*.py)\
+ $(wildcard $(SRC_PROXY)/gen3plus/*.py)
- $(wildcard $(SRC_PROXY)/web/*.py)
 CNF_FILES := $(wildcard $(CNF_PROXY)/*.toml)
 
 # determine destination files

ha_addons/ha_addon/translations/de.yaml

@@ -106,4 +106,3 @@ configuration:
 network:
   5005/tcp: listening Port für TSUN GEN3 Wechselrichter
   10000/tcp: listening Port für TSUN GEN3PLUS Wechselrichter
-  8127/tcp: Port für das TSUN-Proxy Dashboard

ha_addons/ha_addon/translations/en.yaml

@@ -107,4 +107,3 @@ configuration:
 network:
   5005/tcp: listening Port for TSUN GEN3 Devices
   10000/tcp: listening Port for TSUN GEN3PLUS Devices
-  8127/tcp: Port for the TSUN-Proxy Dashboard

ha_addons/templates/config.jinja

@@ -23,11 +23,8 @@ services:
 ports:
   5005/tcp: 5005
   10000/tcp: 10000
-  8127/tcp: 8127
+
-webui: "http://[HOST]:[PORT:8127]/"
 watchdog: "http://[HOST]:[PORT:8127]/-/healthy"
-ingress: true
-ingress_port: 8127
 
 # Definition of parameters in the configuration tab of the addon
 # parameters are available within the container as /data/options.json