feat(ark e2e): decrypt by client

Change-Id: I8863f1dc4ffd6d18b6a2ddf096af813b1dd42ceb

Author: liuhuiqi.7

volcenginesdkarkruntime/resources/chat/completions.py

@@ -75,32 +75,8 @@ def _encrypt(self, model: str, messages: Iterable[ChatCompletionMessageParam], e
                                                                                   self._crypto_nonce,
                                                                                   x))
 
-    def _decrypt(self, completion: ChatCompletion | Stream[ChatCompletionChunk]):
-        if isinstance(completion, ChatCompletion):
-            if completion.choices is not None:
-                choice = completion.choices[0]
-                if choice.message.content is not None:
-                    if isinstance(choice.message.content, str):
-                        choice.message.content = self._ka_client.decrypt_string_with_key(self._crypto_key,
-                                                                                         self._crypto_nonce,
-                                                                                         choice.message.content)
-                    else:
-                        raise TypeError("content type {} is not supported end-to-end encryption".
-                                        format(type(choice.message.content)))
-                completion.choices[0] = choice
-        elif isinstance(completion, Stream):
-            for chunk in completion:
-                if chunk.choices:
-                    choice = chunk.choices[0]
-                    if choice.delta.content is not None:
-                        if isinstance(choice.delta.content, str):
-                            choice.delta.content = self._ka_client.decrypt_string_with_key(self._crypto_key,
-                                                                                             self._crypto_nonce,
-                                                                                             choice.delta.content)
-                        else:
-                            raise TypeError("content type {} is not supported end-to-end encryption".
-                                            format(type(choice.delta.content)))
-                    chunk.choices[0] = choice
+    def decrypt(self, ciphertext: str) -> str:
+        return self._ka_client.decrypt_string_with_key(self._crypto_key, self._crypto_nonce, ciphertext)
 
     @with_sts_token
     def create(
@@ -172,8 +148,6 @@ def create(
             stream_cls=Stream[ChatCompletionChunk],
         )
 
-        if is_encrypt:
-            self._decrypt(resp)
         return resp