solana-router-orca 1.1.3

//! Swap tokens with the Orca pool instruction

use {
    solana_farm_sdk::program::{account, protocol::orca},
    solana_program::{
        account_info::AccountInfo, entrypoint::ProgramResult, msg, program::invoke,
        program_error::ProgramError,
    },
    spl_token_swap::instruction,
};

pub fn swap(
    accounts: &[AccountInfo],
    token_a_amount_in: u64,
    token_b_amount_in: u64,
    min_token_amount_out: u64,
) -> ProgramResult {
    msg!("Processing AmmInstruction::Swap");
    msg!("token_a_amount_in {} ", token_a_amount_in);
    msg!("token_b_amount_in {} ", token_b_amount_in);
    msg!("min_token_amount_out {} ", min_token_amount_out);

    #[allow(clippy::deprecated_cfg_attr)]
    #[cfg_attr(rustfmt, rustfmt_skip)]
    if let [
        user_account,
        user_token_a_account,
        user_token_b_account,
        pool_program_id,
        pool_token_a_account,
        pool_token_b_account,
        lp_token_mint,
        _spl_token_id,
        amm_id,
        amm_authority,
        fees_account
        ] = accounts
    {
        if !orca::check_pool_program_id(pool_program_id.key) {
            return Err(ProgramError::IncorrectProgramId);
        }

        let (amount_in, mut min_amount_out) = orca::get_pool_swap_amounts(
            pool_token_a_account,
            pool_token_b_account,
            token_a_amount_in,
            token_b_amount_in,
        )?;
        if min_token_amount_out > min_amount_out {
            min_amount_out = min_token_amount_out;
        }
        if amount_in == 0 || min_amount_out == 0 {
            msg!("Nothing to do: Not enough tokens to swap");
            return Ok(());
        }

        let data = instruction::Swap {
            amount_in,
            minimum_amount_out: min_amount_out,
        };

        msg!(
            "Swap tokens in the pool. amount_in: {}, min_amount_out: {}",
            amount_in,
            min_amount_out
        );

        if token_a_amount_in == 0 {
            if !account::check_token_account_owner(user_token_a_account, user_account.key)? {
                return Err(ProgramError::IllegalOwner);
            }

            let initial_balance_in = account::get_token_balance(user_token_b_account)?;
            let initial_balance_out = account::get_token_balance(user_token_a_account)?;

            let instruction = instruction::swap(
                pool_program_id.key,
                &spl_token::id(),
                amm_id.key,
                amm_authority.key,
                user_account.key,
                user_token_b_account.key,
                pool_token_b_account.key,
                pool_token_a_account.key,
                user_token_a_account.key,
                lp_token_mint.key,
                fees_account.key,
                None,
                data,
            )?;
            invoke(&instruction, accounts)?;

            account::check_tokens_spent(user_token_b_account, initial_balance_in, amount_in)?;
            account::check_tokens_received(
                user_token_a_account,
                initial_balance_out,
                min_amount_out,
            )?;
        } else {
            if !account::check_token_account_owner(user_token_b_account, user_account.key)? {
                return Err(ProgramError::IllegalOwner);
            }

            let initial_balance_in = account::get_token_balance(user_token_a_account)?;
            let initial_balance_out = account::get_token_balance(user_token_b_account)?;

            let instruction = instruction::swap(
                pool_program_id.key,
                &spl_token::id(),
                amm_id.key,
                amm_authority.key,
                user_account.key,
                user_token_a_account.key,
                pool_token_a_account.key,
                pool_token_b_account.key,
                user_token_b_account.key,
                lp_token_mint.key,
                fees_account.key,
                None,
                data,
            )?;
            invoke(&instruction, accounts)?;

            account::check_tokens_spent(user_token_a_account, initial_balance_in, amount_in)?;
            account::check_tokens_received(
                user_token_b_account,
                initial_balance_out,
                min_amount_out,
            )?;
        }
    } else {
        return Err(ProgramError::NotEnoughAccountKeys);
    }

    msg!("AmmInstruction::Swap complete");
    Ok(())
}