feat(amgi): switch message protocol to per-message scope

[jackburridge]

This simplifies AMGI message protocol, it is now simplified to one call per message

async def app(scope, receive, send):
    if scope["type"] == "message":
        message = await receive()
        try:
            headers = message["headers"]
            payload = message.get("payload")
            bindings = message.get("bindings", {})
            ...  # Do some message handling here!
            await send(
                {
                    "type": "message.ack",
                }
            )
        except Exception as e:
            await send(
                {
                    "type": "message.nack",
                    "message": str(e),
                }
            )
    else:
        pass  # Handle other types

This should simplify the creation of middleware, allowing for easy implementation of tracing etc.

[codecov]

Codecov Report

✅ All modified and coverable lines are covered by tests.

📢 Thoughts on this report? Let us know!

[read-the-docs-community]

Documentation build overview

📚 AMGI | 🛠️ Build #31466247 | 📁 Comparing 5305fa2 against latest (7eeadc4)

🔍 Preview build

Show files changed (4 files in total): 📝 4 modified | ➕ 0 added | ➖ 0 deleted

File	Status
extensions.html	📝 modified
specifications.html	📝 modified
specifications/lifespan.html	📝 modified
specifications/message.html	📝 modified