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

set 

Signed-off-by: microwavedcola1 <microwavedcola@gmail.com>
This commit is contained in:
microwavedcola1 2022-12-15 11:44:19 +01:00
parent 309f218c6e
commit 74ce413482
1 changed files with 27 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
keeper/src/crank.rs
View File

@ -1,4 +1,4 @@
use std::{sync::Arc, time::Duration, time::Instant}; use std::{collections::HashSet, sync::Arc, time::Duration, time::Instant};
use crate::MangoClient; use crate::MangoClient;
use itertools::Itertools; use itertools::Itertools;
@ -190,6 +190,7 @@ pub async fn loop_consume_events(
// TODO: future, choose better constant of how many max events to pack // TODO: future, choose better constant of how many max events to pack
// TODO: future, choose better constant of how many max mango accounts to pack // TODO: future, choose better constant of how many max mango accounts to pack
let mut already_packed_accounts = HashSet::new();
for _ in 0..10 { for _ in 0..10 {
let event = match event_queue.peek_front() { let event = match event_queue.peek_front() {
None => break, None => break,
@ -198,16 +199,31 @@ pub async fn loop_consume_events(
match EventType::try_from(event.event_type)? { match EventType::try_from(event.event_type)? {
EventType::Fill => { EventType::Fill => {
let fill: &FillEvent = cast_ref(event); let fill: &FillEvent = cast_ref(event);
ams_.push(AccountMeta { if fill.maker == fill.taker && !already_packed_accounts.contains(&fill.maker.to_string()) {
pubkey: fill.maker, ams_.push(AccountMeta {
is_signer: false, pubkey: fill.maker,
is_writable: true, is_signer: false,
}); is_writable: true,
ams_.push(AccountMeta { });
pubkey: fill.taker, already_packed_accounts.insert(fill.maker.to_string());
is_signer: false, } else {
is_writable: true, if !already_packed_accounts.contains(&fill.maker.to_string()) {
}); ams_.push(AccountMeta {
pubkey: fill.maker,
is_signer: false,
is_writable: true,
});
already_packed_accounts.insert(fill.maker.to_string());
}
if !already_packed_accounts.contains(&fill.taker.to_string()) {
ams_.push(AccountMeta {
pubkey: fill.taker,
is_signer: false,
is_writable: true,
});
already_packed_accounts.insert(fill.taker.to_string());
}}
} }
EventType::Out => { EventType::Out => {
let out: &OutEvent = cast_ref(event); let out: &OutEvent = cast_ref(event);