ProgressiveResponseTests.cs

using System;
using System.Net;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;
using Alexa.NET.Response;
using Alexa.NET.Response.Directive;
using Xunit;

namespace Alexa.NET.Tests
{
    public class ProgressiveResponseTests
    {
        [Fact]
        public void VoicePlayerCreatesCorrectJson()
        {
            var directive = new VoicePlayerSpeakDirective("This text is spoken while your skill processes the full response.");
            Assert.True(Utility.CompareJson(directive, "VoicePlayerSpeakDirective.json"));
        }

        [Fact]
        public void ProgressiveResponseRequestCreatesCorrectJson()
        {
            var header = new ProgressiveResponseHeader("amzn1.echo-api.request.xxxxxxx");
            var directive = new VoicePlayerSpeakDirective("This text is spoken while your skill processes the full response.");
            var request = new ProgressiveResponseRequest(header, directive);
            Assert.True(Utility.CompareJson(request, "ProgressiveResponseRequest.json"));
        }

        [Fact]
        public async Task ResponseWithNoDetailReturnsNull()
        {
            var request = new ProgressiveResponse();
            var result = await request.Send(null);
            Assert.Null(result);
        }

        [Fact]
        public void ResponseWithNoDetailReturnsCanSendFalse()
        {
            var request = new ProgressiveResponse();
            var result = request.CanSend();
            Assert.False(result);
        }

        [Fact]
        public async Task ResponseWithNoHeaderReturnsNull()
        {
            var request = new ProgressiveResponse {Client = new HttpClient()};
            var result = await request.Send(new VoicePlayerSpeakDirective("test"));
            Assert.Null(result);
        }

        [Fact]
        public async Task ResponseWithNoClientReturnsNull()
        {
            var request = new ProgressiveResponse { Header = new ProgressiveResponseHeader("test") };
            var result = await request.Send(new VoicePlayerSpeakDirective("test"));
            Assert.Null(result);
        }

        [Fact]
        public async Task ResponseWithNullDirectiveReturnsNull()
        {
            var request = new ProgressiveResponse { Header = new ProgressiveResponseHeader("test"),Client = new HttpClient() };
            var result = await request.Send(null);
            Assert.Null(result);
        }

        [Fact]
        public async Task ProgressiveResponseCallsBaseUrl()
        {
            var passed = false;

            var response = CreateProgressiveResponse(req =>
            {
                passed = req.RequestUri.Host == "localhost";
                return new HttpResponseMessage(HttpStatusCode.NoContent);
            });

            var result = await response.SendSpeech("hello");

            Assert.True(passed);
            Assert.NotNull(result);
        }

        [Fact]
        public async Task ProgressiveResponseCallsDirectiveApi()
        {
            var passed = false;

            var response = CreateProgressiveResponse(req =>
            {
                passed = req.RequestUri.AbsolutePath == "/v1/directives";
                return new HttpResponseMessage(HttpStatusCode.NoContent);
            });

            await response.SendSpeech("hello");

            Assert.True(passed);
        }

        [Fact]
        public async Task ProgressiveResponseSetsAuthorizationHandler()
        {
            var passed = false;

            var response = CreateProgressiveResponse(req =>
            {
                passed = req.Headers.Authorization.Scheme == "Bearer";
                passed = req.Headers.Authorization.Parameter == "authToken";
                return new HttpResponseMessage(HttpStatusCode.NoContent);
            });

            await response.SendSpeech("hello");

            Assert.True(passed);
        }

        private ProgressiveResponse CreateProgressiveResponse(Func<HttpRequestMessage, HttpResponseMessage> handlerAction)
        {
            var handler = new ActionMessageHandler(handlerAction);
            var client =  new HttpClient(handler);
            return new ProgressiveResponse("xxx", "authToken", "http://localhost", client);
        }
    }

    public class ActionMessageHandler:HttpMessageHandler
    {
        private Func<HttpRequestMessage,HttpResponseMessage> Action { get; }

        public ActionMessageHandler(Func<HttpRequestMessage,HttpResponseMessage> action)
        {
            Action = action;
        }

        protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
        {
            return Task.FromResult(Action(request));
        }
    }
}