justinyoo · August 13, 2021 17:34
diff --git a/health-check-function.cs b/health-check-function.cs
 public interface IHealthCheckFunction : IFunction<ILogger>
 {
 }

 public class HealthCheckFunction : FunctionBase<ILogger>, IHealthCheckFunction
 {
    ...
    // Dependency injections here

    public override async Task<TOutput> InvokeAsync<TInput, TOutput>(
        TInput input,
        functionOptionsBase options = null)
    {
        var result = (IActionResult)null;
        var requestUri = $"{this._settings.BaseUri.TrimEnd('/')}/{this._settings.Endpoints.HealthCheck.TrimStart('/')}";
        using (var response = await this._httpClient.GetAsync(requestUri).ConfigureAwaitfalse))
        {
            try
            {
                response.EnsureSuccessStatusCode();
                result = new OkResult();
            }
            catch (Exception ex)
            {
                var error = new ErrorResponse(ex);
                result = new ObjectResult(error) { StatusCode = (int)response.StatusCode };
            }
        }

        return (TOutput)result;
    }
 }
diff --git a/health-check-http-trigger.cs b/health-check-http-trigger.cs
 public class HealthCheckHttpTrigger
 {
    ...
    // Dependency injections here

    [FunctionName(nameof(HealthCheckHttpTrigger.PingAsync))]
    public async Task<IActionResult> PingAsync(
        [HttpTrigger(AuthorizationLevel.Function, "get", Route = "ping")] HttpRequest req,
        ILogger log)
    {
        return result = await this._function
                                  .InvokeAsync<HttpRequest, IActionResult>(req)
                                  .ConfigureAwait(false);
    }
 }
diff --git a/install-mountebank.sh b/install-mountebank.sh
 npm install -g mountebank
diff --git a/integration-test-dotnet-cli.sh b/integration-test-dotnet-cli.sh
 dotnet test [Test_Project_Name].csproj -c Release --filter:"TestCategory=Integration"
diff --git a/integration-test-http-trigger.cs b/integration-test-http-trigger.cs
 [TestClass]
 public class HealthCheckHttpTriggerTests
 {
    private const string CategoryIntegration = "Integration";
    private ServerFixture _fixture;

    [TestInitialize]
    public void Init()
    {
        this._fixture = new LocalhostServerFixture();
    }

    [TestMethod]
    [TestCategory(CategoryIntegration)]
    public async Task Given_Url_When_Invoked_Then_Trigger_Should_Return_Healthy()
    {
        // Arrange
        var uri = this._fixture.GetHealthCheckUrl();
        using (var http = new HttpClient())

        // Act
        using (var res = await http.GetAsync(uri))
        {
        // Assert
            res.StatusCode.Should().Be(HttpStatusCode.OK);
        }
    }

    [TestMethod]
    [TestCategory(CategoryIntegration)]
    public async Task Given_Url_When_Invoked_Then_Trigger_Should_Return_Unhealthy()
    {
        // Arrange
        var uri = this._fixture.GetHealthCheckUrl(HttpStatusCode.InternalServerError);
        using (var http = new HttpClient())

        // Act
        using (var res = await http.GetAsync(uri))
        {
        // Assert
            res.StatusCode.Should().Be(HttpStatusCode.InternalServerError);
        }
    }
 }
diff --git a/mountebank-server-fixture.cs b/mountebank-server-fixture.cs
 public class LocalhostServerFixture
 {
    private readonly MountebankClient _client;

    public MountebankServerFixture()
    {
        this._client = new MountebankClient();
    }

    public override string GetHealthCheckUrl(HttpStatusCode statusCode = HttpStatusCode.OK)
    {
        this._client.DeleteImposter(8080);

        var imposter = this._client
                           .CreateHttpImposter(8080, statusCode.ToString());
        imposter.AddStub()
                .OnPathAndMethodEqual("/api/ping", Method.Get)
                .ReturnsStatus(statusCode);

        this._client.Submit(imposter);

        return "http://localhost:7071/api/ping";
    }
 }
diff --git a/run-mountebank.sh b/run-mountebank.sh
 mb
diff --git a/run-services-1.sh b/run-services-1.sh
 start /b mb --noLogFile
 start /b func host start --csharp
diff --git a/run-services-2.sh b/run-services-2.sh
 # Console #1
 mb --noLogFile

 # Console #2
 func host start --csharp
diff --git a/unit-test-dotnet-cli.sh b/unit-test-dotnet-cli.sh
 dotnet test [Test_Project_Name].csproj -c Release
diff --git a/unit-test-function.cs b/unit-test-function.cs
 [TestMethod]
 public async Task Given_Parameters_When_Invoked_Then_InvokeAsync_Should_Return_Result()
 {
    // Arrange
    var result = new OkResult();

    var function = new Mock<IHealthCheckFunction>();
    function.Setup(p => p.InvokeAsync<HttpRequest, IActionResult>(It.IsAny<HttpRequest>(), It.IsAny<FunctionOptionsBase>()))
            .ReturnsAsync(result);

    var trigger = new HealthCheckHttpTrigger(function.Object);

    var req = new Mock<HttpRequest>();
    var log = new Mock<ILogger>();

    // Action
    var response = await trigger.PingAsync(req.Object, log.Object).ConfigureAwait(false);

    // Assert
    response
        .Should().BeOfType<OkResult>()
        .And.Subject.As<OkResult>()
            .StatusCode.Should().Be((int)HttpStatusCode.OK);
 }
