feat: prod sync

ops/mainnet/mark/config.tf

@@ -138,8 +138,6 @@ locals {
       SOLANA_PRIVATE_KEY    = local.mark_config.solana.privateKey
       SOLANA_RPC_URL        = local.mark_config.solana.rpcUrl
       SOLANA_SIGNER_ADDRESS = local.mark_config.solanaSignerAddress
-      # ptUSDe SPL token mint on Solana (from SSM config)
-      PTUSDE_SOLANA_MINT = local.mark_config.solana.ptUsdeMint
     }
   )
 

ops/mainnet/mason/config.tf

@@ -137,8 +137,6 @@ locals {
       SOLANA_PRIVATE_KEY    = local.mark_config.solana.privateKey
       SOLANA_RPC_URL        = local.mark_config.solana.rpcUrl
       SOLANA_SIGNER_ADDRESS = local.mark_config.solanaSignerAddress
-      # ptUSDe SPL token mint on Solana (from SSM config)
-      PTUSDE_SOLANA_MINT = local.mark_config.solana.ptUsdeMint
     }
   )
 

ops/mainnet/mason/main.tf

@@ -362,7 +362,7 @@ module "mark_solana_usdc_poller" {
   subnet_ids          = module.network.private_subnets
   security_group_id   = module.sgs.lambda_sg_id
   container_env_vars  = local.solana_usdc_poller_env_vars
-  schedule_expression = "rate(30 minutes)"
+  schedule_expression = "rate(5 minutes)"
 }
 
 # TAC-only Lambda - runs TAC USDT rebalancing every 1 minute

packages/adapters/chainservice/src/solana.ts

@@ -26,6 +26,8 @@ import {
   TransactionInstruction,
   sendAndConfirmTransaction,
   ComputeBudgetProgram,
+  MessageV0,
+  AddressLookupTableAccount,
 } from '@solana/web3.js';
 import bs58 from 'bs58';
 
@@ -77,6 +79,8 @@ export interface SolanaTransactionRequest {
   computeUnitPrice?: number;
   /** Optional compute unit limit */
   computeUnitLimit?: number;
+  /** Optional address lookup table addresses for versioned transactions */
+  addressLookupTableAddresses?: PublicKey[];
 }
 
 /**
@@ -151,6 +155,13 @@ export class SolanaSigner {
     return this.keypair.publicKey.toBase58();
   }
 
+  /**
+   * Get the underlying keypair for direct access
+   */
+  getKeypair(): Keypair {
+    return this.keypair;
+  }
+
   /**
    * Get the underlying connection for read operations
    */
@@ -213,23 +224,97 @@ export class SolanaSigner {
     return transaction;
   }
 
