Add thread message delete operation

Author: nick863

sdk/ai/Azure.AI.Agents.Persistent/CHANGELOG.md

@@ -3,6 +3,7 @@
 ## 1.1.0-beta.3 (Unreleased)
 
 ### Features Added
+- Added delete operation for `ThreadMessages`.
 
 ### Breaking Changes
 

sdk/ai/Azure.AI.Agents.Persistent/assets.json

@@ -2,5 +2,5 @@
   "AssetsRepo": "Azure/azure-sdk-assets",
   "AssetsRepoPrefixPath": "net",
   "TagPrefix": "net/ai/Azure.AI.Agents.Persistent",
-  "Tag": "net/ai/Azure.AI.Agents.Persistent_8e1aef00a7"
+  "Tag": "net/ai/Azure.AI.Agents.Persistent_812e51862e"
 }

sdk/ai/Azure.AI.Agents.Persistent/samples/README.md

@@ -32,5 +32,6 @@ description: Samples for the Azure.AI.Agents.Persistent client library.
 | [Sample17_PersistentAgents_ImageUrlInputs](https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/ai/Azure.AI.Agents.Persistent/samples/Sample17_PersistentAgents_ImageUrlInputs.md) | Sample using agents with Image URL as an input. |
 | [Sample18_PersistentAgents_ImageFileInputs](https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/ai/Azure.AI.Agents.Persistent/samples/Sample18_PersistentAgents_ImageFileInputs.md) | Sample using agents with Image Fileas an input. |
 | [Sample19_PersistentAgents_VectorStoreFile_WithSteps](https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/ai/Azure.AI.Agents.Persistent/samples/Sample19_PersistentAgents_VectorStoreFile_WithSteps.md) | Sample file search using `VectorStoreFile` and agents. |
+| [Sample20_PersistentAgents_FileSearch_Steaming](https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/ai/Azure.AI.Agents.Persistent/samples/Sample20_PersistentAgents_FileSearch_Steaming.md) | Sample file search with agent and streaming. |
 
 

sdk/ai/Azure.AI.Agents.Persistent/samples/Sample20_PersistentAgents_FileSearch_Steaming.md

@@ -1,4 +1,4 @@
-# Sample file search with agent in Azure.AI.Agents.Persistent.
+# Sample file search with agent and streaming in Azure.AI.Agents.Persistent.
 
 In this example we will create the local file, upload it to the newly created `VectorStore`, which will be used in the file search. In this example we will stream the result.
 

sdk/ai/Azure.AI.Agents.Persistent/src/Custom/ThreadMessages.cs

@@ -361,5 +361,57 @@ internal virtual Pageable<BinaryData> GetMessages(string threadId, string runId,
             HttpMessage FirstPageRequest(int? pageSizeHint) => CreateGetMessagesRequest(threadId, runId, limit, order, after, before, context);
             return GeneratorPageableHelpers.CreatePageable(FirstPageRequest, null, e => BinaryData.FromString(e.GetRawText()), ClientDiagnostics, _pipeline, "ThreadMessagesClient.GetMessages", "data", null, context);
         }
+
+        /// <summary> Deletes a thread message. </summary>
+        /// <param name="threadId"> The ID of the thread to delete. </param>
+        /// <param name="messageId">The ID of the message to delete. </param>
+        /// <param name="cancellationToken"> The cancellation token to use. </param>
+        /// <exception cref="ArgumentNullException"> <paramref name="threadId"/> is null. </exception>
+        /// <exception cref="ArgumentException"> <paramref name="threadId"/> is an empty string, and was expected to be non-empty. </exception>
+        public virtual Response<bool> DeleteMessage(
+            string threadId,
+            string messageId,
+            CancellationToken cancellationToken = default)
+        {
+            using DiagnosticScope scope = ClientDiagnostics.CreateScope("PersistentAgentsClient.DeleteThread");
+            scope.Start();
+            Response<MessageDeletionStatus> baseResponse
+                = InternalDeleteMessage(
+                    threadId:threadId,
+                    messageId: messageId,
+                    cancellationToken: cancellationToken);
+            bool simplifiedValue =
+                baseResponse.GetRawResponse() != null
+                && !baseResponse.GetRawResponse().IsError
+                && baseResponse.Value != null
+                && baseResponse.Value.Deleted;
+            return Response.FromValue(simplifiedValue, baseResponse.GetRawResponse());
+        }
+
+        /// <summary> Deletes a thread message. </summary>
+        /// <param name="threadId"> The ID of the thread to delete. </param>
+        /// <param name="messageId">The ID of the message to delete. </param>
+        /// <param name="cancellationToken"> The cancellation token to use. </param>
+        /// <exception cref="ArgumentNullException"> <paramref name="threadId"/> is null. </exception>
+        /// <exception cref="ArgumentException"> <paramref name="threadId"/> is an empty string, and was expected to be non-empty. </exception>
+        public virtual async Task<Response<bool>> DeleteMessageAsync(
+            string threadId,
+            string messageId,
+            CancellationToken cancellationToken = default)
+        {
+            using DiagnosticScope scope = ClientDiagnostics.CreateScope("PersistentAgentsClient.DeleteThread");
+            scope.Start();
+            Response<MessageDeletionStatus> baseResponse
+                = await InternalDeleteMessageAsync(
+                    threadId: threadId,
+                    messageId: messageId,
+                    cancellationToken: cancellationToken).ConfigureAwait(false);
+            bool simplifiedValue =
+                baseResponse.GetRawResponse() != null
+                && !baseResponse.GetRawResponse().IsError
+                && baseResponse.Value != null
+                && baseResponse.Value.Deleted;
+            return Response.FromValue(simplifiedValue, baseResponse.GetRawResponse());
+        }
     }
 }