Added sample with composite pattern

Author: dandrejvv

Modules/CompositePublishTest/CompositePublishTest/.gitignore

@@ -0,0 +1,147 @@
+using System;
+using System.Collections.Generic;
+using System.Diagnostics.CodeAnalysis;
+using System.IO;
+using System.Threading;
+using System.Threading.Tasks;
+using Intent.RoslynWeaver.Attributes;
+using Microsoft.AspNetCore.Http;
+
+[assembly: DefaultIntentManaged(Mode.Fully)]
+[assembly: IntentTemplate("Intent.AzureFunctions.AzureFunctionClassHelper", Version = "1.0")]
+
+namespace CompositePublishTest.Api
+{
+    static class AzureFunctionHelper
+    {
+        private static readonly System.Text.Json.JsonSerializerOptions SerializationSettings = new() { PropertyNameCaseInsensitive = true };
+
+        public static async Task<T> DeserializeJsonContentAsync<T>(Stream jsonContentStream, CancellationToken cancellationToken)
+        {
+            return await System.Text.Json.JsonSerializer.DeserializeAsync<T>(jsonContentStream, SerializationSettings, cancellationToken) ?? throw new FormatException("Unable to deserialize JSON content.");
+        }
+
+        public static T GetQueryParam<T>(string paramName, IQueryCollection query, ParseDelegate<T> parse)
+            where T : struct
+        {
+            var strVal = query[paramName];
+            if (string.IsNullOrEmpty(strVal) || !parse(strVal, out T parsed))
+            {
+                throw new FormatException($"Parameter '{paramName}' could not be parsed as a {typeof(T).Name}.");
+            }
+
+            return parsed;
+        }
+
+        public static T? GetQueryParamNullable<T>(string paramName, IQueryCollection query, ParseDelegate<T> parse)
+            where T : struct
+        {
+            var strVal = query[paramName];
+            if (string.IsNullOrEmpty(strVal))
+            {
+                return null;
+            }
+
+            if (!parse(strVal, out T parsed))
+            {
+                throw new FormatException($"Parameter '{paramName}' could not be parsed as a {typeof(T).Name}.");
+            }
+
+            return parsed;
+        }
+
+        public static IEnumerable<T> GetQueryParamCollection<T>(string paramName, IQueryCollection query, ParseDelegate<T> parse)
+            where T : struct
+        {
+            var result = new List<T>();
+            var strVal = query[paramName];
+            var values = strVal.ToString().Split(",");
+            foreach (var v in values)
+            {
+                if (string.IsNullOrEmpty(v) || !parse(v, out T parsed))
+                {
+                    throw new FormatException($"Parameter '{paramName}' could not be parsed as a {typeof(T).Name}.");
+                }
+                result.Add(parsed);
+            }
+
+            return result;
+        }
+
+        public static T GetHeadersParam<T>(string paramName, IHeaderDictionary headers, ParseDelegate<T> parse)
+            where T : struct
+        {
+            var strVal = headers[paramName];
+            if (string.IsNullOrEmpty(strVal) || !parse(strVal, out T parsed))
+            {
+                throw new FormatException($"Parameter '{paramName}' could not be parsed as a {typeof(T).Name}.");
+            }
+
+            return parsed;
+        }
+
+        public static T? GetHeadersParamNullable<T>(string paramName, IHeaderDictionary headers, ParseDelegate<T> parse)
+            where T : struct
+        {
+            var strVal = headers[paramName];
+            if (string.IsNullOrEmpty(strVal))
+            {
+                return null;
+            }
+
+            if (!parse(strVal, out T parsed))
+            {
+                throw new FormatException($"Parameter '{paramName}' could not be parsed as a {typeof(T).Name}.");
+            }
+
+            return parsed;
+        }
+
+        public static IEnumerable<T> GetHeadersParamCollection<T>(string paramName, IHeaderDictionary headers, ParseDelegate<T> parse)
+            where T : struct
+        {
+            var result = new List<T>();
+            var strVal = headers[paramName];
+            var values = strVal.ToString().Split(",");
+            foreach (var v in values)
+            {
+                if (string.IsNullOrEmpty(v) || !parse(v, out T parsed))
+                {
+                    throw new FormatException($"Parameter '{paramName}' could not be parsed as a {typeof(T).Name}.");
+                }
+                result.Add(parsed);
+            }
+
+            return result;
+        }
+
+        public static TEnum GetEnumParam<TEnum>(string paramName, string enumString)
+            where TEnum : struct
+        {
+            if (!Enum.TryParse<TEnum>(enumString, true, out var enumValue))
+            {
+                throw new FormatException($"Parameter {paramName} has value of {enumString} which is not a valid literal value for Enum {typeof(TEnum).Name}");
+            }
+
+            return enumValue;
+        }
+
+        public static TEnum? GetEnumParamNullable<TEnum>(string paramName, string? enumString)
+            where TEnum : struct
+        {
+            if (enumString is null)
+            {
+                return null;
+            }
+
+            if (!Enum.TryParse<TEnum>(enumString, true, out var enumValue))
+            {
+                throw new FormatException($"Parameter {paramName} has value of {enumString} which is not a valid literal value for Enum {typeof(TEnum).Name}");
+            }
+
+            return enumValue;
+        }
+
+        public delegate bool ParseDelegate<T>(string strVal, out T parsed);
+    }
+}

