pub mod restaking_pool_row;
pub use self::restaking_pool_row::*;
use super::SolayerRestakingProgramAccount;
pub struct SolayerRestakingProgramAccountsMigration;
impl sqlx_migrator::Migration<sqlx::Postgres> for SolayerRestakingProgramAccountsMigration {
fn app(&self) -> &str {
"solayer-restaking-program"
}
fn name(&self) -> &str {
"solayer_restaking_program_accounts"
}
fn operations(&self) -> Vec<Box<dyn sqlx_migrator::Operation<sqlx::Postgres>>> {
vec![Box::new(RestakingPoolMigrationOperation)]
}
fn parents(&self) -> Vec<Box<dyn sqlx_migrator::Migration<sqlx::Postgres>>> {
vec![]
}
}
pub struct SolayerRestakingProgramAccountWithMetadata(
pub SolayerRestakingProgramAccount,
pub carbon_core::account::AccountMetadata,
);
impl
From<(
SolayerRestakingProgramAccount,
carbon_core::account::AccountMetadata,
)> for SolayerRestakingProgramAccountWithMetadata
{
fn from(
value: (
SolayerRestakingProgramAccount,
carbon_core::account::AccountMetadata,
),
) -> Self {
SolayerRestakingProgramAccountWithMetadata(value.0, value.1)
}
}
#[async_trait::async_trait]
impl carbon_core::postgres::operations::Insert for SolayerRestakingProgramAccountWithMetadata {
async fn insert(&self, pool: &sqlx::PgPool) -> carbon_core::error::CarbonResult<()> {
let SolayerRestakingProgramAccountWithMetadata(account, metadata) = self;
match account {
SolayerRestakingProgramAccount::RestakingPool(account) => {
let row = restaking_pool_row::RestakingPoolRow::from_parts(
*account.clone(),
metadata.clone(),
);
row.insert(pool).await?;
Ok(())
}
}
}
}
#[async_trait::async_trait]
impl carbon_core::postgres::operations::Upsert for SolayerRestakingProgramAccountWithMetadata {
async fn upsert(&self, pool: &sqlx::PgPool) -> carbon_core::error::CarbonResult<()> {
let SolayerRestakingProgramAccountWithMetadata(account, metadata) = self;
match account {
SolayerRestakingProgramAccount::RestakingPool(account) => {
let row = restaking_pool_row::RestakingPoolRow::from_parts(
*account.clone(),
metadata.clone(),
);
row.upsert(pool).await?;
Ok(())
}
}
}
}