feat: ExecutorTransferMethods in UniswapV3Executor

This commit is contained in:
TAMARA LIPOWSKI
2025-03-13 11:59:13 -04:00
committed by Diana Carvalho
parent 147ba68392
commit 389009901e
4 changed files with 47 additions and 21 deletions

View File

@@ -5,13 +5,14 @@ import "@interfaces/IExecutor.sol";
import "@openzeppelin/contracts/token/ERC20/utils/SafeERC20.sol"; import "@openzeppelin/contracts/token/ERC20/utils/SafeERC20.sol";
import "@uniswap/v3-core/contracts/interfaces/IUniswapV3Pool.sol"; import "@uniswap/v3-core/contracts/interfaces/IUniswapV3Pool.sol";
import "@interfaces/ICallback.sol"; import "@interfaces/ICallback.sol";
import {ExecutorTransferMethods} from "./ExecutorTransferMethods.sol";
error UniswapV3Executor__InvalidDataLength(); error UniswapV3Executor__InvalidDataLength();
error UniswapV3Executor__InvalidFactory(); error UniswapV3Executor__InvalidFactory();
error UniswapV3Executor__InvalidTarget(); error UniswapV3Executor__InvalidTarget();
error UniswapV3Executor__InvalidInitCode(); error UniswapV3Executor__InvalidInitCode();
contract UniswapV3Executor is IExecutor, ICallback { contract UniswapV3Executor is IExecutor, ICallback, ExecutorTransferMethods {
using SafeERC20 for IERC20; using SafeERC20 for IERC20;
uint160 private constant MIN_SQRT_RATIO = 4295128739; uint160 private constant MIN_SQRT_RATIO = 4295128739;
@@ -22,7 +23,9 @@ contract UniswapV3Executor is IExecutor, ICallback {
bytes32 public immutable initCode; bytes32 public immutable initCode;
address private immutable self; address private immutable self;
constructor(address _factory, bytes32 _initCode) { constructor(address _factory, bytes32 _initCode, address _permit2)
ExecutorTransferMethods(_permit2)
{
if (_factory == address(0)) { if (_factory == address(0)) {
revert UniswapV3Executor__InvalidFactory(); revert UniswapV3Executor__InvalidFactory();
} }
@@ -46,7 +49,8 @@ contract UniswapV3Executor is IExecutor, ICallback {
uint24 fee, uint24 fee,
address receiver, address receiver,
address target, address target,
bool zeroForOne bool zeroForOne,
TransferMethod method
) = _decodeData(data); ) = _decodeData(data);
_verifyPairAddress(tokenIn, tokenOut, fee, target); _verifyPairAddress(tokenIn, tokenOut, fee, target);
@@ -55,7 +59,8 @@ contract UniswapV3Executor is IExecutor, ICallback {
int256 amount1; int256 amount1;
IUniswapV3Pool pool = IUniswapV3Pool(target); IUniswapV3Pool pool = IUniswapV3Pool(target);
bytes memory callbackData = _makeV3CallbackData(tokenIn, tokenOut, fee); bytes memory callbackData =
_makeV3CallbackData(tokenIn, tokenOut, fee, method);
{ {
(amount0, amount1) = pool.swap( (amount0, amount1) = pool.swap(
@@ -92,12 +97,20 @@ contract UniswapV3Executor is IExecutor, ICallback {
address tokenIn = address(bytes20(msgData[132:152])); address tokenIn = address(bytes20(msgData[132:152]));
require(
uint8(msgData[171]) <= uint8(TransferMethod.NONE),
"InvalidTransferMethod"
);
TransferMethod method = TransferMethod(uint8(msgData[171]));
verifyCallback(msgData[132:]); verifyCallback(msgData[132:]);
uint256 amountOwed = uint256 amountOwed =
amount0Delta > 0 ? uint256(amount0Delta) : uint256(amount1Delta); amount0Delta > 0 ? uint256(amount0Delta) : uint256(amount1Delta);
IERC20(tokenIn).safeTransfer(msg.sender, amountOwed); // TODO This must never be a safeTransfer. Figure out how to ensure this.
_transfer(IERC20(tokenIn), msg.sender, amountOwed, method);
return abi.encode(amountOwed, tokenIn); return abi.encode(amountOwed, tokenIn);
} }
@@ -132,7 +145,8 @@ contract UniswapV3Executor is IExecutor, ICallback {
uint24 fee, uint24 fee,
address receiver, address receiver,
address target, address target,
bool zeroForOne bool zeroForOne,
TransferMethod method
) )
{ {
if (data.length != 84) { if (data.length != 84) {
@@ -144,14 +158,16 @@ contract UniswapV3Executor is IExecutor, ICallback {
receiver = address(bytes20(data[43:63])); receiver = address(bytes20(data[43:63]));
target = address(bytes20(data[63:83])); target = address(bytes20(data[63:83]));
zeroForOne = uint8(data[83]) > 0; zeroForOne = uint8(data[83]) > 0;
method = TransferMethod.TRANSFER;
} }
function _makeV3CallbackData(address tokenIn, address tokenOut, uint24 fee) function _makeV3CallbackData(
internal address tokenIn,
pure address tokenOut,
returns (bytes memory) uint24 fee,
{ TransferMethod method
return abi.encodePacked(tokenIn, tokenOut, fee); ) internal pure returns (bytes memory) {
return abi.encodePacked(tokenIn, tokenOut, fee, uint8(method), self);
} }
function _verifyPairAddress( function _verifyPairAddress(

View File

@@ -98,7 +98,7 @@ contract TychoRouterTestSetup is Constants {
IPoolManager poolManager = IPoolManager(poolManagerAddress); IPoolManager poolManager = IPoolManager(poolManagerAddress);
usv2Executor = new UniswapV2Executor(factoryV2, initCodeV2, PERMIT2_ADDRESS); usv2Executor = new UniswapV2Executor(factoryV2, initCodeV2, PERMIT2_ADDRESS);
usv3Executor = new UniswapV3Executor(factoryV3, initCodeV3); usv3Executor = new UniswapV3Executor(factoryV3, initCodeV3, PERMIT2_ADDRESS);
usv4Executor = new UniswapV4Executor(poolManager); usv4Executor = new UniswapV4Executor(poolManager);
pancakev3Executor = pancakev3Executor =
new UniswapV3Executor(factoryPancakeV3, initCodePancakeV3); new UniswapV3Executor(factoryPancakeV3, initCodePancakeV3);

View File

@@ -87,7 +87,10 @@ contract UniswapV2ExecutorTest is Test, Constants {
assertEq(target, address(2)); assertEq(target, address(2));
assertEq(receiver, address(3)); assertEq(receiver, address(3));
assertEq(zeroForOne, false); assertEq(zeroForOne, false);
assertEq(0, uint8(method)); assertEq(
uint8(ExecutorTransferMethods.TransferMethod.TRANSFER),
uint8(method)
);
} }
function testDecodeParamsInvalidDataLength() public { function testDecodeParamsInvalidDataLength() public {

View File

@@ -6,8 +6,8 @@ import {Test} from "../../lib/forge-std/src/Test.sol";
import {Constants} from "../Constants.sol"; import {Constants} from "../Constants.sol";
contract UniswapV3ExecutorExposed is UniswapV3Executor { contract UniswapV3ExecutorExposed is UniswapV3Executor {
constructor(address _factory, bytes32 _initCode) constructor(address _factory, bytes32 _initCode, address _permit2)
UniswapV3Executor(_factory, _initCode) UniswapV3Executor(_factory, _initCode, _permit2)
{} {}
function decodeData(bytes calldata data) function decodeData(bytes calldata data)
@@ -19,7 +19,8 @@ contract UniswapV3ExecutorExposed is UniswapV3Executor {
uint24 fee, uint24 fee,
address receiver, address receiver,
address target, address target,
bool zeroForOne bool zeroForOne,
TransferMethod method
) )
{ {
return _decodeData(data); return _decodeData(data);
@@ -48,10 +49,10 @@ contract UniswapV3ExecutorTest is Test, Constants {
vm.createSelectFork(vm.rpcUrl("mainnet"), forkBlock); vm.createSelectFork(vm.rpcUrl("mainnet"), forkBlock);
uniswapV3Exposed = new UniswapV3ExecutorExposed( uniswapV3Exposed = new UniswapV3ExecutorExposed(
USV3_FACTORY_ETHEREUM, USV3_POOL_CODE_INIT_HASH USV3_FACTORY_ETHEREUM, USV3_POOL_CODE_INIT_HASH, PERMIT2_ADDRESS
); );
pancakeV3Exposed = new UniswapV3ExecutorExposed( pancakeV3Exposed = new UniswapV3ExecutorExposed(
PANCAKESWAPV3_DEPLOYER_ETHEREUM, PANCAKEV3_POOL_CODE_INIT_HASH PANCAKESWAPV3_DEPLOYER_ETHEREUM, PANCAKEV3_POOL_CODE_INIT_HASH, PERMIT2_ADDRESS
); );
} }
@@ -67,7 +68,8 @@ contract UniswapV3ExecutorTest is Test, Constants {
uint24 fee, uint24 fee,
address receiver, address receiver,
address target, address target,
bool zeroForOne bool zeroForOne,
ExecutorTransferMethods.TransferMethod method
) = uniswapV3Exposed.decodeData(data); ) = uniswapV3Exposed.decodeData(data);
assertEq(tokenIn, WETH_ADDR); assertEq(tokenIn, WETH_ADDR);
@@ -76,6 +78,10 @@ contract UniswapV3ExecutorTest is Test, Constants {
assertEq(receiver, address(2)); assertEq(receiver, address(2));
assertEq(target, address(3)); assertEq(target, address(3));
assertEq(zeroForOne, false); assertEq(zeroForOne, false);
assertEq(
uint8(method),
uint8(ExecutorTransferMethods.TransferMethod.TRANSFER)
);
} }
function testDecodeParamsInvalidDataLength() public { function testDecodeParamsInvalidDataLength() public {
@@ -116,7 +122,8 @@ contract UniswapV3ExecutorTest is Test, Constants {
int256(0), // amount1Delta int256(0), // amount1Delta
dataOffset, dataOffset,
dataLength, dataLength,
protocolData protocolData,
uint8(ExecutorTransferMethods.TransferMethod.TRANSFER)
); );
uniswapV3Exposed.handleCallback(callbackData); uniswapV3Exposed.handleCallback(callbackData);
vm.stopPrank(); vm.stopPrank();