change commitment message recent to processed solves issue coral-xyz#289

Necmttn · Dec 11, 2021 · f590e28 · f590e28
1 parent fcb07eb
commit f590e28
Show file tree

Hide file tree

Showing 6 changed files with 12 additions and 12 deletions.
diff --git a/tests/cfo/scripts/fees.js b/tests/cfo/scripts/fees.js
@@ -19,7 +19,7 @@ async function main() {
     let marketClient = await Market.load(
       provider.connection,
       market,
-      { commitment: "recent" },
+      { commitment: "processed" },
       DEX_PID
     );
     console.log("Fees: ", marketClient._decoded.quoteFeesAccrued.toString());

diff --git a/tests/cfo/tests/cfo.js b/tests/cfo/tests/cfo.js
@@ -102,13 +102,13 @@ describe("cfo", () => {
     marketAClient = await Market.load(
       program.provider.connection,
       ORDERBOOK_ENV.marketA.address,
-      { commitment: "recent" },
+      { commitment: "processed" },
       DEX_PID
     );
     marketBClient = await Market.load(
       program.provider.connection,
       ORDERBOOK_ENV.marketB.address,
-      { commitment: "recent" },
+      { commitment: "processed" },
       DEX_PID
     );
     assert.ok(marketAClient._decoded.quoteFeesAccrued.toString() === FEES);

diff --git a/tests/cfo/tests/utils/index.js b/tests/cfo/tests/utils/index.js
@@ -201,7 +201,7 @@ async function setupMarket({
   const MARKET_A_USDC = await Market.load(
     provider.connection,
     marketAPublicKey,
-    { commitment: "recent" },
+    { commitment: "processed" },
     DEX_PID
   );
   for (let k = 0; k < asks.length; k += 1) {
@@ -405,7 +405,7 @@ async function signTransactions({
 async function sendAndConfirmRawTransaction(
   connection,
   raw,
-  commitment = "recent"
+  commitment = "processed"
 ) {
   let tx = await connection.sendRawTransaction(raw, {
     skipPreflight: true,
@@ -433,7 +433,7 @@ async function runTradeBot(market, provider, iterations = undefined) {
   let marketClient = await Market.load(
     provider.connection,
     market,
-    { commitment: "recent" },
+    { commitment: "processed" },
     DEX_PID
   );
   const baseTokenUser1 = (

diff --git a/tests/swap/tests/utils/index.js b/tests/swap/tests/utils/index.js
@@ -272,7 +272,7 @@ async function setupMarket({
   const MARKET_A_USDC = await Market.load(
     provider.connection,
     marketAPublicKey,
-    { commitment: "recent" },
+    { commitment: "processed" },
     DEX_PID
   );
   for (let k = 0; k < asks.length; k += 1) {
@@ -476,7 +476,7 @@ async function signTransactions({
 async function sendAndConfirmRawTransaction(
   connection,
   raw,
-  commitment = "recent"
+  commitment = "processed"
 ) {
   let tx = await connection.sendRawTransaction(raw, {
     skipPreflight: true,

diff --git a/ts/src/provider.ts b/ts/src/provider.ts
@@ -30,8 +30,8 @@ export default class Provider {
 
   static defaultOptions(): ConfirmOptions {
     return {
-      preflightCommitment: "recent",
-      commitment: "recent",
+      preflightCommitment: "processed",
+      commitment: "processed",
     };
   }
 
@@ -207,7 +207,7 @@ export default class Provider {
     return await simulateTransaction(
       this.connection,
       tx,
-      opts.commitment ?? this.opts.commitment ?? "recent"
+      opts.commitment ?? this.opts.commitment ?? "processed"
     );
   }
 }

diff --git a/ts/src/utils/rpc.ts b/ts/src/utils/rpc.ts
@@ -65,7 +65,7 @@ async function getMultipleAccountsCore(
 ): Promise<
   Array<null | { publicKey: PublicKey; account: AccountInfo<Buffer> }>
 > {
-  const args = [publicKeys.map((k) => k.toBase58()), { commitment: "recent" }];
+  const args = [publicKeys.map((k) => k.toBase58()), { commitment: "processed" }];
   // @ts-ignore
   const res = await connection._rpcRequest("getMultipleAccounts", args);
   if (res.error) {