request.sh

curl localhost:8080 -d @json

server.py

#!/usr/bin/python3

import asyncio
import aiohttp
from aiohttp import web

def process_body(f):
  try:
    print(f.result())
  except aiohttp.errors.ClientDisconnectedError:
    print("disconnected")

def sink(r):
  asyncio.Task(r.json()).add_done_callback(process_body)
  return web.Response()

def listen(
  loop
, ip : str
, port : int
) -> None:
  app = web.Application(loop = loop)
  app.router.add_route(
    'POST'
  , '/'
  , sink
  )

  srv = loop.run_until_complete(loop.create_server(app.make_handler(), ip, port))
  print("Server started at {0}".format(srv.sockets[0].getsockname()))

def main(): # pragma: no cover
  loop = asyncio.get_event_loop()
  listen(loop, '0.0.0.0', 8080)
  loop.run_forever()

main()

testcase.sh

resp=$(./request.sh)
sent=$(cat json)

[[ "${resp}" == "${sent}" ]] && exit 0 || exit 1