Replace getter functions with properties for meta access (#256)

Signed-off-by: Anuraag Agrawal <anuraaga@gmail.com>

Author: anuraaga

conformance/test/client.py

@@ -674,13 +674,13 @@ async def send_unary_request(
 
         test_response.response.payloads.extend(payloads)
 
-        for name in meta.headers():
+        for name in meta.headers:
             test_response.response.response_headers.add(
-                name=name, value=meta.headers().getall(name)
+                name=name, value=meta.headers.getall(name)
             )
-        for name in meta.trailers():
+        for name in meta.trailers:
             test_response.response.response_trailers.add(
-                name=name, value=meta.trailers().getall(name)
+                name=name, value=meta.trailers.getall(name)
             )
 
     return test_response

conformance/test/server.py

@@ -122,22 +122,22 @@ def _send_headers(
 ) -> None:
     for header in definition.response_headers:
         for value in header.value:
-            ctx.response_headers().add(header.name, value)
+            ctx.response_headers.add(header.name, value)
     for trailer in definition.response_trailers:
         for value in trailer.value:
-            ctx.response_trailers().add(trailer.name, value)
+            ctx.response_trailers.add(trailer.name, value)
 
 
 def _create_request_info(
     ctx: RequestContext, reqs: list[Any]
 ) -> ConformancePayload.RequestInfo:
     request_info = ConformancePayload.RequestInfo(requests=reqs)
-    timeout_ms = ctx.timeout_ms()
+    timeout_ms = ctx.timeout_ms
     if timeout_ms is not None:
         request_info.timeout_ms = int(timeout_ms)
-    for key in ctx.request_headers():
+    for key in ctx.request_headers:
         request_info.request_headers.add(
-            name=key, value=ctx.request_headers().getall(key)
+            name=key, value=ctx.request_headers.getall(key)
         )
     return request_info
 

connectrpc-otel/connectrpc_otel/_instrumentor.py

@@ -16,7 +16,7 @@
     from opentelemetry.metrics import MeterProvider
     from opentelemetry.trace import TracerProvider
 
-_instruments = ("connectrpc>=0.9.0",)
+_instruments = ("connectrpc>=0.11.0",)
 
 P = ParamSpec("P")
 R = TypeVar("R")

connectrpc-otel/connectrpc_otel/_interceptor.py

@@ -102,13 +102,13 @@ async def on_start(self, ctx: RequestContext) -> Token:
     def on_start_sync(self, ctx: RequestContext) -> Token:
         start_time = time.perf_counter()
 
-        rpc_method = f"{ctx.method().service_name}/{ctx.method().name}"
+        rpc_method = f"{ctx.method.service_name}/{ctx.method.name}"
         shared_attrs: dict[str, AttributeValue] = {
             RPC_SYSTEM_NAME: RpcSystemNameValues.CONNECTRPC.value,
             RPC_METHOD: rpc_method,
         }
 
-        if sa := ctx.server_address():
+        if sa := ctx.server_address:
             addr, port = sa.rsplit(":", 1)
             shared_attrs[SERVER_ADDRESS] = addr
             shared_attrs[SERVER_PORT] = int(port)
@@ -150,18 +150,18 @@ def _start_span(
         parent_otel_ctx = None
         if self._client:
             span_kind = SpanKind.CLIENT
-            carrier = ctx.request_headers()
+            carrier = ctx.request_headers
             self._propagator.inject(carrier, setter=_DEFAULT_TEXTMAP_SETTER)
         else:
             span_kind = SpanKind.SERVER
             parent_span = get_current_span()
             if not parent_span.get_span_context().is_valid:
-                carrier = ctx.request_headers()
+                carrier = ctx.request_headers
                 parent_otel_ctx = self._propagator.extract(carrier)
 
         attrs: dict[str, AttributeValue] = shared_attrs.copy()
 
-        if ca := ctx.client_address():
+        if ca := ctx.client_address:
             addr, port = ca.rsplit(":", 1)
             attrs[CLIENT_ADDRESS] = addr
             attrs[CLIENT_PORT] = int(port)

connectrpc-otel/pyproject.toml

@@ -61,7 +61,7 @@ dev = [
   # have a real dependency to avoid any possible version conflicts. But for Python,
   # the ecosystem vastly favors auto-instrumentation, and it is easier to add than remove
   # a transitive dependency, so we go ahead and leave it out.
-  "connectrpc>=0.8.0",
+  "connectrpc>=0.11.0",
 
   "connect-python-example",
   "pytest",

protoc-gen-connect-python/pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "protoc-gen-connectrpc"
-version = "0.10.1"
+version = "0.11.0"
 description = "Code generator for connect-python"
 readme = "README.md"
 requires-python = ">= 3.10"

protoc-gen-connect-python/uv.lock

@@ -1,6 +1,6 @@
 [project]
 name = "connectrpc"
-version = "0.10.1"
+version = "0.11.0"
 description = "Server and client runtime library for Connect RPC"
 readme = "README.md"
 requires-python = ">= 3.10"

pyproject.toml

@@ -283,9 +283,9 @@ async def _send_request_unary(
                 self._send_request_bidi_stream(_yield_single_message(request), ctx)
             )
 
-        request_headers = HTTPHeaders(ctx.request_headers().allitems())
-        url = f"{self._address}/{ctx.method().service_name}/{ctx.method().name}"
-        if (timeout_ms := ctx.timeout_ms()) is not None:
+        request_headers = HTTPHeaders(ctx.request_headers.allitems())
+        url = f"{self._address}/{ctx.method.service_name}/{ctx.method.name}"
+        if (timeout_ms := ctx.timeout_ms) is not None:
             timeout_s = timeout_ms / 1000.0
         else:
             timeout_s = None
@@ -295,7 +295,7 @@ async def _send_request_unary(
             if self._send_compression:
                 request_data = self._send_compression.compress(request_data)
 
-            if ctx.http_method() == "GET":
+            if ctx.http_method == "GET":
                 params = _client_shared.prepare_get_params(
                     self._codec, request_data, request_headers
                 )
@@ -333,7 +333,7 @@ async def _send_request_unary(
                         f"message is larger than configured max {self._read_max_bytes}",
                     )
 
-                response = ctx.method().output()
+                response = ctx.method.output()
                 self._codec.decode(resp.content, response)
                 return response
             raise ConnectWireError.from_response(resp).to_exception()
@@ -361,9 +361,9 @@ def _send_request_server_stream(
     async def _send_request_bidi_stream(
         self, request: AsyncIterator[REQ], ctx: RequestContext[REQ, RES]
     ) -> AsyncIterator[RES]:
-        request_headers = HTTPHeaders(ctx.request_headers().allitems())
-        url = f"{self._address}/{ctx.method().service_name}/{ctx.method().name}"
-        if (timeout_ms := ctx.timeout_ms()) is not None:
+        request_headers = HTTPHeaders(ctx.request_headers.allitems())
+        url = f"{self._address}/{ctx.method.service_name}/{ctx.method.name}"
+        if (timeout_ms := ctx.timeout_ms) is not None:
             timeout_s = timeout_ms / 1000.0
         else:
             timeout_s = None
@@ -390,7 +390,7 @@ async def _send_request_bidi_stream(
                         resp.headers, self._response_compressions, stream=True
                     )
                     reader = self._protocol.create_envelope_reader(
-                        ctx.method().output,
+                        ctx.method.output,
                         self._codec,
                         compression,
                         self._read_max_bytes,

src/connectrpc/_client_async.py

@@ -56,7 +56,7 @@ def maybe_map_stream_reset(
         case StreamErrorCode.CANCEL:
             # Some servers use CANCEL when deadline expires. We can't differentiate
             # that from normal cancel without checking our own deadline.
-            if (t := ctx.timeout_ms()) is not None and t <= 0:
+            if (t := ctx.timeout_ms) is not None and t <= 0:
                 return ConnectError(Code.DEADLINE_EXCEEDED, msg)
             return ConnectError(Code.CANCELED, msg)
         case StreamErrorCode.ENHANCE_YOUR_CALM: