Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
@@ -2,3 +2,5 @@
/node_modules
/build
/tsconfig.tsbuildinfo
/hardhat
/.vscode
14 changes: 9 additions & 5 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,13 +1,16 @@
simple-arbitrage
simple-arbitrage-FL-Variant
================
This repository contains a simple, mechanical system for discovering, evaluating, rating, and submitting arbitrage opportunities to the Flashbots bundle endpoint. This script is very unlikely to be profitable, as many users have access to it, and it is targeting well-known Ethereum opportunities.
This repository is a fork of the Flashbots simple arbitrage bot. It builds on top of their work by adding a flashloan capability, which lets anyone try to capture arbitrage opportunities regardless of how much ETH they have.

We hope you will use this repository as an example of how to integrate Flashbots into your own Flashbot searcher (bot). For more information, see the [Flashbots Searcher FAQ](https://hackmd.io/@flashbots/rk-qzgzCD)
*Note that the added gas cost of using a flashloan will make it difficult to capture arbitrage opportunities you might find.* Also be mindful that several people are currently running this bot, and it is unlikely to be profitable for you to do so.

Lastly, this fork is still using Flashbot's old API authentication, which is likely to be deprecated soon and which I think you can no longer get keys for. Searchers may need to upgrade to the new authentication method, and they can refer to the main repository for a reference.

Environment Variables
=====================
- ETHEREUM_RPC_URL - Ethereum RPC endpoint. Can not be the same as FLASHBOTS_RPC_URL
- PRIVATE_KEY - Private key for the Ethereum EOA that will be submitting Flashbots Ethereum transactions
- BUNDLE_EXECUTOR_ADDRESS - The address for the BundledExecutor.sol that you have deployed (see "Usage" below for details).
- FLASHBOTS_KEY_ID / FLASHBOTS_SECRET - Flashbots submissions requires an API key. [Apply for an API key here](https://docs.google.com/forms/d/e/1FAIpQLSd4AKrS-vcfW1X-dQvkFY73HysoKfkhcd-31Tj8frDAU6D6aQ/viewform)
- HEALTHCHECK_URL _[Optional]_ - Health check URL, hit only after successfully submitting a bundle.
- MINER_REWARD_PERCENTAGE _[Optional, default 80]_ - 0 -> 100, what percentage of overall profitability to send to miner.
@@ -22,9 +25,10 @@ _It is important to keep both the bot wallet private key and bundleExecutor owne

```
$ npm install
$ PRIVATE_KEY=__PRIVATE_KEY_FROM_ABOVE__ \
$ ETHEREUM_RPC_URL=__ETHEREUM_RPC_URL_FROM_ABOVE__ \
PRIVATE_KEY=__PRIVATE_KEY_FROM_ABOVE__ \
BUNDLE_EXECUTOR_ADDRESS=__DEPLOYED_ADDRESS_FROM_ABOVE__ \
FLASHBOTS_KEY_ID=__YOUR_PERSONAL_KEY_ID__ \
FLASHBOTS_SECRET=__YOUR_PERSONAL_SECRET__ \
npm run start
npm run start
```
2 changes: 1 addition & 1 deletion contracts/BundleExecutor.sol
Original file line number Diff line number Diff line change
@@ -78,4 +78,4 @@ contract FlashBotsMultiCall {
require(_success);
return _result;
}
}
}
125 changes: 125 additions & 0 deletions contracts/BundleExecutorFL.sol
Original file line number Diff line number Diff line change
@@ -0,0 +1,125 @@
//SPDX-License-Identifier: UNLICENSED
pragma solidity 0.6.12;
pragma experimental ABIEncoderV2;

import "./FlashLoanReceiverBase.sol";
import "./Interfaces.sol";
import "./Libraries.sol";

interface IWETH is IERC20 {
function deposit() external payable;
function withdraw(uint) external;
}

