feat: implement jupiter as a swapper

.env.base

@@ -61,13 +61,14 @@ REACT_APP_FEATURE_DYNAMIC_LP_ASSETS=false
 REACT_APP_FEATURE_READ_ONLY_ASSETS=true
 
 # swapper feature flags - other .env files will override these
-REACT_APP_FEATURE_CHAINFLIP=false
-REACT_APP_FEATURE_CHAINFLIP_DCA=false
+REACT_APP_FEATURE_CHAINFLIP_SWAP=false
+REACT_APP_FEATURE_CHAINFLIP_SWAP_DCA=false
 REACT_APP_FEATURE_COWSWAP=true
 REACT_APP_FEATURE_LIFI_SWAP=true
 REACT_APP_FEATURE_THOR_SWAP=true
 REACT_APP_FEATURE_THOR_SWAP_STREAMING_SWAPS=true
 REACT_APP_FEATURE_ZRX_SWAP=true
+REACT_APP_FEATURE_JUPITER_SWAP=false
 
 # chat woot
 REACT_APP_CHATWOOT_TOKEN=jmoXp9BPMSPEYHeJX5YKT15Q

.env.dev

@@ -1,8 +1,9 @@
 # feature flags
-REACT_APP_FEATURE_CHAINFLIP=true
-REACT_APP_FEATURE_CHAINFLIP_DCA=false
-REACT_APP_FEATURE_PUBLIC_TRADE_ROUTE=true
+REACT_APP_FEATURE_CHAINFLIP_SWAP=true
+REACT_APP_FEATURE_CHAINFLIP_SWAP_DCA=false
+REACT_APP_FEATURE_PUBLIC_TRADE_ROUTE=false
 REACT_APP_FEATURE_LIMIT_ORDERS=true
+REACT_APP_FEATURE_JUPITER_SWAP=true
 
 # logging
 REACT_APP_REDUX_WINDOW=false

.env.develop

@@ -1,8 +1,8 @@
 # feature flags
 REACT_APP_FEATURE_LIMIT_ORDERS=true
-REACT_APP_FEATURE_PUBLIC_TRADE_ROUTE=true
-REACT_APP_FEATURE_CHAINFLIP=true
-REACT_APP_FEATURE_CHAINFLIP_DCA=false
+REACT_APP_FEATURE_PUBLIC_TRADE_ROUTE=false
+REACT_APP_FEATURE_CHAINFLIP_SWAP=true
+REACT_APP_FEATURE_CHAINFLIP_SWAP_DCA=false
 
 # mixpanel
 REACT_APP_MIXPANEL_TOKEN=1c1369f6ea23a6404bac41b42817cc4b

package.json

@@ -93,18 +93,18 @@
     "@shapeshiftoss/caip": "workspace:^",
     "@shapeshiftoss/chain-adapters": "workspace:^",
     "@shapeshiftoss/errors": "workspace:^",
-    "@shapeshiftoss/hdwallet-coinbase": "1.55.12",
-    "@shapeshiftoss/hdwallet-core": "1.55.12",
-    "@shapeshiftoss/hdwallet-keepkey": "1.55.12",
-    "@shapeshiftoss/hdwallet-keepkey-webusb": "1.55.12",
-    "@shapeshiftoss/hdwallet-keplr": "1.55.12",
-    "@shapeshiftoss/hdwallet-ledger": "1.55.12",
-    "@shapeshiftoss/hdwallet-ledger-webusb": "1.55.12",
-    "@shapeshiftoss/hdwallet-metamask-multichain": "1.55.12",
-    "@shapeshiftoss/hdwallet-native": "1.55.12",
-    "@shapeshiftoss/hdwallet-native-vault": "1.55.12",
-    "@shapeshiftoss/hdwallet-phantom": "1.55.12",
-    "@shapeshiftoss/hdwallet-walletconnectv2": "1.55.12",
+    "@shapeshiftoss/hdwallet-coinbase": "1.55.13",
+    "@shapeshiftoss/hdwallet-core": "1.55.13",
+    "@shapeshiftoss/hdwallet-keepkey": "1.55.13",
+    "@shapeshiftoss/hdwallet-keepkey-webusb": "1.55.13",
+    "@shapeshiftoss/hdwallet-keplr": "1.55.13",
+    "@shapeshiftoss/hdwallet-ledger": "1.55.13",
+    "@shapeshiftoss/hdwallet-ledger-webusb": "1.55.13",
+    "@shapeshiftoss/hdwallet-metamask-multichain": "1.55.13",
+    "@shapeshiftoss/hdwallet-native": "1.55.13",
+    "@shapeshiftoss/hdwallet-native-vault": "1.55.13",
+    "@shapeshiftoss/hdwallet-phantom": "1.55.13",
+    "@shapeshiftoss/hdwallet-walletconnectv2": "1.55.13",
     "@shapeshiftoss/swapper": "workspace:^",
     "@shapeshiftoss/types": "workspace:^",
     "@shapeshiftoss/unchained-client": "workspace:^",

