@@ -228,6 +228,7 @@ def generate_river_module(
228228 chunks : list [str ] = [
229229 dedent (
230230 f"""\
231+ # ruff: noqa
231232 # Code generated by river.codegen. DO NOT EDIT.
232233 import datetime
233234 from typing import Any, Mapping, Tuple
@@ -257,22 +258,21 @@ def _remove_namespace(name: str) -> str:
257258 for service in pd .service :
258259 chunks .extend (
259260 [
260- f"""def add_{ service .name } Servicer_to_server(
261+ dedent (
262+ f"""\
263+ def add_{ service .name } Servicer_to_server(
261264 servicer: { pb_module_name } _pb2_grpc.{ service .name } Servicer,
262265 server: river.Server,
263- ) -> None:""" ,
264- (
265- " rpc_method_handlers: Mapping[Tuple[str, str], "
266- "Tuple[str, river.GenericRpcHandler]] = {"
266+ ) -> None:
267+ rpc_method_handlers: Mapping[
268+ Tuple[str, str],
269+ Tuple[str, river.GenericRpcHandler]
270+ ] = {{
271+ """
267272 ),
268273 ]
269274 )
270275 for method in service .method :
271- descriptor = f"""('{
272- '' .join ([service .name [0 ].lower (), service .name [1 :]])
273- } ', '{
274- '' .join ([method .name [0 ].lower (), method .name [1 :]])
275- } ')"""
276276 method_kind : str
277277 handler_name : str
278278 if method .client_streaming :
@@ -290,17 +290,30 @@ def _remove_namespace(name: str) -> str:
290290 method_kind = "rpc"
291291 handler_name = "rpc_method_handler"
292292
293+ descriptor = dedent (
294+ f"""\
295+ (
296+ { repr ('' .join ([service .name [0 ].lower (), service .name [1 :]]))} ,
297+ { repr ('' .join ([method .name [0 ].lower (), method .name [1 :]]))}
298+ )
299+ """
300+ )
301+ decoder_term = f"_{ _remove_namespace (method .input_type )} Decoder"
302+ encoder_term = f"_{ _remove_namespace (method .output_type )} Encoder"
293303 chunks .extend (
294304 [
295- f" { descriptor } : ('{ method_kind } ', river.{ handler_name } (" ,
296- f" servicer.{ method .name } ," ,
297- f""" _{
298- _remove_namespace (method .input_type )
299- } Decoder,""" ,
300- f""" _{
301- _remove_namespace (method .output_type )
302- } Encoder,""" ,
303- " ))," ,
305+ dedent (
306+ f"""\
307+ { descriptor } : (
308+ { repr (method_kind )} ,
309+ river.{ handler_name } (
310+ servicer.{ method .name } ,
311+ { decoder_term } ,
312+ { encoder_term } ,
313+ ),
314+ ),
315+ """
316+ ),
304317 ]
305318 )
306319 chunks .append (" }" )
0 commit comments