contract FlashBotsMultiCallFL is FlashLoanReceiverBase {
using SafeMath for uint256;
address private immutable owner;
address private immutable executor;
IWETH private constant WETH = IWETH(0xC02aaA39b223FE8D0A0e5C4F27eAD9083C756Cc2);
address private constant ETH_address = address(0xEeeeeEeeeEeEeeEeEeEeeEEEeeeeEeeeeeeeEEeE);

modifier onlyExecutor() {
require(msg.sender == executor);
_;
}

modifier onlyOwner() {
require(msg.sender == owner);
_;
}

constructor(address _executor, ILendingPoolAddressesProvider _addressProvider) FlashLoanReceiverBase(_addressProvider) public payable {
owner = msg.sender;
executor = _executor;
if (msg.value > 0) {
WETH.deposit{value: msg.value}();
}
}

/**
This function is called after your contract has received the flash loaned amount
*/
function executeOperation(
address[] calldata assets,
uint256[] calldata amounts,
uint256[] calldata premiums,
address initiator,
bytes calldata params
)
external
override
returns (bool)
{
uint amountOwing = amounts[0].add(premiums[0]);
uniswapWethFLParams(amounts[0], params, amountOwing);
WETH.approve(address(LENDING_POOL), amountOwing);

return true;
}

function flashloan(address borrowedTokenAddress, uint256 amountToBorrow, bytes memory _params) external onlyExecutor() {
address receiverAddress = address(this);

address[] memory assets = new address[](1);
assets[0] = borrowedTokenAddress;

uint256[] memory amounts = new uint256[](1);
amounts[0] = amountToBorrow;

uint256[] memory modes = new uint256[](1);
modes[0] = 0;

address onBehalfOf = address(this);
uint16 referralCode = 161;

LENDING_POOL.flashLoan(
receiverAddress,
assets,
amounts,
modes,
onBehalfOf,
_params,
referralCode
);
}

function uniswapWethFLParams(uint256 _amountToFirstMarket, bytes memory _params, uint256 totalAaveDebt) internal {
(uint256 _ethAmountToCoinbase, address[] memory _targets, bytes[] memory _payloads) = abi.decode(_params, (uint256, address[], bytes[]));
require(_targets.length == _payloads.length);

WETH.transfer(_targets[0], _amountToFirstMarket);
for (uint256 i = 0; i < _targets.length; i++) {
(bool _success, bytes memory _response) = _targets[i].call(_payloads[i]);
require(_success);
}

uint256 _wethBalanceAfter = WETH.balanceOf(address(this));
require(_wethBalanceAfter > totalAaveDebt + _ethAmountToCoinbase);

uint256 _ethBalance = address(this).balance;
if (_ethBalance < _ethAmountToCoinbase) {
WETH.withdraw(_ethAmountToCoinbase - _ethBalance);
}
block.coinbase.transfer(_ethAmountToCoinbase);
}

function call(address payable _to, uint256 _value, bytes calldata _data) external onlyOwner payable returns (bytes memory) {
require(_to != address(0));
(bool _success, bytes memory _result) = _to.call{value: _value}(_data);
require(_success);
return _result;
}

function withdraw(address token) external onlyOwner {
if (token == ETH_address) {
uint256 bal = address(this).balance;
msg.sender.transfer(bal);
} else if (token != ETH_address) {
uint256 bal = IERC20(token).balanceOf(address(this));
IERC20(token).transfer(address(msg.sender), bal);
}
}

receive() external payable {
}
}
18 changes: 18 additions & 0 deletions contracts/FlashLoanReceiverBase.sol
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
// SPDX-License-Identifier: agpl-3.0
pragma solidity 0.6.12;

import "./Interfaces.sol";
import "./Libraries.sol";

abstract contract FlashLoanReceiverBase is IFlashLoanReceiver {
using SafeERC20 for IERC20;
using SafeMath for uint256;

ILendingPoolAddressesProvider public immutable ADDRESSES_PROVIDER;
ILendingPool public immutable LENDING_POOL;

constructor(ILendingPoolAddressesProvider provider) public {
ADDRESSES_PROVIDER = provider;
LENDING_POOL = ILendingPool(provider.getLendingPool());
}
}
542 changes: 542 additions & 0 deletions contracts/Interfaces.sol

Large diffs are not rendered by default.

315 changes: 315 additions & 0 deletions contracts/Libraries.sol
Original file line number Diff line number Diff line change
@@ -0,0 +1,315 @@
// SPDX-License-Identifier: agpl-3.0
pragma solidity 0.6.12;
pragma experimental ABIEncoderV2;

import "./Interfaces.sol";

