Commit 0a22a8e

mz-koMZC01-HYUPKO

authored and

MZC01-HYUPKO

committed

test: add debug codes for alert-manager

Signed-off-by: MZC01-HYUPKO <mzc01-hyupko@MZC01-HYUPKO.local>

1 parent a6e8b13 commit 0a22a8eCopy full SHA for 0a22a8e

File tree

2 files changed

+32

-4

lines changed

src/spaceone/core
- connector
  - space_connector.py
- pygrpc
  - client.py

2 files changed

+32

-4

lines changed

`‎src/spaceone/core/connector/space_connector.py‎`

Lines changed: 9 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -44,6 +44,7 @@ def client(self) -> GRPCClient:`
`44`	`44`	`return self._client`
`45`	`45`
`46`	`46`	`def dispatch(self, method: str, params: dict = None, **kwargs) -> Any:`
	`47`	`+ _LOGGER.debug(f"space_connector.dispatch : method: {method}")`
`47`	`48`	`return self._call_api(method, params, **kwargs)`
`48`	`49`
`49`	`50`	`def _call_api(`
`@@ -55,15 +56,23 @@ def _call_api(`
`55`	`56`	`x_workspace_id: str = None,`
`56`	`57`	`) -> Any:`
`57`	`58`	`resource, verb = self._parse_method(method)`
	`59`	`+ _LOGGER.debug(f"space_connector.dispatch :: resource: {resource}, verb: {verb}")`
	`60`	`+`
`58`	`61`	`self._check_method(resource, verb)`
`59`	`62`
`60`	`63`	`params = params or {}`
	`64`	`+ _LOGGER.debug(f"space_connector.dispatch :: params: {params}")`
`61`	`65`	`metadata = self._get_connection_metadata(token, x_domain_id, x_workspace_id)`
	`66`	`+ _LOGGER.debug(f"space_connector.dispatch :: metadata: {metadata}")`
`62`	`67`
`63`	`68`	`response_or_iterator = getattr(getattr(self._client, resource), verb)(`
`64`	`69`	`params, metadata=metadata`
`65`	`70`	`)`
`66`	`71`
	`72`	`+ _LOGGER.debug(`
	`73`	`+ f"space_connector.dispatch :: response_or_iterator: {response_or_iterator}"`
	`74`	`+ )`
	`75`	`+`
`67`	`76`	`if self._return_type == "dict":`
`68`	`77`	`if isinstance(response_or_iterator, types.GeneratorType):`
`69`	`78`	`return self._generate_response(response_or_iterator)`

`‎src/spaceone/core/pygrpc/client.py‎`

Lines changed: 23 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,7 @@`
`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 (`
`@@ -109,16 +109,24 @@ def _retry_call(`
`109`	`109`	`):`
`110`	`110`	`retries = 0`
`111`	`111`
	`112`	`+ _LOGGER.debug(`
	`113`	`+ f"client._retry_call.init :: client_call_details: {client_call_details}"`
	`114`	`+ )`
	`115`	`+`
`112`	`116`	`while True:`
`113`	`117`	`try:`
	`118`	`+ _LOGGER.debug(f"client._retry_call.start!!!")`
`114`	`119`	`response_or_iterator = continuation(`
`115`	`120`	`client_call_details, request_or_iterator`
`116`	`121`	`)`
	`122`	`+ _LOGGER.debug(f"client._retry_call.response_or_iterator Success!!!")`
`117`	`123`
`118`	`124`	`if is_stream:`
`119`	`125`	`response_or_iterator = self._generate_response(response_or_iterator)`
`120`	`126`	`else:`
	`127`	`+ _LOGGER.debug(f"client._retry_call.start _check_error!!!")`
`121`	`128`	`self._check_error(response_or_iterator)`
	`129`	`+ _LOGGER.debug(f"client._retry_call.finished _check_error!!!")`
`122`	`130`
`123`	`131`	`return response_or_iterator`
`124`	`132`
`@@ -207,13 +215,17 @@ def _bind_grpc_method(`
`207`	`215`	`request_desc = self._desc_pool.FindMessageTypeByName(`
`208`	`216`	`method_desc.input_type.full_name`
`209`	`217`	`)`
`210`		`- request_message_desc = MessageFactory(self._desc_pool).GetPrototype(request_desc)`
	`218`	`+ request_message_desc = MessageFactory(self._desc_pool).GetPrototype(`
	`219`	`+ request_desc`
	`220`	`+ )`
`211`	`221`	`# request_message_desc = GetMessageClass(request_desc)`
`212`	`222`
`213`	`223`	`response_desc = self._desc_pool.FindMessageTypeByName(`
`214`	`224`	`method_desc.output_type.full_name`
`215`	`225`	`)`
`216`		`- response_message_desc = MessageFactory(self._desc_pool).GetPrototype(response_desc)`
	`226`	`+ response_message_desc = MessageFactory(self._desc_pool).GetPrototype(`
	`227`	`+ response_desc`
	`228`	`+ )`
`217`	`229`	`# response_message_desc = GetMessageClass(response_desc)`
`218`	`230`
`219`	`231`	`if method_desc.client_streaming and method_desc.server_streaming:`
`@@ -286,7 +298,9 @@ def _init_grpc_reflection(self):`
`286`	`298`	`request_desc = self._desc_pool.FindMessageTypeByName(`
`287`	`299`	`method_desc.input_type.full_name`
`288`	`300`	`)`
`289`		`- self._request_map[method_key] = MessageFactory(self._desc_pool).GetPrototype(request_desc)`
	`301`	`+ self._request_map[method_key] = MessageFactory(`
	`302`	`+ self._desc_pool`
	`303`	`+ ).GetPrototype(request_desc)`
`290`	`304`	`# self._request_map[method_key] = GetMessageClass(request_desc)`
`291`	`305`
`292`	`306`	`if service_desc.name not in self._api_resources:`
`@@ -324,6 +338,11 @@ def client(endpoint=None, ssl_enabled=False, max_message_length=None, **client_o`
`324`	`338`	`if endpoint is None:`
`325`	`339`	`raise Exception("Client's endpoint is undefined.")`
`326`	`340`
	`341`	`+ _LOGGER.debug(f"pygrpc.client :: endpoint: {endpoint}")`
	`342`	`+ _LOGGER.debug(`
	`343`	`+ f"pygrpc.client :: _GRPC_CHANNEL: {_GRPC_CHANNEL} / is in? {endpoint in _GRPC_CHANNEL}"`
	`344`	`+ )`
	`345`	`+`
`327`	`346`	`if endpoint not in _GRPC_CHANNEL:`
`328`	`347`	`options = []`
`329`	`348`

0 commit comments

Comments

(0)

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit 0a22a8e

File tree

2 files changed

2 files changed

`‎src/spaceone/core/connector/space_connector.py‎`

`‎src/spaceone/core/pygrpc/client.py‎`

0 commit comments