|
2 | 2 | import types
|
3 | 3 | import grpc
|
4 | 4 | from google.protobuf.json_format import ParseDict
|
5 |
| -from google.protobuf.message_factory import MessageFactory, GetMessageClass |
| 5 | +from google.protobuf.message_factory import MessageFactory #, GetMessageClass |
6 | 6 | from google.protobuf.descriptor_pool import DescriptorPool
|
7 | 7 | from google.protobuf.descriptor import ServiceDescriptor, MethodDescriptor
|
8 | 8 | from grpc_reflection.v1alpha.proto_reflection_descriptor_database import (
|
@@ -207,14 +207,14 @@ def _bind_grpc_method(
|
207 | 207 | request_desc = self._desc_pool.FindMessageTypeByName(
|
208 | 208 | method_desc.input_type.full_name
|
209 | 209 | )
|
210 |
| - # request_message_desc = MessageFactory(self._desc_pool).GetPrototype(request_desc) |
211 |
| - request_message_desc = GetMessageClass(request_desc) |
| 210 | + request_message_desc = MessageFactory(self._desc_pool).GetPrototype(request_desc) |
| 211 | + # request_message_desc = GetMessageClass(request_desc) |
212 | 212 |
|
213 | 213 | response_desc = self._desc_pool.FindMessageTypeByName(
|
214 | 214 | method_desc.output_type.full_name
|
215 | 215 | )
|
216 |
| - # response_message_desc = MessageFactory(self._desc_pool).GetPrototype(response_desc) |
217 |
| - response_message_desc = GetMessageClass(response_desc) |
| 216 | + response_message_desc = MessageFactory(self._desc_pool).GetPrototype(response_desc) |
| 217 | + # response_message_desc = GetMessageClass(response_desc) |
218 | 218 |
|
219 | 219 | if method_desc.client_streaming and method_desc.server_streaming:
|
220 | 220 | setattr(
|
@@ -286,8 +286,8 @@ def _init_grpc_reflection(self):
|
286 | 286 | request_desc = self._desc_pool.FindMessageTypeByName(
|
287 | 287 | method_desc.input_type.full_name
|
288 | 288 | )
|
289 |
| - # self._request_map[method_key] = MessageFactory(self._desc_pool).GetPrototype(request_desc) |
290 |
| - self._request_map[method_key] = GetMessageClass(request_desc) |
| 289 | + self._request_map[method_key] = MessageFactory(self._desc_pool).GetPrototype(request_desc) |
| 290 | + # self._request_map[method_key] = GetMessageClass(request_desc) |
291 | 291 |
|
292 | 292 | if service_desc.name not in self._api_resources:
|
293 | 293 | self._api_resources[service_name] = []
|
|
0 commit comments