solana: emit -> emit_cpi

Author: a5-pickle

solana/programs/matching-engine/src/processor/admin/init_event.rs

@@ -0,0 +1,26 @@
+use anchor_lang::prelude::*;
+
+use crate::composite::*;
+
+#[derive(Accounts)]
+pub struct InitEventSubscription<'info> {
+    #[account(mut)]
+    payer: Signer<'info>,
+
+    admin: OwnerOnly<'info>,
+
+    /// This account will be serialized with an event, so its discriminator will change with every
+    /// update.
+    ///
+    /// CHECK: Mutable, must have seeds \["event"\].
+    #[account(
+        init,
+        payer = payer,
+        space = 10_240,
+        seeds = [b"event"],
+        bump,
+    )]
+    event_subscription: UncheckedAccount<'info>,
+
+    system_program: Program<'info, System>,
+}

solana/programs/matching-engine/src/processor/admin/propose/auction_parameters.rs

@@ -6,6 +6,7 @@ use crate::{
 use anchor_lang::prelude::*;
 
 #[derive(Accounts)]
+#[event_cpi]
 pub struct ProposeAuctionParameters<'info> {
     #[account(mut)]
     payer: Signer<'info>,
@@ -56,7 +57,7 @@ pub fn propose_auction_parameters(
     )?;
 
     // Emit event reflecting the proposal.
-    emit!(crate::events::Proposed { action });
+    emit_cpi!(crate::events::Proposed { action });
 
     // Done.
     Ok(())

solana/programs/matching-engine/src/processor/admin/update/auction_parameters.rs

@@ -6,6 +6,7 @@ use crate::{
 use anchor_lang::prelude::*;
 
 #[derive(Accounts)]
+#[event_cpi]
 pub struct UpdateAuctionParameters<'info> {
     #[account(mut)]
     payer: Signer<'info>,
@@ -70,7 +71,7 @@ pub fn update_auction_parameters(ctx: Context<UpdateAuctionParameters>) -> Resul
     let action = ctx.accounts.proposal.action;
 
     // Emit event to reflect enacting the proposal.
-    emit!(crate::events::Enacted { action });
+    emit_cpi!(crate::events::Enacted { action });
 
     match action {
         ProposalAction::UpdateAuctionParameters { id, parameters } => {

solana/programs/matching-engine/src/processor/auction/execute_fast_order/cctp.rs

@@ -9,6 +9,7 @@ use common::{wormhole_cctp_solana, wormhole_io::TypePrefixedPayload};
 
 /// Accounts required for [execute_fast_order_cctp].
 #[derive(Accounts)]
+#[event_cpi]
 pub struct ExecuteFastOrderCctp<'info> {
     #[account(mut)]
     payer: Signer<'info>,
@@ -79,6 +80,7 @@ pub fn handle_execute_fast_order_cctp(
     let super::PreparedOrderExecution {
         user_amount: amount,
         fill,
+        order_executed_event,
     } = super::handle_execute_fast_order(
         &mut ctx.accounts.execute_order,
         &ctx.accounts.custodian,
@@ -182,6 +184,10 @@ pub fn handle_execute_fast_order_cctp(
         },
     )?;
 
+    // Emit the order executed event, which liquidators can listen to if this execution ended up
+    // being penalized so they can collect the base fee at settlement.
+    emit_cpi!(order_executed_event);
+
     // Finally close the account since it is no longer needed.
     token::close_account(CpiContext::new_with_signer(
         token_program.to_account_info(),

solana/programs/matching-engine/src/processor/auction/execute_fast_order/local.rs

@@ -98,19 +98,26 @@ pub fn execute_fast_order_local(ctx: Context<ExecuteFastOrderLocal>) -> Result<(
     let super::PreparedOrderExecution {
         user_amount: amount,
         fill,
+        order_executed_event,
     } = super::handle_execute_fast_order(
         &mut ctx.accounts.execute_order,
         &ctx.accounts.custodian,
         &ctx.accounts.token_program,
     )?;
 
+    // Emit the order executed event, which liquidators can listen to if this execution ended up
+    // being penalized so they can collect the base fee at settlement.
+    emit_cpi!(order_executed_event);
+
     let fast_fill = FastFill::new(
         fill,
         ctx.accounts.reserved_sequence.fast_fill_seeds.sequence,
         ctx.bumps.fast_fill,
         ctx.accounts.payer.key(),
         amount,
     );
+
+    // Emit the fast fill.
     emit_cpi!(crate::events::LocalFastOrderFilled {
         seeds: fast_fill.seeds,
         info: fast_fill.info,

solana/programs/matching-engine/src/processor/auction/execute_fast_order/mod.rs

@@ -7,6 +7,7 @@ pub use local::*;
 use crate::{
     composite::*,
     error::MatchingEngineError,
+    events::OrderExecuted,
     state::{Auction, AuctionStatus, MessageProtocol},
     utils::{self, auction::DepositPenalty},
 };
@@ -20,6 +21,7 @@ use common::messages::{
 struct PreparedOrderExecution {
     pub user_amount: u64,
     pub fill: Fill,
+    pub order_executed_event: OrderExecuted,
 }
 
 fn handle_execute_fast_order<'info>(
@@ -40,7 +42,7 @@ fn handle_execute_fast_order<'info>(
         .unwrap()
         .to_fast_market_order_unchecked();
 
-    let (user_amount, new_status) = {
+    let (user_amount, new_status, order_executed_event) = {
         let auction_info = auction.info.as_ref().unwrap();
         let current_slot = Clock::get().unwrap().slot;
 
@@ -205,22 +207,19 @@ fn handle_execute_fast_order<'info>(
             custodian.key().into(),
         )?;
 
-        // Emit the order executed event, which liquidators can listen to if this execution ended up
-        // being penalized so they can collect the base fee at settlement.
-        emit!(crate::events::OrderExecuted {
-            auction: auction.key(),
-            vaa: fast_vaa.key(),
-            source_chain: auction_info.source_chain,
-            target_protocol: auction.target_protocol,
-            penalized,
-        });
-
         (
             user_amount,
             AuctionStatus::Completed {
                 slot: current_slot,
                 execute_penalty: if penalized { penalty.into() } else { None },
             },
+            OrderExecuted {
+                auction: auction.key(),
+                vaa: fast_vaa.key(),
+                source_chain: auction_info.source_chain,
+                target_protocol: auction.target_protocol,
+                penalized,
+            },
         )
     };
 
@@ -238,5 +237,6 @@ fn handle_execute_fast_order<'info>(
                 .try_into()
                 .map_err(|_| MatchingEngineError::RedeemerMessageTooLarge)?,
         },
+        order_executed_event,
     })
 }

solana/programs/matching-engine/src/processor/auction/offer/improve.rs

@@ -5,6 +5,7 @@ use common::TRANSFER_AUTHORITY_SEED_PREFIX;
 
 #[derive(Accounts)]
 #[instruction(offer_price: u64)]
+#[event_cpi]
 pub struct ImproveOffer<'info> {
     /// The auction participant needs to set approval to this PDA.
     ///
@@ -134,7 +135,7 @@ pub fn improve_offer(ctx: Context<ImproveOffer>, offer_price: u64) -> Result<()>
         let info = auction.info.as_ref().unwrap();
 
         // Emit event for auction participants to listen to.
-        emit!(crate::events::AuctionUpdated {
+        emit_cpi!(crate::utils::log_emit(crate::events::AuctionUpdated {
             config_id: info.config_id,
             auction: auction.key(),
             vaa: Default::default(),
@@ -148,7 +149,7 @@ pub fn improve_offer(ctx: Context<ImproveOffer>, offer_price: u64) -> Result<()>
             total_deposit: info.total_deposit(),
             max_offer_price_allowed: utils::auction::compute_min_allowed_offer(config, info)
                 .checked_sub(1),
-        });
+        }));
     }
 
     // Done.

solana/programs/matching-engine/src/processor/auction/offer/place_initial/cctp.rs

@@ -10,6 +10,7 @@ use common::{messages::raw::LiquidityLayerMessage, TRANSFER_AUTHORITY_SEED_PREFI
 
 #[derive(Accounts)]
 #[instruction(offer_price: u64)]
+#[event_cpi]
 pub struct PlaceInitialOfferCctp<'info> {
     #[account(mut)]
     payer: Signer<'info>,
@@ -92,7 +93,7 @@ pub struct PlaceInitialOfferCctp<'info> {
     )]
     auction: Box<Account<'info, Auction>>,
 
-    offer_token: Account<'info, token::TokenAccount>,
+    offer_token: Box<Account<'info, token::TokenAccount>>,
 
     #[account(
         init,
@@ -105,7 +106,7 @@ pub struct PlaceInitialOfferCctp<'info> {
         ],
         bump,
     )]
-    auction_custody_token: Account<'info, token::TokenAccount>,
+    auction_custody_token: Box<Account<'info, token::TokenAccount>>,
 
     usdc: Usdc<'info>,
 
@@ -166,7 +167,7 @@ pub fn place_initial_offer_cctp(
     let info = ctx.accounts.auction.info.as_ref().unwrap();
 
     // Emit event for auction participants to listen to.
-    emit!(crate::events::AuctionUpdated {
+    emit_cpi!(crate::utils::log_emit(crate::events::AuctionUpdated {
         config_id: info.config_id,
         auction: ctx.accounts.auction.key(),
         vaa: ctx.accounts.fast_order_path.fast_vaa.key().into(),
@@ -180,7 +181,7 @@ pub fn place_initial_offer_cctp(
         total_deposit: info.total_deposit(),
         max_offer_price_allowed: utils::auction::compute_min_allowed_offer(config, info)
             .checked_sub(1),
-    });
+    }));
 
     // Finally transfer tokens from the offer authority's token account to the
     // auction's custody account.

solana/programs/matching-engine/src/processor/auction/settle/complete.rs

@@ -8,6 +8,7 @@ use anchor_lang::prelude::*;
 use anchor_spl::token::{self, TokenAccount};
 
 #[derive(Accounts)]
+#[event_cpi]
 pub struct SettleAuctionComplete<'info> {
     /// CHECK: Must equal prepared_order_response.prepared_by, who paid the rent to post the
     /// finalized VAA.
@@ -247,7 +248,7 @@ fn handle_settle_auction_complete(
         None => None,
     };
 
-    emit!(crate::events::AuctionSettled {
+    emit_cpi!(crate::events::AuctionSettled {
         auction: ctx.accounts.auction.key(),
         best_offer_token: settled_best_offer_result,
         base_fee_token: settled_base_fee_result,

solana/programs/matching-engine/src/processor/auction/settle/none/cctp.rs

@@ -9,6 +9,7 @@ use common::{wormhole_cctp_solana, wormhole_io::TypePrefixedPayload};
 
 /// Accounts required for [settle_auction_none_cctp].
 #[derive(Accounts)]
+#[event_cpi]
 pub struct SettleAuctionNoneCctp<'info> {
     #[account(mut)]
     payer: Signer<'info>,
@@ -102,6 +103,7 @@ fn handle_settle_auction_none_cctp(
     let super::SettledNone {
         user_amount: amount,
         fill,
+        auction_settled_event,
     } = super::settle_none_and_prepare_fill(super::SettleNoneAndPrepareFill {
         prepared_order_response: &mut ctx.accounts.prepared.order_response,
         prepared_custody_token,
@@ -209,6 +211,9 @@ fn handle_settle_auction_none_cctp(
         },
     )?;
 
+    // Emit an event indicating that the auction has been settled.
+    emit_cpi!(auction_settled_event);
+
     // Finally close the account since it is no longer needed.
     token::close_account(CpiContext::new_with_signer(
         token_program.to_account_info(),

solana/programs/matching-engine/src/processor/auction/settle/none/local.rs

@@ -126,6 +126,7 @@ pub fn settle_auction_none_local(ctx: Context<SettleAuctionNoneLocal>) -> Result
     let super::SettledNone {
         user_amount: amount,
         fill,
+        auction_settled_event,
     } = super::settle_none_and_prepare_fill(super::SettleNoneAndPrepareFill {
         prepared_order_response: &mut ctx.accounts.prepared.order_response,
         prepared_custody_token,
@@ -135,13 +136,18 @@ pub fn settle_auction_none_local(ctx: Context<SettleAuctionNoneLocal>) -> Result
         token_program,
     })?;
 
+    // Emit an event indicating that the auction has been settled.
+    emit_cpi!(auction_settled_event);
+
     let fast_fill = FastFill::new(
         fill,
         ctx.accounts.reserved_sequence.fast_fill_seeds.sequence,
         ctx.bumps.fast_fill,
         ctx.accounts.payer.key(),
         amount,
     );
+
+    // Emit the fast fill.
     emit_cpi!(crate::events::LocalFastOrderFilled {
         seeds: fast_fill.seeds,
         info: fast_fill.info,

solana/programs/matching-engine/src/processor/auction/settle/none/mod.rs

@@ -6,6 +6,7 @@ pub use local::*;
 
 use crate::{
     composite::*,
+    events::AuctionSettled,
     state::{Auction, AuctionStatus, PreparedOrderResponse},
 };
 use anchor_lang::prelude::*;
@@ -24,6 +25,7 @@ struct SettleNoneAndPrepareFill<'ctx, 'info> {
 struct SettledNone {
     user_amount: u64,
     fill: Fill,
+    auction_settled_event: AuctionSettled,
 }
 
 fn settle_none_and_prepare_fill(accounts: SettleNoneAndPrepareFill<'_, '_>) -> Result<SettledNone> {
@@ -81,16 +83,16 @@ fn settle_none_and_prepare_fill(accounts: SettleNoneAndPrepareFill<'_, '_>) -> R
         total_penalty: None,
     };
 
-    emit!(crate::events::AuctionSettled {
+    let auction_settled_event = AuctionSettled {
         auction: auction.key(),
         best_offer_token: Default::default(),
         base_fee_token: crate::events::SettledTokenAccountInfo {
             key: fee_recipient_token.key(),
-            balance_after: fee_recipient_token.amount.saturating_add(fee)
+            balance_after: fee_recipient_token.amount.saturating_add(fee),
         }
         .into(),
         with_execute: auction.target_protocol.into(),
-    });
+    };
 
     // TryInto is safe to unwrap here because the redeemer message had to have been able to fit in
     // the prepared order response account (so it would not have exceed u32::MAX).
@@ -105,5 +107,6 @@ fn settle_none_and_prepare_fill(accounts: SettleNoneAndPrepareFill<'_, '_>) -> R
             redeemer: prepared_order_response.redeemer,
             redeemer_message,
         },
+        auction_settled_event,
     })
 }

solana/programs/matching-engine/src/processor/fast_fill/complete.rs

@@ -9,6 +9,7 @@ use common::wormhole_cctp_solana::wormhole::SOLANA_CHAIN;
 
 /// Accounts required for [complete_fast_fill].
 #[derive(Accounts)]
+#[event_cpi]
 pub struct CompleteFastFill<'info> {
     /// Custodian, which may be used in the future.
     custodian: CheckedCustodian<'info>,
@@ -81,7 +82,7 @@ pub fn complete_fast_fill(ctx: Context<CompleteFastFill>) -> Result<()> {
     ctx.accounts.fast_fill.redeemed = true;
 
     // Emit event that the fast fill is redeemed. Listeners can close this account.
-    emit!(crate::events::FastFillRedeemed {
+    emit_cpi!(crate::events::FastFillRedeemed {
         prepared_by: ctx.accounts.fast_fill.info.prepared_by,
         fast_fill: ctx.accounts.fast_fill.key(),
     });