This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch refactor-binary-7-http
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 11be16e6a fix(server,sdk): fix O(n^2) memory in HTTP SendMessages and
missing transport codes
omit a44e11845 fix(server,sdk): harden wire type migration
omit 2d257dd9a fix(server,sdk): harden wire type migration from review
findings
omit db9b7df3b fix(server): restore partition count validation in binary
handlers
omit 810b90f07 refactor(sdk): delete BytesSerializable trait entirely
omit 975d67e4a refactor(server): migrate WAL to WireEncode/WireDecode traits
omit 53bb42b86 refactor(server): remove dead BytesSerializable impls from
10 types
omit 5c3addfea refactor(server): extract shared HTTP DTOs to iggy_common
omit 4a8690a95 refactor(server): switch WAL to wire types and move domain
commands to http DTOs
omit 6c4971214 refactor(server): delete dead command structs and simplify
SDK traits
omit 2018a4393 refactor(server): route wire types through
ShardRequestPayload and SDK
add 169a09bcd fix(go): correct Permissions serialization and add unit
tests (#3015)
add 3e848424b feat(cli): Add context create/delete CLI commands to
complete login/logout workflow (#2998)
add 4ca3cf2b3 feat(security): encrypt user headers alongside message
payload (#3040)
add e0c55e6e4 fix(test): remove race condition in postgres source mark
test (#3052)
add 30fae4cef fix: stats semver wire alignment using a zero sentinel
(#3036)
add bd595ef34 chore(deps): bump pygments from 2.19.2 to 2.20.0 in
/bdd/python (#3055)
add d0786e0f9 chore(deps): bump pygments from 2.19.2 to 2.20.0 in
/foreign/python (#3054)
new 89c729e05 refactor(server): route wire types through
ShardRequestPayload and SDK
new 10159a266 refactor(server): delete dead command structs and simplify
SDK traits
new 286dc2076 refactor(server): switch WAL to wire types and move domain
commands to http DTOs
new b9505ca98 refactor(server): extract shared HTTP DTOs to iggy_common
new 0bb7377ca refactor(server): remove dead BytesSerializable impls from
10 types
new fe7c92d2c refactor(server): migrate WAL to WireEncode/WireDecode traits
new 056cff621 refactor(sdk): delete BytesSerializable trait entirely
new 0ee9523ad fix(server): restore partition count validation in binary
handlers
new 06f091ed5 fix(server,sdk): harden wire type migration from review
findings
new 92b607110 fix(server,sdk): harden wire type migration
new 38f132138 fix(server,sdk): fix O(n^2) memory in HTTP SendMessages and
missing transport codes
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 (11be16e6a)
\
N -- N -- N refs/heads/refactor-binary-7-http (38f132138)
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.
The 11 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
Cargo.lock | 35 +-
Cargo.toml | 10 +-
DEPENDENCIES.md | 34 +-
bdd/python/uv.lock | 8 +-
core/ai/mcp/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
.../src/responses/system/get_stats.rs | 88 ++-
core/cli/Cargo.toml | 6 +-
core/cli/src/args/context.rs | 157 +++++
core/cli/src/commands/binary_context/common.rs | 483 ++++++++++++-
.../{use_context.rs => create_context.rs} | 57 +-
.../{use_context.rs => delete_context.rs} | 49 +-
core/cli/src/commands/binary_context/mod.rs | 2 +
core/cli/src/main.rs | 9 +
core/common/Cargo.toml | 2 +-
core/common/src/http/messages/send_messages.rs | 76 ++-
core/common/src/types/message/iggy_message.rs | 64 +-
core/common/src/utils/crypto.rs | 70 ++
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/sdk/Cargo.toml | 2 +-
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +-
core/connectors/sinks/mongodb_sink/Cargo.toml | 2 +-
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +-
core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
.../sources/elasticsearch_source/Cargo.toml | 2 +-
core/connectors/sources/postgres_source/Cargo.toml | 2 +-
core/connectors/sources/random_source/Cargo.toml | 2 +-
.../src/harness/handle/client_builder.rs | 16 +-
.../src/harness/orchestrator/harness.rs | 28 +-
core/integration/tests/cli/context/common.rs | 4 +
core/integration/tests/cli/context/mod.rs | 2 +
.../tests/cli/context/test_context_applied.rs | 4 +-
.../cli/context/test_context_create_command.rs | 239 +++++++
.../cli/context/test_context_delete_command.rs | 224 +++++++
.../tests/cli/context/test_context_list_command.rs | 6 +-
.../tests/cli/context/test_context_use_command.rs | 4 +-
.../tests/connectors/postgres/postgres_source.rs | 11 +-
.../tests/server/scenarios/encryption_scenario.rs | 252 ++++++-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/binary_message.rs | 12 +
core/sdk/src/clients/consumer.rs | 19 +-
core/sdk/src/clients/producer.rs | 6 +
core/server/Cargo.toml | 2 +-
core/server/src/shard/system/messages.rs | 59 +-
.../HeaderEncryptionIntegrationTests.cs | 211 ++++++
foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.cs | 12 +-
.../csharp/Iggy_SDK/Contracts/MessageResponse.cs | 12 +-
.../csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs | 4 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
.../Iggy_SDK/JsonConverters/MessageConverter.cs | 9 +-
.../JsonConverters/MessageResponseConverter.cs | 98 +++
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 108 ++-
foreign/csharp/Iggy_SDK/Messages/Message.cs | 6 +
.../csharp/Iggy_SDK/Publishers/IggyPublisher.cs | 13 +-
.../Iggy_SDK/Utils/TcpMessageStreamHelpers.cs | 6 +
.../MapperTests/HeaderEncryptionTests.cs | 174 +++++
foreign/go/contracts/users.go | 25 +-
foreign/go/contracts/users_test.go | 746 +++++++++++++++++++++
foreign/python/Cargo.toml | 4 +-
foreign/python/pyproject.toml | 2 +-
foreign/python/uv.lock | 8 +-
63 files changed, 3209 insertions(+), 297 deletions(-)
copy core/cli/src/commands/binary_context/{use_context.rs =>
create_context.rs} (51%)
copy core/cli/src/commands/binary_context/{use_context.rs =>
delete_context.rs} (61%)
create mode 100644
core/integration/tests/cli/context/test_context_create_command.rs
create mode 100644
core/integration/tests/cli/context/test_context_delete_command.rs
create mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/HeaderEncryptionIntegrationTests.cs
create mode 100644
foreign/csharp/Iggy_SDK/JsonConverters/MessageResponseConverter.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/MapperTests/HeaderEncryptionTests.cs
create mode 100644 foreign/go/contracts/users_test.go
