import asyncio import json import pysqlite3 as sql import sanic app = sanic.Sanic() @app.route("/static/") async def static(request, f): return await sanic.response.file('static/{}'.format(f)) @app.route("/") async def index(request): return await sanic.response.file('static/index.html') @app.websocket("/socket") async def socket(request, ws): initial = await ws.recv() config = json.loads(initial) sanic.log.logger.info('connected websocket for {} in game {}'.format( config['user'], config['game'])) for x in range(50): await ws.send(json.dumps({"author": "server", "content": str(x)})) await asyncio.sleep(1) # await ws.send(json.dumps({"author": "server", "content": "two"})) # await asyncio.sleep(1) # await ws.send(json.dumps({"author": "server", "content": "three"})) # while True: # data = 'hello!' # print('Sending: ' + data) # await ws.send(data) # data = await ws.recv() # print('Received: ' + data) if __name__ == '__main__': app.run()