This is an automated email from the ASF dual-hosted git repository.
piotr pushed a change to branch bump-versions-script
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 90655ca5b Merge branch 'master' into bump-versions-script
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 eca0147e0 Merge branch 'master' into bump-versions-script
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 35 +-
Cargo.toml | 10 +-
DEPENDENCIES.md | 34 +-
core/ai/mcp/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
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/commands/messages/send_messages.rs | 75 ++--
core/common/src/types/message/iggy_message.rs | 63 ++-
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/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/python/Cargo.toml | 4 +-
foreign/python/pyproject.toml | 2 +-
57 files changed, 2390 insertions(+), 228 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
