✨ Add WebSocket events

Author: BertrandD

Cargo.lock

@@ -7,10 +7,10 @@ members = ["contracts", "contracts/wallet", "server"]
 # client-sdk = { default-features = false, package = "hyle-client-sdk", version = "0.13.0-rc.4" }
 # hyle = { version = "0.13.0-rc.4" }
 
-sdk = { git = "https://github.com/Hyle-org/hyle.git", package = "hyle-contract-sdk", branch = "refacto/multiproof" }
-client-sdk = { git = "https://github.com/Hyle-org/hyle.git", default-features = false, package = "hyle-client-sdk", branch = "refacto/multiproof" }
-hyle = { git = "https://github.com/Hyle-org/hyle.git", branch = "refacto/multiproof" }
-hyle-hyllar = { git = "https://github.com/Hyle-org/hyle.git", package = "hyle-hyllar", branch = "refacto/multiproof" }
+sdk = { git = "https://github.com/Hyle-org/hyle.git", package = "hyle-contract-sdk", branch = "feat/csi_events" }
+client-sdk = { git = "https://github.com/Hyle-org/hyle.git", default-features = false, package = "hyle-client-sdk", branch = "feat/csi_events" }
+hyle = { git = "https://github.com/Hyle-org/hyle.git", branch = "feat/csi_events" }
+hyle-hyllar = { git = "https://github.com/Hyle-org/hyle.git", package = "hyle-hyllar", branch = "feat/csi_events" }
 
 contracts = { path = "contracts", default-features = false, package = "contracts" }
 wallet = { path = "contracts/wallet", package = "wallet" }

Cargo.toml

@@ -17,7 +17,13 @@ use crate::*;
 use client_sdk::contract_indexer::axum;
 use client_sdk::contract_indexer::utoipa;
 
-impl ContractHandler for Wallet {
+#[derive(Debug, Clone, Default, Serialize)]
+pub struct WalletEvent {
+    pub account: sdk::Identity,
+    pub program_outputs: String,
+}
+
+impl ContractHandler<WalletEvent> for Wallet {
     async fn api(store: ContractHandlerStore<Wallet>) -> (Router<()>, OpenApi) {
         let (router, api) = OpenApiRouter::default()
             .routes(routes!(get_state))
@@ -31,7 +37,7 @@ impl ContractHandler for Wallet {
         tx: &sdk::BlobTransaction,
         index: sdk::BlobIndex,
         tx_context: sdk::TxContext,
-    ) -> Result<()> {
+    ) -> Result<Option<WalletEvent>> {
         let sdk::Blob {
             contract_name,
             data: _,
@@ -55,7 +61,10 @@ impl ContractHandler for Wallet {
             handler = %contract_name,
             "hyle_output: {:?}", hyle_output
         );
-        Ok(())
+        Ok(Some(WalletEvent {
+            account: tx.identity.clone(),
+            program_outputs: program_outputs.to_string(),
+        }))
     }
 }
 

contracts/wallet/src/client/indexer.rs

@@ -26,6 +26,8 @@ clap = "4.5.28"
 opentelemetry = { version = "0.28" }
 prometheus = { version = "0.13.4" }
 rand = "0.9.0"
+serde_json = "1.0.140"
+futures = "0.3.31"
 
 [package.metadata.cargo-machete]
 ignored = ["tracing-subscriber", "opentelemetry", "prometheus", "rand"]