carbon-gavel-decoder 1.0.0

//! This code was AUTOGENERATED using the Codama library.
pub mod add_liquidity_row;
pub mod initialize_lp_position_row;
pub mod initialize_pool_row;
pub mod log_row;
pub mod remove_liquidity_row;
pub mod renounce_liquidity_row;
pub mod swap_row;
pub mod transfer_liquidity_row;
pub mod withdraw_lp_fees_row;
pub mod withdraw_protocol_fees_row;

pub use self::{
    add_liquidity_row::*, initialize_lp_position_row::*, initialize_pool_row::*, log_row::*,
    remove_liquidity_row::*, renounce_liquidity_row::*, swap_row::*, transfer_liquidity_row::*,
    withdraw_lp_fees_row::*, withdraw_protocol_fees_row::*,
};
use super::GavelInstruction;

pub struct GavelInstructionsMigration;

impl sqlx_migrator::Migration<sqlx::Postgres> for GavelInstructionsMigration {
    fn app(&self) -> &str {
        "gavel"
    }

    fn name(&self) -> &str {
        "gavel_instructions"
    }

    fn operations(&self) -> Vec<Box<dyn sqlx_migrator::Operation<sqlx::Postgres>>> {
        vec![
            Box::new(AddLiquidityMigrationOperation),
            Box::new(InitializeLpPositionMigrationOperation),
            Box::new(InitializePoolMigrationOperation),
            Box::new(LogMigrationOperation),
            Box::new(RemoveLiquidityMigrationOperation),
            Box::new(RenounceLiquidityMigrationOperation),
            Box::new(SwapMigrationOperation),
            Box::new(TransferLiquidityMigrationOperation),
            Box::new(WithdrawLpFeesMigrationOperation),
            Box::new(WithdrawProtocolFeesMigrationOperation),
        ]
    }

    fn parents(&self) -> Vec<Box<dyn sqlx_migrator::Migration<sqlx::Postgres>>> {
        vec![]
    }
}

pub struct GavelInstructionWithMetadata(
    pub GavelInstruction,
    pub carbon_core::instruction::InstructionMetadata,
    pub Vec<solana_instruction::AccountMeta>,
);

impl
    From<(
        GavelInstruction,
        carbon_core::instruction::InstructionMetadata,
        Vec<solana_instruction::AccountMeta>,
    )> for GavelInstructionWithMetadata
{
    fn from(
        value: (
            GavelInstruction,
            carbon_core::instruction::InstructionMetadata,
            Vec<solana_instruction::AccountMeta>,
        ),
    ) -> Self {
        GavelInstructionWithMetadata(value.0, value.1, value.2)
    }
}

#[async_trait::async_trait]
impl carbon_core::postgres::operations::Insert for GavelInstructionWithMetadata {
    async fn insert(&self, pool: &sqlx::PgPool) -> carbon_core::error::CarbonResult<()> {
        let GavelInstructionWithMetadata(decoded_instruction, metadata, raw_accounts) = self;
        match decoded_instruction {
            GavelInstruction::Swap { data, .. } => {
                let row = swap_row::SwapRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.insert(pool).await?;
                Ok(())
            }
            GavelInstruction::AddLiquidity { data, .. } => {
                let row = add_liquidity_row::AddLiquidityRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.insert(pool).await?;
                Ok(())
            }
            GavelInstruction::RemoveLiquidity { data, .. } => {
                let row = remove_liquidity_row::RemoveLiquidityRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.insert(pool).await?;
                Ok(())
            }
            GavelInstruction::RenounceLiquidity { data, .. } => {
                let row = renounce_liquidity_row::RenounceLiquidityRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.insert(pool).await?;
                Ok(())
            }
            GavelInstruction::WithdrawLpFees { data, .. } => {
                let row = withdraw_lp_fees_row::WithdrawLpFeesRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.insert(pool).await?;
                Ok(())
            }
            GavelInstruction::InitializeLpPosition { data, .. } => {
                let row = initialize_lp_position_row::InitializeLpPositionRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.insert(pool).await?;
                Ok(())
            }
            GavelInstruction::InitializePool { data, .. } => {
                let row = initialize_pool_row::InitializePoolRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.insert(pool).await?;
                Ok(())
            }
            GavelInstruction::WithdrawProtocolFees { data, .. } => {
                let row = withdraw_protocol_fees_row::WithdrawProtocolFeesRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.insert(pool).await?;
                Ok(())
            }
            GavelInstruction::Log { data, .. } => {
                let row = log_row::LogRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.insert(pool).await?;
                Ok(())
            }
            GavelInstruction::TransferLiquidity { data, .. } => {
                let row = transfer_liquidity_row::TransferLiquidityRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.insert(pool).await?;
                Ok(())
            }
        }
    }
}

#[async_trait::async_trait]
impl carbon_core::postgres::operations::Upsert for GavelInstructionWithMetadata {
    async fn upsert(&self, pool: &sqlx::PgPool) -> carbon_core::error::CarbonResult<()> {
        let GavelInstructionWithMetadata(decoded_instruction, metadata, raw_accounts) = self;
        match decoded_instruction {
            GavelInstruction::Swap { data, .. } => {
                let row = swap_row::SwapRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
            GavelInstruction::AddLiquidity { data, .. } => {
                let row = add_liquidity_row::AddLiquidityRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
            GavelInstruction::RemoveLiquidity { data, .. } => {
                let row = remove_liquidity_row::RemoveLiquidityRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
            GavelInstruction::RenounceLiquidity { data, .. } => {
                let row = renounce_liquidity_row::RenounceLiquidityRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
            GavelInstruction::WithdrawLpFees { data, .. } => {
                let row = withdraw_lp_fees_row::WithdrawLpFeesRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
            GavelInstruction::InitializeLpPosition { data, .. } => {
                let row = initialize_lp_position_row::InitializeLpPositionRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
            GavelInstruction::InitializePool { data, .. } => {
                let row = initialize_pool_row::InitializePoolRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
            GavelInstruction::WithdrawProtocolFees { data, .. } => {
                let row = withdraw_protocol_fees_row::WithdrawProtocolFeesRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
            GavelInstruction::Log { data, .. } => {
                let row = log_row::LogRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
            GavelInstruction::TransferLiquidity { data, .. } => {
                let row = transfer_liquidity_row::TransferLiquidityRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
        }
    }
}