packages/caip/src/constants.ts

@@ -16,6 +16,8 @@ export const arbitrumAssetId: AssetId = 'eip155:42161/slip44:60'
 export const arbitrumNovaAssetId: AssetId = 'eip155:42170/slip44:60'
 export const baseAssetId: AssetId = 'eip155:8453/slip44:60'
 export const solAssetId: AssetId = 'solana:5eykt4UsFv8P8NJdTREpY1vzqKqZKvdp/slip44:501'
+export const wrappedSolAssetId: AssetId =
+  'solana:5eykt4UsFv8P8NJdTREpY1vzqKqZKvdp/token:So11111111111111111111111111111111111111112'
 
 export const foxatarAssetId: AssetId =
   'eip155:137/erc721:0x2e727c425a11ce6b8819b3004db332c12d2af2a2'

packages/chain-adapters/src/solana/SolanaChainAdapter.ts

@@ -8,6 +8,7 @@ import {
 } from '@shapeshiftoss/caip'
 import type {
   HDWallet,
+  SolanaAddressLookupTableAccountInfo,
   SolanaSignTx,
   SolanaTxInstruction,
   SolanaWallet,
@@ -22,18 +23,22 @@ import {
   createTransferInstruction,
   getAccount,
   getAssociatedTokenAddressSync,
+  TOKEN_2022_PROGRAM_ID,
+  TOKEN_PROGRAM_ID,
   TokenAccountNotFoundError,
   TokenInvalidAccountOwnerError,
 } from '@solana/spl-token'
-import type { TransactionInstruction } from '@solana/web3.js'
+import type { AccountInfo, TransactionInstruction } from '@solana/web3.js'
 import {
+  AddressLookupTableAccount,
   ComputeBudgetProgram,
   Connection,
   PublicKey,
   SystemProgram,
   TransactionMessage,
   VersionedTransaction,
 } from '@solana/web3.js'
+import { isUndefined } from 'lodash'
 import PQueue from 'p-queue'
 
 import type { ChainAdapter as IChainAdapter } from '../api'
@@ -62,6 +67,8 @@ import { toAddressNList, toRootDerivationPath } from '../utils'
 import { assertAddressNotSanctioned } from '../utils/validateAddress'
 import { microLamportsToLamports } from './utils'
 
+export const svmChainIds = [KnownChainIds.SolanaMainnet] as const
+
 // Maximum compute units allowed for a single solana transaction
 const MAX_COMPUTE_UNITS = 1400000
 
@@ -251,6 +258,10 @@ export class ChainAdapter implements IChainAdapter<KnownChainIds.SolanaMainnet>
         )
       }
 
+      const addressLookupTableAccountInfos = await this.getAddressLookupTableAccounts(
+        chainSpecific.addressLookupTableAccounts ?? [],
+      )
+
       const txToSign: SignTx<KnownChainIds.SolanaMainnet> = {
         addressNList: toAddressNList(this.getBIP44Params({ accountNumber })),
         blockHash: blockhash,
@@ -259,6 +270,7 @@ export class ChainAdapter implements IChainAdapter<KnownChainIds.SolanaMainnet>
         instructions,
         to: tokenId ? '' : to,
         value: tokenId ? '' : value,
+        addressLookupTableAccountInfos,
       }
 
       return { txToSign }
@@ -449,8 +461,14 @@ export class ChainAdapter implements IChainAdapter<KnownChainIds.SolanaMainnet>
     const { to, chainSpecific } = input
     const { from, tokenId, instructions = [] } = chainSpecific
 
