add init program upgrade command

cli/src/command/initiate_program_upgrade.rs

@@ -0,0 +1,225 @@
+use std::str::FromStr;
+use std::time::Duration;
+
+use clap::Args;
+use colored::Colorize;
+use dialoguer::Confirm;
+use indicatif::ProgressBar;
+use solana_program::bpf_loader_upgradeable::upgrade;
+use solana_sdk::compute_budget::ComputeBudgetInstruction;
+use solana_sdk::instruction::Instruction;
+use solana_sdk::message::v0::Message;
+use solana_sdk::message::VersionedMessage;
+use solana_sdk::pubkey::Pubkey;
+use solana_sdk::transaction::VersionedTransaction;
+
+use squads_multisig::anchor_lang::InstructionData;
+use squads_multisig::client::get_multisig;
+use squads_multisig::pda::{get_proposal_pda, get_transaction_pda, get_vault_pda};
+use squads_multisig::solana_client::nonblocking::rpc_client::RpcClient;
+use squads_multisig::squads_multisig_program::accounts::ProposalCreate as ProposalCreateAccounts;
+use squads_multisig::squads_multisig_program::accounts::VaultTransactionCreate as VaultTransactionCreateAccounts;
+use squads_multisig::squads_multisig_program::anchor_lang::ToAccountMetas;
+use squads_multisig::squads_multisig_program::instruction::ProposalCreate as ProposalCreateData;
+use squads_multisig::squads_multisig_program::instruction::VaultTransactionCreate as VaultTransactionCreateData;
+use squads_multisig::squads_multisig_program::ProposalCreateArgs;
+use squads_multisig::squads_multisig_program::VaultTransactionCreateArgs;
+
+use crate::utils::{create_signer_from_path, send_and_confirm_transaction};
+
+#[derive(Args)]
+pub struct InitiateProgramUpgrade {
+    /// RPC URL
+    #[arg(long)]
+    rpc_url: Option<String>,
+
+    /// Multisig Program ID
+    #[arg(long)]
+    squads_program_id: Option<String>,
+
+    /// Token Mint Address.
+    #[arg(long)]
+    buffer_address: String,
+
+    /// Path to the Program Config Initializer Keypair
+    #[arg(long)]
+    keypair: String,
+
+    /// The multisig where the transaction has been proposed
+    #[arg(long)]
+    multisig_pubkey: String,
+
+    #[arg(long)]
+    vault_index: u8,
+
+    /// Memo to be included in the transaction
+    #[arg(long)]
+    memo: Option<String>,
+
+    /// The program to upgrade
+    #[arg(long)]
+    program_to_upgrade_id: String,
+
+    /// The spill address
+    #[arg(long)]
+    spill_address: String,
+
+    #[arg(long)]
+    priority_fee_lamports: Option<u64>,
+}
+
+impl InitiateProgramUpgrade {
+    pub async fn execute(self) -> eyre::Result<()> {
+        let Self {
+            rpc_url,
+            squads_program_id,
+            keypair,
+            multisig_pubkey,
+            memo,
+            vault_index,
+            priority_fee_lamports,
+            buffer_address,
+            program_to_upgrade_id,
+            spill_address,
+        } = self;
+
+        let program_id = squads_program_id
+            .unwrap_or_else(|| "SQDS4ep65T869zMMBKyuUq6aD6EgTu8psMjkvj52pCf".to_string());
+
+        let program_id = Pubkey::from_str(&program_id).expect("Invalid program ID");
+
+        let transaction_creator_keypair = create_signer_from_path(keypair).unwrap();
+
+        let transaction_creator = transaction_creator_keypair.pubkey();
+
+        let program_to_upgrade =
+            Pubkey::from_str(&program_to_upgrade_id).expect("Invalid to upgrade program ID");
+        let spill_address_id = Pubkey::from_str(&spill_address).expect("Invalid spill address");
+        let buffer_address_id = Pubkey::from_str(&buffer_address).expect("Invalid buffer address");
+
+        let rpc_url = rpc_url.unwrap_or_else(|| "https://api.mainnet-beta.solana.com".to_string());
+        let rpc_url_clone = rpc_url.clone();
+        let rpc_client = &RpcClient::new(rpc_url);
+
+        let multisig = Pubkey::from_str(&multisig_pubkey).expect("Invalid multisig address");
+
+        let multisig_data = get_multisig(rpc_client, &multisig).await?;
+
+        let transaction_index = multisig_data.transaction_index + 1;
+
+        let transaction_pda = get_transaction_pda(&multisig, transaction_index, Some(&program_id));
+        let proposal_pda = get_proposal_pda(&multisig, transaction_index, Some(&program_id));
+        println!();
+        println!(
+            "{}",
+            "👀 You're about to create a vault to upgrade your program from a buffer, please review the details:".yellow()
+        );
+        println!();
+        println!("RPC Cluster URL:   {}", rpc_url_clone);
+        println!("Program ID:        {}", program_id);
+        println!("Your Public Key:       {}", transaction_creator);
+        println!();
+        println!("⚙️ Config Parameters");
+        println!("Multisig Key:       {}", multisig_pubkey);
+        println!("Transaction Index:       {}", transaction_index);
+        println!("Vault Index:       {}", vault_index);
+        println!("To upgrade program ID:       {}", program_to_upgrade_id);
+        println!("Buffer Address:       {}", buffer_address);
+        println!("Spill Address:       {}", spill_address);
+        println!();
+
+        let proceed = Confirm::new()
+            .with_prompt("Do you want to proceed?")
+            .default(false)
+            .interact()?;
+        if !proceed {
+            println!("OK, aborting.");
+            return Ok(());
+        }
+        println!();
+
+        let progress = ProgressBar::new_spinner().with_message("Sending transaction...");
+        progress.enable_steady_tick(Duration::from_millis(100));
+
+        let blockhash = rpc_client
+            .get_latest_blockhash()
+            .await
+            .expect("Failed to get blockhash");
+
+        let vault_pda = get_vault_pda(&multisig, vault_index, Some(&program_id));
+
+        let instruction = upgrade(
+            &program_to_upgrade,
+            &buffer_address_id,
+            &vault_pda.0,
+            &spill_address_id,
+        );
+
+        let upgrade_program_message =
+            Message::try_compile(&vault_pda.0, &[instruction], &[], blockhash).unwrap();
+
+        let message = Message::try_compile(
+            &transaction_creator,
+            &[
+                ComputeBudgetInstruction::set_compute_unit_price(
+                    priority_fee_lamports.unwrap_or(200_000),
+                ),
+                Instruction {
+                    accounts: VaultTransactionCreateAccounts {
+                        creator: transaction_creator,
+                        rent_payer: transaction_creator,
+                        transaction: transaction_pda.0,
+                        multisig,
+                        system_program: solana_sdk::system_program::id(),
+                    }
+                    .to_account_metas(Some(false)),
+                    data: VaultTransactionCreateData {
+                        args: VaultTransactionCreateArgs {
+                            ephemeral_signers: 0,
+                            vault_index,
+                            memo,
+                            transaction_message: upgrade_program_message.serialize(),
+                        },
+                    }
+                    .data(),
+                    program_id,
+                },
+                Instruction {
+                    accounts: ProposalCreateAccounts {
+                        creator: transaction_creator,
+                        rent_payer: transaction_creator,
+                        proposal: proposal_pda.0,
+                        multisig,
+                        system_program: solana_sdk::system_program::id(),
+                    }
+                    .to_account_metas(Some(false)),
+                    data: ProposalCreateData {
+                        args: ProposalCreateArgs {
+                            draft: false,
+                            transaction_index,
+                        },
+                    }
+                    .data(),
+                    program_id,
+                },
+            ],
+            &[],
+            blockhash,
+        )
+        .unwrap();
+
+        let transaction = VersionedTransaction::try_new(
+            VersionedMessage::V0(message),
+            &[&*transaction_creator_keypair],
+        )
+        .expect("Failed to create transaction");
+
+        let signature = send_and_confirm_transaction(&transaction, &rpc_client).await?;
+
+        println!(
+            "✅ Transaction created successfully. Signature: {}",
+            signature.green()
+        );
+        Ok(())
+    }
+}