library SafeMath {
/**
* @dev Returns the addition of two unsigned integers, reverting on
* overflow.
*
* Counterpart to Solidity's `+` operator.
*
* Requirements:
* - Addition cannot overflow.
*/
function add(uint256 a, uint256 b) internal pure returns (uint256) {
uint256 c = a + b;
require(c >= a, 'SafeMath: addition overflow');

return c;
}

/**
* @dev Returns the subtraction of two unsigned integers, reverting on
* overflow (when the result is negative).
*
* Counterpart to Solidity's `-` operator.
*
* Requirements:
* - Subtraction cannot overflow.
*/
function sub(uint256 a, uint256 b) internal pure returns (uint256) {
return sub(a, b, 'SafeMath: subtraction overflow');
}

/**
* @dev Returns the subtraction of two unsigned integers, reverting with custom message on
* overflow (when the result is negative).
*
* Counterpart to Solidity's `-` operator.
*
* Requirements:
* - Subtraction cannot overflow.
*/
function sub(
uint256 a,
uint256 b,
string memory errorMessage
) internal pure returns (uint256) {
require(b <= a, errorMessage);
uint256 c = a - b;

return c;
}

/**
* @dev Returns the multiplication of two unsigned integers, reverting on
* overflow.
*
* Counterpart to Solidity's `*` operator.
*
* Requirements:
* - Multiplication cannot overflow.
*/
function mul(uint256 a, uint256 b) internal pure returns (uint256) {
// Gas optimization: this is cheaper than requiring 'a' not being zero, but the
// benefit is lost if 'b' is also tested.
// See: https://github.com/OpenZeppelin/openzeppelin-contracts/pull/522
if (a == 0) {
return 0;
}

uint256 c = a * b;
require(c / a == b, 'SafeMath: multiplication overflow');

return c;
}

/**
* @dev Returns the integer division of two unsigned integers. Reverts on
* division by zero. The result is rounded towards zero.
*
* Counterpart to Solidity's `/` operator. Note: this function uses a
* `revert` opcode (which leaves remaining gas untouched) while Solidity
* uses an invalid opcode to revert (consuming all remaining gas).
*
* Requirements:
* - The divisor cannot be zero.
*/
function div(uint256 a, uint256 b) internal pure returns (uint256) {
return div(a, b, 'SafeMath: division by zero');
}

/**
* @dev Returns the integer division of two unsigned integers. Reverts with custom message on
* division by zero. The result is rounded towards zero.
*
* Counterpart to Solidity's `/` operator. Note: this function uses a
* `revert` opcode (which leaves remaining gas untouched) while Solidity
* uses an invalid opcode to revert (consuming all remaining gas).
*
* Requirements:
* - The divisor cannot be zero.
*/
function div(
uint256 a,
uint256 b,
string memory errorMessage
) internal pure returns (uint256) {
// Solidity only automatically asserts when dividing by 0
require(b > 0, errorMessage);
uint256 c = a / b;
// assert(a == b * c + a % b); // There is no case in which this doesn't hold

return c;
}

/**
* @dev Returns the remainder of dividing two unsigned integers. (unsigned integer modulo),
* Reverts when dividing by zero.
*
* Counterpart to Solidity's `%` operator. This function uses a `revert`
* opcode (which leaves remaining gas untouched) while Solidity uses an
* invalid opcode to revert (consuming all remaining gas).
*
* Requirements:
* - The divisor cannot be zero.
*/
function mod(uint256 a, uint256 b) internal pure returns (uint256) {
return mod(a, b, 'SafeMath: modulo by zero');
}

/**
* @dev Returns the remainder of dividing two unsigned integers. (unsigned integer modulo),
* Reverts with custom message when dividing by zero.
*
* Counterpart to Solidity's `%` operator. This function uses a `revert`
* opcode (which leaves remaining gas untouched) while Solidity uses an
* invalid opcode to revert (consuming all remaining gas).
*
* Requirements:
* - The divisor cannot be zero.
*/
function mod(
uint256 a,
uint256 b,
string memory errorMessage
) internal pure returns (uint256) {
require(b != 0, errorMessage);
return a % b;
}
}

