Microsoft Azureのチャットボットで会話ログを取得してみる

// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.

using System;
using System.IO;
using System.Text;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Bot.Builder;
using Microsoft.Bot.Builder.AI.QnA;
using Microsoft.Bot.Schema;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Logging;

namespace Microsoft.BotBuilderSamples
{
    public class QnABot : ActivityHandler
    {
        private readonly IConfiguration _configuration;
        private readonly ILogger<QnABot> _logger;
        private readonly IHttpClientFactory _httpClientFactory;

        public QnABot(IConfiguration configuration, ILogger<QnABot> logger, 
　　　　　　　　　　　　IHttpClientFactory httpClientFactory)
        {
            _configuration = configuration;
            _logger = logger;
            _httpClientFactory = httpClientFactory;
        }

        protected override async Task OnMessageActivityAsync(
                                          ITurnContext<IMessageActivity> turnContext,
　　　　　　　　　　　　　　　　　　　　　　  CancellationToken cancellationToken)
        {
            var httpClient = _httpClientFactory.CreateClient();

            var qnaMaker = new QnAMaker(new QnAMakerEndpoint
            {
                KnowledgeBaseId = _configuration["QnAKnowledgebaseId"],
                EndpointKey = _configuration["QnAAuthKey"],
                Host = GetHostname()
            },
            null,
            httpClient);

            _logger.LogInformation("Calling QnA Maker");

            // The actual call to the QnA Maker service.
            var response = await qnaMaker.GetAnswersAsync(turnContext);
            if (response != null && response.Length > 0)
            {
                await turnContext.SendActivityAsync(
                          MessageFactory.Text(response[0].Answer), 
　　　　　　               cancellationToken);
                            
                //ログ出力へ（回答見つかった場合）
                LogOutput(turnContext.Activity.Text, response[0].Answer);
            }
            else
            {
                await turnContext.SendActivityAsync(
                          MessageFactory.Text("回答が見つかりませんでした。"),
                          cancellationToken);
                
                //ログ出力へ（回答見つからなかった場合）
                LogOutput(turnContext.Activity.Text, "回答が見つかりませんでした。");
            }
        }
        
        //ログ出力
        private void LogOutput(string question, string answer)
        {
            //日本時間に合わせる
            DateTime date = DateTime.Now.AddHours(9);
            
            //文字コードの設定（utf-16）
            Encoding sjisEnc = Encoding.GetEncoding(1200);
            
            //ログ出力
            StreamWriter writer =  new StreamWriter(@"Log.txt", true, sjisEnc);
            writer.WriteLine(date.ToString("yyyy/MM/dd HH:mm:ss.fff") + 
                             "\n質問：" + question + "\n回答：" + answer + "\n");
            writer.Close();
        }

        private string GetHostname()
        {
            var hostname = _configuration["QnAEndpointHostName"];
            if (!hostname.StartsWith("https://"))
            {
                hostname = string.Concat("https://", hostname);
            }

            if (!hostname.EndsWith("/qnamaker"))
            {
                hostname = string.Concat(hostname, "/qnamaker");
            }

            return hostname;
        }
    }
}

private async Task<DialogTurnResult> DisplayQnAResult(WaterfallStepContext stepContext,
                                                      CancellationToken cancellationToken)
{
    var dialogOptions = GetDialogOptionsValue(stepContext);
    var qnaDialogResponseOptions =
        dialogOptions[QnADialogResponseOptions] as QnADialogResponseOptions;
    var reply = stepContext.Context.Activity.Text;

    if (reply.Equals(qnaDialogResponseOptions.CardNoMatchText,
                     StringComparison.OrdinalIgnoreCase))
    {
        await stepContext.Context.SendActivityAsync(
            qnaDialogResponseOptions.CardNoMatchResponse,
            cancellationToken: cancellationToken).ConfigureAwait(false);
        return await stepContext.EndDialogAsync().ConfigureAwait(false);
    }

    // If previous QnAId is present, replace the dialog
    var previousQnAId = Convert.ToInt32(dialogOptions[PreviousQnAId]);
    if (previousQnAId > 0)
    {
        return await stepContext.ReplaceDialogAsync(QnAMakerDialogName,
                                                    dialogOptions, 
                                                    cancellationToken).ConfigureAwait(false);
    }

    // If response is present then show that response, else default answer.
    if (stepContext.Result is List<QueryResult> response && response.Count > 0)
    {
        await stepContext.Context.SendActivityAsync(response.First().Answer,
              cancellationToken: cancellationToken).ConfigureAwait(false);
        LogOutput(stepContext.Context.Activity.Text, response.First().Answer);
    }
    else
    {
        await stepContext.Context.SendActivityAsync(qnaDialogResponseOptions.NoAnswer,
              cancellationToken: cancellationToken).ConfigureAwait(false);
        LogOutput(stepContext.Context.Activity.Text, qnaDialogResponseOptions.NoAnswer);
    }

    return await stepContext.EndDialogAsync().ConfigureAwait(false);
}