Merge pull request #37 from jupyter-naas/30-implement-the-interface-for-the-secrets

feat: interface for secrets

Author: Dr0p42

naas_python/domains/secret/adaptors/primary/TyperSecretAdaptor.py

@@ -20,6 +20,7 @@
     ISecretDomain,
     ISecretInvoker,
     SecretConflictError,
+    Secret
 )
 # from naas_python.domains.secret.SecretSchema import SecrettryConflictError
 from naas_python.utils.cicd import Pipeline
@@ -53,6 +54,7 @@ def __init__(self, domain: ISecretDomain):
         # Include all commands
         self.app.command()(self.list)
         self.app.command()(self.create)
+        self.app.command()(self.bulk_create)
         self.app.command()(self.get)
         self.app.command()(self.delete)
 
@@ -96,6 +98,20 @@ def create(
 
         if secret is None:
             print('Secret Successfully created')
+            
+    def bulk_create(
+        self,
+        secrets: str = typer.Option(..., "--secrets", help="List of secrets"),
+
+    ):
+        print("\ntyper_list:",json.dumps(secrets))
+        """Create Secrets with the given specifications"""
+        secrets = self.domain.bulk_create(
+            secrets_list=secrets,
+        )
+
+        if secrets is None:
+            print('Secret Successfully created')
 
     def get(
         self,

naas_python/utils/domains_base/secondary/BaseAPIAdaptor.py

@@ -22,7 +22,7 @@ class ServiceStatusError(NaasException):
 
 class BaseAPIAdaptor(NaasSpaceAuthenticatorAdapter):
     host = os.environ.get("NAAS_PYTHON_API_BASE_URL", "https://api.naas.ai")
-    # host = os.environ.get("NAAS_PYTHON_API_BASE_URL", "http://localhost:8000")
+    #host = os.environ.get("NAAS_PYTHON_API_BASE_URL", "http://localhost:8000")
     # Cache name is the name of the calling module
     cache_name = __name__
     cache_expire_after = 60  # Cache expires after 60 seconds
@@ -89,8 +89,8 @@ def make_api_request(
             return api_response
 
         except requests.exceptions.HTTPError as e:
+            _response = api_response.json()
             if api_response.status_code == 401:
-                _response = api_response.json()
                 _message = ""
                 if "error_message" in _response:
                     _message = _response["error_message"]
@@ -103,7 +103,13 @@ def make_api_request(
                     e,
                 )
             elif api_response.status_code == 500:
-                _message = "Internal Server Error"
+                _message = ""
+                if "error_message" in _response:
+                    _message = _response["error_message"]
+                elif "detail" in _response:
+                    _message = _response["detail"]
+                else:
+                    _message = "Internal Server Error"
                 raise ServiceStatusError(_message, e)
             else:
                 # Other status codes will be handled by the calling method