gavindiaz/solana-streamer
1
0
Fork 0
mirror of https://github.com/0xfnzero/solana-streamer.git synced 2026-08-09 07:07:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix jito buy

Browse Source
This commit is contained in:
William
2025-01-25 16:01:16 +08:00
parent be36888e6c
commit 858c0e5700
2 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/common/logs_subscribe.rs
+6 -4
View File
@@ -12,6 +12,8 @@ use crate::{constants, common::{
logs_data::DexInstruction, logs_events::DexEvent, logs_filters::LogFilter
}};
use super::logs_events::PumpfunEvent;
/// Subscription handle containing task and unsubscribe logic
pub struct SubscriptionHandle {
pub task: JoinHandle<()>,
@@ -37,7 +39,7 @@ pub async fn tokens_subscription<F>(
bot_wallet: Option<Pubkey>,
) -> Result<SubscriptionHandle, Box<dyn std::error::Error>>
where
F: Fn(DexEvent) + Send + Sync + 'static,
F: Fn(PumpfunEvent) + Send + Sync + 'static,
{
let program_address = constants::accounts::PUMPFUN.to_string();
let logs_filter = RpcTransactionLogsFilter::Mentions(vec![program_address]);
@@ -70,13 +72,13 @@ where
for instruction in instructions {
match instruction {
DexInstruction::CreateToken(token_info) => {
callback(DexEvent::NewToken(token_info));
callback(PumpfunEvent::NewToken(token_info));
}
DexInstruction::UserTrade(trade_info) => {
callback(DexEvent::NewUserTrade(trade_info));
callback(PumpfunEvent::NewUserTrade(trade_info));
}
DexInstruction::BotTrade(trade_info) => {
callback(DexEvent::NewBotTrade(trade_info));
callback(PumpfunEvent::NewBotTrade(trade_info));
}
_ => {}
}
src/lib.rs
+2 -2
View File
@@ -23,7 +23,7 @@ use spl_associated_token_account::{
instruction::create_associated_token_account,
};
use common::logs_subscribe;
use common::{logs_events::PumpfunEvent, logs_subscribe};
use common::logs_subscribe::SubscriptionHandle;
use common::logs_events::DexEvent;
use spl_token::instruction::close_account;
@@ -590,7 +590,7 @@ impl PumpFun {
bot_wallet: Option<Pubkey>,
) -> Result<SubscriptionHandle, Box<dyn std::error::Error>>
where
F: Fn(DexEvent) + Send + Sync + 'static,
F: Fn(PumpfunEvent) + Send + Sync + 'static,
{
logs_subscribe::tokens_subscription(ws_url, commitment, callback, bot_wallet).await
}