🙏[Question] How to start flet app async?❌

[azat385]

GUI

import flet as ft

def main(page: ft.Page):
    page.add(ft.Text("Hello, world!"))

ft.app(main)

DATA

import asyncio
import websockets
from jsonrpcclient import Ok, parse_json, request_json, request


async def work():
    uri = "ws://127.0.0.1:5000"
    async with websockets.connect(uri, ping_timeout=None) as websocket:
        sub = '{"jsonrpc": "2.0", "id": 1, "method": "subscribe", "params": [....]}'
        await websocket.send(sub)
        print(f">>> {sub}")

        async def ping():
            req = "PING"
            while True:
                await websocket.send(req)
                print(f">>> {req}")
                await asyncio.sleep(5)

        async def recv():
            while True:
                resp = await websocket.recv()
                print(f"<<< {resp}")

        await asyncio.gather(ping(), recv())



if __name__ == "__main__":
    asyncio.run(work())

how to combine this 2 files?

i need to get the data from websocket resp = await websocket.recv() and send it to GUI.
how to start flet app async and get data from resp?

Please help

[azat385]

I read Async apps 20 times but cant figure out how to do it (

[sidviny]

I have a project in progress that has this incorporated. I posted the code in main below, to help you get started. The code below has too many other things which you don't ask, but sorry, I don't have the time at the moment to brew you a better example. Nor is this code optimal. Just want to help you with this.

Basically: I used flet_fastapi so I needed the async. You must use the async methods and await everywhere you use the standard methods now.

If you want to see the full project, checkout https://gitlab.com/vindevoy/cockpyt branch "feature/flet"

import sys

import flet as ft
import flet_fastapi

from cockpyt.core import logger
from cockpyt.core.config import cockpyt_title, assets_path
from cockpyt.core.globals import SYS_EXIT_NO_UVICORN, APPLICATION_NAME, APPLICATION_VERSION
from cockpyt.core.routes import collect
from cockpyt.pages.template import page_404

###
# sidviny - 2023-09-26
# This check must go very much in the front.  Otherwise, the other parts of the application will start,
# which makes no sense.
if __name__ == "__main__":
    print("Please start the app with the 'uvicorn' command as shown in the start.sh or start.bat script")
    sys.exit(SYS_EXIT_NO_UVICORN)

###
# sidviny - 2023-09-26
# All is ok, start the application from here on
###

logger.configure()

_logger = logger.get_logger("main")
_logger.info(f"Starting {APPLICATION_NAME} {APPLICATION_VERSION}")

###
# sidviny - 2023-09-26
# The imports hereafter must be done after the logger.configure() or the formatting is not correct,
# and the logging appears too soon because we want the "Starting ..." first
# from cockpyt.core import application  # noqa
from cockpyt.core import config  # noqa

###
# sidviny - 2023-10-23
# The global page object for now, so we can have common navigation
page: ft.Page


async def main(__page: ft.Page):
    global page
    page = __page

    color_scheme = ft.ColorScheme(
        primary=ft.colors.DEEP_ORANGE,
        secondary=ft.colors.BLACK,
        background=ft.colors.WHITE,
    )

    default_theme = ft.Theme(
        visual_density=ft.ThemeVisualDensity.COMPACT,
        color_scheme=color_scheme,
    )

    routes = collect()

    page.title = f"{cockpyt_title}"
    page.theme = default_theme
    await page.update_async()

    async def route_change(_: ft.RouteChangeEvent):
        await page.clean_async()

        if page.route in routes:
            module = routes[page.route]
            bld = module.build()

        else:
            _logger.warn(f"Could not find route for: {page.route}")

            bld = page_404.build(page.route)

        await page.add_async(*bld)
        await page.update_async()

    page.on_route_change = route_change

    await page.go_async(page.route)


app = flet_fastapi.FastAPI()
app.mount("/", flet_fastapi.app(main, assets_dir=str(assets_path.absolute())))

config.info()

_logger.info("Application started")

[azat385]

i am wondering how to use await ft.app_async(main) to start the flet app as the part of a bigger app.
it is mentioned in getting-started-with-async but i cant figure out how yo use it.

Please help.

[FeodorFitsner]

Don't await ft.app_async(main), but wrap it into a task to run Flet app concurrently with the rest of your app.

[azat385]

Thanks a lot!

[azat385]

is there more convenient way to display data value?

import flet as ft
import asyncio
from random import randint

event = asyncio.Event()
data = None

# get some data from anywhere in async mode
async def get_data():
    global data

    while True:
        data = randint(0, 100)
        event.set()
        await asyncio.sleep(1)


async def gui(page: ft.Page):
    txt = ft.Text('init')
    await page.add_async(txt)

    async def process_data():
        while True:
            await event.wait()
            print(f"data={data}")
            txt.value = str(data)
            await page.update_async()
            event.clear()

    await process_data()

# wrap the gui???
async def startgui():
    await ft.app_async(gui)


async def main():
    task_get = asyncio.create_task(get_data())
    task_gui = asyncio.create_task(startgui())

    await asyncio.gather(task_gui, task_get,)


if __name__ == "__main__":
    asyncio.run(main())

[azat385]

wrap the gui???

async def startgui():
    await ft.app_async(gui)

is there any better way to wrap the app in async task to start?