library Address {
/**
* @dev Returns true if `account` is a contract.
*
* [IMPORTANT]
* ====
* It is unsafe to assume that an address for which this function returns
* false is an externally-owned account (EOA) and not a contract.
*
* Among others, `isContract` will return false for the following
* types of addresses:
*
* - an externally-owned account
* - a contract in construction
* - an address where a contract will be created
* - an address where a contract lived, but was destroyed
* ====
*/
function isContract(address account) internal view returns (bool) {
// According to EIP-1052, 0x0 is the value returned for not-yet created accounts
// and 0xc5d2460186f7233c927e7db2dcc703c0e500b653ca82273b7bfad8045d85a470 is returned
// for accounts without code, i.e. `keccak256('')`
bytes32 codehash;
bytes32 accountHash = 0xc5d2460186f7233c927e7db2dcc703c0e500b653ca82273b7bfad8045d85a470;
// solhint-disable-next-line no-inline-assembly
assembly {
codehash := extcodehash(account)
}
return (codehash != accountHash && codehash != 0x0);
}

/**
* @dev Replacement for Solidity's `transfer`: sends `amount` wei to
* `recipient`, forwarding all available gas and reverting on errors.
*
* https://eips.ethereum.org/EIPS/eip-1884[EIP1884] increases the gas cost
* of certain opcodes, possibly making contracts go over the 2300 gas limit
* imposed by `transfer`, making them unable to receive funds via
* `transfer`. {sendValue} removes this limitation.
*
* https://diligence.consensys.net/posts/2019/09/stop-using-soliditys-transfer-now/[Learn more].
*
* IMPORTANT: because control is transferred to `recipient`, care must be
* taken to not create reentrancy vulnerabilities. Consider using
* {ReentrancyGuard} or the
* https://solidity.readthedocs.io/en/v0.5.11/security-considerations.html#use-the-checks-effects-interactions-pattern[checks-effects-interactions pattern].
*/
function sendValue(address payable recipient, uint256 amount) internal {
require(address(this).balance >= amount, 'Address: insufficient balance');

// solhint-disable-next-line avoid-low-level-calls, avoid-call-value
(bool success, ) = recipient.call{value: amount}('');
require(success, 'Address: unable to send value, recipient may have reverted');
}
}



/**
* @title SafeERC20
* @dev Wrappers around ERC20 operations that throw on failure (when the token
* contract returns false). Tokens that return no value (and instead revert or
* throw on failure) are also supported, non-reverting calls are assumed to be
* successful.
* To use this library you can add a `using SafeERC20 for IERC20;` statement to your contract,
* which allows you to call the safe operations as `token.safeTransfer(...)`, etc.
*/
library SafeERC20 {
using SafeMath for uint256;
using Address for address;

function safeTransfer(
IERC20 token,
address to,
uint256 value
) internal {
callOptionalReturn(token, abi.encodeWithSelector(token.transfer.selector, to, value));
}

function safeTransferFrom(
IERC20 token,
address from,
address to,
uint256 value
) internal {
callOptionalReturn(token, abi.encodeWithSelector(token.transferFrom.selector, from, to, value));
}

function safeApprove(
IERC20 token,
address spender,
uint256 value
) internal {
require(
(value == 0) || (token.allowance(address(this), spender) == 0),
'SafeERC20: approve from non-zero to non-zero allowance'
);
callOptionalReturn(token, abi.encodeWithSelector(token.approve.selector, spender, value));
}

function callOptionalReturn(IERC20 token, bytes memory data) private {
require(address(token).isContract(), 'SafeERC20: call to non-contract');

// solhint-disable-next-line avoid-low-level-calls
(bool success, bytes memory returndata) = address(token).call(data);
require(success, 'SafeERC20: low-level call failed');

if (returndata.length > 0) {
// Return data is optional
// solhint-disable-next-line max-line-length
require(abi.decode(returndata, (bool)), 'SafeERC20: ERC20 operation did not succeed');
}
}
}