-    if (!to) throw new Error('to is required')
-    if (!input.value) throw new Error('value is required')
+    const estimationInstructions = [...instructions]
+
+    const addressLookupTableAccounts = await this.getSolanaAddressLookupTableAccountsInfo(
+      chainSpecific.addressLookupTableAccounts ?? [],
+    )
+
+    if (isUndefined(input.to)) throw new Error(`${this.getName()}ChainAdapter: to is required`)
+    if (!input.value) throw new Error(`${this.getName()}ChainAdapter: value is required`)
 
     const value = Number(input.value)
 
@@ -463,9 +481,9 @@ export class ChainAdapter implements IChainAdapter<KnownChainIds.SolanaMainnet>
           value: input.value,
         })
 
-        instructions.push(...tokenTransferInstructions)
+        estimationInstructions.push(...tokenTransferInstructions)
       } else {
-        instructions.push(
+        estimationInstructions.push(
           SystemProgram.transfer({
             fromPubkey: new PublicKey(from),
             toPubkey: new PublicKey(to),
@@ -477,17 +495,19 @@ export class ChainAdapter implements IChainAdapter<KnownChainIds.SolanaMainnet>
 
     // Set compute unit limit to the maximum compute units for the purposes of estimating the compute unit cost of a transaction,
     // ensuring the transaction does not exceed the maximum compute units alotted for a single transaction.
-    instructions.push(ComputeBudgetProgram.setComputeUnitLimit({ units: MAX_COMPUTE_UNITS }))
+    estimationInstructions.push(
+      ComputeBudgetProgram.setComputeUnitLimit({ units: MAX_COMPUTE_UNITS }),
+    )
 
     // placeholder compute unit price instruction for the purposes of estimating the compute unit cost of a transaction
-    instructions.push(ComputeBudgetProgram.setComputeUnitPrice({ microLamports: 0 }))
+    estimationInstructions.push(ComputeBudgetProgram.setComputeUnitPrice({ microLamports: 0 }))
 
     const message = new TransactionMessage({
       payerKey: new PublicKey(input.chainSpecific.from),
-      instructions,
+      instructions: estimationInstructions,
       // static block hash as fee estimation replaces the block hash with latest to save us a client side call
       recentBlockhash: '4sGjMW1sUnHzSxGspuhpqLDx6wiyjNtZAMdL4VZHirAn',
-    }).compileToV0Message()
+    }).compileToV0Message(addressLookupTableAccounts)
 
     const transaction = new VersionedTransaction(message)
 
@@ -507,10 +527,49 @@ export class ChainAdapter implements IChainAdapter<KnownChainIds.SolanaMainnet>
   }): Promise<TransactionInstruction[]> {
     const instructions: TransactionInstruction[] = []
 
+    const { instruction, destinationTokenAccount } =
+      await this.createAssociatedTokenAccountInstruction({ from, to, tokenId })
+
+    if (instruction) {
+      instructions.push(instruction)
+    }
+
+    instructions.push(
+      createTransferInstruction(
+        getAssociatedTokenAddressSync(new PublicKey(tokenId), new PublicKey(from), true),
+        destinationTokenAccount,
+        new PublicKey(from),
+        Number(value),
+      ),
+    )
+
+    return instructions
+  }
+
+  public async createAssociatedTokenAccountInstruction({
+    from,
+    to,
+    tokenId,
+  }: {
+    from: string
+    to: string
+    tokenId: string
+  }): Promise<{
+    instruction?: TransactionInstruction
+    destinationTokenAccount: PublicKey
+  }> {
+    const accountInfo = await this.connection.getAccountInfo(new PublicKey(tokenId))
+
+    const TOKEN_PROGRAM =
+      accountInfo?.owner.toString() === TOKEN_2022_PROGRAM_ID.toString()
+        ? TOKEN_2022_PROGRAM_ID
+        : TOKEN_PROGRAM_ID
+
     const destinationTokenAccount = getAssociatedTokenAddressSync(
       new PublicKey(tokenId),
       new PublicKey(to),
       true,
+      TOKEN_PROGRAM,
     )
 
     // check if destination token account exists and add creation instruction if it doesn't
@@ -521,31 +580,27 @@ export class ChainAdapter implements IChainAdapter<KnownChainIds.SolanaMainnet>
         err instanceof TokenAccountNotFoundError ||
         err instanceof TokenInvalidAccountOwnerError
       ) {
-        instructions.push(
-          createAssociatedTokenAccountInstruction(
+        return {
+          instruction: createAssociatedTokenAccountInstruction(
             // sender pays for creation of the token account
             new PublicKey(from),
             destinationTokenAccount,
             new PublicKey(to),
             new PublicKey(tokenId),
+            TOKEN_PROGRAM,
           ),
-        )
+          destinationTokenAccount,
+        }
       }
     }
 
-    instructions.push(
-      createTransferInstruction(
-        getAssociatedTokenAddressSync(new PublicKey(tokenId), new PublicKey(from), true),
-        destinationTokenAccount,
-        new PublicKey(from),
-        Number(value),
-      ),
-    )
-
-    return instructions
+    return {
+      instruction: undefined,
+      destinationTokenAccount,
+    }
   }
 
