This is an automated email from the ASF dual-hosted git repository.
maciej pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iggy.git
The following commit(s) were added to refs/heads/master by this push:
new 1be2aa3c0 fix(rust): fix log in with PAT by publishing missing
diagnostic event (#2569)
1be2aa3c0 is described below
commit 1be2aa3c0e566c47185021aeacf9b38738ae6885
Author: Maciej Modzelewski <[email protected]>
AuthorDate: Thu Jan 15 18:24:20 2026 +0100
fix(rust): fix log in with PAT by publishing missing diagnostic event
(#2569)
---
Cargo.lock | 8 ++++----
DEPENDENCIES.md | 8 ++++----
core/ai/mcp/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
.../src/client/binary_personal_access_tokens/mod.rs | 8 +++++---
core/connectors/runtime/Cargo.toml | 2 +-
core/sdk/Cargo.toml | 2 +-
7 files changed, 17 insertions(+), 15 deletions(-)
diff --git a/Cargo.lock b/Cargo.lock
index c333aaabe..135d7bd94 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -4474,7 +4474,7 @@ dependencies = [
[[package]]
name = "iggy"
-version = "0.8.1-edge.3"
+version = "0.8.1-edge.4"
dependencies = [
"async-broadcast",
"async-dropper",
@@ -4584,7 +4584,7 @@ dependencies = [
[[package]]
name = "iggy-connectors"
-version = "0.2.1-edge.2"
+version = "0.2.1-edge.3"
dependencies = [
"async-trait",
"axum",
@@ -4625,7 +4625,7 @@ dependencies = [
[[package]]
name = "iggy-mcp"
-version = "0.2.1-edge.2"
+version = "0.2.1-edge.3"
dependencies = [
"axum",
"axum-server",
@@ -4649,7 +4649,7 @@ dependencies = [
[[package]]
name = "iggy_binary_protocol"
-version = "0.8.1-edge.1"
+version = "0.8.1-edge.2"
dependencies = [
"anyhow",
"async-broadcast",
diff --git a/DEPENDENCIES.md b/DEPENDENCIES.md
index 2da51928b..1468dcbb0 100644
--- a/DEPENDENCIES.md
+++ b/DEPENDENCIES.md
@@ -392,13 +392,13 @@ icu_provider: 2.1.1, "Unicode-3.0",
ident_case: 1.0.1, "Apache-2.0 OR MIT",
idna: 1.1.0, "Apache-2.0 OR MIT",
idna_adapter: 1.2.1, "Apache-2.0 OR MIT",
-iggy: 0.8.1-edge.3, "Apache-2.0",
+iggy: 0.8.1-edge.4, "Apache-2.0",
iggy-bench: 0.3.1-edge.1, "Apache-2.0",
iggy-bench-dashboard-server: 0.5.1-edge.1, "Apache-2.0",
iggy-cli: 0.10.1-edge.1, "Apache-2.0",
-iggy-connectors: 0.2.1-edge.2, "Apache-2.0",
-iggy-mcp: 0.2.1-edge.2, "Apache-2.0",
-iggy_binary_protocol: 0.8.1-edge.1, "Apache-2.0",
+iggy-connectors: 0.2.1-edge.3, "Apache-2.0",
+iggy-mcp: 0.2.1-edge.3, "Apache-2.0",
+iggy_binary_protocol: 0.8.1-edge.2, "Apache-2.0",
iggy_common: 0.8.1-edge.1, "Apache-2.0",
iggy_connector_elasticsearch_sink: 0.1.0, "Apache-2.0",
iggy_connector_elasticsearch_source: 0.1.0, "Apache-2.0",
diff --git a/core/ai/mcp/Cargo.toml b/core/ai/mcp/Cargo.toml
index b5cb5b0e0..7f1f56380 100644
--- a/core/ai/mcp/Cargo.toml
+++ b/core/ai/mcp/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy-mcp"
-version = "0.2.1-edge.2"
+version = "0.2.1-edge.3"
description = "MCP Server for Iggy message streaming platform"
edition = "2024"
license = "Apache-2.0"
diff --git a/core/binary_protocol/Cargo.toml b/core/binary_protocol/Cargo.toml
index aeff9c2a9..bb10cb841 100644
--- a/core/binary_protocol/Cargo.toml
+++ b/core/binary_protocol/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy_binary_protocol"
-version = "0.8.1-edge.1"
+version = "0.8.1-edge.2"
description = "Iggy is the persistent message streaming platform written in
Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing
millions of messages per second."
edition = "2024"
license = "Apache-2.0"
diff --git
a/core/binary_protocol/src/client/binary_personal_access_tokens/mod.rs
b/core/binary_protocol/src/client/binary_personal_access_tokens/mod.rs
index fffca48db..bb151dde7 100644
--- a/core/binary_protocol/src/client/binary_personal_access_tokens/mod.rs
+++ b/core/binary_protocol/src/client/binary_personal_access_tokens/mod.rs
@@ -1,4 +1,5 @@
-/* Licensed to the Apache Software Foundation (ASF) under one
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
@@ -24,8 +25,8 @@ use
iggy_common::delete_personal_access_token::DeletePersonalAccessToken;
use iggy_common::get_personal_access_tokens::GetPersonalAccessTokens;
use
iggy_common::login_with_personal_access_token::LoginWithPersonalAccessToken;
use iggy_common::{
- ClientState, IdentityInfo, IggyError, PersonalAccessTokenExpiry,
PersonalAccessTokenInfo,
- RawPersonalAccessToken,
+ ClientState, DiagnosticEvent, IdentityInfo, IggyError,
PersonalAccessTokenExpiry,
+ PersonalAccessTokenInfo, RawPersonalAccessToken,
};
#[async_trait::async_trait]
@@ -70,6 +71,7 @@ impl<B: BinaryClient> PersonalAccessTokenClient for B {
})
.await?;
self.set_state(ClientState::Authenticated).await;
+ self.publish_event(DiagnosticEvent::SignedIn).await;
mapper::map_identity_info(response)
}
}
diff --git a/core/connectors/runtime/Cargo.toml
b/core/connectors/runtime/Cargo.toml
index 2f2d18971..4b60f74fe 100644
--- a/core/connectors/runtime/Cargo.toml
+++ b/core/connectors/runtime/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy-connectors"
-version = "0.2.1-edge.2"
+version = "0.2.1-edge.3"
description = "Connectors runtime for Iggy message streaming platform"
edition = "2024"
license = "Apache-2.0"
diff --git a/core/sdk/Cargo.toml b/core/sdk/Cargo.toml
index 21b0f7dfa..1ac7bcdf2 100644
--- a/core/sdk/Cargo.toml
+++ b/core/sdk/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy"
-version = "0.8.1-edge.3"
+version = "0.8.1-edge.4"
description = "Iggy is the persistent message streaming platform written in
Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing
millions of messages per second."
edition = "2024"
license = "Apache-2.0"
