app.py

# app.py
from fastapi import FastAPI
import socketio    

from fastapi.responses import HTMLResponse
from fastapi.staticfiles import StaticFiles

from data import sample

#from fastapi_socketio import SocketManager

app = FastAPI()
# sio = socketio.Server(logger=False);
# socket_app = socketio.WSGIApp(sio, static_files={'/': 'viewer/index.html'})    
sio = socketio.AsyncServer(logger=False, async_mode='asgi')    
socket_app = socketio.ASGIApp(sio, static_files={'/': 'viewer/index.html'})    
background_task_started = False 

#sio = SocketManager(app=app)
#sio.attach(app)

def background_task(): 
    print("background task")

@sio.on('disconnect')
def test_disconnect(sid):
    print('Client disconnected')


@app.get("/hello")
def root():
    return {"message": "Hello World"}


app.mount("/static", StaticFiles(directory="viewer"), name="static")
app.mount("/data", StaticFiles(directory="data"), name="data")


app.mount('/', socket_app)

#@app.get("/viewer", response_class=HTMLResponse)
#async def index():
#    with open('viewer/index.html') as f:
#        return f.read()


@sio.on('run')
async def handle_join(sid, *args, **kwargs):
    print("JOINING")
    await sample.run(sio)
    #return sample.run(sio)
    # print(sid)
    # print(args)
    # await sio.emit('lobby', 'User joined')


# @sio.on('test')
# async def test(sid, *args, **kwargs):
#     await sio.emit('hey', 'joe')

#app.router.add_get('/', index)


if __name__ == '__main__':
    import logging
    import sys

    logging.basicConfig(level=logging.DEBUG,
                        stream=sys.stdout)

    import uvicorn

    uvicorn.run("app:app", host='0.0.0.0', port=8000, reload=True, debug=False,log_level="info")