This is an automated email from the ASF dual-hosted git repository.
piotr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iggy.git
The following commit(s) were added to refs/heads/master by this push:
new 33fca8d45 style(csharp): format dotnet code and enable `dotnet format`
in CI (#2290)
33fca8d45 is described below
commit 33fca8d45b560453729c93891eaf8b57f27b3602
Author: Łukasz Zborek <[email protected]>
AuthorDate: Wed Oct 29 08:56:12 2025 +0100
style(csharp): format dotnet code and enable `dotnet format` in CI (#2290)
---
.github/actions/csharp-dotnet/pre-merge/action.yml | 5 ++--
examples/csharp/.editorconfig | 2 +-
.../Iggy_SDK.Examples.Basic.Consumer/Program.cs | 2 +-
.../Iggy_SDK.Examples.Basic.Producer/Program.cs | 2 +-
.../Program.cs | 2 +-
.../Program.cs | 2 +-
.../src/Iggy_SDK.Examples.Shared/ExampleHelpers.cs | 4 +--
.../src/Iggy_SDK.Examples.Shared/Messages.cs | 30 ++++++++--------------
.../Program.cs | 2 +-
.../Utils.cs | 6 ++---
.../Program.cs | 2 +-
.../Program.cs | 2 +-
.../Utils.cs | 6 ++---
.../Program.cs | 2 +-
.../Iggy_SDK.Examples.NewSdk.Consumer/Program.cs | 2 +-
.../Iggy_SDK.Examples.NewSdk.Consumer/Utils.cs | 6 ++---
.../Iggy_SDK.Examples.NewSdk.Producer/Program.cs | 2 +-
.../Iggy_SDK.Examples.NewSdk.Producer/Utils.cs | 10 ++++----
foreign/csharp/.editorconfig | 2 +-
.../Iggy_SDK.Tests.BDD/Context/TestContext.cs | 2 +-
.../csharp/Iggy_SDK.Tests.BDD/Context/TestHooks.cs | 2 +-
.../Configuration/IggyClientConfigurator.cs | 2 +-
.../Configuration/MessageBatchingSettings.cs | 2 +-
.../Configuration/MessagePollingSettings.cs | 2 +-
.../Iggy_SDK/ConnectionStream/IConnectionStream.cs | 2 +-
.../ConnectionStream/TcpTslConnectionStream.cs | 2 +-
.../Iggy_SDK/Consumers/IggyConsumerBuilderOfT.cs | 2 +-
.../csharp/Iggy_SDK/Consumers/IggyConsumerOfT.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Auth/AuthResponse.cs | 2 +-
.../Iggy_SDK/Contracts/Auth/GlobalPermissions.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Auth/Permissions.cs | 2 +-
.../Contracts/Auth/PersonalAccessTokenResponse.cs | 2 +-
.../Contracts/Auth/RawPersonalAccessToken.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Auth/TokenInfo.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Auth/UserResponse.cs | 2 +-
foreign/csharp/Iggy_SDK/Contracts/CacheMetrics.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/CacheMetricsKey.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/ConsumerGroupInfo.cs | 2 +-
.../Iggy_SDK/Contracts/ConsumerGroupMembers.cs | 2 +-
.../Iggy_SDK/Contracts/ConsumerGroupResponse.cs | 2 +-
.../Contracts/Http/Auth/ChangePasswordRequest.cs | 2 +-
.../Http/Auth/CreatePersonalAccessTokenRequest.cs | 2 +-
.../Contracts/Http/Auth/CreateUserRequest.cs | 2 +-
.../Contracts/Http/Auth/LoginUserRequest.cs | 2 +-
.../Auth/LoginWIthPersonalAccessTokenRequest.cs | 2 +-
.../Http/Auth/UpdateUserPermissionsRequest.cs | 2 +-
.../Contracts/Http/Auth/UpdateUserRequest.cs | 2 +-
.../Contracts/Http/CreateConsumerGroupRequest.cs | 2 +-
.../Contracts/Http/CreatePartitionsRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/CreateStreamRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/CreateTopicRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/StoreOffsetRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/UpdateStreamRequest.cs | 2 +-
.../Iggy_SDK/Contracts/Http/UpdateTopicRequest.cs | 2 +-
.../Iggy_SDK/Contracts/MessageSendRequest.cs | 2 +-
.../Contracts/MessageSendRequestGeneric.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/OffsetResponse.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/PartitionResponse.cs | 2 +-
.../Iggy_SDK/Contracts/PollMessagesRequest.cs | 2 +-
.../Iggy_SDK/Contracts/PolledMessagesGeneric.cs | 2 +-
foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/StreamPermissions.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/StreamResponse.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/TopicPermissions.cs | 2 +-
foreign/csharp/Iggy_SDK/Contracts/TopicResponse.cs | 2 +-
.../csharp/Iggy_SDK/Enums/CompressionAlgorithm.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/ConsumerType.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/IdKind.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/MessagePolling.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/MessageState.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/Protocol.cs | 2 +-
.../csharp/Iggy_SDK/Enums/SnapshotCompression.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/StoreOffset.cs | 2 +-
.../csharp/Iggy_SDK/Enums/SystemSnapshotType.cs | 2 +-
foreign/csharp/Iggy_SDK/Enums/UserStatus.cs | 2 +-
foreign/csharp/Iggy_SDK/Errors/ErrorFactory.cs | 2 +-
foreign/csharp/Iggy_SDK/Errors/ErrorModel.cs | 2 +-
.../Exceptions/FeatureUnavailableException.cs | 2 +-
.../InvalidConsumerGroupNameException.cs | 2 +-
.../Exceptions/InvalidResponseException.cs | 2 +-
.../Exceptions/TcpInvalidResponseException.cs | 2 +-
.../csharp/Iggy_SDK/Exceptions/TcpInvalidStatus.cs | 2 +-
foreign/csharp/Iggy_SDK/Extensions/Extensions.cs | 2 +-
foreign/csharp/Iggy_SDK/Headers/HeaderKey.cs | 2 +-
foreign/csharp/Iggy_SDK/Headers/HeaderKind.cs | 2 +-
foreign/csharp/Iggy_SDK/Headers/HeaderValue.cs | 2 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyOffset.cs | 2 +-
.../csharp/Iggy_SDK/IggyClient/IIggyPartition.cs | 2 +-
.../IggyClient/IIggyPersonalAccessToken.cs | 2 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyStream.cs | 2 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggySystem.cs | 2 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyTopic.cs | 2 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyUsers.cs | 2 +-
.../JsonConverters/DateTimeOffsetConverter.cs | 2 +-
.../Iggy_SDK/JsonConverters/ExpiryConverter.cs | 2 +-
.../Iggy_SDK/JsonConverters/HeaderKeyConverter.cs | 2 +-
.../Iggy_SDK/JsonConverters/MessageConverter.cs | 2 +-
.../Iggy_SDK/JsonConverters/MessagesConverter.cs | 2 +-
.../Iggy_SDK/JsonConverters/SizeConverter.cs | 2 +-
foreign/csharp/Iggy_SDK/Kinds/Consumer.cs | 2 +-
foreign/csharp/Iggy_SDK/Kinds/Partitioning.cs | 2 +-
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 22 ++++++++--------
.../Iggy_SDK/Publishers/IggyPublisherBuilder.cs | 2 +-
.../Iggy_SDK/Publishers/IggyPublisherConfig.cs | 2 +-
.../MessageRequestInterpolationHandler.cs | 26 +++++++++----------
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 2 +-
foreign/csharp/Iggy_SDK_Tests/Usings.cs | 2 +-
.../UtilityTests/HeaderValueTests.cs | 2 +-
.../IdentifiersByteSerializationTests.cs | 2 +-
.../csharp/Iggy_SDK_Tests/Utils/BinaryFactory.cs | 2 +-
.../Iggy_SDK_Tests/Utils/DummyObj/DummyMessage.cs | 2 +-
.../Utils/DummyObj/DummyObjFactory.cs | 2 +-
.../Utils/Errors/ErrorModelFactory.cs | 2 +-
.../Iggy_SDK_Tests/Utils/Groups/GroupFactory.cs | 2 +-
.../csharp/Iggy_SDK_Tests/Utils/PriorityOrderer.cs | 2 +-
.../SpecFlowTypes/ConsumerPollStreamTopicId.cs | 2 +-
.../Iggy_SDK_Tests/Utils/Stats/StatsFactory.cs | 2 +-
.../Iggy_SDK_Tests/Utils/Streams/StreamFactory.cs | 2 +-
.../Iggy_SDK_Tests/Utils/TestPriorityAttribute.cs | 2 +-
.../Iggy_SDK_Tests/Utils/Topics/TopicFactory.cs | 2 +-
.../Utils/Users/PermissionsFactory.cs | 2 +-
.../Iggy_SDK_Tests/Utils/Users/UsersFactory.cs | 2 +-
foreign/csharp/Iggy_SDK_Tests/Utils/Utility.cs | 2 +-
foreign/csharp/Shared/Envelope.cs | 2 +-
foreign/csharp/Shared/ISerializableMessage.cs | 2 +-
foreign/csharp/Shared/Orders.cs | 2 +-
128 files changed, 172 insertions(+), 181 deletions(-)
diff --git a/.github/actions/csharp-dotnet/pre-merge/action.yml
b/.github/actions/csharp-dotnet/pre-merge/action.yml
index 4c08ea344..712dda261 100644
--- a/.github/actions/csharp-dotnet/pre-merge/action.yml
+++ b/.github/actions/csharp-dotnet/pre-merge/action.yml
@@ -64,9 +64,8 @@ runs:
dotnet build foreign/csharp/Iggy_SDK.sln --no-restore
/p:EnforceCodeStyleInBuild=true /p:TreatWarningsAsErrors=false
dotnet build examples/csharp/Iggy_SDK.Examples.sln --no-restore
/p:EnforceCodeStyleInBuild=true /p:TreatWarningsAsErrors=false
- # TODO: make format check blocking (requires dotnet-format tool)
- dotnet format examples/csharp/Iggy_SDK.Examples.sln
--verify-no-changes --verbosity diagnostic || true
- dotnet format foreign/csharp/Iggy_SDK.sln --verify-no-changes
--verbosity diagnostic || true
+ dotnet format examples/csharp/Iggy_SDK.Examples.sln
--verify-no-changes --verbosity diagnostic
+ dotnet format foreign/csharp/Iggy_SDK.sln --verify-no-changes
--verbosity diagnostic
shell: bash
diff --git a/examples/csharp/.editorconfig b/examples/csharp/.editorconfig
index 7fb91e9d1..b5ab0daec 100644
--- a/examples/csharp/.editorconfig
+++ b/examples/csharp/.editorconfig
@@ -1,6 +1,6 @@
[*]
charset = utf-8
-end_of_line = crlf
+end_of_line = lf
trim_trailing_whitespace = false
insert_final_newline = true
indent_style = space
diff --git
a/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Consumer/Program.cs
b/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Consumer/Program.cs
index a288204a1..a4f27cfb9 100644
--- a/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Consumer/Program.cs
+++ b/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Consumer/Program.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git
a/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Producer/Program.cs
b/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Producer/Program.cs
index fa23193f5..6276175af 100644
--- a/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Producer/Program.cs
+++ b/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Producer/Program.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git
a/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Consumer/Program.cs
b/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Consumer/Program.cs
index deb1ae1df..fcdce8b52 100644
---
a/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Consumer/Program.cs
+++
b/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Consumer/Program.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git
a/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Producer/Program.cs
b/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Producer/Program.cs
index 125215ef9..62432ee40 100644
---
a/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Producer/Program.cs
+++
b/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Producer/Program.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git a/examples/csharp/src/Iggy_SDK.Examples.Shared/ExampleHelpers.cs
b/examples/csharp/src/Iggy_SDK.Examples.Shared/ExampleHelpers.cs
index f9e36c696..35520edd3 100644
--- a/examples/csharp/src/Iggy_SDK.Examples.Shared/ExampleHelpers.cs
+++ b/examples/csharp/src/Iggy_SDK.Examples.Shared/ExampleHelpers.cs
@@ -31,7 +31,7 @@ public static class ExampleHelpers
)
{
var stream = await client.GetStreamByIdAsync(streamId, token);
- if(stream == null)
+ if (stream == null)
{
await client.CreateStreamAsync(streamName, token: token);
}
@@ -47,7 +47,7 @@ public static class ExampleHelpers
)
{
var topic = await client.GetTopicByIdAsync(streamId, topicId,
cancellationToken);
- if(topic == null)
+ if (topic == null)
{
await client.CreateTopicAsync(
streamId,
diff --git a/examples/csharp/src/Iggy_SDK.Examples.Shared/Messages.cs
b/examples/csharp/src/Iggy_SDK.Examples.Shared/Messages.cs
index 3807b10ea..60b4c876c 100644
--- a/examples/csharp/src/Iggy_SDK.Examples.Shared/Messages.cs
+++ b/examples/csharp/src/Iggy_SDK.Examples.Shared/Messages.cs
@@ -22,9 +22,12 @@ namespace Iggy_SDK.Examples.Shared;
public class Envelope
{
- public const string OrderCreatedType = "order_created";
- public const string OrderConfirmedType = "order_confirmed";
- public const string OrderRejectedType = "order_rejected";
+ public const string ORDER_CREATED_TYPE = "order_created";
+ public const string ORDER_CONFIRMED_TYPE = "order_confirmed";
+ public const string ORDER_REJECTED_TYPE = "order_rejected";
+
+ public string MessageType { get; }
+ public string Payload { get; }
public Envelope(string messageType, ISerializableMessage payload)
{
@@ -39,9 +42,6 @@ public class Envelope
Payload = payload;
}
- public string MessageType { get; }
- public string Payload { get; }
-
public string ToJson()
{
return JsonSerializer.Serialize(this);
@@ -63,7 +63,7 @@ public record OrderCreated(
string Side,
DateTimeOffset Timestamp) : ISerializableMessage
{
- public string MessageType => Envelope.OrderCreatedType;
+ public string MessageType => Envelope.ORDER_CREATED_TYPE;
public string ToJson()
{
@@ -76,13 +76,9 @@ public record OrderCreated(
}
}
-public record OrderConfirmed(
- ulong OrderId,
- double Price,
- DateTimeOffset Timestamp
-) : ISerializableMessage
+public record OrderConfirmed(ulong OrderId, double Price, DateTimeOffset
Timestamp) : ISerializableMessage
{
- public string MessageType => Envelope.OrderConfirmedType;
+ public string MessageType => Envelope.ORDER_CONFIRMED_TYPE;
public string ToJson()
{
@@ -95,13 +91,9 @@ public record OrderConfirmed(
}
}
-public record OrderRejected(
- ulong OrderId,
- DateTimeOffset Timestamp,
- string Reason
-) : ISerializableMessage
+public record OrderRejected(ulong OrderId, DateTimeOffset Timestamp, string
Reason) : ISerializableMessage
{
- public string MessageType => Envelope.OrderRejectedType;
+ public string MessageType => Envelope.ORDER_REJECTED_TYPE;
public string ToJson()
{
diff --git
a/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Program.cs
b/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Program.cs
index 219200345..03b39c8c5 100644
---
a/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Program.cs
+++
b/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Program.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git
a/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Utils.cs
b/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Utils.cs
index bdebc69fc..079829ba1 100644
---
a/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Utils.cs
+++
b/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Utils.cs
@@ -100,18 +100,18 @@ public static class Utils
switch (envelope.MessageType)
{
- case Envelope.OrderCreatedType:
+ case Envelope.ORDER_CREATED_TYPE:
var orderCreated =
JsonSerializer.Deserialize<OrderCreated>(envelope.Payload) ??
throw new Exception("Could not deserialize
order_created.");
logger.LogInformation("{OrderCreated}", orderCreated);
break;
- case Envelope.OrderConfirmedType:
+ case Envelope.ORDER_CONFIRMED_TYPE:
var orderConfirmed =
JsonSerializer.Deserialize<OrderConfirmed>(envelope.Payload) ??
throw new Exception("Could not
deserialize order_confirmed.");
logger.LogInformation("{OrderConfirmed}", orderConfirmed);
break;
- case Envelope.OrderRejectedType:
+ case Envelope.ORDER_REJECTED_TYPE:
var orderRejected =
JsonSerializer.Deserialize<OrderRejected>(envelope.Payload) ??
throw new Exception("Could not deserialize
order_rejected.");
logger.LogInformation("{OrderRejected}", orderRejected);
diff --git
a/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Producer/Program.cs
b/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Producer/Program.cs
index 02e45b679..9379ebb67 100644
---
a/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Producer/Program.cs
+++
b/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Producer/Program.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git
a/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Program.cs
b/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Program.cs
index ac6d114b8..1dfdc02df 100644
---
a/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Program.cs
+++
b/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Program.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git
a/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Utils.cs
b/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Utils.cs
index ae03bca2e..2250d3e41 100644
---
a/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Utils.cs
+++
b/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Utils.cs
@@ -101,18 +101,18 @@ public static class Utils
switch (messageType)
{
- case Envelope.OrderCreatedType:
+ case Envelope.ORDER_CREATED_TYPE:
var orderCreated =
JsonSerializer.Deserialize<OrderCreated>(message.Payload) ??
throw new Exception("Could not deserialize
order_created.");
logger.LogInformation("{OrderCreated}", orderCreated);
break;
- case Envelope.OrderConfirmedType:
+ case Envelope.ORDER_CONFIRMED_TYPE:
var orderConfirmed =
JsonSerializer.Deserialize<OrderConfirmed>(message.Payload) ??
throw new Exception("Could not
deserialize order_confirmed.");
logger.LogInformation("{OrderConfirmed}", orderConfirmed);
break;
- case Envelope.OrderRejectedType:
+ case Envelope.ORDER_REJECTED_TYPE:
var orderRejected =
JsonSerializer.Deserialize<OrderRejected>(message.Payload) ??
throw new Exception("Could not deserialize
order_rejected.");
logger.LogInformation("{OrderRejected}", orderRejected);
diff --git
a/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Producer/Program.cs
b/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Producer/Program.cs
index 0fbb1c38b..560666f36 100644
---
a/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Producer/Program.cs
+++
b/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Producer/Program.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git
a/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Program.cs
b/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Program.cs
index c4c0d9806..c1a1a8a7d 100644
--- a/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Program.cs
+++ b/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Program.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git
a/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Utils.cs
b/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Utils.cs
index bbf58c6f0..07831d114 100644
--- a/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Utils.cs
+++ b/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Utils.cs
@@ -45,18 +45,18 @@ public static class Utils
switch (envelope.MessageType)
{
- case Envelope.OrderCreatedType:
+ case Envelope.ORDER_CREATED_TYPE:
var orderCreated =
JsonSerializer.Deserialize<OrderCreated>(envelope.Payload) ??
throw new Exception("Could not deserialize
order_created.");
logger.LogInformation("{OrderCreated}", orderCreated);
break;
- case Envelope.OrderConfirmedType:
+ case Envelope.ORDER_CONFIRMED_TYPE:
var orderConfirmed =
JsonSerializer.Deserialize<OrderConfirmed>(envelope.Payload) ??
throw new Exception("Could not
deserialize order_confirmed.");
logger.LogInformation("{OrderConfirmed}", orderConfirmed);
break;
- case Envelope.OrderRejectedType:
+ case Envelope.ORDER_REJECTED_TYPE:
var orderRejected =
JsonSerializer.Deserialize<OrderRejected>(envelope.Payload) ??
throw new Exception("Could not deserialize
order_rejected.");
logger.LogInformation("{OrderRejected}", orderRejected);
diff --git
a/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Program.cs
b/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Program.cs
index aa03c6d7f..2c4052d91 100644
--- a/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Program.cs
+++ b/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Program.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git
a/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Utils.cs
b/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Utils.cs
index 488493105..1cee63eb1 100644
--- a/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Utils.cs
+++ b/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Utils.cs
@@ -26,13 +26,13 @@ namespace Iggy_SDK.Examples.NewSdk.Producer;
public static class Utils
{
- private const uint BATCHES_LIMIT = 5;
+ private const uint BatchesLimit = 5;
public static async Task ProduceMessages(IggyPublisher publisher, ILogger
logger)
{
var interval = TimeSpan.FromMilliseconds(500);
logger.LogInformation(
- "Messages will be sent to stream: {StreamId}, topic: {TopicId}}
with interval {Interval}.",
+ "Messages will be sent to stream: {StreamId}, topic: {TopicId}
with interval {Interval}",
publisher.StreamId,
publisher.TopicId,
interval
@@ -44,10 +44,10 @@ public static class Utils
while (true)
{
- if (sentBatches == BATCHES_LIMIT)
+ if (sentBatches == BatchesLimit)
{
logger.LogInformation(
- "Sent {SentBatches} batches of messages, exiting.",
+ "Sent {SentBatches} batches of messages, exiting",
sentBatches
);
return;
@@ -74,7 +74,7 @@ public static class Utils
await publisher.SendMessages(messages.ToArray());
sentBatches++;
- logger.LogInformation("Sent messages: {Messages}.",
serializableMessages);
+ logger.LogInformation("Sent messages: {Messages}",
serializableMessages);
await Task.Delay(interval);
}
diff --git a/foreign/csharp/.editorconfig b/foreign/csharp/.editorconfig
index 7fb91e9d1..b5ab0daec 100644
--- a/foreign/csharp/.editorconfig
+++ b/foreign/csharp/.editorconfig
@@ -1,6 +1,6 @@
[*]
charset = utf-8
-end_of_line = crlf
+end_of_line = lf
trim_trailing_whitespace = false
insert_final_newline = true
indent_style = space
diff --git a/foreign/csharp/Iggy_SDK.Tests.BDD/Context/TestContext.cs
b/foreign/csharp/Iggy_SDK.Tests.BDD/Context/TestContext.cs
index 46ffd5f0e..2ae5176cc 100644
--- a/foreign/csharp/Iggy_SDK.Tests.BDD/Context/TestContext.cs
+++ b/foreign/csharp/Iggy_SDK.Tests.BDD/Context/TestContext.cs
@@ -29,4 +29,4 @@ public class TestContext
public TopicResponse? CreatedTopic { get; set; }
public List<MessageResponse> PolledMessages { get; set; } = new();
public Message? LastSendMessage { get; set; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK.Tests.BDD/Context/TestHooks.cs
b/foreign/csharp/Iggy_SDK.Tests.BDD/Context/TestHooks.cs
index d32500518..fa1c4d386 100644
--- a/foreign/csharp/Iggy_SDK.Tests.BDD/Context/TestHooks.cs
+++ b/foreign/csharp/Iggy_SDK.Tests.BDD/Context/TestHooks.cs
@@ -52,4 +52,4 @@ public class TestHooks
{
//
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Configuration/IggyClientConfigurator.cs
b/foreign/csharp/Iggy_SDK/Configuration/IggyClientConfigurator.cs
index 8255fd47c..f75917283 100644
--- a/foreign/csharp/Iggy_SDK/Configuration/IggyClientConfigurator.cs
+++ b/foreign/csharp/Iggy_SDK/Configuration/IggyClientConfigurator.cs
@@ -29,4 +29,4 @@ public sealed class IggyClientConfigurator
public int SendBufferSize { get; set; } = 4096;
public TlsSettings TlsSettings { get; set; } = new();
public ILoggerFactory LoggerFactory { get; set; } =
NullLoggerFactory.Instance;
-}
+}
diff --git a/foreign/csharp/Iggy_SDK/Configuration/MessageBatchingSettings.cs
b/foreign/csharp/Iggy_SDK/Configuration/MessageBatchingSettings.cs
index e2b531388..f5e8c9ef6 100644
--- a/foreign/csharp/Iggy_SDK/Configuration/MessageBatchingSettings.cs
+++ b/foreign/csharp/Iggy_SDK/Configuration/MessageBatchingSettings.cs
@@ -28,4 +28,4 @@ public sealed class MessageBatchingSettings
/// Used mainly to avoid flooding the channel (default value 2056).
/// </summary>
public int MaxRequests { get; set; } = 2056;
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Configuration/MessagePollingSettings.cs
b/foreign/csharp/Iggy_SDK/Configuration/MessagePollingSettings.cs
index cb8a2736b..73c404faf 100644
--- a/foreign/csharp/Iggy_SDK/Configuration/MessagePollingSettings.cs
+++ b/foreign/csharp/Iggy_SDK/Configuration/MessagePollingSettings.cs
@@ -23,4 +23,4 @@ public sealed class MessagePollingSettings
{
public TimeSpan Interval { get; set; }
public StoreOffset StoreOffsetStrategy { get; set; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/ConnectionStream/IConnectionStream.cs
b/foreign/csharp/Iggy_SDK/ConnectionStream/IConnectionStream.cs
index 828b49136..d05a0a86c 100644
--- a/foreign/csharp/Iggy_SDK/ConnectionStream/IConnectionStream.cs
+++ b/foreign/csharp/Iggy_SDK/ConnectionStream/IConnectionStream.cs
@@ -23,4 +23,4 @@ public interface IConnectionStream : IDisposable
ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken
cancellationToken = default);
Task FlushAsync(CancellationToken cancellationToken = default);
void Close();
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/ConnectionStream/TcpTslConnectionStream.cs
b/foreign/csharp/Iggy_SDK/ConnectionStream/TcpTslConnectionStream.cs
index 007dd51d3..db4a36252 100644
--- a/foreign/csharp/Iggy_SDK/ConnectionStream/TcpTslConnectionStream.cs
+++ b/foreign/csharp/Iggy_SDK/ConnectionStream/TcpTslConnectionStream.cs
@@ -52,4 +52,4 @@ public sealed class TcpTlsConnectionStream : IConnectionStream
{
_stream.Dispose();
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Consumers/IggyConsumerBuilderOfT.cs
b/foreign/csharp/Iggy_SDK/Consumers/IggyConsumerBuilderOfT.cs
index d8f595014..a0b2d3a1e 100644
--- a/foreign/csharp/Iggy_SDK/Consumers/IggyConsumerBuilderOfT.cs
+++ b/foreign/csharp/Iggy_SDK/Consumers/IggyConsumerBuilderOfT.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git a/foreign/csharp/Iggy_SDK/Consumers/IggyConsumerOfT.cs
b/foreign/csharp/Iggy_SDK/Consumers/IggyConsumerOfT.cs
index c5aeb17d5..d91e6f510 100644
--- a/foreign/csharp/Iggy_SDK/Consumers/IggyConsumerOfT.cs
+++ b/foreign/csharp/Iggy_SDK/Consumers/IggyConsumerOfT.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Auth/AuthResponse.cs
b/foreign/csharp/Iggy_SDK/Contracts/Auth/AuthResponse.cs
index b40eb5952..a7f865479 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Auth/AuthResponse.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Auth/AuthResponse.cs
@@ -17,4 +17,4 @@
namespace Apache.Iggy.Contracts.Auth;
-public record AuthResponse(int UserId, TokenInfo? AccessToken);
\ No newline at end of file
+public record AuthResponse(int UserId, TokenInfo? AccessToken);
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Auth/GlobalPermissions.cs
b/foreign/csharp/Iggy_SDK/Contracts/Auth/GlobalPermissions.cs
index 052da1ed7..4c69e5711 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Auth/GlobalPermissions.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Auth/GlobalPermissions.cs
@@ -29,4 +29,4 @@ public sealed class GlobalPermissions
public required bool ReadTopics { get; init; }
public required bool PollMessages { get; init; }
public required bool SendMessages { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Auth/Permissions.cs
b/foreign/csharp/Iggy_SDK/Contracts/Auth/Permissions.cs
index caacd19e6..f85f82dab 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Auth/Permissions.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Auth/Permissions.cs
@@ -21,4 +21,4 @@ public sealed class Permissions
{
public required GlobalPermissions Global { get; init; }
public Dictionary<int, StreamPermissions>? Streams { get; init; }
-}
\ No newline at end of file
+}
diff --git
a/foreign/csharp/Iggy_SDK/Contracts/Auth/PersonalAccessTokenResponse.cs
b/foreign/csharp/Iggy_SDK/Contracts/Auth/PersonalAccessTokenResponse.cs
index 9c12094e3..516338e72 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Auth/PersonalAccessTokenResponse.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Auth/PersonalAccessTokenResponse.cs
@@ -26,4 +26,4 @@ public sealed class PersonalAccessTokenResponse
[JsonConverter(typeof(ExpiryConverter))]
public DateTimeOffset? ExpiryAt { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Auth/RawPersonalAccessToken.cs
b/foreign/csharp/Iggy_SDK/Contracts/Auth/RawPersonalAccessToken.cs
index dbe041953..5ff6199d5 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Auth/RawPersonalAccessToken.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Auth/RawPersonalAccessToken.cs
@@ -20,4 +20,4 @@ namespace Apache.Iggy.Contracts.Auth;
public sealed class RawPersonalAccessToken
{
public required string Token { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Auth/TokenInfo.cs
b/foreign/csharp/Iggy_SDK/Contracts/Auth/TokenInfo.cs
index 1534bfe30..4f23c6be0 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Auth/TokenInfo.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Auth/TokenInfo.cs
@@ -26,4 +26,4 @@ public class TokenInfo
[JsonConverter(typeof(ExpiryConverter))]
public required DateTimeOffset? Expiry { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Auth/UserResponse.cs
b/foreign/csharp/Iggy_SDK/Contracts/Auth/UserResponse.cs
index 18096bf46..edc684900 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Auth/UserResponse.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Auth/UserResponse.cs
@@ -26,4 +26,4 @@ public sealed class UserResponse
public required UserStatus Status { get; init; }
public required string Username { get; init; }
public Permissions? Permissions { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/CacheMetrics.cs
b/foreign/csharp/Iggy_SDK/Contracts/CacheMetrics.cs
index 7c558c9e7..a0e409187 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/CacheMetrics.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/CacheMetrics.cs
@@ -22,4 +22,4 @@ public class CacheMetrics
public ulong Hits { get; set; }
public ulong Misses { get; set; }
public float HitRatio { get; set; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/CacheMetricsKey.cs
b/foreign/csharp/Iggy_SDK/Contracts/CacheMetricsKey.cs
index d9924c912..40a9b4131 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/CacheMetricsKey.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/CacheMetricsKey.cs
@@ -47,4 +47,4 @@ public struct CacheMetricsKey : IEquatable<CacheMetricsKey>
{
return !(left == right);
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupInfo.cs
b/foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupInfo.cs
index afe7b559f..78e7d668c 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupInfo.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupInfo.cs
@@ -22,4 +22,4 @@ public sealed class ConsumerGroupInfo
public required int StreamId { get; init; }
public required int TopicId { get; init; }
public required int GroupId { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupMembers.cs
b/foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupMembers.cs
index 526a52c73..dec60e972 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupMembers.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupMembers.cs
@@ -22,4 +22,4 @@ public sealed class ConsumerGroupMember
public required uint Id { get; init; }
public required int PartitionsCount { get; init; }
public required List<int> Partitions { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupResponse.cs
b/foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupResponse.cs
index 3b0a272ba..e02d33c46 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupResponse.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupResponse.cs
@@ -24,4 +24,4 @@ public sealed class ConsumerGroupResponse
public required uint MembersCount { get; init; }
public required uint PartitionsCount { get; init; }
public List<ConsumerGroupMember>? Members { get; init; }
-}
\ No newline at end of file
+}
diff --git
a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/ChangePasswordRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/ChangePasswordRequest.cs
index 6ea7f044a..1bbfc2788 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/ChangePasswordRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/ChangePasswordRequest.cs
@@ -17,4 +17,4 @@
namespace Apache.Iggy.Contracts.Http.Auth;
-internal sealed record ChangePasswordRequest(string CurrentPassword, string
NewPassword);
\ No newline at end of file
+internal sealed record ChangePasswordRequest(string CurrentPassword, string
NewPassword);
diff --git
a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/CreatePersonalAccessTokenRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/CreatePersonalAccessTokenRequest.cs
index c7f2cf289..426aa82a4 100644
---
a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/CreatePersonalAccessTokenRequest.cs
+++
b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/CreatePersonalAccessTokenRequest.cs
@@ -17,4 +17,4 @@
namespace Apache.Iggy.Contracts.Http.Auth;
-internal sealed record CreatePersonalAccessTokenRequest(string Name, ulong?
Expiry);
\ No newline at end of file
+internal sealed record CreatePersonalAccessTokenRequest(string Name, ulong?
Expiry);
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/CreateUserRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/CreateUserRequest.cs
index 62b299c33..a1f6eea0b 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/CreateUserRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/CreateUserRequest.cs
@@ -20,4 +20,4 @@ using Apache.Iggy.Enums;
namespace Apache.Iggy.Contracts.Http.Auth;
-internal sealed record CreateUserRequest(string Username, string Password,
UserStatus Status, Permissions? Permissions);
\ No newline at end of file
+internal sealed record CreateUserRequest(string Username, string Password,
UserStatus Status, Permissions? Permissions);
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/LoginUserRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/LoginUserRequest.cs
index a5bb82a7c..b5f9bcdf8 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/LoginUserRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/LoginUserRequest.cs
@@ -17,4 +17,4 @@
namespace Apache.Iggy.Contracts.Http.Auth;
-internal sealed record LoginUserRequest(string Username, string Password,
string? Version, string? Context);
\ No newline at end of file
+internal sealed record LoginUserRequest(string Username, string Password,
string? Version, string? Context);
diff --git
a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/LoginWIthPersonalAccessTokenRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/LoginWIthPersonalAccessTokenRequest.cs
index c23c845a9..40744f319 100644
---
a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/LoginWIthPersonalAccessTokenRequest.cs
+++
b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/LoginWIthPersonalAccessTokenRequest.cs
@@ -17,4 +17,4 @@
namespace Apache.Iggy.Contracts.Http.Auth;
-internal sealed record LoginWithPersonalAccessTokenRequest(string Token);
\ No newline at end of file
+internal sealed record LoginWithPersonalAccessTokenRequest(string Token);
diff --git
a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/UpdateUserPermissionsRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/UpdateUserPermissionsRequest.cs
index ee9ee0b37..10973b25e 100644
---
a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/UpdateUserPermissionsRequest.cs
+++
b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/UpdateUserPermissionsRequest.cs
@@ -19,4 +19,4 @@ using Apache.Iggy.Contracts.Auth;
namespace Apache.Iggy.Contracts.Http.Auth;
-internal sealed record UpdateUserPermissionsRequest(Permissions? Permissions);
\ No newline at end of file
+internal sealed record UpdateUserPermissionsRequest(Permissions? Permissions);
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/UpdateUserRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/UpdateUserRequest.cs
index 8bc665850..7ef9c59f6 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/UpdateUserRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Http/Auth/UpdateUserRequest.cs
@@ -19,4 +19,4 @@ using Apache.Iggy.Enums;
namespace Apache.Iggy.Contracts.Http.Auth;
-internal sealed record UpdateUserRequest(string? Username, UserStatus?
UserStatus);
\ No newline at end of file
+internal sealed record UpdateUserRequest(string? Username, UserStatus?
UserStatus);
diff --git
a/foreign/csharp/Iggy_SDK/Contracts/Http/CreateConsumerGroupRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/CreateConsumerGroupRequest.cs
index 594b60dd4..fde15bd9e 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Http/CreateConsumerGroupRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Http/CreateConsumerGroupRequest.cs
@@ -17,4 +17,4 @@
namespace Apache.Iggy.Contracts.Http;
-internal sealed record CreateConsumerGroupRequest(string Name, uint?
ConsumerGroupId);
\ No newline at end of file
+internal sealed record CreateConsumerGroupRequest(string Name, uint?
ConsumerGroupId);
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Http/CreatePartitionsRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/CreatePartitionsRequest.cs
index d9a231f8c..661da61f7 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Http/CreatePartitionsRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Http/CreatePartitionsRequest.cs
@@ -17,4 +17,4 @@
namespace Apache.Iggy.Contracts.Http;
-internal sealed record CreatePartitionsRequest(uint PartitionsCount);
\ No newline at end of file
+internal sealed record CreatePartitionsRequest(uint PartitionsCount);
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Http/CreateStreamRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/CreateStreamRequest.cs
index f83e6a0dc..31fe06957 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Http/CreateStreamRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Http/CreateStreamRequest.cs
@@ -17,4 +17,4 @@
namespace Apache.Iggy.Contracts.Http;
-internal sealed record CreateStreamRequest(uint? StreamId, string Name);
\ No newline at end of file
+internal sealed record CreateStreamRequest(uint? StreamId, string Name);
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Http/CreateTopicRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/CreateTopicRequest.cs
index fd81621fa..f64204856 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Http/CreateTopicRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Http/CreateTopicRequest.cs
@@ -51,4 +51,4 @@ internal sealed class CreateTopicRequest
ReplicationFactor = replicationFactor;
MaxTopicSize = maxTopicSize;
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Http/StoreOffsetRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/StoreOffsetRequest.cs
index e43d98010..b03e63a11 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Http/StoreOffsetRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Http/StoreOffsetRequest.cs
@@ -19,4 +19,4 @@ using Apache.Iggy.Kinds;
namespace Apache.Iggy.Contracts.Http;
-internal sealed record StoreOffsetRequest(Consumer Consumer, uint?
PartitionId, ulong Offset);
\ No newline at end of file
+internal sealed record StoreOffsetRequest(Consumer Consumer, uint?
PartitionId, ulong Offset);
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Http/UpdateStreamRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/UpdateStreamRequest.cs
index 1f6d89d93..09f602bbd 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Http/UpdateStreamRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Http/UpdateStreamRequest.cs
@@ -17,4 +17,4 @@
namespace Apache.Iggy.Contracts.Http;
-internal sealed record UpdateStreamRequest(string Name);
\ No newline at end of file
+internal sealed record UpdateStreamRequest(string Name);
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Http/UpdateTopicRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/Http/UpdateTopicRequest.cs
index 5b1c47ab7..8e5daffe1 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Http/UpdateTopicRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Http/UpdateTopicRequest.cs
@@ -24,4 +24,4 @@ internal record UpdateTopicRequest(
CompressionAlgorithm CompressionAlgorithm,
ulong MaxTopicSize,
ulong MessageExpiry,
- byte? ReplicationFactor);
\ No newline at end of file
+ byte? ReplicationFactor);
diff --git a/foreign/csharp/Iggy_SDK/Contracts/MessageSendRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/MessageSendRequest.cs
index 09fc6eacf..14d425ff4 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/MessageSendRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/MessageSendRequest.cs
@@ -29,4 +29,4 @@ public sealed class MessageSendRequest
public required Identifier TopicId { get; init; }
public required Partitioning Partitioning { get; init; }
public required IList<Message> Messages { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/MessageSendRequestGeneric.cs
b/foreign/csharp/Iggy_SDK/Contracts/MessageSendRequestGeneric.cs
index 744e56d29..e0784ccf8 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/MessageSendRequestGeneric.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/MessageSendRequestGeneric.cs
@@ -25,4 +25,4 @@ public sealed class MessageSendRequest<TMessage>
public required Identifier TopicId { get; init; }
public required Partitioning Partitioning { get; init; }
public required IList<TMessage> Messages { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/OffsetResponse.cs
b/foreign/csharp/Iggy_SDK/Contracts/OffsetResponse.cs
index d4213b91b..10a9e8ed3 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/OffsetResponse.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/OffsetResponse.cs
@@ -22,4 +22,4 @@ public sealed class OffsetResponse
public required int PartitionId { get; init; }
public required ulong CurrentOffset { get; init; }
public required ulong StoredOffset { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/PartitionResponse.cs
b/foreign/csharp/Iggy_SDK/Contracts/PartitionResponse.cs
index 730c25092..947c0d29f 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/PartitionResponse.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/PartitionResponse.cs
@@ -33,4 +33,4 @@ public sealed class PartitionResponse
[JsonConverter(typeof(SizeConverter))]
public required ulong Size { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/PollMessagesRequest.cs
b/foreign/csharp/Iggy_SDK/Contracts/PollMessagesRequest.cs
index 65ad9a11d..3a7ae78d0 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/PollMessagesRequest.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/PollMessagesRequest.cs
@@ -27,4 +27,4 @@ public sealed class PollMessagesRequest
public required uint PartitionId { get; init; }
public required PollingStrategy PollingStrategy { get; set; }
public required int Count { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/PolledMessagesGeneric.cs
b/foreign/csharp/Iggy_SDK/Contracts/PolledMessagesGeneric.cs
index 87ff90674..78dc2ca1d 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/PolledMessagesGeneric.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/PolledMessagesGeneric.cs
@@ -30,4 +30,4 @@ public sealed class PolledMessages<T>
CurrentOffset = 0,
PartitionId = 0
};
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs
b/foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs
index 029f4d95f..af159c8bf 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs
@@ -64,4 +64,4 @@ public sealed class StatsResponse
public required string IggyServerVersion { get; init; }
public uint IggyServerSemver { get; init; }
public Dictionary<CacheMetricsKey, CacheMetrics> CacheMetrics { get; init;
} = [];
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/StreamPermissions.cs
b/foreign/csharp/Iggy_SDK/Contracts/StreamPermissions.cs
index 040849225..8afe52e24 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/StreamPermissions.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/StreamPermissions.cs
@@ -26,4 +26,4 @@ public sealed class StreamPermissions
public required bool PollMessages { get; init; }
public required bool SendMessages { get; init; }
public Dictionary<int, TopicPermissions>? Topics { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/StreamResponse.cs
b/foreign/csharp/Iggy_SDK/Contracts/StreamResponse.cs
index f36c005bd..6d8c5e060 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/StreamResponse.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/StreamResponse.cs
@@ -35,4 +35,4 @@ public sealed class StreamResponse
public required ulong MessagesCount { get; init; }
public required int TopicsCount { get; init; }
public IEnumerable<TopicResponse> Topics { get; init; } = [];
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs
b/foreign/csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs
index 2ea87b7a7..95a6e3fa2 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs
@@ -749,7 +749,7 @@ internal static class TcpContracts
bytes.WriteBytesFromIdentifier(consumer.Id, 1);
var position = 1 + consumer.Id.Length + 2;
bytes.WriteBytesFromStreamAndTopicIdentifiers(streamId, topicId,
position);
- position += + 2 + streamId.Length + 2 + topicId.Length;
+ position += +2 + streamId.Length + 2 + topicId.Length;
BinaryPrimitives.WriteUInt32LittleEndian(bytes[position..(position +
4)], partitionId ?? 0);
return bytes.ToArray();
}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/TopicPermissions.cs
b/foreign/csharp/Iggy_SDK/Contracts/TopicPermissions.cs
index 68fa07546..1cb90cd0d 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/TopicPermissions.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/TopicPermissions.cs
@@ -23,4 +23,4 @@ public sealed class TopicPermissions
public required bool ReadTopic { get; init; }
public required bool PollMessages { get; init; }
public required bool SendMessages { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Contracts/TopicResponse.cs
b/foreign/csharp/Iggy_SDK/Contracts/TopicResponse.cs
index 66d8dfe99..eb8c7de6a 100644
--- a/foreign/csharp/Iggy_SDK/Contracts/TopicResponse.cs
+++ b/foreign/csharp/Iggy_SDK/Contracts/TopicResponse.cs
@@ -41,4 +41,4 @@ public sealed class TopicResponse
public required uint PartitionsCount { get; init; }
public required byte? ReplicationFactor { get; init; }
public IEnumerable<PartitionResponse>? Partitions { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Enums/CompressionAlgorithm.cs
b/foreign/csharp/Iggy_SDK/Enums/CompressionAlgorithm.cs
index bf259da69..2c4706c9b 100644
--- a/foreign/csharp/Iggy_SDK/Enums/CompressionAlgorithm.cs
+++ b/foreign/csharp/Iggy_SDK/Enums/CompressionAlgorithm.cs
@@ -29,4 +29,4 @@ public enum CompressionAlgorithm
// Gzip compression algorithm
Gzip = 2
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Enums/ConsumerType.cs
b/foreign/csharp/Iggy_SDK/Enums/ConsumerType.cs
index df490ea79..ae810d5f7 100644
--- a/foreign/csharp/Iggy_SDK/Enums/ConsumerType.cs
+++ b/foreign/csharp/Iggy_SDK/Enums/ConsumerType.cs
@@ -21,4 +21,4 @@ public enum ConsumerType
{
Consumer,
ConsumerGroup
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Enums/IdKind.cs
b/foreign/csharp/Iggy_SDK/Enums/IdKind.cs
index ff1b8db48..ac5d85563 100644
--- a/foreign/csharp/Iggy_SDK/Enums/IdKind.cs
+++ b/foreign/csharp/Iggy_SDK/Enums/IdKind.cs
@@ -50,4 +50,4 @@ internal static class Extensions
_ => throw new ArgumentOutOfRangeException(nameof(kind), kind,
null)
};
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Enums/MessagePolling.cs
b/foreign/csharp/Iggy_SDK/Enums/MessagePolling.cs
index 95f4e2176..ae8dc7575 100644
--- a/foreign/csharp/Iggy_SDK/Enums/MessagePolling.cs
+++ b/foreign/csharp/Iggy_SDK/Enums/MessagePolling.cs
@@ -29,4 +29,4 @@ public enum MessagePolling
First,
Last,
Next
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Enums/MessageState.cs
b/foreign/csharp/Iggy_SDK/Enums/MessageState.cs
index 2cfcedb70..bab894c47 100644
--- a/foreign/csharp/Iggy_SDK/Enums/MessageState.cs
+++ b/foreign/csharp/Iggy_SDK/Enums/MessageState.cs
@@ -23,4 +23,4 @@ public enum MessageState
Unavailable,
Poisoned,
MarkedForDeletion
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs
b/foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs
index fd10dbb15..2222b5686 100644
--- a/foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs
+++ b/foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs
@@ -23,4 +23,4 @@ public enum Partitioning
Balanced = 1,
PartitionId = 2,
MessageKey = 3
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Enums/Protocol.cs
b/foreign/csharp/Iggy_SDK/Enums/Protocol.cs
index b4da8af77..d48e9beca 100644
--- a/foreign/csharp/Iggy_SDK/Enums/Protocol.cs
+++ b/foreign/csharp/Iggy_SDK/Enums/Protocol.cs
@@ -22,4 +22,4 @@ public enum Protocol
Http,
Tcp,
Quic
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Enums/SnapshotCompression.cs
b/foreign/csharp/Iggy_SDK/Enums/SnapshotCompression.cs
index 40858b9ae..dcb853556 100644
--- a/foreign/csharp/Iggy_SDK/Enums/SnapshotCompression.cs
+++ b/foreign/csharp/Iggy_SDK/Enums/SnapshotCompression.cs
@@ -39,4 +39,4 @@ public enum SnapshotCompression
/// Compress the file using XZ
Xz
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Enums/StoreOffset.cs
b/foreign/csharp/Iggy_SDK/Enums/StoreOffset.cs
index 688d1b49d..6b86ddf36 100644
--- a/foreign/csharp/Iggy_SDK/Enums/StoreOffset.cs
+++ b/foreign/csharp/Iggy_SDK/Enums/StoreOffset.cs
@@ -22,4 +22,4 @@ public enum StoreOffset
Never,
WhenMessagesAreReceived,
AfterProcessingEachMessage
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Enums/SystemSnapshotType.cs
b/foreign/csharp/Iggy_SDK/Enums/SystemSnapshotType.cs
index 97ee4d793..51c0e9db0 100644
--- a/foreign/csharp/Iggy_SDK/Enums/SystemSnapshotType.cs
+++ b/foreign/csharp/Iggy_SDK/Enums/SystemSnapshotType.cs
@@ -42,4 +42,4 @@ public enum SystemSnapshotType
/// Everything
All
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Enums/UserStatus.cs
b/foreign/csharp/Iggy_SDK/Enums/UserStatus.cs
index fe1c85d56..218e0915b 100644
--- a/foreign/csharp/Iggy_SDK/Enums/UserStatus.cs
+++ b/foreign/csharp/Iggy_SDK/Enums/UserStatus.cs
@@ -21,4 +21,4 @@ public enum UserStatus
{
Active = 1,
Inactive = 2
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Errors/ErrorFactory.cs
b/foreign/csharp/Iggy_SDK/Errors/ErrorFactory.cs
index 5d6fea360..2ed617e21 100644
--- a/foreign/csharp/Iggy_SDK/Errors/ErrorFactory.cs
+++ b/foreign/csharp/Iggy_SDK/Errors/ErrorFactory.cs
@@ -379,4 +379,4 @@ internal static class ErrorFactory
{
return new ErrorModel(82, "client_not_found", $"Client with ID:
{clientId} was not found.");
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Errors/ErrorModel.cs
b/foreign/csharp/Iggy_SDK/Errors/ErrorModel.cs
index bf5d5190f..a00f65cd4 100644
--- a/foreign/csharp/Iggy_SDK/Errors/ErrorModel.cs
+++ b/foreign/csharp/Iggy_SDK/Errors/ErrorModel.cs
@@ -29,4 +29,4 @@ public sealed class ErrorModel
Code = code;
Reason = reason;
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Exceptions/FeatureUnavailableException.cs
b/foreign/csharp/Iggy_SDK/Exceptions/FeatureUnavailableException.cs
index bdbae51a9..2de5f8712 100644
--- a/foreign/csharp/Iggy_SDK/Exceptions/FeatureUnavailableException.cs
+++ b/foreign/csharp/Iggy_SDK/Exceptions/FeatureUnavailableException.cs
@@ -22,4 +22,4 @@ public sealed class FeatureUnavailableException : Exception
public FeatureUnavailableException() : base("This feature is not
available.")
{
}
-}
\ No newline at end of file
+}
diff --git
a/foreign/csharp/Iggy_SDK/Exceptions/InvalidConsumerGroupNameException.cs
b/foreign/csharp/Iggy_SDK/Exceptions/InvalidConsumerGroupNameException.cs
index 8969e949a..6452a2d57 100644
--- a/foreign/csharp/Iggy_SDK/Exceptions/InvalidConsumerGroupNameException.cs
+++ b/foreign/csharp/Iggy_SDK/Exceptions/InvalidConsumerGroupNameException.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git a/foreign/csharp/Iggy_SDK/Exceptions/InvalidResponseException.cs
b/foreign/csharp/Iggy_SDK/Exceptions/InvalidResponseException.cs
index 0feba4672..ea7f5d38a 100644
--- a/foreign/csharp/Iggy_SDK/Exceptions/InvalidResponseException.cs
+++ b/foreign/csharp/Iggy_SDK/Exceptions/InvalidResponseException.cs
@@ -22,4 +22,4 @@ public sealed class InvalidResponseException : Exception
internal InvalidResponseException(string message) : base(message)
{
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Exceptions/TcpInvalidResponseException.cs
b/foreign/csharp/Iggy_SDK/Exceptions/TcpInvalidResponseException.cs
index 0e978057d..6e04c7dbb 100644
--- a/foreign/csharp/Iggy_SDK/Exceptions/TcpInvalidResponseException.cs
+++ b/foreign/csharp/Iggy_SDK/Exceptions/TcpInvalidResponseException.cs
@@ -22,4 +22,4 @@ public sealed class TcpInvalidResponseException : Exception
public TcpInvalidResponseException() : base("Received an Invalid Response")
{
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Exceptions/TcpInvalidStatus.cs
b/foreign/csharp/Iggy_SDK/Exceptions/TcpInvalidStatus.cs
index e879c755c..534e6050d 100644
--- a/foreign/csharp/Iggy_SDK/Exceptions/TcpInvalidStatus.cs
+++ b/foreign/csharp/Iggy_SDK/Exceptions/TcpInvalidStatus.cs
@@ -22,4 +22,4 @@ internal sealed class TcpInvalidStatus : Exception
internal TcpInvalidStatus() : base("Received an Invalid Response Status")
{
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Extensions/Extensions.cs
b/foreign/csharp/Iggy_SDK/Extensions/Extensions.cs
index 3fcd45e42..3e2063a3c 100644
--- a/foreign/csharp/Iggy_SDK/Extensions/Extensions.cs
+++ b/foreign/csharp/Iggy_SDK/Extensions/Extensions.cs
@@ -111,4 +111,4 @@ internal static class DateTimeOffsetUtils
{
return (ulong)(date.ToUnixTimeMilliseconds() * 1000);
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Headers/HeaderKey.cs
b/foreign/csharp/Iggy_SDK/Headers/HeaderKey.cs
index bec7da9f9..f2989cd66 100644
--- a/foreign/csharp/Iggy_SDK/Headers/HeaderKey.cs
+++ b/foreign/csharp/Iggy_SDK/Headers/HeaderKey.cs
@@ -64,4 +64,4 @@ public readonly struct HeaderKey : IEquatable<HeaderKey>
{
return !left.Equals(right);
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Headers/HeaderKind.cs
b/foreign/csharp/Iggy_SDK/Headers/HeaderKind.cs
index 909dc9e2e..2cbd94a98 100644
--- a/foreign/csharp/Iggy_SDK/Headers/HeaderKind.cs
+++ b/foreign/csharp/Iggy_SDK/Headers/HeaderKind.cs
@@ -30,4 +30,4 @@ public enum HeaderKind
Uint128,
Float,
Double
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Headers/HeaderValue.cs
b/foreign/csharp/Iggy_SDK/Headers/HeaderValue.cs
index 2e50e2606..b84fb642d 100644
--- a/foreign/csharp/Iggy_SDK/Headers/HeaderValue.cs
+++ b/foreign/csharp/Iggy_SDK/Headers/HeaderValue.cs
@@ -280,4 +280,4 @@ public readonly struct HeaderValue
return BitConverter.ToDouble(Value);
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/IggyClient/IIggyOffset.cs
b/foreign/csharp/Iggy_SDK/IggyClient/IIggyOffset.cs
index 3b6931c78..e7d240f75 100644
--- a/foreign/csharp/Iggy_SDK/IggyClient/IIggyOffset.cs
+++ b/foreign/csharp/Iggy_SDK/IggyClient/IIggyOffset.cs
@@ -30,4 +30,4 @@ public interface IIggyOffset
Task DeleteOffsetAsync(Consumer consumer, Identifier streamId, Identifier
topicId, uint? partitionId,
CancellationToken token = default);
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/IggyClient/IIggyPartition.cs
b/foreign/csharp/Iggy_SDK/IggyClient/IIggyPartition.cs
index b524a0c6b..da84be847 100644
--- a/foreign/csharp/Iggy_SDK/IggyClient/IIggyPartition.cs
+++ b/foreign/csharp/Iggy_SDK/IggyClient/IIggyPartition.cs
@@ -24,4 +24,4 @@ public interface IIggyPartition
Task CreatePartitionsAsync(Identifier streamId, Identifier topicId, uint
partitionsCount,
CancellationToken token = default);
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/IggyClient/IIggyPersonalAccessToken.cs
b/foreign/csharp/Iggy_SDK/IggyClient/IIggyPersonalAccessToken.cs
index aac7e8e87..a04ae067c 100644
--- a/foreign/csharp/Iggy_SDK/IggyClient/IIggyPersonalAccessToken.cs
+++ b/foreign/csharp/Iggy_SDK/IggyClient/IIggyPersonalAccessToken.cs
@@ -28,4 +28,4 @@ public interface IIggyPersonalAccessToken
Task DeletePersonalAccessTokenAsync(string name, CancellationToken token =
default);
Task<AuthResponse?> LoginWithPersonalAccessToken(string token,
CancellationToken ct = default);
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/IggyClient/IIggyStream.cs
b/foreign/csharp/Iggy_SDK/IggyClient/IIggyStream.cs
index 18cc64563..203d91886 100644
--- a/foreign/csharp/Iggy_SDK/IggyClient/IIggyStream.cs
+++ b/foreign/csharp/Iggy_SDK/IggyClient/IIggyStream.cs
@@ -27,4 +27,4 @@ public interface IIggyStream
Task<IReadOnlyList<StreamResponse>> GetStreamsAsync(CancellationToken
token = default);
Task PurgeStreamAsync(Identifier streamId, CancellationToken token =
default);
Task DeleteStreamAsync(Identifier streamId, CancellationToken token =
default);
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/IggyClient/IIggySystem.cs
b/foreign/csharp/Iggy_SDK/IggyClient/IIggySystem.cs
index 5fcf20047..990301bcf 100644
--- a/foreign/csharp/Iggy_SDK/IggyClient/IIggySystem.cs
+++ b/foreign/csharp/Iggy_SDK/IggyClient/IIggySystem.cs
@@ -26,4 +26,4 @@ public interface IIggySystem
Task<ClientResponse?> GetMeAsync(CancellationToken token = default);
Task<StatsResponse?> GetStatsAsync(CancellationToken token = default);
Task PingAsync(CancellationToken token = default);
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/IggyClient/IIggyTopic.cs
b/foreign/csharp/Iggy_SDK/IggyClient/IIggyTopic.cs
index 3db5a1c3e..c48d5f0ec 100644
--- a/foreign/csharp/Iggy_SDK/IggyClient/IIggyTopic.cs
+++ b/foreign/csharp/Iggy_SDK/IggyClient/IIggyTopic.cs
@@ -36,4 +36,4 @@ public interface IIggyTopic
Task DeleteTopicAsync(Identifier streamId, Identifier topicId,
CancellationToken token = default);
Task PurgeTopicAsync(Identifier streamId, Identifier topicId,
CancellationToken token = default);
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/IggyClient/IIggyUsers.cs
b/foreign/csharp/Iggy_SDK/IggyClient/IIggyUsers.cs
index 980454304..69c5f3373 100644
--- a/foreign/csharp/Iggy_SDK/IggyClient/IIggyUsers.cs
+++ b/foreign/csharp/Iggy_SDK/IggyClient/IIggyUsers.cs
@@ -40,4 +40,4 @@ public interface IIggyUsers
Task<AuthResponse?> LoginUser(string userName, string password,
CancellationToken token = default);
Task LogoutUser(CancellationToken token = default);
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/JsonConverters/DateTimeOffsetConverter.cs
b/foreign/csharp/Iggy_SDK/JsonConverters/DateTimeOffsetConverter.cs
index 5b6d97af1..a8fa16801 100644
--- a/foreign/csharp/Iggy_SDK/JsonConverters/DateTimeOffsetConverter.cs
+++ b/foreign/csharp/Iggy_SDK/JsonConverters/DateTimeOffsetConverter.cs
@@ -37,4 +37,4 @@ internal sealed class DateTimeOffsetConverter :
JsonConverter<DateTimeOffset>
{
writer.WriteNumberValue(DateTimeOffsetUtils.ToUnixTimeMicroSeconds(value));
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/JsonConverters/ExpiryConverter.cs
b/foreign/csharp/Iggy_SDK/JsonConverters/ExpiryConverter.cs
index 7b4faae58..e9285636c 100644
--- a/foreign/csharp/Iggy_SDK/JsonConverters/ExpiryConverter.cs
+++ b/foreign/csharp/Iggy_SDK/JsonConverters/ExpiryConverter.cs
@@ -38,4 +38,4 @@ internal class ExpiryConverter :
JsonConverter<DateTimeOffset?>
{
throw new NotImplementedException();
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/JsonConverters/HeaderKeyConverter.cs
b/foreign/csharp/Iggy_SDK/JsonConverters/HeaderKeyConverter.cs
index 8f8c0b6c9..8221796d5 100644
--- a/foreign/csharp/Iggy_SDK/JsonConverters/HeaderKeyConverter.cs
+++ b/foreign/csharp/Iggy_SDK/JsonConverters/HeaderKeyConverter.cs
@@ -43,4 +43,4 @@ internal class HeaderKeyConverter : JsonConverter<HeaderKey>
{
writer.WritePropertyName(value.Value);
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/JsonConverters/MessageConverter.cs
b/foreign/csharp/Iggy_SDK/JsonConverters/MessageConverter.cs
index 9c405acff..6e346057d 100644
--- a/foreign/csharp/Iggy_SDK/JsonConverters/MessageConverter.cs
+++ b/foreign/csharp/Iggy_SDK/JsonConverters/MessageConverter.cs
@@ -90,4 +90,4 @@ internal sealed class MessageConverter :
JsonConverter<Message>
_ => throw new ArgumentOutOfRangeException(nameof(kind), kind,
"Invalid header kind")
};
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/JsonConverters/MessagesConverter.cs
b/foreign/csharp/Iggy_SDK/JsonConverters/MessagesConverter.cs
index 403edf5b1..46430d416 100644
--- a/foreign/csharp/Iggy_SDK/JsonConverters/MessagesConverter.cs
+++ b/foreign/csharp/Iggy_SDK/JsonConverters/MessagesConverter.cs
@@ -76,4 +76,4 @@ internal sealed class MessagesConverter :
JsonConverter<MessageSendRequest>
writer.WriteEndArray();
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/JsonConverters/SizeConverter.cs
b/foreign/csharp/Iggy_SDK/JsonConverters/SizeConverter.cs
index 1618428cb..4a3a5a635 100644
--- a/foreign/csharp/Iggy_SDK/JsonConverters/SizeConverter.cs
+++ b/foreign/csharp/Iggy_SDK/JsonConverters/SizeConverter.cs
@@ -65,4 +65,4 @@ internal class SizeConverter : JsonConverter<ulong>
{
return float.Parse(value, NumberStyles.AllowExponent |
NumberStyles.Number, CultureInfo.InvariantCulture);
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Kinds/Consumer.cs
b/foreign/csharp/Iggy_SDK/Kinds/Consumer.cs
index ec4c03735..15e24931a 100644
--- a/foreign/csharp/Iggy_SDK/Kinds/Consumer.cs
+++ b/foreign/csharp/Iggy_SDK/Kinds/Consumer.cs
@@ -59,4 +59,4 @@ public readonly struct Consumer
Type = ConsumerType.ConsumerGroup
};
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Kinds/Partitioning.cs
b/foreign/csharp/Iggy_SDK/Kinds/Partitioning.cs
index 66e94c7cc..a2ab22e2d 100644
--- a/foreign/csharp/Iggy_SDK/Kinds/Partitioning.cs
+++ b/foreign/csharp/Iggy_SDK/Kinds/Partitioning.cs
@@ -113,4 +113,4 @@ public readonly struct Partitioning
Value = bytes
};
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs
b/foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs
index 1eda3b531..a42112cc8 100644
--- a/foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs
+++ b/foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs
@@ -226,12 +226,12 @@ internal static class BinaryMapper
var readBytes = 4 + 8 + 1 + 1 + usernameLength;
return (new UserResponse
- {
- Id = id,
- CreatedAt = createdAt,
- Status = userStatus,
- Username = username
- },
+ {
+ Id = id,
+ CreatedAt = createdAt,
+ Status = userStatus,
+ Username = username
+ },
readBytes);
}
@@ -870,11 +870,11 @@ internal static class BinaryMapper
}
return (new ConsumerGroupMember
- {
- Id = id,
- PartitionsCount = partitionsCount,
- Partitions = partitions
- },
+ {
+ Id = id,
+ PartitionsCount = partitionsCount,
+ Partitions = partitions
+ },
8 + partitionsCount * 4);
}
diff --git a/foreign/csharp/Iggy_SDK/Publishers/IggyPublisherBuilder.cs
b/foreign/csharp/Iggy_SDK/Publishers/IggyPublisherBuilder.cs
index 09eea1806..a36161e2f 100644
--- a/foreign/csharp/Iggy_SDK/Publishers/IggyPublisherBuilder.cs
+++ b/foreign/csharp/Iggy_SDK/Publishers/IggyPublisherBuilder.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git a/foreign/csharp/Iggy_SDK/Publishers/IggyPublisherConfig.cs
b/foreign/csharp/Iggy_SDK/Publishers/IggyPublisherConfig.cs
index a064b6bcc..bf7dafc1f 100644
--- a/foreign/csharp/Iggy_SDK/Publishers/IggyPublisherConfig.cs
+++ b/foreign/csharp/Iggy_SDK/Publishers/IggyPublisherConfig.cs
@@ -1,4 +1,4 @@
-// Licensed to the Apache Software Foundation (ASF) under one
+// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
diff --git
a/foreign/csharp/Iggy_SDK/StringHandlers/MessageRequestInterpolationHandler.cs
b/foreign/csharp/Iggy_SDK/StringHandlers/MessageRequestInterpolationHandler.cs
index f32000b4e..0d85fb251 100644
---
a/foreign/csharp/Iggy_SDK/StringHandlers/MessageRequestInterpolationHandler.cs
+++
b/foreign/csharp/Iggy_SDK/StringHandlers/MessageRequestInterpolationHandler.cs
@@ -40,19 +40,19 @@ internal ref struct MessageRequestInterpolationHandler
switch (t)
{
case MessagePolling pollingStrat:
- {
- var str = pollingStrat switch
{
- MessagePolling.Offset => "offset",
- MessagePolling.Timestamp => "timestamp",
- MessagePolling.First => "first",
- MessagePolling.Last => "last",
- MessagePolling.Next => "next",
- _ => throw new ArgumentOutOfRangeException()
- };
- _innerHandler.AppendFormatted(str);
- break;
- }
+ var str = pollingStrat switch
+ {
+ MessagePolling.Offset => "offset",
+ MessagePolling.Timestamp => "timestamp",
+ MessagePolling.First => "first",
+ MessagePolling.Last => "last",
+ MessagePolling.Next => "next",
+ _ => throw new ArgumentOutOfRangeException()
+ };
+ _innerHandler.AppendFormatted(str);
+ break;
+ }
case bool tBool:
_innerHandler.AppendFormatted(tBool.ToString().ToLower());
break;
@@ -71,4 +71,4 @@ internal ref struct MessageRequestInterpolationHandler
{
return _innerHandler.ToStringAndClear();
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs
b/foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs
index eb7fa9e5b..9025cfca9 100644
--- a/foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs
+++ b/foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs
@@ -64,4 +64,4 @@ internal static class CommandCodes
internal const int DELETE_CONSUMER_GROUP_CODE = 603;
internal const int JOIN_CONSUMER_GROUP_CODE = 604;
internal const int LEAVE_CONSUMER_GROUP_CODE = 605;
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Usings.cs
b/foreign/csharp/Iggy_SDK_Tests/Usings.cs
index aa880e0f3..32c527781 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Usings.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Usings.cs
@@ -15,4 +15,4 @@
// specific language governing permissions and limitations
// under the License.
-global using Xunit;
\ No newline at end of file
+global using Xunit;
diff --git a/foreign/csharp/Iggy_SDK_Tests/UtilityTests/HeaderValueTests.cs
b/foreign/csharp/Iggy_SDK_Tests/UtilityTests/HeaderValueTests.cs
index fb5d816e6..e3f4cd40d 100644
--- a/foreign/csharp/Iggy_SDK_Tests/UtilityTests/HeaderValueTests.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/UtilityTests/HeaderValueTests.cs
@@ -543,4 +543,4 @@ public sealed class HeaderValueTests
// Act and Assert
Assert.Throws<InvalidOperationException>(() => headerValue.ToGuid());
}
-}
\ No newline at end of file
+}
diff --git
a/foreign/csharp/Iggy_SDK_Tests/UtilityTests/IdentifiersByteSerializationTests.cs
b/foreign/csharp/Iggy_SDK_Tests/UtilityTests/IdentifiersByteSerializationTests.cs
index 809c1f73a..478b184d3 100644
---
a/foreign/csharp/Iggy_SDK_Tests/UtilityTests/IdentifiersByteSerializationTests.cs
+++
b/foreign/csharp/Iggy_SDK_Tests/UtilityTests/IdentifiersByteSerializationTests.cs
@@ -45,4 +45,4 @@ public sealed class IdentifiersByteSerializationTests
var val = Enumerable.Range(0, 500).Select(x => (byte)x).ToArray();
Assert.Throws<ArgumentException>(() =>
Partitioning.EntityIdBytes(val));
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/BinaryFactory.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/BinaryFactory.cs
index bd51e15fb..daa787552 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/BinaryFactory.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/BinaryFactory.cs
@@ -181,4 +181,4 @@ internal sealed class BinaryFactory
return bytes;
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/DummyObj/DummyMessage.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/DummyObj/DummyMessage.cs
index 28ff9b8cc..143fe07c3 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/DummyObj/DummyMessage.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/DummyObj/DummyMessage.cs
@@ -21,4 +21,4 @@ public sealed class DummyMessage
{
public int Id { get; set; }
public required string Text { get; set; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/DummyObj/DummyObjFactory.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/DummyObj/DummyObjFactory.cs
index fe300c5f7..877981b01 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/DummyObj/DummyObjFactory.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/DummyObj/DummyObjFactory.cs
@@ -29,4 +29,4 @@ internal static class DummyObjFactory
Text = "TROLOLOLO" + Random.Shared.Next(1, 5)
};
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/Errors/ErrorModelFactory.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/Errors/ErrorModelFactory.cs
index bba155792..137a2bb2d 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/Errors/ErrorModelFactory.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/Errors/ErrorModelFactory.cs
@@ -30,4 +30,4 @@ public static class ErrorModelFactory
{
return new ErrorModel(69, "not_found", "Not Found");
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/Groups/GroupFactory.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/Groups/GroupFactory.cs
index f37fbfb8a..9f8564e29 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/Groups/GroupFactory.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/Groups/GroupFactory.cs
@@ -27,4 +27,4 @@ internal static class ConsumerGroupFactory
var name = Utility.RandomString(69);
return (id1, membersCount1, partitionsCount1, name);
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/PriorityOrderer.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/PriorityOrderer.cs
index 225c6e14b..389d9c6e0 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/PriorityOrderer.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/PriorityOrderer.cs
@@ -66,4 +66,4 @@ public class PriorityOrderer : ITestCaseOrderer
return result;
}
-}
\ No newline at end of file
+}
diff --git
a/foreign/csharp/Iggy_SDK_Tests/Utils/SpecFlowTypes/ConsumerPollStreamTopicId.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/SpecFlowTypes/ConsumerPollStreamTopicId.cs
index 4b3682899..7e3f9b30f 100644
---
a/foreign/csharp/Iggy_SDK_Tests/Utils/SpecFlowTypes/ConsumerPollStreamTopicId.cs
+++
b/foreign/csharp/Iggy_SDK_Tests/Utils/SpecFlowTypes/ConsumerPollStreamTopicId.cs
@@ -22,4 +22,4 @@ public sealed class ConsumerPollStreamTopicId
public required int StreamId { get; init; }
public required int ConsumerTopicId { get; init; }
public required int ConsumerGroupTopicId { get; init; }
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/Stats/StatsFactory.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/Stats/StatsFactory.cs
index 72a1a4353..b38432f92 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/Stats/StatsFactory.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/Stats/StatsFactory.cs
@@ -50,4 +50,4 @@ public static class StatsFactory
IggyServerVersion = "1234"
};
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/Streams/StreamFactory.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/Streams/StreamFactory.cs
index 67a466a88..92f1b1d37 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/Streams/StreamFactory.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/Streams/StreamFactory.cs
@@ -30,4 +30,4 @@ internal static class StreamFactory
var createdAt = (ulong)Random.Shared.Next(69, 42069);
return (id, topicsCount, sizeBytes, messageCount, name, createdAt);
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/TestPriorityAttribute.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/TestPriorityAttribute.cs
index 180c145b2..efc13c1f9 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/TestPriorityAttribute.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/TestPriorityAttribute.cs
@@ -26,4 +26,4 @@ public class TestPriorityAttribute : Attribute
{
Priority = priority;
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/Topics/TopicFactory.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/Topics/TopicFactory.cs
index be7023ed7..0cb92deac 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/Topics/TopicFactory.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/Topics/TopicFactory.cs
@@ -49,4 +49,4 @@ internal static class TopicFactory
replicationFactor: (byte)Random.Shared.Next(1, 8),
partitionsCount: (uint)Random.Shared.Next(5, 25));
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/Users/PermissionsFactory.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/Users/PermissionsFactory.cs
index e69bb837c..d6ab48097 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/Users/PermissionsFactory.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/Users/PermissionsFactory.cs
@@ -180,4 +180,4 @@ internal static class PermissionsFactory
Streams = streamMap.Count > 0 ? streamMap : null
};
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/Users/UsersFactory.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/Users/UsersFactory.cs
index 240f7840a..aef0443bb 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/Users/UsersFactory.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/Users/UsersFactory.cs
@@ -79,4 +79,4 @@ public static class UsersFactory
Streams = CreateStreamPermissions()
};
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Iggy_SDK_Tests/Utils/Utility.cs
b/foreign/csharp/Iggy_SDK_Tests/Utils/Utility.cs
index 5652c3eae..f258bdbc4 100644
--- a/foreign/csharp/Iggy_SDK_Tests/Utils/Utility.cs
+++ b/foreign/csharp/Iggy_SDK_Tests/Utils/Utility.cs
@@ -25,4 +25,4 @@ internal static class Utility
return new string(Enumerable.Repeat(chars, length)
.Select(s => s[Random.Shared.Next(s.Length)]).ToArray());
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Shared/Envelope.cs
b/foreign/csharp/Shared/Envelope.cs
index 504c11746..927539b08 100644
--- a/foreign/csharp/Shared/Envelope.cs
+++ b/foreign/csharp/Shared/Envelope.cs
@@ -44,4 +44,4 @@ public sealed class Envelope
Payload = JsonSerializer.Serialize(payload, _jsonSerializerOptions)
};
}
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Shared/ISerializableMessage.cs
b/foreign/csharp/Shared/ISerializableMessage.cs
index 406c05838..d6a8e6592 100644
--- a/foreign/csharp/Shared/ISerializableMessage.cs
+++ b/foreign/csharp/Shared/ISerializableMessage.cs
@@ -22,4 +22,4 @@ public interface ISerializableMessage
string ToJson();
byte[] ToBytes();
Envelope ToEnvelope();
-}
\ No newline at end of file
+}
diff --git a/foreign/csharp/Shared/Orders.cs b/foreign/csharp/Shared/Orders.cs
index 2994bf1e9..a6e4b10c3 100644
--- a/foreign/csharp/Shared/Orders.cs
+++ b/foreign/csharp/Shared/Orders.cs
@@ -162,4 +162,4 @@ public class OrderRejected : ISerializableMessage
{
return $"OrderRejected {ToJsonPrint()}";
}
-}
\ No newline at end of file
+}
