From 850606c7689eb8506862fbc8803c1c6a80f481a5 Mon Sep 17 00:00:00 2001 From: ImMin5 Date: Fri, 22 Dec 2023 12:13:11 +0900 Subject: [PATCH] fix: temporary remove send metadat to noti plugin --- .../connector/notification_plugin_connector.py | 7 ++++--- src/spaceone/notification/service/protocol_service.py | 5 ++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/src/spaceone/notification/connector/notification_plugin_connector.py b/src/spaceone/notification/connector/notification_plugin_connector.py index d4813e0..b9c5c93 100644 --- a/src/spaceone/notification/connector/notification_plugin_connector.py +++ b/src/spaceone/notification/connector/notification_plugin_connector.py @@ -3,6 +3,7 @@ from google.protobuf.json_format import MessageToDict from spaceone.core.connector import BaseConnector +from spaceone.core.connector.space_connector import SpaceConnector from spaceone.core import pygrpc from spaceone.core.utils import parse_endpoint @@ -30,8 +31,8 @@ def init(self, options): response = self.client.Protocol.init( { "options": options, - }, - metadata=self.transaction.meta, + } + # metadata=self.transaction.meta, ) return self._change_message(response) @@ -39,7 +40,7 @@ def init(self, options): def verify(self, options, secret_data): params = {"options": options, "secret_data": secret_data} - self.client.Protocol.verify(params, metadata=self.transaction.meta) + self.client.Protocol.verify(params) # todo: add metadata def dispatch_notification( self, secret_data, channel_data, notification_type, message, options={} diff --git a/src/spaceone/notification/service/protocol_service.py b/src/spaceone/notification/service/protocol_service.py index cfd197e..0300297 100644 --- a/src/spaceone/notification/service/protocol_service.py +++ b/src/spaceone/notification/service/protocol_service.py @@ -83,14 +83,13 @@ def _create(self, params: dict) -> Protocol: "name": utils.generate_id("secret-noti-proto", 4), "data": plugin_info["secret_data"], "resource_group": "WORKSPACE", - "schema_id": plugin_info["schema_id"], + "schema_id": plugin_info["schema"], # todo change to schema_id } - protocol_secret = secret_mgr.create_secret(secret_params) request_plugin.update( { "secret_id": protocol_secret["secret_id"], - "schema_id": plugin_info["schema_id"], + "schema_id": plugin_info["schema"], # todo change to schema_id } )