363877

Committed 10 Aug 2023 08:52PM UTC coverage: 79.092% (+0.1%) from 78.979%

Build # 363877

Build Type

Pull #6655

CI-PR build

Committed by

web-flow

Commit Message

Merge 94ad1d11f into fdaed8b69

Pull Request Pull Request #6655: Implementation of Teams batch APIs

Run Details

26094 of 32992 relevant lines covered (79.09%)

0.79 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/libraries/integration/Microsoft.Bot.Builder.Integration.AspNet.Core/BotMessageHandler.cs

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

using System;
using System.IO;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Http;
using Microsoft.Bot.Schema;
using Newtonsoft.Json;

namespace Microsoft.Bot.Builder.Integration.AspNet.Core.Handlers
{
    /// <summary>
    /// A handler to process incoming http requests via using an adapter.
    /// </summary>
    /// <remarks>
    /// BotFrameworkAdapter is still supported but the recommended adapter is `CloudAdapter`.
    /// </remarks>
    public class BotMessageHandler : BotMessageHandlerBase
    {
        /// <summary>
        /// Deserializes the incoming request using a BotMessageHandler, processes it with an <see cref="IAdapterIntegration"/>
        /// and returns an <see cref="InvokeResponse"/>.
        /// </summary>
        /// <param name="request">A <see cref="HttpRequest"/>.</param>
        /// <param name="adapter">An instance of <see cref="IAdapterIntegration"/>.</param>
        /// <param name="botCallbackHandler">An instance of <see cref="BotCallbackHandler"/>.</param>
        /// <param name="cancellationToken">A <see cref="CancellationToken"/>.</param>
        /// <returns>An <see cref="InvokeResponse"/> returned from the adapter.</returns>
        protected override async Task<InvokeResponse> ProcessMessageRequestAsync(HttpRequest request, IAdapterIntegration adapter, BotCallbackHandler botCallbackHandler, CancellationToken cancellationToken)
        {
            Activity activity;

            using (var memoryStream = new MemoryStream())
            {
                await request.Body.CopyToAsync(memoryStream).ConfigureAwait(false);

                // In the case of request buffering being enabled, we could possibly receive a Stream that needs its position reset,
                // but we can't _blindly_ reset in case buffering hasn't been enabled since we'll be working with a non-seekable Stream
                // in that case which will throw a NotSupportedException
                if (request.Body.CanSeek)
                {
                    request.Body.Position = 0;
                }

                memoryStream.Position = 0;

                // Get the request body and deserialize to the Activity object.
                // NOTE: We explicitly leave the stream open here so others can still access it (in case buffering was enabled); ASP.NET runtime will always dispose of it anyway
                using (var bodyReader = new JsonTextReader(new StreamReader(memoryStream, Encoding.UTF8, detectEncodingFromByteOrderMarks: false, bufferSize: 1024, leaveOpen: true)) { MaxDepth = null })
                {
                    activity = BotMessageSerializer.Deserialize<Activity>(bodyReader);
                }
            }

            var invokeResponse = await adapter.ProcessActivityAsync(
                request.Headers["Authorization"],
                activity,
                botCallbackHandler,
                cancellationToken).ConfigureAwait(false);

            return invokeResponse;
        }
    }
}

1	// Copyright (c) Microsoft Corporation. All rights reserved.
2	// Licensed under the MIT License.
3
4	using System;
5	using System.IO;
6	using System.Text;
7	using System.Threading;
8	using System.Threading.Tasks;
9	using Microsoft.AspNetCore.Http;
10	using Microsoft.Bot.Schema;
11	using Newtonsoft.Json;
12
13	namespace Microsoft.Bot.Builder.Integration.AspNet.Core.Handlers
14	{
15	/// <summary>
16	/// A handler to process incoming http requests via using an adapter.
17	/// </summary>
18	/// <remarks>
19	/// BotFrameworkAdapter is still supported but the recommended adapter is `CloudAdapter`.
20	/// </remarks>
21	public class BotMessageHandler : BotMessageHandlerBase
22	{
23	/// <summary>
24	/// Deserializes the incoming request using a BotMessageHandler, processes it with an <see cref="IAdapterIntegration"/>
25	/// and returns an <see cref="InvokeResponse"/>.
26	/// </summary>
27	/// <param name="request">A <see cref="HttpRequest"/>.</param>
28	/// <param name="adapter">An instance of <see cref="IAdapterIntegration"/>.</param>
29	/// <param name="botCallbackHandler">An instance of <see cref="BotCallbackHandler"/>.</param>
30	/// <param name="cancellationToken">A <see cref="CancellationToken"/>.</param>
31	/// <returns>An <see cref="InvokeResponse"/> returned from the adapter.</returns>
32	protected override async Task<InvokeResponse> ProcessMessageRequestAsync(HttpRequest request, IAdapterIntegration adapter, BotCallbackHandler botCallbackHandler, CancellationToken cancellationToken)
33	{
34	Activity activity;
35
36	using (var memoryStream = new MemoryStream())	×
37	{
38	await request.Body.CopyToAsync(memoryStream).ConfigureAwait(false);	×
39
40	// In the case of request buffering being enabled, we could possibly receive a Stream that needs its position reset,
41	// but we can't _blindly_ reset in case buffering hasn't been enabled since we'll be working with a non-seekable Stream
42	// in that case which will throw a NotSupportedException
43	if (request.Body.CanSeek)	×
44	{
45	request.Body.Position = 0;	×
46	}
47
48	memoryStream.Position = 0;	×
49
50	// Get the request body and deserialize to the Activity object.
51	// NOTE: We explicitly leave the stream open here so others can still access it (in case buffering was enabled); ASP.NET runtime will always dispose of it anyway
52	using (var bodyReader = new JsonTextReader(new StreamReader(memoryStream, Encoding.UTF8, detectEncodingFromByteOrderMarks: false, bufferSize: 1024, leaveOpen: true)) { MaxDepth = null })	×
53	{
54	activity = BotMessageSerializer.Deserialize<Activity>(bodyReader);	×
55	}	×
56	}	×
57
58	var invokeResponse = await adapter.ProcessActivityAsync(	×
59	request.Headers["Authorization"],	×
60	activity,	×
61	botCallbackHandler,	×
62	cancellationToken).ConfigureAwait(false);	×
63
64	return invokeResponse;	×
65	}	×
66	}
67	}

microsoft / botbuilder-dotnet / 363877

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous