UnhandledErrorInterceptor re-raises grpc.RpcError, so a failed outbound call reaches the caller as UNKNOWN with its details #86

import asyncio
import logging

import grpc
from grpc_server_kit import GrpcApp, GrpcServerConfig
from servicewright.adapters.grpc import UnhandledErrorInterceptor


def generic(service, method, handler):
    return lambda server: server.add_generic_rpc_handlers((
        grpc.method_handlers_generic_handler(service, {method: grpc.unary_unary_rpc_method_handler(handler)}),
    ))


async def main():
    async def ledger(request, context):
        await context.abort(grpc.StatusCode.INTERNAL, "ledger dsn=postgres://ledger:s3cret@10.0.3.7/ledger")

    downstream = GrpcApp(GrpcServerConfig(host="127.0.0.1", port=0))
    downstream.register(generic("billing.Ledger", "Get", ledger))
    async with downstream:
        target = f"127.0.0.1:{downstream.bound_port}"

        async def invoice(request, context):
            async with grpc.aio.insecure_channel(target) as channel:
                await channel.unary_unary("/billing.Ledger/Get")(b"", timeout=2)
            return b"ok"

        app = GrpcApp(GrpcServerConfig(host="127.0.0.1", port=0), interceptors=[UnhandledErrorInterceptor()])
        app.register(generic("orders.Invoices", "GetInvoice", invoice))
        async with app:
            async with grpc.aio.insecure_channel(f"127.0.0.1:{app.bound_port}") as channel:
                try:
                    await channel.unary_unary("/orders.Invoices/GetInvoice")(b"", timeout=3)
                except grpc.aio.AioRpcError as error:
                    print("status: ", error.code().name)
                    print("details:", error.details())


logging.basicConfig(level=logging.CRITICAL)
asyncio.run(main())