Add Api Clients with Reactions and Targeted Message support

.gitignore

@@ -9,6 +9,8 @@
 # local app settings files
 appsettings.Local.json
 
+.claude/
+
 # User-specific files
 *.rsuser
 *.suo

core/samples/CompatBot/EchoBot.cs

@@ -5,6 +5,7 @@
 using Microsoft.Bot.Builder.Teams;
 using Microsoft.Bot.Schema;
 using Microsoft.Bot.Schema.Teams;
+using Microsoft.Identity.Client;
 using Microsoft.Teams.Bot.Apps;
 using Microsoft.Teams.Bot.Apps.Schema;
 using Microsoft.Teams.Bot.Compat;
@@ -36,15 +37,67 @@ protected override async Task OnMessageActivityAsync(ITurnContext<IMessageActivi
         ConversationData conversationData = await conversationStateAccessors.GetAsync(turnContext, () => new ConversationData(), cancellationToken);
 
         string replyText = $"Echo from BF Compat [{conversationData.MessageCount++}]: {turnContext.Activity.Text}";
-        await turnContext.SendActivityAsync(MessageFactory.Text(replyText, replyText), cancellationToken);
+
+        var act = MessageFactory.Text(replyText, replyText);
+        act.Properties.Add("isTargeted", true); 
+        await turnContext.SendActivityAsync(act, cancellationToken);
+
+
         await turnContext.SendActivityAsync(MessageFactory.Text($"Send a proactive message `/api/notify/{turnContext.Activity.Conversation.Id}`"), cancellationToken);
 
+        var activity = ((Activity)turnContext.Activity).FromCompatActivity();
+        TeamsActivity tm = TeamsActivity.CreateBuilder()
+            .WithConversation(new Conversation { Id = activity.Conversation?.Id! })
+            .WithText("Hello TM !")
+            .WithRecipient(activity.From, true)
+            .WithFrom(activity.Recipient)
+            //.WithServiceUrl(activity.ServiceUrl!)
+            .WithServiceUrl("https://pilot1.botapi.skype.com/amer/9a9b49fd-1dc5-4217-88b3-ecf855e91b0e/")
+            .Build();
+
+        //await teamsBotApp.ConversationClient.SendActivityAsync(tm, cancellationToken: cancellationToken);
+
+        var res = await turnContext.SendActivityAsync(MessageFactory.Text("I'm going to add and remove reactions to this message."), cancellationToken);
+
+        await Task.Delay(500, cancellationToken);
+        var ca = ((Activity)turnContext.Activity).FromCompatActivity();
+        await teamsBotApp.ConversationClient.AddReactionAsync(
+            turnContext.Activity.Conversation.Id,
+            res.Id,
+            "laugh",
+            //new Uri("https://pilot1.botapi.skype.com/amer/9a9b49fd-1dc5-4217-88b3-ecf855e91b0e/"),
+            ca.ServiceUrl!,
+            AgenticIdentity.FromProperties(ca.Recipient?.Properties),
+            null,
+            cancellationToken);
+
+        await Task.Delay(500, cancellationToken);
+        await teamsBotApp.ConversationClient.AddReactionAsync(
+            turnContext.Activity.Conversation.Id,
+            res.Id,
+            "sad",
+            ca.ServiceUrl!,
+            AgenticIdentity.FromProperties(ca.Recipient?.Properties),
+            null,
+            cancellationToken);
+
+        await Task.Delay(500, cancellationToken);
+        await teamsBotApp.ConversationClient.DeleteReactionAsync(
+            turnContext.Activity.Conversation.Id,
+            res.Id,
+            "laugh",
+            //new Uri("https://pilot1.botapi.skype.com/amer/9a9b49fd-1dc5-4217-88b3-ecf855e91b0e/"), 
+            ca.ServiceUrl!,
+            AgenticIdentity.FromProperties(ca.Recipient?.Properties),
+            null,
+            cancellationToken);
+
         // TeamsAPXClient provides Teams-specific operations like:
         // - FetchTeamDetailsAsync, FetchChannelListAsync
         // - FetchMeetingInfoAsync, FetchParticipantAsync, SendMeetingNotificationAsync
         // - Batch messaging: SendMessageToListOfUsersAsync, SendMessageToAllUsersInTenantAsync, etc.
 
-        await SendUpdateDeleteActivityAsync(turnContext, teamsBotApp.ConversationClient, cancellationToken);
+         // await SendUpdateDeleteActivityAsync(turnContext, teamsBotApp.ConversationClient, cancellationToken);
 
         Attachment attachment = new()
         {

core/samples/TeamsBot/GlobalSuppressions.cs

@@ -1,4 +1,4 @@
-// This file is used by Code Analysis to maintain SuppressMessage
+// This file is used by Code Analysis to maintain SuppressMessage
 // attributes that are applied to this project.
 // Project-level suppressions either have no target or are given
 // a specific target and scoped to a namespace, type, member, etc.

core/samples/TeamsBot/Program.cs

@@ -99,9 +99,19 @@ [Visit Microsoft](https://www.microsoft.com)
     string replyText = $"You sent: `{context.Activity.Text}` in activity of type `{context.Activity.Type}`.";
 
     MessageActivity reply = new(replyText);
+
     reply.AddMention(context.Activity.From!);
 
-    await context.SendActivityAsync(reply, cancellationToken);
+    ArgumentNullException.ThrowIfNull(context.Activity.From);
+
+    TeamsActivity ta = TeamsActivity.CreateBuilder()
+        .WithType(TeamsActivityType.Message)
+        .WithText(replyText)
+        .WithRecipient(context.Activity.From, true)
+        .AddMention(context.Activity.From)
+        .Build();
+
+    await context.SendActivityAsync(ta, cancellationToken);
 
     TeamsAttachment feedbackCard = TeamsAttachment.CreateBuilder()
             .WithAdaptiveCard(Cards.FeedbackCardObj)

core/src/Microsoft.Teams.Bot.Apps/Api/ActivitiesApi.cs

@@ -0,0 +1,195 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT License.
+
+using Microsoft.Teams.Bot.Apps.Schema;
+using Microsoft.Teams.Bot.Core;
+using Microsoft.Teams.Bot.Core.Schema;
+
+namespace Microsoft.Teams.Bot.Apps.Api;
+
+using CustomHeaders = Dictionary<string, string>;
+
+/// <summary>
+/// Provides activity operations for sending, updating, and deleting activities in conversations.
+/// </summary>
+public class ActivitiesApi
+{
+    private readonly ConversationClient _client;
+
+    /// <summary>
+    /// Initializes a new instance of the <see cref="ActivitiesApi"/> class.
+    /// </summary>
+    /// <param name="conversationClient">The conversation client for activity operations.</param>
+    internal ActivitiesApi(ConversationClient conversationClient)
+    {
+        _client = conversationClient;
+    }
+
+    /// <summary>
+    /// Sends an activity to a conversation.
+    /// </summary>
+    /// <param name="activity">The activity to send. Must contain valid conversation and service URL information.</param>
+    /// <param name="customHeaders">Optional custom headers to include in the request.</param>
+    /// <param name="cancellationToken">A cancellation token that can be used to cancel the operation.</param>
+    /// <returns>A task that represents the asynchronous operation. The task result contains the response with the ID of the sent activity.</returns>
+    public Task<SendActivityResponse> SendAsync(
+        CoreActivity activity,
+        CustomHeaders? customHeaders = null,
+        CancellationToken cancellationToken = default)
+        => _client.SendActivityAsync(activity, customHeaders, cancellationToken);
+
+    /// <summary>
+    /// Updates an existing activity in a conversation.
+    /// </summary>
+    /// <param name="conversationId">The ID of the conversation.</param>
+    /// <param name="activityId">The ID of the activity to update.</param>
+    /// <param name="activity">The updated activity data.</param>
+    /// <param name="customHeaders">Optional custom headers to include in the request.</param>
+    /// <param name="cancellationToken">A cancellation token that can be used to cancel the operation.</param>
+    /// <returns>A task that represents the asynchronous operation. The task result contains the response with the ID of the updated activity.</returns>
+    public Task<UpdateActivityResponse> UpdateAsync(
+        string conversationId,
+        string activityId,
+        CoreActivity activity,
+        CustomHeaders? customHeaders = null,
+        CancellationToken cancellationToken = default)
+        => _client.UpdateActivityAsync(conversationId, activityId, activity, customHeaders, cancellationToken);
+
+    /// <summary>
+    /// Deletes an existing activity from a conversation.
+    /// </summary>
+    /// <param name="conversationId">The ID of the conversation.</param>
+    /// <param name="activityId">The ID of the activity to delete.</param>
+    /// <param name="serviceUrl">The service URL for the conversation.</param>
+    /// <param name="agenticIdentity">Optional agentic identity for authentication.</param>
+    /// <param name="customHeaders">Optional custom headers to include in the request.</param>
+    /// <param name="cancellationToken">A cancellation token that can be used to cancel the operation.</param>
+    /// <returns>A task that represents the asynchronous operation.</returns>
+    public Task DeleteAsync(
+        string conversationId,
+        string activityId,
+        Uri serviceUrl,
+        AgenticIdentity? agenticIdentity = null,
+        CustomHeaders? customHeaders = null,
+        CancellationToken cancellationToken = default)
+        => _client.DeleteActivityAsync(conversationId, activityId, serviceUrl, agenticIdentity, customHeaders, cancellationToken);
+
+    /// <summary>
+    /// Deletes an existing activity from a conversation using activity context.
+    /// </summary>
+    /// <param name="activity">The activity to delete. Must contain valid Id, Conversation.Id, and ServiceUrl.</param>
+    /// <param name="customHeaders">Optional custom headers to include in the request.</param>
+    /// <param name="cancellationToken">A cancellation token that can be used to cancel the operation.</param>
+    /// <returns>A task that represents the asynchronous operation.</returns>
+    public Task DeleteAsync(
+        CoreActivity activity,
+        CustomHeaders? customHeaders = null,
+        CancellationToken cancellationToken = default)
+        => _client.DeleteActivityAsync(activity, customHeaders, cancellationToken);
+
+    /// <summary>
+    /// Deletes an existing activity from a conversation using Teams activity context.
+    /// </summary>
+    /// <param name="activity">The Teams activity to delete. Must contain valid Id, Conversation.Id, and ServiceUrl.</param>
+    /// <param name="customHeaders">Optional custom headers to include in the request.</param>
+    /// <param name="cancellationToken">A cancellation token that can be used to cancel the operation.</param>
+    /// <returns>A task that represents the asynchronous operation.</returns>
+    public Task DeleteAsync(
+        TeamsActivity activity,
+        CustomHeaders? customHeaders = null,
+        CancellationToken cancellationToken = default)
+        => _client.DeleteActivityAsync(activity, customHeaders, cancellationToken);
+
+    /// <summary>
+    /// Uploads and sends historic activities to a conversation.
+    /// </summary>
+    /// <param name="conversationId">The ID of the conversation.</param>
+    /// <param name="transcript">The transcript containing the historic activities.</param>
+    /// <param name="serviceUrl">The service URL for the conversation.</param>
+    /// <param name="agenticIdentity">Optional agentic identity for authentication.</param>
+    /// <param name="customHeaders">Optional custom headers to include in the request.</param>
+    /// <param name="cancellationToken">A cancellation token that can be used to cancel the operation.</param>
+    /// <returns>A task that represents the asynchronous operation. The task result contains the response with a resource ID.</returns>
+    public Task<SendConversationHistoryResponse> SendHistoryAsync(
+        string conversationId,
+        Transcript transcript,
+        Uri serviceUrl,
+        AgenticIdentity? agenticIdentity = null,
+        CustomHeaders? customHeaders = null,
+        CancellationToken cancellationToken = default)
+        => _client.SendConversationHistoryAsync(conversationId, transcript, serviceUrl, agenticIdentity, customHeaders, cancellationToken);
+
+    /// <summary>
+    /// Uploads and sends historic activities to a conversation using activity context.
+    /// </summary>
+    /// <param name="activity">The activity providing conversation context. Must contain valid Conversation.Id and ServiceUrl.</param>
+    /// <param name="transcript">The transcript containing the historic activities.</param>
+    /// <param name="customHeaders">Optional custom headers to include in the request.</param>
+    /// <param name="cancellationToken">A cancellation token that can be used to cancel the operation.</param>
+    /// <returns>A task that represents the asynchronous operation. The task result contains the response with a resource ID.</returns>
+    public Task<SendConversationHistoryResponse> SendHistoryAsync(
+        TeamsActivity activity,
+        Transcript transcript,
+        CustomHeaders? customHeaders = null,
+        CancellationToken cancellationToken = default)
+    {
+        ArgumentNullException.ThrowIfNull(activity);
+        ArgumentNullException.ThrowIfNull(activity.Conversation);
+        ArgumentNullException.ThrowIfNull(activity.Conversation.Id);
+        ArgumentNullException.ThrowIfNull(activity.ServiceUrl);
+
+        return _client.SendConversationHistoryAsync(
+            activity.Conversation.Id,
+            transcript,
+            activity.ServiceUrl,
+            activity.From?.GetAgenticIdentity(),
+            customHeaders,
+            cancellationToken);
+    }
+
+    /// <summary>
+    /// Gets the members of a specific activity.
+    /// </summary>
+    /// <param name="conversationId">The ID of the conversation.</param>
+    /// <param name="activityId">The ID of the activity.</param>
+    /// <param name="serviceUrl">The service URL for the conversation.</param>
+    /// <param name="agenticIdentity">Optional agentic identity for authentication.</param>
+    /// <param name="customHeaders">Optional custom headers to include in the request.</param>
+    /// <param name="cancellationToken">A cancellation token that can be used to cancel the operation.</param>
+    /// <returns>A task that represents the asynchronous operation. The task result contains a list of members for the activity.</returns>
+    public Task<IList<ConversationAccount>> GetMembersAsync(
+        string conversationId,
+        string activityId,
+        Uri serviceUrl,
+        AgenticIdentity? agenticIdentity = null,
+        CustomHeaders? customHeaders = null,
+        CancellationToken cancellationToken = default)
+        => _client.GetActivityMembersAsync(conversationId, activityId, serviceUrl, agenticIdentity, customHeaders, cancellationToken);
+
+    /// <summary>
+    /// Gets the members of a specific activity using activity context.
+    /// </summary>
+    /// <param name="activity">The activity to get members for. Must contain valid Id, Conversation.Id, and ServiceUrl.</param>
+    /// <param name="customHeaders">Optional custom headers to include in the request.</param>
+    /// <param name="cancellationToken">A cancellation token that can be used to cancel the operation.</param>
+    /// <returns>A task that represents the asynchronous operation. The task result contains a list of members for the activity.</returns>
+    public Task<IList<ConversationAccount>> GetMembersAsync(
+        TeamsActivity activity,
+        CustomHeaders? customHeaders = null,
+        CancellationToken cancellationToken = default)
+    {
+        ArgumentNullException.ThrowIfNull(activity);
+        ArgumentNullException.ThrowIfNull(activity.Id);
+        ArgumentNullException.ThrowIfNull(activity.Conversation);
+        ArgumentNullException.ThrowIfNull(activity.Conversation.Id);
+        ArgumentNullException.ThrowIfNull(activity.ServiceUrl);
+
+        return _client.GetActivityMembersAsync(
+            activity.Conversation.Id,
+            activity.Id,
+            activity.ServiceUrl,
+            activity.From?.GetAgenticIdentity(),
+            customHeaders,
+            cancellationToken);
+    }
+}