Lint Node using-cards

samples/csharp_dotnetcore/16.proactive-messages/Bots/ProactiveBot.cs

@@ -2,6 +2,7 @@
 // Licensed under the MIT License.
 
 using System.Collections.Concurrent;
+using System.Collections.Generic;
 using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.Bot.Builder;
@@ -11,18 +12,48 @@ namespace Microsoft.BotBuilderSamples
 {
     public class ProactiveBot : ActivityHandler
     {
+        // Message to send to users when the bot receives a Conversation Update event
+        private const string WelcomeMessage = "Welcome to the Proactive Bot sample.  Navigate to http://localhost:3978/api/notify to proactively message everyone who has previously messaged this bot.";
+
+        // Dependency injected dictionary for storing ConversationReference objects used in NotifyController to proactively message users
         private ConcurrentDictionary<string, ConversationReference> _conversationReferences;
 
         public ProactiveBot(ConcurrentDictionary<string, ConversationReference> conversationReferences)
         {
             _conversationReferences = conversationReferences;
         }
 
+        private void AddConversationReference(Activity activity)
+        {
+            var conversationReference = activity.GetConversationReference();
+            _conversationReferences.AddOrUpdate(conversationReference.User.Id, conversationReference, (key, newValue) => conversationReference);
+        }
+
         protected override Task OnConversationUpdateActivityAsync(ITurnContext<IConversationUpdateActivity> turnContext, CancellationToken cancellationToken)
         {
-            var conversationReference = turnContext.Activity.GetConversationReference();
-            _conversationReferences.TryAdd(conversationReference.Conversation.Id, conversationReference);
-            return Task.CompletedTask;
+            AddConversationReference(turnContext.Activity as Activity);
+
+            return base.OnConversationUpdateActivityAsync(turnContext, cancellationToken);
+        }
+
+        protected override async Task OnMembersAddedAsync(IList<ChannelAccount> membersAdded, ITurnContext<IConversationUpdateActivity> turnContext, CancellationToken cancellationToken)
+        {
+            foreach (var member in membersAdded)
+            {
+                // Greet anyone that was not the target (recipient) of this message.
+                if (member.Id != turnContext.Activity.Recipient.Id)
+                {
+                    await turnContext.SendActivityAsync(((Activity)turnContext.Activity).CreateReply(WelcomeMessage), cancellationToken);
+                }
+            }
+        }
+
+        protected override async Task OnMessageActivityAsync(ITurnContext<IMessageActivity> turnContext, CancellationToken cancellationToken)
+        {
+            AddConversationReference(turnContext.Activity as Activity);
+
+            // Echo back what the user said
+            await turnContext.SendActivityAsync(((Activity)turnContext.Activity).CreateReply($"You sent '{turnContext.Activity.Text}'"), cancellationToken);
         }
     }
 }

samples/csharp_dotnetcore/16.proactive-messages/Controllers/NotifyController.cs

@@ -1,7 +1,9 @@
 // Copyright (c) Microsoft Corporation. All rights reserved.
 // Licensed under the MIT License.
 
+using System;
 using System.Collections.Concurrent;
+using System.Net;
 using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Mvc;
@@ -25,6 +27,14 @@ public NotifyController(IBotFrameworkHttpAdapter adapter, ICredentialProvider cr
             _adapter = adapter;
             _conversationReferences = conversationReferences;
             _appId = ((SimpleCredentialProvider)credentials).AppId;
+
+            // If the channel is the Emulator, and authentication is not in use,
+            // the AppId will be null.  We generate a random AppId for this case only.
+            // This is not required for production, since the AppId will have a value.
+            if (string.IsNullOrEmpty(_appId))
+            {
+                _appId = Guid.NewGuid().ToString(); //if no AppId, use a random Guid
+            }
         }
 
         public async Task<IActionResult> Get()
@@ -33,7 +43,14 @@ public async Task<IActionResult> Get()
             {
                 await ((BotAdapter)_adapter).ContinueConversationAsync(_appId, conversationReference, BotCallback, default(CancellationToken));
             }
-            return Ok();
+
+            // Let the caller know proactive messages have been sent
+            return new ContentResult()
+            {
+                Content = "<html><body><h1>Proactive messages have been sent.</h1></body></html>",
+                ContentType = "text/html",
+                StatusCode = (int)HttpStatusCode.OK,
+            };
         }
 
         private async Task BotCallback(ITurnContext turnContext, CancellationToken cancellationToken)

samples/csharp_dotnetcore/16.proactive-messages/README.md

@@ -15,6 +15,9 @@ if a bot requires some time to compile a response to the user's question, it may
 and allow the conversation to continue in the meantime. When the bot finishes compiling the response to the
 question, it will share that information with the user.
 
+This project has a NotifyController with an endpoint that will trigger the proactive messages to be sent to 
+all users who have previously messaged the bot.
+
 # To try this sample
 
 - Clone the samples repository

samples/csharp_dotnetcore/16.proactive-messages/Startup.cs

@@ -6,6 +6,7 @@
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Bot.Builder;
+using Microsoft.Bot.Builder.BotFramework;
 using Microsoft.Bot.Builder.Integration.AspNet.Core;
 using Microsoft.Bot.Connector.Authentication;
 using Microsoft.Bot.Schema;