carbon-associated-token-account-decoder 1.0.0

Associated Token Account program decoder
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135

//! This code was AUTOGENERATED using the Codama library.
pub mod create_idempotent_row;
pub mod create_row;
pub mod recover_nested_row;

pub use self::{create_idempotent_row::*, create_row::*, recover_nested_row::*};
use super::AssociatedTokenAccountInstruction;

pub struct AssociatedTokenAccountInstructionsMigration;

impl sqlx_migrator::Migration<sqlx::Postgres> for AssociatedTokenAccountInstructionsMigration {
    fn app(&self) -> &str {
        "associated-token-account"
    }

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

    fn operations(&self) -> Vec<Box<dyn sqlx_migrator::Operation<sqlx::Postgres>>> {
        vec![
            Box::new(CreateMigrationOperation),
            Box::new(CreateIdempotentMigrationOperation),
            Box::new(RecoverNestedMigrationOperation),
        ]
    }

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

pub struct AssociatedTokenAccountInstructionWithMetadata(
    pub AssociatedTokenAccountInstruction,
    pub carbon_core::instruction::InstructionMetadata,
    pub Vec<solana_instruction::AccountMeta>,
);

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

#[async_trait::async_trait]
impl carbon_core::postgres::operations::Insert for AssociatedTokenAccountInstructionWithMetadata {
    async fn insert(&self, pool: &sqlx::PgPool) -> carbon_core::error::CarbonResult<()> {
        let AssociatedTokenAccountInstructionWithMetadata(
            decoded_instruction,
            metadata,
            raw_accounts,
        ) = self;
        match decoded_instruction {
            AssociatedTokenAccountInstruction::Create { data, .. } => {
                let row = create_row::CreateRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.insert(pool).await?;
                Ok(())
            }
            AssociatedTokenAccountInstruction::CreateIdempotent { data, .. } => {
                let row = create_idempotent_row::CreateIdempotentRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.insert(pool).await?;
                Ok(())
            }
            AssociatedTokenAccountInstruction::RecoverNested { data, .. } => {
                let row = recover_nested_row::RecoverNestedRow::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 AssociatedTokenAccountInstructionWithMetadata {
    async fn upsert(&self, pool: &sqlx::PgPool) -> carbon_core::error::CarbonResult<()> {
        let AssociatedTokenAccountInstructionWithMetadata(
            decoded_instruction,
            metadata,
            raw_accounts,
        ) = self;
        match decoded_instruction {
            AssociatedTokenAccountInstruction::Create { data, .. } => {
                let row = create_row::CreateRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
            AssociatedTokenAccountInstruction::CreateIdempotent { data, .. } => {
                let row = create_idempotent_row::CreateIdempotentRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
            AssociatedTokenAccountInstruction::RecoverNested { data, .. } => {
                let row = recover_nested_row::RecoverNestedRow::from_parts(
                    data.clone(),
                    metadata.clone(),
                    raw_accounts.clone(),
                );
                row.upsert(pool).await?;
                Ok(())
            }
        }
    }
}