library DataTypes {
// refer to the whitepaper, section 1.1 basic concepts for a formal description of these properties.
struct ReserveData {
//stores the reserve configuration
ReserveConfigurationMap configuration;
//the liquidity index. Expressed in ray
uint128 liquidityIndex;
//variable borrow index. Expressed in ray
uint128 variableBorrowIndex;
//the current supply rate. Expressed in ray
uint128 currentLiquidityRate;
//the current variable borrow rate. Expressed in ray
uint128 currentVariableBorrowRate;
//the current stable borrow rate. Expressed in ray
uint128 currentStableBorrowRate;
uint40 lastUpdateTimestamp;
//tokens addresses
address aTokenAddress;
address stableDebtTokenAddress;
address variableDebtTokenAddress;
//address of the interest rate strategy
address interestRateStrategyAddress;
//the id of the reserve. Represents the position in the list of the active reserves
uint8 id;
}

struct ReserveConfigurationMap {
//bit 0-15: LTV
//bit 16-31: Liq. threshold
//bit 32-47: Liq. bonus
//bit 48-55: Decimals
//bit 56: Reserve is active
//bit 57: reserve is frozen
//bit 58: borrowing is enabled
//bit 59: stable rate borrowing enabled
//bit 60-63: reserved
//bit 64-79: reserve factor
uint256 data;
}

struct UserConfigurationMap {
uint256 data;
}

enum InterestRateMode {NONE, STABLE, VARIABLE}
}
126 changes: 83 additions & 43 deletions src/Arbitrage.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import * as _ from "lodash";
import { BigNumber, Contract, Wallet } from "ethers";
import { BigNumber, Contract, Wallet, utils } from "ethers";
import { FlashbotsBundleProvider } from "@flashbots/ethers-provider-bundle";
import { WETH_ADDRESS } from "./addresses";
import { EthMarket } from "./EthMarket";
@@ -17,17 +17,31 @@ export type MarketsByToken = { [tokenAddress: string]: Array<EthMarket> }

// TODO: implement binary search (assuming linear/exponential global maximum profitability)
const TEST_VOLUMES = [
ETHER.div(100),
ETHER.div(10),
ETHER.div(6),
ETHER.div(4),
ETHER.div(2),
ETHER.div(1),
ETHER.mul(2),
ETHER.mul(5),
ETHER.mul(10),
ETHER.mul(15),
ETHER.mul(20),
ETHER.mul(25),
ETHER.mul(30),
ETHER.mul(35),
ETHER.mul(40),
ETHER.mul(45),
ETHER.mul(50),
ETHER.mul(75),
ETHER.mul(100),
ETHER.mul(150),
ETHER.mul(200),
ETHER.mul(250),
ETHER.mul(300),
ETHER.mul(350),
ETHER.mul(400),
ETHER.mul(450),
ETHER.mul(500),
ETHER.mul(750),
ETHER.mul(1000)
]

