bump to 1.0.1

- Curl-Log wird jetzt auch bei `GetAsync` und `GetListAsAsyncEnumerable` ausgeführt.
- Bisher wurde Logging nur bei `PostAsync` durchgeführt.
- Hilft beim Debuggen von HTTP-Requests und beim Nachvollziehen von API-Aufrufen.

src/Leanetec.EConnect.Client/Alive/GetExtensions.cs

@@ -11,7 +11,7 @@ public static class GetExtensions
     /// <param name="role">Optional role of the logged-in user.</param>
     /// <param name="apiVersion">Optional API version.</param>
     /// <returns>A <see cref="Task{Boolean}"/> representing whether the application is alive.</returns>
-    public static Task<bool> IsAliveAsync(this IMediator mediator, Role? role = null, int? apiVersion = null) =>
+    public static Task<bool> IsAliveAsync(this IMediator mediator, Role? role = null, int apiVersion = 1) =>
         mediator.Send(new GetRequest(role)
         {
             ApiVersion = apiVersion
@@ -24,7 +24,7 @@ public static class GetExtensions
     /// <param name="role">Optional role of the logged-in user.</param>
     /// <param name="apiVersion">Optional API version.</param>
     /// <returns>True if the application is alive; otherwise, false.</returns>
-    public static bool IsAlive(this IMediator mediator, Role? role = null, int? apiVersion = null) =>
+    public static bool IsAlive(this IMediator mediator, Role? role = null, int apiVersion = 1) =>
         mediator.Send(new GetRequest(role)
         {
             ApiVersion = apiVersion

src/Leanetec.EConnect.Client/Articles/GetExtensions.cs

@@ -19,7 +19,7 @@ public static class GetExtensions
     /// <returns>
     /// A task that represents the asynchronous operation. The task result contains the matching <see cref="Article"/>, or <c>null</c> if not found.
     /// </returns>
-    public static async Task<Article?> GetArticleByIdAsync(this IMediator mediator, int id, int? apiVersion = null)
+    public static async Task<Article?> GetArticleByIdAsync(this IMediator mediator, int id, int apiVersion = 1)
     {
         var articles = await mediator.Send(new GetRequest(id) { ApiVersion = apiVersion });
         return articles.FirstOrDefault();
@@ -34,7 +34,7 @@ public static class GetExtensions
     /// <returns>
     /// The matching <see cref="Article"/>, or <c>null</c> if not found.
     /// </returns>
-    public static Article? GetArticleById(this IMediator mediator, int id, int? apiVersion = null)
+    public static Article? GetArticleById(this IMediator mediator, int id, int apiVersion = 1)
     {
         var articles = mediator.Send(new GetRequest(id) { ApiVersion = apiVersion }).GetAwaiter().GetResult();
         return articles.FirstOrDefault();
@@ -52,7 +52,7 @@ public static class GetExtensions
     /// <returns>
     /// A task that represents the asynchronous operation. The task result contains a collection of all available <see cref="Article"/> entities.
     /// </returns>
-    public static Task<IEnumerable<Article>> GetAllArticlesAsync(this IMediator mediator, int? apiVersion = null) => mediator.Send(new GetRequest()
+    public static Task<IEnumerable<Article>> GetAllArticlesAsync(this IMediator mediator, int apiVersion = 1) => mediator.Send(new GetRequest()
     {
         ApiVersion = apiVersion
     });
@@ -65,7 +65,7 @@ public static class GetExtensions
     /// <returns>
     /// A collection of all available <see cref="Article"/> entities.
     /// </returns>
-    public static IEnumerable<Article> GetAllArticles(this IMediator mediator, int? apiVersion = null) => mediator.Send(new GetRequest()
+    public static IEnumerable<Article> GetAllArticles(this IMediator mediator, int apiVersion = 1) => mediator.Send(new GetRequest()
     {
         ApiVersion = apiVersion
     }).GetAwaiter().GetResult();

src/Leanetec.EConnect.Client/Articles/PostExtensions.cs

@@ -15,7 +15,7 @@ public static class PostExtensions
     /// <param name="article">The <see cref="Article"/> entity to be created.</param>
     /// <param name="apiVersion">Optional API version to include in the request.</param>
     /// <returns>A <see cref="Task"/> representing the asynchronous operation.</returns>
-    public static Task CreateArticleAsync(this IMediator mediator, Article article, int? apiVersion = null) => mediator.Send(new PostRequest(article)
+    public static Task CreateArticleAsync(this IMediator mediator, Article article, int apiVersion = 1) => mediator.Send(new PostRequest(article)
     {
         ApiVersion = apiVersion
     });
@@ -26,7 +26,7 @@ public static class PostExtensions
     /// <param name="mediator">The <see cref="IMediator"/> instance used to send the request.</param>
     /// <param name="article">The <see cref="Article"/> entity to be created.</param>
     /// <param name="apiVersion">Optional API version to include in the request.</param>
-    public static void CreateArticle(this IMediator mediator, Article article, int? apiVersion = null) => mediator.Send(new PostRequest(article)
+    public static void CreateArticle(this IMediator mediator, Article article, int apiVersion = 1) => mediator.Send(new PostRequest(article)
     {
         ApiVersion = apiVersion
     }).GetAwaiter().GetResult();

src/Leanetec.EConnect.Client/Articles/PutExtensions.cs

@@ -15,7 +15,7 @@ public static class PutExtensions
     /// <param name="article">The <see cref="Article"/> entity to be updated.</param>
     /// <param name="apiVersion">Optional API version to include in the request.</param>
     /// <returns>A <see cref="Task"/> representing the asynchronous operation.</returns>
-    public static Task UpdateArticleAsync(this IMediator mediator, Article article, int? apiVersion = null) => mediator.Send(new PutRequest(article)
+    public static Task UpdateArticleAsync(this IMediator mediator, Article article, int apiVersion = 1) => mediator.Send(new PutRequest(article)
     {
         ApiVersion = apiVersion
     });
@@ -26,7 +26,7 @@ public static class PutExtensions
     /// <param name="mediator">The <see cref="IMediator"/> instance used to send the request.</param>
     /// <param name="article">The <see cref="Article"/> entity to be updated.</param>
     /// <param name="apiVersion">Optional API version to include in the request.</param>
-    public static void UpdateArticle(this IMediator mediator, Article article, int? apiVersion = null) => mediator.Send(new PutRequest(article)
+    public static void UpdateArticle(this IMediator mediator, Article article, int apiVersion = 1) => mediator.Send(new PutRequest(article)
     {
         ApiVersion = apiVersion
     }).GetAwaiter().GetResult();

src/Leanetec.EConnect.Client/Client.cs

@@ -1,49 +0,0 @@
-using MediatR;
-using Microsoft.Extensions.DependencyInjection;
-
-namespace Leanetec.EConnect.Client;
-
-/// <summary>
-/// Provides a lazily initialized <see cref="IServiceProvider"/> for accessing the EConnect client services,
-/// including an <see cref="IMediator"/> instance for sending and publishing messages.
-/// </summary>
-public static class Client
-{
-    private static Action<ClientOptions>? _options = null;
-
-    /// <summary>
-    /// Gets or sets the configuration options for the EConnect client.
-    /// Can only be set once; subsequent attempts to set will result in an exception.
-    /// </summary>
-    public static Action<ClientOptions> Options
-    {
-        get => _options ?? throw new InvalidOperationException("EConnect Client options have not been configured. Please set the 'Client.Options' property before accessing client services.");
-        set
-        {
-            if (_options is null)
-                _options = value;
-            else
-                throw new InvalidOperationException("EConnect Client options have already been configured. Reassignment is not allowed.");
-        }
-    }
-
-    /// <summary>
-    /// Lazily initializes the <see cref="IServiceProvider"/> that registers and builds the EConnect client services.
-    /// </summary>
-    private static readonly Lazy<IServiceProvider> _serviceProvider = new(() =>
-    {
-        var services = new ServiceCollection();
-        services.AddEConnectClient(Options);
-        return services.BuildServiceProvider();
-    });
-
-    /// <summary>
-    /// Gets the initialized <see cref="IServiceProvider"/> that provides access to registered EConnect client services.
-    /// </summary>
-    public static IServiceProvider Provider => _serviceProvider.Value;
-
-    /// <summary>
-    /// Gets the <see cref="IMediator"/> instance used for sending commands, queries, and publishing events within the EConnect client.
-    /// </summary>
-    public static IMediator Mediator => Provider.GetRequiredService<IMediator>();
-}

src/Leanetec.EConnect.Client/ClientOptions.cs

@@ -1,10 +0,0 @@
-namespace Leanetec.EConnect.Client;
-
-public class ClientOptions
-{
-    public string? BaseAddress { get; set; }
-
-    public string? ApiKey { get; set; }
-
-    public TimeSpan? Timeout { get; set; }
-}

src/Leanetec.EConnect.Client/DependencyInjection.cs

@@ -1,36 +1,12 @@
-using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.DependencyInjection;
 
 namespace Leanetec.EConnect.Client;
 
 public static class DependencyInjection
 {
-    public static IServiceCollection AddEConnectClient(this IServiceCollection services, Action<Config>? options = null)
+    public static IServiceCollection AddClientServices(this IServiceCollection services)
     {
-        var config = new Config(services);
-        options?.Invoke(config);
-
         services.AddMediatR(cfg => cfg.RegisterServicesFromAssembly(typeof(DependencyInjection).Assembly));
         return services;
     }
-
-    public sealed class Config
-    {
-        private readonly IServiceCollection _services;
-
-        internal Config(IServiceCollection services)
-        {
-            _services = services;
-        }
-
-        public void ConfigureClient(IConfiguration config)
-        {
-            _services.Configure<ClientOptions>(config);
-        }
-
-        public void ConfigureClient(Action<ClientOptions> options)
-        {
-            _services.Configure(options);
-        }
-    }
 }

src/Leanetec.EConnect.Client/Dto/HttpRequest.cs

@@ -4,7 +4,7 @@ namespace Leanetec.EConnect.Client.Dto;
 
 public record HttpRequestBase
 {
-    public int? ApiVersion { get; set; }
+    public int ApiVersion { get; set; } = 1;
 }
 
 public record HttpRequest : HttpRequestBase, IRequest

src/Leanetec.EConnect.Client/Interface/IEConnectClient.cs

@@ -4,8 +4,7 @@ namespace Leanetec.EConnect.Client.Interface;
 
 public interface IEConnectClient<TError> where TError : class
 {
-    public Task<Response<TData, TError>> GetAsync<TData>(string? route = null, CancellationToken cancel = default) where TData : class;
+    public Task<Response<TData, TError>> GetAsync<TData>(string? route = null, object? queryParams = null, CancellationToken cancel = default) where TData : class;
 
-    public Task<Response<IAsyncEnumerable<TData?>, TError>> GetListAsAsyncEnumerable<TData>(string? route = null, CancellationToken cancel = default)
+    Task<Response<TError>> PostAsync(Stream stream, string fileName, string? route = null, object? queryParams = null, CancellationToken cancel = default);
-        where TData : class;
 }

src/Leanetec.EConnect.Client/Leanetec.EConnect.Client.csproj

@@ -1,17 +1,28 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net8.0</TargetFramework>
+    <TargetFrameworks>net7.0;net8.0;net9.0</TargetFrameworks>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="MediatR" Version="13.0.0" />
     <PackageReference Include="Microsoft.Extensions.Configuration.Abstractions" Version="8.0.0" />
     <PackageReference Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="8.0.0" />
   </ItemGroup>
 
+  <ItemGroup Condition="'$(TargetFramework)' == 'net7.0'">
+	<PackageReference Include="MediatR" Version="12.5.0" />
+  </ItemGroup>
+	
+  <ItemGroup Condition="'$(TargetFramework)' == 'net8.0'">
+    <PackageReference Include="MediatR" Version="13.0.0" />
+  </ItemGroup>
+	
+  <ItemGroup Condition="'$(TargetFramework)' == 'net9.0'">
+	  <PackageReference Include="MediatR" Version="13.0.0" />
+  </ItemGroup>
+	
   <ItemGroup>
     <ProjectReference Include="..\Leanetec.EConnect.Domain\Leanetec.EConnect.Domain.csproj" />
   </ItemGroup>

src/Leanetec.EConnect.Client/Order/GetDocumentRequest.cs

@@ -0,0 +1,30 @@
+using Leanetec.EConnect.Client.Dto;
+using Leanetec.EConnect.Client.Interface;
+using Leanetec.EConnect.Domain.Entities;
+using MediatR;
+
+namespace Leanetec.EConnect.Client.Order;
+
+//TODO: EConnectClient.GetListAsAsyncEnumerable
+public record GetDocumentRequest(string TenantId, int OrderId) : HttpRequest<Response<IEnumerable<OrderDocument>, ProblemDetail>>
+{
+}
+
+public class GetDocumentRequestHandler : IRequestHandler<GetDocumentRequest, Response<IEnumerable<OrderDocument>, ProblemDetail>>
+{
+    private readonly IEConnectClient<ProblemDetail> _client;
+
+    public GetDocumentRequestHandler(IEConnectClient<ProblemDetail> client)
+    {
+        _client = client;
+    }
+
+    public async Task<Response<IEnumerable<OrderDocument>, ProblemDetail>> Handle(GetDocumentRequest request, CancellationToken cancel)
+    {
+        return await _client.GetAsync<IEnumerable<OrderDocument>>(
+            $"api/public/v{request.ApiVersion}/econnect/order/document/list",
+            new { request.TenantId, request.OrderId },
+            cancel
+        );
+    }
+}

src/Leanetec.EConnect.Client/Order/PostDocumentRequest.cs

@@ -0,0 +1,37 @@
+using Leanetec.EConnect.Client.Dto;
+using Leanetec.EConnect.Client.Interface;
+using Leanetec.EConnect.Domain.Entities;
+using MediatR;
+
+namespace Leanetec.EConnect.Client.Order;
+
+public record PostDocumentRequest(string TenantId, int OrderId) : HttpRequest<Response<ProblemDetail>>
+{
+    public UploadDocumentRequest ToUploadDocument(Stream stream, string fileName)
+    {
+        return new UploadDocumentRequest(this, stream, fileName);
+    }
+}
+
+public record UploadDocumentRequest(PostDocumentRequest Original, Stream Stream, string FileName) : PostDocumentRequest(Original);
+
+public class PostDocumentRequestHandler : IRequestHandler<UploadDocumentRequest, Response<ProblemDetail>>
+{
+    private readonly IEConnectClient<ProblemDetail> _client;
+
+    public PostDocumentRequestHandler(IEConnectClient<ProblemDetail> client)
+    {
+        _client = client;
+    }
+
+    public async Task<Response<ProblemDetail>> Handle(UploadDocumentRequest request, CancellationToken cancel)
+    {
+        return await _client.PostAsync(
+            request.Stream,
+            request.FileName,
+            $"api/public/v{request.ApiVersion}/econnect/order/document",
+            new { request.TenantId, request.OrderId },
+            cancel
+        );
+    }
+}

src/Leanetec.EConnect.Domain/Entities/Response.cs

@@ -1,5 +1,25 @@
-namespace Leanetec.EConnect.Domain.Entities;
+using System.Net;
 
-public record Response<TData, TError>(bool Ok, TData? Data = null, TError? Error = null)
+namespace Leanetec.EConnect.Domain.Entities;
-    where TData : class
+
-    where TError : class;
+public record Response<TError>() where TError : class
+{
+    public bool Ok { get; init; }
+
+    private HttpStatusCode? _statusCode;
+
+    public HttpStatusCode StatusCode
+    {
+        get => _statusCode ?? (Ok ? HttpStatusCode.OK : HttpStatusCode.InternalServerError);
+        init => _statusCode = value;
+    }
+
+    public int StatusCodeInt => (int)StatusCode;
+
+    public TError? Error { get; init; }
+}
+
+public record Response<TData, TError> : Response<TError> where TData : class where TError : class
+{
+    public TData? Data { get; init; }
+}

src/Leanetec.EConnect.Infrastructure/ClientOptions.cs

@@ -0,0 +1,34 @@
+using System.Text.Json;
+
+namespace Leanetec.EConnect.Infrastructure;
+
+public class ClientOptions
+{
+    public string? BaseAddress { get; set; }
+
+    public TimeSpan? Timeout { get; set; }
+
+    public Dictionary<string, string?>? DefaultQueryStrings { get; set; }
+
+    public Action<HttpClient>? AfterHttpInit { get; set; }
+
+    private string? _jsonSerializerDateFormat = null;
+
+    public string? JsonSerializerDateFormat
+    {
+        get => _jsonSerializerDateFormat;
+        set
+        {
+            _jsonSerializerDateFormat = value;
+            if (value is not null)
+            {
+                JsonSerializerOptions.Converters.Add(new DateTimeConverter(value));
+            }
+        }
+    }
+
+    public JsonSerializerOptions JsonSerializerOptions { get; set; } = new()
+    {
+        PropertyNameCaseInsensitive = true
+    };
+}

src/Leanetec.EConnect.Infrastructure/DateTimeConverter.cs

@@ -0,0 +1,26 @@
+using System.Globalization;
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+namespace Leanetec.EConnect.Infrastructure;
+
+public class DateTimeConverter : JsonConverter<DateTime>
+{
+    private readonly string _format;
+
+    public DateTimeConverter(string format)
+    {
+        _format = format;
+    }
+
+    public override DateTime Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options)
+    {
+        var value = reader.GetString();
+        return DateTime.ParseExact(value!, _format, CultureInfo.InvariantCulture);
+    }
+
+    public override void Write(Utf8JsonWriter writer, DateTime value, JsonSerializerOptions options)
+    {
+        writer.WriteStringValue(value.ToString(_format));
+    }
+}

src/Leanetec.EConnect.Infrastructure/DependencyInjection.cs

@@ -1,5 +1,5 @@
-using Leanetec.EConnect.Client;
+using Leanetec.EConnect.Client.Interface;
-using Leanetec.EConnect.Client.Interface;
+using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Options;
 
@@ -9,7 +9,7 @@ public static class DependencyInjection
 {
     internal static readonly string EConnectClientName = Guid.NewGuid().ToString();
 
-    internal static IServiceCollection ConfigureEConnectClient(this IServiceCollection services, Action<HttpClient> configureClient)
+    internal static IServiceCollection AddEConnectHttpClient(this IServiceCollection services)
     {
         services.AddHttpClient(EConnectClientName, (provider, client) => {
             var opt = provider.GetRequiredService<IOptions<ClientOptions>>().Value;
@@ -21,9 +21,9 @@ public static class DependencyInjection
             if (opt.Timeout is TimeSpan timeout)
                 client.Timeout = timeout;
 
-            // add spesific (library based) parameters
+            opt.AfterHttpInit?.Invoke(client);
-            configureClient(client);
         });
+
         return services;
     }
 
@@ -31,7 +31,7 @@ public static class DependencyInjection
     {
         Config config = new(services);
         options?.Invoke(config);
-        services.ConfigureEConnectClient(config.EConnectClient);
+        services.AddEConnectHttpClient();
         services.AddScoped(typeof(IEConnectClient<>), typeof(EConnectClient<>));
         return services;
     }
@@ -45,6 +45,14 @@ public static class DependencyInjection
             _services = services;
         }
 
-        public Action<HttpClient> EConnectClient { get; set; } = _ => { };
+        public void ConfigureClient(IConfiguration config)
+        {
+            _services.Configure<ClientOptions>(config);
+        }
+
+        public void ConfigureClient(Action<ClientOptions> options)
+        {
+            _services.Configure(options);
+        }
     }
 }

src/Leanetec.EConnect.Infrastructure/EConnectClient.cs

@@ -1,7 +1,9 @@
-using Leanetec.EConnect.Client;
+using Leanetec.EConnect.Client.Interface;
-using Leanetec.EConnect.Client.Interface;
 using Leanetec.EConnect.Domain.Entities;
+using Microsoft.AspNetCore.StaticFiles;
+using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
+using System.Net.Http.Headers;
 using System.Net.Http.Json;
 
 namespace Leanetec.EConnect.Infrastructure;
@@ -14,43 +16,103 @@ public class EConnectClient<TError> : IEConnectClient<TError> where TError :  cl
 
     private HttpClient Http => LazyHttp.Value;
 
-    public EConnectClient(IOptions<ClientOptions> options, IHttpClientFactory httpFactory)
+    private readonly ILogger<EConnectClient<TError>>? _logger;
+
+    public EConnectClient(IOptions<ClientOptions> options, IHttpClientFactory httpFactory, ILogger<EConnectClient<TError>>? logger = null)
     {
         _options = options.Value;
         LazyHttp = new Lazy<HttpClient>(httpFactory.CreateEConnectClient);
+        _logger = logger;
     }
 
-    public async Task<Response<TData, TError>> GetAsync<TData>(string? route = null, CancellationToken cancel = default)
+    private string? AddQueryString(string? route = null, object? queryParams = null)
+    {
+        // add global query strings
+        if (_options.DefaultQueryStrings is not null)
+            route = route.AddQueryString(_options.DefaultQueryStrings);
+
+        // add query strings
+        if (queryParams is not null)
+            route = route.AddQueryString(queryParams.ToPropertyDictionary());
+
+        return route;
+    }
+
+    public async Task<Response<TData, TError>> GetAsync<TData>(string? route = null, object? queryParams = null, CancellationToken cancel = default)
         where TData : class
     {
-        var res = await Http.GetAsync(route, cancel);
+        route = AddQueryString(route, queryParams);
 
-        if (res.IsSuccessStatusCode)
+        var res = await Http.GetAsync(route, cancel);
-        {
+        _logger?.LogCurl(Http, HttpMethod.Get, route);
-            var data = await res.Content.ReadFromJsonAsync<TData>(cancel);
+
-            return new Response<TData, TError>(true, Data: data);
+        return res.IsSuccessStatusCode
-        }
+            ? new()
-        else
+            {
-        {
+                Ok = true,
-            var error = await res.Content.ReadFromJsonAsync<TError>(cancel);
+                StatusCode = res.StatusCode,
-            return new Response<TData, TError>(false, Error: error);
+                Data = (res.Content.Headers.ContentLength > 0)
-        }
+                            ? await res.Content.ReadFromJsonAsync<TData>(_options.JsonSerializerOptions, cancel)
+                            : null
+            }
+            : new()
+            {
+                Ok = false,
+                StatusCode = res.StatusCode,
+                Error = (res.Content.Headers.ContentLength > 0)
+                            ? await res.Content.ReadFromJsonAsync<TError>(_options.JsonSerializerOptions, cancel)
+                            : null
+            };
     }
 
-    public async Task<Response<IAsyncEnumerable<TData?>, TError>> GetListAsAsyncEnumerable<TData>(string? route = null, CancellationToken cancel = default)
+    public async Task<Response<TError>> PostAsync(Stream stream, string fileName, string? route = null, object? queryParams = null, CancellationToken cancel = default)
-        where TData : class
     {
-        var res = await Http.GetAsync(route, cancel);
+        route = AddQueryString(route, queryParams);
 
-        if (res.IsSuccessStatusCode)
+        // create message and add accept header
+        using var message = new HttpRequestMessage(HttpMethod.Post, route);
+        message.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("*/*"));
+
+        // add file type
+        var fileContent = new StreamContent(stream);
+        var mimeType = GetMimeType(fileName);
+        fileContent.Headers.ContentType = new MediaTypeHeaderValue(mimeType);
+
+        // Create multipart form data form
+        using var form = new MultipartFormDataContent
         {
-            var data = res.Content.ReadFromJsonAsAsyncEnumerable<TData>(cancel);
+            { fileContent, "file", fileName }
-            return new Response<IAsyncEnumerable<TData?>, TError>(true, Data: data);
+        };
-        }
+        
-        else
+        message.Content = form;
-        {
+
-            var error = await res.Content.ReadFromJsonAsync<TError>(cancellationToken: cancel);
+        var res = await Http.SendAsync(message, cancel);
-            return new Response<IAsyncEnumerable<TData?>, TError>(false, Error: error);
+
-        }
+        _logger?.LogCurl(Http, message);
+
+        return res.IsSuccessStatusCode
+            ? new()
+            {
+                Ok = true,
+                StatusCode = res.StatusCode
+            }
+            : new()
+            {
+                Ok = false,
+                StatusCode = res.StatusCode,
+                Error = (res.Content.Headers.ContentLength > 0)
+                            ? await res.Content.ReadFromJsonAsync<TError>(_options.JsonSerializerOptions, cancel)
+                            : null
+            };
     }
-}
+
+    private static string GetMimeType(string fileName)
+    {
+        var provider = new FileExtensionContentTypeProvider();
+        if (!provider.TryGetContentType(fileName, out var contentType))
+        {
+            contentType = "application/octet-stream"; // fallback
+        }
+        return contentType;
+    }
+}

src/Leanetec.EConnect.Infrastructure/Leanetec.EConnect.Infrastructure.csproj

@@ -1,16 +1,29 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net8.0</TargetFramework>
+    <TargetFrameworks>net7.0;net8.0;net9.0</TargetFrameworks>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Microsoft.AspNetCore.WebUtilities" Version="8.0.19" />
+    <PackageReference Include="HttpClientToCurl" Version="2.0.6" />
+    <PackageReference Include="Microsoft.AspNetCore.StaticFiles" Version="2.3.0" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="8.0.2" />
     <PackageReference Include="Microsoft.Extensions.Http" Version="8.0.1" />
   </ItemGroup>
+	
+  <ItemGroup Condition="'$(TargetFramework)' == 'net7.0'">
+    <PackageReference Include="Microsoft.AspNetCore.WebUtilities" Version="2.3.0" />
+  </ItemGroup>
+	
+  <ItemGroup Condition="'$(TargetFramework)' == 'net8.0'">
+    <PackageReference Include="Microsoft.AspNetCore.WebUtilities" Version="8.0.19" />
+  </ItemGroup>
+	
+  <ItemGroup Condition="'$(TargetFramework)' == 'net9.0'">
+    <PackageReference Include="Microsoft.AspNetCore.WebUtilities" Version="8.0.19" />
+  </ItemGroup>
 
   <ItemGroup>
     <ProjectReference Include="..\Leanetec.EConnect.Client\Leanetec.EConnect.Client.csproj" />

src/Leanetec.EConnect.Infrastructure/LogExtensions.cs

@@ -0,0 +1,100 @@
+using HttpClientToCurl;
+using HttpClientToCurl.Config;
+using Microsoft.Extensions.Logging;
+using System.Net.Http.Headers;
+
+namespace Leanetec.EConnect.Infrastructure;
+
+public static class LogExtensions
+{
+    public static void LogCurl(
+        this ILogger logger,
+        HttpClient client,
+        HttpRequestMessage request,
+        Action<StringConfig>? config = null,
+        int maxLength = 1000,
+        LogLevel logLevel = LogLevel.Information)
+    {
+        try
+        {
+            var curl = client.GenerateCurlInString(
+                    request,
+                    config
+                    ).Truncate(maxLength);
+            logger?.Log(logLevel, "{curl}", curl);
+        }
+        catch(Exception ex)
+        {
+            logger.LogError(ex, "An unexpected error occurred while logging the HTTP request as cURL.");
+        }
+    }
+
+    public static void LogCurl(
+        this ILogger logger,
+        HttpClient client,
+        HttpMethod method,
+        string? uri = null,
+        HttpRequestHeaders? headers = null,
+        HttpContent? content = null,
+        Action<StringConfig>? config = null,
+        int maxLength = 1000,
+        LogLevel logLevel = LogLevel.Information)
+    {
+        try
+        {
+            var curl = client.GenerateCurlInString(
+                method,
+                uri ?? "",
+                headers,
+                content,
+                config
+            ).Truncate(maxLength);
+            logger?.Log(logLevel, "{curl}", curl);
+        }
+        catch (Exception ex)
+        {
+            logger.LogError(ex, "An unexpected error occurred while logging the HTTP request as cURL.");
+        }
+    }
+
+    public static void LogCurl(
+        this ILogger logger,
+        HttpClient client,
+        HttpMethod method,
+        Uri uri,
+        HttpRequestHeaders? headers = null,
+        HttpContent? content = null,
+        Action<StringConfig>? config = null,
+        int maxLength = 1000,
+        LogLevel logLevel = LogLevel.Information)
+    {
+        try
+        {
+            var curl = client.GenerateCurlInString(
+                method,
+                uri,
+                headers,
+                content,
+                config
+            ).Truncate(maxLength);
+            logger?.Log(logLevel, "{curl}", curl);
+        }
+        catch (Exception ex)
+        {
+            logger.LogError(ex, "An unexpected error occurred while logging the HTTP request as cURL.");
+        }
+    }
+
+    /// <summary>
+    /// Truncates the string to the specified max length and appends a suffix if truncated.
+    /// </summary>
+    public static string Truncate(this string? value, int maxLength, string suffix = "...[truncated]")
+    {
+        if (string.IsNullOrEmpty(value) || maxLength <= 0)
+            return string.Empty;
+
+        return value.Length <= maxLength
+            ? value
+            : value[..maxLength] + suffix;
+    }
+}

src/Leanetec.EConnect.Infrastructure/ObjectExtensions.cs

@@ -11,15 +11,16 @@ public static class ObjectExtensions
         .GetType()
         .GetProperties(BindingFlags.Instance | BindingFlags.Public)
         .ToDictionary(
-            prop => prop.Name,
+            prop => prop.Name.ToCamelCase(),
             prop => prop.GetValue(obj).ToSafeString()
         );
     }
+
     public static Dictionary<string, string?> ToPropertyDictionary(this Dictionary<string, object?> obj)
     {
         return obj
         .ToDictionary(
-            prop => prop.Key,
+            prop => prop.Key.ToCamelCase(),
             prop => prop.Value?.ToString()
         );
     }
@@ -29,12 +30,23 @@ public static class ObjectExtensions
             ? (b ? "true" : "false")
             : obj?.ToString();
 
-    public static string? AddQueryString(this string? route, Dictionary<string, string?> queryPrams)
+    public static string? AddQueryString(this string? route, Dictionary<string, string?> queryParams)
     {
-        if (queryPrams.Count > 0)
+        if (queryParams.Count > 0)
-            route = QueryHelpers.AddQueryString(route ?? string.Empty, queryPrams);
+            route = QueryHelpers.AddQueryString(route ?? string.Empty, queryParams);
         return route;
     }
 
-    public static string? AddQueryString(this string? route, object queryPrams) => route.AddQueryString(queryPrams.ToPropertyDictionary());
+    public static string? AddQueryString(this string? route, object queryParams) => route.AddQueryString(queryParams.ToPropertyDictionary());
+
+    public static string ToCamelCase(this string input)
+    {
+        if (string.IsNullOrWhiteSpace(input))
+            return input;
+
+        if (char.IsLower(input[0]))
+            return input;
+        
+        return char.ToLowerInvariant(input[0]) + input[1..];
+    }
 }

src/Leanetec.EConnect.Proxy/Controllers/OrderController.cs

@@ -0,0 +1,43 @@
+using Leanetec.EConnect.Client.Order;
+using MediatR;
+using Microsoft.AspNetCore.Mvc;
+
+namespace Leanetec.EConnect.Proxy.Controllers;
+
+[Route("api/[controller]")]
+[ApiController]
+public class OrderController : ControllerBase
+{
+    private readonly IMediator _mediator;
+
+    public OrderController(IMediator mediator)
+    {
+        _mediator = mediator;
+    }
+
+    [HttpGet("document")]
+    public async Task<IActionResult> GetDocument([FromQuery] GetDocumentRequest request, CancellationToken cancel)
+    {
+        var res = await _mediator.Send(request, cancel);
+        if(res.Ok)
+            return res.Data is null || !res.Data.Any()
+                ? NotFound()
+                : Ok(res.Data);
+        else
+            return StatusCode(res.StatusCodeInt, res?.Error);
+    }
+
+    [HttpPost("document")]
+    public async Task<IActionResult> PostDocument(IFormFile file, [FromQuery] PostDocumentRequest request, CancellationToken cancel)
+    {
+        using var stream = file.OpenReadStream();
+
+        var uploadRequest = request.ToUploadDocument(stream, file.FileName);
+
+        var res = await _mediator.Send(uploadRequest, cancel);
+
+        return res.Ok
+            ? StatusCode(res.StatusCodeInt)
+            : StatusCode(res.StatusCodeInt, res?.Error);
+    }
+}

src/Leanetec.EConnect.Proxy/Leanetec.EConnect.Proxy.csproj

@@ -1,19 +1,25 @@
 <Project Sdk="Microsoft.NET.Sdk.Web">
 
   <PropertyGroup>
-    <TargetFramework>net8.0</TargetFramework>
+    <TargetFrameworks>net7.0;net8.0;net9.0</TargetFrameworks>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
+	<PackageId>Leanetec.EConnect.Proxy</PackageId>
+	<Version>1.0.1</Version>
+	<Company>Digital Data GmbH</Company>
+	<Product>Leanetec.EConnect.Proxy</Product>
+	<Title>Leanetec.EConnect.Proxy</Title>
+	<AssemblyVersion>1.0.1</AssemblyVersion>
+	<FileVersion>1.0.1</FileVersion>
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="DigitalData.Core.Exceptions" Version="1.1.0" />
+    <PackageReference Include="NLog" Version="6.0.3" />
+    <PackageReference Include="NLog.Web.AspNetCore" Version="6.0.3" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="6.6.2" />
   </ItemGroup>
 
-  <ItemGroup>
-    <Folder Include="Controllers\" />
-  </ItemGroup>
-
   <ItemGroup>
     <ProjectReference Include="..\Leanetec.EConnect.Client\Leanetec.EConnect.Client.csproj" />
     <ProjectReference Include="..\Leanetec.EConnect.Infrastructure\Leanetec.EConnect.Infrastructure.csproj" />

src/Leanetec.EConnect.Proxy/Middleware/ExceptionHandlingMiddleware.cs

@@ -0,0 +1,84 @@
+using DigitalData.Core.Exceptions;
+using System.Net;
+using System.Text.Json;
+
+namespace Leanetec.EConnect.Proxy.Middleware;
+
+//TODO: Fix and use DigitalData.Core.Exceptions.Middleware
+/// <summary>
+/// Middleware for handling exceptions globally in the application.
+/// Captures exceptions thrown during the request pipeline execution,
+/// logs them, and returns an appropriate HTTP response with a JSON error message.
+/// </summary>
+[Obsolete("Use DigitalData.Core.Exceptions.Middleware")]
+public class ExceptionHandlingMiddleware
+{
+    private readonly RequestDelegate _next;
+    private readonly ILogger<ExceptionHandlingMiddleware> _logger;
+
+    /// <summary>
+    /// Initializes a new instance of the <see cref="ExceptionHandlingMiddleware"/> class.
+    /// </summary>
+    /// <param name="next">The next middleware in the request pipeline.</param>
+    /// <param name="logger">The logger instance for logging exceptions.</param>
+    public ExceptionHandlingMiddleware(RequestDelegate next, ILogger<ExceptionHandlingMiddleware> logger)
+    {
+        _next = next;
+        _logger = logger;
+    }
+
+    /// <summary>
+    /// Invokes the middleware to handle the HTTP request.
+    /// </summary>
+    /// <param name="context">The HTTP context of the current request.</param>
+    /// <returns>A task that represents the asynchronous operation.</returns>
+    public async Task InvokeAsync(HttpContext context)
+    {
+        try
+        {
+            await _next(context); // Continue down the pipeline
+        }
+        catch (Exception ex)
+        {
+            await HandleExceptionAsync(context, ex, _logger);
+        }
+    }
+
+    /// <summary>
+    /// Handles exceptions by logging them and writing an appropriate JSON response.
+    /// </summary>
+    /// <param name="context">The HTTP context of the current request.</param>
+    /// <param name="exception">The exception that occurred.</param>
+    /// <param name="logger">The logger instance for logging the exception.</param>
+    /// <returns>A task that represents the asynchronous operation.</returns>
+    private static async Task HandleExceptionAsync(HttpContext context, Exception exception, ILogger logger)
+    {
+        context.Response.ContentType = "application/json";
+
+        string message;
+
+        switch (exception)
+        {
+            case BadRequestException badRequestEx:
+                context.Response.StatusCode = (int)HttpStatusCode.BadRequest;
+                message = badRequestEx.Message;
+                break;
+
+            case NotFoundException notFoundEx:
+                context.Response.StatusCode = (int)HttpStatusCode.NotFound;
+                message = notFoundEx.Message;
+                break;
+
+            default:
+                logger.LogError(exception, "Unhandled exception occurred.");
+                context.Response.StatusCode = (int)HttpStatusCode.InternalServerError;
+                message = "An unexpected error occurred.";
+                break;
+        }
+
+        await context.Response.WriteAsync(JsonSerializer.Serialize(new
+        {
+            message
+        }));
+    }
+}

src/Leanetec.EConnect.Proxy/Program.cs

@@ -1,31 +1,65 @@
 using Leanetec.EConnect.Client;
 using Leanetec.EConnect.Infrastructure;
+using Leanetec.EConnect.Proxy.Middleware;
+using NLog;
+using NLog.Web;
 
-var builder = WebApplication.CreateBuilder(args);
+var logger = LogManager.Setup().LoadConfigurationFromAppSettings().GetCurrentClassLogger();
-var config = builder.Configuration;
+logger.Info("Logging initialized!");
 
-// Add services to the container.
+try
-var clientOpt = config.GetSection("EConnect");
-builder.Services.AddEConnectClient(opt => opt.ConfigureClient(clientOpt)).AddInfrastructureServices();
-
-builder.Services.AddControllers();
-// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
-builder.Services.AddEndpointsApiExplorer();
-builder.Services.AddSwaggerGen();
-
-var app = builder.Build();
-
-// Configure the HTTP request pipeline.
-if (app.Environment.IsDevelopment())
 {
-    app.UseSwagger();
+    var builder = WebApplication.CreateBuilder(args);
-    app.UseSwaggerUI();
+    var config = builder.Configuration;
+
+    builder.Logging.SetMinimumLevel(Microsoft.Extensions.Logging.LogLevel.Trace);
+    if (!builder.Environment.IsDevelopment())
+    {
+        builder.Logging.ClearProviders();
+        builder.Host.UseNLog();
+    }
+
+    // Add services to the container.
+    var clientOpt = config.GetSection("EConnect");
+    builder.Services.AddClientServices().AddInfrastructureServices(opt => opt.ConfigureClient(clientOpt));
+
+    builder.Services.AddControllers();
+    // Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
+    builder.Services.AddEndpointsApiExplorer();
+    builder.Services.AddSwaggerGen();
+
+    var app = builder.Build();
+
+    app.UseMiddleware<ExceptionHandlingMiddleware>();
+
+    bool useSwagger = config.GetValue<bool>("UseSwagger");
+    if(useSwagger)
+        app.Services.GetRequiredService<ILogger<Program>>()
+            .LogWarning("Swagger UI is enabled. Using Swagger in a production environment may expose sensitive API information and pose security risks.");
+
+    // Configure the HTTP request pipeline.
+    if (app.Environment.IsDevelopment() || useSwagger)
+    {
+        app.UseSwagger();
+        app.UseSwaggerUI();
+    }
+
+    app.UseHttpsRedirection();
+
+    app.UseAuthorization();
+
+    app.MapControllers();
+
+    app.Run();
 }
-
+catch (Exception ex)
-app.UseHttpsRedirection();
+{
-
+    // NLog: catch setup errors
-app.UseAuthorization();
+    logger.Error(ex, "Application stopped because of exception");
-
+    throw;
-app.MapControllers();
+}
-
+finally
-app.Run();
+{
+    // Ensure to flush and stop internal timers/threads before application-exit (Avoid segmentation fault on Linux)
+    LogManager.Shutdown();
+}

src/Leanetec.EConnect.Proxy/Properties/PublishProfiles/IISProfileNet8Win64.pubxml

@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="utf-8"?>
+<!-- https://go.microsoft.com/fwlink/?LinkID=208121. -->
+<Project>
+  <PropertyGroup>
+    <WebPublishMethod>Package</WebPublishMethod>
+    <LastUsedBuildConfiguration>Release</LastUsedBuildConfiguration>
+    <LastUsedPlatform>Any CPU</LastUsedPlatform>
+    <SiteUrlToLaunchAfterPublish />
+    <LaunchSiteAfterPublish>true</LaunchSiteAfterPublish>
+    <ExcludeApp_Data>false</ExcludeApp_Data>
+    <ProjectGuid>79d9868e-6a67-45c1-ba3e-1c2e822ecc58</ProjectGuid>
+    <DesktopBuildPackageLocation>P:\Install .Net\0 DD - Smart UP\EConnect\Proxy\$(Version)\EConnect.Proxy.zip</DesktopBuildPackageLocation>
+    <PackageAsSingleFile>true</PackageAsSingleFile>
+    <DeployIisAppPath>EConnect.Proxy</DeployIisAppPath>
+    <_TargetId>IISWebDeployPackage</_TargetId>
+	<TargetFramework>net8.0</TargetFramework>
+	<RuntimeIdentifier>win-x64</RuntimeIdentifier>
+	<SelfContained>true</SelfContained>
+  </PropertyGroup>
+</Project>

src/Leanetec.EConnect.Proxy/appsettings.json

@@ -5,9 +5,64 @@
       "Microsoft.AspNetCore": "Warning"
     }
   },
+  "UseSwagger": true,
   "AllowedHosts": "*",
   "EConnect": {
     "BaseAddress": "https://portal.demoportal01.leanetec.com",
-    "apiKey": "HGpGp3vk3MsKgSe0tKVZ1ZRCuq6bFoJ1"
+    "DefaultQueryStrings": {
+      "apiKey": "HGpGp3vk3MsKgSe0tKVZ1ZRCuq6bFoJ1"
+    },
+    "JsonSerializerDateFormat": "yyyy-MM-dd HH:mm"
+  },
+  "NLog": {
+    "throwConfigExceptions": true,
+    "variables": {
+      "logDirectory": "E:\\LogFiles\\Digital Data\\EConnect-Proxy",
+      "logFileNamePrefix": "${shortdate}-ECM.EConnect-Proxy.Web"
+    },
+    "targets": {
+      "infoLogs": {
+        "type": "File",
+        "fileName": "${logDirectory}\\${logFileNamePrefix}-Info.log",
+        "maxArchiveDays": 30
+      },
+      "warningLogs": {
+        "type": "File",
+        "fileName": "${logDirectory}\\${logFileNamePrefix}-Warning.log",
+        "maxArchiveDays": 30
+      },
+      "errorLogs": {
+        "type": "File",
+        "fileName": "${logDirectory}\\${logFileNamePrefix}-Error.log",
+        "maxArchiveDays": 30
+      },
+      "criticalLogs": {
+        "type": "File",
+        "fileName": "${logDirectory}\\${logFileNamePrefix}-Critical.log",
+        "maxArchiveDays": 30
+      }
+    },
+    "rules": [
+      {
+        "logger": "*",
+        "level": "Info",
+        "writeTo": "infoLogs"
+      },
+      {
+        "logger": "*",
+        "level": "Warn",
+        "writeTo": "warningLogs"
+      },
+      {
+        "logger": "*",
+        "level": "Error",
+        "writeTo": "errorLogs"
+      },
+      {
+        "logger": "*",
+        "level": "Fatal",
+        "writeTo": "criticalLogs"
+      }
+    ]
   }
-}
+}