diff --git a/unit-test-http-trigger.cs b/unit-test-http-trigger.cs
 [TestMethod]
 public async Task Given_Parameters_When_Invoked_Then_InvokeAsync_Should_Return_Result()
 {
    // Arrange
    var result = new OkResult();

    var function = new Mock<IHealthCheckFunction>();
    function.Setup(p => p.InvokeAsync<HttpRequest, IActionResult>(It.IsAny<HttpRequest>(), It.IsAny<FunctionOptionsBase>()))
            .ReturnsAsync(result);

    var trigger = new HealthCheckHttpTrigger(function.Object);

    var req = new Mock<HttpRequest>();
    var log = new Mock<ILogger>();

    // Action
    var response = await trigger.PingAsync(req.Object, log.Object).ConfigureAwait(false);

    // Assert
    response
        .Should().BeOfType<OkResult>()
        .And.Subject.As<OkResult>()
            .StatusCode.Should().Be((int)HttpStatusCode.OK);
 }
	public interface IHealthCheckFunction : IFunction<ILogger>
	{
	}

	public class HealthCheckFunction : FunctionBase<ILogger>, IHealthCheckFunction
	{
	...
	// Dependency injections here

	public override async Task<TOutput> InvokeAsync<TInput, TOutput>(
	TInput input,
	functionOptionsBase options = null)
	{
	var result = (IActionResult)null;
	var requestUri = $"{this._settings.BaseUri.TrimEnd('/')}/{this._settings.Endpoints.HealthCheck.TrimStart('/')}";
	using (var response = await this._httpClient.GetAsync(requestUri).ConfigureAwaitfalse))
	{
	try
	{
	response.EnsureSuccessStatusCode();
	result = new OkResult();
	}
	catch (Exception ex)
	{
	var error = new ErrorResponse(ex);
	result = new ObjectResult(error) { StatusCode = (int)response.StatusCode };
	}
	}

	return (TOutput)result;
	}
	}
	public class HealthCheckHttpTrigger
	{
	...
	// Dependency injections here

	[FunctionName(nameof(HealthCheckHttpTrigger.PingAsync))]
	public async Task<IActionResult> PingAsync(
	[HttpTrigger(AuthorizationLevel.Function, "get", Route = "ping")] HttpRequest req,
	ILogger log)
	{
	return result = await this._function
	.InvokeAsync<HttpRequest, IActionResult>(req)
	.ConfigureAwait(false);
	}
	}
	[TestClass]
	public class HealthCheckHttpTriggerTests
	{
	private const string CategoryIntegration = "Integration";
	private ServerFixture _fixture;

	[TestInitialize]
	public void Init()
	{
	this._fixture = new LocalhostServerFixture();
	}

	[TestMethod]
	[TestCategory(CategoryIntegration)]
	public async Task Given_Url_When_Invoked_Then_Trigger_Should_Return_Healthy()
	{
	// Arrange
	var uri = this._fixture.GetHealthCheckUrl();
	using (var http = new HttpClient())

	// Act
	using (var res = await http.GetAsync(uri))
	{
	// Assert
	res.StatusCode.Should().Be(HttpStatusCode.OK);
	}
	}

	[TestMethod]
	[TestCategory(CategoryIntegration)]
	public async Task Given_Url_When_Invoked_Then_Trigger_Should_Return_Unhealthy()
	{
	// Arrange
	var uri = this._fixture.GetHealthCheckUrl(HttpStatusCode.InternalServerError);
	using (var http = new HttpClient())

	// Act
	using (var res = await http.GetAsync(uri))
	{
	// Assert
	res.StatusCode.Should().Be(HttpStatusCode.InternalServerError);
	}
	}
	}
	public class LocalhostServerFixture
	{
	private readonly MountebankClient _client;

	public MountebankServerFixture()
	{
	this._client = new MountebankClient();
	}

	public override string GetHealthCheckUrl(HttpStatusCode statusCode = HttpStatusCode.OK)
	{
	this._client.DeleteImposter(8080);

	var imposter = this._client
	.CreateHttpImposter(8080, statusCode.ToString());
	imposter.AddStub()
	.OnPathAndMethodEqual("/api/ping", Method.Get)
	.ReturnsStatus(statusCode);

	this._client.Submit(imposter);

	return "http://localhost:7071/api/ping";
	}
	}
	# Console #1
	mb --noLogFile

	# Console #2
	func host start --csharp
	[TestMethod]
	public async Task Given_Parameters_When_Invoked_Then_InvokeAsync_Should_Return_Result()
	{
	// Arrange
	var result = new OkResult();

	var function = new Mock<IHealthCheckFunction>();
	function.Setup(p => p.InvokeAsync<HttpRequest, IActionResult>(It.IsAny<HttpRequest>(), It.IsAny<FunctionOptionsBase>()))
	.ReturnsAsync(result);

	var trigger = new HealthCheckHttpTrigger(function.Object);

	var req = new Mock<HttpRequest>();
	var log = new Mock<ILogger>();

	// Action
	var response = await trigger.PingAsync(req.Object, log.Object).ConfigureAwait(false);

	// Assert
	response
	.Should().BeOfType<OkResult>()
	.And.Subject.As<OkResult>()
	.StatusCode.Should().Be((int)HttpStatusCode.OK);
	}