index.ts

import { Connection, Keypair, Transaction } from "@solana/web3.js";
import promiseRetry from "promise-retry";
import dotenv from "dotenv";
import bs58 from "bs58";
import { NodeWallet } from "nodewallet";

console.log({ dotenv });
dotenv.config();

const connection = new Connection(
  ""
);

const wallet = new NodeWallet(
  Keypair.fromSecretKey(bs58.decode(process.env.PRIVATE_KEY || ""))
);

const USDC_MINT = "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v";
const SOL_MINT = "So11111111111111111111111111111111111111112";
const initial = 50_000_000;
const minimal_output = initial * 1.0015;
const profit_wanted = minimal_output / 1000000;

const indexedRoute = await getIndexedRoutes();
const SOL_POSITION = indexedRoute.mintKeys.indexOf("DUSTawucrTsGU8hcqRdHDCbuYhCPADMLM2VcCb8VnFnQ");
const INDEXES_INTERMEDIATE = indexedRoute.indexedRouteMap[SOL_POSITION];
let MINT_KEYS: string[] = []
for (const intermediate in INDEXES_INTERMEDIATE) {
  const value = INDEXES_INTERMEDIATE[intermediate];
  const key: string = indexedRoute.mintKeys[value]
  MINT_KEYS.push(key);
}

async function getIndexedRoutes(){
  const url = "https://quote-api.jup.ag/v1/indexed-route-map?onlyDirectRoutes=true"
  return await (
    await fetch(
      url, {
        method: "GET",
      }
    )
  ).json();
}

async function getQuotes(){
  const url1 = `https://quote-api.jup.ag/v1/quote?outputMint=${SOL_MINT}&inputMint=${USDC_MINT}&amount=${initial}`//&onlyDirectRoutes=true
  const usdcToSol = await (
    await fetch(
      url1, { 
        method: "GET",
      }
    )
  ).json();

  const url2 = `https://quote-api.jup.ag/v1/quote?outputMint=${USDC_MINT}&inputMint=${SOL_MINT}&amount=${usdcToSol.data[0].outAmount}`
  const solToUsdc = await (
    await fetch(
      url2, {
        method: "GET",
      }
    )
  ).json();

  console.log("Output: " + solToUsdc.data[0].outAmount/1000000 + " | Wanted: " + profit_wanted + " | Market: " + solToUsdc.data[0].marketInfos[0].label + " | Time taken: " + solToUsdc.timeTaken);

  return [ usdcToSol.data[0], solToUsdc.data[0] ];
}

async function getTransaction(route){
  const tx = await (
    await fetch("https://quote-api.jup.ag/v1/swap", {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
      },
      body: JSON.stringify({
        route: route,
        userPublicKey: "7SZM2pvDUfonYmdPqxwaw8bp93JvUXWiWWyRSHfga2Q7",
        wrapUnwrapSOL: false,
      }),
    })
  ).json();

  return [ tx.setupTransaction, tx.swapTransaction, tx.cleanupTransaction ]
}

const getConfirmTransaction = async (txid) => {
  const res = await promiseRetry(
    async (retry) => {
      let txResult = await connection.getTransaction(txid, {
        commitment: "confirmed",
      });
      if (!txResult) {
        const error = new Error("Transaction was not confirmed");

        retry(error);
        return;
      }
      return txResult;
    },
    {
      retries: 40,
      minTimeout: 500,
      maxTimeout: 1000,
    }
  );
  if (res.meta.err) {
    throw new Error("Transaction failed");
  }
  return txid;
};

while (true) {
  const [ usdcToSol, solToUsdc ] = await getQuotes()
  if (solToUsdc.outAmount > minimal_output) {
    console.log("Opportunity found");
    await Promise.all(
      [usdcToSol, solToUsdc].map(async (route) => {
        const [ setupTransaction, swapTransaction, cleanupTransaction ] = await getTransaction(route);
        await Promise.all(// i think setupTx creates necessary ATA's and cleanupTx closes it, if the necessary ATA's are already created you will get those attributes as undefined
          [setupTransaction, swapTransaction, cleanupTransaction]
            .filter(Boolean)
            .map(async (serializedTransaction) => {
              const transaction = Transaction.from(
                Buffer.from(serializedTransaction, "base64")
              );
              const txid = await connection.sendTransaction(
                transaction,
                [wallet.payer],
                {
                  skipPreflight: true,
                }
              );
              try {
                await getConfirmTransaction(txid);
                console.log(`Success: https://solscan.io/tx/${txid}`);
              } catch (e) {
                console.log(`Failed: https://solscan.io/tx/${txid}`);
              }
            })
        );
      })
    );
  }
}