-  private convertInstruction(instruction: TransactionInstruction): SolanaTxInstruction {
+  public convertInstruction(instruction: TransactionInstruction): SolanaTxInstruction {
     return {
       keys: instruction.keys.map(key => ({
         pubkey: key.pubkey.toString(),
@@ -557,6 +612,12 @@ export class ChainAdapter implements IChainAdapter<KnownChainIds.SolanaMainnet>
     }
   }
 
+  public async getTxStatus(tx: unchained.solana.Tx, pubkey: string): Promise<unchained.TxStatus> {
+    const parsedTx = await this.parseTx(tx, pubkey)
+
+    return parsedTx.status
+  }
+
   private async parseTx(tx: unchained.solana.Tx, pubkey: string): Promise<Transaction> {
     const { address: _, ...parsedTx } = await this.parser.parse(tx, pubkey)
 
@@ -572,4 +633,54 @@ export class ChainAdapter implements IChainAdapter<KnownChainIds.SolanaMainnet>
       })),
     }
   }
+
+  get httpProvider(): unchained.solana.Api {
+    return this.providers.http
+  }
+
+  private async getAddressLookupTableAccountsInfo(
+    addresses: string[],
+  ): Promise<(AccountInfo<Buffer> | null)[]> {
+    return await this.connection.getMultipleAccountsInfo(addresses.map(key => new PublicKey(key)))
+  }
+
+  private async getSolanaAddressLookupTableAccountsInfo(
+    addresses: string[],
+  ): Promise<AddressLookupTableAccount[]> {
+    const addressLookupTableAccountInfos = await this.getAddressLookupTableAccountsInfo(addresses)
+
+    return addressLookupTableAccountInfos.reduce((acc, accountInfo, index) => {
+      const addressLookupTableAddress = addresses[index]
+      if (accountInfo) {
+        const addressLookupTableAccount = new AddressLookupTableAccount({
+          key: new PublicKey(addressLookupTableAddress),
+          state: AddressLookupTableAccount.deserialize(
+            new Uint8Array(Buffer.from(accountInfo.data)),
+          ),
+        })
+        acc.push(addressLookupTableAccount)
+      }
+
+      return acc
+    }, new Array<AddressLookupTableAccount>())
+  }
+
+  private async getAddressLookupTableAccounts(
+    addresses: string[],
+  ): Promise<SolanaAddressLookupTableAccountInfo[]> {
+    const addressLookupTableAccountInfos = await this.getAddressLookupTableAccountsInfo(addresses)
+
+    return addressLookupTableAccountInfos.reduce((acc, accountInfo, index) => {
+      const addressLookupTableAddress = addresses[index]
+      if (accountInfo) {
+        const addressLookupTableAccount = {
+          key: addressLookupTableAddress,
+          data: Buffer.from(accountInfo.data),
+        }
+        acc.push(addressLookupTableAccount)
+      }
+
+      return acc
+    }, new Array<SolanaAddressLookupTableAccountInfo>())
+  }
 }

packages/chain-adapters/src/solana/types.ts

@@ -25,12 +25,14 @@ export type BuildTxInput = {
   computeUnitPrice?: string
   tokenId?: string
   instructions?: SolanaTxInstruction[]
+  addressLookupTableAccounts?: string[]
 }
 
 export type GetFeeDataInput = {
   from: string
   tokenId?: string
   instructions?: TransactionInstruction[]
+  addressLookupTableAccounts?: string[]
 }
 
 export type FeeData = {