636 lines
19 KiB
Solidity
636 lines
19 KiB
Solidity
// SPDX-License-Identifier: AGPL-3.0-or-later
|
|
pragma solidity ^0.8.13;
|
|
|
|
import {ISwapAdapter} from "src/interfaces/ISwapAdapter.sol";
|
|
import {IERC20Metadata} from
|
|
"openzeppelin-contracts/contracts/token/ERC20/extensions/IERC20Metadata.sol";
|
|
import {
|
|
IERC20,
|
|
SafeERC20
|
|
} from "openzeppelin-contracts/contracts/token/ERC20/utils/SafeERC20.sol";
|
|
|
|
/// @dev Integral submitted deadline of 3600 seconds (1 hour) to Paraswap, but
|
|
/// it is not strictly necessary to be this long
|
|
/// as the contract allows less durations, we use 1000 seconds (15 minutes) as a
|
|
/// deadline
|
|
uint256 constant SWAP_DEADLINE_SEC = 1000;
|
|
uint256 constant STANDARD_TOKEN_DECIMALS = 10 ** 18;
|
|
|
|
/// @title Integral Swap Adapter
|
|
contract IntegralSwapAdapter is ISwapAdapter {
|
|
using SafeERC20 for IERC20;
|
|
|
|
ITwapRelayer immutable relayer;
|
|
|
|
constructor(address relayer_) {
|
|
relayer = ITwapRelayer(relayer_);
|
|
}
|
|
|
|
/// @inheritdoc ISwapAdapter
|
|
/// @dev Integral always relies on a single pool linked to the factory to
|
|
/// map two pairs, and does not use routing
|
|
/// we can then use getPriceByTokenAddresses() instead of
|
|
/// getPriceByPairAddresses()
|
|
/// as they both return the same value and the first also handles the order
|
|
/// of tokens inside.
|
|
/// @dev Since the price of a token is determined externally by Integral
|
|
/// Oracles and not by reserves
|
|
/// it will always be the same (pre and post trade) and independent of the
|
|
/// amounts swapped,
|
|
/// but we still return an array of length=specifiedAmounts.length with same
|
|
/// values to make sure the return value is the expected from caller.
|
|
function price(
|
|
bytes32,
|
|
address _sellToken,
|
|
address _buyToken,
|
|
uint256[] memory _specifiedAmounts
|
|
) external view override returns (Fraction[] memory _prices) {
|
|
_prices = new Fraction[](_specifiedAmounts.length);
|
|
Fraction memory uniformPrice = getPriceAt(_sellToken, _buyToken);
|
|
|
|
for (uint256 i = 0; i < _specifiedAmounts.length; i++) {
|
|
_prices[i] = uniformPrice;
|
|
}
|
|
}
|
|
|
|
/// @inheritdoc ISwapAdapter
|
|
function swap(
|
|
bytes32,
|
|
address sellToken,
|
|
address buyToken,
|
|
OrderSide side,
|
|
uint256 specifiedAmount
|
|
) external override returns (Trade memory trade) {
|
|
if (specifiedAmount == 0) {
|
|
return trade;
|
|
}
|
|
|
|
uint256 gasBefore = gasleft();
|
|
if (side == OrderSide.Sell) {
|
|
// sell
|
|
trade.calculatedAmount = sell(sellToken, buyToken, specifiedAmount);
|
|
} else {
|
|
// buy
|
|
trade.calculatedAmount = buy(sellToken, buyToken, specifiedAmount);
|
|
}
|
|
trade.gasUsed = gasBefore - gasleft();
|
|
trade.price = getPriceAt(sellToken, buyToken);
|
|
}
|
|
|
|
/// @inheritdoc ISwapAdapter
|
|
function getLimits(bytes32, address sellToken, address buyToken)
|
|
external
|
|
view
|
|
override
|
|
returns (uint256[] memory limits)
|
|
{
|
|
(,,, uint256 limitMax0,, uint256 limitMax1) =
|
|
relayer.getPoolState(sellToken, buyToken);
|
|
|
|
limits = new uint256[](2);
|
|
limits[0] = limitMax0;
|
|
limits[1] = limitMax1;
|
|
/**
|
|
* @dev minLimits in integral are the args: 2(for sellToken, the one
|
|
* before limitMax0)
|
|
* and 4(for buyToken, the one before limitMax1) of the function
|
|
* relayer.getPoolState(sellToken, buyToken);
|
|
* an implementation of them can be found in the test of this adapter
|
|
*/
|
|
}
|
|
|
|
/// @inheritdoc ISwapAdapter
|
|
function getCapabilities(bytes32, address, address)
|
|
external
|
|
pure
|
|
override
|
|
returns (Capability[] memory capabilities)
|
|
{
|
|
capabilities = new Capability[](4);
|
|
capabilities[0] = Capability.SellOrder;
|
|
capabilities[1] = Capability.BuyOrder;
|
|
capabilities[2] = Capability.PriceFunction;
|
|
capabilities[3] = Capability.ConstantPrice;
|
|
}
|
|
|
|
/// @inheritdoc ISwapAdapter
|
|
function getTokens(bytes32 poolId)
|
|
external
|
|
view
|
|
override
|
|
returns (address[] memory tokens)
|
|
{
|
|
tokens = new address[](2);
|
|
ITwapPair pair = ITwapPair(address(bytes20(poolId)));
|
|
tokens[0] = pair.token0();
|
|
tokens[1] = pair.token1();
|
|
}
|
|
|
|
/// @inheritdoc ISwapAdapter
|
|
function getPoolIds(uint256 offset, uint256 limit)
|
|
external
|
|
view
|
|
override
|
|
returns (bytes32[] memory ids)
|
|
{
|
|
ITwapFactory factory = ITwapFactory(relayer.factory());
|
|
uint256 endIdx = offset + limit;
|
|
if (endIdx > factory.allPairsLength()) {
|
|
endIdx = factory.allPairsLength();
|
|
}
|
|
ids = new bytes32[](endIdx - offset);
|
|
for (uint256 i = 0; i < ids.length; i++) {
|
|
ids[i] = bytes20(factory.allPairs(offset + i));
|
|
}
|
|
}
|
|
|
|
/// @notice Executes a sell order on a given pool.
|
|
/// @param sellToken The address of the token being sold.
|
|
/// @param buyToken The address of the token being bought.
|
|
/// @param amount The amount to be traded.
|
|
/// @return uint256 The amount of tokens received.
|
|
function sell(address sellToken, address buyToken, uint256 amount)
|
|
internal
|
|
returns (uint256)
|
|
{
|
|
uint256 amountOut = relayer.quoteSell(sellToken, buyToken, amount);
|
|
if (amountOut == 0) {
|
|
revert Unavailable("AmountOut is zero!");
|
|
}
|
|
|
|
IERC20(sellToken).safeTransferFrom(msg.sender, address(this), amount);
|
|
IERC20(sellToken).safeIncreaseAllowance(address(relayer), amount);
|
|
|
|
relayer.sell(
|
|
ITwapRelayer.SellParams({
|
|
tokenIn: sellToken,
|
|
tokenOut: buyToken,
|
|
wrapUnwrap: false,
|
|
to: msg.sender,
|
|
submitDeadline: uint32(block.timestamp + SWAP_DEADLINE_SEC),
|
|
amountIn: amount,
|
|
amountOutMin: amountOut
|
|
})
|
|
);
|
|
|
|
return amountOut;
|
|
}
|
|
|
|
/// @notice Executes a buy order on a given pool.
|
|
/// @param sellToken The address of the token being sold.
|
|
/// @param buyToken The address of the token being bought.
|
|
/// @param amountBought The amount of buyToken tokens to buy.
|
|
/// @return uint256 The amount of tokens received.
|
|
function buy(address sellToken, address buyToken, uint256 amountBought)
|
|
internal
|
|
returns (uint256)
|
|
{
|
|
uint256 amountIn = relayer.quoteBuy(sellToken, buyToken, amountBought);
|
|
if (amountIn == 0) {
|
|
revert Unavailable("AmountIn is zero!");
|
|
}
|
|
|
|
IERC20(sellToken).safeTransferFrom(msg.sender, address(this), amountIn);
|
|
IERC20(sellToken).safeIncreaseAllowance(address(relayer), amountIn);
|
|
|
|
relayer.buy(
|
|
ITwapRelayer.BuyParams({
|
|
tokenIn: sellToken,
|
|
tokenOut: buyToken,
|
|
wrapUnwrap: false,
|
|
to: msg.sender,
|
|
submitDeadline: uint32(block.timestamp + SWAP_DEADLINE_SEC),
|
|
amountInMax: amountIn,
|
|
amountOut: amountBought
|
|
})
|
|
);
|
|
|
|
return amountIn;
|
|
}
|
|
|
|
/// @notice Get swap price including fee
|
|
/// @param sellToken token to sell
|
|
/// @param buyToken token to buy
|
|
function getPriceAt(address sellToken, address buyToken)
|
|
internal
|
|
view
|
|
returns (Fraction memory)
|
|
{
|
|
uint256 priceWithoutFee =
|
|
relayer.getPriceByTokenAddresses(sellToken, buyToken);
|
|
ITwapFactory factory = ITwapFactory(relayer.factory());
|
|
address pairAddress = factory.getPair(sellToken, buyToken);
|
|
|
|
// get swapFee formatted; swapFee is a constant
|
|
uint256 swapFeeFormatted =
|
|
(STANDARD_TOKEN_DECIMALS - relayer.swapFee(pairAddress));
|
|
|
|
// get token decimals
|
|
uint256 sellTokenDecimals = 10 ** IERC20Metadata(sellToken).decimals();
|
|
uint256 buyTokenDecimals = 10 ** IERC20Metadata(buyToken).decimals();
|
|
|
|
/**
|
|
* @dev
|
|
* Denominator works as a "standardizer" for the price rather than a
|
|
* reserve value
|
|
* as Integral takes prices from oracles and do not operate with
|
|
* reserves;
|
|
* it is therefore used to maintain integrity for the Fraction division,
|
|
* as numerator and denominator could have different token decimals(es.
|
|
* ETH(18)-USDC(6)).
|
|
* Both numerator and denominator are also multiplied by
|
|
* STANDARD_TOKEN_DECIMALS
|
|
* to ensure that precision losses are minimized or null.
|
|
*/
|
|
return Fraction(
|
|
priceWithoutFee * STANDARD_TOKEN_DECIMALS,
|
|
STANDARD_TOKEN_DECIMALS * sellTokenDecimals * swapFeeFormatted
|
|
/ buyTokenDecimals
|
|
);
|
|
}
|
|
}
|
|
|
|
interface ITwapRelayer {
|
|
event OwnerSet(address owner);
|
|
event RebalancerSet(address rebalancer);
|
|
event DelaySet(address delay);
|
|
event PairEnabledSet(address pair, bool enabled);
|
|
event SwapFeeSet(address pair, uint256 fee);
|
|
event TwapIntervalSet(address pair, uint32 interval);
|
|
event EthTransferGasCostSet(uint256 gasCost);
|
|
event ExecutionGasLimitSet(uint256 limit);
|
|
event TokenLimitMinSet(address token, uint256 limit);
|
|
event TokenLimitMaxMultiplierSet(address token, uint256 limit);
|
|
event ToleranceSet(address pair, uint16 tolerance);
|
|
event Approve(address token, address to, uint256 amount);
|
|
event Withdraw(address token, address to, uint256 amount);
|
|
event Sell(
|
|
address indexed sender,
|
|
address tokenIn,
|
|
address tokenOut,
|
|
uint256 amountIn,
|
|
uint256 amountOut,
|
|
uint256 amountOutMin,
|
|
bool wrapUnwrap,
|
|
uint256 fee,
|
|
address indexed to,
|
|
address orderContract,
|
|
uint256 indexed orderId
|
|
);
|
|
event Buy(
|
|
address indexed sender,
|
|
address tokenIn,
|
|
address tokenOut,
|
|
uint256 amountIn,
|
|
uint256 amountInMax,
|
|
uint256 amountOut,
|
|
bool wrapUnwrap,
|
|
uint256 fee,
|
|
address indexed to,
|
|
address orderContract,
|
|
uint256 indexed orderId
|
|
);
|
|
event RebalanceSellWithDelay(
|
|
address indexed sender,
|
|
address tokenIn,
|
|
address tokenOut,
|
|
uint256 amountIn,
|
|
uint256 indexed delayOrderId
|
|
);
|
|
event RebalanceSellWithOneInch(
|
|
address indexed oneInchRouter, uint256 gas, bytes data
|
|
);
|
|
event OneInchRouterWhitelisted(
|
|
address indexed oneInchRouter, bool whitelisted
|
|
);
|
|
|
|
function factory() external pure returns (address);
|
|
|
|
function delay() external pure returns (address);
|
|
|
|
function weth() external pure returns (address);
|
|
|
|
function owner() external view returns (address);
|
|
|
|
function rebalancer() external view returns (address);
|
|
|
|
function isOneInchRouterWhitelisted(address oneInchRouter)
|
|
external
|
|
view
|
|
returns (bool);
|
|
|
|
function setOwner(address _owner) external;
|
|
|
|
function swapFee(address pair) external view returns (uint256);
|
|
|
|
function setSwapFee(address pair, uint256 fee) external;
|
|
|
|
function twapInterval(address pair) external pure returns (uint32);
|
|
|
|
function isPairEnabled(address pair) external view returns (bool);
|
|
|
|
function setPairEnabled(address pair, bool enabled) external;
|
|
|
|
function ethTransferGasCost() external pure returns (uint256);
|
|
|
|
function executionGasLimit() external pure returns (uint256);
|
|
|
|
function tokenLimitMin(address token) external pure returns (uint256);
|
|
|
|
function tokenLimitMaxMultiplier(address token)
|
|
external
|
|
pure
|
|
returns (uint256);
|
|
|
|
function tolerance(address pair) external pure returns (uint16);
|
|
|
|
function setRebalancer(address _rebalancer) external;
|
|
|
|
function whitelistOneInchRouter(address oneInchRouter, bool whitelisted)
|
|
external;
|
|
|
|
function getTolerance(address pair) external pure returns (uint16);
|
|
|
|
function getTokenLimitMin(address token) external pure returns (uint256);
|
|
|
|
function getTokenLimitMaxMultiplier(address token)
|
|
external
|
|
pure
|
|
returns (uint256);
|
|
|
|
function getTwapInterval(address pair) external pure returns (uint32);
|
|
|
|
struct SellParams {
|
|
address tokenIn;
|
|
address tokenOut;
|
|
uint256 amountIn;
|
|
uint256 amountOutMin;
|
|
bool wrapUnwrap;
|
|
address to;
|
|
uint32 submitDeadline;
|
|
}
|
|
|
|
function sell(SellParams memory sellParams)
|
|
external
|
|
payable
|
|
returns (uint256 orderId);
|
|
|
|
struct BuyParams {
|
|
address tokenIn;
|
|
address tokenOut;
|
|
uint256 amountInMax;
|
|
uint256 amountOut;
|
|
bool wrapUnwrap;
|
|
address to;
|
|
uint32 submitDeadline;
|
|
}
|
|
|
|
function buy(BuyParams memory buyParams)
|
|
external
|
|
payable
|
|
returns (uint256 orderId);
|
|
|
|
function getPriceByPairAddress(address pair, bool inverted)
|
|
external
|
|
view
|
|
returns (uint8 xDecimals, uint8 yDecimals, uint256 price);
|
|
|
|
function getPriceByTokenAddresses(address tokenIn, address tokenOut)
|
|
external
|
|
view
|
|
returns (uint256 price);
|
|
|
|
function getPoolState(address token0, address token1)
|
|
external
|
|
view
|
|
returns (
|
|
uint256 price,
|
|
uint256 fee,
|
|
uint256 limitMin0,
|
|
uint256 limitMax0,
|
|
uint256 limitMin1,
|
|
uint256 limitMax1
|
|
);
|
|
|
|
function quoteSell(address tokenIn, address tokenOut, uint256 amountIn)
|
|
external
|
|
view
|
|
returns (uint256 amountOut);
|
|
|
|
function quoteBuy(address tokenIn, address tokenOut, uint256 amountOut)
|
|
external
|
|
view
|
|
returns (uint256 amountIn);
|
|
|
|
function approve(address token, uint256 amount, address to) external;
|
|
|
|
function withdraw(address token, uint256 amount, address to) external;
|
|
|
|
function rebalanceSellWithDelay(
|
|
address tokenIn,
|
|
address tokenOut,
|
|
uint256 amountIn
|
|
) external;
|
|
|
|
function rebalanceSellWithOneInch(
|
|
address tokenIn,
|
|
uint256 amountIn,
|
|
address oneInchRouter,
|
|
uint256 _gas,
|
|
bytes calldata data
|
|
) external;
|
|
}
|
|
|
|
interface ITwapFactory {
|
|
event PairCreated(
|
|
address indexed token0, address indexed token1, address pair, uint256
|
|
);
|
|
event OwnerSet(address owner);
|
|
|
|
function owner() external view returns (address);
|
|
|
|
function getPair(address tokenA, address tokenB)
|
|
external
|
|
view
|
|
returns (address pair);
|
|
|
|
function allPairs(uint256) external view returns (address pair);
|
|
|
|
function allPairsLength() external view returns (uint256);
|
|
|
|
function createPair(
|
|
address tokenA,
|
|
address tokenB,
|
|
address oracle,
|
|
address trader
|
|
) external returns (address pair);
|
|
|
|
function setOwner(address) external;
|
|
|
|
function setMintFee(address tokenA, address tokenB, uint256 fee) external;
|
|
|
|
function setBurnFee(address tokenA, address tokenB, uint256 fee) external;
|
|
|
|
function setSwapFee(address tokenA, address tokenB, uint256 fee) external;
|
|
|
|
function setOracle(address tokenA, address tokenB, address oracle)
|
|
external;
|
|
|
|
function setTrader(address tokenA, address tokenB, address trader)
|
|
external;
|
|
|
|
function collect(address tokenA, address tokenB, address to) external;
|
|
|
|
function withdraw(
|
|
address tokenA,
|
|
address tokenB,
|
|
uint256 amount,
|
|
address to
|
|
) external;
|
|
}
|
|
|
|
interface ITwapERC20 is IERC20 {
|
|
function PERMIT_TYPEHASH() external pure returns (bytes32);
|
|
|
|
function nonces(address owner) external view returns (uint256);
|
|
|
|
function permit(
|
|
address owner,
|
|
address spender,
|
|
uint256 value,
|
|
uint256 deadline,
|
|
uint8 v,
|
|
bytes32 r,
|
|
bytes32 s
|
|
) external;
|
|
|
|
function increaseAllowance(address spender, uint256 addedValue)
|
|
external
|
|
returns (bool);
|
|
|
|
function decreaseAllowance(address spender, uint256 subtractedValue)
|
|
external
|
|
returns (bool);
|
|
}
|
|
|
|
interface IReserves {
|
|
function getReserves()
|
|
external
|
|
view
|
|
returns (uint112 reserve0, uint112 reserve1);
|
|
|
|
function getFees() external view returns (uint256 fee0, uint256 fee1);
|
|
}
|
|
|
|
interface ITwapPair is ITwapERC20, IReserves {
|
|
event Mint(
|
|
address indexed sender,
|
|
uint256 amount0In,
|
|
uint256 amount1In,
|
|
uint256 liquidityOut,
|
|
address indexed to
|
|
);
|
|
event Burn(
|
|
address indexed sender,
|
|
uint256 amount0Out,
|
|
uint256 amount1Out,
|
|
uint256 liquidityIn,
|
|
address indexed to
|
|
);
|
|
event Swap(
|
|
address indexed sender,
|
|
uint256 amount0In,
|
|
uint256 amount1In,
|
|
uint256 amount0Out,
|
|
uint256 amount1Out,
|
|
address indexed to
|
|
);
|
|
event SetMintFee(uint256 fee);
|
|
event SetBurnFee(uint256 fee);
|
|
event SetSwapFee(uint256 fee);
|
|
event SetOracle(address account);
|
|
event SetTrader(address trader);
|
|
|
|
function MINIMUM_LIQUIDITY() external pure returns (uint256);
|
|
|
|
function factory() external view returns (address);
|
|
|
|
function token0() external view returns (address);
|
|
|
|
function token1() external view returns (address);
|
|
|
|
function oracle() external view returns (address);
|
|
|
|
function trader() external view returns (address);
|
|
|
|
function mintFee() external view returns (uint256);
|
|
|
|
function setMintFee(uint256 fee) external;
|
|
|
|
function mint(address to) external returns (uint256 liquidity);
|
|
|
|
function burnFee() external view returns (uint256);
|
|
|
|
function setBurnFee(uint256 fee) external;
|
|
|
|
function burn(address to)
|
|
external
|
|
returns (uint256 amount0, uint256 amount1);
|
|
|
|
function swapFee() external view returns (uint256);
|
|
|
|
function setSwapFee(uint256 fee) external;
|
|
|
|
function setOracle(address account) external;
|
|
|
|
function setTrader(address account) external;
|
|
|
|
function collect(address to) external;
|
|
|
|
function swap(
|
|
uint256 amount0Out,
|
|
uint256 amount1Out,
|
|
address to,
|
|
bytes calldata data
|
|
) external;
|
|
|
|
function sync() external;
|
|
|
|
function initialize(
|
|
address _token0,
|
|
address _token1,
|
|
address _oracle,
|
|
address _trader
|
|
) external;
|
|
|
|
function getSwapAmount0In(uint256 amount1Out, bytes calldata data)
|
|
external
|
|
view
|
|
returns (uint256 swapAmount0In);
|
|
|
|
function getSwapAmount1In(uint256 amount0Out, bytes calldata data)
|
|
external
|
|
view
|
|
returns (uint256 swapAmount1In);
|
|
|
|
function getSwapAmount0Out(uint256 amount1In, bytes calldata data)
|
|
external
|
|
view
|
|
returns (uint256 swapAmount0Out);
|
|
|
|
function getSwapAmount1Out(uint256 amount0In, bytes calldata data)
|
|
external
|
|
view
|
|
returns (uint256 swapAmount1Out);
|
|
|
|
function getDepositAmount0In(uint256 amount0, bytes calldata data)
|
|
external
|
|
view
|
|
returns (uint256 depositAmount0In);
|
|
|
|
function getDepositAmount1In(uint256 amount1, bytes calldata data)
|
|
external
|
|
view
|
|
returns (uint256 depositAmount1In);
|
|
}
|