From f85ef200c0fa9e2710ccafddae1defd502ff0a04 Mon Sep 17 00:00:00 2001 From: tison Date: Sat, 22 Aug 2026 20:14:30 +0800 Subject: [PATCH 1/3] chore: migrate HawkEye to v7 --- .../csharp-dotnet/pre-merge/action.yml | 1 - .github/config/hawkeye.version | 1 - .github/workflows/_common.yml | 6 +-- CONTRIBUTING.md | 4 +- bdd/php/phpunit.xml.dist | 31 ++++++++------- core/bench/dashboard/frontend/index.dev.html | 31 ++++++++------- core/bench/dashboard/frontend/index.html | 28 +++++++------- core/bench/dashboard/frontend/index.prod.html | 31 ++++++++------- .../Iggy_SDK.Examples.Basic.Consumer.csproj | 31 ++++++++------- .../Iggy_SDK.Examples.Basic.Producer.csproj | 31 ++++++++------- ...DK.Examples.GettingStarted.Consumer.csproj | 31 ++++++++------- ...DK.Examples.GettingStarted.Producer.csproj | 31 ++++++++------- .../Iggy_SDK.Examples.Shared.csproj | 31 ++++++++------- ...K.Examples.MessageEnvelope.Consumer.csproj | 31 ++++++++------- ...K.Examples.MessageEnvelope.Producer.csproj | 31 ++++++++------- ...DK.Examples.MessageHeaders.Consumer.csproj | 31 ++++++++------- ...DK.Examples.MessageHeaders.Producer.csproj | 31 ++++++++------- .../Iggy_SDK.Examples.NewSdk.Consumer.csproj | 35 +++++++++-------- .../Iggy_SDK.Examples.NewSdk.Producer.csproj | 31 ++++++++------- .../Iggy_SDK.Examples.TcpTls.Consumer.csproj | 31 ++++++++------- .../Iggy_SDK.Examples.TcpTls.Producer.csproj | 31 ++++++++------- examples/node/eslint.config.ts | 1 - examples/node/src/basic/consumer.ts | 1 - examples/node/src/basic/producer.ts | 1 - examples/node/src/getting-started/consumer.ts | 1 - examples/node/src/getting-started/producer.ts | 1 - examples/node/src/index.ts | 1 - .../node/src/message-envelope/consumer.ts | 1 - .../node/src/message-envelope/producer.ts | 1 - examples/node/src/message-headers/consumer.ts | 1 - examples/node/src/message-headers/producer.ts | 1 - examples/node/src/multi-tenant/consumer.ts | 1 - examples/node/src/multi-tenant/producer.ts | 1 - .../node/src/sink-data-producer/producer.ts | 1 - examples/node/src/stream-builder/example.ts | 1 - examples/node/src/tcp-tls/consumer.ts | 1 - examples/node/src/tcp-tls/producer.ts | 1 - examples/node/src/utils/index.ts | 1 - foreign/csharp/Benchmarks/Benchmarks.csproj | 35 +++++++++-------- foreign/csharp/Directory.Build.props | 31 ++++++++------- foreign/csharp/Directory.Packages.props | 31 ++++++++------- .../Iggy_SDK.Tests.BDD.csproj | 31 ++++++++------- .../Iggy_SDK.Tests.Integration.csproj | 31 ++++++++------- .../Iggy_SDK/Contracts/StatsResponse.cs | 1 - .../Iggy_SDK/Contracts/StreamResponse.cs | 1 - .../Iggy_SDK/Contracts/TopicResponse.cs | 1 - foreign/csharp/Iggy_SDK/Enums/IdKind.cs | 1 - .../csharp/Iggy_SDK/Enums/PartitioningKind.cs | 1 - foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 31 ++++++++------- .../Iggy_SDK_Tests/Iggy_SDK_Tests.csproj | 35 +++++++++-------- foreign/csharp/Shared/Shared.csproj | 31 ++++++++------- foreign/csharp/scripts/pack.sh | 1 - .../java/bench/src/main/resources/logback.xml | 31 ++++++++------- .../dev-support/checkstyle/checkstyle.xml | 35 +++++++++-------- .../dev-support/checkstyle/suppressions.xml | 31 ++++++++------- .../src/test/resources/logback-test.xml | 35 +++++++++-------- foreign/node/commitlint.config.js | 34 ++++++++--------- foreign/node/eslint.config.mjs | 34 ++++++++--------- foreign/node/src/bdd/auth.ts | 1 - foreign/node/src/bdd/message.ts | 1 - foreign/node/src/bdd/stream.ts | 1 - foreign/node/src/bdd/topic.ts | 1 - foreign/node/src/bdd/world.ts | 1 - foreign/node/src/client.e2e.ts | 1 - .../node/src/client/client.connection.test.ts | 1 - foreign/node/src/client/client.connection.ts | 1 - foreign/node/src/client/client.debug.ts | 1 - foreign/node/src/client/client.socket.test.ts | 1 - foreign/node/src/client/client.socket.ts | 1 - foreign/node/src/client/client.ts | 1 - foreign/node/src/client/client.type.ts | 1 - foreign/node/src/client/client.utils.test.ts | 1 - foreign/node/src/client/client.utils.ts | 1 - foreign/node/src/client/index.ts | 1 - foreign/node/src/debug-send.ts | 1 - foreign/node/src/debug.ts | 1 - foreign/node/src/e2e/tcp.client.e2e.ts | 1 - foreign/node/src/e2e/tcp.cluster.e2e.ts | 1 - .../node/src/e2e/tcp.consumer-group.e2e.ts | 1 - .../node/src/e2e/tcp.consumer-stream.e2e.ts | 1 - foreign/node/src/e2e/tcp.parallel.e2e.ts | 1 - foreign/node/src/e2e/tcp.raw.e2e.ts | 1 - foreign/node/src/e2e/tcp.send-message.e2e.ts | 1 - foreign/node/src/e2e/tcp.stream.e2e.ts | 1 - foreign/node/src/e2e/tcp.system.e2e.ts | 1 - foreign/node/src/e2e/tcp.token.e2e.ts | 1 - foreign/node/src/e2e/tcp.topic.e2e.ts | 1 - foreign/node/src/e2e/tcp.user.e2e.ts | 1 - foreign/node/src/e2e/test-client.utils.ts | 1 - foreign/node/src/e2e/tls.system.e2e.ts | 1 - .../node/src/examples/stream-file-to-topic.ts | 1 - .../node/src/examples/stream-topic-to-file.ts | 1 - foreign/node/src/examples/utils.ts | 1 - foreign/node/src/index.ts | 1 - foreign/node/src/stream/consumer-stream.ts | 1 - foreign/node/src/stream/index.ts | 1 - foreign/node/src/tcp.e2e.ts | 1 - foreign/node/src/tcp.sm.utils.ts | 1 - foreign/node/src/tls.system.e2e.ts | 1 - foreign/node/src/type.utils.ts | 1 - foreign/node/src/wire/client/client.utils.ts | 1 - .../src/wire/client/get-client.command.ts | 1 - .../src/wire/client/get-clients.command.ts | 1 - .../node/src/wire/client/get-me.command.ts | 1 - foreign/node/src/wire/client/index.ts | 1 - foreign/node/src/wire/cluster/cluster.type.ts | 1 - .../node/src/wire/cluster/cluster.utils.ts | 1 - .../cluster/get-cluster-metadata.command.ts | 1 - foreign/node/src/wire/cluster/index.ts | 1 - foreign/node/src/wire/command-set.test.ts | 1 - foreign/node/src/wire/command-set.ts | 1 - foreign/node/src/wire/command.code.ts | 1 - foreign/node/src/wire/command.utils.ts | 1 - .../create-group.command.test.ts | 1 - .../consumer-group/create-group.command.ts | 1 - .../consumer-group/delete-group.command.ts | 1 - .../ensure-group.virtual.command.ts | 1 - .../wire/consumer-group/get-group.command.ts | 1 - .../wire/consumer-group/get-groups.command.ts | 1 - .../wire/consumer-group/group.command.test.ts | 1 - .../src/wire/consumer-group/group.utils.ts | 1 - foreign/node/src/wire/consumer-group/index.ts | 1 - .../wire/consumer-group/join-group.command.ts | 1 - .../consumer-group/leave-group.command.ts | 1 - .../consumer-group/sync-group.command.test.ts | 1 - .../wire/consumer-group/sync-group.command.ts | 1 - foreign/node/src/wire/error.code.ts | 1 - foreign/node/src/wire/error.utils.ts | 1 - .../node/src/wire/identifier.utils.test.ts | 1 - foreign/node/src/wire/identifier.utils.ts | 1 - foreign/node/src/wire/index.ts | 1 - .../message/flush-unsaved-buffers.command.ts | 1 - foreign/node/src/wire/message/header.type.ts | 1 - .../src/wire/message/header.utils.test.ts | 1 - foreign/node/src/wire/message/header.utils.ts | 1 - .../src/wire/message/iggy-header.utils.ts | 1 - foreign/node/src/wire/message/index.ts | 1 - .../src/wire/message/message-batch.test.ts | 1 - .../node/src/wire/message/message.utils.ts | 1 - .../src/wire/message/partitioning.utils.ts | 1 - .../message/poll-messages.command.test.ts | 1 - .../src/wire/message/poll-messages.command.ts | 1 - foreign/node/src/wire/message/poll.utils.ts | 1 - .../message/send-messages.command.test.ts | 1 - .../src/wire/message/send-messages.command.ts | 1 - foreign/node/src/wire/number.utils.ts | 1 - .../src/wire/offset/delete-offset.command.ts | 1 - .../src/wire/offset/get-offset.command.ts | 1 - foreign/node/src/wire/offset/index.ts | 1 - foreign/node/src/wire/offset/offset.utils.ts | 1 - .../src/wire/offset/store-offset.command.ts | 1 - foreign/node/src/wire/options.utils.test.ts | 1 - foreign/node/src/wire/options.utils.ts | 1 - .../partition/create-partition.command.ts | 1 - .../partition/delete-partition.command.ts | 1 - foreign/node/src/wire/partition/index.ts | 1 - .../wire/partition/partition.utils.test.ts | 1 - .../src/wire/partition/partition.utils.ts | 1 - .../wire/segment/delete-segments.command.ts | 1 - foreign/node/src/wire/segment/index.ts | 1 - .../node/src/wire/segment/segment.utils.ts | 1 - foreign/node/src/wire/serialize.utils.ts | 1 - foreign/node/src/wire/session/index.ts | 1 - .../session/login-with-token.command.test.ts | 1 - .../wire/session/login-with-token.command.ts | 1 - .../src/wire/session/login.command.test.ts | 1 - .../node/src/wire/session/login.command.ts | 1 - foreign/node/src/wire/session/login.utils.ts | 1 - .../node/src/wire/session/logout.command.ts | 1 - .../wire/stream/create-stream.command.test.ts | 1 - .../src/wire/stream/create-stream.command.ts | 1 - .../src/wire/stream/delete-stream.command.ts | 1 - .../stream/ensure-stream.virtual.command.ts | 1 - .../src/wire/stream/get-stream.command.ts | 1 - .../src/wire/stream/get-streams.command.ts | 1 - foreign/node/src/wire/stream/index.ts | 1 - .../src/wire/stream/purge-stream.command.ts | 1 - foreign/node/src/wire/stream/stream.utils.ts | 1 - .../src/wire/stream/update-stream.command.ts | 1 - .../wire/system/describe-options.command.ts | 1 - .../node/src/wire/system/get-stats.command.ts | 1 - foreign/node/src/wire/system/index.ts | 1 - foreign/node/src/wire/system/ping.command.ts | 1 - .../wire/token/create-token.command.test.ts | 1 - .../src/wire/token/create-token.command.ts | 1 - .../wire/token/delete-token.command.test.ts | 1 - .../src/wire/token/delete-token.command.ts | 1 - .../node/src/wire/token/get-tokens.command.ts | 1 - foreign/node/src/wire/token/index.ts | 1 - foreign/node/src/wire/token/token.utils.ts | 1 - .../wire/topic/create-topic.command.test.ts | 1 - .../src/wire/topic/create-topic.command.ts | 1 - .../src/wire/topic/delete-topic.command.ts | 1 - .../topic/ensure-topic.virtual.command.ts | 1 - .../node/src/wire/topic/get-topic.command.ts | 1 - .../node/src/wire/topic/get-topics.command.ts | 1 - foreign/node/src/wire/topic/index.ts | 1 - .../src/wire/topic/purge-topic.command.ts | 1 - .../node/src/wire/topic/topic.utils.test.ts | 1 - foreign/node/src/wire/topic/topic.utils.ts | 1 - .../src/wire/topic/update-topic.command.ts | 1 - .../src/wire/user/change-password.command.ts | 1 - .../src/wire/user/create-user.command.test.ts | 1 - .../node/src/wire/user/create-user.command.ts | 1 - .../node/src/wire/user/delete-user.command.ts | 1 - .../node/src/wire/user/get-user.command.ts | 1 - .../node/src/wire/user/get-users.command.ts | 1 - foreign/node/src/wire/user/index.ts | 1 - .../src/wire/user/permissions.utils.test.ts | 1 - .../node/src/wire/user/permissions.utils.ts | 1 - .../wire/user/update-permissions.command.ts | 1 - .../node/src/wire/user/update-user.command.ts | 1 - foreign/node/src/wire/user/user.utils.ts | 1 - foreign/node/src/wire/uuid.utils.ts | 1 - foreign/node/src/wire/vsr/header.ts | 1 - foreign/node/src/wire/vsr/index.ts | 1 - foreign/node/src/wire/vsr/operation.ts | 1 - foreign/node/src/wire/vsr/register.ts | 1 - foreign/node/src/wire/vsr/reply.ts | 1 - foreign/node/src/wire/vsr/session.ts | 1 - foreign/node/src/wire/vsr/vsr.test.ts | 1 - foreign/php/iggy-php.stubs.php | 1 - foreign/php/phpunit.xml.dist | 31 ++++++++------- foreign/python/tests/__init__.py | 1 + licenserc.toml | 26 ++++++++----- scripts/ci/license-headers.sh | 38 +++++++++++-------- scripts/dashboard/build_release.sh | 1 - scripts/dashboard/run_dev.sh | 1 - web/src/app.html | 31 ++++++++------- web/src/lib/components/AppToasts.svelte | 35 +++++++++-------- web/src/lib/components/Breadcrumbs.svelte | 35 +++++++++-------- web/src/lib/components/Button.svelte | 31 ++++++++------- web/src/lib/components/Checkbox.svelte | 35 +++++++++-------- web/src/lib/components/Combobox.svelte | 35 +++++++++-------- .../DeleteButtonWithConfirmation.svelte | 31 ++++++++------- .../DropdownMenu/DropdownMenu.svelte | 31 ++++++++------- web/src/lib/components/DurationInput.svelte | 35 +++++++++-------- .../components/FixedSvelteComponent.svelte | 35 +++++++++-------- web/src/lib/components/Header.svelte | 31 ++++++++------- web/src/lib/components/Icon.svelte | 31 ++++++++------- web/src/lib/components/Input.svelte | 31 ++++++++------- .../components/Layouts/SettingsLayout.svelte | 31 ++++++++------- web/src/lib/components/Listbox.svelte | 31 ++++++++------- web/src/lib/components/Loader.svelte | 35 +++++++++-------- .../lib/components/LoadingIndicator.svelte | 31 ++++++++------- web/src/lib/components/Logo/Logo.svelte | 31 ++++++++------- web/src/lib/components/Logo/LogoMark.svelte | 31 ++++++++------- web/src/lib/components/Logo/LogoType.svelte | 31 ++++++++------- .../MessageDecoder/MessageDecoder.svelte | 35 +++++++++-------- .../lib/components/ModalConfirmation.svelte | 31 ++++++++------- .../Modals/AddPartitionsModal.svelte | 31 ++++++++------- .../components/Modals/AddStreamModal.svelte | 31 ++++++++------- .../components/Modals/AddTopicModal.svelte | 35 +++++++++-------- .../lib/components/Modals/AddUserModal.svelte | 35 +++++++++-------- .../lib/components/Modals/AppModals.svelte | 31 ++++++++------- .../Modals/DeletePartitionsModal.svelte | 35 +++++++++-------- .../components/Modals/DeleteUserModal.svelte | 35 +++++++++-------- .../components/Modals/EditUserModal.svelte | 35 +++++++++-------- .../Modals/EditUserPermissionsModal.svelte | 35 +++++++++-------- .../components/Modals/InspectMessage.svelte | 35 +++++++++-------- .../lib/components/Modals/ModalBase.svelte | 31 ++++++++------- .../Modals/StreamSettingsModal.svelte | 35 +++++++++-------- .../Modals/TopicSettingsModal.svelte | 35 +++++++++-------- web/src/lib/components/Navbar.svelte | 31 ++++++++------- web/src/lib/components/Paginator.svelte | 35 +++++++++-------- web/src/lib/components/PasswordInput.svelte | 31 ++++++++------- .../lib/components/PeriodicInvalidator.svelte | 31 ++++++++------- .../lib/components/PermissionsManager.svelte | 35 +++++++++-------- .../PreventEventsPropagation.svelte | 31 ++++++++------- web/src/lib/components/RangeInput.svelte | 31 ++++++++------- .../RouteComponents/Settings/UsersTab.svelte | 35 +++++++++-------- .../Settings/UsersTabActions.svelte | 31 ++++++++------- .../lib/components/SegmentedControl.svelte | 31 ++++++++------- web/src/lib/components/Select.svelte | 31 ++++++++------- .../lib/components/SlimSortableList.svelte | 35 +++++++++-------- web/src/lib/components/SortableList.svelte | 35 +++++++++-------- web/src/lib/components/StopPropagation.svelte | 31 ++++++++------- web/src/lib/components/ThemeController.svelte | 31 ++++++++------- web/src/lib/components/Toggler.svelte | 35 +++++++++-------- web/src/routes/+error.svelte | 31 ++++++++------- web/src/routes/+layout.svelte | 31 ++++++++------- web/src/routes/auth/+layout.svelte | 31 ++++++++------- web/src/routes/auth/logout/+page.svelte | 31 ++++++++------- web/src/routes/auth/sign-in/+page.svelte | 35 +++++++++-------- web/src/routes/dashboard/+layout.svelte | 35 +++++++++-------- web/src/routes/dashboard/clients/+page.svelte | 31 ++++++++------- web/src/routes/dashboard/logs/+page.svelte | 31 ++++++++------- .../routes/dashboard/overview/+page.svelte | 35 +++++++++-------- .../dashboard/settings/server/+page.svelte | 31 ++++++++------- .../dashboard/settings/terminal/+page.svelte | 31 ++++++++------- .../dashboard/settings/users/+page.svelte | 35 +++++++++-------- .../dashboard/settings/webUI/+page.svelte | 31 ++++++++------- .../routes/dashboard/streams/+layout.svelte | 31 ++++++++------- web/src/routes/dashboard/streams/+page.svelte | 31 ++++++++------- .../streams/[streamId=i32]/+page.svelte | 31 ++++++++------- .../[streamId=i32]/topics/+page.svelte | 31 ++++++++------- .../topics/[topicId=i32]/+page.svelte | 31 ++++++++------- .../partitions/[partitionId=i32]/+page.svelte | 31 ++++++++------- .../[partitionId=i32]/messages/+page.svelte | 35 +++++++++-------- 299 files changed, 1654 insertions(+), 1940 deletions(-) delete mode 100644 .github/config/hawkeye.version diff --git a/.github/actions/csharp-dotnet/pre-merge/action.yml b/.github/actions/csharp-dotnet/pre-merge/action.yml index b8acbff815..d68f930c5b 100644 --- a/.github/actions/csharp-dotnet/pre-merge/action.yml +++ b/.github/actions/csharp-dotnet/pre-merge/action.yml @@ -15,7 +15,6 @@ # specific language governing permissions and limitations # under the License. - name: csharp-dotnet-pre-merge description: .NET pre-merge testing github iggy actions diff --git a/.github/config/hawkeye.version b/.github/config/hawkeye.version deleted file mode 100644 index a194c18e86..0000000000 --- a/.github/config/hawkeye.version +++ /dev/null @@ -1 +0,0 @@ -6.5.1 diff --git a/.github/workflows/_common.yml b/.github/workflows/_common.yml index 69f849fa44..d40ee3dfec 100644 --- a/.github/workflows/_common.yml +++ b/.github/workflows/_common.yml @@ -88,14 +88,10 @@ jobs: steps: - uses: actions/checkout@v7.0.1 - - name: Read HawkEye version - id: hawkeye-version - run: echo "version=$(cat .github/config/hawkeye.version)" >> "$GITHUB_OUTPUT" - - name: Install HawkEye uses: taiki-e/install-action@v2.85.11 with: - tool: hawkeye@${{ steps.hawkeye-version.outputs.version }} + tool: hawkeye - name: Check license headers run: ./scripts/ci/license-headers.sh --check diff --git a/CONTRIBUTING.md b/CONTRIBUTING.md index 8297d919dd..7c18cff871 100644 --- a/CONTRIBUTING.md +++ b/CONTRIBUTING.md @@ -67,10 +67,10 @@ If it's indeed not a typo, you can set an exception in `.typos.toml`. ### License Header Checks -We use [HawkEye](https://github.com/korandoru/hawkeye): +We use [HawkEye](https://github.com/fast/hawkeye): ```bash -cargo install hawkeye --version "$(cat .github/config/hawkeye.version)" --locked +cargo install hawkeye --locked ./scripts/ci/license-headers.sh --check ./scripts/ci/license-headers.sh --fix ``` diff --git a/bdd/php/phpunit.xml.dist b/bdd/php/phpunit.xml.dist index aee1c115fc..83857094df 100644 --- a/bdd/php/phpunit.xml.dist +++ b/bdd/php/phpunit.xml.dist @@ -1,24 +1,23 @@ + + diff --git a/core/bench/dashboard/frontend/index.html b/core/bench/dashboard/frontend/index.html index 4d73168572..92fd763a23 100644 --- a/core/bench/dashboard/frontend/index.html +++ b/core/bench/dashboard/frontend/index.html @@ -1,21 +1,21 @@ diff --git a/core/bench/dashboard/frontend/index.prod.html b/core/bench/dashboard/frontend/index.prod.html index a983403d79..fcf3499bdf 100644 --- a/core/bench/dashboard/frontend/index.prod.html +++ b/core/bench/dashboard/frontend/index.prod.html @@ -1,24 +1,23 @@ + diff --git a/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Consumer/Iggy_SDK.Examples.Basic.Consumer.csproj b/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Consumer/Iggy_SDK.Examples.Basic.Consumer.csproj index 31fb849aa5..7f7546089b 100644 --- a/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Consumer/Iggy_SDK.Examples.Basic.Consumer.csproj +++ b/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Consumer/Iggy_SDK.Examples.Basic.Consumer.csproj @@ -1,23 +1,22 @@  + Exe diff --git a/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Producer/Iggy_SDK.Examples.Basic.Producer.csproj b/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Producer/Iggy_SDK.Examples.Basic.Producer.csproj index cd81ac749e..a019e9bae7 100644 --- a/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Producer/Iggy_SDK.Examples.Basic.Producer.csproj +++ b/examples/csharp/src/Basic/Iggy_SDK.Examples.Basic.Producer/Iggy_SDK.Examples.Basic.Producer.csproj @@ -1,23 +1,22 @@  + Exe diff --git a/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Consumer/Iggy_SDK.Examples.GettingStarted.Consumer.csproj b/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Consumer/Iggy_SDK.Examples.GettingStarted.Consumer.csproj index 2601a08e7e..7ac7151b5e 100644 --- a/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Consumer/Iggy_SDK.Examples.GettingStarted.Consumer.csproj +++ b/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Consumer/Iggy_SDK.Examples.GettingStarted.Consumer.csproj @@ -1,23 +1,22 @@  + Exe diff --git a/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Producer/Iggy_SDK.Examples.GettingStarted.Producer.csproj b/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Producer/Iggy_SDK.Examples.GettingStarted.Producer.csproj index 35a6bf8ac7..41e80d8ead 100644 --- a/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Producer/Iggy_SDK.Examples.GettingStarted.Producer.csproj +++ b/examples/csharp/src/GettingStarted/Iggy_SDK.Examples.GettingStarted.Producer/Iggy_SDK.Examples.GettingStarted.Producer.csproj @@ -1,23 +1,22 @@  + Exe diff --git a/examples/csharp/src/Iggy_SDK.Examples.Shared/Iggy_SDK.Examples.Shared.csproj b/examples/csharp/src/Iggy_SDK.Examples.Shared/Iggy_SDK.Examples.Shared.csproj index 4ea9661bce..7800535339 100644 --- a/examples/csharp/src/Iggy_SDK.Examples.Shared/Iggy_SDK.Examples.Shared.csproj +++ b/examples/csharp/src/Iggy_SDK.Examples.Shared/Iggy_SDK.Examples.Shared.csproj @@ -1,23 +1,22 @@  + net10.0 diff --git a/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Iggy_SDK.Examples.MessageEnvelope.Consumer.csproj b/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Iggy_SDK.Examples.MessageEnvelope.Consumer.csproj index 80145d2457..8a9df22a93 100644 --- a/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Iggy_SDK.Examples.MessageEnvelope.Consumer.csproj +++ b/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Consumer/Iggy_SDK.Examples.MessageEnvelope.Consumer.csproj @@ -1,23 +1,22 @@  + Exe diff --git a/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Producer/Iggy_SDK.Examples.MessageEnvelope.Producer.csproj b/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Producer/Iggy_SDK.Examples.MessageEnvelope.Producer.csproj index 80145d2457..8a9df22a93 100644 --- a/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Producer/Iggy_SDK.Examples.MessageEnvelope.Producer.csproj +++ b/examples/csharp/src/MessageEnvelope/Iggy_SDK.Examples.MessageEnvelope.Producer/Iggy_SDK.Examples.MessageEnvelope.Producer.csproj @@ -1,23 +1,22 @@  + Exe diff --git a/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Iggy_SDK.Examples.MessageHeaders.Consumer.csproj b/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Iggy_SDK.Examples.MessageHeaders.Consumer.csproj index 2601a08e7e..7ac7151b5e 100644 --- a/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Iggy_SDK.Examples.MessageHeaders.Consumer.csproj +++ b/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Consumer/Iggy_SDK.Examples.MessageHeaders.Consumer.csproj @@ -1,23 +1,22 @@  + Exe diff --git a/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Producer/Iggy_SDK.Examples.MessageHeaders.Producer.csproj b/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Producer/Iggy_SDK.Examples.MessageHeaders.Producer.csproj index 2601a08e7e..7ac7151b5e 100644 --- a/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Producer/Iggy_SDK.Examples.MessageHeaders.Producer.csproj +++ b/examples/csharp/src/MessageHeaders/Iggy_SDK.Examples.MessageHeaders.Producer/Iggy_SDK.Examples.MessageHeaders.Producer.csproj @@ -1,23 +1,22 @@  + Exe diff --git a/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Iggy_SDK.Examples.NewSdk.Consumer.csproj b/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Iggy_SDK.Examples.NewSdk.Consumer.csproj index 35f41c1f37..25bbea561b 100644 --- a/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Iggy_SDK.Examples.NewSdk.Consumer.csproj +++ b/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Consumer/Iggy_SDK.Examples.NewSdk.Consumer.csproj @@ -1,23 +1,22 @@  + diff --git a/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Iggy_SDK.Examples.NewSdk.Producer.csproj b/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Iggy_SDK.Examples.NewSdk.Producer.csproj index 2c9664db42..3b90b79f0e 100644 --- a/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Iggy_SDK.Examples.NewSdk.Producer.csproj +++ b/examples/csharp/src/NewSdk/Iggy_SDK.Examples.NewSdk.Producer/Iggy_SDK.Examples.NewSdk.Producer.csproj @@ -1,23 +1,22 @@  + diff --git a/examples/csharp/src/TcpTls/Iggy_SDK.Examples.TcpTls.Consumer/Iggy_SDK.Examples.TcpTls.Consumer.csproj b/examples/csharp/src/TcpTls/Iggy_SDK.Examples.TcpTls.Consumer/Iggy_SDK.Examples.TcpTls.Consumer.csproj index 7473430a7a..5e7f1573b2 100644 --- a/examples/csharp/src/TcpTls/Iggy_SDK.Examples.TcpTls.Consumer/Iggy_SDK.Examples.TcpTls.Consumer.csproj +++ b/examples/csharp/src/TcpTls/Iggy_SDK.Examples.TcpTls.Consumer/Iggy_SDK.Examples.TcpTls.Consumer.csproj @@ -1,23 +1,22 @@ + Exe diff --git a/examples/csharp/src/TcpTls/Iggy_SDK.Examples.TcpTls.Producer/Iggy_SDK.Examples.TcpTls.Producer.csproj b/examples/csharp/src/TcpTls/Iggy_SDK.Examples.TcpTls.Producer/Iggy_SDK.Examples.TcpTls.Producer.csproj index 9b4f94bc75..28bbeaa21a 100644 --- a/examples/csharp/src/TcpTls/Iggy_SDK.Examples.TcpTls.Producer/Iggy_SDK.Examples.TcpTls.Producer.csproj +++ b/examples/csharp/src/TcpTls/Iggy_SDK.Examples.TcpTls.Producer/Iggy_SDK.Examples.TcpTls.Producer.csproj @@ -1,23 +1,22 @@ + Exe diff --git a/examples/node/eslint.config.ts b/examples/node/eslint.config.ts index e3be110769..c40af70d5f 100644 --- a/examples/node/eslint.config.ts +++ b/examples/node/eslint.config.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// //? I don't know why we need to add license header here for eslint config file diff --git a/examples/node/src/basic/consumer.ts b/examples/node/src/basic/consumer.ts index 44856ddb53..0229ff599e 100644 --- a/examples/node/src/basic/consumer.ts +++ b/examples/node/src/basic/consumer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client, PollingStrategy, Consumer } from 'apache-iggy'; import debug from 'debug'; diff --git a/examples/node/src/basic/producer.ts b/examples/node/src/basic/producer.ts index efd2d6597b..421ac523d9 100644 --- a/examples/node/src/basic/producer.ts +++ b/examples/node/src/basic/producer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client, Partitioning } from "apache-iggy"; import debug from "debug"; diff --git a/examples/node/src/getting-started/consumer.ts b/examples/node/src/getting-started/consumer.ts index 7da1739eb1..017a22a0fd 100644 --- a/examples/node/src/getting-started/consumer.ts +++ b/examples/node/src/getting-started/consumer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client, PollingStrategy, Consumer } from 'apache-iggy'; import { BATCHES_LIMIT, log, MESSAGES_PER_BATCH, PARTITION_ID, STREAM_ID, TOPIC_ID } from '../utils'; diff --git a/examples/node/src/getting-started/producer.ts b/examples/node/src/getting-started/producer.ts index 9e1ae5f777..aadc3acd11 100644 --- a/examples/node/src/getting-started/producer.ts +++ b/examples/node/src/getting-started/producer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client, Partitioning } from "apache-iggy"; import { diff --git a/examples/node/src/index.ts b/examples/node/src/index.ts index 7c91dbf64d..fbee05cdc2 100644 --- a/examples/node/src/index.ts +++ b/examples/node/src/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// // Re-export all examples for easy importing export * from './getting-started/producer.js'; diff --git a/examples/node/src/message-envelope/consumer.ts b/examples/node/src/message-envelope/consumer.ts index 5d1f1b08ac..8f6a0ac458 100644 --- a/examples/node/src/message-envelope/consumer.ts +++ b/examples/node/src/message-envelope/consumer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client, Consumer, PollingStrategy } from 'apache-iggy'; import { initSystem, cleanup, log, BATCHES_LIMIT, MESSAGES_PER_BATCH } from '../utils'; diff --git a/examples/node/src/message-envelope/producer.ts b/examples/node/src/message-envelope/producer.ts index 477973871c..db832c68a9 100644 --- a/examples/node/src/message-envelope/producer.ts +++ b/examples/node/src/message-envelope/producer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client, Partitioning } from 'apache-iggy'; import { BATCHES_LIMIT, cleanup, initSystem, log, MESSAGES_PER_BATCH, parseArgs, sleep } from '../utils'; diff --git a/examples/node/src/message-headers/consumer.ts b/examples/node/src/message-headers/consumer.ts index 485fee1387..d62a4af59e 100644 --- a/examples/node/src/message-headers/consumer.ts +++ b/examples/node/src/message-headers/consumer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client, Consumer, PollingStrategy } from 'apache-iggy'; import { log, initSystem, cleanup, BATCHES_LIMIT, MESSAGES_PER_BATCH } from '../utils'; diff --git a/examples/node/src/message-headers/producer.ts b/examples/node/src/message-headers/producer.ts index 6c058b83ca..5973bfcc70 100644 --- a/examples/node/src/message-headers/producer.ts +++ b/examples/node/src/message-headers/producer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client, Partitioning } from "apache-iggy"; import { diff --git a/examples/node/src/multi-tenant/consumer.ts b/examples/node/src/multi-tenant/consumer.ts index 4555221ece..75ea2218f9 100644 --- a/examples/node/src/multi-tenant/consumer.ts +++ b/examples/node/src/multi-tenant/consumer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client, Consumer, PollingStrategy } from 'apache-iggy'; import { BATCHES_LIMIT, log, parseArgs } from '../utils'; diff --git a/examples/node/src/multi-tenant/producer.ts b/examples/node/src/multi-tenant/producer.ts index fb914a6c51..612a26a0e8 100644 --- a/examples/node/src/multi-tenant/producer.ts +++ b/examples/node/src/multi-tenant/producer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client, Partitioning } from 'apache-iggy'; import { BATCHES_LIMIT, log, MESSAGES_PER_BATCH } from '../utils'; diff --git a/examples/node/src/sink-data-producer/producer.ts b/examples/node/src/sink-data-producer/producer.ts index ce2a34c6b3..70fecff549 100644 --- a/examples/node/src/sink-data-producer/producer.ts +++ b/examples/node/src/sink-data-producer/producer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client, Partitioning } from 'apache-iggy'; import { log, sleep } from '../utils'; diff --git a/examples/node/src/stream-builder/example.ts b/examples/node/src/stream-builder/example.ts index fb511b366c..c9943c10fe 100644 --- a/examples/node/src/stream-builder/example.ts +++ b/examples/node/src/stream-builder/example.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client, Partitioning } from 'apache-iggy'; import { log, sleep } from '../utils'; diff --git a/examples/node/src/tcp-tls/consumer.ts b/examples/node/src/tcp-tls/consumer.ts index 6817193123..eb39033f0d 100644 --- a/examples/node/src/tcp-tls/consumer.ts +++ b/examples/node/src/tcp-tls/consumer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// // TCP/TLS Consumer Example // diff --git a/examples/node/src/tcp-tls/producer.ts b/examples/node/src/tcp-tls/producer.ts index 98f7dc99c2..799e2bbfcc 100644 --- a/examples/node/src/tcp-tls/producer.ts +++ b/examples/node/src/tcp-tls/producer.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// // TCP/TLS Producer Example // diff --git a/examples/node/src/utils/index.ts b/examples/node/src/utils/index.ts index df98700e19..8b1172fa68 100644 --- a/examples/node/src/utils/index.ts +++ b/examples/node/src/utils/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import crypto from 'crypto'; import { Client } from 'apache-iggy'; diff --git a/foreign/csharp/Benchmarks/Benchmarks.csproj b/foreign/csharp/Benchmarks/Benchmarks.csproj index 7f629254ea..754e268d09 100644 --- a/foreign/csharp/Benchmarks/Benchmarks.csproj +++ b/foreign/csharp/Benchmarks/Benchmarks.csproj @@ -1,23 +1,22 @@ + diff --git a/foreign/csharp/Directory.Build.props b/foreign/csharp/Directory.Build.props index 0326fdde06..684da2c884 100644 --- a/foreign/csharp/Directory.Build.props +++ b/foreign/csharp/Directory.Build.props @@ -1,23 +1,22 @@ + true diff --git a/foreign/csharp/Directory.Packages.props b/foreign/csharp/Directory.Packages.props index 46946479f2..ea85e7f370 100644 --- a/foreign/csharp/Directory.Packages.props +++ b/foreign/csharp/Directory.Packages.props @@ -1,23 +1,22 @@ + true diff --git a/foreign/csharp/Iggy_SDK.Tests.BDD/Iggy_SDK.Tests.BDD.csproj b/foreign/csharp/Iggy_SDK.Tests.BDD/Iggy_SDK.Tests.BDD.csproj index 489a43fc68..7d7785453f 100644 --- a/foreign/csharp/Iggy_SDK.Tests.BDD/Iggy_SDK.Tests.BDD.csproj +++ b/foreign/csharp/Iggy_SDK.Tests.BDD/Iggy_SDK.Tests.BDD.csproj @@ -1,23 +1,22 @@ + diff --git a/foreign/csharp/Iggy_SDK.Tests.Integration/Iggy_SDK.Tests.Integration.csproj b/foreign/csharp/Iggy_SDK.Tests.Integration/Iggy_SDK.Tests.Integration.csproj index ad13f5d132..3bcbe28563 100644 --- a/foreign/csharp/Iggy_SDK.Tests.Integration/Iggy_SDK.Tests.Integration.csproj +++ b/foreign/csharp/Iggy_SDK.Tests.Integration/Iggy_SDK.Tests.Integration.csproj @@ -1,23 +1,22 @@ + diff --git a/foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs b/foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs index d09c716eb2..8ca1fb9be3 100644 --- a/foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs +++ b/foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs @@ -15,7 +15,6 @@ // specific language governing permissions and limitations // under the License. - using System.Text.Json.Serialization; using Apache.Iggy.JsonConverters; diff --git a/foreign/csharp/Iggy_SDK/Contracts/StreamResponse.cs b/foreign/csharp/Iggy_SDK/Contracts/StreamResponse.cs index ee23a0ec6f..39f46c795a 100644 --- a/foreign/csharp/Iggy_SDK/Contracts/StreamResponse.cs +++ b/foreign/csharp/Iggy_SDK/Contracts/StreamResponse.cs @@ -15,7 +15,6 @@ // specific language governing permissions and limitations // under the License. - using System.Text.Json.Serialization; using Apache.Iggy.Headers; using Apache.Iggy.JsonConverters; diff --git a/foreign/csharp/Iggy_SDK/Contracts/TopicResponse.cs b/foreign/csharp/Iggy_SDK/Contracts/TopicResponse.cs index 877aec6178..fd508e6949 100644 --- a/foreign/csharp/Iggy_SDK/Contracts/TopicResponse.cs +++ b/foreign/csharp/Iggy_SDK/Contracts/TopicResponse.cs @@ -15,7 +15,6 @@ // specific language governing permissions and limitations // under the License. - using System.Text.Json.Serialization; using Apache.Iggy.Enums; using Apache.Iggy.Headers; diff --git a/foreign/csharp/Iggy_SDK/Enums/IdKind.cs b/foreign/csharp/Iggy_SDK/Enums/IdKind.cs index b1068a7ef2..9e48e4ddee 100644 --- a/foreign/csharp/Iggy_SDK/Enums/IdKind.cs +++ b/foreign/csharp/Iggy_SDK/Enums/IdKind.cs @@ -15,7 +15,6 @@ // specific language governing permissions and limitations // under the License. - using System.Runtime.CompilerServices; namespace Apache.Iggy.Enums; diff --git a/foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs b/foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs index b7bb64caf7..6ea8c724e2 100644 --- a/foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs +++ b/foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs @@ -15,7 +15,6 @@ // specific language governing permissions and limitations // under the License. - namespace Apache.Iggy.Enums; /// diff --git a/foreign/csharp/Iggy_SDK/Iggy_SDK.csproj b/foreign/csharp/Iggy_SDK/Iggy_SDK.csproj index 6a22ab0366..a2a6bbcf84 100644 --- a/foreign/csharp/Iggy_SDK/Iggy_SDK.csproj +++ b/foreign/csharp/Iggy_SDK/Iggy_SDK.csproj @@ -1,23 +1,22 @@ + diff --git a/foreign/csharp/Iggy_SDK_Tests/Iggy_SDK_Tests.csproj b/foreign/csharp/Iggy_SDK_Tests/Iggy_SDK_Tests.csproj index 3ed1071ea6..24b8c6f54f 100644 --- a/foreign/csharp/Iggy_SDK_Tests/Iggy_SDK_Tests.csproj +++ b/foreign/csharp/Iggy_SDK_Tests/Iggy_SDK_Tests.csproj @@ -1,23 +1,22 @@ + diff --git a/foreign/csharp/Shared/Shared.csproj b/foreign/csharp/Shared/Shared.csproj index 0cf43f4495..862b314ea2 100644 --- a/foreign/csharp/Shared/Shared.csproj +++ b/foreign/csharp/Shared/Shared.csproj @@ -1,23 +1,22 @@ + diff --git a/foreign/csharp/scripts/pack.sh b/foreign/csharp/scripts/pack.sh index cb66da0b4f..4b6d00720d 100755 --- a/foreign/csharp/scripts/pack.sh +++ b/foreign/csharp/scripts/pack.sh @@ -16,7 +16,6 @@ # specific language governing permissions and limitations # under the License. - # Function to extract the version number from the commit message using regular expressions function extract_version { local commit_message="$1" diff --git a/foreign/java/bench/src/main/resources/logback.xml b/foreign/java/bench/src/main/resources/logback.xml index 10f3de0dff..602c624732 100644 --- a/foreign/java/bench/src/main/resources/logback.xml +++ b/foreign/java/bench/src/main/resources/logback.xml @@ -1,24 +1,23 @@ + diff --git a/foreign/java/dev-support/checkstyle/checkstyle.xml b/foreign/java/dev-support/checkstyle/checkstyle.xml index fd97187005..e72c1497fe 100644 --- a/foreign/java/dev-support/checkstyle/checkstyle.xml +++ b/foreign/java/dev-support/checkstyle/checkstyle.xml @@ -1,24 +1,23 @@ + diff --git a/foreign/java/dev-support/checkstyle/suppressions.xml b/foreign/java/dev-support/checkstyle/suppressions.xml index 0cd76c414f..9aaab31960 100644 --- a/foreign/java/dev-support/checkstyle/suppressions.xml +++ b/foreign/java/dev-support/checkstyle/suppressions.xml @@ -1,24 +1,23 @@ + diff --git a/foreign/java/java-sdk/src/test/resources/logback-test.xml b/foreign/java/java-sdk/src/test/resources/logback-test.xml index 2bc06c8ef6..3bb305c9c7 100644 --- a/foreign/java/java-sdk/src/test/resources/logback-test.xml +++ b/foreign/java/java-sdk/src/test/resources/logback-test.xml @@ -1,24 +1,23 @@ + diff --git a/foreign/node/commitlint.config.js b/foreign/node/commitlint.config.js index 2fe5989f9a..fbbe32b4d1 100644 --- a/foreign/node/commitlint.config.js +++ b/foreign/node/commitlint.config.js @@ -1,21 +1,19 @@ -/** - * 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 - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ +// 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 +// to you under the Apache License, Version 2.0 (the +// "License"); you may not use this file except in compliance +// with the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, +// software distributed under the License is distributed on an +// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +// KIND, either express or implied. See the License for the +// specific language governing permissions and limitations +// under the License. export default { extends: ['@commitlint/config-conventional'], diff --git a/foreign/node/eslint.config.mjs b/foreign/node/eslint.config.mjs index 6181c29610..c73d61a16c 100644 --- a/foreign/node/eslint.config.mjs +++ b/foreign/node/eslint.config.mjs @@ -1,21 +1,19 @@ -/** - * 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 - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ +// 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 +// to you under the Apache License, Version 2.0 (the +// "License"); you may not use this file except in compliance +// with the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, +// software distributed under the License is distributed on an +// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +// KIND, either express or implied. See the License for the +// specific language governing permissions and limitations +// under the License. // import jsLint from "@eslint/js" // import stylistic from "@stylistic/eslint-plugin" diff --git a/foreign/node/src/bdd/auth.ts b/foreign/node/src/bdd/auth.ts index 147327ee1d..2212893091 100644 --- a/foreign/node/src/bdd/auth.ts +++ b/foreign/node/src/bdd/auth.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import assert from 'node:assert/strict'; import { Client } from '../client/index.js'; diff --git a/foreign/node/src/bdd/message.ts b/foreign/node/src/bdd/message.ts index 0cb07a7337..606a61f5a9 100644 --- a/foreign/node/src/bdd/message.ts +++ b/foreign/node/src/bdd/message.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import assert from "node:assert/strict"; import { When, Then } from "@cucumber/cucumber"; diff --git a/foreign/node/src/bdd/stream.ts b/foreign/node/src/bdd/stream.ts index f06038fe75..b19aa32c17 100644 --- a/foreign/node/src/bdd/stream.ts +++ b/foreign/node/src/bdd/stream.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import assert from 'node:assert/strict'; import { Given, When, Then } from "@cucumber/cucumber"; diff --git a/foreign/node/src/bdd/topic.ts b/foreign/node/src/bdd/topic.ts index 084a76c258..cfc05aea68 100644 --- a/foreign/node/src/bdd/topic.ts +++ b/foreign/node/src/bdd/topic.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import assert from 'node:assert/strict'; import { When, Then } from "@cucumber/cucumber"; diff --git a/foreign/node/src/bdd/world.ts b/foreign/node/src/bdd/world.ts index aeade3c041..0a1a83ad05 100644 --- a/foreign/node/src/bdd/world.ts +++ b/foreign/node/src/bdd/world.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { Stream } from '../wire/stream/stream.utils.js'; import type { Topic } from '../wire/topic/topic.utils.js'; diff --git a/foreign/node/src/client.e2e.ts b/foreign/node/src/client.e2e.ts index a0957b79ca..2f2a341a0f 100644 --- a/foreign/node/src/client.e2e.ts +++ b/foreign/node/src/client.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import assert from 'node:assert/strict'; import { Client } from './client/client.js'; diff --git a/foreign/node/src/client/client.connection.test.ts b/foreign/node/src/client/client.connection.test.ts index 2564cfacfd..ed1f6428fa 100644 --- a/foreign/node/src/client/client.connection.test.ts +++ b/foreign/node/src/client/client.connection.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import assert from 'node:assert/strict'; import { once } from 'node:events'; diff --git a/foreign/node/src/client/client.connection.ts b/foreign/node/src/client/client.connection.ts index 10b68639d0..767da571d8 100644 --- a/foreign/node/src/client/client.connection.ts +++ b/foreign/node/src/client/client.connection.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { EventEmitter } from 'node:events'; import type { Socket } from 'node:net'; diff --git a/foreign/node/src/client/client.debug.ts b/foreign/node/src/client/client.debug.ts index 7728774c34..3623ab33b7 100644 --- a/foreign/node/src/client/client.debug.ts +++ b/foreign/node/src/client/client.debug.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import Debug from 'debug'; diff --git a/foreign/node/src/client/client.socket.test.ts b/foreign/node/src/client/client.socket.test.ts index 0697c5f3d4..9605e8d86b 100644 --- a/foreign/node/src/client/client.socket.test.ts +++ b/foreign/node/src/client/client.socket.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import assert from 'node:assert/strict'; import { once } from 'node:events'; diff --git a/foreign/node/src/client/client.socket.ts b/foreign/node/src/client/client.socket.ts index d1e5e4fe2a..2f02764c6c 100644 --- a/foreign/node/src/client/client.socket.ts +++ b/foreign/node/src/client/client.socket.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { EventEmitter } from 'node:events'; import type { diff --git a/foreign/node/src/client/client.ts b/foreign/node/src/client/client.ts index cfb7d2626f..fc642f5ef8 100644 --- a/foreign/node/src/client/client.ts +++ b/foreign/node/src/client/client.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { createPool, type Pool } from 'generic-pool'; import type { RawClient, ClientConfig } from "./client.type.js" diff --git a/foreign/node/src/client/client.type.ts b/foreign/node/src/client/client.type.ts index 4df9813e79..40c29bc2cc 100644 --- a/foreign/node/src/client/client.type.ts +++ b/foreign/node/src/client/client.type.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { Readable } from 'stream'; import { type TcpSocketConnectOpts } from 'node:net'; diff --git a/foreign/node/src/client/client.utils.test.ts b/foreign/node/src/client/client.utils.test.ts index 815058dd31..b70b5681d0 100644 --- a/foreign/node/src/client/client.utils.test.ts +++ b/foreign/node/src/client/client.utils.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/client/client.utils.ts b/foreign/node/src/client/client.utils.ts index dfde49b820..97b04c6a4a 100644 --- a/foreign/node/src/client/client.utils.ts +++ b/foreign/node/src/client/client.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from './client.type.js'; diff --git a/foreign/node/src/client/index.ts b/foreign/node/src/client/index.ts index d17a9e603e..d968e5ca0b 100644 --- a/foreign/node/src/client/index.ts +++ b/foreign/node/src/client/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export { Client, SimpleClient, SingleClient } from './client.js' export * from './client.config.js'; diff --git a/foreign/node/src/debug-send.ts b/foreign/node/src/debug-send.ts index c6cc2a6df3..ce9575255c 100644 --- a/foreign/node/src/debug-send.ts +++ b/foreign/node/src/debug-send.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import assert from 'node:assert/strict'; import { type ClientConfig, SingleClient } from './client/index.js'; diff --git a/foreign/node/src/debug.ts b/foreign/node/src/debug.ts index 514951f354..d45ac439b2 100644 --- a/foreign/node/src/debug.ts +++ b/foreign/node/src/debug.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import assert from 'node:assert/strict'; import { Client, DEFAULT_HEARTBEAT_INTERVAL } from './client/index.js'; diff --git a/foreign/node/src/e2e/tcp.client.e2e.ts b/foreign/node/src/e2e/tcp.client.e2e.ts index 2a9c49f29e..b5f668d6f1 100644 --- a/foreign/node/src/e2e/tcp.client.e2e.ts +++ b/foreign/node/src/e2e/tcp.client.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { after, describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/e2e/tcp.cluster.e2e.ts b/foreign/node/src/e2e/tcp.cluster.e2e.ts index d3e5c85e41..711672fb6b 100644 --- a/foreign/node/src/e2e/tcp.cluster.e2e.ts +++ b/foreign/node/src/e2e/tcp.cluster.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { after, describe, it } from "node:test"; import assert from "node:assert/strict"; diff --git a/foreign/node/src/e2e/tcp.consumer-group.e2e.ts b/foreign/node/src/e2e/tcp.consumer-group.e2e.ts index 58234fbb10..b6afd90858 100644 --- a/foreign/node/src/e2e/tcp.consumer-group.e2e.ts +++ b/foreign/node/src/e2e/tcp.consumer-group.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { after, describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/e2e/tcp.consumer-stream.e2e.ts b/foreign/node/src/e2e/tcp.consumer-stream.e2e.ts index 40d9afe93a..b7026745e9 100644 --- a/foreign/node/src/e2e/tcp.consumer-stream.e2e.ts +++ b/foreign/node/src/e2e/tcp.consumer-stream.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { after, describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/e2e/tcp.parallel.e2e.ts b/foreign/node/src/e2e/tcp.parallel.e2e.ts index d96e62a446..08678a2337 100644 --- a/foreign/node/src/e2e/tcp.parallel.e2e.ts +++ b/foreign/node/src/e2e/tcp.parallel.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { after, describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/e2e/tcp.raw.e2e.ts b/foreign/node/src/e2e/tcp.raw.e2e.ts index e1fcf27378..9ed5bc2b9f 100644 --- a/foreign/node/src/e2e/tcp.raw.e2e.ts +++ b/foreign/node/src/e2e/tcp.raw.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { after, describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/e2e/tcp.send-message.e2e.ts b/foreign/node/src/e2e/tcp.send-message.e2e.ts index 8b170c7bad..6f3a3a1d0e 100644 --- a/foreign/node/src/e2e/tcp.send-message.e2e.ts +++ b/foreign/node/src/e2e/tcp.send-message.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { after, describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/e2e/tcp.stream.e2e.ts b/foreign/node/src/e2e/tcp.stream.e2e.ts index 8864d9b45a..ba63c5059f 100644 --- a/foreign/node/src/e2e/tcp.stream.e2e.ts +++ b/foreign/node/src/e2e/tcp.stream.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { after, describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/e2e/tcp.system.e2e.ts b/foreign/node/src/e2e/tcp.system.e2e.ts index 992595b6c1..bf8bf8c166 100644 --- a/foreign/node/src/e2e/tcp.system.e2e.ts +++ b/foreign/node/src/e2e/tcp.system.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { after, describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/e2e/tcp.token.e2e.ts b/foreign/node/src/e2e/tcp.token.e2e.ts index ee5a3cd6f2..88f5ba4515 100644 --- a/foreign/node/src/e2e/tcp.token.e2e.ts +++ b/foreign/node/src/e2e/tcp.token.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { after, describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/e2e/tcp.topic.e2e.ts b/foreign/node/src/e2e/tcp.topic.e2e.ts index 43c09f341d..58e4c712f8 100644 --- a/foreign/node/src/e2e/tcp.topic.e2e.ts +++ b/foreign/node/src/e2e/tcp.topic.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { after, describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/e2e/tcp.user.e2e.ts b/foreign/node/src/e2e/tcp.user.e2e.ts index e7268e8d16..c9a008811b 100644 --- a/foreign/node/src/e2e/tcp.user.e2e.ts +++ b/foreign/node/src/e2e/tcp.user.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { after, describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/e2e/test-client.utils.ts b/foreign/node/src/e2e/test-client.utils.ts index 22090066ec..79dfa2b03f 100644 --- a/foreign/node/src/e2e/test-client.utils.ts +++ b/foreign/node/src/e2e/test-client.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client } from '../client/client.js'; import { getIggyAddress } from '../tcp.sm.utils.js'; diff --git a/foreign/node/src/e2e/tls.system.e2e.ts b/foreign/node/src/e2e/tls.system.e2e.ts index e1dde409e4..eeb8c3d640 100644 --- a/foreign/node/src/e2e/tls.system.e2e.ts +++ b/foreign/node/src/e2e/tls.system.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// // TLS integration tests for the Node.js SDK. // diff --git a/foreign/node/src/examples/stream-file-to-topic.ts b/foreign/node/src/examples/stream-file-to-topic.ts index cd2beefa09..0d31dce1b0 100644 --- a/foreign/node/src/examples/stream-file-to-topic.ts +++ b/foreign/node/src/examples/stream-file-to-topic.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { open } from "node:fs/promises"; import { resolve } from "node:path"; diff --git a/foreign/node/src/examples/stream-topic-to-file.ts b/foreign/node/src/examples/stream-topic-to-file.ts index b8644f10cd..b0eb9fa0b7 100644 --- a/foreign/node/src/examples/stream-topic-to-file.ts +++ b/foreign/node/src/examples/stream-topic-to-file.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { PollingStrategy, singleConsumerStream, Consumer } from '../index.js'; import { open } from 'node:fs/promises'; diff --git a/foreign/node/src/examples/utils.ts b/foreign/node/src/examples/utils.ts index 68e3ac8043..971ae23867 100644 --- a/foreign/node/src/examples/utils.ts +++ b/foreign/node/src/examples/utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Client } from '../index.js'; import { getIggyAddress } from '../tcp.sm.utils.js'; diff --git a/foreign/node/src/index.ts b/foreign/node/src/index.ts index 60146ae1ad..4ecd1bae4f 100644 --- a/foreign/node/src/index.ts +++ b/foreign/node/src/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export { type Id, diff --git a/foreign/node/src/stream/consumer-stream.ts b/foreign/node/src/stream/consumer-stream.ts index aa91b45222..f69873421b 100644 --- a/foreign/node/src/stream/consumer-stream.ts +++ b/foreign/node/src/stream/consumer-stream.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { Readable } from "node:stream"; import type { ClientConfig } from "../client/client.type.js"; diff --git a/foreign/node/src/stream/index.ts b/foreign/node/src/stream/index.ts index c932255bdc..8d2cc2401b 100644 --- a/foreign/node/src/stream/index.ts +++ b/foreign/node/src/stream/index.ts @@ -14,6 +14,5 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './consumer-stream.js'; diff --git a/foreign/node/src/tcp.e2e.ts b/foreign/node/src/tcp.e2e.ts index c9d79e53e4..1278a3bfaf 100644 --- a/foreign/node/src/tcp.e2e.ts +++ b/foreign/node/src/tcp.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import assert from 'node:assert/strict'; import { getRawClient } from './client/index.js'; diff --git a/foreign/node/src/tcp.sm.utils.ts b/foreign/node/src/tcp.sm.utils.ts index c130492379..8e942f9442 100644 --- a/foreign/node/src/tcp.sm.utils.ts +++ b/foreign/node/src/tcp.sm.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import assert from "node:assert/strict"; import { v7 } from "./wire/uuid.utils.js"; diff --git a/foreign/node/src/tls.system.e2e.ts b/foreign/node/src/tls.system.e2e.ts index 8ed6229173..5e4d8475d3 100644 --- a/foreign/node/src/tls.system.e2e.ts +++ b/foreign/node/src/tls.system.e2e.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { getRawClient } from './client/index.js'; import { login, logout, getStats, ping } from './wire/index.js'; diff --git a/foreign/node/src/type.utils.ts b/foreign/node/src/type.utils.ts index a3d19ccc98..54836d0117 100644 --- a/foreign/node/src/type.utils.ts +++ b/foreign/node/src/type.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// /** * Reverses the keys and values of a record object. diff --git a/foreign/node/src/wire/client/client.utils.ts b/foreign/node/src/wire/client/client.utils.ts index 720e4e96a1..18314bd02b 100644 --- a/foreign/node/src/wire/client/client.utils.ts +++ b/foreign/node/src/wire/client/client.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export type Client = { clientId: number, diff --git a/foreign/node/src/wire/client/get-client.command.ts b/foreign/node/src/wire/client/get-client.command.ts index 8456716f9d..c3f71ef5fc 100644 --- a/foreign/node/src/wire/client/get-client.command.ts +++ b/foreign/node/src/wire/client/get-client.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { deserializeClient, type Client } from './client.utils.js'; diff --git a/foreign/node/src/wire/client/get-clients.command.ts b/foreign/node/src/wire/client/get-clients.command.ts index 41c4312a3e..4fe1921cb2 100644 --- a/foreign/node/src/wire/client/get-clients.command.ts +++ b/foreign/node/src/wire/client/get-clients.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { deserializeClient, type Client } from './client.utils.js'; diff --git a/foreign/node/src/wire/client/get-me.command.ts b/foreign/node/src/wire/client/get-me.command.ts index 56291ad459..f44c65676c 100644 --- a/foreign/node/src/wire/client/get-me.command.ts +++ b/foreign/node/src/wire/client/get-me.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { deserializeClient, type Client } from './client.utils.js'; diff --git a/foreign/node/src/wire/client/index.ts b/foreign/node/src/wire/client/index.ts index 47a6ae40f2..959712a355 100644 --- a/foreign/node/src/wire/client/index.ts +++ b/foreign/node/src/wire/client/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './get-client.command.js'; export * from './get-clients.command.js'; diff --git a/foreign/node/src/wire/cluster/cluster.type.ts b/foreign/node/src/wire/cluster/cluster.type.ts index 546eff6f28..478f419de5 100644 --- a/foreign/node/src/wire/cluster/cluster.type.ts +++ b/foreign/node/src/wire/cluster/cluster.type.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { type ValueOf, reverseRecord } from "../../type.utils.js"; diff --git a/foreign/node/src/wire/cluster/cluster.utils.ts b/foreign/node/src/wire/cluster/cluster.utils.ts index 2d51f420fe..e2a8c15aff 100644 --- a/foreign/node/src/wire/cluster/cluster.utils.ts +++ b/foreign/node/src/wire/cluster/cluster.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { deserializeError } from '../error.utils.js'; diff --git a/foreign/node/src/wire/cluster/get-cluster-metadata.command.ts b/foreign/node/src/wire/cluster/get-cluster-metadata.command.ts index 8f310b3e84..9b89cfb96a 100644 --- a/foreign/node/src/wire/cluster/get-cluster-metadata.command.ts +++ b/foreign/node/src/wire/cluster/get-cluster-metadata.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/index.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/cluster/index.ts b/foreign/node/src/wire/cluster/index.ts index d66f10275c..df04812c62 100644 --- a/foreign/node/src/wire/cluster/index.ts +++ b/foreign/node/src/wire/cluster/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './get-cluster-metadata.command.js'; export * from './cluster.type.js'; diff --git a/foreign/node/src/wire/command-set.test.ts b/foreign/node/src/wire/command-set.test.ts index dbc3a78c95..56069ef483 100644 --- a/foreign/node/src/wire/command-set.test.ts +++ b/foreign/node/src/wire/command-set.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/command-set.ts b/foreign/node/src/wire/command-set.ts index 1588306d6b..ed8da501aa 100644 --- a/foreign/node/src/wire/command-set.ts +++ b/foreign/node/src/wire/command-set.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { ClientProvider } from '../client/client.type.js'; diff --git a/foreign/node/src/wire/command.code.ts b/foreign/node/src/wire/command.code.ts index fd27a4876c..e4fec901b5 100644 --- a/foreign/node/src/wire/command.code.ts +++ b/foreign/node/src/wire/command.code.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { reverseRecord } from '../type.utils.js'; diff --git a/foreign/node/src/wire/command.utils.ts b/foreign/node/src/wire/command.utils.ts index 24cef5f1bf..92a8587f3c 100644 --- a/foreign/node/src/wire/command.utils.ts +++ b/foreign/node/src/wire/command.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse, ClientProvider } from '../client/client.type.js'; diff --git a/foreign/node/src/wire/consumer-group/create-group.command.test.ts b/foreign/node/src/wire/consumer-group/create-group.command.test.ts index 614809603c..f00d8002f1 100644 --- a/foreign/node/src/wire/consumer-group/create-group.command.test.ts +++ b/foreign/node/src/wire/consumer-group/create-group.command.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/consumer-group/create-group.command.ts b/foreign/node/src/wire/consumer-group/create-group.command.ts index 2b691c5e69..38fbec7b05 100644 --- a/foreign/node/src/wire/consumer-group/create-group.command.ts +++ b/foreign/node/src/wire/consumer-group/create-group.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { serializeIdentifier, type Id } from '../identifier.utils.js'; diff --git a/foreign/node/src/wire/consumer-group/delete-group.command.ts b/foreign/node/src/wire/consumer-group/delete-group.command.ts index c0fafb0ff8..551d83fc30 100644 --- a/foreign/node/src/wire/consumer-group/delete-group.command.ts +++ b/foreign/node/src/wire/consumer-group/delete-group.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { serializeTargetGroup, diff --git a/foreign/node/src/wire/consumer-group/ensure-group.virtual.command.ts b/foreign/node/src/wire/consumer-group/ensure-group.virtual.command.ts index e62dfebb71..c8efb2f820 100644 --- a/foreign/node/src/wire/consumer-group/ensure-group.virtual.command.ts +++ b/foreign/node/src/wire/consumer-group/ensure-group.virtual.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { Id } from '../identifier.utils.js'; import type { ClientProvider } from '../../client/index.js'; diff --git a/foreign/node/src/wire/consumer-group/get-group.command.ts b/foreign/node/src/wire/consumer-group/get-group.command.ts index 7e40c6e483..d90891fe19 100644 --- a/foreign/node/src/wire/consumer-group/get-group.command.ts +++ b/foreign/node/src/wire/consumer-group/get-group.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/consumer-group/get-groups.command.ts b/foreign/node/src/wire/consumer-group/get-groups.command.ts index ccb1626197..0ab80dde48 100644 --- a/foreign/node/src/wire/consumer-group/get-groups.command.ts +++ b/foreign/node/src/wire/consumer-group/get-groups.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import type { ConsumerGroup } from './group.utils.js'; diff --git a/foreign/node/src/wire/consumer-group/group.command.test.ts b/foreign/node/src/wire/consumer-group/group.command.test.ts index 3d02a003a3..8e73b637d7 100644 --- a/foreign/node/src/wire/consumer-group/group.command.test.ts +++ b/foreign/node/src/wire/consumer-group/group.command.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/consumer-group/group.utils.ts b/foreign/node/src/wire/consumer-group/group.utils.ts index a64f91a5b6..7a0144d4b9 100644 --- a/foreign/node/src/wire/consumer-group/group.utils.ts +++ b/foreign/node/src/wire/consumer-group/group.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { serializeIdentifier, type Id } from '../identifier.utils.js'; diff --git a/foreign/node/src/wire/consumer-group/index.ts b/foreign/node/src/wire/consumer-group/index.ts index 89219ad063..cb4b64a2bd 100644 --- a/foreign/node/src/wire/consumer-group/index.ts +++ b/foreign/node/src/wire/consumer-group/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './create-group.command.js'; export * from './delete-group.command.js'; diff --git a/foreign/node/src/wire/consumer-group/join-group.command.ts b/foreign/node/src/wire/consumer-group/join-group.command.ts index 4f28965aa5..fe9bbb8ea1 100644 --- a/foreign/node/src/wire/consumer-group/join-group.command.ts +++ b/foreign/node/src/wire/consumer-group/join-group.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { serializeTargetGroup, diff --git a/foreign/node/src/wire/consumer-group/leave-group.command.ts b/foreign/node/src/wire/consumer-group/leave-group.command.ts index 0bee9345e6..121f170406 100644 --- a/foreign/node/src/wire/consumer-group/leave-group.command.ts +++ b/foreign/node/src/wire/consumer-group/leave-group.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { serializeTargetGroup, diff --git a/foreign/node/src/wire/consumer-group/sync-group.command.test.ts b/foreign/node/src/wire/consumer-group/sync-group.command.test.ts index 85b3ba0508..00c4731950 100644 --- a/foreign/node/src/wire/consumer-group/sync-group.command.test.ts +++ b/foreign/node/src/wire/consumer-group/sync-group.command.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/consumer-group/sync-group.command.ts b/foreign/node/src/wire/consumer-group/sync-group.command.ts index 8fcac11b90..aa2f65e2dc 100644 --- a/foreign/node/src/wire/consumer-group/sync-group.command.ts +++ b/foreign/node/src/wire/consumer-group/sync-group.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { DeserializeError } from '../error.utils.js'; diff --git a/foreign/node/src/wire/error.code.ts b/foreign/node/src/wire/error.code.ts index 8c542c1d96..397c85406e 100644 --- a/foreign/node/src/wire/error.code.ts +++ b/foreign/node/src/wire/error.code.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export const translateErrorCode = (code: number): string => { switch (code.toString()) { diff --git a/foreign/node/src/wire/error.utils.ts b/foreign/node/src/wire/error.utils.ts index 54988abd0a..01eeb401ed 100644 --- a/foreign/node/src/wire/error.utils.ts +++ b/foreign/node/src/wire/error.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { translateCommandCode } from './command.code.js'; import { translateErrorCode } from './error.code.js'; diff --git a/foreign/node/src/wire/identifier.utils.test.ts b/foreign/node/src/wire/identifier.utils.test.ts index dc203f77c9..faf10a549a 100644 --- a/foreign/node/src/wire/identifier.utils.test.ts +++ b/foreign/node/src/wire/identifier.utils.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/identifier.utils.ts b/foreign/node/src/wire/identifier.utils.ts index ee38a94fa6..5d786a5007 100644 --- a/foreign/node/src/wire/identifier.utils.ts +++ b/foreign/node/src/wire/identifier.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// /** Identifier kind for numeric IDs */ const NUMERIC = 1; diff --git a/foreign/node/src/wire/index.ts b/foreign/node/src/wire/index.ts index 4e14c00b92..e82ba84b48 100644 --- a/foreign/node/src/wire/index.ts +++ b/foreign/node/src/wire/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './client/index.js'; export * from './consumer-group/index.js'; diff --git a/foreign/node/src/wire/message/flush-unsaved-buffers.command.ts b/foreign/node/src/wire/message/flush-unsaved-buffers.command.ts index 2aea31f2a1..3f8bff8d3d 100644 --- a/foreign/node/src/wire/message/flush-unsaved-buffers.command.ts +++ b/foreign/node/src/wire/message/flush-unsaved-buffers.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { type Id } from '../identifier.utils.js'; import { serializeFlushUnsavedBuffers } from './message.utils.js'; diff --git a/foreign/node/src/wire/message/header.type.ts b/foreign/node/src/wire/message/header.type.ts index 0f48e38ee0..4a40a2ae52 100644 --- a/foreign/node/src/wire/message/header.type.ts +++ b/foreign/node/src/wire/message/header.type.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { type ValueOf, reverseRecord } from "../../type.utils.js"; diff --git a/foreign/node/src/wire/message/header.utils.test.ts b/foreign/node/src/wire/message/header.utils.test.ts index 764bfc7524..590c21f121 100644 --- a/foreign/node/src/wire/message/header.utils.test.ts +++ b/foreign/node/src/wire/message/header.utils.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from "node:test"; import assert from "node:assert/strict"; diff --git a/foreign/node/src/wire/message/header.utils.ts b/foreign/node/src/wire/message/header.utils.ts index 95f7c900d6..c31d45b433 100644 --- a/foreign/node/src/wire/message/header.utils.ts +++ b/foreign/node/src/wire/message/header.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { boolToBuf, diff --git a/foreign/node/src/wire/message/iggy-header.utils.ts b/foreign/node/src/wire/message/iggy-header.utils.ts index cd4c53b448..168b4c5c3b 100644 --- a/foreign/node/src/wire/message/iggy-header.utils.ts +++ b/foreign/node/src/wire/message/iggy-header.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { xxh3 } from "@node-rs/xxhash"; import { u128LEBufToBigint } from "../number.utils.js"; diff --git a/foreign/node/src/wire/message/index.ts b/foreign/node/src/wire/message/index.ts index d394c009a6..069e7d05e5 100644 --- a/foreign/node/src/wire/message/index.ts +++ b/foreign/node/src/wire/message/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from "./poll-messages.command.js"; export * from "./send-messages.command.js"; diff --git a/foreign/node/src/wire/message/message-batch.test.ts b/foreign/node/src/wire/message/message-batch.test.ts index 4cb14bb343..027ead5b2f 100644 --- a/foreign/node/src/wire/message/message-batch.test.ts +++ b/foreign/node/src/wire/message/message-batch.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from "node:test"; import assert from "node:assert/strict"; diff --git a/foreign/node/src/wire/message/message.utils.ts b/foreign/node/src/wire/message/message.utils.ts index a350f7bd28..8ed7c0b289 100644 --- a/foreign/node/src/wire/message/message.utils.ts +++ b/foreign/node/src/wire/message/message.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { uuidv4 } from 'uuidv7'; import { uint32ToBuf, u128ToBuf, uint8ToBuf } from '../number.utils.js'; diff --git a/foreign/node/src/wire/message/partitioning.utils.ts b/foreign/node/src/wire/message/partitioning.utils.ts index b0a1d6e864..9919b0f211 100644 --- a/foreign/node/src/wire/message/partitioning.utils.ts +++ b/foreign/node/src/wire/message/partitioning.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { uint32ToBuf, uint64ToBuf } from '../number.utils.js'; import type { ValueOf } from '../../type.utils.js'; diff --git a/foreign/node/src/wire/message/poll-messages.command.test.ts b/foreign/node/src/wire/message/poll-messages.command.test.ts index f396e45393..274b8e578d 100644 --- a/foreign/node/src/wire/message/poll-messages.command.test.ts +++ b/foreign/node/src/wire/message/poll-messages.command.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import assert from 'node:assert/strict'; import { EventEmitter } from 'node:events'; diff --git a/foreign/node/src/wire/message/poll-messages.command.ts b/foreign/node/src/wire/message/poll-messages.command.ts index 4023f387e6..da6a0b4d65 100644 --- a/foreign/node/src/wire/message/poll-messages.command.ts +++ b/foreign/node/src/wire/message/poll-messages.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { Id } from '../identifier.utils.js'; import type { diff --git a/foreign/node/src/wire/message/poll.utils.ts b/foreign/node/src/wire/message/poll.utils.ts index a92e06adf8..097a9ed104 100644 --- a/foreign/node/src/wire/message/poll.utils.ts +++ b/foreign/node/src/wire/message/poll.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { type Id } from "../identifier.utils.js"; import { type ValueOf, reverseRecord } from "../../type.utils.js"; diff --git a/foreign/node/src/wire/message/send-messages.command.test.ts b/foreign/node/src/wire/message/send-messages.command.test.ts index 01fa75e45e..6026fbaf87 100644 --- a/foreign/node/src/wire/message/send-messages.command.test.ts +++ b/foreign/node/src/wire/message/send-messages.command.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from "node:test"; import assert from "node:assert/strict"; diff --git a/foreign/node/src/wire/message/send-messages.command.ts b/foreign/node/src/wire/message/send-messages.command.ts index f5cc3118da..99c5981887 100644 --- a/foreign/node/src/wire/message/send-messages.command.ts +++ b/foreign/node/src/wire/message/send-messages.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { type Id } from '../identifier.utils.js'; import { serializeSendMessages, type CreateMessage } from './message.utils.js'; diff --git a/foreign/node/src/wire/number.utils.ts b/foreign/node/src/wire/number.utils.ts index 1fceefe59f..3ea8f691fb 100644 --- a/foreign/node/src/wire/number.utils.ts +++ b/foreign/node/src/wire/number.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// /** * Converts a boolean value to a 1-byte Buffer. diff --git a/foreign/node/src/wire/offset/delete-offset.command.ts b/foreign/node/src/wire/offset/delete-offset.command.ts index 6d7f37f7ea..7e51737878 100644 --- a/foreign/node/src/wire/offset/delete-offset.command.ts +++ b/foreign/node/src/wire/offset/delete-offset.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { deserializeVoidResponse } from '../../client/client.utils.js'; import type { GetOffset } from './get-offset.command.js'; diff --git a/foreign/node/src/wire/offset/get-offset.command.ts b/foreign/node/src/wire/offset/get-offset.command.ts index d203dadb8b..a77fd85575 100644 --- a/foreign/node/src/wire/offset/get-offset.command.ts +++ b/foreign/node/src/wire/offset/get-offset.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import type { Id } from '../identifier.utils.js'; diff --git a/foreign/node/src/wire/offset/index.ts b/foreign/node/src/wire/offset/index.ts index 6f4e176131..4840da166d 100644 --- a/foreign/node/src/wire/offset/index.ts +++ b/foreign/node/src/wire/offset/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './get-offset.command.js'; export * from './store-offset.command.js'; diff --git a/foreign/node/src/wire/offset/offset.utils.ts b/foreign/node/src/wire/offset/offset.utils.ts index 4a7c859977..2561910743 100644 --- a/foreign/node/src/wire/offset/offset.utils.ts +++ b/foreign/node/src/wire/offset/offset.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { ValueOf } from '../../type.utils.js'; import { serializeIdentifier, type Id } from '../identifier.utils.js'; diff --git a/foreign/node/src/wire/offset/store-offset.command.ts b/foreign/node/src/wire/offset/store-offset.command.ts index 7d7fc6f7fe..dd2b876faa 100644 --- a/foreign/node/src/wire/offset/store-offset.command.ts +++ b/foreign/node/src/wire/offset/store-offset.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { deserializeVoidResponse } from '../../client/client.utils.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/options.utils.test.ts b/foreign/node/src/wire/options.utils.test.ts index 15d30ae1af..7fbc381d8f 100644 --- a/foreign/node/src/wire/options.utils.test.ts +++ b/foreign/node/src/wire/options.utils.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/options.utils.ts b/foreign/node/src/wire/options.utils.ts index 5946c14333..c3eb16a71e 100644 --- a/foreign/node/src/wire/options.utils.ts +++ b/foreign/node/src/wire/options.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { HeaderKind } from './message/header.type.js'; import { diff --git a/foreign/node/src/wire/partition/create-partition.command.ts b/foreign/node/src/wire/partition/create-partition.command.ts index ce3f6cb2c4..255f024b21 100644 --- a/foreign/node/src/wire/partition/create-partition.command.ts +++ b/foreign/node/src/wire/partition/create-partition.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { wrapCommand } from '../command.utils.js'; import { COMMAND_CODE } from '../command.code.js'; diff --git a/foreign/node/src/wire/partition/delete-partition.command.ts b/foreign/node/src/wire/partition/delete-partition.command.ts index cdea87ecd2..1de013133b 100644 --- a/foreign/node/src/wire/partition/delete-partition.command.ts +++ b/foreign/node/src/wire/partition/delete-partition.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { deserializeVoidResponse } from '../../client/client.utils.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/partition/index.ts b/foreign/node/src/wire/partition/index.ts index a1441b62b2..51911b9d2d 100644 --- a/foreign/node/src/wire/partition/index.ts +++ b/foreign/node/src/wire/partition/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './create-partition.command.js'; export * from './delete-partition.command.js'; diff --git a/foreign/node/src/wire/partition/partition.utils.test.ts b/foreign/node/src/wire/partition/partition.utils.test.ts index 1e5ed15715..c98442c017 100644 --- a/foreign/node/src/wire/partition/partition.utils.test.ts +++ b/foreign/node/src/wire/partition/partition.utils.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/partition/partition.utils.ts b/foreign/node/src/wire/partition/partition.utils.ts index 870c0ab246..4bacc06df3 100644 --- a/foreign/node/src/wire/partition/partition.utils.ts +++ b/foreign/node/src/wire/partition/partition.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { serializeIdentifier, type Id } from '../identifier.utils.js'; import { uint32ToBuf } from '../number.utils.js'; diff --git a/foreign/node/src/wire/segment/delete-segments.command.ts b/foreign/node/src/wire/segment/delete-segments.command.ts index dc71983a4d..ff40e73e21 100644 --- a/foreign/node/src/wire/segment/delete-segments.command.ts +++ b/foreign/node/src/wire/segment/delete-segments.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { deserializeVoidResponse } from '../../client/client.utils.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/segment/index.ts b/foreign/node/src/wire/segment/index.ts index 5fde164a57..76306fbd2e 100644 --- a/foreign/node/src/wire/segment/index.ts +++ b/foreign/node/src/wire/segment/index.ts @@ -14,6 +14,5 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './delete-segments.command.js'; diff --git a/foreign/node/src/wire/segment/segment.utils.ts b/foreign/node/src/wire/segment/segment.utils.ts index 41bba2f99e..adea44a9a1 100644 --- a/foreign/node/src/wire/segment/segment.utils.ts +++ b/foreign/node/src/wire/segment/segment.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { serializeIdentifier, type Id } from '../identifier.utils.js'; import { uint32ToBuf } from '../number.utils.js'; diff --git a/foreign/node/src/wire/serialize.utils.ts b/foreign/node/src/wire/serialize.utils.ts index 7cfc2d8bbc..9346ff7854 100644 --- a/foreign/node/src/wire/serialize.utils.ts +++ b/foreign/node/src/wire/serialize.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// /** * Converts a microsecond timestamp (BigInt) to a JavaScript Date object. diff --git a/foreign/node/src/wire/session/index.ts b/foreign/node/src/wire/session/index.ts index 63b1a5c2f4..ee52eee717 100644 --- a/foreign/node/src/wire/session/index.ts +++ b/foreign/node/src/wire/session/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './login.command.js'; export * from './login-with-token.command.js'; diff --git a/foreign/node/src/wire/session/login-with-token.command.test.ts b/foreign/node/src/wire/session/login-with-token.command.test.ts index 50a599be8b..5c8294d4f0 100644 --- a/foreign/node/src/wire/session/login-with-token.command.test.ts +++ b/foreign/node/src/wire/session/login-with-token.command.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/session/login-with-token.command.ts b/foreign/node/src/wire/session/login-with-token.command.ts index e3a50c3b1a..0eedc2d7b3 100644 --- a/foreign/node/src/wire/session/login-with-token.command.ts +++ b/foreign/node/src/wire/session/login-with-token.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { serializeLoginWithToken, type LoginResponse } from './login.utils.js'; diff --git a/foreign/node/src/wire/session/login.command.test.ts b/foreign/node/src/wire/session/login.command.test.ts index 073c43c931..8eff14341e 100644 --- a/foreign/node/src/wire/session/login.command.test.ts +++ b/foreign/node/src/wire/session/login.command.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/session/login.command.ts b/foreign/node/src/wire/session/login.command.ts index 478307921d..901e0c9883 100644 --- a/foreign/node/src/wire/session/login.command.ts +++ b/foreign/node/src/wire/session/login.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/session/login.utils.ts b/foreign/node/src/wire/session/login.utils.ts index 2e3e5854c5..e095673f07 100644 --- a/foreign/node/src/wire/session/login.utils.ts +++ b/foreign/node/src/wire/session/login.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { uint32ToBuf, uint8ToBuf } from "../number.utils.js"; diff --git a/foreign/node/src/wire/session/logout.command.ts b/foreign/node/src/wire/session/logout.command.ts index cd6f2339ab..9fe0cacd66 100644 --- a/foreign/node/src/wire/session/logout.command.ts +++ b/foreign/node/src/wire/session/logout.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { deserializeVoidResponse } from '../../client/client.utils.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/stream/create-stream.command.test.ts b/foreign/node/src/wire/stream/create-stream.command.test.ts index d985c77578..eb05fde5f6 100644 --- a/foreign/node/src/wire/stream/create-stream.command.test.ts +++ b/foreign/node/src/wire/stream/create-stream.command.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/stream/create-stream.command.ts b/foreign/node/src/wire/stream/create-stream.command.ts index 0bd82219fe..44ba2f4ad8 100644 --- a/foreign/node/src/wire/stream/create-stream.command.ts +++ b/foreign/node/src/wire/stream/create-stream.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/stream/delete-stream.command.ts b/foreign/node/src/wire/stream/delete-stream.command.ts index 4711727bf2..4fd00675f8 100644 --- a/foreign/node/src/wire/stream/delete-stream.command.ts +++ b/foreign/node/src/wire/stream/delete-stream.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { deserializeVoidResponse } from '../../client/client.utils.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/stream/ensure-stream.virtual.command.ts b/foreign/node/src/wire/stream/ensure-stream.virtual.command.ts index 3226faf162..8ee24faf33 100644 --- a/foreign/node/src/wire/stream/ensure-stream.virtual.command.ts +++ b/foreign/node/src/wire/stream/ensure-stream.virtual.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { ClientProvider } from '../../client/index.js'; import { createStream } from './create-stream.command.js'; diff --git a/foreign/node/src/wire/stream/get-stream.command.ts b/foreign/node/src/wire/stream/get-stream.command.ts index f6fb859b8b..a7ac9f42cd 100644 --- a/foreign/node/src/wire/stream/get-stream.command.ts +++ b/foreign/node/src/wire/stream/get-stream.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/stream/get-streams.command.ts b/foreign/node/src/wire/stream/get-streams.command.ts index 4a33eb907a..d424ddc544 100644 --- a/foreign/node/src/wire/stream/get-streams.command.ts +++ b/foreign/node/src/wire/stream/get-streams.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/stream/index.ts b/foreign/node/src/wire/stream/index.ts index c6ec4e4c10..35b2ad1b5f 100644 --- a/foreign/node/src/wire/stream/index.ts +++ b/foreign/node/src/wire/stream/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './create-stream.command.js'; export * from './delete-stream.command.js'; diff --git a/foreign/node/src/wire/stream/purge-stream.command.ts b/foreign/node/src/wire/stream/purge-stream.command.ts index cef91d8d75..7d79f438e2 100644 --- a/foreign/node/src/wire/stream/purge-stream.command.ts +++ b/foreign/node/src/wire/stream/purge-stream.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { wrapCommand } from '../command.utils.js'; import { COMMAND_CODE } from '../command.code.js'; diff --git a/foreign/node/src/wire/stream/stream.utils.ts b/foreign/node/src/wire/stream/stream.utils.ts index c7e3f019e6..4c453b6bb9 100644 --- a/foreign/node/src/wire/stream/stream.utils.ts +++ b/foreign/node/src/wire/stream/stream.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { toDate } from '../serialize.utils.js'; import { deserializePrefixedOptions, type ParsedOptions } from '../options.utils.js'; diff --git a/foreign/node/src/wire/stream/update-stream.command.ts b/foreign/node/src/wire/stream/update-stream.command.ts index 1a142b91c6..6aa61ab9f3 100644 --- a/foreign/node/src/wire/stream/update-stream.command.ts +++ b/foreign/node/src/wire/stream/update-stream.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { deserializeVoidResponse } from '../../client/client.utils.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/system/describe-options.command.ts b/foreign/node/src/wire/system/describe-options.command.ts index 70707f89c6..930af011bc 100644 --- a/foreign/node/src/wire/system/describe-options.command.ts +++ b/foreign/node/src/wire/system/describe-options.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/index.js'; import { COMMAND_CODE } from '../command.code.js'; diff --git a/foreign/node/src/wire/system/get-stats.command.ts b/foreign/node/src/wire/system/get-stats.command.ts index 43591f9528..5f4cf2b987 100644 --- a/foreign/node/src/wire/system/get-stats.command.ts +++ b/foreign/node/src/wire/system/get-stats.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/index.js'; import { COMMAND_CODE } from '../command.code.js'; diff --git a/foreign/node/src/wire/system/index.ts b/foreign/node/src/wire/system/index.ts index 3326db31a7..754dafd4ce 100644 --- a/foreign/node/src/wire/system/index.ts +++ b/foreign/node/src/wire/system/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './describe-options.command.js'; export * from './get-stats.command.js'; diff --git a/foreign/node/src/wire/system/ping.command.ts b/foreign/node/src/wire/system/ping.command.ts index ec4be4d047..babf87a992 100644 --- a/foreign/node/src/wire/system/ping.command.ts +++ b/foreign/node/src/wire/system/ping.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { deserializeVoidResponse } from '../../client/client.utils.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/token/create-token.command.test.ts b/foreign/node/src/wire/token/create-token.command.test.ts index 10657d2129..f6cfe085a8 100644 --- a/foreign/node/src/wire/token/create-token.command.test.ts +++ b/foreign/node/src/wire/token/create-token.command.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/token/create-token.command.ts b/foreign/node/src/wire/token/create-token.command.ts index 8c966439eb..d87d5c4cc4 100644 --- a/foreign/node/src/wire/token/create-token.command.ts +++ b/foreign/node/src/wire/token/create-token.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { deserializeCreateToken, type CreateTokenResponse } from './token.utils.js'; diff --git a/foreign/node/src/wire/token/delete-token.command.test.ts b/foreign/node/src/wire/token/delete-token.command.test.ts index fe58935082..e69e32a521 100644 --- a/foreign/node/src/wire/token/delete-token.command.test.ts +++ b/foreign/node/src/wire/token/delete-token.command.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/token/delete-token.command.ts b/foreign/node/src/wire/token/delete-token.command.ts index baeec9e1f0..ee5f537b76 100644 --- a/foreign/node/src/wire/token/delete-token.command.ts +++ b/foreign/node/src/wire/token/delete-token.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { deserializeVoidResponse } from '../../client/client.utils.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/token/get-tokens.command.ts b/foreign/node/src/wire/token/get-tokens.command.ts index b472ff2735..09fec1422c 100644 --- a/foreign/node/src/wire/token/get-tokens.command.ts +++ b/foreign/node/src/wire/token/get-tokens.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/token/index.ts b/foreign/node/src/wire/token/index.ts index cc2ff184c0..ca86e1d22e 100644 --- a/foreign/node/src/wire/token/index.ts +++ b/foreign/node/src/wire/token/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './create-token.command.js'; export * from './delete-token.command.js'; diff --git a/foreign/node/src/wire/token/token.utils.ts b/foreign/node/src/wire/token/token.utils.ts index 4da0a3f812..e4b7a641c7 100644 --- a/foreign/node/src/wire/token/token.utils.ts +++ b/foreign/node/src/wire/token/token.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { toDate } from '../serialize.utils.js'; diff --git a/foreign/node/src/wire/topic/create-topic.command.test.ts b/foreign/node/src/wire/topic/create-topic.command.test.ts index 4235d91bfb..0ca484abbe 100644 --- a/foreign/node/src/wire/topic/create-topic.command.test.ts +++ b/foreign/node/src/wire/topic/create-topic.command.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/topic/create-topic.command.ts b/foreign/node/src/wire/topic/create-topic.command.ts index 92e6226225..bdbd9d2c67 100644 --- a/foreign/node/src/wire/topic/create-topic.command.ts +++ b/foreign/node/src/wire/topic/create-topic.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { serializeIdentifier, type Id } from '../identifier.utils.js'; diff --git a/foreign/node/src/wire/topic/delete-topic.command.ts b/foreign/node/src/wire/topic/delete-topic.command.ts index bb8378b2c2..a87529a470 100644 --- a/foreign/node/src/wire/topic/delete-topic.command.ts +++ b/foreign/node/src/wire/topic/delete-topic.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { deserializeVoidResponse } from '../../client/client.utils.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/topic/ensure-topic.virtual.command.ts b/foreign/node/src/wire/topic/ensure-topic.virtual.command.ts index e6d3bff0ec..0a61de3d61 100644 --- a/foreign/node/src/wire/topic/ensure-topic.virtual.command.ts +++ b/foreign/node/src/wire/topic/ensure-topic.virtual.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { Id } from '../identifier.utils.js'; import type { ClientProvider } from '../../client/index.js'; diff --git a/foreign/node/src/wire/topic/get-topic.command.ts b/foreign/node/src/wire/topic/get-topic.command.ts index c34c6cd066..0ce0a278ee 100644 --- a/foreign/node/src/wire/topic/get-topic.command.ts +++ b/foreign/node/src/wire/topic/get-topic.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/topic/get-topics.command.ts b/foreign/node/src/wire/topic/get-topics.command.ts index dbc0e1f1b0..0780e43fe1 100644 --- a/foreign/node/src/wire/topic/get-topics.command.ts +++ b/foreign/node/src/wire/topic/get-topics.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/topic/index.ts b/foreign/node/src/wire/topic/index.ts index 0c742aa116..8baa49a180 100644 --- a/foreign/node/src/wire/topic/index.ts +++ b/foreign/node/src/wire/topic/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './create-topic.command.js'; export * from './delete-topic.command.js'; diff --git a/foreign/node/src/wire/topic/purge-topic.command.ts b/foreign/node/src/wire/topic/purge-topic.command.ts index d7dfd9a957..e01bf569c1 100644 --- a/foreign/node/src/wire/topic/purge-topic.command.ts +++ b/foreign/node/src/wire/topic/purge-topic.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { serializeIdentifier, type Id } from '../identifier.utils.js'; import { COMMAND_CODE } from '../command.code.js'; diff --git a/foreign/node/src/wire/topic/topic.utils.test.ts b/foreign/node/src/wire/topic/topic.utils.test.ts index 0e012c5a15..6d620e3853 100644 --- a/foreign/node/src/wire/topic/topic.utils.test.ts +++ b/foreign/node/src/wire/topic/topic.utils.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/topic/topic.utils.ts b/foreign/node/src/wire/topic/topic.utils.ts index 6fae7daa32..6f35e792e6 100644 --- a/foreign/node/src/wire/topic/topic.utils.ts +++ b/foreign/node/src/wire/topic/topic.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { toDate } from '../serialize.utils.js'; import type { ValueOf } from '../../type.utils.js'; diff --git a/foreign/node/src/wire/topic/update-topic.command.ts b/foreign/node/src/wire/topic/update-topic.command.ts index a719781773..e8255ef421 100644 --- a/foreign/node/src/wire/topic/update-topic.command.ts +++ b/foreign/node/src/wire/topic/update-topic.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { serializeIdentifier, type Id } from '../identifier.utils.js'; import { dedupeOptions, serializeOptions, type OptionEntry } from '../options.utils.js'; diff --git a/foreign/node/src/wire/user/change-password.command.ts b/foreign/node/src/wire/user/change-password.command.ts index 53ae1951a6..12b4485c1c 100644 --- a/foreign/node/src/wire/user/change-password.command.ts +++ b/foreign/node/src/wire/user/change-password.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { uint8ToBuf } from '../number.utils.js'; import { serializeIdentifier } from '../identifier.utils.js'; diff --git a/foreign/node/src/wire/user/create-user.command.test.ts b/foreign/node/src/wire/user/create-user.command.test.ts index 19b94df8a1..c9d4d03748 100644 --- a/foreign/node/src/wire/user/create-user.command.test.ts +++ b/foreign/node/src/wire/user/create-user.command.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/user/create-user.command.ts b/foreign/node/src/wire/user/create-user.command.ts index fb907170d6..316cdaf5a8 100644 --- a/foreign/node/src/wire/user/create-user.command.ts +++ b/foreign/node/src/wire/user/create-user.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/user/delete-user.command.ts b/foreign/node/src/wire/user/delete-user.command.ts index d7274672b8..e0a3559746 100644 --- a/foreign/node/src/wire/user/delete-user.command.ts +++ b/foreign/node/src/wire/user/delete-user.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { deserializeVoidResponse } from '../../client/client.utils.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/user/get-user.command.ts b/foreign/node/src/wire/user/get-user.command.ts index fb047e1e7e..ce773827c5 100644 --- a/foreign/node/src/wire/user/get-user.command.ts +++ b/foreign/node/src/wire/user/get-user.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/user/get-users.command.ts b/foreign/node/src/wire/user/get-users.command.ts index fd88bef862..0930c3b33e 100644 --- a/foreign/node/src/wire/user/get-users.command.ts +++ b/foreign/node/src/wire/user/get-users.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import type { CommandResponse } from '../../client/client.type.js'; import { wrapCommand } from '../command.utils.js'; diff --git a/foreign/node/src/wire/user/index.ts b/foreign/node/src/wire/user/index.ts index 5def0a7adc..0de300ada9 100644 --- a/foreign/node/src/wire/user/index.ts +++ b/foreign/node/src/wire/user/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// export * from './change-password.command.js'; export * from './create-user.command.js' diff --git a/foreign/node/src/wire/user/permissions.utils.test.ts b/foreign/node/src/wire/user/permissions.utils.test.ts index d0eea0948b..67be55628c 100644 --- a/foreign/node/src/wire/user/permissions.utils.test.ts +++ b/foreign/node/src/wire/user/permissions.utils.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/node/src/wire/user/permissions.utils.ts b/foreign/node/src/wire/user/permissions.utils.ts index 472f85f7e7..709f03b7b5 100644 --- a/foreign/node/src/wire/user/permissions.utils.ts +++ b/foreign/node/src/wire/user/permissions.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { uint8ToBuf, uint32ToBuf } from '../number.utils.js'; diff --git a/foreign/node/src/wire/user/update-permissions.command.ts b/foreign/node/src/wire/user/update-permissions.command.ts index 9a67b4e11d..cb49b26440 100644 --- a/foreign/node/src/wire/user/update-permissions.command.ts +++ b/foreign/node/src/wire/user/update-permissions.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { wrapCommand } from '../command.utils.js'; import { COMMAND_CODE } from '../command.code.js'; diff --git a/foreign/node/src/wire/user/update-user.command.ts b/foreign/node/src/wire/user/update-user.command.ts index 028418c168..4317237a20 100644 --- a/foreign/node/src/wire/user/update-user.command.ts +++ b/foreign/node/src/wire/user/update-user.command.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { wrapCommand } from '../command.utils.js'; import { COMMAND_CODE } from '../command.code.js'; diff --git a/foreign/node/src/wire/user/user.utils.ts b/foreign/node/src/wire/user/user.utils.ts index cab94001d5..a7eaa71b07 100644 --- a/foreign/node/src/wire/user/user.utils.ts +++ b/foreign/node/src/wire/user/user.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { toDate } from '../serialize.utils.js'; import { deserializePermissions, type UserPermissions } from './permissions.utils.js'; diff --git a/foreign/node/src/wire/uuid.utils.ts b/foreign/node/src/wire/uuid.utils.ts index d0c74d07e9..e87d575080 100644 --- a/foreign/node/src/wire/uuid.utils.ts +++ b/foreign/node/src/wire/uuid.utils.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { uuidv7, UUID } from "uuidv7"; diff --git a/foreign/node/src/wire/vsr/header.ts b/foreign/node/src/wire/vsr/header.ts index 4b00e60aed..d54182c5ba 100644 --- a/foreign/node/src/wire/vsr/header.ts +++ b/foreign/node/src/wire/vsr/header.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// /** * VSR consensus header layout, ported from diff --git a/foreign/node/src/wire/vsr/index.ts b/foreign/node/src/wire/vsr/index.ts index ca88e7945b..24091ca1fe 100644 --- a/foreign/node/src/wire/vsr/index.ts +++ b/foreign/node/src/wire/vsr/index.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { createRequire } from 'node:module'; import type { CommandResponse } from '../../client/client.type.js'; diff --git a/foreign/node/src/wire/vsr/operation.ts b/foreign/node/src/wire/vsr/operation.ts index 6c7520d5c6..2781668885 100644 --- a/foreign/node/src/wire/vsr/operation.ts +++ b/foreign/node/src/wire/vsr/operation.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// /** * `Operation` values and classification, ported from diff --git a/foreign/node/src/wire/vsr/register.ts b/foreign/node/src/wire/vsr/register.ts index 11e102738f..6075efabb2 100644 --- a/foreign/node/src/wire/vsr/register.ts +++ b/foreign/node/src/wire/vsr/register.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// /** * The Register (login) handshake bodies and reply, ported from diff --git a/foreign/node/src/wire/vsr/reply.ts b/foreign/node/src/wire/vsr/reply.ts index b0871eaef2..8db1c18df6 100644 --- a/foreign/node/src/wire/vsr/reply.ts +++ b/foreign/node/src/wire/vsr/reply.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// /** * Reply decode funnel, ported from `decode_response` in diff --git a/foreign/node/src/wire/vsr/session.ts b/foreign/node/src/wire/vsr/session.ts index af86b4c254..f61cbc3f0b 100644 --- a/foreign/node/src/wire/vsr/session.ts +++ b/foreign/node/src/wire/vsr/session.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { randomBytes } from 'node:crypto'; diff --git a/foreign/node/src/wire/vsr/vsr.test.ts b/foreign/node/src/wire/vsr/vsr.test.ts index 61f8564555..60e9c19088 100644 --- a/foreign/node/src/wire/vsr/vsr.test.ts +++ b/foreign/node/src/wire/vsr/vsr.test.ts @@ -14,7 +14,6 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -// import { describe, it } from 'node:test'; import assert from 'node:assert/strict'; diff --git a/foreign/php/iggy-php.stubs.php b/foreign/php/iggy-php.stubs.php index 211e6f120f..a1c913e042 100644 --- a/foreign/php/iggy-php.stubs.php +++ b/foreign/php/iggy-php.stubs.php @@ -16,7 +16,6 @@ // specific language governing permissions and limitations // under the License. - // Stubs for iggy-php namespace Iggy { diff --git a/foreign/php/phpunit.xml.dist b/foreign/php/phpunit.xml.dist index 5c6f310389..aef6443c5c 100644 --- a/foreign/php/phpunit.xml.dist +++ b/foreign/php/phpunit.xml.dist @@ -1,24 +1,23 @@ + /dev/null; then exit 1 fi -HAWKEYE_VERSION="$(cat .github/config/hawkeye.version)" - # Check if HawkEye is available if ! command -v hawkeye &> /dev/null; then echo "❌ hawkeye command not found" - echo "💡 Install HawkEye: cargo install hawkeye --version $HAWKEYE_VERSION --locked" - exit 1 -fi - -INSTALLED_HAWKEYE_VERSION="$(hawkeye -V | awk '{print $2}')" -if [ "$INSTALLED_HAWKEYE_VERSION" != "$HAWKEYE_VERSION" ]; then - echo "❌ hawkeye $HAWKEYE_VERSION is required, found ${INSTALLED_HAWKEYE_VERSION:-unknown}" - echo "💡 Install HawkEye: cargo install hawkeye --version $HAWKEYE_VERSION --locked --force" + echo "💡 Install HawkEye: cargo install hawkeye --locked" exit 1 fi @@ -143,7 +134,18 @@ extract_hawkeye_paths() { local key="$1" local file="$2" - jq -r --arg key "$key" '.[$key] // [] | .[]' "$file" \ + jq -r --arg key "$key" ' + .files[] + | select( + if $key == "missing" then .outcome == "add" + elif $key == "inconsistent" then (.outcome == "replace" or .outcome == "conflict") + elif $key == "change" then (.outcome == "add" or .outcome == "replace") + elif $key == "unknown" then .outcome == "unsupported" + else .outcome == $key + end + ) + | .path + ' "$file" \ | awk -v root="$REPO_ROOT" ' NF { if (index($0, root "/") == 1) { @@ -176,20 +178,24 @@ write_hawkeye_report() { local json_file="$1" local report_file="$2" local missing_file + local inconsistent_file local unknown_file missing_file=$(mktemp) + inconsistent_file=$(mktemp) unknown_file=$(mktemp) extract_hawkeye_paths missing "$json_file" > "$missing_file" + extract_hawkeye_paths inconsistent "$json_file" > "$inconsistent_file" extract_hawkeye_paths unknown "$json_file" > "$unknown_file" { append_hawkeye_section "Missing license headers" "$missing_file" + append_hawkeye_section "Inconsistent license headers" "$inconsistent_file" append_hawkeye_section "Unknown file types" "$unknown_file" } > "$report_file" - rm -f "$missing_file" "$unknown_file" + rm -f "$missing_file" "$inconsistent_file" "$unknown_file" } find_duplicate_license_headers() { @@ -286,8 +292,8 @@ if [ "$MODE" = "fix" ]; then LOG_FILE=$(mktemp) trap 'rm -f "$TEMP_FILE" "$MISSING_FILE" "$UNKNOWN_FILE" "$DUPLICATE_FILE" "$LOG_FILE"' EXIT - run_hawkeye check --config licenserc.toml --fail-if-unknown -o "$TEMP_FILE" > "$LOG_FILE" 2>&1 || true - extract_hawkeye_paths missing "$TEMP_FILE" > "$MISSING_FILE" + run_hawkeye check --config licenserc.toml --fail-on-unknown --output-format json > "$TEMP_FILE" 2> "$LOG_FILE" || true + extract_hawkeye_paths change "$TEMP_FILE" > "$MISSING_FILE" extract_hawkeye_paths unknown "$TEMP_FILE" > "$UNKNOWN_FILE" if [ -s "$UNKNOWN_FILE" ]; then @@ -297,7 +303,7 @@ if [ "$MODE" = "fix" ]; then exit 1 fi - run_hawkeye format --config licenserc.toml --fail-if-updated false --fail-if-unknown + run_hawkeye format --config licenserc.toml --fail-on-unknown find_duplicate_license_headers "$DUPLICATE_FILE" if [ -s "$MISSING_FILE" ]; then @@ -327,7 +333,7 @@ else trap 'rm -f "$TEMP_FILE" "$REPORT_FILE" "$DUPLICATE_FILE" "$LOG_FILE"' EXIT HAWKEYE_STATUS=0 - run_hawkeye check --config licenserc.toml --fail-if-unknown -o "$TEMP_FILE" > "$LOG_FILE" 2>&1 || HAWKEYE_STATUS=$? + run_hawkeye check --config licenserc.toml --fail-on-unknown --output-format json > "$TEMP_FILE" 2> "$LOG_FILE" || HAWKEYE_STATUS=$? find_duplicate_license_headers "$DUPLICATE_FILE" if [ "$HAWKEYE_STATUS" -eq 0 ] && [ ! -s "$DUPLICATE_FILE" ]; then diff --git a/scripts/dashboard/build_release.sh b/scripts/dashboard/build_release.sh index e06b9b46a7..360e6af0f2 100755 --- a/scripts/dashboard/build_release.sh +++ b/scripts/dashboard/build_release.sh @@ -16,7 +16,6 @@ # specific language governing permissions and limitations # under the License. - # Exit on any error set -euo pipefail diff --git a/scripts/dashboard/run_dev.sh b/scripts/dashboard/run_dev.sh index 6cbd365283..3d7489a94c 100755 --- a/scripts/dashboard/run_dev.sh +++ b/scripts/dashboard/run_dev.sh @@ -16,7 +16,6 @@ # specific language governing permissions and limitations # under the License. - # Exit on any error set -euo pipefail diff --git a/web/src/app.html b/web/src/app.html index 6b3c4b7ae3..5ab5a6432a 100644 --- a/web/src/app.html +++ b/web/src/app.html @@ -1,24 +1,23 @@ + diff --git a/web/src/lib/components/AppToasts.svelte b/web/src/lib/components/AppToasts.svelte index f3356964cc..e0215f6f04 100644 --- a/web/src/lib/components/AppToasts.svelte +++ b/web/src/lib/components/AppToasts.svelte @@ -1,23 +1,22 @@ + diff --git a/web/src/lib/components/LoadingIndicator.svelte b/web/src/lib/components/LoadingIndicator.svelte index 362370358a..ffa821d54e 100644 --- a/web/src/lib/components/LoadingIndicator.svelte +++ b/web/src/lib/components/LoadingIndicator.svelte @@ -1,23 +1,22 @@ + diff --git a/web/src/routes/+layout.svelte b/web/src/routes/+layout.svelte index 8d46bc8751..c61d7bf190 100644 --- a/web/src/routes/+layout.svelte +++ b/web/src/routes/+layout.svelte @@ -1,23 +1,22 @@ + diff --git a/web/src/routes/dashboard/logs/+page.svelte b/web/src/routes/dashboard/logs/+page.svelte index f01f925202..0ef21ee4af 100644 --- a/web/src/routes/dashboard/logs/+page.svelte +++ b/web/src/routes/dashboard/logs/+page.svelte @@ -1,23 +1,22 @@ + diff --git a/web/src/routes/dashboard/overview/+page.svelte b/web/src/routes/dashboard/overview/+page.svelte index dcc36533df..dd860aec15 100644 --- a/web/src/routes/dashboard/overview/+page.svelte +++ b/web/src/routes/dashboard/overview/+page.svelte @@ -1,23 +1,22 @@ + diff --git a/web/src/routes/dashboard/settings/users/+page.svelte b/web/src/routes/dashboard/settings/users/+page.svelte index 409edb17fa..1e958a41c0 100644 --- a/web/src/routes/dashboard/settings/users/+page.svelte +++ b/web/src/routes/dashboard/settings/users/+page.svelte @@ -1,23 +1,22 @@ + diff --git a/web/src/routes/dashboard/streams/[streamId=i32]/+page.svelte b/web/src/routes/dashboard/streams/[streamId=i32]/+page.svelte index fd4d185c5e..041f0de6de 100644 --- a/web/src/routes/dashboard/streams/[streamId=i32]/+page.svelte +++ b/web/src/routes/dashboard/streams/[streamId=i32]/+page.svelte @@ -1,23 +1,22 @@ +