diff --git a/proto/agent/v1/service.proto b/proto/agent/v1/service.proto index e1e69ac6..b13e4e95 100644 --- a/proto/agent/v1/service.proto +++ b/proto/agent/v1/service.proto @@ -26,10 +26,11 @@ message WatchLockupsRequest { message LockupEvent { uint64 slot = 1; + string lockupAddress = 2; oneof event { - LockupEventNew new = 2; - LockupEventVAAPosted vaaPosted = 3; - Empty empty = 4; + LockupEventNew new = 3; + LockupEventVAAPosted vaaPosted = 4; + Empty empty = 5; } } diff --git a/solana/agent/src/main.rs b/solana/agent/src/main.rs index 4e6f66fb..b47f9fd6 100644 --- a/solana/agent/src/main.rs +++ b/solana/agent/src/main.rs @@ -133,6 +133,7 @@ impl Agent for AgentImpl { // The Lockup was created LockupEvent { slot: v.context.slot, + lockup_address: v.value.pubkey.to_string(), event: Some(Event::New(LockupEventNew { nonce: b.nonce, source_chain: CHAIN_ID_SOLANA as u32, @@ -148,6 +149,7 @@ impl Agent for AgentImpl { // The VAA was submitted LockupEvent { slot: v.context.slot, + lockup_address: v.value.pubkey.to_string(), event: Some(Event::VaaPosted(LockupEventVaaPosted { nonce: b.nonce, source_chain: CHAIN_ID_SOLANA as u32, @@ -182,6 +184,7 @@ impl Agent for AgentImpl { loop { tx1.send(Ok(LockupEvent { slot: 0, + lockup_address: String::from(""), event: Some(Event::Empty(Empty {})), })) .await;