Add scheduled start time E2E Test

Author: andystaples

test/e2e/Apps/BasicDotNetIsolated/HelloCities.cs

@@ -54,5 +54,27 @@ public static async Task<HttpResponseData> HttpStart(
             // See https://learn.microsoft.com/azure/azure-functions/durable/durable-functions-http-api#start-orchestration
             return await client.CreateCheckStatusResponseAsync(req, instanceId);
         }
+
+        [Function("HelloCities_HttpStart_Scheduled")]
+        public static async Task<HttpResponseData> HttpStartScheduled(
+            [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequestData req,
+            [DurableClient] DurableTaskClient client,
+            FunctionContext executionContext,
+            DateTime ScheduledStartTime)
+        {
+            ILogger logger = executionContext.GetLogger("HelloCities_HttpStart");
+
+            var startOptions = new StartOrchestrationOptions(StartAt: ScheduledStartTime);
+
+            // Function input comes from the request content.
+            string instanceId = await client.ScheduleNewOrchestrationInstanceAsync(
+                nameof(HelloCities), startOptions);
+
+            logger.LogInformation("Started orchestration with ID = '{instanceId}'.", instanceId);
+
+            // Returns an HTTP 202 response with an instance management payload.
+            // See https://learn.microsoft.com/azure/azure-functions/durable/durable-functions-http-api#start-orchestration
+            return await client.CreateCheckStatusResponseAsync(req, instanceId);
+        }
     }
 }

test/e2e/Tests/Helpers/DurableHelpers.cs

@@ -0,0 +1,39 @@
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using System.Text.Json.Nodes;
+
+namespace Microsoft.Azure.Durable.Tests.DotnetIsolatedE2E;
+
+internal class DurableHelpers
+{
+    internal static string ParseStatusQueryGetUri(HttpResponseMessage invocationStartResponse)
+    {
+        string? responseString = invocationStartResponse.Content?.ReadAsStringAsync().Result;
+        if (string.IsNullOrEmpty(responseString))
+        {
+            return string.Empty;
+        }
+        JsonNode? responseJsonNode = JsonNode.Parse(responseString);
+        if (responseJsonNode == null)
+        {
+            return string.Empty;
+        }
+
+        string? statusQueryGetUri = responseJsonNode["StatusQueryGetUri"]?.GetValue<string>();
+        return statusQueryGetUri ?? string.Empty;
+    }
+    internal static string GetRuntimeStatus(string statusQueryGetUri)
+    {
+        HttpClient client = new HttpClient();
+        var statusQueryResponse = client.GetAsync(statusQueryGetUri);
+
+        string? statusQueryResponseString = statusQueryResponse.Result.Content.ReadAsStringAsync().Result;
+        JsonNode? statusQueryJsonNode = JsonNode.Parse(statusQueryResponseString);
+        if (statusQueryJsonNode == null)
+        {
+            return string.Empty;
+        }
+        return statusQueryJsonNode["runtimeStatus"]?.GetValue<string>() ?? string.Empty;
+    }
+}

test/e2e/Tests/Tests/HelloCitiesTest.cs

@@ -7,7 +7,7 @@
 
 namespace Microsoft.Azure.Durable.Tests.DotnetIsolatedE2E;
 
-[Collection(Constants.FunctionAppCollectionName )]
+[Collection(Constants.FunctionAppCollectionName)]
 public class HttpEndToEndTests
 {
     private readonly FunctionAppFixture _fixture;
@@ -19,17 +19,34 @@ public HttpEndToEndTests(FunctionAppFixture fixture, ITestOutputHelper testOutpu
     }
 
     [Theory]
-    [InlineData("HelloCities_HttpStart", "", HttpStatusCode.Accepted, "")]
-    public async Task HttpTriggerTests(string functionName, string queryString, HttpStatusCode expectedStatusCode, string expectedMessage)
+    [InlineData("HelloCities_HttpStart", HttpStatusCode.Accepted)]
+    public async Task HttpTriggerTests(string functionName, HttpStatusCode expectedStatusCode)
     {
-        using HttpResponseMessage response = await HttpHelpers.InvokeHttpTrigger(functionName, queryString);
+        using HttpResponseMessage response = await HttpHelpers.InvokeHttpTrigger(functionName, "");
         string actualMessage = await response.Content.ReadAsStringAsync();
 
         Assert.Equal(expectedStatusCode, response.StatusCode);
+        Assert.False(string.IsNullOrEmpty(actualMessage));
+    }
+
+    [Theory]
+    [InlineData("HelloCities_HttpStart_Scheduled", HttpStatusCode.Accepted)]
+    public async Task ScheduledStartTests(string functionName, HttpStatusCode expectedStatusCode)
+    {
+        var scheduledStartDate = DateTime.Now + TimeSpan.FromSeconds(10);
+
+        using HttpResponseMessage response = await HttpHelpers.InvokeHttpTrigger(functionName, $"?ScheduledStartTime={scheduledStartDate.ToString("o")}");
+        string actualMessage = await response.Content.ReadAsStringAsync();
+
+        string statusQueryGetUri = DurableHelpers.ParseStatusQueryGetUri(response);
+
+        Assert.Equal(expectedStatusCode, response.StatusCode);
+
+        string startRuntimeStatus = DurableHelpers.GetRuntimeStatus(statusQueryGetUri);
+        Assert.Equal("Pending", startRuntimeStatus);
+        Thread.Sleep(11000);
 
-        if (!string.IsNullOrEmpty(expectedMessage))
-        {
-            Assert.False(string.IsNullOrEmpty(actualMessage));
-        }
+        string endRuntimeStatus = DurableHelpers.GetRuntimeStatus(statusQueryGetUri);
+        Assert.Equal("Completed", endRuntimeStatus);
     }
 }