cli/src/command/mod.rs

@@ -1,5 +1,6 @@
 use crate::command::config_transaction_create::ConfigTransactionCreate;
 use crate::command::config_transaction_execute::ConfigTransactionExecute;
+use crate::command::initiate_program_upgrade::InitiateProgramUpgrade;
 use crate::command::initiate_transfer::InitiateTransfer;
 use crate::command::multisig_create::MultisigCreate;
 use crate::command::program_config_init::ProgramConfigInit;
@@ -12,6 +13,7 @@ use clap::Subcommand;
 
 pub mod config_transaction_create;
 pub mod config_transaction_execute;
+pub mod initiate_program_upgrade;
 pub mod initiate_transfer;
 pub mod multisig_create;
 pub mod program_config_init;
@@ -31,4 +33,5 @@ pub enum Command {
     ConfigTransactionExecute(ConfigTransactionExecute),
     VaultTransactionAccountsClose(VaultTransactionAccountsClose),
     InitiateTransfer(InitiateTransfer),
+    InitiateProgramUpgrade(InitiateProgramUpgrade),
 }

cli/src/main.rs

@@ -25,5 +25,6 @@ async fn main() -> eyre::Result<()> {
         Command::ConfigTransactionExecute(command) => command.execute().await,
         Command::VaultTransactionAccountsClose(command) => command.execute().await,
         Command::InitiateTransfer(command) => command.execute().await,
+        Command::InitiateProgramUpgrade(command) => command.execute().await,
     }
 }

programs/squads_multisig_program/Cargo.toml

@@ -21,5 +21,4 @@ default = []
 anchor-lang = { version = "=0.29.0", features = ["allow-missing-optionals"] }
 anchor-spl = { version="=0.29.0", features=["token"] }
 solana-program = "1.17.4"
-solana-security-txt = "1.1.1"
-#
+solana-security-txt = "1.1.1"