+  /**
+   * Build a versioned transaction with address lookup tables for reduced transaction size.
+   */
+  async buildVersionedTransaction(request: SolanaTransactionRequest): Promise<VersionedTransaction> {
+    const { instructions, feePayer, computeUnitPrice, computeUnitLimit, addressLookupTableAddresses } = request;
+
+    const allInstructions: TransactionInstruction[] = [];
+
+    // Add compute budget instructions if specified (for priority fees)
+    if (computeUnitLimit) {
+      allInstructions.push(
+        ComputeBudgetProgram.setComputeUnitLimit({
+          units: computeUnitLimit,
+        }),
+      );
+    }
+
+    if (computeUnitPrice) {
+      allInstructions.push(
+        ComputeBudgetProgram.setComputeUnitPrice({
+          microLamports: computeUnitPrice,
+        }),
+      );
+    }
+
+    // Add user instructions
+    allInstructions.push(...instructions);
+
+    // Get recent blockhash
+    const { blockhash } = await this.connection.getLatestBlockhash(this.config.commitment);
+
+    // Fetch address lookup table accounts if provided
+    const lookupTableAccounts: AddressLookupTableAccount[] = [];
+    if (addressLookupTableAddresses && addressLookupTableAddresses.length > 0) {
+      for (const address of addressLookupTableAddresses) {
+        const lookupTableAccount = await this.connection.getAddressLookupTable(address);
+        if (lookupTableAccount.value) {
+          lookupTableAccounts.push(lookupTableAccount.value);
+        }
+      }
+    }
+
+    // Create versioned transaction message using MessageV0
+    const messageV0 = MessageV0.compile({
+      payerKey: feePayer || this.keypair.publicKey,
+      recentBlockhash: blockhash,
+      instructions: allInstructions,
+      addressLookupTableAccounts: lookupTableAccounts,
+    });
+
+    return new VersionedTransaction(messageV0);
+  }
+
   /**
    * Sign and send a transaction with automatic retry and confirmation
    */
   async signAndSendTransaction(request: SolanaTransactionRequest): Promise<SolanaTransactionResult> {
-    // Build the transaction
-    const transaction = await this.buildTransaction(request);
+    const useVersionedTransaction =
+      request.addressLookupTableAddresses && request.addressLookupTableAddresses.length > 0;
 
     // Sign and send with retries
     let lastError: Error | null = null;
 
     for (let attempt = 1; attempt <= this.config.maxRetries; attempt++) {
       try {
-        const signature = await sendAndConfirmTransaction(this.connection, transaction, [this.keypair], {
-          commitment: this.config.commitment,
-          skipPreflight: this.config.skipPreflight,
-          maxRetries: 0, // We handle retries ourselves
-        });
+        let signature: string;
+
+        if (useVersionedTransaction) {
+          // Build and send versioned transaction with lookup tables
+          const versionedTx = await this.buildVersionedTransaction(request);
+          versionedTx.sign([this.keypair]);
+
+          signature = await this.connection.sendTransaction(versionedTx, {
+            skipPreflight: this.config.skipPreflight,
+            maxRetries: 0,
+          });
+
+          // Wait for confirmation
+          const confirmation = await this.connection.confirmTransaction(signature, this.config.commitment);
+          if (confirmation.value.err) {
+            throw new Error(`Transaction failed: ${JSON.stringify(confirmation.value.err)}`);
+          }
+        } else {
+          // Build and send legacy transaction
+          const transaction = await this.buildTransaction(request);
+          signature = await sendAndConfirmTransaction(this.connection, transaction, [this.keypair], {
+            commitment: this.config.commitment,
+            skipPreflight: this.config.skipPreflight,
+            maxRetries: 0, // We handle retries ourselves
+          });
+        }
 
         // Get transaction details
         const txDetails = await this.connection.getTransaction(signature, {
@@ -259,11 +344,6 @@ export class SolanaSigner {
         // Exponential backoff
         const backoffMs = Math.min(1000 * Math.pow(2, attempt - 1), 10000);
         await this.delay(backoffMs);
-
-        // Get fresh blockhash for retry
-        const { blockhash, lastValidBlockHeight } = await this.connection.getLatestBlockhash(this.config.commitment);
-        transaction.recentBlockhash = blockhash;
-        transaction.lastValidBlockHeight = lastValidBlockHeight;
       }
     }
 

packages/adapters/database/src/db.ts

@@ -712,6 +712,7 @@ export async function getRebalanceOperations(
   offset?: number,
   filter?: {
     status?: RebalanceOperationStatus | RebalanceOperationStatus[];
+    bridge?: string | string[];
     chainId?: number;
     earmarkId?: string | null;
     invoiceId?: string;
@@ -737,6 +738,17 @@ export async function getRebalanceOperations(
       paramCount++;
     }
 
+    if (filter.bridge) {
+      if (Array.isArray(filter.bridge)) {
+        conditions.push(`ro.bridge = ANY($${paramCount})`);
+        values.push(filter.bridge);
+      } else {
+        conditions.push(`ro.bridge = $${paramCount}`);
+        values.push(filter.bridge);
+      }
+      paramCount++;
+    }
+
     if (filter.chainId !== undefined) {
       conditions.push(`ro."origin_chain_id" = $${paramCount}`);
       values.push(filter.chainId);

packages/adapters/rebalance/package.json

@@ -18,12 +18,13 @@
         "test:unit": "jest --coverage --testPathIgnorePatterns='.*\\.integration\\.spec\\.ts$'"
     },
     "dependencies": {
-        "@chainlink/ccip-js": "^0.2.6",
+        "@chainlink/ccip-sdk": "^0.93.0",
         "@cowprotocol/cow-sdk": "^7.1.2-beta.0",
         "@defuse-protocol/one-click-sdk-typescript": "^0.1.5",
         "@mark/core": "workspace:*",
         "@mark/database": "workspace:*",
         "@mark/logger": "workspace:*",
+        "@solana/web3.js": "^1.98.0",
         "@tonappchain/sdk": "0.7.1",
         "axios": "1.9.0",
         "bs58": "^6.0.0",