This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/npm_and_yarn/foreign/node/node-b6545ba305
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit bcd1c0e8b chore(deps): Bump the node group across 1 directory with 3
updates
add c1f837534 test(bdd): fail Go BDD runner on undefined steps (#3681)
add 990ff05bd fix(node): correct scoped permissions wire codec (#3642)
add 96746159f fix(sdk): rejoin consumer group after membership loss under
vsr (#3703)
add 90ce2da8e perf(common): write message header directly into target
buffer (#3707)
add 499d8aa46 perf(common): decode user headers without copying the blob
(#3708)
add 178961055 fix(server-ng): eliminate unnecessary backpressure under
concurrent clients (#3692)
add 4a6f173d4 feat(python): add user management methods to IggyClient
(#3695)
add 13484af11 chore(deps): Bump the csharp group with 4 updates (#3712)
add c2f270cc8 feat(sdk): expose raw command API across foreign clients
(#3691)
add d29aef3b5 chore(deps): Bump brace-expansion from 5.0.5 to 5.0.7 in
/web (#3714)
add 5de407286 test(bdd): fail Rust BDD runner on undefined steps (#3680)
add 95c85e9e0 chore(deps): Bump brace-expansion from 5.0.4 to 5.0.7 in
/foreign/node (#3713)
add f65bb974f fix(integration): gate keyring setup on supported targets
(#3717)
add a114eb5d7 fix(ci): align local golangci-lint version with CI (#3719)
add 6c655b586 chore(deps): Bump the node group across 1 directory with 3
updates
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (bcd1c0e8b)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/foreign/node/node-b6545ba305 (6c655b586)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.pre-commit-config.yaml | 6 +-
Cargo.lock | 9 +-
Cargo.toml | 6 +-
.../step_definitions/raw_command_steps.cpp | 65 +
bdd/cpp/features/step_definitions/world.hpp | 2 +
bdd/cpp/scripts/entrypoint.sh | 8 +-
bdd/docker-compose.yml | 56 +-
bdd/go/tests/raw_command.go | 126 ++
bdd/go/tests/suite_test.go | 13 +
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 36 +
.../test/java/org/apache/iggy/bdd/TestContext.java | 2 +
bdd/node/Dockerfile | 1 +
bdd/php/tests/BasicMessagingFeatureTest.php | 88 +-
bdd/php/tests/RawCommandFeatureTest.php | 102 ++
bdd/php/tests/SharedFeatureParser.php | 94 ++
bdd/python/tests/conftest.py | 2 +
bdd/python/tests/test_raw_command.py | 82 ++
bdd/python/uv.lock | 2 +-
bdd/rust/Cargo.toml | 5 +
bdd/rust/tests/basic_messaging.rs | 5 +-
bdd/rust/tests/common/global_context.rs | 4 +-
bdd/rust/tests/leader_redirection.rs | 5 +-
.../tests/{basic_messaging.rs => raw_command.rs} | 2 +-
bdd/rust/tests/steps/mod.rs | 1 +
bdd/rust/tests/steps/raw_command.rs | 60 +
bdd/scenarios/raw_command.feature | 41 +
core/binary_protocol/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/common/src/consumer_group_client_state.rs | 26 +
core/common/src/traits/binary_impls/messages.rs | 32 +-
core/common/src/traits/message_client.rs | 2 +
core/common/src/types/message/iggy_message.rs | 46 +-
core/common/src/types/message/message_header.rs | 80 +-
core/common/src/types/message/message_view.rs | 78 +-
core/common/src/wire_conversions.rs | 93 +-
core/configs/src/lib.rs | 4 +-
core/configs/src/server_ng_config/defaults.rs | 14 +
core/configs/src/server_ng_config/displays.rs | 14 +-
core/configs/src/server_ng_config/metadata.rs | 183 +++
core/configs/src/server_ng_config/mod.rs | 1 +
core/configs/src/server_ng_config/server_ng.rs | 2 +
core/configs/src/server_ng_config/validators.rs | 3 +
core/consensus/src/impls.rs | 100 +-
core/consensus/src/plane_helpers.rs | 22 +
core/integration/Cargo.toml | 1 -
.../src/harness/handle/connectors_runtime.rs | 17 +-
core/integration/src/harness/handle/mcp.rs | 13 +-
core/integration/src/harness/handle/server.rs | 15 +-
core/integration/src/harness/port_reserver.rs | 677 +++++----
core/integration/src/harness/traits.rs | 1 -
core/integration/tests/cli/common/keyring.rs | 43 +-
core/integration/tests/cli/common/mod.rs | 35 +-
.../tests/connectors/doris/doris_sink.rs | 69 +-
.../tests/sdk/consumer_group_membership.rs | 139 ++
core/integration/tests/sdk/mod.rs | 2 +
core/journal/Cargo.toml | 1 +
core/journal/src/prepare_journal.rs | 150 +-
core/message_bus/src/client_listener/quic.rs | 9 +-
core/message_bus/src/socket_opts.rs | 18 +-
core/metadata/Cargo.toml | 1 +
core/metadata/src/impls/metadata.rs | 1537 +++++++++++++++++---
core/metadata/src/impls/recovery.rs | 48 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/prelude.rs | 4 +-
core/server-ng/config.toml | 19 +
core/server-ng/src/bootstrap.rs | 26 +-
core/server-ng/src/dispatch.rs | 343 +++++
core/server-ng/src/http/state.rs | 21 +-
core/server-ng/src/http/submit.rs | 31 +-
core/shard/src/lib.rs | 8 +
examples/python/uv.lock | 2 +-
foreign/cpp/Cargo.toml | 2 +-
foreign/cpp/MODULE.bazel | 2 +-
foreign/cpp/src/client.rs | 14 +
foreign/cpp/src/lib.rs | 1 +
foreign/cpp/tests/client/low_level_e2e.cpp | 89 +-
foreign/csharp/Directory.Packages.props | 8 +-
.../Iggy_SDK.Tests.BDD/Context/TestContext.cs | 2 +
.../csharp/Iggy_SDK.Tests.BDD/Context/TestHooks.cs | 2 +
.../Iggy_SDK.Tests.BDD/Iggy_SDK.Tests.BDD.csproj | 3 +
.../StepDefinitions/RawCommandSteps.cs | 71 +
.../Iggy_SDK.Tests.Integration/RawCommandTests.cs | 83 ++
foreign/csharp/Iggy_SDK/IggyClient/IIggyClient.cs | 13 +
.../Implementations/HttpMessageStream.cs | 13 +
.../IggyClient/Implementations/TcpMessageStream.cs | 28 +
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 2 +
foreign/go/client/tcp/tcp_core.go | 47 +-
foreign/go/client/tcp/tcp_core_test.go | 104 ++
foreign/go/contracts/client.go | 4 +
foreign/go/contracts/version.go | 2 +-
foreign/go/internal/command/code.go | 2 +
foreign/java/gradle.properties | 2 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 47 +
.../iggy/client/blocking/IggyBaseClient.java | 12 +
.../iggy/client/blocking/http/IggyHttpClient.java | 7 +
.../iggy/client/blocking/tcp/IggyTcpClient.java | 6 +
.../java/org/apache/iggy/serde/CommandCode.java | 6 +-
...tFactory.java => RawCommandHttpClientTest.java} | 15 +-
.../blocking/tcp/RawCommandTcpClientTest.java | 74 +
foreign/node/package-lock.json | 132 +-
foreign/node/package.json | 2 +-
foreign/node/src/bdd/raw.ts | 48 +
foreign/node/src/bdd/world.ts | 4 +-
.../src/e2e/{tcp.client.e2e.ts => tcp.raw.e2e.ts} | 30 +-
foreign/node/src/e2e/tcp.user.e2e.ts | 38 +-
foreign/node/src/wire/command-set.test.ts | 113 ++
foreign/node/src/wire/command-set.ts | 31 +-
foreign/node/src/wire/command.code.ts | 2 +
.../node/src/wire/user/create-user.command.test.ts | 40 +-
foreign/node/src/wire/user/create-user.command.ts | 14 +-
.../node/src/wire/user/permissions.utils.test.ts | 118 +-
foreign/node/src/wire/user/permissions.utils.ts | 73 +-
foreign/php/Cargo.toml | 2 +-
foreign/php/README.md | 2 +
foreign/php/iggy-php.stubs.php | 10 +
foreign/php/src/client.rs | 17 +-
foreign/php/tests/RawCommandTest.php | 77 +
foreign/python/Cargo.toml | 4 +-
foreign/python/apache_iggy.pyi | 170 +++
foreign/python/pyproject.toml | 2 +-
foreign/python/src/client.rs | 178 ++-
foreign/python/src/lib.rs | 5 +
foreign/python/src/user.rs | 131 ++
foreign/python/tests/test_raw_command.py | 47 +
foreign/python/tests/test_user.py | 616 ++++++++
foreign/python/uv.lock | 2 +-
justfile | 14 +
scripts/run-bdd-tests.sh | 6 +-
web/package-lock.json | 6 +-
130 files changed, 6389 insertions(+), 967 deletions(-)
create mode 100644 bdd/cpp/features/step_definitions/raw_command_steps.cpp
create mode 100644 bdd/go/tests/raw_command.go
create mode 100644 bdd/php/tests/RawCommandFeatureTest.php
create mode 100644 bdd/php/tests/SharedFeatureParser.php
create mode 100644 bdd/python/tests/test_raw_command.py
copy bdd/rust/tests/{basic_messaging.rs => raw_command.rs} (92%)
create mode 100644 bdd/rust/tests/steps/raw_command.rs
create mode 100644 bdd/scenarios/raw_command.feature
create mode 100644 core/configs/src/server_ng_config/metadata.rs
create mode 100644 core/integration/tests/sdk/consumer_group_membership.rs
create mode 100644
foreign/csharp/Iggy_SDK.Tests.BDD/StepDefinitions/RawCommandSteps.cs
create mode 100644 foreign/csharp/Iggy_SDK.Tests.Integration/RawCommandTests.cs
copy
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/http/{HttpClientFactory.java
=> RawCommandHttpClientTest.java} (65%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/tcp/RawCommandTcpClientTest.java
create mode 100644 foreign/node/src/bdd/raw.ts
copy foreign/node/src/e2e/{tcp.client.e2e.ts => tcp.raw.e2e.ts} (58%)
create mode 100644 foreign/node/src/wire/command-set.test.ts
create mode 100644 foreign/php/tests/RawCommandTest.php
create mode 100644 foreign/python/src/user.rs
create mode 100644 foreign/python/tests/test_raw_command.py
create mode 100644 foreign/python/tests/test_user.py