dsa-connectors/contracts/arbitrum/connectors/uniswap/v3_swap/main.sol

//SPDX-License-Identifier: MIT
pragma solidity ^0.7.6;
pragma abicoder v2;

/**
 * @title Uniswap v3 swap.
 * @dev Decentralized Exchange.
 */

import {TokenInterface} from "../../../common/interfaces.sol";
import {Helpers} from "./helpers.sol";
import {Events} from "./events.sol";
import "./interface.sol";

abstract contract UniswapResolver is Helpers, Events {
	/**
	 * @dev Buy Function
	 * @notice Swap token(sellAddr) with token(buyAddr), buy token with minimum sell token
	 * @param buyData Data input for the buy action
	 */
	function buy(
		BuyInfo memory buyData
	)
		external
		payable
		returns (string memory _eventName, bytes memory _eventParam)
	{
		uint256 _buyAmt = getUint(buyData.getId, buyData.buyAmt);
		(TokenInterface _buyAddr, TokenInterface _sellAddr) = changeEthAddress(
			buyData.buyAddr,
			buyData.sellAddr
		);
		
		{
			uint _slippageAmt = convert18ToDec(_sellAddr.decimals(),
				wmul(buyData.unitAmt, convertTo18(_buyAddr.decimals(), _buyAmt))
			);
			require(_slippageAmt >= buyData.expectedAmt, "Too much slippage");
		}		

		bool isEth = address(_sellAddr) == wethAddr;
		convertEthToWeth(isEth, _sellAddr, uint256(-1));
		approve(_sellAddr, address(swapRouter), uint256(-1));
		ISwapRouter.ExactOutputSingleParams memory params;

		{
			params = ISwapRouter.ExactOutputSingleParams({
				tokenIn: buyData.sellAddr,
				tokenOut: buyData.buyAddr,
				fee: buyData.fee,
				recipient: address(this),
				deadline: block.timestamp + 1,
				amountOut: _buyAmt,
				amountInMaximum: buyData.expectedAmt,
				sqrtPriceLimitX96: 0
			});
		}

		uint256 _sellAmt = swapRouter.exactOutputSingle(params);

		isEth = address(_buyAddr) == wethAddr;
		convertWethToEth(isEth, _buyAddr, _buyAmt);

		setUint(buyData.setId, _sellAmt);

		_eventName = "LogBuy(address,address,uint256,uint256,uint256,uint256)";
		_eventParam = abi.encode(
			buyData.buyAddr,
			buyData.sellAddr,
			_buyAmt,
			_sellAmt,
			buyData.getId,
			buyData.setId
		);
	}

	/**
	 * @dev Sell Function
	 * @notice Swap token(sellAddr) with token(buyAddr), sell token to get maximum amount of buy token
	 * @param buyAddr token to be bought
	 * @param sellAddr token to be sold
	 * @param fee pool fees for buyAddr-sellAddr token pair
	 * @param sellAmt amount of token to be sold
	 * @param getId Id to get sellAmount
	 * @param setId Id to store buyAmount
	 */
	function sell(
		address buyAddr,
		address sellAddr,
		uint24 fee,
		uint256 sellAmt,
		uint256 getId,
		uint256 setId
	)
		external
		payable
		returns (string memory _eventName, bytes memory _eventParam)
	{
		uint256 _sellAmt = getUint(getId, sellAmt);
		(TokenInterface _buyAddr, TokenInterface _sellAddr) = changeEthAddress(
			buyAddr,
			sellAddr
		);

		if (_sellAmt == uint256(-1)) {
			_sellAmt = sellAddr == ethAddr
				? address(this).balance
				: _sellAddr.balanceOf(address(this));
		}

		// uint _slippageAmt = convert18ToDec(_buyAddr.decimals(),
		//     wmul(unitAmt, convertTo18(_sellAddr.decimals(), _sellAmt))
		// );
		// require(_slippageAmt <= _expectedAmt, "Too much slippage");

		bool isEth = address(_sellAddr) == wethAddr;
		convertEthToWeth(isEth, _sellAddr, _sellAmt);
		approve(_sellAddr, address(swapRouter), _sellAmt);
		ISwapRouter.ExactInputSingleParams memory params;

		{
			params = ISwapRouter.ExactInputSingleParams({
				tokenIn: sellAddr,
				tokenOut: buyAddr,
				fee: fee,
				recipient: address(this),
				deadline: block.timestamp + 1,
				amountIn: _sellAmt,
				amountOutMinimum: 0,
				sqrtPriceLimitX96: 0
			});
		}

		uint256 _buyAmt = swapRouter.exactInputSingle(params);

		isEth = address(_buyAddr) == wethAddr;
		convertWethToEth(isEth, _buyAddr, _buyAmt);

		setUint(setId, _buyAmt);

		_eventName = "LogSell(address,address,uint256,uint256,uint256,uint256)";
		_eventParam = abi.encode(
			buyAddr,
			sellAddr,
			_buyAmt,
			_sellAmt,
			getId,
			setId
		);
	}
}

contract ConnectV2UniswapV3Arbitrum is UniswapResolver {
	string public constant name = "UniswapV3-v1";
}