Ananto30/zero

import logging

import aiozmq.rpc
from aiohttp import web

try:
    import uvloop

    uvloop.install()
except ImportError:
    logging.warning("Cannot use uvloop")
    pass

aiozmq_client = None


async def hello(request):
    global aiozmq_client
    if aiozmq_client is None:
        aiozmq_client = await aiozmq.rpc.connect_rpc(connect="tcp://server:5555")

    resp = await aiozmq_client.call.hello_world()
    return web.Response(text=resp)


async def save_order(request):
    global aiozmq_client
    if aiozmq_client is None:
        aiozmq_client = await aiozmq.rpc.connect_rpc(connect="tcp://server:5555")

    data = {"user_id": "1", "items": ["apple", "python"]}
    resp = await aiozmq_client.call.save_order(data)
    return web.json_response(resp)


app = web.Application()
app.router.add_get("/hello", hello)
app.router.add_get("/order", save_order)