feat: insert x_domain_id when check_plugin

cloudforet-io · Dec 21, 2023 · 0b5347a · 0b5347a
1 parent cb0583b
commit 0b5347a
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/src/spaceone/plugin/manager/repository_manager.py b/src/spaceone/plugin/manager/repository_manager.py
@@ -21,9 +21,14 @@ def get_plugin(self, plugin_id: str, domain_id: str, token: str) -> dict:
             "Plugin.get", {"plugin_id": plugin_id}, token=token, x_domain_id=domain_id
         )
 
-    def check_plugin_version(self, plugin_id, version, token: str) -> None:
+    def check_plugin_version(
+        self, plugin_id: str, version: str, token: str, domain_id: str
+    ) -> None:
         response = self.repo_connector.dispatch(
-            "Plugin.get_versions", {"plugin_id": plugin_id}, token=token
+            "Plugin.get_versions",
+            {"plugin_id": plugin_id},
+            token=token,
+            x_domain_id=domain_id,
         )
 
         if version not in response.get("results", []):

diff --git a/src/spaceone/plugin/service/plugin_service.py b/src/spaceone/plugin/service/plugin_service.py
@@ -279,7 +279,7 @@ def _check_plugin(self, plugin_id: str, domain_id: str, version: str, token: str
 
         # Check version
         try:
-            repo_mgr.check_plugin_version(plugin_id, version, token)
+            repo_mgr.check_plugin_version(plugin_id, version, token, domain_id)
         except Exception as e:
             raise ERROR_INVALID_PLUGIN_VERSION(plugin_id=plugin_id, version=version)