blockworks-foundation
/
pyth-crosschain
mirror of https://github.com/blockworks-foundation/pyth-crosschain.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

agent: add lockup_address

This commit is contained in:
Hendrik Hofstadt 2020-08-21 17:58:35 +02:00
parent a1e548e4b9
commit e0c2fbf990
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
proto/agent/v1/service.proto
View File

@ -26,10 +26,11 @@ message WatchLockupsRequest {
message LockupEvent { message LockupEvent {
uint64 slot = 1; uint64 slot = 1;
string lockupAddress = 2;
oneof event { oneof event {
LockupEventNew new = 2; LockupEventNew new = 3;
LockupEventVAAPosted vaaPosted = 3; LockupEventVAAPosted vaaPosted = 4;
Empty empty = 4; Empty empty = 5;
} }
} }

3
solana/agent/src/main.rs
View File

@ -133,6 +133,7 @@ impl Agent for AgentImpl {
// The Lockup was created // The Lockup was created
LockupEvent { LockupEvent {
slot: v.context.slot, slot: v.context.slot,
lockup_address: v.value.pubkey.to_string(),
event: Some(Event::New(LockupEventNew { event: Some(Event::New(LockupEventNew {
nonce: b.nonce, nonce: b.nonce,
source_chain: CHAIN_ID_SOLANA as u32, source_chain: CHAIN_ID_SOLANA as u32,
@ -148,6 +149,7 @@ impl Agent for AgentImpl {
// The VAA was submitted // The VAA was submitted
LockupEvent { LockupEvent {
slot: v.context.slot, slot: v.context.slot,
lockup_address: v.value.pubkey.to_string(),
event: Some(Event::VaaPosted(LockupEventVaaPosted { event: Some(Event::VaaPosted(LockupEventVaaPosted {
nonce: b.nonce, nonce: b.nonce,
source_chain: CHAIN_ID_SOLANA as u32, source_chain: CHAIN_ID_SOLANA as u32,
@ -182,6 +184,7 @@ impl Agent for AgentImpl {
loop { loop {
tx1.send(Ok(LockupEvent { tx1.send(Ok(LockupEvent {
slot: 0, slot: 0,
lockup_address: String::from(""),
event: Some(Event::Empty(Empty {})), event: Some(Event::Empty(Empty {})),
})) }))
.await; .await;