Modules/CompositePublishTest/CompositePublishTest/CompositePublishTest.Api/AzureFunctionHelper.cs

@@ -0,0 +1,68 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Net;
+using System.Text.Json;
+using System.Threading;
+using System.Threading.Tasks;
+using CompositePublishTest.Application.Clients.CreateClient;
+using CompositePublishTest.Domain.Common.Exceptions;
+using CompositePublishTest.Domain.Common.Interfaces;
+using FluentValidation;
+using Intent.RoslynWeaver.Attributes;
+using MediatR;
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Azure.Functions.Worker;
+using Microsoft.Azure.WebJobs.Extensions.OpenApi.Core.Attributes;
+using Microsoft.OpenApi.Models;
+
+[assembly: DefaultIntentManaged(Mode.Fully)]
+[assembly: IntentTemplate("Intent.AzureFunctions.AzureFunctionClass", Version = "2.0")]
+
+namespace CompositePublishTest.Api.Clients
+{
+    public class CreateClient
+    {
+        private readonly IMediator _mediator;
+
+        public CreateClient(IMediator mediator)
+        {
+            _mediator = mediator ?? throw new ArgumentNullException(nameof(mediator));
+        }
+
+        [Function("CreateClient")]
+        [OpenApiOperation("CreateClientCommand", tags: new[] { "Clients" }, Description = "Create client command")]
+        [OpenApiRequestBody(contentType: "application/json", bodyType: typeof(CreateClientCommand))]
+        [OpenApiResponseWithBody(statusCode: HttpStatusCode.Created, contentType: "application/json", bodyType: typeof(Guid))]
+        [OpenApiResponseWithBody(statusCode: HttpStatusCode.BadRequest, contentType: "application/json", bodyType: typeof(object))]
+        [OpenApiResponseWithBody(statusCode: HttpStatusCode.NotFound, contentType: "application/json", bodyType: typeof(object))]
+        public async Task<IActionResult> Run(
+            [HttpTrigger(AuthorizationLevel.Function, "post", Route = "clients")] HttpRequest req,
+            CancellationToken cancellationToken)
+        {
+            try
+            {
+                var command = await AzureFunctionHelper.DeserializeJsonContentAsync<CreateClientCommand>(req.Body, cancellationToken);
+                var result = await _mediator.Send(command, cancellationToken);
+                return new CreatedResult(string.Empty, result);
+            }
+            catch (ValidationException exception)
+            {
+                return new BadRequestObjectResult(exception.Errors);
+            }
+            catch (NotFoundException exception)
+            {
+                return new NotFoundObjectResult(new { exception.Message });
+            }
+            catch (JsonException exception)
+            {
+                return new BadRequestObjectResult(new { exception.Message });
+            }
+            catch (FormatException exception)
+            {
+                return new BadRequestObjectResult(new { exception.Message });
+            }
+        }
+    }
+}

Modules/CompositePublishTest/CompositePublishTest/CompositePublishTest.Api/Clients/CreateClient.cs

