d0zingcat/ore
1
0
Fork 0
mirror of https://github.com/d0zingcat/ore.git synced 2026-05-13 23:16:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

cleanup migraiton

Browse Source
This commit is contained in:
Hardhat Chad
2025-08-28 14:14:15 -07:00
parent 04133c42b8
commit 3f15aca904
7 changed files with 3 additions and 153 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
cli/src/main.rs
View File

@@ -81,12 +81,6 @@ async fn main() {
"set_fee_collector" => {
set_fee_collector(&rpc, &payer).await.unwrap();
}
"migrate" => {
migrate(&rpc, &payer).await.unwrap();
}
"migrate_all" => {
migrate_all(&rpc, &payer).await.unwrap();
}
"benchmark" => {
benchmark_keccak().await.unwrap();
}
@@ -247,36 +241,6 @@ async fn set_fee_collector(
Ok(())
}
async fn migrate(
rpc: &RpcClient,
payer: &solana_sdk::signer::keypair::Keypair,
) -> Result<(), anyhow::Error> {
let address = std::env::var("ADDRESS").expect("Missing ADDRESS env var");
let address = Pubkey::from_str(&address).expect("Invalid ADDRESS");
let ix = ore_api::sdk::migrate_miner_account(payer.pubkey(), address);
simulate_transaction(rpc, payer, &[ix]).await;
Ok(())
}
async fn migrate_all(
rpc: &RpcClient,
payer: &solana_sdk::signer::keypair::Keypair,
) -> Result<(), anyhow::Error> {
let old_miners = get_old_miners(rpc).await?;
println!("Found {} old miners", old_miners.len());
for (i, (miner_address, _)) in old_miners.iter().enumerate() {
println!(
"[{} / {}] Migrating miner {}",
i,
old_miners.len(),
miner_address
);
let ix = ore_api::sdk::migrate_miner_account(payer.pubkey(), *miner_address);
let sig = submit_transaction(rpc, payer, &[ix]).await?;
}
Ok(())
}
async fn log_treasury(_rpc: &RpcClient) -> Result<(), anyhow::Error> {
let treasury_address = ore_api::state::treasury_pda().0;
println!("Treasury");
@@ -403,10 +367,10 @@ async fn get_market(rpc: &RpcClient) -> Result<Market, anyhow::Error> {
Ok(*market)
}
async fn get_miner(rpc: &RpcClient, authority: Pubkey) -> Result<MinerOLD, anyhow::Error> {
async fn get_miner(rpc: &RpcClient, authority: Pubkey) -> Result<Miner, anyhow::Error> {
let miner_pda = ore_api::state::miner_pda(authority);
let account = rpc.get_account(&miner_pda.0).await?;
let miner = MinerOLD::try_from_bytes(&account.data)?;
let miner = Miner::try_from_bytes(&account.data)?;
Ok(*miner)
}
@@ -421,11 +385,6 @@ async fn get_blocks(rpc: &RpcClient) -> Result<Vec<(Pubkey, Block)>, anyhow::Err
Ok(blocks)
}
async fn get_old_miners(rpc: &RpcClient) -> Result<Vec<(Pubkey, MinerOLD)>, anyhow::Error> {
let miners = get_program_accounts::<MinerOLD>(rpc, ore_api::ID, vec![]).await?;
Ok(miners)
}
async fn get_miners(rpc: &RpcClient) -> Result<Vec<(Pubkey, Miner)>, anyhow::Error> {
let miners = get_program_accounts::<Miner>(rpc, ore_api::ID, vec![]).await?;
Ok(miners)