feat: update getTransaction to support versioned transactions

web3.js/src/connection.ts

@@ -32,8 +32,12 @@ import {NonceAccount} from './nonce-account';
 import {PublicKey} from './publickey';
 import {Signer} from './keypair';
 import {MS_PER_SLOT} from './timing';
-import {Transaction, TransactionStatus} from './transaction';
-import {Message} from './message';
+import {
+  Transaction,
+  TransactionStatus,
+  TransactionVersion,
+} from './transaction';
+import {Message, MessageV0, VersionedMessage} from './message';
 import {AddressLookupTableAccount} from './programs/address-lookup-table/state';
 import assert from './utils/assert';
 import {sleep} from './utils/sleep';
@@ -862,6 +866,8 @@ export type ConfirmedTransactionMeta = {
   postTokenBalances?: Array<TokenBalance> | null;
   /** The error result of transaction processing */
   err: TransactionError | null;
+  /** The collection of addresses loaded using address lookup tables */
+  loadedAddresses?: LoadedAddresses;
 };
 
 /**
@@ -873,14 +879,16 @@ export type TransactionResponse = {
   /** The transaction */
   transaction: {
     /** The transaction message */
-    message: Message;
+    message: VersionedMessage;
     /** The transaction signatures */
     signatures: string[];
   };
   /** Metadata produced from the transaction */
   meta: ConfirmedTransactionMeta | null;
   /** The unix timestamp of when the transaction was processed */
   blockTime?: number | null;
+  /** The transaction version */
+  version?: TransactionVersion;
 };
 
 /**
@@ -935,6 +943,18 @@ export type ParsedInstruction = {
   parsed: any;
 };
 
+/**
+ * A parsed address table lookup
+ */
+export type ParsedAddressTableLookup = {
+  /** Address lookup table account key */
+  accountKey: PublicKey;
+  /** Parsed instruction info */
+  writableIndexes: number[];
+  /** Parsed instruction info */
+  readonlyIndexes: number[];
+};
+
 /**
  * A parsed transaction message
  */
@@ -945,6 +965,8 @@ export type ParsedMessage = {
   instructions: (ParsedInstruction | PartiallyDecodedInstruction)[];
   /** Recent blockhash */
   recentBlockhash: string;
+  /** Address table lookups used to load additional accounts */
+  addressTableLookups?: ParsedAddressTableLookup[] | null;
 };
 
 /**
@@ -976,6 +998,8 @@ export type ParsedTransactionWithMeta = {
   meta: ParsedTransactionMeta | null;
   /** The unix timestamp of when the transaction was processed */
   blockTime?: number | null;
+  /** The version of the transaction message */
+  version?: TransactionVersion;
 };
 
 /**
@@ -1722,6 +1746,12 @@ const GetSignatureStatusesRpcResult = jsonRpcResultAndContext(
  */
 const GetMinimumBalanceForRentExemptionRpcResult = jsonRpcResult(number());
 
+const AddressTableLookupStruct = pick({
+  accountKey: PublicKeyFromString,
+  writableIndexes: array(number()),
+  readonlyIndexes: array(number()),
+});
+
 const ConfirmedTransactionResult = pick({
   signatures: array(string()),
   message: pick({
@@ -1739,6 +1769,7 @@ const ConfirmedTransactionResult = pick({
       }),
     ),
     recentBlockhash: string(),
+    addressTableLookups: optional(array(AddressTableLookupStruct)),
   }),
 });
 
@@ -1799,6 +1830,7 @@ const ParsedConfirmedTransactionResult = pick({
     ),
     instructions: array(ParsedOrRawInstruction),
     recentBlockhash: string(),
+    addressTableLookups: optional(nullable(array(AddressTableLookupStruct))),
   }),
 });
 
@@ -1946,6 +1978,8 @@ const GetBlockSignaturesRpcResult = jsonRpcResult(
   ),
 );
 
+const TransactionVersionStruct = union([number(), literal('legacy')]);
+
 /**
  * Expected JSON RPC response for the "getTransaction" message
  */
@@ -1956,6 +1990,7 @@ const GetTransactionRpcResult = jsonRpcResult(
       meta: ConfirmedTransactionMetaResult,
       blockTime: optional(nullable(number())),
       transaction: ConfirmedTransactionResult,
+      version: optional(TransactionVersionStruct),
     }),
   ),
 );
@@ -1970,6 +2005,7 @@ const GetParsedTransactionRpcResult = jsonRpcResult(
       transaction: ParsedConfirmedTransactionResult,
       meta: nullable(ParsedConfirmedTransactionMetaResult),
       blockTime: optional(nullable(number())),
+      version: optional(TransactionVersionStruct),
     }),
   ),
 );
@@ -3758,11 +3794,31 @@ export class Connection {
     const result = res.result;
     if (!result) return result;
 
+    const messageResponse = result.transaction.message;
+    let message: VersionedMessage;
+    if (result.version === 0) {
+      message = new MessageV0({
+        header: messageResponse.header,
+        staticAccountKeys: messageResponse.accountKeys.map(
+          address => new PublicKey(address),
+        ),
+        recentBlockhash: messageResponse.recentBlockhash,
+        compiledInstructions: messageResponse.instructions.map(ix => ({
+          programIdIndex: ix.programIdIndex,
+          accountKeyIndexes: ix.accounts,
+          data: bs58.decode(ix.data),
+        })),
+        addressTableLookups: messageResponse.addressTableLookups!,
+      });
+    } else {
+      message = new Message(messageResponse);
+    }
+
     return {
       ...result,
       transaction: {
         ...result.transaction,
-        message: new Message(result.transaction.message),
+        message,
       },
     };
   }
@@ -3773,7 +3829,7 @@ export class Connection {
   async getParsedTransaction(
     signature: TransactionSignature,
     commitmentOrConfig?: GetTransactionConfig | Finality,
-  ): Promise<ParsedConfirmedTransaction | null> {
+  ): Promise<ParsedTransactionWithMeta | null> {
     const {commitment, config} =
       extractCommitmentFromConfig(commitmentOrConfig);
     const args = this._buildArgsAtLeastConfirmed(
@@ -3796,7 +3852,7 @@ export class Connection {
   async getParsedTransactions(
     signatures: TransactionSignature[],
     commitmentOrConfig?: GetTransactionConfig | Finality,
-  ): Promise<(ParsedConfirmedTransaction | null)[]> {
+  ): Promise<(ParsedTransactionWithMeta | null)[]> {
     const {commitment, config} =
       extractCommitmentFromConfig(commitmentOrConfig);
     const batch = signatures.map(signature => {