fix(cli_update): fix ak-sk of cli update (#298)

* fix(cli_update): fix ak-sk of cli update

* fix(cli_update): fix ak-sk of cli update (cloudapp)

Author: floritange

veadk/cli/cli_update.py

@@ -13,10 +13,10 @@
 # limitations under the License.
 
 import click
-import os
 
 from veadk.cloud.cloud_agent_engine import CloudAgentEngine
 from veadk.utils.logger import get_logger
+from veadk.config import getenv
 
 logger = get_logger(__name__)
 
@@ -79,13 +79,16 @@ def update(
         FileNotFoundError: If local path does not exist.
     """
     # Set environment variables if provided
-    if volcengine_access_key and "VOLCENGINE_ACCESS_KEY" not in os.environ:
-        os.environ["VOLCENGINE_ACCESS_KEY"] = volcengine_access_key
-    if volcengine_secret_key and "VOLCENGINE_SECRET_KEY" not in os.environ:
-        os.environ["VOLCENGINE_SECRET_KEY"] = volcengine_secret_key
+    if not volcengine_access_key:
+        volcengine_access_key = getenv("VOLCENGINE_ACCESS_KEY")
+    if not volcengine_secret_key:
+        volcengine_secret_key = getenv("VOLCENGINE_SECRET_KEY")
 
     # Initialize cloud agent engine
-    engine = CloudAgentEngine()
+    engine = CloudAgentEngine(
+        volcengine_access_key=volcengine_access_key,
+        volcengine_secret_key=volcengine_secret_key,
+    )
 
     try:
         # Update function code

veadk/cloud/cloud_agent_engine.py

@@ -57,8 +57,12 @@ class CloudAgentEngine(BaseModel):
         ```
     """
 
-    volcengine_access_key: str = getenv("VOLCENGINE_ACCESS_KEY")
-    volcengine_secret_key: str = getenv("VOLCENGINE_SECRET_KEY")
+    volcengine_access_key: str = getenv(
+        "VOLCENGINE_ACCESS_KEY", "", allow_false_values=True
+    )
+    volcengine_secret_key: str = getenv(
+        "VOLCENGINE_SECRET_KEY", "", allow_false_values=True
+    )
     region: str = "cn-beijing"
 
     def model_post_init(self, context: Any, /) -> None:

veadk/cloud/cloud_app.py

@@ -124,8 +124,12 @@ def __init__(
 
     def _get_vefaas_endpoint(
         self,
-        volcengine_ak: str = getenv("VOLCENGINE_ACCESS_KEY"),
-        volcengine_sk: str = getenv("VOLCENGINE_SECRET_KEY"),
+        volcengine_ak: str = getenv(
+            "VOLCENGINE_ACCESS_KEY", "", allow_false_values=True
+        ),
+        volcengine_sk: str = getenv(
+            "VOLCENGINE_SECRET_KEY", "", allow_false_values=True
+        ),
     ) -> str:
         """Fetches the application endpoint from VeFaaS details if not directly provided.
 
@@ -244,8 +248,12 @@ async def _get_a2a_client(self) -> A2AClient:
     def update_self(
         self,
         path: str,
-        volcengine_ak: str = getenv("VOLCENGINE_ACCESS_KEY"),
-        volcengine_sk: str = getenv("VOLCENGINE_SECRET_KEY"),
+        volcengine_ak: str = getenv(
+            "VOLCENGINE_ACCESS_KEY", "", allow_false_values=True
+        ),
+        volcengine_sk: str = getenv(
+            "VOLCENGINE_SECRET_KEY", "", allow_false_values=True
+        ),
     ):
         """Updates the configuration of this cloud application.
 
@@ -291,8 +299,12 @@ def update_self(
 
     def delete_self(
         self,
-        volcengine_ak: str = getenv("VOLCENGINE_ACCESS_KEY"),
-        volcengine_sk: str = getenv("VOLCENGINE_SECRET_KEY"),
+        volcengine_ak: str = getenv(
+            "VOLCENGINE_ACCESS_KEY", "", allow_false_values=True
+        ),
+        volcengine_sk: str = getenv(
+            "VOLCENGINE_SECRET_KEY", "", allow_false_values=True
+        ),
     ):
         """Deletes this cloud application after interactive confirmation.