#!/usr/bin/python3


import uvloop

uvloop.install()

from starlette.applications import Starlette
from starlette.responses import Response
from starlette.routing import Route

import httpx


async def topic(request):
    path = request.path_params["path"]

    body = await request.body()

    # Forward the request to the target URL
    async with httpx.AsyncClient() as client:
        upstream_response = await client.post(
            url=path,
            data=body,
        )

    return Response(
        content=upstream_response.content, status_code=upstream_response.status_code
    )


app = Starlette(
    routes=[
        Route("/{path:path}", topic, methods=["PUT"]),
    ],
)