feat: add missing text generation APIs

- Add stop_completion_message to CompletionClient
- Add get_app_feedbacks to DifyClient
- Add get_end_user_info to DifyClient
- Add corresponding async methods

Author: sunbos

dify_client/async_client.py

@@ -178,6 +178,30 @@ async def get_file_preview(self, file_id: str):
         """Get file preview by file ID."""
         return await self._send_request("GET", f"/files/{file_id}/preview")
 
+    async def get_app_feedbacks(self, page: int = 1, limit: int = 20):
+        """Get message feedbacks for the application.
+
+        Args:
+            page: Page number (default: 1)
+            limit: Number of items per page (default: 20)
+
+        Returns:
+            httpx.Response object
+        """
+        params = {"page": page, "limit": limit}
+        return await self._send_request("GET", "/app/feedbacks", params=params)
+
+    async def get_end_user_info(self, end_user_id: str):
+        """Get end user information.
+
+        Args:
+            end_user_id: End user ID
+
+        Returns:
+            httpx.Response object
+        """
+        return await self._send_request("GET", f"/end-users/{end_user_id}")
+
     # App Configuration APIs
     async def get_app_site_config(self, app_id: str):
         """Get app site configuration.
@@ -281,6 +305,19 @@ async def create_completion_message(
             stream=(response_mode == "streaming"),
         )
 
+    async def stop_completion_message(self, task_id: str, user: str):
+        """Stop a running completion message generation.
+
+        Args:
+            task_id: Task ID from the completion message response
+            user: User identifier (must match the one used in the original request)
+
+        Returns:
+            httpx.Response object
+        """
+        data = {"user": user}
+        return await self._send_request("POST", f"/completion-messages/{task_id}/stop", data)
+
 
 class AsyncChatClient(AsyncDifyClient):
     """Async client for Chat API operations."""

dify_client/client.py

@@ -255,6 +255,32 @@ def get_file_preview(self, file_id: str):
         """Get file preview by file ID."""
         return self._send_request("GET", f"/files/{file_id}/preview")
 
+    def get_app_feedbacks(self, page: int = 1, limit: int = 20):
+        """Get message feedbacks for the application.
+
+        Args:
+            page: Page number (default: 1)
+            limit: Number of items per page (default: 20)
+
+        Returns:
+            httpx.Response object
+        """
+        self._validate_params(page=page, limit=limit)
+        params = {"page": page, "limit": limit}
+        return self._send_request("GET", "/app/feedbacks", params=params)
+
+    def get_end_user_info(self, end_user_id: str):
+        """Get end user information.
+
+        Args:
+            end_user_id: End user ID
+
+        Returns:
+            httpx.Response object
+        """
+        self._validate_params(end_user_id=end_user_id)
+        return self._send_request("GET", f"/end-users/{end_user_id}")
+
     # App Configuration APIs
     def get_app_site_config(self, app_id: str):
         """Get app site configuration.
@@ -353,6 +379,20 @@ def create_completion_message(
             stream=(response_mode == "streaming"),
         )
 
+    def stop_completion_message(self, task_id: str, user: str):
+        """Stop a running completion message generation.
+
+        Args:
+            task_id: Task ID from the completion message response
+            user: User identifier (must match the one used in the original request)
+
+        Returns:
+            httpx.Response object
+        """
+        self._validate_params(task_id=task_id, user=user)
+        data = {"user": user}
+        return self._send_request("POST", f"/completion-messages/{task_id}/stop", data)
+
 
 class ChatClient(DifyClient):
     def create_chat_message(