@@ -0,0 +1,63 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Net;
+using System.Threading;
+using System.Threading.Tasks;
+using CompositePublishTest.Application.Clients.DeleteClient;
+using CompositePublishTest.Domain.Common.Exceptions;
+using CompositePublishTest.Domain.Common.Interfaces;
+using FluentValidation;
+using Intent.RoslynWeaver.Attributes;
+using MediatR;
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Azure.Functions.Worker;
+using Microsoft.Azure.WebJobs.Extensions.OpenApi.Core.Attributes;
+using Microsoft.OpenApi.Models;
+
+[assembly: DefaultIntentManaged(Mode.Fully)]
+[assembly: IntentTemplate("Intent.AzureFunctions.AzureFunctionClass", Version = "2.0")]
+
+namespace CompositePublishTest.Api.Clients
+{
+    public class DeleteClient
+    {
+        private readonly IMediator _mediator;
+
+        public DeleteClient(IMediator mediator)
+        {
+            _mediator = mediator ?? throw new ArgumentNullException(nameof(mediator));
+        }
+
+        [Function("DeleteClient")]
+        [OpenApiOperation("DeleteClientCommand", tags: new[] { "Clients" }, Description = "Delete client command")]
+        [OpenApiParameter(name: "id", In = ParameterLocation.Path, Required = true, Type = typeof(Guid))]
+        [OpenApiResponseWithoutBody(statusCode: HttpStatusCode.OK)]
+        [OpenApiResponseWithBody(statusCode: HttpStatusCode.BadRequest, contentType: "application/json", bodyType: typeof(object))]
+        [OpenApiResponseWithBody(statusCode: HttpStatusCode.NotFound, contentType: "application/json", bodyType: typeof(object))]
+        public async Task<IActionResult> Run(
+            [HttpTrigger(AuthorizationLevel.Function, "delete", Route = "clients/{id}")] HttpRequest req,
+            Guid id,
+            CancellationToken cancellationToken)
+        {
+            try
+            {
+                await _mediator.Send(new DeleteClientCommand(id: id), cancellationToken);
+                return new OkResult();
+            }
+            catch (ValidationException exception)
+            {
+                return new BadRequestObjectResult(exception.Errors);
+            }
+            catch (NotFoundException exception)
+            {
+                return new NotFoundObjectResult(new { exception.Message });
+            }
+            catch (FormatException exception)
+            {
+                return new BadRequestObjectResult(new { exception.Message });
+            }
+        }
+    }
+}

Modules/CompositePublishTest/CompositePublishTest/CompositePublishTest.Api/Clients/DeleteClient.cs

@@ -0,0 +1,64 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Net;
+using System.Threading;
+using System.Threading.Tasks;
+using CompositePublishTest.Application.Clients;
+using CompositePublishTest.Application.Clients.GetClientById;
+using CompositePublishTest.Domain.Common.Exceptions;
+using CompositePublishTest.Domain.Common.Interfaces;
+using FluentValidation;
+using Intent.RoslynWeaver.Attributes;
+using MediatR;
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Azure.Functions.Worker;
+using Microsoft.Azure.WebJobs.Extensions.OpenApi.Core.Attributes;
+using Microsoft.OpenApi.Models;
+
+[assembly: DefaultIntentManaged(Mode.Fully)]
+[assembly: IntentTemplate("Intent.AzureFunctions.AzureFunctionClass", Version = "2.0")]
+
+namespace CompositePublishTest.Api.Clients
+{
+    public class GetClientById
+    {
+        private readonly IMediator _mediator;
+
+        public GetClientById(IMediator mediator)
+        {
+            _mediator = mediator ?? throw new ArgumentNullException(nameof(mediator));
+        }
+
+        [Function("GetClientById")]
+        [OpenApiOperation("GetClientByIdQuery", tags: new[] { "Clients" }, Description = "Get client by id query")]
+        [OpenApiParameter(name: "id", In = ParameterLocation.Path, Required = true, Type = typeof(Guid))]
+        [OpenApiResponseWithBody(statusCode: HttpStatusCode.OK, contentType: "application/json", bodyType: typeof(ClientDto))]
+        [OpenApiResponseWithBody(statusCode: HttpStatusCode.BadRequest, contentType: "application/json", bodyType: typeof(object))]
+        [OpenApiResponseWithBody(statusCode: HttpStatusCode.NotFound, contentType: "application/json", bodyType: typeof(object))]
+        public async Task<IActionResult> Run(
+            [HttpTrigger(AuthorizationLevel.Function, "get", Route = "clients/{id}")] HttpRequest req,
+            Guid id,
+            CancellationToken cancellationToken)
+        {
+            try
+            {
+                var result = await _mediator.Send(new GetClientByIdQuery(id: id), cancellationToken);
+                return result != null ? new OkObjectResult(result) : new NotFoundResult();
+            }
+            catch (ValidationException exception)
+            {
+                return new BadRequestObjectResult(exception.Errors);
+            }
+            catch (NotFoundException exception)
+            {
+                return new NotFoundObjectResult(new { exception.Message });
+            }
+            catch (FormatException exception)
+            {
+                return new BadRequestObjectResult(new { exception.Message });
+            }
+        }
+    }
+}