AppStd/Leanetec.EConnect
8
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(EConnectClient): Vereinfachung der Antwortverarbeitung in EConnectClient durch Verwendung von bedingten Ausdrücken und Entfernen der ungenutzten PostAsync-Überladung

Browse Source
This commit is contained in:
tekh 2025-08-18 15:31:56 +02:00
parent beadc3c4bb
commit 20b5b8124d
2 changed files with 14 additions and 54 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Leanetec.EConnect.Client/Interface/IEConnectClient.cs
View File

@ -9,7 +9,5 @@ public interface IEConnectClient<TError> where TError : class
public Task<Response<IAsyncEnumerable<TData?>, TError>> GetListAsAsyncEnumerable<TData>(string? route = null, object? queryParams = null, CancellationToken cancel = default) public Task<Response<IAsyncEnumerable<TData?>, TError>> GetListAsAsyncEnumerable<TData>(string? route = null, object? queryParams = null, CancellationToken cancel = default)
where TData : class; where TData : class;
public Task<Response<TError>> PostAsync(string? route = null, object? queryParams = null, CancellationToken cancel = default);
Task<Response<TError>> PostAsync(Stream stream, string fileName, string? route = null, object? queryParams = null, CancellationToken cancel = default); Task<Response<TError>> PostAsync(Stream stream, string fileName, string? route = null, object? queryParams = null, CancellationToken cancel = default);
} }

66
src/Leanetec.EConnect.Infrastructure/EConnectClient.cs
View File

@ -45,20 +45,16 @@ public class EConnectClient<TError> : IEConnectClient<TError> where TError : cl
var res = await Http.GetAsync(route, cancel); var res = await Http.GetAsync(route, cancel);
if (res.IsSuccessStatusCode) return res.IsSuccessStatusCode
{ ? new()
return new ()
{ {
Ok = true, Ok = true,
StatusCode = res.StatusCode, StatusCode = res.StatusCode,
Data = (res.Content.Headers.ContentLength > 0) Data = (res.Content.Headers.ContentLength > 0)
? await res.Content.ReadFromJsonAsync<TData>(_options.JsonSerializerOptions, cancel) ? await res.Content.ReadFromJsonAsync<TData>(_options.JsonSerializerOptions, cancel)
: null : null
}; }
} : new()
else
{
return new ()
{ {
Ok = false, Ok = false,
StatusCode = res.StatusCode, StatusCode = res.StatusCode,
@ -66,7 +62,6 @@ public class EConnectClient<TError> : IEConnectClient<TError> where TError : cl
? await res.Content.ReadFromJsonAsync<TError>(_options.JsonSerializerOptions, cancel) ? await res.Content.ReadFromJsonAsync<TError>(_options.JsonSerializerOptions, cancel)
: null : null
}; };
}
} }
public async Task<Response<IAsyncEnumerable<TData?>, TError>> GetListAsAsyncEnumerable<TData>(string? route = null, object? queryParams = null, CancellationToken cancel = default) public async Task<Response<IAsyncEnumerable<TData?>, TError>> GetListAsAsyncEnumerable<TData>(string? route = null, object? queryParams = null, CancellationToken cancel = default)
@ -76,20 +71,16 @@ public class EConnectClient<TError> : IEConnectClient<TError> where TError : cl
var res = await Http.GetAsync(route, cancel); var res = await Http.GetAsync(route, cancel);
if (res.IsSuccessStatusCode) return res.IsSuccessStatusCode
{ ? new()
return new ()
{ {
Ok = true, Ok = true,
StatusCode = res.StatusCode, StatusCode = res.StatusCode,
Data = (res.Content.Headers.ContentLength > 0) Data = (res.Content.Headers.ContentLength > 0)
? res.Content.ReadFromJsonAsAsyncEnumerable<TData>(_options.JsonSerializerOptions, cancel) ? res.Content.ReadFromJsonAsAsyncEnumerable<TData>(_options.JsonSerializerOptions, cancel)
: null : null
}; }
} : new()
else
{
return new()
{ {
Ok = false, Ok = false,
StatusCode = res.StatusCode, StatusCode = res.StatusCode,
@ -97,34 +88,6 @@ public class EConnectClient<TError> : IEConnectClient<TError> where TError : cl
? await res.Content.ReadFromJsonAsync<TError>(_options.JsonSerializerOptions, cancel) ? await res.Content.ReadFromJsonAsync<TError>(_options.JsonSerializerOptions, cancel)
: null : null
}; };
}
}
public async Task<Response<TError>> PostAsync(string? route = null, object? queryParams = null, CancellationToken cancel = default)
{
route = AddQueryString(route, queryParams);
var res = await Http.PostAsync(route, null, cancel);
if (res.IsSuccessStatusCode)
{
return new()
{
Ok = true,
StatusCode = res.StatusCode
};
}
else
{
return 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<TError>> PostAsync(Stream stream, string fileName, string? route = null, object? queryParams = null, CancellationToken cancel = default) public async Task<Response<TError>> PostAsync(Stream stream, string fileName, string? route = null, object? queryParams = null, CancellationToken cancel = default)
@ -152,14 +115,13 @@ public class EConnectClient<TError> : IEConnectClient<TError> where TError : cl
_logger?.LogCurlAsync(Http, requestMessage: message); _logger?.LogCurlAsync(Http, requestMessage: message);
if (res.IsSuccessStatusCode) return res.IsSuccessStatusCode
return new() ? new()
{ {
Ok = true, Ok = true,
StatusCode = res.StatusCode StatusCode = res.StatusCode
}; }
else : new()
return new()
{ {
Ok = false, Ok = false,
StatusCode = res.StatusCode, StatusCode = res.StatusCode,