From 23d60f30eff1c337f1383b5034ddba70d0784c2c Mon Sep 17 00:00:00 2001 From: JBBianchi Date: Wed, 25 Sep 2024 16:06:02 +0200 Subject: [PATCH] fix(Core.Api.Client): fixed partition query parameters format Closes #64 --- .../Services/CloudStreamsCoreApiClient.CloudEvents.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/core/CloudStreams.Core.Api.Client/Services/CloudStreamsCoreApiClient.CloudEvents.cs b/src/core/CloudStreams.Core.Api.Client/Services/CloudStreamsCoreApiClient.CloudEvents.cs index aadbfef0..e3f7278f 100644 --- a/src/core/CloudStreams.Core.Api.Client/Services/CloudStreamsCoreApiClient.CloudEvents.cs +++ b/src/core/CloudStreams.Core.Api.Client/Services/CloudStreamsCoreApiClient.CloudEvents.cs @@ -68,8 +68,8 @@ public virtual async Task GetStreamMetadataAsync(CancellationTok var queryParameters = new Dictionary() { { $"{nameof(options.Direction)}".ToCamelCase(), options.Direction.ToString() } }; if (options.Partition != null) { - queryParameters.Add($"{nameof(options.Partition)}.{nameof(options.Partition.Type)}".ToCamelCase(), options.Partition.Type.ToString()); - queryParameters.Add($"{nameof(options.Partition)}.{nameof(options.Partition.Id)}".ToCamelCase(), options.Partition.Id); + queryParameters.Add($"{nameof(options.Partition).ToCamelCase()}.{nameof(options.Partition.Type).ToCamelCase()}", options.Partition.Type.ToString()); + queryParameters.Add($"{nameof(options.Partition).ToCamelCase()}.{nameof(options.Partition.Id).ToCamelCase()}", options.Partition.Id); } if (options.Offset.HasValue) queryParameters.Add(nameof(options.Offset).ToCamelCase(), options.Offset.Value); queryParameters.Add(nameof(options.Length).ToCamelCase(), options.Length);