const flashloanFeePercentage = 9 // (0.09%) or 9/10000
export function getBestCrossedMarket(crossedMarkets: Array<EthMarket>[], tokenAddress: string): CrossedMarketDetails | undefined {
let bestCrossedMarket: CrossedMarketDetails | undefined = undefined;
for (const crossedMarket of crossedMarkets) {
@@ -114,7 +128,7 @@ export class Arbitrage {
}

const bestCrossedMarket = getBestCrossedMarket(crossedMarkets, tokenAddress);
if (bestCrossedMarket !== undefined && bestCrossedMarket.profit.gt(ETHER.div(1000))) {
if (bestCrossedMarket !== undefined && bestCrossedMarket.profit.gt(ETHER.div(100))) {
bestCrossedMarkets.push(bestCrossedMarket)
}
}
@@ -125,48 +139,74 @@ export class Arbitrage {
// TODO: take more than 1
async takeCrossedMarkets(bestCrossedMarkets: CrossedMarketDetails[], blockNumber: number, minerRewardPercentage: number): Promise<void> {
for (const bestCrossedMarket of bestCrossedMarkets) {

console.log("Send this much WETH", bestCrossedMarket.volume.toString(), "get this much profit", bestCrossedMarket.profit.toString())
const buyCalls = await bestCrossedMarket.buyFromMarket.sellTokensToNextMarket(WETH_ADDRESS, bestCrossedMarket.volume, bestCrossedMarket.sellToMarket);
const inter = bestCrossedMarket.buyFromMarket.getTokensOut(WETH_ADDRESS, bestCrossedMarket.tokenAddress, bestCrossedMarket.volume)
const sellCallData = await bestCrossedMarket.sellToMarket.sellTokens(bestCrossedMarket.tokenAddress, inter, this.bundleExecutorContract.address);

const targets: Array<string> = [...buyCalls.targets, bestCrossedMarket.sellToMarket.marketAddress]
const payloads: Array<string> = [...buyCalls.data, sellCallData]
console.log({targets, payloads})
const minerReward = bestCrossedMarket.profit.mul(minerRewardPercentage).div(100);
const transaction = await this.bundleExecutorContract.populateTransaction.uniswapWeth(bestCrossedMarket.volume, minerReward, targets, payloads, {
gasPrice: BigNumber.from(0),
gasLimit: BigNumber.from(1000000),
});

try {
const estimateGas = await this.bundleExecutorContract.provider.estimateGas(
{
...transaction,
from: this.executorWallet.address
})
if (estimateGas.gt(1400000)) {
console.log("EstimateGas succeeded, but suspiciously large: " + estimateGas.toString())
continue
const flashloanFee = bestCrossedMarket.volume.mul(flashloanFeePercentage).div(10000);
if (flashloanFee.lt(bestCrossedMarket.profit)){
const profitMinusFee = bestCrossedMarket.profit.sub(flashloanFee)

try {
const minerReward = profitMinusFee.mul(minerRewardPercentage).div(100);
const profitMinusFeeMinusMinerReward = profitMinusFee.sub(minerReward)
console.log("Send this much WETH", bestCrossedMarket.volume.toString(), "get this much profit after fees", profitMinusFeeMinusMinerReward.toString())

const ethersAbiCoder = new utils.AbiCoder()
const typeParams = ['uint256', 'address[]', 'bytes[]']
const inputParams = [minerReward.toString(), targets, payloads]
const params = ethersAbiCoder.encode(typeParams, inputParams)
console.log({targets, payloads})

if (profitMinusFeeMinusMinerReward.gt(0)){

const transaction = await this.bundleExecutorContract.populateTransaction.flashloan(WETH_ADDRESS, bestCrossedMarket.volume, params, {
gasPrice: BigNumber.from(0),
gasLimit: BigNumber.from(1400000),
});

try {
const estimateGas = await this.bundleExecutorContract.provider.estimateGas(
{
...transaction,
from: this.executorWallet.address
})
if (estimateGas.gt(1400000)) {
console.log("EstimateGas succeeded, but suspiciously large: " + estimateGas.toString())
continue
}
transaction.gasLimit = estimateGas.mul(2)
} catch (e) {
console.warn(`Estimate gas failure for ${JSON.stringify(bestCrossedMarket)}`)
continue
}
const bundlePromises = _.map([blockNumber + 1, blockNumber + 2], targetBlockNumber =>
this.flashbotsProvider.sendBundle(
[
{
signer: this.executorWallet,
transaction: transaction
}
],
targetBlockNumber
)
)
await Promise.all(bundlePromises)

} else {
console.log("Transaction would be unprofitable after the flashloan fee and miner reward.")
continue
}

} catch (e) {
console.warn("Error setting miner and flashloan payment:", e);
}
transaction.gasLimit = estimateGas.mul(2)
} catch (e) {
console.warn(`Estimate gas failure for ${JSON.stringify(bestCrossedMarket)}`)
continue
} else {
console.log("Flashloan fee is greater than profit.")
}
const bundlePromises = _.map([blockNumber + 1, blockNumber + 2], targetBlockNumber =>
this.flashbotsProvider.sendBundle(
[
{
signer: this.executorWallet,
transaction: transaction
}
],
targetBlockNumber
)
)
await Promise.all(bundlePromises)

return
}
throw new Error("No arbitrage submitted to relay")
2 changes: 1 addition & 1 deletion src/UniswappyV2EthPair.ts
Original file line number Diff line number Diff line change
@@ -96,7 +96,7 @@ export class UniswappyV2EthPair extends EthMarket {
await UniswappyV2EthPair.updateReserves(provider, allMarketPairs);

const marketsByToken = _.chain(allMarketPairs)
.filter(pair => (pair.getBalance(WETH_ADDRESS).gt(ETHER)))
.filter(pair => (pair.getBalance(WETH_ADDRESS).gt(ETHER.mul(10))))
.groupBy(pair => pair.tokens[0] === WETH_ADDRESS ? pair.tokens[1] : pair.tokens[0])
.value()

185 changes: 152 additions & 33 deletions src/abi.ts
Original file line number Diff line number Diff line change
@@ -20,39 +20,158 @@ export const UNISWAP_QUERY_ABI = [{
"type": "function"
}]

export const BUNDLE_EXECUTOR_ABI = [{
"inputs": [{
"internalType": "address payable",
"name": "_to",
"type": "address"
}, {"internalType": "uint256", "name": "_value", "type": "uint256"}, {
"internalType": "bytes",
"name": "_data",
"type": "bytes"
}],
"name": "call",
"outputs": [{"internalType": "bytes", "name": "", "type": "bytes"}],
"stateMutability": "payable",
"type": "function"
}, {
"inputs": [{"internalType": "address", "name": "_executor", "type": "address"}],
"stateMutability": "payable",
"type": "constructor"
}, {
"inputs": [{
"internalType": "uint256",
"name": "_wethAmountToFirstMarket",
"type": "uint256"
}, {"internalType": "uint256", "name": "_ethAmountToCoinbase", "type": "uint256"}, {
"internalType": "address[]",
"name": "_targets",
"type": "address[]"
}, {"internalType": "bytes[]", "name": "_payloads", "type": "bytes[]"}],
"name": "uniswapWeth",
"outputs": [],
"stateMutability": "payable",
"type": "function"
}, {"stateMutability": "payable", "type": "receive"}]
export const BUNDLE_EXECUTOR_ABI = [
{
"inputs": [
{
"internalType": "address",
"name": "_executor",
"type": "address"
},
{
"internalType": "contract ILendingPoolAddressesProvider",
"name": "_addressProvider",
"type": "address"
}
],
"stateMutability": "payable",
"type": "constructor"
},
{
"inputs": [],
"name": "ADDRESSES_PROVIDER",
"outputs": [
{
"internalType": "contract ILendingPoolAddressesProvider",
"name": "",
"type": "address"
}
],
"stateMutability": "view",
"type": "function"
},
{
"inputs": [],
"name": "LENDING_POOL",
"outputs": [
{
"internalType": "contract ILendingPool",
"name": "",
"type": "address"
}
],
"stateMutability": "view",
"type": "function"
},
{
"inputs": [
{
"internalType": "address payable",
"name": "_to",
"type": "address"
},
{
"internalType": "uint256",
"name": "_value",
"type": "uint256"
},
{
"internalType": "bytes",
"name": "_data",
"type": "bytes"
}
],
"name": "call",
"outputs": [
{
"internalType": "bytes",
"name": "",
"type": "bytes"
}
],
"stateMutability": "payable",
"type": "function"
},
{
"inputs": [
{
"internalType": "address[]",
"name": "assets",
"type": "address[]"
},
{
"internalType": "uint256[]",
"name": "amounts",
"type": "uint256[]"
},
{
"internalType": "uint256[]",
"name": "premiums",
"type": "uint256[]"
},
{
"internalType": "address",
"name": "initiator",
"type": "address"
},
{
"internalType": "bytes",
"name": "params",
"type": "bytes"
}
],
"name": "executeOperation",
"outputs": [
{
"internalType": "bool",
"name": "",
"type": "bool"
}
],
"stateMutability": "nonpayable",
"type": "function"
},
{
"inputs": [
{
"internalType": "address",
"name": "borrowedTokenAddress",
"type": "address"
},
{
"internalType": "uint256",
"name": "amountToBorrow",
"type": "uint256"
},
{
"internalType": "bytes",
"name": "_params",
"type": "bytes"
}
],
"name": "flashloan",
"outputs": [],
"stateMutability": "nonpayable",
"type": "function"
},
{
"inputs": [
{
"internalType": "address",
"name": "token",
"type": "address"
}
],
"name": "withdraw",
"outputs": [],
"stateMutability": "nonpayable",
"type": "function"
},
{
"stateMutability": "payable",
"type": "receive"
}
]


export const UNISWAP_PAIR_ABI = [{
2 changes: 1 addition & 1 deletion src/index.ts
Original file line number Diff line number Diff line change
@@ -29,7 +29,7 @@ if (FLASHBOTS_KEY_ID === "" || FLASHBOTS_SECRET === "") {

const HEALTHCHECK_URL = process.env.HEALTHCHECK_URL || ""

const provider = new providers.JsonRpcProvider(ETHEREUM_RPC_URL);
const provider = new providers.StaticJsonRpcProvider(ETHEREUM_RPC_URL);

function healthcheck() {
if (HEALTHCHECK_URL === "") {