Blockchain / Global / Address
Contract
0x09652B1707EB7623874C91a72dE6D1C8d1c9259c
- Balance
- 0 SOMI
- Transactions sent
- 1
- Type
- Contract · 23,871 bytes of code
OrderRouter Verified
- Compiler
- solc 0.8.20+commit.a1b79de6
- Language
- Solidity
- Optimization
- Yes, 10 runs
- EVM version
- paris
- License
- —
- Verified
- 2026-10-12
contracts/order/OrderRouter.sol
and 40 more files
Solidity
// SPDX-License-Identifier: BUSL-1.1
pragma solidity ^0.8.20;
import "@openzeppelin/contracts/utils/ReentrancyGuard.sol";
import "@openzeppelin/contracts/token/ERC20/IERC20.sol";
import "@openzeppelin/contracts/token/ERC20/utils/SafeERC20.sol";
import "../base/CustomAddress.sol";
import "./IOrderRouter.sol";
import "../tokens/IWETH.sol";
import "../oracle/PriceLib.sol";
import "../oracle/IOracle.sol";
import "../position/PositionLib.sol";
import "../position/IIncreasePositionHandler.sol";
import "../position/IDecreasePositionHandler.sol";
import "./OrderBase.sol";
import "./OrderVault.sol";
import "./OrderDao.sol";
import "../event/OrderLogger.sol";
import "./OrderUtils.sol";
import "../position/PositionDao.sol";
contract OrderRouter is IOrderRouter, ReentrancyGuard {
using SafeERC20 for IERC20;
using CustomAddress for address payable;
OrderBase public immutable orderBase;
OrderVault public immutable orderVault;
OrderLogger public immutable orderLogger;
uint256 public MIN_UPDATE_INTERVAL = 30;
address public admin;
DataBase public dataBase;
address public oracle;
address public gov;
address public weth;
address public increasePositionHandler;
address public decreasePositionHandler;
address public multicall;
uint256 public minExecutionFee;
uint256 public minPurchaseTokenAmountUsd;
bool public isInitialized = false;
mapping (address => bool) public isManager;
event Initialize(
address oracle,
address increasePositionHandler,
address decreasePositionHandler,
address weth,
uint256 minExecutionFee,
uint256 minPurchaseTokenAmountUsd
);
event UpdateMinExecutionFee(uint256 minExecutionFee);
event UpdateMinPurchaseTokenAmountUsd(uint256 minPurchaseTokenAmountUsd);
event UpdateIncreasePositionHandler(address positionHandler);
event UpdateDecreasePositionHandler(address positionHandler);
event UpdateGov(address gov);
error InvalidSender();
error UnauthorizedGov();
error UnauthorizedManager();
error AlreadyInitialized();
error InsufficientExecutionFee();
error OnlyWethWrapped();
error IncorrectTransferredValue();
error IncorrectExecutionFee();
error UnsupportedPurchaseToken();
error PathLengthExceeded();
error InsufficientCollateral();
error UnauthorizedMuticall();
error ZeroAddress();
error TooShortUpdateInterval();
error NonExistentOrder();
error InvalidPriceForExecution();
error FailedTransferETHToOrderVault();
error FailedTransferETHToReceiver();
modifier onlyGov() {
if (msg.sender != gov) { revert UnauthorizedGov(); }
_;
}
modifier onlyManager() {
if (!isManager[msg.sender]) { revert UnauthorizedManager(); }
_;
}
constructor(OrderBase _orderBase, OrderVault _orderVault, OrderLogger _orderLogger, DataBase _dataBase) {
orderBase = _orderBase;
orderVault = _orderVault;
orderLogger = _orderLogger;
dataBase = _dataBase;
gov = msg.sender;
}
function initialize(
address _oracle,
address _increasePositionHandler,
address _decreasePositionHandler,
address _weth,
uint256 _minExecutionFee,
uint256 _minPurchaseTokenAmountUsd
) external onlyGov {
if (isInitialized) {
revert AlreadyInitialized();
}
isInitialized = true;
oracle = _oracle;
increasePositionHandler = _increasePositionHandler;
decreasePositionHandler = _decreasePositionHandler;
weth = _weth;
minExecutionFee = _minExecutionFee;
minPurchaseTokenAmountUsd = _minPurchaseTokenAmountUsd;
emit Initialize(_oracle, _increasePositionHandler, _decreasePositionHandler, _weth, _minExecutionFee, _minPurchaseTokenAmountUsd);
}
receive() external payable {
if (msg.sender != weth) { revert InvalidSender(); }
}
function setMinExecutionFee(uint256 _minExecutionFee) external onlyGov {
minExecutionFee = _minExecutionFee;
emit UpdateMinExecutionFee(_minExecutionFee);
}
function setMinPurchaseTokenAmountUsd(uint256 _minPurchaseTokenAmountUsd) external onlyGov {
minPurchaseTokenAmountUsd = _minPurchaseTokenAmountUsd;
emit UpdateMinPurchaseTokenAmountUsd(_minPurchaseTokenAmountUsd);
}
function setIncreasePositionHandler(address _positionHandler) external onlyGov {
increasePositionHandler = _positionHandler;
emit UpdateIncreasePositionHandler(_positionHandler);
}
function setDecreasePositionHandler(address _positionHandler) external onlyGov {
decreasePositionHandler = _positionHandler;
emit UpdateDecreasePositionHandler(_positionHandler);
}
function setGov(address _gov) external onlyGov {
if (_gov != address(0)) {
gov = _gov;
emit UpdateGov(_gov);
}
}
function setManager(address _manager, bool _isManager) external onlyGov {
isManager[_manager] = _isManager;
}
function setMulticall(address _multicall) external onlyGov {
multicall = _multicall;
}
function cancelMultiple(
address _poolToken,
uint256[] memory _swapOrderIndexes,
uint256[] memory _increaseOrderIndexes,
uint256[] memory _decreaseOrderIndexes
) external {
for (uint256 i = 0; i < _increaseOrderIndexes.length; i++) {
cancelIncreaseOrder(_poolToken, _increaseOrderIndexes[i]);
}
for (uint256 i = 0; i < _decreaseOrderIndexes.length; i++) {
cancelDecreaseOrder(_poolToken, _decreaseOrderIndexes[i]);
}
}
function increaseOrdersIndex(address _account, address _poolToken) external view returns (uint256) {
return OrderDao.getIncreaseIndex(orderBase, _account, _poolToken);
}
function decreaseOrdersIndex(address _account, address _poolToken) external view returns (uint256) {
return OrderDao.getDecreaseIndex(orderBase, _account, _poolToken);
}
function createIncreaseOrder(
address _poolToken,
address[] memory _path,
uint256 _amountIn,
address _indexToken,
uint256 _minOut,
uint256 _sizeDelta,
address _collateralToken,
bool _isLong,
uint256 _triggerPrice,
bool _triggerAboveThreshold,
uint256 _executionFee,
bool _shouldWrap
) external payable nonReentrant {
_transferInAndOutETH();
if (_executionFee < minExecutionFee) { revert InsufficientExecutionFee(); }
if (_shouldWrap) {
if (_path[0] != weth) { revert OnlyWethWrapped(); }
if (msg.value != (_executionFee + _amountIn)) { revert IncorrectTransferredValue(); }
} else {
if (msg.value != _executionFee) { revert IncorrectExecutionFee(); }
IERC20(_path[0]).safeTransferFrom(msg.sender, address(orderVault), _amountIn);
}
address _purchaseToken = _path[_path.length - 1];
if (_purchaseToken != _collateralToken) {
revert UnsupportedPurchaseToken();
}
uint256 _purchaseTokenAmount;
if (_path.length > 1) {
revert PathLengthExceeded();
} else {
_purchaseTokenAmount = _amountIn;
}
{
uint256 _purchaseTokenAmountUsd = PriceLib.tokenToUsdMin(dataBase, _purchaseToken, _purchaseTokenAmount);
if (_purchaseTokenAmountUsd < minPurchaseTokenAmountUsd) { revert InsufficientCollateral(); }
}
(uint256 _orderIndex, bytes32 _positionKey) = OrderUtils.createIncreaseOrder(
orderBase,
msg.sender,
_poolToken,
_purchaseToken,
_purchaseTokenAmount,
_collateralToken,
_indexToken,
_sizeDelta,
_isLong,
_triggerPrice,
_triggerAboveThreshold,
_executionFee
);
orderLogger.emitCreateIncreaseOrder(
msg.sender,
_orderIndex,
_poolToken,
_purchaseToken,
_purchaseTokenAmount,
_collateralToken,
_indexToken,
_sizeDelta,
_isLong,
_triggerPrice,
_triggerAboveThreshold,
_executionFee,
_positionKey
);
}
function updateIncreaseOrder(address _poolToken, uint256 _orderIndex, uint256 _sizeDelta, uint256 _triggerPrice, bool _triggerAboveThreshold) external nonReentrant {
bytes32 orderKey = OrderDao.getOrderKey(msg.sender, _orderIndex, _poolToken, OrderDao.ORDER_TYPE_INCREASE);
OrderDao.IncreaseOrder memory order = OrderDao.getIncreaseOrder(orderBase, orderKey);
if (order.account == address(0)) { revert NonExistentOrder(); }
if (block.timestamp <= order.timestamp + MIN_UPDATE_INTERVAL) { revert TooShortUpdateInterval(); }
order.triggerPrice = _triggerPrice;
order.triggerAboveThreshold = _triggerAboveThreshold;
order.sizeDelta = _sizeDelta;
order.timestamp = block.timestamp;
OrderDao.updateIncreaseOrder(orderBase, order, orderKey);
orderLogger.emitUpdateIncreaseOrder(
msg.sender,
_orderIndex,
_poolToken,
order.collateralToken,
order.indexToken,
order.isLong,
_sizeDelta,
_triggerPrice,
_triggerAboveThreshold
);
}
function cancelIncreaseOrder(address _poolToken, uint256 _orderIndex) public nonReentrant {
bytes32 orderKey = OrderDao.getOrderKey(msg.sender, _orderIndex, _poolToken, OrderDao.ORDER_TYPE_INCREASE);
OrderDao.IncreaseOrder memory order = OrderDao.getIncreaseOrder(orderBase, orderKey);
if (order.account == address(0)) { revert NonExistentOrder(); }
OrderDao.removeIncreaseOrder(orderBase, msg.sender, _poolToken, orderKey);
if (order.purchaseToken == weth) {
orderVault.withdrawEth(msg.sender, order.executionFee + order.purchaseTokenAmount);
} else {
orderVault.withdrawToken(msg.sender, order.purchaseToken, order.purchaseTokenAmount);
orderVault.withdrawEth(msg.sender, order.executionFee);
}
orderLogger.emitCancelIncreaseOrder(
order.account,
_orderIndex,
order.poolToken,
order.purchaseToken,
order.purchaseTokenAmount,
order.collateralToken,
order.indexToken,
order.sizeDelta,
order.isLong,
order.triggerPrice,
order.triggerAboveThreshold,
order.executionFee
);
}
function setPriceMMAndExecuteIncreaseOrder(address[] memory _tokens, PriceLib.Prices[] memory _prices, address _address, address _poolToken, uint256 _orderIndex, address payable _feeReceiver) override external nonReentrant onlyManager {
_setPricesMM(_tokens, _prices);
_executeIncreaseOrder(_address, _poolToken, _orderIndex, _feeReceiver);
}
function _executeIncreaseOrder(address _address, address _poolToken, uint256 _orderIndex, address payable _feeReceiver) internal {
bytes32 orderKey = OrderDao.getOrderKey(_address, _orderIndex, _poolToken, OrderDao.ORDER_TYPE_INCREASE);
OrderDao.IncreaseOrder memory order = OrderDao.getIncreaseOrder(orderBase, orderKey);
if (order.account == address(0)) { revert NonExistentOrder(); }
// increase long should use max price
// increase short should use min price
(uint256 currentPrice, ) = validatePositionOrderPrice(
order.triggerAboveThreshold,
order.triggerPrice,
order.indexToken,
order.isLong,
true
);
OrderDao.removeIncreaseOrder(orderBase, _address, _poolToken, orderKey);
orderVault.withdrawToken(increasePositionHandler, order.purchaseToken, order.purchaseTokenAmount);
PositionLib.IncreasePositionCache memory cache = PositionLib.IncreasePositionCache({
account: order.account,
poolToken: order.poolToken,
indexToken: order.indexToken,
collateralToken: order.collateralToken,
sizeDelta: order.sizeDelta,
isLong: order.isLong
});
IIncreasePositionHandler(increasePositionHandler).increasePosition(cache);
// pay executor
orderVault.withdrawEth(_feeReceiver, order.executionFee);
orderLogger.emitExecuteIncreaseOrder(
order.account,
_orderIndex,
order.poolToken,
order.purchaseToken,
order.purchaseTokenAmount,
order.collateralToken,
order.indexToken,
order.sizeDelta,
order.isLong,
order.triggerPrice,
order.triggerAboveThreshold,
order.executionFee,
currentPrice
);
}
function createDecreaseOrder(
address _poolToken,
address _indexToken,
uint256 _sizeDelta,
address _collateralToken,
uint256 _collateralDelta,
bool _isLong,
uint256 _triggerPrice,
bool _triggerAboveThreshold
) external payable nonReentrant {
_transferInAndOutETH();
if (msg.value < minExecutionFee) { revert InsufficientExecutionFee(); }
(uint256 _orderIndex, bytes32 _positionKey) = OrderUtils.createDecreaseOrder(
orderBase,
msg.sender,
_poolToken,
_collateralToken,
_collateralDelta,
_indexToken,
_sizeDelta,
_isLong,
_triggerPrice,
_triggerAboveThreshold,
msg.value);
orderLogger.emitCreateDecreaseOrder(
msg.sender,
_orderIndex,
_poolToken,
_collateralToken,
_collateralDelta,
_indexToken,
_sizeDelta,
_isLong,
_triggerPrice,
_triggerAboveThreshold,
msg.value,
_positionKey
);
}
function createDecreaseOrderTpSl(
address _account,
address _poolToken,
address _indexToken,
uint256 _sizeDelta,
address _collateralToken,
uint256 _collateralDelta,
bool _isLong,
uint256 _triggerPrice,
bool _triggerAboveThreshold
) external payable nonReentrant {
if (msg.sender != multicall) { revert UnauthorizedMuticall(); }
_transferInAndOutETH();
if (msg.value <= minExecutionFee) { revert InsufficientExecutionFee(); }
if (_account == address(0)) { revert ZeroAddress(); }
(uint256 _orderIndex, bytes32 _positionKey) = OrderUtils.createDecreaseOrder(
orderBase,
_account,
_poolToken,
_collateralToken,
_collateralDelta,
_indexToken,
_sizeDelta,
_isLong,
_triggerPrice,
_triggerAboveThreshold,
msg.value);
orderLogger.emitCreateDecreaseOrder(
_account,
_orderIndex,
_poolToken,
_collateralToken,
_collateralDelta,
_indexToken,
_sizeDelta,
_isLong,
_triggerPrice,
_triggerAboveThreshold,
msg.value,
_positionKey
);
}
function setPriceMMAndExecuteDecreaseOrder(address[] memory _tokens, PriceLib.Prices[] memory _prices, address _address, address _poolToken, uint256 _orderIndex, address payable _feeReceiver) override external nonReentrant onlyManager {
_setPricesMM(_tokens, _prices);
_executeDecreaseOrder(_address, _poolToken, _orderIndex, _feeReceiver);
}
function _executeDecreaseOrder(address _address, address _poolToken, uint256 _orderIndex, address payable _feeReceiver) internal {
bytes32 orderKey = OrderDao.getOrderKey(_address, _orderIndex, _poolToken, OrderDao.ORDER_TYPE_DECREASE);
OrderDao.DecreaseOrder memory order = OrderDao.getDecreaseOrder(orderBase, orderKey);
if (order.account == address(0)) { revert NonExistentOrder(); }
// decrease long should use min price
// decrease short should use max price
(uint256 currentPrice, ) = validatePositionOrderPrice(
order.triggerAboveThreshold,
order.triggerPrice,
order.indexToken,
!order.isLong,
true
);
OrderDao.removeDecreaseOrder(orderBase, _address, _poolToken, orderKey);
PositionLib.DecreasePositionCache memory cache = PositionLib.DecreasePositionCache({
account: order.account,
poolToken: order.poolToken,
indexToken: order.indexToken,
collateralToken: order.collateralToken,
collateralDelta: order.collateralDelta,
sizeDelta: order.sizeDelta,
isLong: order.isLong,
receiver: address(this)
});
uint256 amountOut = IDecreasePositionHandler(decreasePositionHandler).decreasePosition(cache);
// transfer released collateral to user
if (order.collateralToken == weth) {
_transferOutETH(amountOut, payable(order.account));
} else {
IERC20(order.collateralToken).safeTransfer(order.account, amountOut);
}
// pay executor
orderVault.withdrawEth(_feeReceiver, order.executionFee);
(uint256 _positionSize,) = PositionDao.getPositionFields(dataBase, order.account, order.poolToken,
order.collateralToken, order.indexToken, order.isLong);
if (_positionSize == 0) {
_batchCancelDecreaseOrders(order.account, order.poolToken, order.indexToken, order.isLong);
}
orderLogger.emitExecuteDecreaseOrder(
order.account,
_orderIndex,
order.poolToken,
order.collateralToken,
order.collateralDelta,
order.indexToken,
order.sizeDelta,
order.isLong,
order.triggerPrice,
order.triggerAboveThreshold,
order.executionFee,
currentPrice
);
}
function updateDecreaseOrder(
address _poolToken,
uint256 _orderIndex,
uint256 _collateralDelta,
uint256 _sizeDelta,
uint256 _triggerPrice,
bool _triggerAboveThreshold
) external nonReentrant {
bytes32 orderKey = OrderDao.getOrderKey(msg.sender, _orderIndex, _poolToken, OrderDao.ORDER_TYPE_DECREASE);
OrderDao.DecreaseOrder memory order = OrderDao.getDecreaseOrder(orderBase, orderKey);
if (order.account == address(0)) { revert NonExistentOrder(); }
if (block.timestamp <= order.timestamp + MIN_UPDATE_INTERVAL) { revert TooShortUpdateInterval(); }
order.triggerPrice = _triggerPrice;
order.triggerAboveThreshold = _triggerAboveThreshold;
order.sizeDelta = _sizeDelta;
order.collateralDelta = _collateralDelta;
order.timestamp = block.timestamp;
OrderDao.updateDecreaseOrder(orderBase, order, orderKey);
orderLogger.emitUpdateDecreaseOrder(
msg.sender,
_orderIndex,
order.poolToken,
order.collateralToken,
_collateralDelta,
order.indexToken,
_sizeDelta,
order.isLong,
_triggerPrice,
_triggerAboveThreshold
);
}
function cancelDecreaseOrder(address _poolToken, uint256 _orderIndex) override public nonReentrant {
_cancelDecreaseOrder(OrderDao.getOrderKey(msg.sender, _orderIndex, _poolToken, OrderDao.ORDER_TYPE_DECREASE), true);
}
function cancelDecreaseOrderByKey(bytes32 _orderKey) override external onlyManager nonReentrant {
_cancelDecreaseOrder(_orderKey, true);
}
function batchCancelDecreaseOrders(address _account, address _poolToken, address _indexToken, bool _isLong) override external onlyManager nonReentrant {
_batchCancelDecreaseOrders(_account, _poolToken, _indexToken, _isLong);
}
function _batchCancelDecreaseOrders(address _account, address _poolToken, address _indexToken, bool _isLong) internal {
OrderDao.DecreaseOrder[] memory _orders = OrderDao.getDecreaseOrders(orderBase, _account, _poolToken);
for (uint256 i = 0; i < _orders.length; i++) {
OrderDao.DecreaseOrder memory _order = _orders[i];
if (_order.indexToken == _indexToken && _order.isLong == _isLong) {
_cancelDecreaseOrder(OrderDao.getOrderKey(_account, _order.index, _poolToken, OrderDao.ORDER_TYPE_DECREASE), false);
}
}
}
function _cancelDecreaseOrder(bytes32 _orderKey, bool _raised) internal {
OrderDao.DecreaseOrder memory order = OrderDao.getDecreaseOrder(orderBase, _orderKey);
if (order.account == address(0)) {
if (_raised) { revert NonExistentOrder(); }
return;
}
OrderDao.removeDecreaseOrder(orderBase, order.account, order.poolToken, _orderKey);
orderVault.withdrawEth(order.account, order.executionFee);
orderLogger.emitCancelDecreaseOrder(
order.account,
order.index,
order.poolToken,
order.collateralToken,
order.collateralDelta,
order.indexToken,
order.sizeDelta,
order.isLong,
order.triggerPrice,
order.triggerAboveThreshold,
order.executionFee
);
}
function validatePositionOrderPrice(
bool _triggerAboveThreshold,
uint256 _triggerPrice,
address _indexToken,
bool _maximizePrice,
bool _raise
) public view returns (uint256, bool) {
uint256 currentPrice = _maximizePrice
? PriceLib.pricesMax(dataBase, _indexToken) : PriceLib.pricesMin(dataBase, _indexToken);
bool isPriceValid = _triggerAboveThreshold ? currentPrice > _triggerPrice : currentPrice < _triggerPrice;
if (_raise) {
if (!isPriceValid) { revert InvalidPriceForExecution(); }
}
return (currentPrice, isPriceValid);
}
function _transferInAndOutETH() private {
if (msg.value != 0) {
(bool success, ) = address(orderVault).call{value: msg.value}("");
if (!success) { revert FailedTransferETHToOrderVault(); }
}
}
function _transferOutETH(uint256 _amountOut, address payable _receiver) private {
IWETH(weth).withdraw(_amountOut);
(bool success, ) = _receiver.call{value: _amountOut}("");
if (!success) { revert FailedTransferETHToReceiver(); }
}
function _setPricesMM(address[] memory _tokens, PriceLib.Prices[] memory _prices) internal {
IOracle(oracle).batchSetPriceMM(_tokens, _prices);
}
}Other files
@openzeppelin/contracts/token/ERC20/utils/SafeERC20.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.3.0) (token/ERC20/utils/SafeERC20.sol) pragma solidity ^0.8.20; import {IERC20} from "../IERC20.sol"; import {IERC1363} from "../../../interfaces/IERC1363.sol"; /** * @title SafeERC20 * @dev Wrappers around ERC-20 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 { /** * @dev An operation with an ERC-20 token failed. */ error SafeERC20FailedOperation(address token); /** * @dev Indicates a failed `decreaseAllowance` request. */ error SafeERC20FailedDecreaseAllowance(address spender, uint256 currentAllowance, uint256 requestedDecrease); /** * @dev Transfer `value` amount of `token` from the calling contract to `to`. If `token` returns no value, * non-reverting calls are assumed to be successful. */ function safeTransfer(IERC20 token, address to, uint256 value) internal { _callOptionalReturn(token, abi.encodeCall(token.transfer, (to, value))); } /** * @dev Transfer `value` amount of `token` from `from` to `to`, spending the approval given by `from` to the * calling contract. If `token` returns no value, non-reverting calls are assumed to be successful. */ function safeTransferFrom(IERC20 token, address from, address to, uint256 value) internal { _callOptionalReturn(token, abi.encodeCall(token.transferFrom, (from, to, value))); } /** * @dev Variant of {safeTransfer} that returns a bool instead of reverting if the operation is not successful. */ function trySafeTransfer(IERC20 token, address to, uint256 value) internal returns (bool) { return _callOptionalReturnBool(token, abi.encodeCall(token.transfer, (to, value))); } /** * @dev Variant of {safeTransferFrom} that returns a bool instead of reverting if the operation is not successful. */ function trySafeTransferFrom(IERC20 token, address from, address to, uint256 value) internal returns (bool) { return _callOptionalReturnBool(token, abi.encodeCall(token.transferFrom, (from, to, value))); } /** * @dev Increase the calling contract's allowance toward `spender` by `value`. If `token` returns no value, * non-reverting calls are assumed to be successful. * * IMPORTANT: If the token implements ERC-7674 (ERC-20 with temporary allowance), and if the "client" * smart contract uses ERC-7674 to set temporary allowances, then the "client" smart contract should avoid using * this function. Performing a {safeIncreaseAllowance} or {safeDecreaseAllowance} operation on a token contract * that has a non-zero temporary allowance (for that particular owner-spender) will result in unexpected behavior. */ function safeIncreaseAllowance(IERC20 token, address spender, uint256 value) internal { uint256 oldAllowance = token.allowance(address(this), spender); forceApprove(token, spender, oldAllowance + value); } /** * @dev Decrease the calling contract's allowance toward `spender` by `requestedDecrease`. If `token` returns no * value, non-reverting calls are assumed to be successful. * * IMPORTANT: If the token implements ERC-7674 (ERC-20 with temporary allowance), and if the "client" * smart contract uses ERC-7674 to set temporary allowances, then the "client" smart contract should avoid using * this function. Performing a {safeIncreaseAllowance} or {safeDecreaseAllowance} operation on a token contract * that has a non-zero temporary allowance (for that particular owner-spender) will result in unexpected behavior. */ function safeDecreaseAllowance(IERC20 token, address spender, uint256 requestedDecrease) internal { unchecked { uint256 currentAllowance = token.allowance(address(this), spender); if (currentAllowance < requestedDecrease) { revert SafeERC20FailedDecreaseAllowance(spender, currentAllowance, requestedDecrease); } forceApprove(token, spender, currentAllowance - requestedDecrease); } } /** * @dev Set the calling contract's allowance toward `spender` to `value`. If `token` returns no value, * non-reverting calls are assumed to be successful. Meant to be used with tokens that require the approval * to be set to zero before setting it to a non-zero value, such as USDT. * * NOTE: If the token implements ERC-7674, this function will not modify any temporary allowance. This function * only sets the "standard" allowance. Any temporary allowance will remain active, in addition to the value being * set here. */ function forceApprove(IERC20 token, address spender, uint256 value) internal { bytes memory approvalCall = abi.encodeCall(token.approve, (spender, value)); if (!_callOptionalReturnBool(token, approvalCall)) { _callOptionalReturn(token, abi.encodeCall(token.approve, (spender, 0))); _callOptionalReturn(token, approvalCall); } } /** * @dev Performs an {ERC1363} transferAndCall, with a fallback to the simple {ERC20} transfer if the target has no * code. This can be used to implement an {ERC721}-like safe transfer that rely on {ERC1363} checks when * targeting contracts. * * Reverts if the returned value is other than `true`. */ function transferAndCallRelaxed(IERC1363 token, address to, uint256 value, bytes memory data) internal { if (to.code.length == 0) { safeTransfer(token, to, value); } else if (!token.transferAndCall(to, value, data)) { revert SafeERC20FailedOperation(address(token)); } } /** * @dev Performs an {ERC1363} transferFromAndCall, with a fallback to the simple {ERC20} transferFrom if the target * has no code. This can be used to implement an {ERC721}-like safe transfer that rely on {ERC1363} checks when * targeting contracts. * * Reverts if the returned value is other than `true`. */ function transferFromAndCallRelaxed( IERC1363 token, address from, address to, uint256 value, bytes memory data ) internal { if (to.code.length == 0) { safeTransferFrom(token, from, to, value); } else if (!token.transferFromAndCall(from, to, value, data)) { revert SafeERC20FailedOperation(address(token)); } } /** * @dev Performs an {ERC1363} approveAndCall, with a fallback to the simple {ERC20} approve if the target has no * code. This can be used to implement an {ERC721}-like safe transfer that rely on {ERC1363} checks when * targeting contracts. * * NOTE: When the recipient address (`to`) has no code (i.e. is an EOA), this function behaves as {forceApprove}. * Opposedly, when the recipient address (`to`) has code, this function only attempts to call {ERC1363-approveAndCall} * once without retrying, and relies on the returned value to be true. * * Reverts if the returned value is other than `true`. */ function approveAndCallRelaxed(IERC1363 token, address to, uint256 value, bytes memory data) internal { if (to.code.length == 0) { forceApprove(token, to, value); } else if (!token.approveAndCall(to, value, data)) { revert SafeERC20FailedOperation(address(token)); } } /** * @dev Imitates a Solidity high-level call (i.e. a regular function call to a contract), relaxing the requirement * on the return value: the return value is optional (but if data is returned, it must not be false). * @param token The token targeted by the call. * @param data The call data (encoded using abi.encode or one of its variants). * * This is a variant of {_callOptionalReturnBool} that reverts if call fails to meet the requirements. */ function _callOptionalReturn(IERC20 token, bytes memory data) private { uint256 returnSize; uint256 returnValue; assembly ("memory-safe") { let success := call(gas(), token, 0, add(data, 0x20), mload(data), 0, 0x20) // bubble errors if iszero(success) { let ptr := mload(0x40) returndatacopy(ptr, 0, returndatasize()) revert(ptr, returndatasize()) } returnSize := returndatasize() returnValue := mload(0) } if (returnSize == 0 ? address(token).code.length == 0 : returnValue != 1) { revert SafeERC20FailedOperation(address(token)); } } /** * @dev Imitates a Solidity high-level call (i.e. a regular function call to a contract), relaxing the requirement * on the return value: the return value is optional (but if data is returned, it must not be false). * @param token The token targeted by the call. * @param data The call data (encoded using abi.encode or one of its variants). * * This is a variant of {_callOptionalReturn} that silently catches all reverts and returns a bool instead. */ function _callOptionalReturnBool(IERC20 token, bytes memory data) private returns (bool) { bool success; uint256 returnSize; uint256 returnValue; assembly ("memory-safe") { success := call(gas(), token, 0, add(data, 0x20), mload(data), 0, 0x20) returnSize := returndatasize() returnValue := mload(0) } return success && (returnSize == 0 ? address(token).code.length > 0 : returnValue == 1); } }contracts/tokens/IWETH.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; interface IWETH { function deposit() external payable; function transfer(address to, uint value) external returns (bool); function withdraw(uint256 amount) external; }@openzeppelin/contracts/utils/structs/EnumerableSet.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.3.0) (utils/structs/EnumerableSet.sol) // This file was procedurally generated from scripts/generate/templates/EnumerableSet.js. pragma solidity ^0.8.20; import {Arrays} from "../Arrays.sol"; /** * @dev Library for managing * https://en.wikipedia.org/wiki/Set_(abstract_data_type)[sets] of primitive * types. * * Sets have the following properties: * * - Elements are added, removed, and checked for existence in constant time * (O(1)). * - Elements are enumerated in O(n). No guarantees are made on the ordering. * - Set can be cleared (all elements removed) in O(n). * * ```solidity * contract Example { * // Add the library methods * using EnumerableSet for EnumerableSet.AddressSet; * * // Declare a set state variable * EnumerableSet.AddressSet private mySet; * } * ``` * * As of v3.3.0, sets of type `bytes32` (`Bytes32Set`), `address` (`AddressSet`) * and `uint256` (`UintSet`) are supported. * * [WARNING] * ==== * Trying to delete such a structure from storage will likely result in data corruption, rendering the structure * unusable. * See https://github.com/ethereum/solidity/pull/11843[ethereum/solidity#11843] for more info. * * In order to clean an EnumerableSet, you can either remove all elements one by one or create a fresh instance using an * array of EnumerableSet. * ==== */ library EnumerableSet { // To implement this library for multiple types with as little code // repetition as possible, we write it in terms of a generic Set type with // bytes32 values. // The Set implementation uses private functions, and user-facing // implementations (such as AddressSet) are just wrappers around the // underlying Set. // This means that we can only create new EnumerableSets for types that fit // in bytes32. struct Set { // Storage of set values bytes32[] _values; // Position is the index of the value in the `values` array plus 1. // Position 0 is used to mean a value is not in the set. mapping(bytes32 value => uint256) _positions; } /** * @dev Add a value to a set. O(1). * * Returns true if the value was added to the set, that is if it was not * already present. */ function _add(Set storage set, bytes32 value) private returns (bool) { if (!_contains(set, value)) { set._values.push(value); // The value is stored at length-1, but we add 1 to all indexes // and use 0 as a sentinel value set._positions[value] = set._values.length; return true; } else { return false; } } /** * @dev Removes a value from a set. O(1). * * Returns true if the value was removed from the set, that is if it was * present. */ function _remove(Set storage set, bytes32 value) private returns (bool) { // We cache the value's position to prevent multiple reads from the same storage slot uint256 position = set._positions[value]; if (position != 0) { // Equivalent to contains(set, value) // To delete an element from the _values array in O(1), we swap the element to delete with the last one in // the array, and then remove the last element (sometimes called as 'swap and pop'). // This modifies the order of the array, as noted in {at}. uint256 valueIndex = position - 1; uint256 lastIndex = set._values.length - 1; if (valueIndex != lastIndex) { bytes32 lastValue = set._values[lastIndex]; // Move the lastValue to the index where the value to delete is set._values[valueIndex] = lastValue; // Update the tracked position of the lastValue (that was just moved) set._positions[lastValue] = position; } // Delete the slot where the moved value was stored set._values.pop(); // Delete the tracked position for the deleted slot delete set._positions[value]; return true; } else { return false; } } /** * @dev Removes all the values from a set. O(n). * * WARNING: Developers should keep in mind that this function has an unbounded cost and using it may render the * function uncallable if the set grows to the point where clearing it consumes too much gas to fit in a block. */ function _clear(Set storage set) private { uint256 len = _length(set); for (uint256 i = 0; i < len; ++i) { delete set._positions[set._values[i]]; } Arrays.unsafeSetLength(set._values, 0); } /** * @dev Returns true if the value is in the set. O(1). */ function _contains(Set storage set, bytes32 value) private view returns (bool) { return set._positions[value] != 0; } /** * @dev Returns the number of values on the set. O(1). */ function _length(Set storage set) private view returns (uint256) { return set._values.length; } /** * @dev Returns the value stored at position `index` in the set. O(1). * * Note that there are no guarantees on the ordering of values inside the * array, and it may change when more values are added or removed. * * Requirements: * * - `index` must be strictly less than {length}. */ function _at(Set storage set, uint256 index) private view returns (bytes32) { return set._values[index]; } /** * @dev Return the entire set in an array * * WARNING: This operation will copy the entire storage to memory, which can be quite expensive. This is designed * to mostly be used by view accessors that are queried without any gas fees. Developers should keep in mind that * this function has an unbounded cost, and using it as part of a state-changing function may render the function * uncallable if the set grows to a point where copying to memory consumes too much gas to fit in a block. */ function _values(Set storage set) private view returns (bytes32[] memory) { return set._values; } // Bytes32Set struct Bytes32Set { Set _inner; } /** * @dev Add a value to a set. O(1). * * Returns true if the value was added to the set, that is if it was not * already present. */ function add(Bytes32Set storage set, bytes32 value) internal returns (bool) { return _add(set._inner, value); } /** * @dev Removes a value from a set. O(1). * * Returns true if the value was removed from the set, that is if it was * present. */ function remove(Bytes32Set storage set, bytes32 value) internal returns (bool) { return _remove(set._inner, value); } /** * @dev Removes all the values from a set. O(n). * * WARNING: Developers should keep in mind that this function has an unbounded cost and using it may render the * function uncallable if the set grows to the point where clearing it consumes too much gas to fit in a block. */ function clear(Bytes32Set storage set) internal { _clear(set._inner); } /** * @dev Returns true if the value is in the set. O(1). */ function contains(Bytes32Set storage set, bytes32 value) internal view returns (bool) { return _contains(set._inner, value); } /** * @dev Returns the number of values in the set. O(1). */ function length(Bytes32Set storage set) internal view returns (uint256) { return _length(set._inner); } /** * @dev Returns the value stored at position `index` in the set. O(1). * * Note that there are no guarantees on the ordering of values inside the * array, and it may change when more values are added or removed. * * Requirements: * * - `index` must be strictly less than {length}. */ function at(Bytes32Set storage set, uint256 index) internal view returns (bytes32) { return _at(set._inner, index); } /** * @dev Return the entire set in an array * * WARNING: This operation will copy the entire storage to memory, which can be quite expensive. This is designed * to mostly be used by view accessors that are queried without any gas fees. Developers should keep in mind that * this function has an unbounded cost, and using it as part of a state-changing function may render the function * uncallable if the set grows to a point where copying to memory consumes too much gas to fit in a block. */ function values(Bytes32Set storage set) internal view returns (bytes32[] memory) { bytes32[] memory store = _values(set._inner); bytes32[] memory result; assembly ("memory-safe") { result := store } return result; } // AddressSet struct AddressSet { Set _inner; } /** * @dev Add a value to a set. O(1). * * Returns true if the value was added to the set, that is if it was not * already present. */ function add(AddressSet storage set, address value) internal returns (bool) { return _add(set._inner, bytes32(uint256(uint160(value)))); } /** * @dev Removes a value from a set. O(1). * * Returns true if the value was removed from the set, that is if it was * present. */ function remove(AddressSet storage set, address value) internal returns (bool) { return _remove(set._inner, bytes32(uint256(uint160(value)))); } /** * @dev Removes all the values from a set. O(n). * * WARNING: Developers should keep in mind that this function has an unbounded cost and using it may render the * function uncallable if the set grows to the point where clearing it consumes too much gas to fit in a block. */ function clear(AddressSet storage set) internal { _clear(set._inner); } /** * @dev Returns true if the value is in the set. O(1). */ function contains(AddressSet storage set, address value) internal view returns (bool) { return _contains(set._inner, bytes32(uint256(uint160(value)))); } /** * @dev Returns the number of values in the set. O(1). */ function length(AddressSet storage set) internal view returns (uint256) { return _length(set._inner); } /** * @dev Returns the value stored at position `index` in the set. O(1). * * Note that there are no guarantees on the ordering of values inside the * array, and it may change when more values are added or removed. * * Requirements: * * - `index` must be strictly less than {length}. */ function at(AddressSet storage set, uint256 index) internal view returns (address) { return address(uint160(uint256(_at(set._inner, index)))); } /** * @dev Return the entire set in an array * * WARNING: This operation will copy the entire storage to memory, which can be quite expensive. This is designed * to mostly be used by view accessors that are queried without any gas fees. Developers should keep in mind that * this function has an unbounded cost, and using it as part of a state-changing function may render the function * uncallable if the set grows to a point where copying to memory consumes too much gas to fit in a block. */ function values(AddressSet storage set) internal view returns (address[] memory) { bytes32[] memory store = _values(set._inner); address[] memory result; assembly ("memory-safe") { result := store } return result; } // UintSet struct UintSet { Set _inner; } /** * @dev Add a value to a set. O(1). * * Returns true if the value was added to the set, that is if it was not * already present. */ function add(UintSet storage set, uint256 value) internal returns (bool) { return _add(set._inner, bytes32(value)); } /** * @dev Removes a value from a set. O(1). * * Returns true if the value was removed from the set, that is if it was * present. */ function remove(UintSet storage set, uint256 value) internal returns (bool) { return _remove(set._inner, bytes32(value)); } /** * @dev Removes all the values from a set. O(n). * * WARNING: Developers should keep in mind that this function has an unbounded cost and using it may render the * function uncallable if the set grows to the point where clearing it consumes too much gas to fit in a block. */ function clear(UintSet storage set) internal { _clear(set._inner); } /** * @dev Returns true if the value is in the set. O(1). */ function contains(UintSet storage set, uint256 value) internal view returns (bool) { return _contains(set._inner, bytes32(value)); } /** * @dev Returns the number of values in the set. O(1). */ function length(UintSet storage set) internal view returns (uint256) { return _length(set._inner); } /** * @dev Returns the value stored at position `index` in the set. O(1). * * Note that there are no guarantees on the ordering of values inside the * array, and it may change when more values are added or removed. * * Requirements: * * - `index` must be strictly less than {length}. */ function at(UintSet storage set, uint256 index) internal view returns (uint256) { return uint256(_at(set._inner, index)); } /** * @dev Return the entire set in an array * * WARNING: This operation will copy the entire storage to memory, which can be quite expensive. This is designed * to mostly be used by view accessors that are queried without any gas fees. Developers should keep in mind that * this function has an unbounded cost, and using it as part of a state-changing function may render the function * uncallable if the set grows to a point where copying to memory consumes too much gas to fit in a block. */ function values(UintSet storage set) internal view returns (uint256[] memory) { bytes32[] memory store = _values(set._inner); uint256[] memory result; assembly ("memory-safe") { result := store } return result; } }@openzeppelin/contracts/interfaces/IERC20.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.0.0) (interfaces/IERC20.sol) pragma solidity ^0.8.20; import {IERC20} from "../token/ERC20/IERC20.sol";contracts/order/OrderVault.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "@openzeppelin/contracts/utils/ReentrancyGuard.sol"; import "@openzeppelin/contracts/token/ERC20/IERC20.sol"; import "@openzeppelin/contracts/token/ERC20/utils/SafeERC20.sol"; import "../tokens/IWETH.sol"; import "../base/CustomAddress.sol"; import "./IOrderVault.sol"; contract OrderVault is IOrderVault, ReentrancyGuard { using SafeERC20 for IERC20; using CustomAddress for address payable; address public gov; address public immutable weth; mapping(address => bool) public isHandler; mapping(address => bool) public tokenWhitelist; // Optional: whitelisted tokens event UpdateGov(address gov); event UpdateHandler(address handler, bool isActive); event UpdateTokenWhitelist(address token, bool isWhitelisted); event Received(address sender, uint256 amount); event EthDeposited(address sender, uint256 amount); event TokenReceived(address sender, address token, uint256 amount); event Withdrawn(address recipient, uint256 amount); event TokenWithdrawn(address recipient, address token, uint256 amount); error NotGov(); error NotHandler(); error ZeroAddress(); error InvalidETHSender(); error NoneETH(); error InvalidAmount(); error NotWhitelisted(); error InsufficientETH(); error InsufficientWeth(); error FailedWithdrawWeth(); error InsufficientToken(); modifier onlyGov() { if (msg.sender != gov) { revert NotGov(); } _; } modifier onlyHandler() { if (!isHandler[msg.sender]) { revert NotHandler(); } _; } constructor(address _weth) { if (_weth == address(0)) { revert ZeroAddress(); } weth = _weth; gov = msg.sender; } receive() external payable { if (!isHandler[msg.sender]) { revert InvalidETHSender(); } emit Received(msg.sender, msg.value); } function setGov(address _gov) external onlyGov { if (_gov == address(0)) { revert ZeroAddress(); } gov = _gov; emit UpdateGov(_gov); } function setHandler(address _handler, bool _isActive) external onlyGov { isHandler[_handler] = _isActive; emit UpdateHandler(_handler, _isActive); } function setTokenWhitelist(address _token, bool _isWhitelisted) external onlyGov { tokenWhitelist[_token] = _isWhitelisted; emit UpdateTokenWhitelist(_token, _isWhitelisted); } function depositEth() external payable { if (msg.value == 0) { revert NoneETH(); } emit EthDeposited(msg.sender, msg.value); } function depositToken(address _token, uint256 _amount) external { if (_amount == 0) { revert InvalidAmount(); } if (!tokenWhitelist[_token]) { revert NotWhitelisted(); } IERC20(_token).safeTransferFrom(msg.sender, address(this), _amount); emit TokenReceived(msg.sender, _token, _amount); } function depositTokenFrom(address _from, address _token, uint256 _amount) external { if (_amount == 0) { revert InvalidAmount(); } if (!tokenWhitelist[_token]) { revert NotWhitelisted(); } IERC20(_token).safeTransferFrom(_from, address(this), _amount); emit TokenReceived(_from, _token, _amount); } function withdrawEth(address _to, uint256 _amount) external onlyHandler nonReentrant { if (_amount > address(this).balance) { revert InsufficientETH(); } payable(_to).sendValue(_amount); emit Withdrawn(_to, _amount); } function withdrawWeth(address _to, uint256 _amount) external onlyHandler nonReentrant { if (IERC20(weth).balanceOf(address(this)) < _amount) { revert InsufficientWeth(); } (bool success, ) = address(weth).call(abi.encodeWithSignature("withdraw(uint256)", _amount)); if (!success) { revert FailedWithdrawWeth(); } payable(_to).sendValue(_amount); emit Withdrawn(_to, _amount); } function withdrawToken(address _to, address _token, uint256 _amount) external onlyHandler nonReentrant { if (!tokenWhitelist[_token]) { revert NotWhitelisted(); } if (_amount > IERC20(_token).balanceOf(address(this))) { revert InsufficientToken(); } IERC20(_token).safeTransfer(_to, _amount); emit TokenWithdrawn(_to, _token, _amount); } function balanceOfEth() external view returns (uint256) { return address(this).balance; } function balanceOfToken(address _token) external view returns (uint256) { return IERC20(_token).balanceOf(address(this)); } }contracts/vault/VaultDao.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "../repo/DataBase.sol"; library VaultDao { bytes32 public constant INDEX_TOKEN_LIST = keccak256(abi.encode("INDEX_TOKEN_LIST")); bytes32 public constant STABLE_TOKEN_LIST = keccak256(abi.encode("STABLE_TOKEN_LIST")); function poolStableToken(DataBase _dataBase, address _poolToken, address _token) internal view returns (bool) { return _dataBase.containsAddress(keccak256(abi.encode(_poolToken, STABLE_TOKEN_LIST)), _token); } function poolIndexToken(DataBase _dataBase, address _poolToken, address _token) internal view returns (bool) { return _dataBase.containsAddress(keccak256(abi.encode(_poolToken, INDEX_TOKEN_LIST)), _token); } }@openzeppelin/contracts/utils/Arrays.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.3.0) (utils/Arrays.sol) // This file was procedurally generated from scripts/generate/templates/Arrays.js. pragma solidity ^0.8.20; import {Comparators} from "./Comparators.sol"; import {SlotDerivation} from "./SlotDerivation.sol"; import {StorageSlot} from "./StorageSlot.sol"; import {Math} from "./math/Math.sol"; /** * @dev Collection of functions related to array types. */ library Arrays { using SlotDerivation for bytes32; using StorageSlot for bytes32; /** * @dev Sort an array of uint256 (in memory) following the provided comparator function. * * This function does the sorting "in place", meaning that it overrides the input. The object is returned for * convenience, but that returned value can be discarded safely if the caller has a memory pointer to the array. * * NOTE: this function's cost is `O(n · log(n))` in average and `O(n²)` in the worst case, with n the length of the * array. Using it in view functions that are executed through `eth_call` is safe, but one should be very careful * when executing this as part of a transaction. If the array being sorted is too large, the sort operation may * consume more gas than is available in a block, leading to potential DoS. * * IMPORTANT: Consider memory side-effects when using custom comparator functions that access memory in an unsafe way. */ function sort( uint256[] memory array, function(uint256, uint256) pure returns (bool) comp ) internal pure returns (uint256[] memory) { _quickSort(_begin(array), _end(array), comp); return array; } /** * @dev Variant of {sort} that sorts an array of uint256 in increasing order. */ function sort(uint256[] memory array) internal pure returns (uint256[] memory) { sort(array, Comparators.lt); return array; } /** * @dev Sort an array of address (in memory) following the provided comparator function. * * This function does the sorting "in place", meaning that it overrides the input. The object is returned for * convenience, but that returned value can be discarded safely if the caller has a memory pointer to the array. * * NOTE: this function's cost is `O(n · log(n))` in average and `O(n²)` in the worst case, with n the length of the * array. Using it in view functions that are executed through `eth_call` is safe, but one should be very careful * when executing this as part of a transaction. If the array being sorted is too large, the sort operation may * consume more gas than is available in a block, leading to potential DoS. * * IMPORTANT: Consider memory side-effects when using custom comparator functions that access memory in an unsafe way. */ function sort( address[] memory array, function(address, address) pure returns (bool) comp ) internal pure returns (address[] memory) { sort(_castToUint256Array(array), _castToUint256Comp(comp)); return array; } /** * @dev Variant of {sort} that sorts an array of address in increasing order. */ function sort(address[] memory array) internal pure returns (address[] memory) { sort(_castToUint256Array(array), Comparators.lt); return array; } /** * @dev Sort an array of bytes32 (in memory) following the provided comparator function. * * This function does the sorting "in place", meaning that it overrides the input. The object is returned for * convenience, but that returned value can be discarded safely if the caller has a memory pointer to the array. * * NOTE: this function's cost is `O(n · log(n))` in average and `O(n²)` in the worst case, with n the length of the * array. Using it in view functions that are executed through `eth_call` is safe, but one should be very careful * when executing this as part of a transaction. If the array being sorted is too large, the sort operation may * consume more gas than is available in a block, leading to potential DoS. * * IMPORTANT: Consider memory side-effects when using custom comparator functions that access memory in an unsafe way. */ function sort( bytes32[] memory array, function(bytes32, bytes32) pure returns (bool) comp ) internal pure returns (bytes32[] memory) { sort(_castToUint256Array(array), _castToUint256Comp(comp)); return array; } /** * @dev Variant of {sort} that sorts an array of bytes32 in increasing order. */ function sort(bytes32[] memory array) internal pure returns (bytes32[] memory) { sort(_castToUint256Array(array), Comparators.lt); return array; } /** * @dev Performs a quick sort of a segment of memory. The segment sorted starts at `begin` (inclusive), and stops * at end (exclusive). Sorting follows the `comp` comparator. * * Invariant: `begin <= end`. This is the case when initially called by {sort} and is preserved in subcalls. * * IMPORTANT: Memory locations between `begin` and `end` are not validated/zeroed. This function should * be used only if the limits are within a memory array. */ function _quickSort(uint256 begin, uint256 end, function(uint256, uint256) pure returns (bool) comp) private pure { unchecked { if (end - begin < 0x40) return; // Use first element as pivot uint256 pivot = _mload(begin); // Position where the pivot should be at the end of the loop uint256 pos = begin; for (uint256 it = begin + 0x20; it < end; it += 0x20) { if (comp(_mload(it), pivot)) { // If the value stored at the iterator's position comes before the pivot, we increment the // position of the pivot and move the value there. pos += 0x20; _swap(pos, it); } } _swap(begin, pos); // Swap pivot into place _quickSort(begin, pos, comp); // Sort the left side of the pivot _quickSort(pos + 0x20, end, comp); // Sort the right side of the pivot } } /** * @dev Pointer to the memory location of the first element of `array`. */ function _begin(uint256[] memory array) private pure returns (uint256 ptr) { assembly ("memory-safe") { ptr := add(array, 0x20) } } /** * @dev Pointer to the memory location of the first memory word (32bytes) after `array`. This is the memory word * that comes just after the last element of the array. */ function _end(uint256[] memory array) private pure returns (uint256 ptr) { unchecked { return _begin(array) + array.length * 0x20; } } /** * @dev Load memory word (as a uint256) at location `ptr`. */ function _mload(uint256 ptr) private pure returns (uint256 value) { assembly { value := mload(ptr) } } /** * @dev Swaps the elements memory location `ptr1` and `ptr2`. */ function _swap(uint256 ptr1, uint256 ptr2) private pure { assembly { let value1 := mload(ptr1) let value2 := mload(ptr2) mstore(ptr1, value2) mstore(ptr2, value1) } } /// @dev Helper: low level cast address memory array to uint256 memory array function _castToUint256Array(address[] memory input) private pure returns (uint256[] memory output) { assembly { output := input } } /// @dev Helper: low level cast bytes32 memory array to uint256 memory array function _castToUint256Array(bytes32[] memory input) private pure returns (uint256[] memory output) { assembly { output := input } } /// @dev Helper: low level cast address comp function to uint256 comp function function _castToUint256Comp( function(address, address) pure returns (bool) input ) private pure returns (function(uint256, uint256) pure returns (bool) output) { assembly { output := input } } /// @dev Helper: low level cast bytes32 comp function to uint256 comp function function _castToUint256Comp( function(bytes32, bytes32) pure returns (bool) input ) private pure returns (function(uint256, uint256) pure returns (bool) output) { assembly { output := input } } /** * @dev Searches a sorted `array` and returns the first index that contains * a value greater or equal to `element`. If no such index exists (i.e. all * values in the array are strictly less than `element`), the array length is * returned. Time complexity O(log n). * * NOTE: The `array` is expected to be sorted in ascending order, and to * contain no repeated elements. * * IMPORTANT: Deprecated. This implementation behaves as {lowerBound} but lacks * support for repeated elements in the array. The {lowerBound} function should * be used instead. */ function findUpperBound(uint256[] storage array, uint256 element) internal view returns (uint256) { uint256 low = 0; uint256 high = array.length; if (high == 0) { return 0; } while (low < high) { uint256 mid = Math.average(low, high); // Note that mid will always be strictly less than high (i.e. it will be a valid array index) // because Math.average rounds towards zero (it does integer division with truncation). if (unsafeAccess(array, mid).value > element) { high = mid; } else { low = mid + 1; } } // At this point `low` is the exclusive upper bound. We will return the inclusive upper bound. if (low > 0 && unsafeAccess(array, low - 1).value == element) { return low - 1; } else { return low; } } /** * @dev Searches an `array` sorted in ascending order and returns the first * index that contains a value greater or equal than `element`. If no such index * exists (i.e. all values in the array are strictly less than `element`), the array * length is returned. Time complexity O(log n). * * See C++'s https://en.cppreference.com/w/cpp/algorithm/lower_bound[lower_bound]. */ function lowerBound(uint256[] storage array, uint256 element) internal view returns (uint256) { uint256 low = 0; uint256 high = array.length; if (high == 0) { return 0; } while (low < high) { uint256 mid = Math.average(low, high); // Note that mid will always be strictly less than high (i.e. it will be a valid array index) // because Math.average rounds towards zero (it does integer division with truncation). if (unsafeAccess(array, mid).value < element) { // this cannot overflow because mid < high unchecked { low = mid + 1; } } else { high = mid; } } return low; } /** * @dev Searches an `array` sorted in ascending order and returns the first * index that contains a value strictly greater than `element`. If no such index * exists (i.e. all values in the array are strictly less than `element`), the array * length is returned. Time complexity O(log n). * * See C++'s https://en.cppreference.com/w/cpp/algorithm/upper_bound[upper_bound]. */ function upperBound(uint256[] storage array, uint256 element) internal view returns (uint256) { uint256 low = 0; uint256 high = array.length; if (high == 0) { return 0; } while (low < high) { uint256 mid = Math.average(low, high); // Note that mid will always be strictly less than high (i.e. it will be a valid array index) // because Math.average rounds towards zero (it does integer division with truncation). if (unsafeAccess(array, mid).value > element) { high = mid; } else { // this cannot overflow because mid < high unchecked { low = mid + 1; } } } return low; } /** * @dev Same as {lowerBound}, but with an array in memory. */ function lowerBoundMemory(uint256[] memory array, uint256 element) internal pure returns (uint256) { uint256 low = 0; uint256 high = array.length; if (high == 0) { return 0; } while (low < high) { uint256 mid = Math.average(low, high); // Note that mid will always be strictly less than high (i.e. it will be a valid array index) // because Math.average rounds towards zero (it does integer division with truncation). if (unsafeMemoryAccess(array, mid) < element) { // this cannot overflow because mid < high unchecked { low = mid + 1; } } else { high = mid; } } return low; } /** * @dev Same as {upperBound}, but with an array in memory. */ function upperBoundMemory(uint256[] memory array, uint256 element) internal pure returns (uint256) { uint256 low = 0; uint256 high = array.length; if (high == 0) { return 0; } while (low < high) { uint256 mid = Math.average(low, high); // Note that mid will always be strictly less than high (i.e. it will be a valid array index) // because Math.average rounds towards zero (it does integer division with truncation). if (unsafeMemoryAccess(array, mid) > element) { high = mid; } else { // this cannot overflow because mid < high unchecked { low = mid + 1; } } } return low; } /** * @dev Access an array in an "unsafe" way. Skips solidity "index-out-of-range" check. * * WARNING: Only use if you are certain `pos` is lower than the array length. */ function unsafeAccess(address[] storage arr, uint256 pos) internal pure returns (StorageSlot.AddressSlot storage) { bytes32 slot; assembly ("memory-safe") { slot := arr.slot } return slot.deriveArray().offset(pos).getAddressSlot(); } /** * @dev Access an array in an "unsafe" way. Skips solidity "index-out-of-range" check. * * WARNING: Only use if you are certain `pos` is lower than the array length. */ function unsafeAccess(bytes32[] storage arr, uint256 pos) internal pure returns (StorageSlot.Bytes32Slot storage) { bytes32 slot; assembly ("memory-safe") { slot := arr.slot } return slot.deriveArray().offset(pos).getBytes32Slot(); } /** * @dev Access an array in an "unsafe" way. Skips solidity "index-out-of-range" check. * * WARNING: Only use if you are certain `pos` is lower than the array length. */ function unsafeAccess(uint256[] storage arr, uint256 pos) internal pure returns (StorageSlot.Uint256Slot storage) { bytes32 slot; assembly ("memory-safe") { slot := arr.slot } return slot.deriveArray().offset(pos).getUint256Slot(); } /** * @dev Access an array in an "unsafe" way. Skips solidity "index-out-of-range" check. * * WARNING: Only use if you are certain `pos` is lower than the array length. */ function unsafeMemoryAccess(address[] memory arr, uint256 pos) internal pure returns (address res) { assembly { res := mload(add(add(arr, 0x20), mul(pos, 0x20))) } } /** * @dev Access an array in an "unsafe" way. Skips solidity "index-out-of-range" check. * * WARNING: Only use if you are certain `pos` is lower than the array length. */ function unsafeMemoryAccess(bytes32[] memory arr, uint256 pos) internal pure returns (bytes32 res) { assembly { res := mload(add(add(arr, 0x20), mul(pos, 0x20))) } } /** * @dev Access an array in an "unsafe" way. Skips solidity "index-out-of-range" check. * * WARNING: Only use if you are certain `pos` is lower than the array length. */ function unsafeMemoryAccess(uint256[] memory arr, uint256 pos) internal pure returns (uint256 res) { assembly { res := mload(add(add(arr, 0x20), mul(pos, 0x20))) } } /** * @dev Helper to set the length of a dynamic array. Directly writing to `.length` is forbidden. * * WARNING: this does not clear elements if length is reduced, of initialize elements if length is increased. */ function unsafeSetLength(address[] storage array, uint256 len) internal { assembly ("memory-safe") { sstore(array.slot, len) } } /** * @dev Helper to set the length of a dynamic array. Directly writing to `.length` is forbidden. * * WARNING: this does not clear elements if length is reduced, of initialize elements if length is increased. */ function unsafeSetLength(bytes32[] storage array, uint256 len) internal { assembly ("memory-safe") { sstore(array.slot, len) } } /** * @dev Helper to set the length of a dynamic array. Directly writing to `.length` is forbidden. * * WARNING: this does not clear elements if length is reduced, of initialize elements if length is increased. */ function unsafeSetLength(uint256[] storage array, uint256 len) internal { assembly ("memory-safe") { sstore(array.slot, len) } } }@openzeppelin/contracts/interfaces/IERC1363.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (interfaces/IERC1363.sol) pragma solidity ^0.8.20; import {IERC20} from "./IERC20.sol"; import {IERC165} from "./IERC165.sol"; /** * @title IERC1363 * @dev Interface of the ERC-1363 standard as defined in the https://eips.ethereum.org/EIPS/eip-1363[ERC-1363]. * * Defines an extension interface for ERC-20 tokens that supports executing code on a recipient contract * after `transfer` or `transferFrom`, or code on a spender contract after `approve`, in a single transaction. */ interface IERC1363 is IERC20, IERC165 { /* * Note: the ERC-165 identifier for this interface is 0xb0202a11. * 0xb0202a11 === * bytes4(keccak256('transferAndCall(address,uint256)')) ^ * bytes4(keccak256('transferAndCall(address,uint256,bytes)')) ^ * bytes4(keccak256('transferFromAndCall(address,address,uint256)')) ^ * bytes4(keccak256('transferFromAndCall(address,address,uint256,bytes)')) ^ * bytes4(keccak256('approveAndCall(address,uint256)')) ^ * bytes4(keccak256('approveAndCall(address,uint256,bytes)')) */ /** * @dev Moves a `value` amount of tokens from the caller's account to `to` * and then calls {IERC1363Receiver-onTransferReceived} on `to`. * @param to The address which you want to transfer to. * @param value The amount of tokens to be transferred. * @return A boolean value indicating whether the operation succeeded unless throwing. */ function transferAndCall(address to, uint256 value) external returns (bool); /** * @dev Moves a `value` amount of tokens from the caller's account to `to` * and then calls {IERC1363Receiver-onTransferReceived} on `to`. * @param to The address which you want to transfer to. * @param value The amount of tokens to be transferred. * @param data Additional data with no specified format, sent in call to `to`. * @return A boolean value indicating whether the operation succeeded unless throwing. */ function transferAndCall(address to, uint256 value, bytes calldata data) external returns (bool); /** * @dev Moves a `value` amount of tokens from `from` to `to` using the allowance mechanism * and then calls {IERC1363Receiver-onTransferReceived} on `to`. * @param from The address which you want to send tokens from. * @param to The address which you want to transfer to. * @param value The amount of tokens to be transferred. * @return A boolean value indicating whether the operation succeeded unless throwing. */ function transferFromAndCall(address from, address to, uint256 value) external returns (bool); /** * @dev Moves a `value` amount of tokens from `from` to `to` using the allowance mechanism * and then calls {IERC1363Receiver-onTransferReceived} on `to`. * @param from The address which you want to send tokens from. * @param to The address which you want to transfer to. * @param value The amount of tokens to be transferred. * @param data Additional data with no specified format, sent in call to `to`. * @return A boolean value indicating whether the operation succeeded unless throwing. */ function transferFromAndCall(address from, address to, uint256 value, bytes calldata data) external returns (bool); /** * @dev Sets a `value` amount of tokens as the allowance of `spender` over the * caller's tokens and then calls {IERC1363Spender-onApprovalReceived} on `spender`. * @param spender The address which will spend the funds. * @param value The amount of tokens to be spent. * @return A boolean value indicating whether the operation succeeded unless throwing. */ function approveAndCall(address spender, uint256 value) external returns (bool); /** * @dev Sets a `value` amount of tokens as the allowance of `spender` over the * caller's tokens and then calls {IERC1363Spender-onApprovalReceived} on `spender`. * @param spender The address which will spend the funds. * @param value The amount of tokens to be spent. * @param data Additional data with no specified format, sent in call to `spender`. * @return A boolean value indicating whether the operation succeeded unless throwing. */ function approveAndCall(address spender, uint256 value, bytes calldata data) external returns (bool); }contracts/order/OrderBase.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "../repo/RoleBase.sol"; import "../utils/EnumerableValues.sol"; import "../utils/Role.sol"; contract OrderBase { using EnumerableSet for EnumerableSet.Bytes32Set; using EnumerableSet for EnumerableSet.AddressSet; using EnumerableSet for EnumerableSet.UintSet; using EnumerableValues for EnumerableSet.Bytes32Set; using EnumerableValues for EnumerableSet.AddressSet; using EnumerableValues for EnumerableSet.UintSet; bytes32 public constant ROLE_ORDER_WRITER = keccak256(abi.encode("ORDER_WRITER")); RoleBase roleBase; mapping(bytes32 => uint256) public uintValues; mapping(bytes32 => int256) public intValues; mapping(bytes32 => address) public addressValues; mapping(bytes32 => bool) public boolValues; mapping(bytes32 => string) public stringValues; mapping(bytes32 => bytes32) public bytes32Values; mapping(bytes32 => uint256[]) public uintArrayValues; mapping(bytes32 => int256[]) public intArrayValues; mapping(bytes32 => address[]) public addressArrayValues; mapping(bytes32 => bool[]) public boolArrayValues; mapping(bytes32 => string[]) public stringArrayValues; mapping(bytes32 => bytes32[]) public bytes32ArrayValues; mapping(bytes32 => EnumerableSet.AddressSet) internal addressSets; mapping(bytes32 => EnumerableSet.Bytes32Set) internal bytes32Sets; mapping(bytes32 => EnumerableSet.UintSet) internal uintSets; error UnauthorizedOrderWrite(address account); modifier onlyOrderWriter() { if (!roleBase.hasRole(msg.sender, ROLE_ORDER_WRITER)) { revert UnauthorizedOrderWrite(msg.sender); } _; } constructor(RoleBase _roleBase) { roleBase = _roleBase; } function getUint(bytes32 key) external view returns (uint256) { return uintValues[key]; } function setUint(bytes32 key, uint256 value) external onlyOrderWriter returns (uint256) { uintValues[key] = value; return value; } function removeUint(bytes32 key) external onlyOrderWriter { delete uintValues[key]; } function addDeltaToUint(bytes32 key, int256 value, string memory errMsg) external onlyOrderWriter returns (uint256) { uint256 curValue = uintValues[key]; if (value < 0 && uint256(-value) > curValue) { revert(errMsg); } uint256 nextUint; if (value >= 0) { nextUint = curValue + uint256(value); } else { nextUint = curValue - uint256(-value); } uintValues[key] = nextUint; return nextUint; } function incrementUint(bytes32 key, uint256 value) external onlyOrderWriter returns (uint256) { uint256 nextUint = uintValues[key] + value; uintValues[key] = nextUint; return nextUint; } function decrementUint(bytes32 key, uint256 value) external onlyOrderWriter returns (uint256) { uint256 nextUint = uintValues[key] - value; uintValues[key] = nextUint; return nextUint; } function getInt(bytes32 key) external view returns (int256) { return intValues[key]; } function setInt(bytes32 key, int256 value) external onlyOrderWriter returns (int256) { intValues[key] = value; return value; } function removeInt(bytes32 key) external onlyOrderWriter { delete intValues[key]; } function incrementInt(bytes32 key, int256 value) external onlyOrderWriter returns (int256) { int256 nextInt = intValues[key] + value; intValues[key] = nextInt; return nextInt; } function decrementInt(bytes32 key, int256 value) external onlyOrderWriter returns (int256) { int256 nextInt = intValues[key] - value; intValues[key] = nextInt; return nextInt; } function getAddress(bytes32 key) external view returns (address) { return addressValues[key]; } function setAddress(bytes32 key, address value) external onlyOrderWriter returns (address) { addressValues[key] = value; return value; } function removeAddress(bytes32 key) external onlyOrderWriter { delete addressValues[key]; } function getBool(bytes32 key) external view returns (bool) { return boolValues[key]; } function setBool(bytes32 key, bool value) external onlyOrderWriter returns (bool) { boolValues[key] = value; return value; } function removeBool(bytes32 key) external onlyOrderWriter { delete boolValues[key]; } function getString(bytes32 key) external view returns (string memory) { return stringValues[key]; } function setString(bytes32 key, string memory value) external onlyOrderWriter returns (string memory) { stringValues[key] = value; return value; } function removeString(bytes32 key) external onlyOrderWriter { delete stringValues[key]; } function getBytes32(bytes32 key) external view returns (bytes32) { return bytes32Values[key]; } function setBytes32(bytes32 key, bytes32 value) external onlyOrderWriter returns (bytes32) { bytes32Values[key] = value; return value; } function removeBytes32(bytes32 key) external onlyOrderWriter { delete bytes32Values[key]; } function getUintArray(bytes32 key) external view returns (uint256[] memory) { return uintArrayValues[key]; } function setUintArray(bytes32 key, uint256[] memory value) external onlyOrderWriter { uintArrayValues[key] = value; } function removeUintArray(bytes32 key) external onlyOrderWriter { delete uintArrayValues[key]; } function getIntArray(bytes32 key) external view returns (int256[] memory) { return intArrayValues[key]; } function setIntArray(bytes32 key, int256[] memory value) external onlyOrderWriter { intArrayValues[key] = value; } function removeIntArray(bytes32 key) external onlyOrderWriter { delete intArrayValues[key]; } function getAddressArray(bytes32 key) external view returns (address[] memory) { return addressArrayValues[key]; } function setAddressArray(bytes32 key, address[] memory value) external onlyOrderWriter { addressArrayValues[key] = value; } function removeAddressArray(bytes32 key) external onlyOrderWriter { delete addressArrayValues[key]; } function getBoolArray(bytes32 key) external view returns (bool[] memory) { return boolArrayValues[key]; } function setBoolArray(bytes32 key, bool[] memory value) external onlyOrderWriter { boolArrayValues[key] = value; } function removeBoolArray(bytes32 key) external onlyOrderWriter { delete boolArrayValues[key]; } function getStringArray(bytes32 key) external view returns (string[] memory) { return stringArrayValues[key]; } function setStringArray(bytes32 key, string[] memory value) external onlyOrderWriter { stringArrayValues[key] = value; } function removeStringArray(bytes32 key) external onlyOrderWriter { delete stringArrayValues[key]; } function getBytes32Array(bytes32 key) external view returns (bytes32[] memory) { return bytes32ArrayValues[key]; } function setBytes32Array(bytes32 key, bytes32[] memory value) external onlyOrderWriter { bytes32ArrayValues[key] = value; } function removeBytes32Array(bytes32 key) external onlyOrderWriter { delete bytes32ArrayValues[key]; } function containsAddress(bytes32 setKey, address value) external view returns (bool) { return addressSets[setKey].contains(value); } function getAddressCount(bytes32 setKey) external view returns (uint256) { return addressSets[setKey].length(); } function getAddressValuesAt(bytes32 setKey, uint256 start, uint256 end) external view returns (address[] memory) { return addressSets[setKey].valuesAt(start, end); } function addAddress(bytes32 setKey, address value) external onlyOrderWriter { addressSets[setKey].add(value); } function removeAddress(bytes32 setKey, address value) external onlyOrderWriter { addressSets[setKey].remove(value); } function containsBytes32(bytes32 setKey, bytes32 value) external view returns (bool) { return bytes32Sets[setKey].contains(value); } function getBytes32Count(bytes32 setKey) external view returns (uint256) { return bytes32Sets[setKey].length(); } function getBytes32ValuesAt(bytes32 setKey, uint256 start, uint256 end) external view returns (bytes32[] memory) { return bytes32Sets[setKey].valuesAt(start, end); } function addBytes32(bytes32 setKey, bytes32 value) external onlyOrderWriter { bytes32Sets[setKey].add(value); } function removeBytes32(bytes32 setKey, bytes32 value) external onlyOrderWriter { bytes32Sets[setKey].remove(value); } function containsUint(bytes32 setKey, uint256 value) external view returns (bool) { return uintSets[setKey].contains(value); } function getUintCount(bytes32 setKey) external view returns (uint256) { return uintSets[setKey].length(); } function getUintValuesAt(bytes32 setKey, uint256 start, uint256 end) external view returns (uint256[] memory) { return uintSets[setKey].valuesAt(start, end); } function addUint(bytes32 setKey, uint256 value) external onlyOrderWriter { uintSets[setKey].add(value); } function removeUint(bytes32 setKey, uint256 value) external onlyOrderWriter { uintSets[setKey].remove(value); } }contracts/oracle/IOracle.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "../oracle/PriceLib.sol"; interface IOracle { function batchSetPrice(address[] memory _tokens, uint256[] memory _prices) external; function batchSetPriceMM(address[] memory _tokens, PriceLib.Prices[] memory _prices) external; }@openzeppelin/contracts/utils/ReentrancyGuard.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (utils/ReentrancyGuard.sol) pragma solidity ^0.8.20; /** * @dev Contract module that helps prevent reentrant calls to a function. * * Inheriting from `ReentrancyGuard` will make the {nonReentrant} modifier * available, which can be applied to functions to make sure there are no nested * (reentrant) calls to them. * * Note that because there is a single `nonReentrant` guard, functions marked as * `nonReentrant` may not call one another. This can be worked around by making * those functions `private`, and then adding `external` `nonReentrant` entry * points to them. * * TIP: If EIP-1153 (transient storage) is available on the chain you're deploying at, * consider using {ReentrancyGuardTransient} instead. * * TIP: If you would like to learn more about reentrancy and alternative ways * to protect against it, check out our blog post * https://blog.openzeppelin.com/reentrancy-after-istanbul/[Reentrancy After Istanbul]. */ abstract contract ReentrancyGuard { // Booleans are more expensive than uint256 or any type that takes up a full // word because each write operation emits an extra SLOAD to first read the // slot's contents, replace the bits taken up by the boolean, and then write // back. This is the compiler's defense against contract upgrades and // pointer aliasing, and it cannot be disabled. // The values being non-zero value makes deployment a bit more expensive, // but in exchange the refund on every call to nonReentrant will be lower in // amount. Since refunds are capped to a percentage of the total // transaction's gas, it is best to keep them low in cases like this one, to // increase the likelihood of the full refund coming into effect. uint256 private constant NOT_ENTERED = 1; uint256 private constant ENTERED = 2; uint256 private _status; /** * @dev Unauthorized reentrant call. */ error ReentrancyGuardReentrantCall(); constructor() { _status = NOT_ENTERED; } /** * @dev Prevents a contract from calling itself, directly or indirectly. * Calling a `nonReentrant` function from another `nonReentrant` * function is not supported. It is possible to prevent this from happening * by making the `nonReentrant` function external, and making it call a * `private` function that does the actual work. */ modifier nonReentrant() { _nonReentrantBefore(); _; _nonReentrantAfter(); } function _nonReentrantBefore() private { // On the first call to nonReentrant, _status will be NOT_ENTERED if (_status == ENTERED) { revert ReentrancyGuardReentrantCall(); } // Any calls to nonReentrant after this point will fail _status = ENTERED; } function _nonReentrantAfter() private { // By storing the original value once again, a refund is triggered (see // https://eips.ethereum.org/EIPS/eip-2200) _status = NOT_ENTERED; } /** * @dev Returns true if the reentrancy guard is currently set to "entered", which indicates there is a * `nonReentrant` function in the call stack. */ function _reentrancyGuardEntered() internal view returns (bool) { return _status == ENTERED; } }contracts/order/IOrderVault.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; interface IOrderVault { function depositToken(address _token, uint256 _amount) external; function depositTokenFrom(address _from, address _token, uint256 _amount) external; function withdrawEth(address _to, uint256 _amount) external; function withdrawWeth(address _to, uint256 _amount) external; function withdrawToken(address _to, address _token, uint256 _amount) external; function balanceOfEth() external view returns (uint256); function balanceOfToken(address _token) external view returns (uint256); }contracts/position/IDecreasePositionHandler.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "./PositionLib.sol"; import "./PositionDao.sol"; interface IDecreasePositionHandler { function gov() external view returns (address); function isHandler(address _account) external view returns (bool); function decreasePosition(PositionLib.DecreasePositionCache memory cache) external returns (uint256); function liquidatePosition(PositionLib.LiquidatePositionCache memory cache) external; }@openzeppelin/contracts/utils/math/SafeCast.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (utils/math/SafeCast.sol) // This file was procedurally generated from scripts/generate/templates/SafeCast.js. pragma solidity ^0.8.20; /** * @dev Wrappers over Solidity's uintXX/intXX/bool casting operators with added overflow * checks. * * Downcasting from uint256/int256 in Solidity does not revert on overflow. This can * easily result in undesired exploitation or bugs, since developers usually * assume that overflows raise errors. `SafeCast` restores this intuition by * reverting the transaction when such an operation overflows. * * Using this library instead of the unchecked operations eliminates an entire * class of bugs, so it's recommended to use it always. */ library SafeCast { /** * @dev Value doesn't fit in an uint of `bits` size. */ error SafeCastOverflowedUintDowncast(uint8 bits, uint256 value); /** * @dev An int value doesn't fit in an uint of `bits` size. */ error SafeCastOverflowedIntToUint(int256 value); /** * @dev Value doesn't fit in an int of `bits` size. */ error SafeCastOverflowedIntDowncast(uint8 bits, int256 value); /** * @dev An uint value doesn't fit in an int of `bits` size. */ error SafeCastOverflowedUintToInt(uint256 value); /** * @dev Returns the downcasted uint248 from uint256, reverting on * overflow (when the input is greater than largest uint248). * * Counterpart to Solidity's `uint248` operator. * * Requirements: * * - input must fit into 248 bits */ function toUint248(uint256 value) internal pure returns (uint248) { if (value > type(uint248).max) { revert SafeCastOverflowedUintDowncast(248, value); } return uint248(value); } /** * @dev Returns the downcasted uint240 from uint256, reverting on * overflow (when the input is greater than largest uint240). * * Counterpart to Solidity's `uint240` operator. * * Requirements: * * - input must fit into 240 bits */ function toUint240(uint256 value) internal pure returns (uint240) { if (value > type(uint240).max) { revert SafeCastOverflowedUintDowncast(240, value); } return uint240(value); } /** * @dev Returns the downcasted uint232 from uint256, reverting on * overflow (when the input is greater than largest uint232). * * Counterpart to Solidity's `uint232` operator. * * Requirements: * * - input must fit into 232 bits */ function toUint232(uint256 value) internal pure returns (uint232) { if (value > type(uint232).max) { revert SafeCastOverflowedUintDowncast(232, value); } return uint232(value); } /** * @dev Returns the downcasted uint224 from uint256, reverting on * overflow (when the input is greater than largest uint224). * * Counterpart to Solidity's `uint224` operator. * * Requirements: * * - input must fit into 224 bits */ function toUint224(uint256 value) internal pure returns (uint224) { if (value > type(uint224).max) { revert SafeCastOverflowedUintDowncast(224, value); } return uint224(value); } /** * @dev Returns the downcasted uint216 from uint256, reverting on * overflow (when the input is greater than largest uint216). * * Counterpart to Solidity's `uint216` operator. * * Requirements: * * - input must fit into 216 bits */ function toUint216(uint256 value) internal pure returns (uint216) { if (value > type(uint216).max) { revert SafeCastOverflowedUintDowncast(216, value); } return uint216(value); } /** * @dev Returns the downcasted uint208 from uint256, reverting on * overflow (when the input is greater than largest uint208). * * Counterpart to Solidity's `uint208` operator. * * Requirements: * * - input must fit into 208 bits */ function toUint208(uint256 value) internal pure returns (uint208) { if (value > type(uint208).max) { revert SafeCastOverflowedUintDowncast(208, value); } return uint208(value); } /** * @dev Returns the downcasted uint200 from uint256, reverting on * overflow (when the input is greater than largest uint200). * * Counterpart to Solidity's `uint200` operator. * * Requirements: * * - input must fit into 200 bits */ function toUint200(uint256 value) internal pure returns (uint200) { if (value > type(uint200).max) { revert SafeCastOverflowedUintDowncast(200, value); } return uint200(value); } /** * @dev Returns the downcasted uint192 from uint256, reverting on * overflow (when the input is greater than largest uint192). * * Counterpart to Solidity's `uint192` operator. * * Requirements: * * - input must fit into 192 bits */ function toUint192(uint256 value) internal pure returns (uint192) { if (value > type(uint192).max) { revert SafeCastOverflowedUintDowncast(192, value); } return uint192(value); } /** * @dev Returns the downcasted uint184 from uint256, reverting on * overflow (when the input is greater than largest uint184). * * Counterpart to Solidity's `uint184` operator. * * Requirements: * * - input must fit into 184 bits */ function toUint184(uint256 value) internal pure returns (uint184) { if (value > type(uint184).max) { revert SafeCastOverflowedUintDowncast(184, value); } return uint184(value); } /** * @dev Returns the downcasted uint176 from uint256, reverting on * overflow (when the input is greater than largest uint176). * * Counterpart to Solidity's `uint176` operator. * * Requirements: * * - input must fit into 176 bits */ function toUint176(uint256 value) internal pure returns (uint176) { if (value > type(uint176).max) { revert SafeCastOverflowedUintDowncast(176, value); } return uint176(value); } /** * @dev Returns the downcasted uint168 from uint256, reverting on * overflow (when the input is greater than largest uint168). * * Counterpart to Solidity's `uint168` operator. * * Requirements: * * - input must fit into 168 bits */ function toUint168(uint256 value) internal pure returns (uint168) { if (value > type(uint168).max) { revert SafeCastOverflowedUintDowncast(168, value); } return uint168(value); } /** * @dev Returns the downcasted uint160 from uint256, reverting on * overflow (when the input is greater than largest uint160). * * Counterpart to Solidity's `uint160` operator. * * Requirements: * * - input must fit into 160 bits */ function toUint160(uint256 value) internal pure returns (uint160) { if (value > type(uint160).max) { revert SafeCastOverflowedUintDowncast(160, value); } return uint160(value); } /** * @dev Returns the downcasted uint152 from uint256, reverting on * overflow (when the input is greater than largest uint152). * * Counterpart to Solidity's `uint152` operator. * * Requirements: * * - input must fit into 152 bits */ function toUint152(uint256 value) internal pure returns (uint152) { if (value > type(uint152).max) { revert SafeCastOverflowedUintDowncast(152, value); } return uint152(value); } /** * @dev Returns the downcasted uint144 from uint256, reverting on * overflow (when the input is greater than largest uint144). * * Counterpart to Solidity's `uint144` operator. * * Requirements: * * - input must fit into 144 bits */ function toUint144(uint256 value) internal pure returns (uint144) { if (value > type(uint144).max) { revert SafeCastOverflowedUintDowncast(144, value); } return uint144(value); } /** * @dev Returns the downcasted uint136 from uint256, reverting on * overflow (when the input is greater than largest uint136). * * Counterpart to Solidity's `uint136` operator. * * Requirements: * * - input must fit into 136 bits */ function toUint136(uint256 value) internal pure returns (uint136) { if (value > type(uint136).max) { revert SafeCastOverflowedUintDowncast(136, value); } return uint136(value); } /** * @dev Returns the downcasted uint128 from uint256, reverting on * overflow (when the input is greater than largest uint128). * * Counterpart to Solidity's `uint128` operator. * * Requirements: * * - input must fit into 128 bits */ function toUint128(uint256 value) internal pure returns (uint128) { if (value > type(uint128).max) { revert SafeCastOverflowedUintDowncast(128, value); } return uint128(value); } /** * @dev Returns the downcasted uint120 from uint256, reverting on * overflow (when the input is greater than largest uint120). * * Counterpart to Solidity's `uint120` operator. * * Requirements: * * - input must fit into 120 bits */ function toUint120(uint256 value) internal pure returns (uint120) { if (value > type(uint120).max) { revert SafeCastOverflowedUintDowncast(120, value); } return uint120(value); } /** * @dev Returns the downcasted uint112 from uint256, reverting on * overflow (when the input is greater than largest uint112). * * Counterpart to Solidity's `uint112` operator. * * Requirements: * * - input must fit into 112 bits */ function toUint112(uint256 value) internal pure returns (uint112) { if (value > type(uint112).max) { revert SafeCastOverflowedUintDowncast(112, value); } return uint112(value); } /** * @dev Returns the downcasted uint104 from uint256, reverting on * overflow (when the input is greater than largest uint104). * * Counterpart to Solidity's `uint104` operator. * * Requirements: * * - input must fit into 104 bits */ function toUint104(uint256 value) internal pure returns (uint104) { if (value > type(uint104).max) { revert SafeCastOverflowedUintDowncast(104, value); } return uint104(value); } /** * @dev Returns the downcasted uint96 from uint256, reverting on * overflow (when the input is greater than largest uint96). * * Counterpart to Solidity's `uint96` operator. * * Requirements: * * - input must fit into 96 bits */ function toUint96(uint256 value) internal pure returns (uint96) { if (value > type(uint96).max) { revert SafeCastOverflowedUintDowncast(96, value); } return uint96(value); } /** * @dev Returns the downcasted uint88 from uint256, reverting on * overflow (when the input is greater than largest uint88). * * Counterpart to Solidity's `uint88` operator. * * Requirements: * * - input must fit into 88 bits */ function toUint88(uint256 value) internal pure returns (uint88) { if (value > type(uint88).max) { revert SafeCastOverflowedUintDowncast(88, value); } return uint88(value); } /** * @dev Returns the downcasted uint80 from uint256, reverting on * overflow (when the input is greater than largest uint80). * * Counterpart to Solidity's `uint80` operator. * * Requirements: * * - input must fit into 80 bits */ function toUint80(uint256 value) internal pure returns (uint80) { if (value > type(uint80).max) { revert SafeCastOverflowedUintDowncast(80, value); } return uint80(value); } /** * @dev Returns the downcasted uint72 from uint256, reverting on * overflow (when the input is greater than largest uint72). * * Counterpart to Solidity's `uint72` operator. * * Requirements: * * - input must fit into 72 bits */ function toUint72(uint256 value) internal pure returns (uint72) { if (value > type(uint72).max) { revert SafeCastOverflowedUintDowncast(72, value); } return uint72(value); } /** * @dev Returns the downcasted uint64 from uint256, reverting on * overflow (when the input is greater than largest uint64). * * Counterpart to Solidity's `uint64` operator. * * Requirements: * * - input must fit into 64 bits */ function toUint64(uint256 value) internal pure returns (uint64) { if (value > type(uint64).max) { revert SafeCastOverflowedUintDowncast(64, value); } return uint64(value); } /** * @dev Returns the downcasted uint56 from uint256, reverting on * overflow (when the input is greater than largest uint56). * * Counterpart to Solidity's `uint56` operator. * * Requirements: * * - input must fit into 56 bits */ function toUint56(uint256 value) internal pure returns (uint56) { if (value > type(uint56).max) { revert SafeCastOverflowedUintDowncast(56, value); } return uint56(value); } /** * @dev Returns the downcasted uint48 from uint256, reverting on * overflow (when the input is greater than largest uint48). * * Counterpart to Solidity's `uint48` operator. * * Requirements: * * - input must fit into 48 bits */ function toUint48(uint256 value) internal pure returns (uint48) { if (value > type(uint48).max) { revert SafeCastOverflowedUintDowncast(48, value); } return uint48(value); } /** * @dev Returns the downcasted uint40 from uint256, reverting on * overflow (when the input is greater than largest uint40). * * Counterpart to Solidity's `uint40` operator. * * Requirements: * * - input must fit into 40 bits */ function toUint40(uint256 value) internal pure returns (uint40) { if (value > type(uint40).max) { revert SafeCastOverflowedUintDowncast(40, value); } return uint40(value); } /** * @dev Returns the downcasted uint32 from uint256, reverting on * overflow (when the input is greater than largest uint32). * * Counterpart to Solidity's `uint32` operator. * * Requirements: * * - input must fit into 32 bits */ function toUint32(uint256 value) internal pure returns (uint32) { if (value > type(uint32).max) { revert SafeCastOverflowedUintDowncast(32, value); } return uint32(value); } /** * @dev Returns the downcasted uint24 from uint256, reverting on * overflow (when the input is greater than largest uint24). * * Counterpart to Solidity's `uint24` operator. * * Requirements: * * - input must fit into 24 bits */ function toUint24(uint256 value) internal pure returns (uint24) { if (value > type(uint24).max) { revert SafeCastOverflowedUintDowncast(24, value); } return uint24(value); } /** * @dev Returns the downcasted uint16 from uint256, reverting on * overflow (when the input is greater than largest uint16). * * Counterpart to Solidity's `uint16` operator. * * Requirements: * * - input must fit into 16 bits */ function toUint16(uint256 value) internal pure returns (uint16) { if (value > type(uint16).max) { revert SafeCastOverflowedUintDowncast(16, value); } return uint16(value); } /** * @dev Returns the downcasted uint8 from uint256, reverting on * overflow (when the input is greater than largest uint8). * * Counterpart to Solidity's `uint8` operator. * * Requirements: * * - input must fit into 8 bits */ function toUint8(uint256 value) internal pure returns (uint8) { if (value > type(uint8).max) { revert SafeCastOverflowedUintDowncast(8, value); } return uint8(value); } /** * @dev Converts a signed int256 into an unsigned uint256. * * Requirements: * * - input must be greater than or equal to 0. */ function toUint256(int256 value) internal pure returns (uint256) { if (value < 0) { revert SafeCastOverflowedIntToUint(value); } return uint256(value); } /** * @dev Returns the downcasted int248 from int256, reverting on * overflow (when the input is less than smallest int248 or * greater than largest int248). * * Counterpart to Solidity's `int248` operator. * * Requirements: * * - input must fit into 248 bits */ function toInt248(int256 value) internal pure returns (int248 downcasted) { downcasted = int248(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(248, value); } } /** * @dev Returns the downcasted int240 from int256, reverting on * overflow (when the input is less than smallest int240 or * greater than largest int240). * * Counterpart to Solidity's `int240` operator. * * Requirements: * * - input must fit into 240 bits */ function toInt240(int256 value) internal pure returns (int240 downcasted) { downcasted = int240(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(240, value); } } /** * @dev Returns the downcasted int232 from int256, reverting on * overflow (when the input is less than smallest int232 or * greater than largest int232). * * Counterpart to Solidity's `int232` operator. * * Requirements: * * - input must fit into 232 bits */ function toInt232(int256 value) internal pure returns (int232 downcasted) { downcasted = int232(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(232, value); } } /** * @dev Returns the downcasted int224 from int256, reverting on * overflow (when the input is less than smallest int224 or * greater than largest int224). * * Counterpart to Solidity's `int224` operator. * * Requirements: * * - input must fit into 224 bits */ function toInt224(int256 value) internal pure returns (int224 downcasted) { downcasted = int224(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(224, value); } } /** * @dev Returns the downcasted int216 from int256, reverting on * overflow (when the input is less than smallest int216 or * greater than largest int216). * * Counterpart to Solidity's `int216` operator. * * Requirements: * * - input must fit into 216 bits */ function toInt216(int256 value) internal pure returns (int216 downcasted) { downcasted = int216(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(216, value); } } /** * @dev Returns the downcasted int208 from int256, reverting on * overflow (when the input is less than smallest int208 or * greater than largest int208). * * Counterpart to Solidity's `int208` operator. * * Requirements: * * - input must fit into 208 bits */ function toInt208(int256 value) internal pure returns (int208 downcasted) { downcasted = int208(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(208, value); } } /** * @dev Returns the downcasted int200 from int256, reverting on * overflow (when the input is less than smallest int200 or * greater than largest int200). * * Counterpart to Solidity's `int200` operator. * * Requirements: * * - input must fit into 200 bits */ function toInt200(int256 value) internal pure returns (int200 downcasted) { downcasted = int200(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(200, value); } } /** * @dev Returns the downcasted int192 from int256, reverting on * overflow (when the input is less than smallest int192 or * greater than largest int192). * * Counterpart to Solidity's `int192` operator. * * Requirements: * * - input must fit into 192 bits */ function toInt192(int256 value) internal pure returns (int192 downcasted) { downcasted = int192(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(192, value); } } /** * @dev Returns the downcasted int184 from int256, reverting on * overflow (when the input is less than smallest int184 or * greater than largest int184). * * Counterpart to Solidity's `int184` operator. * * Requirements: * * - input must fit into 184 bits */ function toInt184(int256 value) internal pure returns (int184 downcasted) { downcasted = int184(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(184, value); } } /** * @dev Returns the downcasted int176 from int256, reverting on * overflow (when the input is less than smallest int176 or * greater than largest int176). * * Counterpart to Solidity's `int176` operator. * * Requirements: * * - input must fit into 176 bits */ function toInt176(int256 value) internal pure returns (int176 downcasted) { downcasted = int176(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(176, value); } } /** * @dev Returns the downcasted int168 from int256, reverting on * overflow (when the input is less than smallest int168 or * greater than largest int168). * * Counterpart to Solidity's `int168` operator. * * Requirements: * * - input must fit into 168 bits */ function toInt168(int256 value) internal pure returns (int168 downcasted) { downcasted = int168(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(168, value); } } /** * @dev Returns the downcasted int160 from int256, reverting on * overflow (when the input is less than smallest int160 or * greater than largest int160). * * Counterpart to Solidity's `int160` operator. * * Requirements: * * - input must fit into 160 bits */ function toInt160(int256 value) internal pure returns (int160 downcasted) { downcasted = int160(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(160, value); } } /** * @dev Returns the downcasted int152 from int256, reverting on * overflow (when the input is less than smallest int152 or * greater than largest int152). * * Counterpart to Solidity's `int152` operator. * * Requirements: * * - input must fit into 152 bits */ function toInt152(int256 value) internal pure returns (int152 downcasted) { downcasted = int152(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(152, value); } } /** * @dev Returns the downcasted int144 from int256, reverting on * overflow (when the input is less than smallest int144 or * greater than largest int144). * * Counterpart to Solidity's `int144` operator. * * Requirements: * * - input must fit into 144 bits */ function toInt144(int256 value) internal pure returns (int144 downcasted) { downcasted = int144(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(144, value); } } /** * @dev Returns the downcasted int136 from int256, reverting on * overflow (when the input is less than smallest int136 or * greater than largest int136). * * Counterpart to Solidity's `int136` operator. * * Requirements: * * - input must fit into 136 bits */ function toInt136(int256 value) internal pure returns (int136 downcasted) { downcasted = int136(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(136, value); } } /** * @dev Returns the downcasted int128 from int256, reverting on * overflow (when the input is less than smallest int128 or * greater than largest int128). * * Counterpart to Solidity's `int128` operator. * * Requirements: * * - input must fit into 128 bits */ function toInt128(int256 value) internal pure returns (int128 downcasted) { downcasted = int128(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(128, value); } } /** * @dev Returns the downcasted int120 from int256, reverting on * overflow (when the input is less than smallest int120 or * greater than largest int120). * * Counterpart to Solidity's `int120` operator. * * Requirements: * * - input must fit into 120 bits */ function toInt120(int256 value) internal pure returns (int120 downcasted) { downcasted = int120(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(120, value); } } /** * @dev Returns the downcasted int112 from int256, reverting on * overflow (when the input is less than smallest int112 or * greater than largest int112). * * Counterpart to Solidity's `int112` operator. * * Requirements: * * - input must fit into 112 bits */ function toInt112(int256 value) internal pure returns (int112 downcasted) { downcasted = int112(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(112, value); } } /** * @dev Returns the downcasted int104 from int256, reverting on * overflow (when the input is less than smallest int104 or * greater than largest int104). * * Counterpart to Solidity's `int104` operator. * * Requirements: * * - input must fit into 104 bits */ function toInt104(int256 value) internal pure returns (int104 downcasted) { downcasted = int104(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(104, value); } } /** * @dev Returns the downcasted int96 from int256, reverting on * overflow (when the input is less than smallest int96 or * greater than largest int96). * * Counterpart to Solidity's `int96` operator. * * Requirements: * * - input must fit into 96 bits */ function toInt96(int256 value) internal pure returns (int96 downcasted) { downcasted = int96(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(96, value); } } /** * @dev Returns the downcasted int88 from int256, reverting on * overflow (when the input is less than smallest int88 or * greater than largest int88). * * Counterpart to Solidity's `int88` operator. * * Requirements: * * - input must fit into 88 bits */ function toInt88(int256 value) internal pure returns (int88 downcasted) { downcasted = int88(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(88, value); } } /** * @dev Returns the downcasted int80 from int256, reverting on * overflow (when the input is less than smallest int80 or * greater than largest int80). * * Counterpart to Solidity's `int80` operator. * * Requirements: * * - input must fit into 80 bits */ function toInt80(int256 value) internal pure returns (int80 downcasted) { downcasted = int80(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(80, value); } } /** * @dev Returns the downcasted int72 from int256, reverting on * overflow (when the input is less than smallest int72 or * greater than largest int72). * * Counterpart to Solidity's `int72` operator. * * Requirements: * * - input must fit into 72 bits */ function toInt72(int256 value) internal pure returns (int72 downcasted) { downcasted = int72(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(72, value); } } /** * @dev Returns the downcasted int64 from int256, reverting on * overflow (when the input is less than smallest int64 or * greater than largest int64). * * Counterpart to Solidity's `int64` operator. * * Requirements: * * - input must fit into 64 bits */ function toInt64(int256 value) internal pure returns (int64 downcasted) { downcasted = int64(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(64, value); } } /** * @dev Returns the downcasted int56 from int256, reverting on * overflow (when the input is less than smallest int56 or * greater than largest int56). * * Counterpart to Solidity's `int56` operator. * * Requirements: * * - input must fit into 56 bits */ function toInt56(int256 value) internal pure returns (int56 downcasted) { downcasted = int56(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(56, value); } } /** * @dev Returns the downcasted int48 from int256, reverting on * overflow (when the input is less than smallest int48 or * greater than largest int48). * * Counterpart to Solidity's `int48` operator. * * Requirements: * * - input must fit into 48 bits */ function toInt48(int256 value) internal pure returns (int48 downcasted) { downcasted = int48(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(48, value); } } /** * @dev Returns the downcasted int40 from int256, reverting on * overflow (when the input is less than smallest int40 or * greater than largest int40). * * Counterpart to Solidity's `int40` operator. * * Requirements: * * - input must fit into 40 bits */ function toInt40(int256 value) internal pure returns (int40 downcasted) { downcasted = int40(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(40, value); } } /** * @dev Returns the downcasted int32 from int256, reverting on * overflow (when the input is less than smallest int32 or * greater than largest int32). * * Counterpart to Solidity's `int32` operator. * * Requirements: * * - input must fit into 32 bits */ function toInt32(int256 value) internal pure returns (int32 downcasted) { downcasted = int32(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(32, value); } } /** * @dev Returns the downcasted int24 from int256, reverting on * overflow (when the input is less than smallest int24 or * greater than largest int24). * * Counterpart to Solidity's `int24` operator. * * Requirements: * * - input must fit into 24 bits */ function toInt24(int256 value) internal pure returns (int24 downcasted) { downcasted = int24(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(24, value); } } /** * @dev Returns the downcasted int16 from int256, reverting on * overflow (when the input is less than smallest int16 or * greater than largest int16). * * Counterpart to Solidity's `int16` operator. * * Requirements: * * - input must fit into 16 bits */ function toInt16(int256 value) internal pure returns (int16 downcasted) { downcasted = int16(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(16, value); } } /** * @dev Returns the downcasted int8 from int256, reverting on * overflow (when the input is less than smallest int8 or * greater than largest int8). * * Counterpart to Solidity's `int8` operator. * * Requirements: * * - input must fit into 8 bits */ function toInt8(int256 value) internal pure returns (int8 downcasted) { downcasted = int8(value); if (downcasted != value) { revert SafeCastOverflowedIntDowncast(8, value); } } /** * @dev Converts an unsigned uint256 into a signed int256. * * Requirements: * * - input must be less than or equal to maxInt256. */ function toInt256(uint256 value) internal pure returns (int256) { // Note: Unsafe cast below is okay because `type(int256).max` is guaranteed to be positive if (value > uint256(type(int256).max)) { revert SafeCastOverflowedUintToInt(value); } return int256(value); } /** * @dev Cast a boolean (false or true) to a uint256 (0 or 1) with no jump. */ function toUint(bool b) internal pure returns (uint256 u) { assembly ("memory-safe") { u := iszero(iszero(b)) } } }contracts/base/CustomAddress.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; /** * @dev Collection of functions related to the address type */ library CustomAddress { /** * @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) { // This method relies on extcodesize, which returns 0 for contracts in // construction, since the code is only stored at the end of the // constructor execution. uint256 size; // solhint-disable-next-line no-inline-assembly assembly { size := extcodesize(account) } return size > 0; } /** * @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"); } /** * @dev Performs a Solidity function call using a low level `call`. A * plain`call` is an unsafe replacement for a function call: use this * function instead. * * If `target` reverts with a revert reason, it is bubbled up by this * function (like regular Solidity function calls). * * Returns the raw returned data. To convert to the expected return value, * use https://solidity.readthedocs.io/en/latest/units-and-global-variables.html?highlight=abi.decode#abi-encoding-and-decoding-functions[`abi.decode`]. * * Requirements: * * - `target` must be a contract. * - calling `target` with `data` must not revert. * * _Available since v3.1._ */ function functionCall(address target, bytes memory data) internal returns (bytes memory) { return functionCall(target, data, "Address: low-level call failed"); } /** * @dev Same as {xref-CustomAddress.sol-functionCall-address-bytes-}[`functionCall`], but with * `errorMessage` as a fallback revert reason when `target` reverts. * * _Available since v3.1._ */ function functionCall(address target, bytes memory data, string memory errorMessage) internal returns (bytes memory) { return functionCallWithValue(target, data, 0, errorMessage); } /** * @dev Same as {xref-CustomAddress.sol-functionCall-address-bytes-}[`functionCall`], * but also transferring `value` wei to `target`. * * Requirements: * * - the calling contract must have an ETH balance of at least `value`. * - the called Solidity function must be `payable`. * * _Available since v3.1._ */ function functionCallWithValue(address target, bytes memory data, uint256 value) internal returns (bytes memory) { return functionCallWithValue(target, data, value, "Address: low-level call with value failed"); } /** * @dev Same as {xref-CustomAddress.sol-functionCallWithValue-address-bytes-uint256-}[`functionCallWithValue`], but * with `errorMessage` as a fallback revert reason when `target` reverts. * * _Available since v3.1._ */ function functionCallWithValue(address target, bytes memory data, uint256 value, string memory errorMessage) internal returns (bytes memory) { require(address(this).balance >= value, "Address: insufficient balance for call"); require(isContract(target), "Address: call to non-contract"); // solhint-disable-next-line avoid-low-level-calls (bool success, bytes memory returndata) = target.call{ value: value }(data); return _verifyCallResult(success, returndata, errorMessage); } /** * @dev Same as {xref-CustomAddress.sol-functionCall-address-bytes-}[`functionCall`], * but performing a static call. * * _Available since v3.3._ */ function functionStaticCall(address target, bytes memory data) internal view returns (bytes memory) { return functionStaticCall(target, data, "Address: low-level static call failed"); } /** * @dev Same as {xref-CustomAddress.sol-functionCall-address-bytes-string-}[`functionCall`], * but performing a static call. * * _Available since v3.3._ */ function functionStaticCall(address target, bytes memory data, string memory errorMessage) internal view returns (bytes memory) { require(isContract(target), "Address: static call to non-contract"); // solhint-disable-next-line avoid-low-level-calls (bool success, bytes memory returndata) = target.staticcall(data); return _verifyCallResult(success, returndata, errorMessage); } /** * @dev Same as {xref-CustomAddress.sol-functionCall-address-bytes-}[`functionCall`], * but performing a delegate call. * * _Available since v3.3._ */ function functionDelegateCall(address target, bytes memory data) internal returns (bytes memory) { return functionDelegateCall(target, data, "Address: low-level delegate call failed"); } /** * @dev Same as {xref-CustomAddress.sol-functionCall-address-bytes-string-}[`functionCall`], * but performing a delegate call. * * _Available since v3.3._ */ function functionDelegateCall(address target, bytes memory data, string memory errorMessage) internal returns (bytes memory) { require(isContract(target), "Address: delegate call to non-contract"); // solhint-disable-next-line avoid-low-level-calls (bool success, bytes memory returndata) = target.delegatecall(data); return _verifyCallResult(success, returndata, errorMessage); } function _verifyCallResult(bool success, bytes memory returndata, string memory errorMessage) private pure returns(bytes memory) { if (success) { return returndata; } else { // Look for revert reason and bubble it up if present if (returndata.length > 0) { // The easiest way to bubble the revert reason is using memory via assembly // solhint-disable-next-line no-inline-assembly assembly { let returndata_size := mload(returndata) revert(add(32, returndata), returndata_size) } } else { revert(errorMessage); } } } }@openzeppelin/contracts/utils/Comparators.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (utils/Comparators.sol) pragma solidity ^0.8.20; /** * @dev Provides a set of functions to compare values. * * _Available since v5.1._ */ library Comparators { function lt(uint256 a, uint256 b) internal pure returns (bool) { return a < b; } function gt(uint256 a, uint256 b) internal pure returns (bool) { return a > b; } }contracts/utils/EnumerableValues.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "@openzeppelin/contracts/utils/structs/EnumerableSet.sol"; library EnumerableValues { using EnumerableSet for EnumerableSet.Bytes32Set; using EnumerableSet for EnumerableSet.AddressSet; using EnumerableSet for EnumerableSet.UintSet; function valuesAt(EnumerableSet.Bytes32Set storage set, uint256 start, uint256 end) internal view returns (bytes32[] memory) { uint256 max = set.length(); if (end > max) { end = max; } bytes32[] memory items = new bytes32[](end - start); for (uint256 i = start; i < end; i++) { items[i - start] = set.at(i); } return items; } function valuesAt(EnumerableSet.AddressSet storage set, uint256 start, uint256 end) internal view returns (address[] memory) { uint256 max = set.length(); if (end > max) { end = max; } address[] memory items = new address[](end - start); for (uint256 i = start; i < end; i++) { items[i - start] = set.at(i); } return items; } function valuesAt(EnumerableSet.UintSet storage set, uint256 start, uint256 end) internal view returns (uint256[] memory) { if (start >= set.length()) { return new uint256[](0); } uint256 max = set.length(); if (end > max) { end = max; } uint256[] memory items = new uint256[](end - start); for (uint256 i = start; i < end; i++) { items[i - start] = set.at(i); } return items; } }contracts/repo/DataBase.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "./RoleBase.sol"; import "../utils/EnumerableValues.sol"; import "../utils/Role.sol"; contract DataBase { using EnumerableSet for EnumerableSet.Bytes32Set; using EnumerableSet for EnumerableSet.AddressSet; using EnumerableSet for EnumerableSet.UintSet; using EnumerableValues for EnumerableSet.Bytes32Set; using EnumerableValues for EnumerableSet.AddressSet; using EnumerableValues for EnumerableSet.UintSet; RoleBase roleBase; mapping(bytes32 => uint256) public uintValues; mapping(bytes32 => int256) public intValues; mapping(bytes32 => address) public addressValues; mapping(bytes32 => bool) public boolValues; mapping(bytes32 => string) public stringValues; mapping(bytes32 => bytes32) public bytes32Values; mapping(bytes32 => uint256[]) public uintArrayValues; mapping(bytes32 => int256[]) public intArrayValues; mapping(bytes32 => address[]) public addressArrayValues; mapping(bytes32 => bool[]) public boolArrayValues; mapping(bytes32 => string[]) public stringArrayValues; mapping(bytes32 => bytes32[]) public bytes32ArrayValues; mapping(bytes32 => EnumerableSet.AddressSet) internal addressSets; mapping(bytes32 => EnumerableSet.Bytes32Set) internal bytes32Sets; mapping(bytes32 => EnumerableSet.UintSet) internal uintSets; error UnauthorizedDataWrite(address account); modifier onlyDataWriter() { if (!roleBase.hasRole(msg.sender, Role.ROLE_DATA_WRITE)) { revert UnauthorizedDataWrite(msg.sender); } _; } constructor(RoleBase _roleBase) { roleBase = _roleBase; } function getUint(bytes32 key) external view returns (uint256) { return uintValues[key]; } function setUint(bytes32 key, uint256 value) external onlyDataWriter returns (uint256) { uintValues[key] = value; return value; } function removeUint(bytes32 key) external onlyDataWriter { delete uintValues[key]; } function addDeltaToUint(bytes32 key, int256 value, string memory errMsg) external onlyDataWriter returns (uint256) { uint256 curValue = uintValues[key]; if (value < 0 && uint256(-value) > curValue) { revert(errMsg); } uint256 nextUint; if (value >= 0) { nextUint = curValue + uint256(value); } else { nextUint = curValue - uint256(-value); } uintValues[key] = nextUint; return nextUint; } function incrementUint(bytes32 key, uint256 value) external onlyDataWriter returns (uint256) { uint256 nextUint = uintValues[key] + value; uintValues[key] = nextUint; return nextUint; } function decrementUint(bytes32 key, uint256 value) external onlyDataWriter returns (uint256) { uint256 nextUint = uintValues[key] - value; uintValues[key] = nextUint; return nextUint; } function getInt(bytes32 key) external view returns (int256) { return intValues[key]; } function setInt(bytes32 key, int256 value) external onlyDataWriter returns (int256) { intValues[key] = value; return value; } function removeInt(bytes32 key) external onlyDataWriter { delete intValues[key]; } function incrementInt(bytes32 key, int256 value) external onlyDataWriter returns (int256) { int256 nextInt = intValues[key] + value; intValues[key] = nextInt; return nextInt; } function decrementInt(bytes32 key, int256 value) external onlyDataWriter returns (int256) { int256 nextInt = intValues[key] - value; intValues[key] = nextInt; return nextInt; } function getAddress(bytes32 key) external view returns (address) { return addressValues[key]; } function setAddress(bytes32 key, address value) external onlyDataWriter returns (address) { addressValues[key] = value; return value; } function removeAddress(bytes32 key) external onlyDataWriter { delete addressValues[key]; } function getBool(bytes32 key) external view returns (bool) { return boolValues[key]; } function setBool(bytes32 key, bool value) external onlyDataWriter returns (bool) { boolValues[key] = value; return value; } function removeBool(bytes32 key) external onlyDataWriter { delete boolValues[key]; } function getString(bytes32 key) external view returns (string memory) { return stringValues[key]; } function setString(bytes32 key, string memory value) external onlyDataWriter returns (string memory) { stringValues[key] = value; return value; } function removeString(bytes32 key) external onlyDataWriter { delete stringValues[key]; } function getBytes32(bytes32 key) external view returns (bytes32) { return bytes32Values[key]; } function setBytes32(bytes32 key, bytes32 value) external onlyDataWriter returns (bytes32) { bytes32Values[key] = value; return value; } function removeBytes32(bytes32 key) external onlyDataWriter { delete bytes32Values[key]; } function getUintArray(bytes32 key) external view returns (uint256[] memory) { return uintArrayValues[key]; } function setUintArray(bytes32 key, uint256[] memory value) external onlyDataWriter { uintArrayValues[key] = value; } function removeUintArray(bytes32 key) external onlyDataWriter { delete uintArrayValues[key]; } function getIntArray(bytes32 key) external view returns (int256[] memory) { return intArrayValues[key]; } function setIntArray(bytes32 key, int256[] memory value) external onlyDataWriter { intArrayValues[key] = value; } function removeIntArray(bytes32 key) external onlyDataWriter { delete intArrayValues[key]; } function getAddressArray(bytes32 key) external view returns (address[] memory) { return addressArrayValues[key]; } function setAddressArray(bytes32 key, address[] memory value) external onlyDataWriter { addressArrayValues[key] = value; } function removeAddressArray(bytes32 key) external onlyDataWriter { delete addressArrayValues[key]; } function getBoolArray(bytes32 key) external view returns (bool[] memory) { return boolArrayValues[key]; } function setBoolArray(bytes32 key, bool[] memory value) external onlyDataWriter { boolArrayValues[key] = value; } function removeBoolArray(bytes32 key) external onlyDataWriter { delete boolArrayValues[key]; } function getStringArray(bytes32 key) external view returns (string[] memory) { return stringArrayValues[key]; } function setStringArray(bytes32 key, string[] memory value) external onlyDataWriter { stringArrayValues[key] = value; } function removeStringArray(bytes32 key) external onlyDataWriter { delete stringArrayValues[key]; } function getBytes32Array(bytes32 key) external view returns (bytes32[] memory) { return bytes32ArrayValues[key]; } function setBytes32Array(bytes32 key, bytes32[] memory value) external onlyDataWriter { bytes32ArrayValues[key] = value; } function removeBytes32Array(bytes32 key) external onlyDataWriter { delete bytes32ArrayValues[key]; } function containsAddress(bytes32 setKey, address value) external view returns (bool) { return addressSets[setKey].contains(value); } function getAddressCount(bytes32 setKey) external view returns (uint256) { return addressSets[setKey].length(); } function getAddressValuesAt(bytes32 setKey, uint256 start, uint256 end) external view returns (address[] memory) { return addressSets[setKey].valuesAt(start, end); } function addAddress(bytes32 setKey, address value) external onlyDataWriter { addressSets[setKey].add(value); } function removeAddress(bytes32 setKey, address value) external onlyDataWriter { addressSets[setKey].remove(value); } function containsBytes32(bytes32 setKey, bytes32 value) external view returns (bool) { return bytes32Sets[setKey].contains(value); } function getBytes32Count(bytes32 setKey) external view returns (uint256) { return bytes32Sets[setKey].length(); } function getBytes32ValuesAt(bytes32 setKey, uint256 start, uint256 end) external view returns (bytes32[] memory) { return bytes32Sets[setKey].valuesAt(start, end); } function addBytes32(bytes32 setKey, bytes32 value) external onlyDataWriter { bytes32Sets[setKey].add(value); } function removeBytes32(bytes32 setKey, bytes32 value) external onlyDataWriter { bytes32Sets[setKey].remove(value); } function containsUint(bytes32 setKey, uint256 value) external view returns (bool) { return uintSets[setKey].contains(value); } function getUintCount(bytes32 setKey) external view returns (uint256) { return uintSets[setKey].length(); } function getUintValuesAt(bytes32 setKey, uint256 start, uint256 end) external view returns (uint256[] memory) { return uintSets[setKey].valuesAt(start, end); } function addUint(bytes32 setKey, uint256 value) external onlyDataWriter { uintSets[setKey].add(value); } function removeUint(bytes32 setKey, uint256 value) external onlyDataWriter { uintSets[setKey].remove(value); } }@openzeppelin/contracts/utils/StorageSlot.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (utils/StorageSlot.sol) // This file was procedurally generated from scripts/generate/templates/StorageSlot.js. pragma solidity ^0.8.20; /** * @dev Library for reading and writing primitive types to specific storage slots. * * Storage slots are often used to avoid storage conflict when dealing with upgradeable contracts. * This library helps with reading and writing to such slots without the need for inline assembly. * * The functions in this library return Slot structs that contain a `value` member that can be used to read or write. * * Example usage to set ERC-1967 implementation slot: * ```solidity * contract ERC1967 { * // Define the slot. Alternatively, use the SlotDerivation library to derive the slot. * bytes32 internal constant _IMPLEMENTATION_SLOT = 0x360894a13ba1a3210667c828492db98dca3e2076cc3735a920a3ca505d382bbc; * * function _getImplementation() internal view returns (address) { * return StorageSlot.getAddressSlot(_IMPLEMENTATION_SLOT).value; * } * * function _setImplementation(address newImplementation) internal { * require(newImplementation.code.length > 0); * StorageSlot.getAddressSlot(_IMPLEMENTATION_SLOT).value = newImplementation; * } * } * ``` * * TIP: Consider using this library along with {SlotDerivation}. */ library StorageSlot { struct AddressSlot { address value; } struct BooleanSlot { bool value; } struct Bytes32Slot { bytes32 value; } struct Uint256Slot { uint256 value; } struct Int256Slot { int256 value; } struct StringSlot { string value; } struct BytesSlot { bytes value; } /** * @dev Returns an `AddressSlot` with member `value` located at `slot`. */ function getAddressSlot(bytes32 slot) internal pure returns (AddressSlot storage r) { assembly ("memory-safe") { r.slot := slot } } /** * @dev Returns a `BooleanSlot` with member `value` located at `slot`. */ function getBooleanSlot(bytes32 slot) internal pure returns (BooleanSlot storage r) { assembly ("memory-safe") { r.slot := slot } } /** * @dev Returns a `Bytes32Slot` with member `value` located at `slot`. */ function getBytes32Slot(bytes32 slot) internal pure returns (Bytes32Slot storage r) { assembly ("memory-safe") { r.slot := slot } } /** * @dev Returns a `Uint256Slot` with member `value` located at `slot`. */ function getUint256Slot(bytes32 slot) internal pure returns (Uint256Slot storage r) { assembly ("memory-safe") { r.slot := slot } } /** * @dev Returns a `Int256Slot` with member `value` located at `slot`. */ function getInt256Slot(bytes32 slot) internal pure returns (Int256Slot storage r) { assembly ("memory-safe") { r.slot := slot } } /** * @dev Returns a `StringSlot` with member `value` located at `slot`. */ function getStringSlot(bytes32 slot) internal pure returns (StringSlot storage r) { assembly ("memory-safe") { r.slot := slot } } /** * @dev Returns an `StringSlot` representation of the string storage pointer `store`. */ function getStringSlot(string storage store) internal pure returns (StringSlot storage r) { assembly ("memory-safe") { r.slot := store.slot } } /** * @dev Returns a `BytesSlot` with member `value` located at `slot`. */ function getBytesSlot(bytes32 slot) internal pure returns (BytesSlot storage r) { assembly ("memory-safe") { r.slot := slot } } /** * @dev Returns an `BytesSlot` representation of the bytes storage pointer `store`. */ function getBytesSlot(bytes storage store) internal pure returns (BytesSlot storage r) { assembly ("memory-safe") { r.slot := store.slot } } }contracts/position/PositionLib.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "@openzeppelin/contracts/token/ERC20/IERC20.sol"; import "@openzeppelin/contracts/token/ERC20/utils/SafeERC20.sol"; import {DataBase} from "../repo/DataBase.sol"; import "../utils/Keys.sol"; import "../repo/Dao.sol"; import "../pool/IPoolToken.sol"; import "../oracle/PriceLib.sol"; import "../vault/VaultLib.sol"; import "../exception/Errs.sol"; library PositionLib { struct Position { address account; address poolToken; address indexToken; address collateralToken; uint256 size; uint256 collateral; uint256 collateralAmount; uint256 averagePrice; uint256 entryFundingRate; uint256 reserveAmount; int256 realisedPnl; uint256 lastIncreasedTime; bool isLong; } struct PositionOut { bytes32 key; address poolToken; address indexToken; address collateralToken; bool isLong; uint256 size; uint256 collateral; uint256 collateralAmount; uint256 averagePrice; uint256 entryFundingRate; bool hasRealisedProfit; uint256 realisedPnl; uint256 lastIncreasedTime; bool hasProfit; uint256 profitDelta; } struct IncreasePositionRequest { address account; address poolToken; address indexToken; address collateralToken; uint256 sizeDelta; uint256 collateralAmount; bool isLong; } struct IncreasePositionCache { address account; address poolToken; address indexToken; address collateralToken; uint256 sizeDelta; bool isLong; } struct DecreasePositionCache { address account; address poolToken; address indexToken; address collateralToken; uint256 collateralDelta; uint256 sizeDelta; bool isLong; address receiver; } struct DecreasePositionRequest { address account; address poolToken; address indexToken; address collateralToken; uint256 collateralDelta; uint256 sizeDelta; bool isLong; address receiver; } struct LiquidatePositionCache { address account; address poolToken; address indexToken; address collateralToken; bool isLong; address feeReceiver; } struct MarginFeeParams { address account; address poolToken; address indexToken; address collateralToken; uint256 size; uint256 sizeDelta; uint256 entryFundingRate; bool isLong; } uint256 public constant BASIS_POINTS_DIVISOR = 10000; uint256 public constant FUNDING_RATE_PRECISION = 1000000; error MustBeWithdrawn(); error LessThanCollateral(); function getPositionKey(address _account, address _poolToken, address _collateralToken, address _indexToken, bool _isLong) internal pure returns (bytes32) { return keccak256(abi.encodePacked( _account, _poolToken, _collateralToken, _indexToken, _isLong )); } function getNextAveragePrice(DataBase _dataBase, address _indexToken, uint256 _size, uint256 _averagePrice, bool _isLong, uint256 _nextPrice, uint256 _sizeDelta, uint256 _lastIncreasedTime) internal view returns (uint256) { (bool hasProfit, uint256 delta) = getDelta(_dataBase, _indexToken, _size, _averagePrice, _isLong, _lastIncreasedTime); uint256 nextSize = _size + _sizeDelta; uint256 divisor; if (_isLong) { divisor = hasProfit ? (nextSize + delta) : (nextSize - delta); } else { divisor = hasProfit ? (nextSize - delta) : (nextSize + delta); } return _nextPrice * nextSize / divisor; } function getDelta(DataBase _dataBase, address _indexToken, uint256 _size, uint256 _averagePrice, bool _isLong, uint256 /*_lastIncreasedTime*/) internal view returns (bool, uint256) { if (_averagePrice <= 0) { revert Errs.InvalidAveragePrice(); } uint256 price = _isLong ? PriceLib.pricesMin(_dataBase, _indexToken) : PriceLib.pricesMax(_dataBase, _indexToken); uint256 priceDelta = _averagePrice > price ? (_averagePrice - price) : (price - _averagePrice); uint256 delta = _size * priceDelta / _averagePrice; bool hasProfit; if (_isLong) { hasProfit = price > _averagePrice; } else { hasProfit = _averagePrice > price; } // // if the minProfitTime has passed then there will be no min profit threshold // // the min profit threshold helps to prevent front-running issues // uint256 minBps = block.timestamp > _lastIncreasedTime.add(minProfitTime) ? 0 : minProfitBasisPoints[_indexToken]; // if (hasProfit && delta.mul(BASIS_POINTS_DIVISOR) <= _size.mul(minBps)) { // delta = 0; // } return (hasProfit, delta); } // struct Position { // address account; // address poolToken; // address indexToken; // address collateralToken; // uint256 size; // uint256 collateral; // uint256 averagePrice; // uint256 entryFundingRate; // uint256 reserveAmount; // int256 realisedPnl; // uint256 lastIncreasedTime; // bool isLong; // } bytes32 public constant POS_ACCOUNT = keccak256(abi.encode("POS_ACCOUNT")); bytes32 public constant POS_POOL = keccak256(abi.encode("POS_POOL")); bytes32 public constant POS_INDEX = keccak256(abi.encode("POS_INDEX")); bytes32 public constant POS_COLLATERAL = keccak256(abi.encode("POS_COLLATERAL")); bytes32 public constant POS_SIZE = keccak256(abi.encode("POS_SIZE")); bytes32 public constant POS_COLLATERAL_USD = keccak256(abi.encode("POS_COLLATERAL_USD")); bytes32 public constant POS_COLLATERAL_AMOUNT = keccak256(abi.encode("POS_COLLATERAL_AMOUNT")); bytes32 public constant POS_AVERAGE_PRICE = keccak256(abi.encode("POS_AVERAGE_PRICE")); bytes32 public constant POS_ENTRY_FUNDING_RATE = keccak256(abi.encode("POS_ENTRY_FUNDING_RATE")); bytes32 public constant POS_RESERVE_AMOUNT = keccak256(abi.encode("POS_RESERVE_AMOUNT")); bytes32 public constant POS_REALISED_PNL = keccak256(abi.encode("POS_REALISED_PNL")); bytes32 public constant POS_LAST_INCREASED_TIME = keccak256(abi.encode("POS_LAST_INCREASED_TIME")); bytes32 public constant POS_IS_LONG = keccak256(abi.encode("POS_IS_LONG")); function savePosition(DataBase _dataBase, Position memory _position) internal { bytes32 _posKey = getPositionKey(_position.account, _position.poolToken, _position.collateralToken, _position.indexToken, _position.isLong); addBytes32(_dataBase, Keys.accountPositionList(_position.account, _position.poolToken), _posKey); addBytes32(_dataBase, Keys.poolPositionList(_position.poolToken), _posKey); setFieldAccount(_dataBase, _posKey, _position.account); setFieldPool(_dataBase, _posKey, _position.poolToken); setFieldIndex(_dataBase, _posKey, _position.indexToken); setFieldCollateral(_dataBase, _posKey, _position.collateralToken); setFieldSize(_dataBase, _posKey, _position.size); setFieldCollateralUsd(_dataBase, _posKey, _position.collateral); setFieldCollateralAmount(_dataBase, _posKey, _position.collateralAmount); setFieldAveragePrice(_dataBase, _posKey, _position.averagePrice); setFieldEntryFundingRate(_dataBase, _posKey, _position.entryFundingRate); setFieldReserveAmount(_dataBase, _posKey, _position.reserveAmount); setFieldRealisedPnl(_dataBase, _posKey, _position.realisedPnl); setFieldLastIncreasedTime(_dataBase, _posKey, _position.lastIncreasedTime); setFieldIsLong(_dataBase, _posKey, _position.isLong); } function removePosition(DataBase _dataBase, address _account, address _poolToken, bytes32 _posKey) internal { removeBytes32(_dataBase, Keys.accountPositionList(_account, _poolToken), _posKey); removeBytes32(_dataBase, Keys.poolPositionList(_poolToken), _posKey); _dataBase.removeAddress(keccak256(abi.encode(POS_ACCOUNT, _posKey))); _dataBase.removeAddress(keccak256(abi.encode(POS_POOL, _posKey))); _dataBase.removeAddress(keccak256(abi.encode(POS_INDEX, _posKey))); _dataBase.removeAddress(keccak256(abi.encode(POS_COLLATERAL, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_SIZE, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_COLLATERAL_USD, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_COLLATERAL_AMOUNT, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_AVERAGE_PRICE, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_ENTRY_FUNDING_RATE, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_RESERVE_AMOUNT, _posKey))); _dataBase.removeInt(keccak256(abi.encode(POS_REALISED_PNL, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_LAST_INCREASED_TIME, _posKey))); _dataBase.removeBool(keccak256(abi.encode(POS_IS_LONG, _posKey))); } function getPosition(DataBase _dataBase, bytes32 _posKey) internal view returns (Position memory) { Position memory position = Position({ account: getFieldAccount(_dataBase, _posKey), poolToken: getFieldPool(_dataBase, _posKey), indexToken: getFieldIndex(_dataBase, _posKey), collateralToken: getFieldCollateral(_dataBase, _posKey), size: getFieldSize(_dataBase, _posKey), collateral: getFieldCollateralUsd(_dataBase, _posKey), collateralAmount: getFieldCollateralAmount(_dataBase, _posKey), averagePrice: getFieldAveragePrice(_dataBase, _posKey), entryFundingRate: getFieldEntryFundingRate(_dataBase, _posKey), reserveAmount: getFieldReserveAmount(_dataBase, _posKey), realisedPnl: getFieldRealisedPnl(_dataBase, _posKey), lastIncreasedTime: getFieldLastIncreasedTime(_dataBase, _posKey), isLong: getFieldIsLong(_dataBase, _posKey) }); return position; } function getPositionFields(DataBase _dataBase, address _account, address _poolToken, address _collateralToken, address _indexToken, bool _isLong) internal view returns (uint256, uint256) { bytes32 _posKey = getPositionKey(_account, _poolToken, _collateralToken, _indexToken, _isLong); return (getFieldSize(_dataBase, _posKey), getFieldCollateralUsd(_dataBase, _posKey)); } function setFieldAccount(DataBase _dataBase, bytes32 _posKey, address _value) internal { setAddress(_dataBase, keccak256(abi.encode(POS_ACCOUNT, _posKey)), _value); } function getFieldAccount(DataBase _dataBase, bytes32 _posKey) internal view returns (address) { return _dataBase.getAddress(keccak256(abi.encode(POS_ACCOUNT, _posKey))); } function setFieldPool(DataBase _dataBase, bytes32 _posKey, address _value) internal { setAddress(_dataBase, keccak256(abi.encode(POS_POOL, _posKey)), _value); } function getFieldPool(DataBase _dataBase, bytes32 _posKey) internal view returns (address) { return _dataBase.getAddress(keccak256(abi.encode(POS_POOL, _posKey))); } function setFieldIndex(DataBase _dataBase, bytes32 _posKey, address _value) internal { setAddress(_dataBase, keccak256(abi.encode(POS_INDEX, _posKey)), _value); } function getFieldIndex(DataBase _dataBase, bytes32 _posKey) internal view returns (address) { return _dataBase.getAddress(keccak256(abi.encode(POS_INDEX, _posKey))); } function setFieldCollateral(DataBase _dataBase, bytes32 _posKey, address _value) internal { setAddress(_dataBase, keccak256(abi.encode(POS_COLLATERAL, _posKey)), _value); } function getFieldCollateral(DataBase _dataBase, bytes32 _posKey) internal view returns (address) { return _dataBase.getAddress(keccak256(abi.encode(POS_COLLATERAL, _posKey))); } function setFieldSize(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_SIZE, _posKey)), _value); } function getFieldSize(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_SIZE, _posKey))); } function setFieldCollateralUsd(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_COLLATERAL_USD, _posKey)), _value); } function getFieldCollateralUsd(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_COLLATERAL_USD, _posKey))); } function setFieldCollateralAmount(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_COLLATERAL_AMOUNT, _posKey)), _value); } function getFieldCollateralAmount(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_COLLATERAL_AMOUNT, _posKey))); } function setFieldAveragePrice(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_AVERAGE_PRICE, _posKey)), _value); } function getFieldAveragePrice(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_AVERAGE_PRICE, _posKey))); } function setFieldEntryFundingRate(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_ENTRY_FUNDING_RATE, _posKey)), _value); } function getFieldEntryFundingRate(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_ENTRY_FUNDING_RATE, _posKey))); } function setFieldReserveAmount(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_RESERVE_AMOUNT, _posKey)), _value); } function getFieldReserveAmount(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_RESERVE_AMOUNT, _posKey))); } function setFieldRealisedPnl(DataBase _dataBase, bytes32 _posKey, int256 _value) internal { setInt(_dataBase, keccak256(abi.encode(POS_REALISED_PNL, _posKey)), _value); } function getFieldRealisedPnl(DataBase _dataBase, bytes32 _posKey) internal view returns (int256) { return _dataBase.getInt(keccak256(abi.encode(POS_REALISED_PNL, _posKey))); } function setFieldLastIncreasedTime(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_LAST_INCREASED_TIME, _posKey)), _value); } function getFieldLastIncreasedTime(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_LAST_INCREASED_TIME, _posKey))); } function setFieldIsLong(DataBase _dataBase, bytes32 _posKey, bool _value) internal { setBool(_dataBase, keccak256(abi.encode(POS_IS_LONG, _posKey)), _value); } function getFieldIsLong(DataBase _dataBase, bytes32 _posKey) internal view returns (bool) { return _dataBase.getBool(keccak256(abi.encode(POS_IS_LONG, _posKey))); } // bytes32 public constant POS_IS_LONG = keccak256(abi.encode("POS_IS_LONG")); function addBytes32(DataBase _dataBase, bytes32 _setKey, bytes32 _value) internal { if (!_dataBase.containsBytes32(_setKey, _value)) { _dataBase.addBytes32(_setKey, _value); } } function removeBytes32(DataBase _dataBase, bytes32 _setKey, bytes32 _value) internal { if (!_dataBase.containsBytes32(_setKey, _value)) { _dataBase.removeBytes32(_setKey, _value); } } function setAddress(DataBase _dataBase, bytes32 _key, address _value) internal { if (_dataBase.getAddress(_key) != _value) { _dataBase.setAddress(_key, _value); } } function setUint(DataBase _dataBase, bytes32 _key, uint256 _value) internal { if (_dataBase.getUint(_key) != _value) { _dataBase.setUint(_key, _value); } } function setInt(DataBase _dataBase, bytes32 _key, int256 _value) internal { if (_dataBase.getInt(_key) != _value) { _dataBase.setInt(_key, _value); } } function setBool(DataBase _dataBase, bytes32 _key, bool _value) internal { if (_dataBase.getBool(_key) != _value) { _dataBase.setBool(_key, _value); } } function addPositionKey(DataBase _dataBase, address _account, address _poolToken, bytes32 _key) internal { Dao.addBytes32(_dataBase, Keys.accountPositionList(_account, _poolToken), _key); } function removePositionKey(DataBase _dataBase, address _account, address _poolToken, bytes32 _key) internal { Dao.removeBytes32(_dataBase, Keys.accountPositionList(_account, _poolToken), _key); } function getPositionKeys(DataBase _dataBase, address _account, address _poolToken) internal view returns (bytes32[] memory) { uint256 positionCount = Dao.getBytes32Count(_dataBase, Keys.accountPositionList(_account, _poolToken)); return Dao.getBytes32ValuesAt(_dataBase, Keys.accountPositionList(_account, _poolToken), 0, positionCount); } function getPositionFee(DataBase _dataBase, address /* _account */, address _poolToken, address /* _collateralToken */, address /* _indexToken */, bool /* _isLong */, uint256 _sizeDelta) internal view returns (uint256) { if (_sizeDelta == 0) { return 0; } uint256 afterFeeUsd = _sizeDelta * (BASIS_POINTS_DIVISOR - Dao.marginFeeBasisPoints(_dataBase, _poolToken)) / BASIS_POINTS_DIVISOR; return _sizeDelta - afterFeeUsd; } function getFundingFee(DataBase _dataBase, address /* _account */, address _poolToken, address _collateralToken, address /* _indexToken */, bool /* _isLong */, uint256 _size, uint256 _entryFundingRate) internal view returns (uint256) { if (_size == 0) { return 0; } uint256 fundingRate = Dao.fundingRate(_dataBase, _poolToken, _collateralToken) - _entryFundingRate; if (fundingRate == 0) { return 0; } return _size * fundingRate / FUNDING_RATE_PRECISION; } function getEntryFundingRate(DataBase _dataBase, address _poolToken, address _collateralToken, address /* _indexToken */, bool /* _isLong */) internal view returns (uint256) { return Dao.fundingRate(_dataBase, _poolToken, _collateralToken); } // function validateLiquidation(address _account, address _poolToken, address _collateralToken, address _indexToken, bool _isLong, bool _raise) public view override returns (uint256, uint256) function validateLiquidation(DataBase _dataBase, Position memory position, bool _raise) internal view returns (uint256, uint256) { (bool hasProfit, uint256 delta) = getDelta(_dataBase, position.indexToken, position.size, position.averagePrice, position.isLong, position.lastIncreasedTime); uint256 marginFees = getFundingFee(_dataBase, position.account, position.poolToken, position.collateralToken, position.indexToken, position.isLong, position.size, position.entryFundingRate); marginFees = marginFees + getPositionFee(_dataBase, position.account, position.poolToken, position.collateralToken, position.indexToken, position.isLong, position.size); if (!hasProfit && position.collateral < delta) { if (_raise) { revert Errs.LossesExceedCollateral(); } return (1, marginFees); } uint256 remainingCollateral = position.collateral; if (!hasProfit) { remainingCollateral = position.collateral - delta; } if (remainingCollateral < marginFees) { if (_raise) { revert Errs.FeesExceedCollateral(); } // cap the fees to the remainingCollateral return (1, remainingCollateral); } if (remainingCollateral < (marginFees + Dao.liquidationFeeUsd(_dataBase, position.poolToken))) { if (_raise) { revert Errs.LiquidationFeesExceedCollateral(); } return (1, marginFees); } if (remainingCollateral * Dao.maxLeverage(_dataBase, position.poolToken, position.indexToken) < position.size * BASIS_POINTS_DIVISOR) { if (_raise) { revert Errs.MaxLeverageExceeded(); } return (2, marginFees); } return (0, marginFees); } function shouldDeductFee( DataBase _dataBase, address _account, address _poolToken, address[] memory _path, uint256 _amountIn, address _indexToken, bool _isLong, uint256 _sizeDelta, uint256 _increasePositionBufferBps ) internal view returns (bool) { // if the position is a short, do not charge a fee if (!_isLong) { return false; } // if the position size is not increasing, this is a collateral deposit if (_sizeDelta == 0) { return true; } address collateralToken = _path[_path.length - 1]; (uint256 size, uint256 collateral) = getPositionFields(_dataBase, _account, _poolToken, collateralToken, _indexToken, _isLong); // if there is no existing position, do not charge a fee if (size == 0) { return false; } uint256 nextSize = size + _sizeDelta; uint256 collateralDelta = PriceLib.tokenToUsdMin(_dataBase, collateralToken, Dao.tokenDecimals(_dataBase, collateralToken), _amountIn); uint256 nextCollateral = collateral + collateralDelta; uint256 prevLeverage = size * BASIS_POINTS_DIVISOR / collateral; // allow for a maximum of a increasePositionBufferBps decrease since there might be some swap fees taken from the collateral uint256 nextLeverage = nextSize * (BASIS_POINTS_DIVISOR + _increasePositionBufferBps) / nextCollateral; // emit LeverageDecreased(collateralDelta, prevLeverage, nextLeverage); // deduct a fee if the leverage is decreased return nextLeverage < prevLeverage; } function validateTokens(DataBase _dataBase, address _poolToken, address _indexToken, address _collateralToken) internal view { if (!_dataBase.containsAddress(Keys.indexTokenList(_poolToken), _indexToken)) { revert Errs.InvalidIndexToken(); } if (!_dataBase.containsAddress(Keys.stableTokenList(_poolToken), _collateralToken)) { revert Errs.InvalidStableToken(); } } function validatePosition(uint256 _size, uint256 _collateral) internal pure { if (_size == 0) { if (_collateral > 0) { revert MustBeWithdrawn(); } return; } if (_size < _collateral) { revert LessThanCollateral(); } } }contracts/position/IIncreasePositionHandler.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "./PositionLib.sol"; interface IIncreasePositionHandler { function gov() external view returns (address); function isHandler(address _account) external view returns (bool); function increasePosition(PositionLib.IncreasePositionCache memory cache) external; }contracts/order/OrderUtils.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "./OrderBase.sol"; import "./OrderDao.sol"; import "../event/OrderLogger.sol"; library OrderUtils { function createIncreaseOrder( OrderBase _orderBase, address _account, address _poolToken, address _purchaseToken, uint256 _purchaseTokenAmount, address _collateralToken, address _indexToken, uint256 _sizeDelta, bool _isLong, uint256 _triggerPrice, bool _triggerAboveThreshold, uint256 _executionFee ) internal returns (uint256, bytes32) { uint256 _orderIndex = OrderDao.getIncreaseIndex(_orderBase, _account, _poolToken); OrderDao.setIncreaseIndex(_orderBase, _account, _poolToken, _orderIndex + 1); bytes32 _positionKey = OrderDao.getPositionKey(_account, _poolToken, _collateralToken, _indexToken, _isLong); OrderDao.IncreaseOrder memory _order = OrderDao.IncreaseOrder( _account, _poolToken, _purchaseToken, _purchaseTokenAmount, _collateralToken, _indexToken, _sizeDelta, _isLong, _triggerPrice, _triggerAboveThreshold, _executionFee, _orderIndex, block.timestamp, _positionKey ); OrderDao.saveIncreaseOrder(_orderBase, _order, OrderDao.getOrderKey(_account, _orderIndex, _poolToken, OrderDao.ORDER_TYPE_INCREASE) ); return (_orderIndex, _positionKey); } function createDecreaseOrder( OrderBase _orderBase, address _account, address _poolToken, address _collateralToken, uint256 _collateralDelta, address _indexToken, uint256 _sizeDelta, bool _isLong, uint256 _triggerPrice, bool _triggerAboveThreshold, uint256 _executionFee ) internal returns (uint256, bytes32) { uint256 _orderIndex = OrderDao.getDecreaseIndex(_orderBase, _account, _poolToken); OrderDao.setDecreaseIndex(_orderBase, _account, _poolToken, _orderIndex + 1); bytes32 _positionKey = OrderDao.getPositionKey(_account, _poolToken, _collateralToken, _indexToken, _isLong); OrderDao.DecreaseOrder memory _order = OrderDao.DecreaseOrder( _account, _poolToken, _collateralToken, _collateralDelta, _indexToken, _sizeDelta, _isLong, _triggerPrice, _triggerAboveThreshold, _executionFee, _orderIndex, block.timestamp, _positionKey ); OrderDao.saveDecreaseOrder(_orderBase, _order, OrderDao.getOrderKey(_account, _orderIndex, _poolToken, OrderDao.ORDER_TYPE_DECREASE) ); return (_orderIndex, _positionKey); } }contracts/pool/IPoolToken.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; interface IPoolToken { function transferOut(address _token, address _to, uint256 _amount) external; function mint(address _account, uint256 _amount) external; function burn(address _account, uint256 _amount) external; }contracts/order/OrderDao.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "./OrderBase.sol"; //import "hardhat/console.sol"; library OrderDao { struct IncreaseOrder { address account; address poolToken; address purchaseToken; uint256 purchaseTokenAmount; address collateralToken; address indexToken; uint256 sizeDelta; bool isLong; uint256 triggerPrice; bool triggerAboveThreshold; uint256 executionFee; uint256 index; uint256 timestamp; bytes32 positionKey; } struct DecreaseOrder { address account; address poolToken; address collateralToken; uint256 collateralDelta; address indexToken; uint256 sizeDelta; bool isLong; uint256 triggerPrice; bool triggerAboveThreshold; uint256 executionFee; uint256 index; uint256 timestamp; bytes32 positionKey; } struct SwapOrder { address account; address poolToken; address[] path; uint256 amountIn; uint256 minOut; uint256 triggerRatio; bool triggerAboveThreshold; bool shouldUnwrap; uint256 executionFee; uint256 index; uint256 timestamp; bytes32 positionKey; } uint256 public constant ORDER_TYPE_INCREASE = 1; uint256 public constant ORDER_TYPE_DECREASE = 2; uint256 public constant ORDER_TYPE_SWAP = 3; bytes32 public constant POOL_INCREASE_ORDER_LIST = keccak256(abi.encode("POOL_INCREASE_ORDER_LIST")); bytes32 public constant POOL_INCREASE_MODIFY_LIST = keccak256(abi.encode("POOL_INCREASE_MODIFY_LIST")); bytes32 public constant POOL_DECREASE_ORDER_LIST = keccak256(abi.encode("POOL_DECREASE_ORDER_LIST")); bytes32 public constant POOL_DECREASE_MODIFY_LIST = keccak256(abi.encode("POOL_DECREASE_MODIFY_LIST")); bytes32 public constant ACCOUNT_INCREASE_ORDER_LIST = keccak256(abi.encode("ACCOUNT_INCREASE_ORDER_LIST")); bytes32 public constant ACCOUNT_DECREASE_ORDER_LIST = keccak256(abi.encode("ACCOUNT_DECREASE_ORDER_LIST")); bytes32 public constant INCREASE_ORDER_INDEX = keccak256(abi.encode("INCREASE_ORDER_INDEX")); bytes32 public constant DECREASE_ORDER_INDEX = keccak256(abi.encode("DECREASE_ORDER_INDEX")); bytes32 public constant FIELD_ORDER_TYPE = keccak256(abi.encode("FIELD_ORDER_TYPE")); bytes32 public constant FIELD_POSITION = keccak256(abi.encode("FIELD_POSITION")); bytes32 public constant FIELD_ACCOUNT = keccak256(abi.encode("FIELD_ACCOUNT")); bytes32 public constant FIELD_POOL = keccak256(abi.encode("FIELD_POOL")); bytes32 public constant FIELD_PURCHASE_TOKEN = keccak256(abi.encode("FIELD_PURCHASE_TOKEN")); bytes32 public constant FIELD_PURCHASE_AMOUNT = keccak256(abi.encode("FIELD_PURCHASE_AMOUNT")); bytes32 public constant FIELD_COLLATERAL_TOKEN = keccak256(abi.encode("FIELD_COLLATERAL_TOKEN")); bytes32 public constant FIELD_COLLATERAL_DELTA = keccak256(abi.encode("FIELD_COLLATERAL_DELTA")); bytes32 public constant FIELD_INDEX_TOKEN = keccak256(abi.encode("FIELD_INDEX_TOKEN")); bytes32 public constant FIELD_SIZE_DELTA = keccak256(abi.encode("FIELD_SIZE_DELTA")); bytes32 public constant FIELD_IS_LONG = keccak256(abi.encode("FIELD_IS_LONG")); bytes32 public constant FIELD_TRIGGER_PRICE = keccak256(abi.encode("FIELD_TRIGGER_PRICE")); bytes32 public constant FIELD_TRIGGER_ABOVE_THRESHOLD = keccak256(abi.encode("FIELD_TRIGGER_ABOVE_THRESHOLD")); bytes32 public constant FIELD_EXECUTION_FEE = keccak256(abi.encode("FIELD_EXECUTION_FEE")); bytes32 public constant FIELD_INDEX = keccak256(abi.encode("FIELD_INDEX")); bytes32 public constant FIELD_TIMESTAMP = keccak256(abi.encode("FIELD_TIMESTAMP")); function getOrderKey(address _account, uint256 _index, address _poolToken, uint256 _orderType) internal pure returns (bytes32) { return keccak256(abi.encodePacked( _account, _index, _poolToken, _orderType )); } function getPositionKey(address _account, address _poolToken, address _collateralToken, address _indexToken, bool _isLong) internal pure returns (bytes32) { return keccak256(abi.encodePacked( _account, _poolToken, _collateralToken, _indexToken, _isLong )); } function saveIncreaseOrder(OrderBase _orderBase, IncreaseOrder memory _order, bytes32 _orderKey) internal { addBytes32(_orderBase, keccak256(abi.encode(POOL_INCREASE_ORDER_LIST, _order.poolToken)), _orderKey); addBytes32(_orderBase, keccak256(abi.encode(ACCOUNT_INCREASE_ORDER_LIST, _order.account, _order.poolToken)), _orderKey); setFieldPositionKey(_orderBase, _orderKey, _order.positionKey); setFieldOrderType(_orderBase, _orderKey, ORDER_TYPE_INCREASE); setFieldAccount(_orderBase, _orderKey, _order.account); setFieldPool(_orderBase, _orderKey, _order.poolToken); setFieldPurchaseToken(_orderBase, _orderKey, _order.purchaseToken); setFieldPurchaseAmount(_orderBase, _orderKey, _order.purchaseTokenAmount); setFieldCollateralToken(_orderBase, _orderKey, _order.collateralToken); setFieldIndexToken(_orderBase, _orderKey, _order.indexToken); setFieldSizeDelta(_orderBase, _orderKey, _order.sizeDelta); setFieldIsLong(_orderBase, _orderKey, _order.isLong); setFieldTriggerPrice(_orderBase, _orderKey, _order.triggerPrice); setFieldTriggerAboveThreshold(_orderBase, _orderKey, _order.triggerAboveThreshold); setFieldExecutionFee(_orderBase, _orderKey, _order.executionFee); setFieldIndex(_orderBase, _orderKey, _order.index); setFieldTimestamp(_orderBase, _orderKey, _order.timestamp); } function updateIncreaseOrder(OrderBase _orderBase, IncreaseOrder memory _order, bytes32 _orderKey) internal { removeBytes32(_orderBase, keccak256(abi.encode(POOL_INCREASE_MODIFY_LIST, _order.poolToken)), _orderKey); addBytes32(_orderBase, keccak256(abi.encode(POOL_INCREASE_MODIFY_LIST, _order.poolToken)), _orderKey); setFieldSizeDelta(_orderBase, _orderKey, _order.sizeDelta); setFieldTriggerPrice(_orderBase, _orderKey, _order.triggerPrice); setFieldTriggerAboveThreshold(_orderBase, _orderKey, _order.triggerAboveThreshold); setFieldTimestamp(_orderBase, _orderKey, _order.timestamp); } function removeIncreaseOrder(OrderBase _orderBase, address _account, address _poolToken, bytes32 _orderKey) internal { removeBytes32(_orderBase, keccak256(abi.encode(POOL_INCREASE_ORDER_LIST, _poolToken)), _orderKey); removeBytes32(_orderBase, keccak256(abi.encode(POOL_INCREASE_MODIFY_LIST, _poolToken)), _orderKey); removeBytes32(_orderBase, keccak256(abi.encode(ACCOUNT_INCREASE_ORDER_LIST, _account, _poolToken)), _orderKey); _orderBase.removeBytes32(keccak256(abi.encode(FIELD_POSITION, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_ORDER_TYPE, _orderKey))); _orderBase.removeAddress(keccak256(abi.encode(FIELD_ACCOUNT, _orderKey))); _orderBase.removeAddress(keccak256(abi.encode(FIELD_POOL, _orderKey))); _orderBase.removeAddress(keccak256(abi.encode(FIELD_PURCHASE_TOKEN, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_PURCHASE_AMOUNT, _orderKey))); _orderBase.removeAddress(keccak256(abi.encode(FIELD_COLLATERAL_TOKEN, _orderKey))); _orderBase.removeAddress(keccak256(abi.encode(FIELD_INDEX_TOKEN, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_SIZE_DELTA, _orderKey))); _orderBase.removeBool(keccak256(abi.encode(FIELD_IS_LONG, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_TRIGGER_PRICE, _orderKey))); _orderBase.removeBool(keccak256(abi.encode(FIELD_TRIGGER_ABOVE_THRESHOLD, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_EXECUTION_FEE, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_INDEX, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_TIMESTAMP, _orderKey))); } function getIncreaseOrder(OrderBase _orderBase, bytes32 _orderKey) internal view returns (IncreaseOrder memory) { IncreaseOrder memory order = IncreaseOrder({ account: getFieldAccount(_orderBase, _orderKey), poolToken: getFieldPool(_orderBase, _orderKey), purchaseToken: getFieldPurchaseToken(_orderBase, _orderKey), purchaseTokenAmount: getFieldPurchaseAmount(_orderBase, _orderKey), collateralToken: getFieldCollateralToken(_orderBase, _orderKey), indexToken: getFieldIndexToken(_orderBase, _orderKey), sizeDelta: getFieldSizeDelta(_orderBase, _orderKey), isLong: getFieldIsLong(_orderBase, _orderKey), triggerPrice: getFieldTriggerPrice(_orderBase, _orderKey), triggerAboveThreshold: getFieldTriggerAboveThreshold(_orderBase, _orderKey), executionFee: getFieldExecutionFee(_orderBase, _orderKey), index: getFieldIndex(_orderBase, _orderKey), timestamp: getFieldTimestamp(_orderBase, _orderKey), positionKey: getFieldPositionKey(_orderBase, _orderKey) }); return order; } function saveDecreaseOrder(OrderBase _orderBase, DecreaseOrder memory _order, bytes32 _orderKey) internal { addBytes32(_orderBase, keccak256(abi.encode(POOL_DECREASE_ORDER_LIST, _order.poolToken)), _orderKey); addBytes32(_orderBase, keccak256(abi.encode(ACCOUNT_DECREASE_ORDER_LIST, _order.account, _order.poolToken)), _orderKey); setFieldPositionKey(_orderBase, _orderKey, _order.positionKey); setFieldOrderType(_orderBase, _orderKey, ORDER_TYPE_DECREASE); setFieldAccount(_orderBase, _orderKey, _order.account); setFieldPool(_orderBase, _orderKey, _order.poolToken); setFieldCollateralToken(_orderBase, _orderKey, _order.collateralToken); setFieldCollateralDelta(_orderBase, _orderKey, _order.collateralDelta); setFieldIndexToken(_orderBase, _orderKey, _order.indexToken); setFieldSizeDelta(_orderBase, _orderKey, _order.sizeDelta); setFieldIsLong(_orderBase, _orderKey, _order.isLong); setFieldTriggerPrice(_orderBase, _orderKey, _order.triggerPrice); setFieldTriggerAboveThreshold(_orderBase, _orderKey, _order.triggerAboveThreshold); setFieldExecutionFee(_orderBase, _orderKey, _order.executionFee); setFieldIndex(_orderBase, _orderKey, _order.index); setFieldTimestamp(_orderBase, _orderKey, _order.timestamp); } function updateDecreaseOrder(OrderBase _orderBase, DecreaseOrder memory _order, bytes32 _orderKey) internal { removeBytes32(_orderBase, keccak256(abi.encode(POOL_DECREASE_MODIFY_LIST, _order.poolToken)), _orderKey); addBytes32(_orderBase, keccak256(abi.encode(POOL_DECREASE_MODIFY_LIST, _order.poolToken)), _orderKey); setFieldSizeDelta(_orderBase, _orderKey, _order.sizeDelta); setFieldCollateralDelta(_orderBase, _orderKey, _order.collateralDelta); setFieldTriggerPrice(_orderBase, _orderKey, _order.triggerPrice); setFieldTriggerAboveThreshold(_orderBase, _orderKey, _order.triggerAboveThreshold); setFieldTimestamp(_orderBase, _orderKey, _order.timestamp); } function removeDecreaseOrder(OrderBase _orderBase, address _account, address _poolToken, bytes32 _orderKey) internal { removeBytes32(_orderBase, keccak256(abi.encode(POOL_DECREASE_ORDER_LIST, _poolToken)), _orderKey); removeBytes32(_orderBase, keccak256(abi.encode(POOL_DECREASE_MODIFY_LIST, _poolToken)), _orderKey); removeBytes32(_orderBase, keccak256(abi.encode(ACCOUNT_DECREASE_ORDER_LIST, _account, _poolToken)), _orderKey); _orderBase.removeBytes32(keccak256(abi.encode(FIELD_POSITION, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_ORDER_TYPE, _orderKey))); _orderBase.removeAddress(keccak256(abi.encode(FIELD_ACCOUNT, _orderKey))); _orderBase.removeAddress(keccak256(abi.encode(FIELD_POOL, _orderKey))); _orderBase.removeAddress(keccak256(abi.encode(FIELD_COLLATERAL_TOKEN, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_COLLATERAL_DELTA, _orderKey))); _orderBase.removeAddress(keccak256(abi.encode(FIELD_INDEX_TOKEN, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_SIZE_DELTA, _orderKey))); _orderBase.removeBool(keccak256(abi.encode(FIELD_IS_LONG, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_TRIGGER_PRICE, _orderKey))); _orderBase.removeBool(keccak256(abi.encode(FIELD_TRIGGER_ABOVE_THRESHOLD, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_EXECUTION_FEE, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_INDEX, _orderKey))); _orderBase.removeUint(keccak256(abi.encode(FIELD_TIMESTAMP, _orderKey))); } function getDecreaseOrder(OrderBase _orderBase, bytes32 _orderKey) internal view returns (DecreaseOrder memory) { DecreaseOrder memory order = DecreaseOrder({ account: getFieldAccount(_orderBase, _orderKey), poolToken: getFieldPool(_orderBase, _orderKey), collateralToken: getFieldCollateralToken(_orderBase, _orderKey), collateralDelta: getFieldCollateralDelta(_orderBase, _orderKey), indexToken: getFieldIndexToken(_orderBase, _orderKey), sizeDelta: getFieldSizeDelta(_orderBase, _orderKey), isLong: getFieldIsLong(_orderBase, _orderKey), triggerPrice: getFieldTriggerPrice(_orderBase, _orderKey), triggerAboveThreshold: getFieldTriggerAboveThreshold(_orderBase, _orderKey), executionFee: getFieldExecutionFee(_orderBase, _orderKey), index: getFieldIndex(_orderBase, _orderKey), timestamp: getFieldTimestamp(_orderBase, _orderKey), positionKey: getFieldPositionKey(_orderBase, _orderKey) }); return order; } function setFieldPositionKey(OrderBase _orderBase, bytes32 _orderKey, bytes32 _value) internal { setBytes32(_orderBase, keccak256(abi.encode(FIELD_POSITION, _orderKey)), _value); } function getFieldPositionKey(OrderBase _orderBase, bytes32 _orderKey) internal view returns (bytes32) { return _orderBase.getBytes32(keccak256(abi.encode(FIELD_POSITION, _orderKey))); } function setFieldOrderType(OrderBase _orderBase, bytes32 _orderKey, uint256 _value) internal { setUint(_orderBase, keccak256(abi.encode(FIELD_ORDER_TYPE, _orderKey)), _value); } function getFieldOrderType(OrderBase _orderBase, bytes32 _orderKey) internal view returns (uint256) { return _orderBase.getUint(keccak256(abi.encode(FIELD_ORDER_TYPE, _orderKey))); } function setFieldAccount(OrderBase _orderBase, bytes32 _orderKey, address _value) internal { setAddress(_orderBase, keccak256(abi.encode(FIELD_ACCOUNT, _orderKey)), _value); } function getFieldAccount(OrderBase _orderBase, bytes32 _orderKey) internal view returns (address) { return _orderBase.getAddress(keccak256(abi.encode(FIELD_ACCOUNT, _orderKey))); } function setFieldPool(OrderBase _orderBase, bytes32 _orderKey, address _value) internal { setAddress(_orderBase, keccak256(abi.encode(FIELD_POOL, _orderKey)), _value); } function getFieldPool(OrderBase _orderBase, bytes32 _orderKey) internal view returns (address) { return _orderBase.getAddress(keccak256(abi.encode(FIELD_POOL, _orderKey))); } function setFieldPurchaseToken(OrderBase _orderBase, bytes32 _orderKey, address _value) internal { setAddress(_orderBase, keccak256(abi.encode(FIELD_PURCHASE_TOKEN, _orderKey)), _value); } function getFieldPurchaseToken(OrderBase _orderBase, bytes32 _orderKey) internal view returns (address) { return _orderBase.getAddress(keccak256(abi.encode(FIELD_PURCHASE_TOKEN, _orderKey))); } function setFieldPurchaseAmount(OrderBase _orderBase, bytes32 _orderKey, uint256 _value) internal { setUint(_orderBase, keccak256(abi.encode(FIELD_PURCHASE_AMOUNT, _orderKey)), _value); } function getFieldPurchaseAmount(OrderBase _orderBase, bytes32 _orderKey) internal view returns (uint256) { return _orderBase.getUint(keccak256(abi.encode(FIELD_PURCHASE_AMOUNT, _orderKey))); } function setFieldCollateralToken(OrderBase _orderBase, bytes32 _orderKey, address _value) internal { setAddress(_orderBase, keccak256(abi.encode(FIELD_COLLATERAL_TOKEN, _orderKey)), _value); } function getFieldCollateralToken(OrderBase _orderBase, bytes32 _orderKey) internal view returns (address) { return _orderBase.getAddress(keccak256(abi.encode(FIELD_COLLATERAL_TOKEN, _orderKey))); } function setFieldCollateralDelta(OrderBase _orderBase, bytes32 _orderKey, uint256 _value) internal { setUint(_orderBase, keccak256(abi.encode(FIELD_COLLATERAL_DELTA, _orderKey)), _value); } function getFieldCollateralDelta(OrderBase _orderBase, bytes32 _orderKey) internal view returns (uint256) { return _orderBase.getUint(keccak256(abi.encode(FIELD_COLLATERAL_DELTA, _orderKey))); } function setFieldIndexToken(OrderBase _orderBase, bytes32 _orderKey, address _value) internal { setAddress(_orderBase, keccak256(abi.encode(FIELD_INDEX_TOKEN, _orderKey)), _value); } function getFieldIndexToken(OrderBase _orderBase, bytes32 _orderKey) internal view returns (address) { return _orderBase.getAddress(keccak256(abi.encode(FIELD_INDEX_TOKEN, _orderKey))); } function setFieldSizeDelta(OrderBase _orderBase, bytes32 _orderKey, uint256 _value) internal { setUint(_orderBase, keccak256(abi.encode(FIELD_SIZE_DELTA, _orderKey)), _value); } function getFieldSizeDelta(OrderBase _orderBase, bytes32 _orderKey) internal view returns (uint256) { return _orderBase.getUint(keccak256(abi.encode(FIELD_SIZE_DELTA, _orderKey))); } function setFieldIsLong(OrderBase _orderBase, bytes32 _orderKey, bool _value) internal { setBool(_orderBase, keccak256(abi.encode(FIELD_IS_LONG, _orderKey)), _value); } function getFieldIsLong(OrderBase _orderBase, bytes32 _orderKey) internal view returns (bool) { return _orderBase.getBool(keccak256(abi.encode(FIELD_IS_LONG, _orderKey))); } function setFieldTriggerPrice(OrderBase _orderBase, bytes32 _orderKey, uint256 _value) internal { setUint(_orderBase, keccak256(abi.encode(FIELD_TRIGGER_PRICE, _orderKey)), _value); } function getFieldTriggerPrice(OrderBase _orderBase, bytes32 _orderKey) internal view returns (uint256) { return _orderBase.getUint(keccak256(abi.encode(FIELD_TRIGGER_PRICE, _orderKey))); } function setFieldTriggerAboveThreshold(OrderBase _orderBase, bytes32 _orderKey, bool _value) internal { setBool(_orderBase, keccak256(abi.encode(FIELD_TRIGGER_ABOVE_THRESHOLD, _orderKey)), _value); } function getFieldTriggerAboveThreshold(OrderBase _orderBase, bytes32 _orderKey) internal view returns (bool) { return _orderBase.getBool(keccak256(abi.encode(FIELD_TRIGGER_ABOVE_THRESHOLD, _orderKey))); } function setFieldExecutionFee(OrderBase _orderBase, bytes32 _orderKey, uint256 _value) internal { setUint(_orderBase, keccak256(abi.encode(FIELD_EXECUTION_FEE, _orderKey)), _value); } function getFieldExecutionFee(OrderBase _orderBase, bytes32 _orderKey) internal view returns (uint256) { return _orderBase.getUint(keccak256(abi.encode(FIELD_EXECUTION_FEE, _orderKey))); } function setFieldIndex(OrderBase _orderBase, bytes32 _orderKey, uint256 _value) internal { setUint(_orderBase, keccak256(abi.encode(FIELD_INDEX, _orderKey)), _value); } function getFieldIndex(OrderBase _orderBase, bytes32 _orderKey) internal view returns (uint256) { return _orderBase.getUint(keccak256(abi.encode(FIELD_INDEX, _orderKey))); } function setFieldTimestamp(OrderBase _orderBase, bytes32 _orderKey, uint256 _value) internal { setUint(_orderBase, keccak256(abi.encode(FIELD_TIMESTAMP, _orderKey)), _value); } function getFieldTimestamp(OrderBase _orderBase, bytes32 _orderKey) internal view returns (uint256) { return _orderBase.getUint(keccak256(abi.encode(FIELD_TIMESTAMP, _orderKey))); } function addBytes32(OrderBase _orderBase, bytes32 _setKey, bytes32 _value) internal { if (!_orderBase.containsBytes32(_setKey, _value)) { _orderBase.addBytes32(_setKey, _value); } } function removeBytes32(OrderBase _orderBase, bytes32 _setKey, bytes32 _value) internal { if (_orderBase.containsBytes32(_setKey, _value)) { _orderBase.removeBytes32(_setKey, _value); } } function setAddress(OrderBase _orderBase, bytes32 _key, address _value) internal { if (_orderBase.getAddress(_key) != _value) { _orderBase.setAddress(_key, _value); } } function setUint(OrderBase _orderBase, bytes32 _key, uint256 _value) internal { if (_orderBase.getUint(_key) != _value) { _orderBase.setUint(_key, _value); } } function setInt(OrderBase _orderBase, bytes32 _key, int256 _value) internal { if (_orderBase.getInt(_key) != _value) { _orderBase.setInt(_key, _value); } } function setBool(OrderBase _orderBase, bytes32 _key, bool _value) internal { if (_orderBase.getBool(_key) != _value) { _orderBase.setBool(_key, _value); } } function setBytes32(OrderBase _orderBase, bytes32 _key, bytes32 _value) internal { if (_orderBase.getBytes32(_key) != _value) { _orderBase.setBytes32(_key, _value); } } function getIncreaseIndex(OrderBase _orderBase, address _account, address _poolToken) internal view returns (uint256) { return _orderBase.getUint(keccak256(abi.encode(INCREASE_ORDER_INDEX, _account, _poolToken))); } function setIncreaseIndex(OrderBase _orderBase, address _account, address _poolToken, uint256 _value) internal { _orderBase.setUint(keccak256(abi.encode(INCREASE_ORDER_INDEX, _account, _poolToken)), _value); } function getDecreaseIndex(OrderBase _orderBase, address _account, address _poolToken) internal view returns (uint256) { return _orderBase.getUint(keccak256(abi.encode(DECREASE_ORDER_INDEX, _account, _poolToken))); } function setDecreaseIndex(OrderBase _orderBase, address _account, address _poolToken, uint256 _value) internal { _orderBase.setUint(keccak256(abi.encode(DECREASE_ORDER_INDEX, _account, _poolToken)), _value); } function getIncreaseOrders(OrderBase _orderBase, address _account, address _poolToken) internal view returns (IncreaseOrder[] memory){ bytes32 _setKey = keccak256(abi.encode(ACCOUNT_INCREASE_ORDER_LIST, _account, _poolToken)); uint256 _count = _orderBase.getBytes32Count(_setKey); bytes32[] memory _orderKeys = _orderBase.getBytes32ValuesAt(_setKey, 0, _count); return getIncreaseOrdersKey(_orderBase, _orderKeys); } function getIncreaseOrdersKey(OrderBase _orderBase, bytes32[] memory _orderKeys) internal view returns (IncreaseOrder[] memory){ uint256 _length = _orderKeys.length; IncreaseOrder[] memory _orders = new IncreaseOrder[](_length); for (uint256 i = 0; i < _length; i++) { IncreaseOrder memory _order = getIncreaseOrder(_orderBase, _orderKeys[i]); _orders[i] = _order; } return _orders; } function getDecreaseOrders(OrderBase _orderBase, address _account, address _poolToken) internal view returns (DecreaseOrder[] memory){ bytes32 _setKey = keccak256(abi.encode(ACCOUNT_DECREASE_ORDER_LIST, _account, _poolToken)); uint256 _count = _orderBase.getBytes32Count(_setKey); bytes32[] memory _orderKeys = _orderBase.getBytes32ValuesAt(_setKey, 0, _count); return getDecreaseOrdersKey(_orderBase, _orderKeys); } function getDecreaseOrdersKey(OrderBase _orderBase, bytes32[] memory _orderKeys) internal view returns (DecreaseOrder[] memory){ uint256 _length = _orderKeys.length; DecreaseOrder[] memory _orders = new DecreaseOrder[](_length); for (uint256 i = 0; i < _length; i++) { DecreaseOrder memory _order = getDecreaseOrder(_orderBase, _orderKeys[i]); _orders[i] = _order; } return _orders; } }@openzeppelin/contracts/utils/SlotDerivation.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.3.0) (utils/SlotDerivation.sol) // This file was procedurally generated from scripts/generate/templates/SlotDerivation.js. pragma solidity ^0.8.20; /** * @dev Library for computing storage (and transient storage) locations from namespaces and deriving slots * corresponding to standard patterns. The derivation method for array and mapping matches the storage layout used by * the solidity language / compiler. * * See https://docs.soliditylang.org/en/v0.8.20/internals/layout_in_storage.html#mappings-and-dynamic-arrays[Solidity docs for mappings and dynamic arrays.]. * * Example usage: * ```solidity * contract Example { * // Add the library methods * using StorageSlot for bytes32; * using SlotDerivation for bytes32; * * // Declare a namespace * string private constant _NAMESPACE = "<namespace>"; // eg. OpenZeppelin.Slot * * function setValueInNamespace(uint256 key, address newValue) internal { * _NAMESPACE.erc7201Slot().deriveMapping(key).getAddressSlot().value = newValue; * } * * function getValueInNamespace(uint256 key) internal view returns (address) { * return _NAMESPACE.erc7201Slot().deriveMapping(key).getAddressSlot().value; * } * } * ``` * * TIP: Consider using this library along with {StorageSlot}. * * NOTE: This library provides a way to manipulate storage locations in a non-standard way. Tooling for checking * upgrade safety will ignore the slots accessed through this library. * * _Available since v5.1._ */ library SlotDerivation { /** * @dev Derive an ERC-7201 slot from a string (namespace). */ function erc7201Slot(string memory namespace) internal pure returns (bytes32 slot) { assembly ("memory-safe") { mstore(0x00, sub(keccak256(add(namespace, 0x20), mload(namespace)), 1)) slot := and(keccak256(0x00, 0x20), not(0xff)) } } /** * @dev Add an offset to a slot to get the n-th element of a structure or an array. */ function offset(bytes32 slot, uint256 pos) internal pure returns (bytes32 result) { unchecked { return bytes32(uint256(slot) + pos); } } /** * @dev Derive the location of the first element in an array from the slot where the length is stored. */ function deriveArray(bytes32 slot) internal pure returns (bytes32 result) { assembly ("memory-safe") { mstore(0x00, slot) result := keccak256(0x00, 0x20) } } /** * @dev Derive the location of a mapping element from the key. */ function deriveMapping(bytes32 slot, address key) internal pure returns (bytes32 result) { assembly ("memory-safe") { mstore(0x00, and(key, shr(96, not(0)))) mstore(0x20, slot) result := keccak256(0x00, 0x40) } } /** * @dev Derive the location of a mapping element from the key. */ function deriveMapping(bytes32 slot, bool key) internal pure returns (bytes32 result) { assembly ("memory-safe") { mstore(0x00, iszero(iszero(key))) mstore(0x20, slot) result := keccak256(0x00, 0x40) } } /** * @dev Derive the location of a mapping element from the key. */ function deriveMapping(bytes32 slot, bytes32 key) internal pure returns (bytes32 result) { assembly ("memory-safe") { mstore(0x00, key) mstore(0x20, slot) result := keccak256(0x00, 0x40) } } /** * @dev Derive the location of a mapping element from the key. */ function deriveMapping(bytes32 slot, uint256 key) internal pure returns (bytes32 result) { assembly ("memory-safe") { mstore(0x00, key) mstore(0x20, slot) result := keccak256(0x00, 0x40) } } /** * @dev Derive the location of a mapping element from the key. */ function deriveMapping(bytes32 slot, int256 key) internal pure returns (bytes32 result) { assembly ("memory-safe") { mstore(0x00, key) mstore(0x20, slot) result := keccak256(0x00, 0x40) } } /** * @dev Derive the location of a mapping element from the key. */ function deriveMapping(bytes32 slot, string memory key) internal pure returns (bytes32 result) { assembly ("memory-safe") { let length := mload(key) let begin := add(key, 0x20) let end := add(begin, length) let cache := mload(end) mstore(end, slot) result := keccak256(begin, add(length, 0x20)) mstore(end, cache) } } /** * @dev Derive the location of a mapping element from the key. */ function deriveMapping(bytes32 slot, bytes memory key) internal pure returns (bytes32 result) { assembly ("memory-safe") { let length := mload(key) let begin := add(key, 0x20) let end := add(begin, length) let cache := mload(end) mstore(end, slot) result := keccak256(begin, add(length, 0x20)) mstore(end, cache) } } }contracts/position/PositionDao.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "../repo/DataBase.sol"; library PositionDao { struct Position { address account; address poolToken; address indexToken; address collateralToken; uint256 size; uint256 collateral; uint256 collateralAmount; uint256 averagePrice; uint256 entryFundingRate; uint256 reserveAmount; int256 realisedPnl; uint256 lastIncreasedTime; bool isLong; uint256 entryLongScaleRate; uint256 entryShortScaleRate; } struct PositionOut { bytes32 key; address poolToken; address indexToken; address collateralToken; bool isLong; uint256 size; uint256 collateral; uint256 collateralAmount; uint256 averagePrice; uint256 entryFundingRate; bool hasRealisedProfit; uint256 realisedPnl; uint256 lastIncreasedTime; bool hasProfit; uint256 profitDelta; uint256 entryLongScaleRate; uint256 entryShortScaleRate; int256 fundingFee; } struct MarginFeeParams { address account; address poolToken; address indexToken; address collateralToken; uint256 size; uint256 sizeDelta; uint256 entryFundingRate; bool isLong; } struct DecreasePositionCache { address account; address poolToken; address indexToken; address collateralToken; uint256 collateralDelta; uint256 sizeDelta; bool isLong; address receiver; } bytes32 public constant ACCOUNT_POSITION_LIST = keccak256(abi.encode("ACCOUNT_POSITION_LIST")); bytes32 public constant POOL_POSITION_LIST = keccak256(abi.encode("POOL_POSITION_LIST")); // bytes32 public constant MODIFY_POSITION_LIST = keccak256(abi.encode("MODIFY_POSITION_LIST")); bytes32 public constant POOL_LIQUIDATIONFEEUSD = keccak256(abi.encode("POOL_LIQUIDATIONFEEUSD")); // 5 * 10 ** 30 5 usd bytes32 public constant MAX_GLOBAL_LONG_SIZE = keccak256(abi.encode("MAX_GLOBAL_LONG_SIZE")); bytes32 public constant MAX_GLOBAL_SHORT_SIZE = keccak256(abi.encode("MAX_GLOBAL_SHORT_SIZE")); bytes32 public constant MAX_ACCOUNT_LONG_SIZE = keccak256(abi.encode("MAX_ACCOUNT_LONG_SIZE")); bytes32 public constant MAX_ACCOUNT_SHORT_SIZE = keccak256(abi.encode("MAX_ACCOUNT_SHORT_SIZE")); bytes32 public constant MAX_PROFIT = keccak256(abi.encode("MAX_PROFIT")); bytes32 public constant GLOBAL_LONG_SIZE = keccak256(abi.encode("GLOBAL_LONG_SIZE")); bytes32 public constant GLOBAL_SHORT_SIZE = keccak256(abi.encode("GLOBAL_SHORT_SIZE")); bytes32 public constant ACCOUNT_LONG_SIZE = keccak256(abi.encode("ACCOUNT_LONG_SIZE")); bytes32 public constant ACCOUNT_SHORT_SIZE = keccak256(abi.encode("ACCOUNT_SHORT_SIZE")); bytes32 public constant LONG_SCALE_RATE = keccak256(abi.encode("LONG_SCALE_RATE")); bytes32 public constant SHORT_SCALE_RATE = keccak256(abi.encode("SHORT_SCALE_RATE")); bytes32 public constant LAST_SCALE_TIME = keccak256(abi.encode("LAST_SCALE_TIME")); bytes32 public constant FUNDING_RATE = keccak256(abi.encode("FUNDING_RATE")); bytes32 public constant LAST_FUNDING_TIME = keccak256(abi.encode("LAST_FUNDING_TIME")); bytes32 public constant FUNDING_INTERVAL = keccak256(abi.encode("FUNDING_INTERVAL")); bytes32 public constant SCALE_INTERVAL = keccak256(abi.encode("SCALE_INTERVAL")); bytes32 public constant POOL_AMOUNT = keccak256(abi.encode("POOL_AMOUNT")); bytes32 public constant RESERVED_AMOUNT = keccak256(abi.encode("RESERVED_AMOUNT")); bytes32 public constant STABLE_TOKEN = keccak256(abi.encode("STABLE_TOKEN")); bytes32 public constant INDEX_TOKEN_LIST = keccak256(abi.encode("INDEX_TOKEN_LIST")); bytes32 public constant STABLE_TOKEN_LIST = keccak256(abi.encode("STABLE_TOKEN_LIST")); bytes32 public constant FUNDING_RATE_FACTOR = keccak256(abi.encode("FUNDING_RATE_FACTOR")); bytes32 public constant STABLE_FUNDING_RATE_FACTOR = keccak256(abi.encode("STABLE_FUNDING_RATE_FACTOR")); bytes32 public constant SCALE_RATE_FACTOR = keccak256(abi.encode("SCALE_RATE_FACTOR")); bytes32 public constant STABLE_SCALE_RATE_FACTOR = keccak256(abi.encode("STABLE_SCALE_RATE_FACTOR")); bytes32 public constant SCALE_FEE_PAY_RATE = keccak256(abi.encode("SCALE_FEE_PAY_RATE")); bytes32 public constant POOL_MARGINFEEBASISPOINTS = keccak256(abi.encode("POOL_MARGINFEEBASISPOINTS")); // 10 0.1% bytes32 public constant SCALE_FEE_CLAIM = keccak256(abi.encode("SCALE_FEE_CLAIM")); bytes32 public constant SCALE_FEE_BALANCE = keccak256(abi.encode("SCALE_FEE_BALANCE")); bytes32 public constant REFERRAL_DISCOUNT_TOTAL = keccak256(abi.encode("REFERRAL_DISCOUNT_TOTAL")); bytes32 public constant REFERRAL_REBATE_TOTAL = keccak256(abi.encode("REFERRAL_REBATE_TOTAL")); bytes32 public constant REFERRAL_REBATE_CLAIMABLE = keccak256(abi.encode("REFERRAL_REBATE_CLAIMABLE")); bytes32 public constant MAX_LEVERAGE = keccak256(abi.encode("MAX_LEVERAGE")); // n * 10000 bytes32 public constant ALLOW_REDUCING_PORTION_POSITION = keccak256(abi.encode("ALLOW_REDUCING_PORTION_POSITION")); bytes32 public constant POS_ACCOUNT = keccak256(abi.encode("POS_ACCOUNT")); bytes32 public constant POS_POOL = keccak256(abi.encode("POS_POOL")); bytes32 public constant POS_INDEX = keccak256(abi.encode("POS_INDEX")); bytes32 public constant POS_COLLATERAL = keccak256(abi.encode("POS_COLLATERAL")); bytes32 public constant POS_SIZE = keccak256(abi.encode("POS_SIZE")); bytes32 public constant POS_COLLATERAL_USD = keccak256(abi.encode("POS_COLLATERAL_USD")); bytes32 public constant POS_COLLATERAL_AMOUNT = keccak256(abi.encode("POS_COLLATERAL_AMOUNT")); bytes32 public constant POS_AVERAGE_PRICE = keccak256(abi.encode("POS_AVERAGE_PRICE")); bytes32 public constant POS_ENTRY_FUNDING_RATE = keccak256(abi.encode("POS_ENTRY_FUNDING_RATE")); bytes32 public constant POS_RESERVE_AMOUNT = keccak256(abi.encode("POS_RESERVE_AMOUNT")); bytes32 public constant POS_REALISED_PNL = keccak256(abi.encode("POS_REALISED_PNL")); bytes32 public constant POS_LAST_INCREASED_TIME = keccak256(abi.encode("POS_LAST_INCREASED_TIME")); bytes32 public constant POS_IS_LONG = keccak256(abi.encode("POS_IS_LONG")); bytes32 public constant POS_ENTRY_LONG_SCALE_RATE = keccak256(abi.encode("POS_ENTRY_LONG_SCALE_RATE")); bytes32 public constant POS_ENTRY_SHORT_SCALE_RATE = keccak256(abi.encode("POS_ENTRY_SHORT_SCALE_RATE")); function getPositionKey(address _account, address _poolToken, address _collateralToken, address _indexToken, bool _isLong) internal pure returns (bytes32) { return keccak256(abi.encodePacked( _account, _poolToken, _collateralToken, _indexToken, _isLong )); } function savePosition(DataBase _dataBase, Position memory _position) internal { bytes32 _posKey = getPositionKey(_position.account, _position.poolToken, _position.collateralToken, _position.indexToken, _position.isLong); // addModifyBytes32(_dataBase, // keccak256(abi.encode(POOL_POSITION_LIST, _position.poolToken)), // keccak256(abi.encode(MODIFY_POSITION_LIST, _position.poolToken)), // _posKey // ); removeBytes32(_dataBase, keccak256(abi.encode(POOL_POSITION_LIST, _position.poolToken)), _posKey); addBytes32(_dataBase, keccak256(abi.encode(POOL_POSITION_LIST, _position.poolToken)), _posKey); addBytes32(_dataBase, keccak256(abi.encode(ACCOUNT_POSITION_LIST, _position.account, _position.poolToken)), _posKey); setFieldAccount(_dataBase, _posKey, _position.account); setFieldPool(_dataBase, _posKey, _position.poolToken); setFieldIndex(_dataBase, _posKey, _position.indexToken); setFieldCollateral(_dataBase, _posKey, _position.collateralToken); setFieldSize(_dataBase, _posKey, _position.size); setFieldCollateralUsd(_dataBase, _posKey, _position.collateral); setFieldCollateralAmount(_dataBase, _posKey, _position.collateralAmount); setFieldAveragePrice(_dataBase, _posKey, _position.averagePrice); setFieldEntryFundingRate(_dataBase, _posKey, _position.entryFundingRate); setFieldReserveAmount(_dataBase, _posKey, _position.reserveAmount); setFieldRealisedPnl(_dataBase, _posKey, _position.realisedPnl); setFieldLastIncreasedTime(_dataBase, _posKey, _position.lastIncreasedTime); setFieldIsLong(_dataBase, _posKey, _position.isLong); setFieldEntryLongScaleRate(_dataBase, _posKey, _position.entryLongScaleRate); setFieldEntryShortScaleRate(_dataBase, _posKey, _position.entryShortScaleRate); } function removePosition(DataBase _dataBase, address _account, address _poolToken, bytes32 _posKey) internal { removeBytes32(_dataBase, keccak256(abi.encode(ACCOUNT_POSITION_LIST, _account, _poolToken)), _posKey); removeBytes32(_dataBase, keccak256(abi.encode(POOL_POSITION_LIST, _poolToken)), _posKey); // removeBytes32(_dataBase, keccak256(abi.encode(MODIFY_POSITION_LIST, _poolToken)), _posKey); _dataBase.removeAddress(keccak256(abi.encode(POS_ACCOUNT, _posKey))); _dataBase.removeAddress(keccak256(abi.encode(POS_POOL, _posKey))); _dataBase.removeAddress(keccak256(abi.encode(POS_INDEX, _posKey))); _dataBase.removeAddress(keccak256(abi.encode(POS_COLLATERAL, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_SIZE, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_COLLATERAL_USD, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_COLLATERAL_AMOUNT, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_AVERAGE_PRICE, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_ENTRY_FUNDING_RATE, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_RESERVE_AMOUNT, _posKey))); _dataBase.removeInt(keccak256(abi.encode(POS_REALISED_PNL, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_LAST_INCREASED_TIME, _posKey))); _dataBase.removeBool(keccak256(abi.encode(POS_IS_LONG, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_ENTRY_LONG_SCALE_RATE, _posKey))); _dataBase.removeUint(keccak256(abi.encode(POS_ENTRY_SHORT_SCALE_RATE, _posKey))); } function getPosition(DataBase _dataBase, bytes32 _posKey) internal view returns (Position memory) { Position memory position = Position({ account: getFieldAccount(_dataBase, _posKey), poolToken: getFieldPool(_dataBase, _posKey), indexToken: getFieldIndex(_dataBase, _posKey), collateralToken: getFieldCollateral(_dataBase, _posKey), size: getFieldSize(_dataBase, _posKey), collateral: getFieldCollateralUsd(_dataBase, _posKey), collateralAmount: getFieldCollateralAmount(_dataBase, _posKey), averagePrice: getFieldAveragePrice(_dataBase, _posKey), entryFundingRate: getFieldEntryFundingRate(_dataBase, _posKey), reserveAmount: getFieldReserveAmount(_dataBase, _posKey), realisedPnl: getFieldRealisedPnl(_dataBase, _posKey), lastIncreasedTime: getFieldLastIncreasedTime(_dataBase, _posKey), isLong: getFieldIsLong(_dataBase, _posKey), entryLongScaleRate: getFieldEntryLongScaleRate(_dataBase, _posKey), entryShortScaleRate: getFieldEntryShortScaleRate(_dataBase, _posKey) }); return position; } function getPositionFields(DataBase _dataBase, address _account, address _poolToken, address _collateralToken, address _indexToken, bool _isLong) internal view returns (uint256, uint256) { bytes32 _posKey = getPositionKey(_account, _poolToken, _collateralToken, _indexToken, _isLong); return (getFieldSize(_dataBase, _posKey), getFieldCollateralUsd(_dataBase, _posKey)); } function setFieldAccount(DataBase _dataBase, bytes32 _posKey, address _value) internal { setAddress(_dataBase, keccak256(abi.encode(POS_ACCOUNT, _posKey)), _value); } function getFieldAccount(DataBase _dataBase, bytes32 _posKey) internal view returns (address) { return _dataBase.getAddress(keccak256(abi.encode(POS_ACCOUNT, _posKey))); } function setFieldPool(DataBase _dataBase, bytes32 _posKey, address _value) internal { setAddress(_dataBase, keccak256(abi.encode(POS_POOL, _posKey)), _value); } function getFieldPool(DataBase _dataBase, bytes32 _posKey) internal view returns (address) { return _dataBase.getAddress(keccak256(abi.encode(POS_POOL, _posKey))); } function setFieldIndex(DataBase _dataBase, bytes32 _posKey, address _value) internal { setAddress(_dataBase, keccak256(abi.encode(POS_INDEX, _posKey)), _value); } function getFieldIndex(DataBase _dataBase, bytes32 _posKey) internal view returns (address) { return _dataBase.getAddress(keccak256(abi.encode(POS_INDEX, _posKey))); } function setFieldCollateral(DataBase _dataBase, bytes32 _posKey, address _value) internal { setAddress(_dataBase, keccak256(abi.encode(POS_COLLATERAL, _posKey)), _value); } function getFieldCollateral(DataBase _dataBase, bytes32 _posKey) internal view returns (address) { return _dataBase.getAddress(keccak256(abi.encode(POS_COLLATERAL, _posKey))); } function setFieldSize(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_SIZE, _posKey)), _value); } function getFieldSize(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_SIZE, _posKey))); } function setFieldCollateralUsd(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_COLLATERAL_USD, _posKey)), _value); } function getFieldCollateralUsd(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_COLLATERAL_USD, _posKey))); } function setFieldCollateralAmount(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_COLLATERAL_AMOUNT, _posKey)), _value); } function getFieldCollateralAmount(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_COLLATERAL_AMOUNT, _posKey))); } function setFieldAveragePrice(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_AVERAGE_PRICE, _posKey)), _value); } function getFieldAveragePrice(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_AVERAGE_PRICE, _posKey))); } function setFieldEntryFundingRate(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_ENTRY_FUNDING_RATE, _posKey)), _value); } function getFieldEntryFundingRate(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_ENTRY_FUNDING_RATE, _posKey))); } function setFieldReserveAmount(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_RESERVE_AMOUNT, _posKey)), _value); } function getFieldReserveAmount(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_RESERVE_AMOUNT, _posKey))); } function setFieldRealisedPnl(DataBase _dataBase, bytes32 _posKey, int256 _value) internal { setInt(_dataBase, keccak256(abi.encode(POS_REALISED_PNL, _posKey)), _value); } function getFieldRealisedPnl(DataBase _dataBase, bytes32 _posKey) internal view returns (int256) { return _dataBase.getInt(keccak256(abi.encode(POS_REALISED_PNL, _posKey))); } function setFieldLastIncreasedTime(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_LAST_INCREASED_TIME, _posKey)), _value); } function getFieldLastIncreasedTime(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_LAST_INCREASED_TIME, _posKey))); } function setFieldIsLong(DataBase _dataBase, bytes32 _posKey, bool _value) internal { setBool(_dataBase, keccak256(abi.encode(POS_IS_LONG, _posKey)), _value); } function getFieldIsLong(DataBase _dataBase, bytes32 _posKey) internal view returns (bool) { return _dataBase.getBool(keccak256(abi.encode(POS_IS_LONG, _posKey))); } function setFieldEntryLongScaleRate(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_ENTRY_LONG_SCALE_RATE, _posKey)), _value); } function getFieldEntryLongScaleRate(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_ENTRY_LONG_SCALE_RATE, _posKey))); } function setFieldEntryShortScaleRate(DataBase _dataBase, bytes32 _posKey, uint256 _value) internal { setUint(_dataBase, keccak256(abi.encode(POS_ENTRY_SHORT_SCALE_RATE, _posKey)), _value); } function getFieldEntryShortScaleRate(DataBase _dataBase, bytes32 _posKey) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POS_ENTRY_SHORT_SCALE_RATE, _posKey))); } function addBytes32(DataBase _dataBase, bytes32 _setKey, bytes32 _value) internal { if (!_dataBase.containsBytes32(_setKey, _value)) { _dataBase.addBytes32(_setKey, _value); } } // function addModifyBytes32(DataBase _dataBase, bytes32 _setKey1, bytes32 _setKey2, bytes32 _value) internal { // if (_dataBase.containsBytes32(_setKey1, _value)) { // if (_dataBase.containsBytes32(_setKey2, _value)) { // _dataBase.removeBytes32(_setKey2, _value); // } // _dataBase.addBytes32(_setKey2, _value); // } else { // _dataBase.addBytes32(_setKey1, _value); // } // } function removeBytes32(DataBase _dataBase, bytes32 _setKey, bytes32 _value) internal { if (_dataBase.containsBytes32(_setKey, _value)) { _dataBase.removeBytes32(_setKey, _value); } } function setAddress(DataBase _dataBase, bytes32 _key, address _value) internal { if (_dataBase.getAddress(_key) != _value) { _dataBase.setAddress(_key, _value); } } function setUint(DataBase _dataBase, bytes32 _key, uint256 _value) internal { if (_dataBase.getUint(_key) != _value) { _dataBase.setUint(_key, _value); } } function setInt(DataBase _dataBase, bytes32 _key, int256 _value) internal { if (_dataBase.getInt(_key) != _value) { _dataBase.setInt(_key, _value); } } function setBool(DataBase _dataBase, bytes32 _key, bool _value) internal { if (_dataBase.getBool(_key) != _value) { _dataBase.setBool(_key, _value); } } function liquidationFeeUsd(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POOL_LIQUIDATIONFEEUSD, _poolToken))); } function stableToken(DataBase _dataBase, address _token) internal view returns (bool) { return _dataBase.getBool(keccak256(abi.encode(STABLE_TOKEN, _token))); } function addStableToken(DataBase _dataBase, address _token) internal { _dataBase.setBool(keccak256(abi.encode(STABLE_TOKEN, _token)), true); } function removeStableToken(DataBase _dataBase, address _token) internal { _dataBase.removeBool(keccak256(abi.encode(STABLE_TOKEN, _token))); } function poolAmount(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POOL_AMOUNT, _poolToken, _token))); } function setPoolAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(POOL_AMOUNT, _poolToken, _token)), _value); } function reservedAmount(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(RESERVED_AMOUNT, _poolToken, _token))); } function setReservedAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(RESERVED_AMOUNT, _poolToken, _token)), _value); } function fundingRate(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(FUNDING_RATE, _poolToken, _token))); } function setFundingRate(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(FUNDING_RATE, _poolToken, _token)), _value); } function scaleInterval(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(SCALE_INTERVAL, _poolToken))); } function scaleRateFactor(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(SCALE_RATE_FACTOR, _poolToken))); } function stableScaleRateFactor(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(STABLE_SCALE_RATE_FACTOR, _poolToken))); } function scaleFeePayRate(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(SCALE_FEE_PAY_RATE, _poolToken))); } function fundingInterval(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(FUNDING_INTERVAL, _poolToken))); } function fundingRateFactor(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(FUNDING_RATE_FACTOR, _poolToken))); } function stableFundingRateFactor(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(STABLE_FUNDING_RATE_FACTOR, _poolToken))); } function lastFundingTime(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(LAST_FUNDING_TIME, _poolToken, _token))); } function setLastFundingTime(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(LAST_FUNDING_TIME, _poolToken, _token)), _value); } function longScaleRate(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(LONG_SCALE_RATE, _poolToken, _token))); } function setLongScaleRate(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(LONG_SCALE_RATE, _poolToken, _token)), _value); } function shortScaleRate(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(SHORT_SCALE_RATE, _poolToken, _token))); } function setShortScaleRate(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(SHORT_SCALE_RATE, _poolToken, _token)), _value); } function lastScaleTime(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(LAST_SCALE_TIME, _poolToken, _token))); } function setLastScaleTime(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(LAST_SCALE_TIME, _poolToken, _token)), _value); } function maxGlobalLongSize(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(MAX_GLOBAL_LONG_SIZE, _poolToken, _token))); } function setMaxGlobalLongSize(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { _dataBase.setUint(keccak256(abi.encode(MAX_GLOBAL_LONG_SIZE, _poolToken, _token)), _amount); } function maxGlobalShortSize(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(MAX_GLOBAL_SHORT_SIZE, _poolToken, _token))); } function setMaxGlobalShortSize(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { _dataBase.setUint(keccak256(abi.encode(MAX_GLOBAL_SHORT_SIZE, _poolToken, _token)), _amount); } function globalShortSize(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(GLOBAL_SHORT_SIZE, _poolToken, _token))); } function setGlobalShortSize(DataBase _dataBase, address _poolToken, address _token, uint256 _size) internal { _dataBase.setUint(keccak256(abi.encode(GLOBAL_SHORT_SIZE, _poolToken, _token)), _size); } function globalLongSize(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(GLOBAL_LONG_SIZE, _poolToken, _token))); } function setGlobalLongSize(DataBase _dataBase, address _poolToken, address _token, uint256 _size) internal { _dataBase.setUint(keccak256(abi.encode(GLOBAL_LONG_SIZE, _poolToken, _token)), _size); } function maxAccountLongSize(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(MAX_ACCOUNT_LONG_SIZE, _poolToken, _token))); } function setMaxAccountLongSize(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { _dataBase.setUint(keccak256(abi.encode(MAX_ACCOUNT_LONG_SIZE, _poolToken, _token)), _amount); } function maxAccountShortSize(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(MAX_ACCOUNT_SHORT_SIZE, _poolToken, _token))); } function setMaxAccountShortSize(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { _dataBase.setUint(keccak256(abi.encode(MAX_ACCOUNT_SHORT_SIZE, _poolToken, _token)), _amount); } function maxProfit(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(MAX_PROFIT, _poolToken, _token))); } function setMaxProfit(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { _dataBase.setUint(keccak256(abi.encode(MAX_PROFIT, _poolToken, _token)), _amount); } function accountLongSize(DataBase _dataBase, address _poolToken, address _token, address _account) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(ACCOUNT_LONG_SIZE, _poolToken, _token, _account))); } function setAccountLongSize(DataBase _dataBase, address _poolToken, address _token, address _account, uint256 _size) internal { _dataBase.setUint(keccak256(abi.encode(ACCOUNT_LONG_SIZE, _poolToken, _token, _account)), _size); } function accountShortSize(DataBase _dataBase, address _poolToken, address _token, address _account) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(ACCOUNT_SHORT_SIZE, _poolToken, _token, _account))); } function setAccountShortSize(DataBase _dataBase, address _poolToken, address _token, address _account, uint256 _size) internal { _dataBase.setUint(keccak256(abi.encode(ACCOUNT_SHORT_SIZE, _poolToken, _token, _account)), _size); } function marginFeeBasisPoints(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(POOL_MARGINFEEBASISPOINTS, _poolToken))); } function setMarginFeeBasisPoints(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(POOL_MARGINFEEBASISPOINTS, _poolToken)), _value); } function getPositionKeys(DataBase _dataBase, address _account, address _poolToken) internal view returns (bytes32[] memory) { bytes32 _setKey = keccak256(abi.encode(ACCOUNT_POSITION_LIST, _account, _poolToken)); uint256 positionCount = _dataBase.getBytes32Count(_setKey); return _dataBase.getBytes32ValuesAt(_setKey, 0, positionCount); } function scaleFeeClaim(DataBase _dataBase, address _poolToken, address _token, address _account) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(SCALE_FEE_CLAIM, _poolToken, _token, _account))); } function setScaleFeeClaim(DataBase _dataBase, address _poolToken, address _token, address _account, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(SCALE_FEE_CLAIM, _poolToken, _token, _account)), _value); } function scaleFeeBalance(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(SCALE_FEE_BALANCE, _poolToken, _token))); } function setScaleFeeBalance(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(SCALE_FEE_BALANCE, _poolToken, _token)), _value); } function referralDiscountTotal(DataBase _dataBase, address _poolToken, address _account) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(REFERRAL_DISCOUNT_TOTAL, _poolToken, _account))); } function setReferralDiscountTotal(DataBase _dataBase, address _poolToken, address _account, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(REFERRAL_DISCOUNT_TOTAL, _poolToken, _account)), _value); } function referralRebateTotal(DataBase _dataBase, address _poolToken, address _account) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(REFERRAL_REBATE_TOTAL, _poolToken, _account))); } function setReferralRebateTotal(DataBase _dataBase, address _poolToken, address _account, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(REFERRAL_REBATE_TOTAL, _poolToken, _account)), _value); } function referralRebateClaimable(DataBase _dataBase, address _poolToken, address _token, address _account) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(REFERRAL_REBATE_CLAIMABLE, _poolToken, _token, _account))); } function setReferralRebateClaimable(DataBase _dataBase, address _poolToken, address _token, address _account, uint256 _value) internal { _dataBase.setUint(keccak256(abi.encode(REFERRAL_REBATE_CLAIMABLE, _poolToken, _token, _account)), _value); } function poolStableToken(DataBase _dataBase, address _poolToken, address _token) internal view returns (bool) { return _dataBase.containsAddress(keccak256(abi.encode(_poolToken, STABLE_TOKEN_LIST)), _token); } function poolIndexToken(DataBase _dataBase, address _poolToken, address _token) internal view returns (bool) { return _dataBase.containsAddress(keccak256(abi.encode(_poolToken, INDEX_TOKEN_LIST)), _token); } function maxLeverage(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(keccak256(abi.encode(MAX_LEVERAGE, _poolToken, _token))); } function allowReducingPortionPosition(DataBase _dataBase, address _poolToken) internal view returns (bool) { return _dataBase.getBool(keccak256(abi.encode(ALLOW_REDUCING_PORTION_POSITION, _poolToken))); } }contracts/vault/VaultLib.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "@openzeppelin/contracts/token/ERC20/IERC20.sol"; import "@openzeppelin/contracts/token/ERC20/utils/SafeERC20.sol"; import {DataBase} from "../repo/DataBase.sol"; import "../utils/Keys.sol"; import "../repo/Dao.sol"; import "./VaultDao.sol"; import "../pool/IPoolToken.sol"; import "../oracle/PriceLib.sol"; import "../position/PositionLib.sol"; library VaultLib { using SafeERC20 for IERC20; uint256 public constant BASIS_POINTS_DIVISOR = 10000; uint256 public constant USDG_DECIMALS = 18; uint256 public constant fundingInterval = 1 hours; uint256 public constant fundingRateFactor = 100; uint256 public constant stableFundingRateFactor = 100; event CollectSwapFees(address poolToken, address token, uint256 feeUsd, uint256 feeTokens); event CollectMarginFees(address poolToken, address token, uint256 feeUsd, uint256 feeTokens); event IncreasePoolAmount(address poolToken, address token, uint256 amount); event InvalidIncreaseEvent(address poolToken, address token, uint256 balance, uint256 nextPoolAmount); event DecreasePoolAmount(address poolToken, address token, uint256 amount); event IncreaseUsdgAmount(address poolToken, address token, uint256 amount); event DecreaseUsdgAmount(address poolToken, address token, uint256 amount); event IncreaseReservedAmount(address poolToken, address token, uint256 amount); event DecreaseReservedAmount(address poolToken, address token, uint256 amount); event IncreaseGuaranteedUsd(address poolToken, address token, uint256 usdAmount); event DecreaseGuaranteedUsd(address poolToken, address token, uint256 usdAmount); event BuyUSDG(address poolToken, address token, uint256 tokenAmount, uint256 mintAmount, uint256 feeBasisPoints); event UpdateFundingRate(address poolToken, address token, uint256 fundingRate); error NoAmountIn(address, address); error InvalidUSDGAmount(); error InvalidIncrease(address, address, uint256, uint256); error PoolAmountExceeded(address poolToken, address token, uint256 poolAmount, uint256 decAmount); error ReservedAmountExceeded(address poolToken, address token, uint256 poolAmount, uint256 reservedAmount); error PoolLessThanBuffer(address poolToken, address token, uint256 poolAmount, uint256 bufferAmount); error ReservedExceedsPool(address poolToken, address token, uint256 reservedAmount, uint256 poolAmount); error InsufficientReserved(address poolToken, address token, uint256 reservedAmount, uint256 decAmount); error InvalidIndexToken(); error InvalidStableToken(); function getFeeBasisPoints(DataBase _dataBase, address _poolToken, address /*_token*/, uint256 /*_usdgDelta*/, uint256 _feeBasisPoints, uint256 /*_taxBasisPoints*/, bool /*_increment*/) internal view returns (uint256) { if (!Dao.hasDynamicFees(_dataBase, _poolToken)) { return _feeBasisPoints; } return _feeBasisPoints; } function collectSwapFees(DataBase _dataBase, address _poolToken, address _token, uint256 _decimals, uint256 _amount, uint256 _feeBasisPoints) internal returns (uint256) { uint256 afterFeeAmount = _amount * (BASIS_POINTS_DIVISOR - _feeBasisPoints) / BASIS_POINTS_DIVISOR; uint256 feeAmount = _amount - afterFeeAmount; uint256 feeUsdMin = PriceLib.tokenToUsdMin(_dataBase, _token, _decimals, feeAmount); updateCumulativeFees(_dataBase, _poolToken, feeUsdMin); distributeSwapFees(_dataBase, _poolToken, _token, feeAmount); emit CollectSwapFees(_poolToken, _token, feeUsdMin, feeAmount); return afterFeeAmount; } function collectMarginFees(DataBase _dataBase, PositionLib.MarginFeeParams memory params) internal returns (uint256) { uint256 feeUsd = PositionLib.getPositionFee( _dataBase, params.account, params.poolToken, params.collateralToken, params.indexToken, params.isLong, params.sizeDelta ); uint256 fundingFee = PositionLib.getFundingFee( _dataBase, params.account, params.poolToken, params.collateralToken, params.indexToken, params.isLong, params.size, params.entryFundingRate ); feeUsd = feeUsd + fundingFee; uint256 feeAmount = PriceLib.usdToTokenMin(_dataBase, params.collateralToken, feeUsd); updateCumulativeFees(_dataBase, params.poolToken, feeUsd); distributeMarginFees(_dataBase, params.poolToken, params.collateralToken, feeAmount); emit CollectMarginFees(params.poolToken, params.collateralToken, feeUsd, feeAmount); return feeUsd; } function collectMarginFees(DataBase _dataBase, address _poolToken, address _token, uint256 _feeAmount, uint256 _feeUsd) internal returns (uint256) { updateCumulativeFees(_dataBase, _poolToken, _feeUsd); distributeMarginFees(_dataBase, _poolToken, _token, _feeAmount); emit CollectMarginFees(_poolToken, _token, _feeUsd, _feeAmount); return _feeUsd; } function updateCumulativeFees(DataBase _dataBase, address _poolToken, uint256 feeUsd) internal { uint256 cumulativeFees = Dao.cumulativeFees(_dataBase, _poolToken); Dao.setCumulativeFees(_dataBase, _poolToken, cumulativeFees + feeUsd); } function distributeSwapFees(DataBase _dataBase, address _poolToken, address _token, uint256 _feeAmount) internal { distributeFees(_dataBase, _poolToken, _token, _feeAmount, Dao.swapFeeToFactor(_dataBase, _poolToken)); } function distributeMarginFees(DataBase _dataBase, address _poolToken, address _token, uint256 _feeAmount) internal { distributeFees(_dataBase, _poolToken, _token, _feeAmount, Dao.positionFeeToFactor(_dataBase, _poolToken)); } function distributeFees(DataBase _dataBase, address _poolToken, address _token, uint256 _feeAmount, uint256 _feeToFactor) internal { uint256 feeToAmount = _feeAmount * _feeToFactor / BASIS_POINTS_DIVISOR; uint256 nextFeeToReserveAmount = Dao.feeReserveTo(_dataBase, _poolToken, _token) + feeToAmount; Dao.setFeeReserveTo(_dataBase, _poolToken, _token, nextFeeToReserveAmount); uint256 feeInAmount = _feeAmount - feeToAmount; uint256 nextFeeInReserveAmount = Dao.feeReserveIn(_dataBase, _poolToken, _token) + feeInAmount; Dao.setFeeReserveIn(_dataBase, _poolToken, _token, nextFeeInReserveAmount); increasePoolAmount(_dataBase, _poolToken, _token, feeInAmount); uint256 feeInUsd = PriceLib.tokenToUsdMin(_dataBase, _token, Dao.tokenDecimals(_dataBase, _token), feeInAmount); uint256 poolInFees = Dao.poolInFees(_dataBase, _poolToken); Dao.setPoolInFees(_dataBase, _poolToken, poolInFees + feeInUsd); } function adjustForDecimals(uint256 _amount, uint256 _decimalsDiv, uint256 _decimalsMul) internal pure returns (uint256) { return _amount * 10 ** _decimalsMul / 10 ** _decimalsDiv; } function increaseUsdgAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { uint256 usdgAmount = Dao.usdgAmount(_dataBase, _poolToken, _token); Dao.setUsdgAmount(_dataBase, _poolToken, _token, usdgAmount + _amount); emit IncreaseUsdgAmount(_poolToken, _token, _amount); } function decreaseUsdgAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { uint256 usdgAmount = Dao.usdgAmount(_dataBase, _poolToken, _token); if (usdgAmount <= _amount) { Dao.setUsdgAmount(_dataBase, _poolToken, _token, 0); emit DecreaseUsdgAmount(_poolToken, _token, usdgAmount); return; } Dao.setUsdgAmount(_dataBase, _poolToken, _token, usdgAmount - _amount); emit DecreaseUsdgAmount(_poolToken, _token, _amount); } function increasePoolAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { uint256 nextPoolAmount = Dao.poolAmount(_dataBase, _poolToken, _token) + _amount; Dao.setPoolAmount(_dataBase, _poolToken, _token, nextPoolAmount); uint256 balance = IERC20(_token).balanceOf(_poolToken); if (nextPoolAmount > balance) { emit InvalidIncreaseEvent(_poolToken, _token, balance, nextPoolAmount); } emit IncreasePoolAmount(_poolToken, _token, _amount); } function decreasePoolAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { uint256 curPoolAmount = Dao.poolAmount(_dataBase, _poolToken, _token); if (curPoolAmount < _amount) { revert PoolAmountExceeded(_poolToken, _token, curPoolAmount, _amount); } uint256 nextPoolAmount = curPoolAmount - _amount; Dao.setPoolAmount(_dataBase, _poolToken, _token, nextPoolAmount); uint256 reservedAmount = Dao.reservedAmount(_dataBase, _poolToken, _token); if (reservedAmount > nextPoolAmount) { revert ReservedAmountExceeded(_poolToken, _token, nextPoolAmount, reservedAmount); } emit DecreasePoolAmount(_poolToken, _token, _amount); } function increaseReservedAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { uint256 nextReservedAmount = Dao.reservedAmount(_dataBase, _poolToken, _token) + _amount; Dao.setReservedAmount(_dataBase, _poolToken, _token, nextReservedAmount); uint256 curPoolAmount = Dao.poolAmount(_dataBase, _poolToken, _token); if (nextReservedAmount > curPoolAmount) { revert ReservedExceedsPool(_poolToken, _token, nextReservedAmount, curPoolAmount); } emit IncreaseReservedAmount(_poolToken, _token, _amount); } function decreaseReservedAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { uint256 curReservedAmount = Dao.reservedAmount(_dataBase, _poolToken, _token); if (curReservedAmount < _amount) { revert InsufficientReserved(_poolToken, _token, curReservedAmount, _amount); } Dao.setReservedAmount(_dataBase, _poolToken, _token, curReservedAmount - _amount); emit DecreaseReservedAmount(_poolToken, _token, _amount); } function increaseGuaranteedUsd(DataBase _dataBase, address _poolToken, address _token, uint256 _usdAmount) internal { uint256 guaranteedUsd = Dao.guaranteedUsd(_dataBase, _poolToken, _token); Dao.setGuaranteedUsd(_dataBase, _poolToken, _token, guaranteedUsd + _usdAmount); emit IncreaseGuaranteedUsd(_poolToken, _token, _usdAmount); } function decreaseGuaranteedUsd(DataBase _dataBase, address _poolToken, address _token, uint256 _usdAmount) internal { uint256 guaranteedUsd = Dao.guaranteedUsd(_dataBase, _poolToken, _token); if (guaranteedUsd > _usdAmount) { Dao.setGuaranteedUsd(_dataBase, _poolToken, _token, guaranteedUsd - _usdAmount); } else { Dao.setGuaranteedUsd(_dataBase, _poolToken, _token, 0); } emit DecreaseGuaranteedUsd(_poolToken, _token, _usdAmount); } function increaseGlobalShortSize(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { uint256 size = Dao.globalShortSize(_dataBase, _poolToken, _token); Dao.setGlobalShortSize(_dataBase, _poolToken, _token, size + _amount); } function updateCumulativeFundingRate(DataBase _dataBase, address _poolToken, address _collateralToken, address /*_indexToken*/) internal { if (Dao.lastFundingTime(_dataBase, _poolToken, _collateralToken) == 0) { Dao.setLastFundingTime(_dataBase, _poolToken, _collateralToken, block.timestamp / fundingInterval * fundingInterval); return; } if ((Dao.lastFundingTime(_dataBase, _poolToken, _collateralToken) + fundingInterval) > block.timestamp) { return; } uint256 fundingRate = getNextFundingRate(_dataBase, _poolToken, _collateralToken); Dao.setFundingRate(_dataBase, _poolToken, _collateralToken, Dao.fundingRate(_dataBase, _poolToken, _collateralToken) + fundingRate); Dao.setLastFundingTime(_dataBase, _poolToken, _collateralToken, block.timestamp / fundingInterval * fundingInterval); emit UpdateFundingRate(_poolToken, _collateralToken, Dao.fundingRate(_dataBase, _poolToken, _collateralToken)); } function getNextFundingRate(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { uint256 lastFundingTime = Dao.lastFundingTime(_dataBase, _poolToken, _token); if ((lastFundingTime + fundingInterval) > block.timestamp) { return 0; } uint256 intervals = (block.timestamp - lastFundingTime) / fundingInterval; uint256 poolAmount = Dao.poolAmount(_dataBase, _poolToken, _token); if (poolAmount == 0) { return 0; } uint256 _fundingRateFactor = Dao.stableToken(_dataBase, _token) ? stableFundingRateFactor : fundingRateFactor; return _fundingRateFactor * Dao.reservedAmount(_dataBase, _poolToken, _token) * intervals / poolAmount; } function getNextGlobalShortAveragePrice(DataBase _dataBase, address _poolToken, address _indexToken, uint256 _nextPrice, uint256 _sizeDelta) internal view returns (uint256) { uint256 size = Dao.globalShortSize(_dataBase, _poolToken, _indexToken); uint256 averagePrice = Dao.globalShortAveragePrice(_dataBase, _poolToken, _indexToken); uint256 priceDelta = averagePrice > _nextPrice ? averagePrice - _nextPrice : _nextPrice - averagePrice; uint256 delta = size * priceDelta / averagePrice; bool hasProfit = averagePrice > _nextPrice; uint256 nextSize = size + _sizeDelta; uint256 divisor = hasProfit ? nextSize - delta : nextSize + delta; return _nextPrice * nextSize / divisor; } function decreaseGlobalShortSize(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { uint256 size = Dao.globalShortSize(_dataBase, _poolToken, _token); if (_amount > size) { Dao.setGlobalShortSize(_dataBase, _poolToken, _token, 0); return; } Dao.setGlobalShortSize(_dataBase, _poolToken, _token, size - _amount); } function transferIn(DataBase _dataBase, address _owner, address _token) internal returns (uint256) { uint256 prevBalance = Dao.balanceAmount(_dataBase, _owner, _token); uint256 nextBalance = IERC20(_token).balanceOf(_owner); Dao.setBalanceAmount(_dataBase, _owner, _token, nextBalance); return nextBalance - prevBalance; } function transferOut(DataBase _dataBase, address _owner, address _token, uint256 _amount, address _receiver) internal { if (_owner == address(this)) { IERC20(_token).safeTransfer(_receiver, _amount); } else { IERC20(_token).safeTransferFrom(_owner, _receiver, _amount); } updateTokenBalance(_dataBase, _owner, _token); } function poolTransferOut(DataBase _dataBase, address _poolToken, address _token, uint256 _amount, address _receiver) internal { IPoolToken(_poolToken).transferOut(_token, _receiver, _amount); updateTokenBalance(_dataBase, _poolToken, _token); } function getRedemptionAmount(DataBase _dataBase, address _token, uint256 _decimals, uint256 _usdgAmount) internal view returns (uint256) { uint256 price = PriceLib.pricesMax(_dataBase, _token); uint256 redemptionAmount = _usdgAmount * PriceLib.PRICE_PRECISION / price; return adjustForDecimals(redemptionAmount, VaultLib.USDG_DECIMALS, _decimals); } function updateTokenBalance(DataBase _dataBase, address _owner, address _token) internal { uint256 nextBalance = IERC20(_token).balanceOf(_owner); Dao.setBalanceAmount(_dataBase, _owner, _token, nextBalance); } function validateBufferAmount(DataBase _dataBase, address _poolToken, address _token) internal view { uint256 poolAmount = Dao.poolAmount(_dataBase, _poolToken, _token); uint256 bufferAmount = Dao.bufferAmount(_dataBase, _poolToken, _token); if (poolAmount < bufferAmount) { revert PoolLessThanBuffer(_poolToken, _token, poolAmount, bufferAmount); } } function validateStableToken(DataBase _dataBase, address _poolToken, address _token) internal view { if (!VaultDao.poolStableToken(_dataBase, _poolToken, _token)) { revert InvalidStableToken(); } } function validateIndexToken(DataBase _dataBase, address _poolToken, address _token) internal view { if (!VaultDao.poolIndexToken(_dataBase, _poolToken, _token)) { revert InvalidIndexToken(); } } }@openzeppelin/contracts/utils/Panic.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (utils/Panic.sol) pragma solidity ^0.8.20; /** * @dev Helper library for emitting standardized panic codes. * * ```solidity * contract Example { * using Panic for uint256; * * // Use any of the declared internal constants * function foo() { Panic.GENERIC.panic(); } * * // Alternatively * function foo() { Panic.panic(Panic.GENERIC); } * } * ``` * * Follows the list from https://github.com/ethereum/solidity/blob/v0.8.24/libsolutil/ErrorCodes.h[libsolutil]. * * _Available since v5.1._ */ // slither-disable-next-line unused-state library Panic { /// @dev generic / unspecified error uint256 internal constant GENERIC = 0x00; /// @dev used by the assert() builtin uint256 internal constant ASSERT = 0x01; /// @dev arithmetic underflow or overflow uint256 internal constant UNDER_OVERFLOW = 0x11; /// @dev division or modulo by zero uint256 internal constant DIVISION_BY_ZERO = 0x12; /// @dev enum conversion error uint256 internal constant ENUM_CONVERSION_ERROR = 0x21; /// @dev invalid encoding in storage uint256 internal constant STORAGE_ENCODING_ERROR = 0x22; /// @dev empty array pop uint256 internal constant EMPTY_ARRAY_POP = 0x31; /// @dev array out of bounds access uint256 internal constant ARRAY_OUT_OF_BOUNDS = 0x32; /// @dev resource error (too large allocation or too large array) uint256 internal constant RESOURCE_ERROR = 0x41; /// @dev calling invalid internal function uint256 internal constant INVALID_INTERNAL_FUNCTION = 0x51; /// @dev Reverts with a panic code. Recommended to use with /// the internal constants with predefined codes. function panic(uint256 code) internal pure { assembly ("memory-safe") { mstore(0x00, 0x4e487b71) mstore(0x20, code) revert(0x1c, 0x24) } } }@openzeppelin/contracts/token/ERC20/IERC20.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (token/ERC20/IERC20.sol) pragma solidity ^0.8.20; /** * @dev Interface of the ERC-20 standard as defined in the ERC. */ interface IERC20 { /** * @dev Emitted when `value` tokens are moved from one account (`from`) to * another (`to`). * * Note that `value` may be zero. */ event Transfer(address indexed from, address indexed to, uint256 value); /** * @dev Emitted when the allowance of a `spender` for an `owner` is set by * a call to {approve}. `value` is the new allowance. */ event Approval(address indexed owner, address indexed spender, uint256 value); /** * @dev Returns the value of tokens in existence. */ function totalSupply() external view returns (uint256); /** * @dev Returns the value of tokens owned by `account`. */ function balanceOf(address account) external view returns (uint256); /** * @dev Moves a `value` amount of tokens from the caller's account to `to`. * * Returns a boolean value indicating whether the operation succeeded. * * Emits a {Transfer} event. */ function transfer(address to, uint256 value) external returns (bool); /** * @dev Returns the remaining number of tokens that `spender` will be * allowed to spend on behalf of `owner` through {transferFrom}. This is * zero by default. * * This value changes when {approve} or {transferFrom} are called. */ function allowance(address owner, address spender) external view returns (uint256); /** * @dev Sets a `value` amount of tokens as the allowance of `spender` over the * caller's tokens. * * Returns a boolean value indicating whether the operation succeeded. * * IMPORTANT: Beware that changing an allowance with this method brings the risk * that someone may use both the old and the new allowance by unfortunate * transaction ordering. One possible solution to mitigate this race * condition is to first reduce the spender's allowance to 0 and set the * desired value afterwards: * https://github.com/ethereum/EIPs/issues/20#issuecomment-263524729 * * Emits an {Approval} event. */ function approve(address spender, uint256 value) external returns (bool); /** * @dev Moves a `value` amount of tokens from `from` to `to` using the * allowance mechanism. `value` is then deducted from the caller's * allowance. * * Returns a boolean value indicating whether the operation succeeded. * * Emits a {Transfer} event. */ function transferFrom(address from, address to, uint256 value) external returns (bool); }contracts/oracle/PriceLib.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import {DataBase} from "../repo/DataBase.sol"; import "../utils/Keys.sol"; import "../repo/Dao.sol"; library PriceLib { struct Prices { uint256 min; uint256 max; } uint256 public constant PRICE_PRECISION = 10 ** 30; function isEmpty(Prices memory _prices) internal pure returns (bool) { return _prices.min == 0 || _prices.max == 0; } function checkMinMax(Prices memory _prices) internal pure returns (bool) { return _prices.min > _prices.max; } function midPrice(Prices memory _prices) internal pure returns (uint256) { return (_prices.max + _prices.min) / 2; } function pickPrice(Prices memory _prices, bool _maximize) internal pure returns (uint256) { return _maximize ? _prices.max : _prices.min; } function pickPriceForPnl(Prices memory _prices, bool _isLong, bool _maximize) internal pure returns (uint256) { // for long positions, pick the larger price to maximize pnl // for short positions, pick the smaller price to maximize pnl if (_isLong) { return _maximize ? _prices.max : _prices.min; } return _maximize ? _prices.min : _prices.max; } function tokenPrices(DataBase _dataBase, address _token) internal view returns(Prices memory) { return Prices( _dataBase.getUint(Keys.pricesMin(_token)), _dataBase.getUint(Keys.pricesMax(_token)) ); } function pricesLow(DataBase _dataBase, address _token, bool _isLong) internal view returns (uint256) { return _isLong ? pricesMin(_dataBase, _token) : pricesMax(_dataBase, _token); } function pricesMin(DataBase _dataBase, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.pricesMin(_token)); } function pricesMax(DataBase _dataBase, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.pricesMax(_token)); } function setPrices(DataBase _dataBase, address _token, uint256 _price) internal { _setPrices(_dataBase, _token, _price, _price); } function setPrices(DataBase _dataBase, address _token, Prices memory _prices) internal { _setPrices(_dataBase, _token, _prices.min, _prices.max); } function havePrices(DataBase _dataBase, address _token) internal view returns (bool) { if (_dataBase.containsAddress(Keys.PRICES_LIST, _token)) { return true; } return false; } function tokensWithPrices(DataBase _dataBase) internal view returns (address[] memory) { uint256 _count = _dataBase.getAddressCount(Keys.PRICES_LIST); return _dataBase.getAddressValuesAt(Keys.PRICES_LIST, 0, _count); } function pricesForTokens(DataBase _dataBase, address[] memory _tokens, bool _maximize) internal view returns (uint256[] memory) { uint256[] memory _prices = new uint256[](_tokens.length); for (uint256 i = 0; i < _tokens.length; i ++) { if (_maximize) { _prices[i] = _dataBase.getUint(Keys.pricesMax(_tokens[i])); } else { _prices[i] = _dataBase.getUint(Keys.pricesMin(_tokens[i])); } } return _prices; } function tokenToUsdMin(DataBase _dataBase, address _token, uint256 _decimals, uint256 _tokenAmount) internal view returns (uint256) { if (_tokenAmount == 0) { return 0; } uint256 _price = pricesMin(_dataBase, _token); return _tokenAmount * _price / 10 ** _decimals; } function tokenToUsdMin(DataBase _dataBase, address _token, uint256 _tokenAmount) internal view returns (uint256) { if (_tokenAmount == 0) { return 0; } uint256 _decimals = Dao.tokenDecimals(_dataBase, _token); if (_decimals == 0) { return 0; } uint256 _price = pricesMin(_dataBase, _token); return _tokenAmount * _price / 10 ** _decimals; } function usdToTokenMax(DataBase _dataBase, address _token, uint256 _usdAmount) internal view returns (uint256) { if (_usdAmount == 0) { return 0; } return usdToToken(_dataBase, _token, _usdAmount, pricesMin(_dataBase, _token)); } function usdToTokenMin(DataBase _dataBase, address _token, uint256 _usdAmount) internal view returns (uint256) { if (_usdAmount == 0) { return 0; } return usdToToken(_dataBase, _token, _usdAmount, pricesMax(_dataBase, _token)); } function usdToToken(DataBase _dataBase, address _token, uint256 _usdAmount, uint256 _price) internal view returns (uint256) { if (_usdAmount == 0) { return 0; } uint256 decimals = Dao.tokenDecimals(_dataBase, _token); return _usdAmount * 10 ** decimals / _price; } function _setPrices(DataBase _dataBase, address _token, uint256 _min, uint256 _max) internal { _dataBase.setUint(Keys.pricesMin(_token), _min); _dataBase.setUint(Keys.pricesMax(_token), _max); if (!_dataBase.containsAddress(Keys.PRICES_LIST, _token)) { _dataBase.addAddress(Keys.PRICES_LIST, _token); } } }@openzeppelin/contracts/utils/math/Math.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.3.0) (utils/math/Math.sol) pragma solidity ^0.8.20; import {Panic} from "../Panic.sol"; import {SafeCast} from "./SafeCast.sol"; /** * @dev Standard math utilities missing in the Solidity language. */ library Math { enum Rounding { Floor, // Toward negative infinity Ceil, // Toward positive infinity Trunc, // Toward zero Expand // Away from zero } /** * @dev Return the 512-bit addition of two uint256. * * The result is stored in two 256 variables such that sum = high * 2²⁵⁶ + low. */ function add512(uint256 a, uint256 b) internal pure returns (uint256 high, uint256 low) { assembly ("memory-safe") { low := add(a, b) high := lt(low, a) } } /** * @dev Return the 512-bit multiplication of two uint256. * * The result is stored in two 256 variables such that product = high * 2²⁵⁶ + low. */ function mul512(uint256 a, uint256 b) internal pure returns (uint256 high, uint256 low) { // 512-bit multiply [high low] = x * y. Compute the product mod 2²⁵⁶ and mod 2²⁵⁶ - 1, then use // the Chinese Remainder Theorem to reconstruct the 512 bit result. The result is stored in two 256 // variables such that product = high * 2²⁵⁶ + low. assembly ("memory-safe") { let mm := mulmod(a, b, not(0)) low := mul(a, b) high := sub(sub(mm, low), lt(mm, low)) } } /** * @dev Returns the addition of two unsigned integers, with a success flag (no overflow). */ function tryAdd(uint256 a, uint256 b) internal pure returns (bool success, uint256 result) { unchecked { uint256 c = a + b; success = c >= a; result = c * SafeCast.toUint(success); } } /** * @dev Returns the subtraction of two unsigned integers, with a success flag (no overflow). */ function trySub(uint256 a, uint256 b) internal pure returns (bool success, uint256 result) { unchecked { uint256 c = a - b; success = c <= a; result = c * SafeCast.toUint(success); } } /** * @dev Returns the multiplication of two unsigned integers, with a success flag (no overflow). */ function tryMul(uint256 a, uint256 b) internal pure returns (bool success, uint256 result) { unchecked { uint256 c = a * b; assembly ("memory-safe") { // Only true when the multiplication doesn't overflow // (c / a == b) || (a == 0) success := or(eq(div(c, a), b), iszero(a)) } // equivalent to: success ? c : 0 result = c * SafeCast.toUint(success); } } /** * @dev Returns the division of two unsigned integers, with a success flag (no division by zero). */ function tryDiv(uint256 a, uint256 b) internal pure returns (bool success, uint256 result) { unchecked { success = b > 0; assembly ("memory-safe") { // The `DIV` opcode returns zero when the denominator is 0. result := div(a, b) } } } /** * @dev Returns the remainder of dividing two unsigned integers, with a success flag (no division by zero). */ function tryMod(uint256 a, uint256 b) internal pure returns (bool success, uint256 result) { unchecked { success = b > 0; assembly ("memory-safe") { // The `MOD` opcode returns zero when the denominator is 0. result := mod(a, b) } } } /** * @dev Unsigned saturating addition, bounds to `2²⁵⁶ - 1` instead of overflowing. */ function saturatingAdd(uint256 a, uint256 b) internal pure returns (uint256) { (bool success, uint256 result) = tryAdd(a, b); return ternary(success, result, type(uint256).max); } /** * @dev Unsigned saturating subtraction, bounds to zero instead of overflowing. */ function saturatingSub(uint256 a, uint256 b) internal pure returns (uint256) { (, uint256 result) = trySub(a, b); return result; } /** * @dev Unsigned saturating multiplication, bounds to `2²⁵⁶ - 1` instead of overflowing. */ function saturatingMul(uint256 a, uint256 b) internal pure returns (uint256) { (bool success, uint256 result) = tryMul(a, b); return ternary(success, result, type(uint256).max); } /** * @dev Branchless ternary evaluation for `a ? b : c`. Gas costs are constant. * * IMPORTANT: This function may reduce bytecode size and consume less gas when used standalone. * However, the compiler may optimize Solidity ternary operations (i.e. `a ? b : c`) to only compute * one branch when needed, making this function more expensive. */ function ternary(bool condition, uint256 a, uint256 b) internal pure returns (uint256) { unchecked { // branchless ternary works because: // b ^ (a ^ b) == a // b ^ 0 == b return b ^ ((a ^ b) * SafeCast.toUint(condition)); } } /** * @dev Returns the largest of two numbers. */ function max(uint256 a, uint256 b) internal pure returns (uint256) { return ternary(a > b, a, b); } /** * @dev Returns the smallest of two numbers. */ function min(uint256 a, uint256 b) internal pure returns (uint256) { return ternary(a < b, a, b); } /** * @dev Returns the average of two numbers. The result is rounded towards * zero. */ function average(uint256 a, uint256 b) internal pure returns (uint256) { // (a + b) / 2 can overflow. return (a & b) + (a ^ b) / 2; } /** * @dev Returns the ceiling of the division of two numbers. * * This differs from standard division with `/` in that it rounds towards infinity instead * of rounding towards zero. */ function ceilDiv(uint256 a, uint256 b) internal pure returns (uint256) { if (b == 0) { // Guarantee the same behavior as in a regular Solidity division. Panic.panic(Panic.DIVISION_BY_ZERO); } // The following calculation ensures accurate ceiling division without overflow. // Since a is non-zero, (a - 1) / b will not overflow. // The largest possible result occurs when (a - 1) / b is type(uint256).max, // but the largest value we can obtain is type(uint256).max - 1, which happens // when a = type(uint256).max and b = 1. unchecked { return SafeCast.toUint(a > 0) * ((a - 1) / b + 1); } } /** * @dev Calculates floor(x * y / denominator) with full precision. Throws if result overflows a uint256 or * denominator == 0. * * Original credit to Remco Bloemen under MIT license (https://xn--2-umb.com/21/muldiv) with further edits by * Uniswap Labs also under MIT license. */ function mulDiv(uint256 x, uint256 y, uint256 denominator) internal pure returns (uint256 result) { unchecked { (uint256 high, uint256 low) = mul512(x, y); // Handle non-overflow cases, 256 by 256 division. if (high == 0) { // Solidity will revert if denominator == 0, unlike the div opcode on its own. // The surrounding unchecked block does not change this fact. // See https://docs.soliditylang.org/en/latest/control-structures.html#checked-or-unchecked-arithmetic. return low / denominator; } // Make sure the result is less than 2²⁵⁶. Also prevents denominator == 0. if (denominator <= high) { Panic.panic(ternary(denominator == 0, Panic.DIVISION_BY_ZERO, Panic.UNDER_OVERFLOW)); } /////////////////////////////////////////////// // 512 by 256 division. /////////////////////////////////////////////// // Make division exact by subtracting the remainder from [high low]. uint256 remainder; assembly ("memory-safe") { // Compute remainder using mulmod. remainder := mulmod(x, y, denominator) // Subtract 256 bit number from 512 bit number. high := sub(high, gt(remainder, low)) low := sub(low, remainder) } // Factor powers of two out of denominator and compute largest power of two divisor of denominator. // Always >= 1. See https://cs.stackexchange.com/q/138556/92363. uint256 twos = denominator & (0 - denominator); assembly ("memory-safe") { // Divide denominator by twos. denominator := div(denominator, twos) // Divide [high low] by twos. low := div(low, twos) // Flip twos such that it is 2²⁵⁶ / twos. If twos is zero, then it becomes one. twos := add(div(sub(0, twos), twos), 1) } // Shift in bits from high into low. low |= high * twos; // Invert denominator mod 2²⁵⁶. Now that denominator is an odd number, it has an inverse modulo 2²⁵⁶ such // that denominator * inv ≡ 1 mod 2²⁵⁶. Compute the inverse by starting with a seed that is correct for // four bits. That is, denominator * inv ≡ 1 mod 2⁴. uint256 inverse = (3 * denominator) ^ 2; // Use the Newton-Raphson iteration to improve the precision. Thanks to Hensel's lifting lemma, this also // works in modular arithmetic, doubling the correct bits in each step. inverse *= 2 - denominator * inverse; // inverse mod 2⁸ inverse *= 2 - denominator * inverse; // inverse mod 2¹⁶ inverse *= 2 - denominator * inverse; // inverse mod 2³² inverse *= 2 - denominator * inverse; // inverse mod 2⁶⁴ inverse *= 2 - denominator * inverse; // inverse mod 2¹²⁸ inverse *= 2 - denominator * inverse; // inverse mod 2²⁵⁶ // Because the division is now exact we can divide by multiplying with the modular inverse of denominator. // This will give us the correct result modulo 2²⁵⁶. Since the preconditions guarantee that the outcome is // less than 2²⁵⁶, this is the final result. We don't need to compute the high bits of the result and high // is no longer required. result = low * inverse; return result; } } /** * @dev Calculates x * y / denominator with full precision, following the selected rounding direction. */ function mulDiv(uint256 x, uint256 y, uint256 denominator, Rounding rounding) internal pure returns (uint256) { return mulDiv(x, y, denominator) + SafeCast.toUint(unsignedRoundsUp(rounding) && mulmod(x, y, denominator) > 0); } /** * @dev Calculates floor(x * y >> n) with full precision. Throws if result overflows a uint256. */ function mulShr(uint256 x, uint256 y, uint8 n) internal pure returns (uint256 result) { unchecked { (uint256 high, uint256 low) = mul512(x, y); if (high >= 1 << n) { Panic.panic(Panic.UNDER_OVERFLOW); } return (high << (256 - n)) | (low >> n); } } /** * @dev Calculates x * y >> n with full precision, following the selected rounding direction. */ function mulShr(uint256 x, uint256 y, uint8 n, Rounding rounding) internal pure returns (uint256) { return mulShr(x, y, n) + SafeCast.toUint(unsignedRoundsUp(rounding) && mulmod(x, y, 1 << n) > 0); } /** * @dev Calculate the modular multiplicative inverse of a number in Z/nZ. * * If n is a prime, then Z/nZ is a field. In that case all elements are inversible, except 0. * If n is not a prime, then Z/nZ is not a field, and some elements might not be inversible. * * If the input value is not inversible, 0 is returned. * * NOTE: If you know for sure that n is (big) a prime, it may be cheaper to use Fermat's little theorem and get the * inverse using `Math.modExp(a, n - 2, n)`. See {invModPrime}. */ function invMod(uint256 a, uint256 n) internal pure returns (uint256) { unchecked { if (n == 0) return 0; // The inverse modulo is calculated using the Extended Euclidean Algorithm (iterative version) // Used to compute integers x and y such that: ax + ny = gcd(a, n). // When the gcd is 1, then the inverse of a modulo n exists and it's x. // ax + ny = 1 // ax = 1 + (-y)n // ax ≡ 1 (mod n) # x is the inverse of a modulo n // If the remainder is 0 the gcd is n right away. uint256 remainder = a % n; uint256 gcd = n; // Therefore the initial coefficients are: // ax + ny = gcd(a, n) = n // 0a + 1n = n int256 x = 0; int256 y = 1; while (remainder != 0) { uint256 quotient = gcd / remainder; (gcd, remainder) = ( // The old remainder is the next gcd to try. remainder, // Compute the next remainder. // Can't overflow given that (a % gcd) * (gcd // (a % gcd)) <= gcd // where gcd is at most n (capped to type(uint256).max) gcd - remainder * quotient ); (x, y) = ( // Increment the coefficient of a. y, // Decrement the coefficient of n. // Can overflow, but the result is casted to uint256 so that the // next value of y is "wrapped around" to a value between 0 and n - 1. x - y * int256(quotient) ); } if (gcd != 1) return 0; // No inverse exists. return ternary(x < 0, n - uint256(-x), uint256(x)); // Wrap the result if it's negative. } } /** * @dev Variant of {invMod}. More efficient, but only works if `p` is known to be a prime greater than `2`. * * From https://en.wikipedia.org/wiki/Fermat%27s_little_theorem[Fermat's little theorem], we know that if p is * prime, then `a**(p-1) ≡ 1 mod p`. As a consequence, we have `a * a**(p-2) ≡ 1 mod p`, which means that * `a**(p-2)` is the modular multiplicative inverse of a in Fp. * * NOTE: this function does NOT check that `p` is a prime greater than `2`. */ function invModPrime(uint256 a, uint256 p) internal view returns (uint256) { unchecked { return Math.modExp(a, p - 2, p); } } /** * @dev Returns the modular exponentiation of the specified base, exponent and modulus (b ** e % m) * * Requirements: * - modulus can't be zero * - underlying staticcall to precompile must succeed * * IMPORTANT: The result is only valid if the underlying call succeeds. When using this function, make * sure the chain you're using it on supports the precompiled contract for modular exponentiation * at address 0x05 as specified in https://eips.ethereum.org/EIPS/eip-198[EIP-198]. Otherwise, * the underlying function will succeed given the lack of a revert, but the result may be incorrectly * interpreted as 0. */ function modExp(uint256 b, uint256 e, uint256 m) internal view returns (uint256) { (bool success, uint256 result) = tryModExp(b, e, m); if (!success) { Panic.panic(Panic.DIVISION_BY_ZERO); } return result; } /** * @dev Returns the modular exponentiation of the specified base, exponent and modulus (b ** e % m). * It includes a success flag indicating if the operation succeeded. Operation will be marked as failed if trying * to operate modulo 0 or if the underlying precompile reverted. * * IMPORTANT: The result is only valid if the success flag is true. When using this function, make sure the chain * you're using it on supports the precompiled contract for modular exponentiation at address 0x05 as specified in * https://eips.ethereum.org/EIPS/eip-198[EIP-198]. Otherwise, the underlying function will succeed given the lack * of a revert, but the result may be incorrectly interpreted as 0. */ function tryModExp(uint256 b, uint256 e, uint256 m) internal view returns (bool success, uint256 result) { if (m == 0) return (false, 0); assembly ("memory-safe") { let ptr := mload(0x40) // | Offset | Content | Content (Hex) | // |-----------|------------|--------------------------------------------------------------------| // | 0x00:0x1f | size of b | 0x0000000000000000000000000000000000000000000000000000000000000020 | // | 0x20:0x3f | size of e | 0x0000000000000000000000000000000000000000000000000000000000000020 | // | 0x40:0x5f | size of m | 0x0000000000000000000000000000000000000000000000000000000000000020 | // | 0x60:0x7f | value of b | 0x<.............................................................b> | // | 0x80:0x9f | value of e | 0x<.............................................................e> | // | 0xa0:0xbf | value of m | 0x<.............................................................m> | mstore(ptr, 0x20) mstore(add(ptr, 0x20), 0x20) mstore(add(ptr, 0x40), 0x20) mstore(add(ptr, 0x60), b) mstore(add(ptr, 0x80), e) mstore(add(ptr, 0xa0), m) // Given the result < m, it's guaranteed to fit in 32 bytes, // so we can use the memory scratch space located at offset 0. success := staticcall(gas(), 0x05, ptr, 0xc0, 0x00, 0x20) result := mload(0x00) } } /** * @dev Variant of {modExp} that supports inputs of arbitrary length. */ function modExp(bytes memory b, bytes memory e, bytes memory m) internal view returns (bytes memory) { (bool success, bytes memory result) = tryModExp(b, e, m); if (!success) { Panic.panic(Panic.DIVISION_BY_ZERO); } return result; } /** * @dev Variant of {tryModExp} that supports inputs of arbitrary length. */ function tryModExp( bytes memory b, bytes memory e, bytes memory m ) internal view returns (bool success, bytes memory result) { if (_zeroBytes(m)) return (false, new bytes(0)); uint256 mLen = m.length; // Encode call args in result and move the free memory pointer result = abi.encodePacked(b.length, e.length, mLen, b, e, m); assembly ("memory-safe") { let dataPtr := add(result, 0x20) // Write result on top of args to avoid allocating extra memory. success := staticcall(gas(), 0x05, dataPtr, mload(result), dataPtr, mLen) // Overwrite the length. // result.length > returndatasize() is guaranteed because returndatasize() == m.length mstore(result, mLen) // Set the memory pointer after the returned data. mstore(0x40, add(dataPtr, mLen)) } } /** * @dev Returns whether the provided byte array is zero. */ function _zeroBytes(bytes memory byteArray) private pure returns (bool) { for (uint256 i = 0; i < byteArray.length; ++i) { if (byteArray[i] != 0) { return false; } } return true; } /** * @dev Returns the square root of a number. If the number is not a perfect square, the value is rounded * towards zero. * * This method is based on Newton's method for computing square roots; the algorithm is restricted to only * using integer operations. */ function sqrt(uint256 a) internal pure returns (uint256) { unchecked { // Take care of easy edge cases when a == 0 or a == 1 if (a <= 1) { return a; } // In this function, we use Newton's method to get a root of `f(x) := x² - a`. It involves building a // sequence x_n that converges toward sqrt(a). For each iteration x_n, we also define the error between // the current value as `ε_n = | x_n - sqrt(a) |`. // // For our first estimation, we consider `e` the smallest power of 2 which is bigger than the square root // of the target. (i.e. `2**(e-1) ≤ sqrt(a) < 2**e`). We know that `e ≤ 128` because `(2¹²⁸)² = 2²⁵⁶` is // bigger than any uint256. // // By noticing that // `2**(e-1) ≤ sqrt(a) < 2**e → (2**(e-1))² ≤ a < (2**e)² → 2**(2*e-2) ≤ a < 2**(2*e)` // we can deduce that `e - 1` is `log2(a) / 2`. We can thus compute `x_n = 2**(e-1)` using a method similar // to the msb function. uint256 aa = a; uint256 xn = 1; if (aa >= (1 << 128)) { aa >>= 128; xn <<= 64; } if (aa >= (1 << 64)) { aa >>= 64; xn <<= 32; } if (aa >= (1 << 32)) { aa >>= 32; xn <<= 16; } if (aa >= (1 << 16)) { aa >>= 16; xn <<= 8; } if (aa >= (1 << 8)) { aa >>= 8; xn <<= 4; } if (aa >= (1 << 4)) { aa >>= 4; xn <<= 2; } if (aa >= (1 << 2)) { xn <<= 1; } // We now have x_n such that `x_n = 2**(e-1) ≤ sqrt(a) < 2**e = 2 * x_n`. This implies ε_n ≤ 2**(e-1). // // We can refine our estimation by noticing that the middle of that interval minimizes the error. // If we move x_n to equal 2**(e-1) + 2**(e-2), then we reduce the error to ε_n ≤ 2**(e-2). // This is going to be our x_0 (and ε_0) xn = (3 * xn) >> 1; // ε_0 := | x_0 - sqrt(a) | ≤ 2**(e-2) // From here, Newton's method give us: // x_{n+1} = (x_n + a / x_n) / 2 // // One should note that: // x_{n+1}² - a = ((x_n + a / x_n) / 2)² - a // = ((x_n² + a) / (2 * x_n))² - a // = (x_n⁴ + 2 * a * x_n² + a²) / (4 * x_n²) - a // = (x_n⁴ + 2 * a * x_n² + a² - 4 * a * x_n²) / (4 * x_n²) // = (x_n⁴ - 2 * a * x_n² + a²) / (4 * x_n²) // = (x_n² - a)² / (2 * x_n)² // = ((x_n² - a) / (2 * x_n))² // ≥ 0 // Which proves that for all n ≥ 1, sqrt(a) ≤ x_n // // This gives us the proof of quadratic convergence of the sequence: // ε_{n+1} = | x_{n+1} - sqrt(a) | // = | (x_n + a / x_n) / 2 - sqrt(a) | // = | (x_n² + a - 2*x_n*sqrt(a)) / (2 * x_n) | // = | (x_n - sqrt(a))² / (2 * x_n) | // = | ε_n² / (2 * x_n) | // = ε_n² / | (2 * x_n) | // // For the first iteration, we have a special case where x_0 is known: // ε_1 = ε_0² / | (2 * x_0) | // ≤ (2**(e-2))² / (2 * (2**(e-1) + 2**(e-2))) // ≤ 2**(2*e-4) / (3 * 2**(e-1)) // ≤ 2**(e-3) / 3 // ≤ 2**(e-3-log2(3)) // ≤ 2**(e-4.5) // // For the following iterations, we use the fact that, 2**(e-1) ≤ sqrt(a) ≤ x_n: // ε_{n+1} = ε_n² / | (2 * x_n) | // ≤ (2**(e-k))² / (2 * 2**(e-1)) // ≤ 2**(2*e-2*k) / 2**e // ≤ 2**(e-2*k) xn = (xn + a / xn) >> 1; // ε_1 := | x_1 - sqrt(a) | ≤ 2**(e-4.5) -- special case, see above xn = (xn + a / xn) >> 1; // ε_2 := | x_2 - sqrt(a) | ≤ 2**(e-9) -- general case with k = 4.5 xn = (xn + a / xn) >> 1; // ε_3 := | x_3 - sqrt(a) | ≤ 2**(e-18) -- general case with k = 9 xn = (xn + a / xn) >> 1; // ε_4 := | x_4 - sqrt(a) | ≤ 2**(e-36) -- general case with k = 18 xn = (xn + a / xn) >> 1; // ε_5 := | x_5 - sqrt(a) | ≤ 2**(e-72) -- general case with k = 36 xn = (xn + a / xn) >> 1; // ε_6 := | x_6 - sqrt(a) | ≤ 2**(e-144) -- general case with k = 72 // Because e ≤ 128 (as discussed during the first estimation phase), we know have reached a precision // ε_6 ≤ 2**(e-144) < 1. Given we're operating on integers, then we can ensure that xn is now either // sqrt(a) or sqrt(a) + 1. return xn - SafeCast.toUint(xn > a / xn); } } /** * @dev Calculates sqrt(a), following the selected rounding direction. */ function sqrt(uint256 a, Rounding rounding) internal pure returns (uint256) { unchecked { uint256 result = sqrt(a); return result + SafeCast.toUint(unsignedRoundsUp(rounding) && result * result < a); } } /** * @dev Return the log in base 2 of a positive value rounded towards zero. * Returns 0 if given 0. */ function log2(uint256 x) internal pure returns (uint256 r) { // If value has upper 128 bits set, log2 result is at least 128 r = SafeCast.toUint(x > 0xffffffffffffffffffffffffffffffff) << 7; // If upper 64 bits of 128-bit half set, add 64 to result r |= SafeCast.toUint((x >> r) > 0xffffffffffffffff) << 6; // If upper 32 bits of 64-bit half set, add 32 to result r |= SafeCast.toUint((x >> r) > 0xffffffff) << 5; // If upper 16 bits of 32-bit half set, add 16 to result r |= SafeCast.toUint((x >> r) > 0xffff) << 4; // If upper 8 bits of 16-bit half set, add 8 to result r |= SafeCast.toUint((x >> r) > 0xff) << 3; // If upper 4 bits of 8-bit half set, add 4 to result r |= SafeCast.toUint((x >> r) > 0xf) << 2; // Shifts value right by the current result and use it as an index into this lookup table: // // | x (4 bits) | index | table[index] = MSB position | // |------------|---------|-----------------------------| // | 0000 | 0 | table[0] = 0 | // | 0001 | 1 | table[1] = 0 | // | 0010 | 2 | table[2] = 1 | // | 0011 | 3 | table[3] = 1 | // | 0100 | 4 | table[4] = 2 | // | 0101 | 5 | table[5] = 2 | // | 0110 | 6 | table[6] = 2 | // | 0111 | 7 | table[7] = 2 | // | 1000 | 8 | table[8] = 3 | // | 1001 | 9 | table[9] = 3 | // | 1010 | 10 | table[10] = 3 | // | 1011 | 11 | table[11] = 3 | // | 1100 | 12 | table[12] = 3 | // | 1101 | 13 | table[13] = 3 | // | 1110 | 14 | table[14] = 3 | // | 1111 | 15 | table[15] = 3 | // // The lookup table is represented as a 32-byte value with the MSB positions for 0-15 in the last 16 bytes. assembly ("memory-safe") { r := or(r, byte(shr(r, x), 0x0000010102020202030303030303030300000000000000000000000000000000)) } } /** * @dev Return the log in base 2, following the selected rounding direction, of a positive value. * Returns 0 if given 0. */ function log2(uint256 value, Rounding rounding) internal pure returns (uint256) { unchecked { uint256 result = log2(value); return result + SafeCast.toUint(unsignedRoundsUp(rounding) && 1 << result < value); } } /** * @dev Return the log in base 10 of a positive value rounded towards zero. * Returns 0 if given 0. */ function log10(uint256 value) internal pure returns (uint256) { uint256 result = 0; unchecked { if (value >= 10 ** 64) { value /= 10 ** 64; result += 64; } if (value >= 10 ** 32) { value /= 10 ** 32; result += 32; } if (value >= 10 ** 16) { value /= 10 ** 16; result += 16; } if (value >= 10 ** 8) { value /= 10 ** 8; result += 8; } if (value >= 10 ** 4) { value /= 10 ** 4; result += 4; } if (value >= 10 ** 2) { value /= 10 ** 2; result += 2; } if (value >= 10 ** 1) { result += 1; } } return result; } /** * @dev Return the log in base 10, following the selected rounding direction, of a positive value. * Returns 0 if given 0. */ function log10(uint256 value, Rounding rounding) internal pure returns (uint256) { unchecked { uint256 result = log10(value); return result + SafeCast.toUint(unsignedRoundsUp(rounding) && 10 ** result < value); } } /** * @dev Return the log in base 256 of a positive value rounded towards zero. * Returns 0 if given 0. * * Adding one to the result gives the number of pairs of hex symbols needed to represent `value` as a hex string. */ function log256(uint256 x) internal pure returns (uint256 r) { // If value has upper 128 bits set, log2 result is at least 128 r = SafeCast.toUint(x > 0xffffffffffffffffffffffffffffffff) << 7; // If upper 64 bits of 128-bit half set, add 64 to result r |= SafeCast.toUint((x >> r) > 0xffffffffffffffff) << 6; // If upper 32 bits of 64-bit half set, add 32 to result r |= SafeCast.toUint((x >> r) > 0xffffffff) << 5; // If upper 16 bits of 32-bit half set, add 16 to result r |= SafeCast.toUint((x >> r) > 0xffff) << 4; // Add 1 if upper 8 bits of 16-bit half set, and divide accumulated result by 8 return (r >> 3) | SafeCast.toUint((x >> r) > 0xff); } /** * @dev Return the log in base 256, following the selected rounding direction, of a positive value. * Returns 0 if given 0. */ function log256(uint256 value, Rounding rounding) internal pure returns (uint256) { unchecked { uint256 result = log256(value); return result + SafeCast.toUint(unsignedRoundsUp(rounding) && 1 << (result << 3) < value); } } /** * @dev Returns whether a provided rounding mode is considered rounding up for unsigned integers. */ function unsignedRoundsUp(Rounding rounding) internal pure returns (bool) { return uint8(rounding) % 2 == 1; } }contracts/utils/Role.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; library Role { uint256 public constant ACCESS_NOACCESS = 0; uint256 public constant ACCESS_DEPOSIT = 1; uint256 public constant ACCESS_READER = 2; uint256 public constant ACCESS_AUTHOR = 3; uint256 public constant ACCESS_EDITOR = 4; uint256 public constant ACCESS_DESIGNER = 5; uint256 public constant ACCESS_MANAGER = 6; uint256 public constant DATA_READ = 4; uint256 public constant DATA_WRITE = 2; uint256 public constant DATA_EXECUTE = 1; bytes32 public constant ROLE_ADMIN = keccak256(abi.encode("ROLE_ADMIN")); bytes32 public constant ROLE_ACCESSNOACCESS = keccak256(abi.encode("ROLE_ACCESS", ACCESS_NOACCESS)); bytes32 public constant ROLE_DATA_WRITE = keccak256(abi.encode("DATA_ACCESS", DATA_WRITE)); bytes32 public constant ROLE_POOL_KEEPER = keccak256(abi.encode("POOL_KEEPER")); bytes32 public constant ROLE_ORACLE_KEEPER = keccak256(abi.encode("ORACLE_KEEPER")); }contracts/repo/RoleBase.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "../utils/Role.sol"; contract RoleBase { mapping(address => mapping (bytes32 => bool)) roleStore; error UnauthorizedRoleAdmin(address account); modifier onlyRoleAdmin() { if (!hasRole(msg.sender, Role.ROLE_ADMIN)) { revert UnauthorizedRoleAdmin(msg.sender); } _; } constructor() { _grantRole(msg.sender, Role.ROLE_ADMIN); } function grantRole(address account, bytes32 roleKey) external onlyRoleAdmin { _grantRole(account, roleKey); } function revokeRole(address account, bytes32 roleKey) external onlyRoleAdmin { _revokeRole(account, roleKey); } function hasRole(address account, bytes32 roleKey) public view returns (bool) { return roleStore[account][roleKey]; } function _grantRole(address account, bytes32 roleKey) internal { roleStore[account][roleKey] = true; } function _revokeRole(address account, bytes32 roleKey) internal { roleStore[account][roleKey] = false; } }contracts/utils/Keys.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; library Keys { bytes32 public constant WNT = keccak256(abi.encode("WNT")); bytes32 public constant POOL_MINI_LIST = keccak256(abi.encode("POOL_MINI_LIST")); // for pool token contracts bytes32 public constant POOL_STABLE_LIST = keccak256(abi.encode("POOL_STABLE_LIST")); // for pool token contracts bytes32 public constant POOL_SALT = keccak256(abi.encode("POOL_SALT")); // for pool token salt bytes32 public constant POOL_SALTKEY = keccak256(abi.encode("POOL_SALTKEY")); // for pool token salt key bytes32 public constant PRICES_LIST = keccak256(abi.encode("PRICES_LIST")); // for token contracts with prices bytes32 public constant PRICES_MAX = keccak256(abi.encode("PRICES_MAX")); bytes32 public constant PRICES_MIN = keccak256(abi.encode("PRICES_MIN")); bytes32 public constant AUM_ADDITION = keccak256(abi.encode("AUM_ADDITION")); bytes32 public constant AUM_DEDUCTION = keccak256(abi.encode("AUM_DEDUCTION")); bytes32 public constant ASSETS_TOKENS = keccak256(abi.encode("ASSETS_TOKENS")); bytes32 public constant POOL_AMOUNT = keccak256(abi.encode("POOL_AMOUNT")); bytes32 public constant BUFFER_AMOUNT = keccak256(abi.encode("BUFFER_AMOUNT")); bytes32 public constant TOKEN_DECIMALS = keccak256(abi.encode("TOKEN_DECIMALS")); bytes32 public constant STABLE_TOKEN = keccak256(abi.encode("STABLE_TOKEN")); bytes32 public constant GLOBAL_SHORT_SIZE = keccak256(abi.encode("GLOBAL_SHORT_SIZE")); bytes32 public constant GLOBAL_SHORT_AVERAGEPRICE = keccak256(abi.encode("GLOBAL_SHORT_AVERAGEPRICE")); bytes32 public constant GUARANTEED_USD = keccak256(abi.encode("GUARANTEED_USD")); bytes32 public constant RESERVED_AMOUNT = keccak256(abi.encode("RESERVED_AMOUNT")); bytes32 public constant BALANCE_AMOUNT = keccak256(abi.encode("BALANCE_AMOUNT")); bytes32 public constant USDG_AMOUNT = keccak256(abi.encode("USDG_AMOUNT")); bytes32 public constant FEE_RESERVE_TO = keccak256(abi.encode("FEE_RESERVE_TO")); bytes32 public constant FEE_RESERVE_IN = keccak256(abi.encode("FEE_RESERVE_IN")); bytes32 public constant FUNDING_RATE = keccak256(abi.encode("FUNDING_RATE")); bytes32 public constant LAST_FUNDING_TIME = keccak256(abi.encode("LAST_FUNDING_TIME")); bytes32 public constant MAX_USDG_AMOUNT = keccak256(abi.encode("MAX_USDG_AMOUNT")); bytes32 public constant MAX_GLOBAL_LONG_SIZE = keccak256(abi.encode("MAX_GLOBAL_LONG_SIZE")); bytes32 public constant MAX_GLOBAL_SHORT_SIZE = keccak256(abi.encode("MAX_GLOBAL_SHORT_SIZE")); bytes32 public constant MAX_LEVERAGE = keccak256(abi.encode("MAX_LEVERAGE")); // n * 10000 bytes32 public constant POOL_MINTFEEBASISPOINTS = keccak256(abi.encode("POOL_MINTFEEBASISPOINTS")); // 0 0% bytes32 public constant POOL_BURNFEEBASISPOINTS = keccak256(abi.encode("POOL_BURNFEEBASISPOINTS")); // 30 0.3% bytes32 public constant POOL_STABLETAXBASISPOINTS = keccak256(abi.encode("POOL_STABLETAXBASISPOINTS")); // 20 0.2% bytes32 public constant POOL_TAXBASISPOINTS = keccak256(abi.encode("POOL_TAXBASISPOINTS")); // 50 0.5% bytes32 public constant POOL_STABLESWAPFEEBASISPOINTS = keccak256(abi.encode("POOL_STABLESWAPFEEBASISPOINTS")); // 4 0.04% bytes32 public constant POOL_SWAPFEEBASISPOINTS = keccak256(abi.encode("POOL_SWAPFEEBASISPOINTS")); // 30 0.3% bytes32 public constant POOL_MARGINFEEBASISPOINTS = keccak256(abi.encode("POOL_MARGINFEEBASISPOINTS")); // 10 0.1% bytes32 public constant POOL_LIQUIDATIONFEEUSD = keccak256(abi.encode("POOL_LIQUIDATIONFEEUSD")); // 5 * 10 ** 30 5 usd bytes32 public constant POOL_HASDYNAMICFEES = keccak256(abi.encode("POOL_HASDYNAMICFEES")); // true bytes32 public constant POOL_SWAPFEETOFACTOR = keccak256(abi.encode("POOL_SWAPFEETOFACTOR")); // 6000 60% bytes32 public constant POOL_POSITIONFEETOFACTOR = keccak256(abi.encode("POOL_POSITIONFEETOFACTOR")); // 6000 bytes32 public constant POOL_BORROWINGFEETOFACTOR = keccak256(abi.encode("POOL_BORROWINGFEETOFACTOR")); // 6000 bytes32 public constant POOL_FEETOTEAMFACTOR = keccak256(abi.encode("POOL_BORROWINGFEETOFACTOR")); // 6000 bytes32 public constant POOL_CUMULATIVEFEES = keccak256(abi.encode("POOL_CUMULATIVEFEES")); bytes32 public constant POOL_POOLINFEES = keccak256(abi.encode("POOL_POOLINFEES")); bytes32 public constant POOL_TEAMWALLET = keccak256(abi.encode("POOL_TEAMWALLET")); bytes32 public constant POOL_PARTNERWALLET = keccak256(abi.encode("POOL_PARTNERWALLET")); bytes32 public constant ACCOUNT_POSITION_LIST = keccak256(abi.encode("ACCOUNT_POSITION_LIST")); bytes32 public constant ACCOUNT_TOTAL_LIQUIDITY = keccak256(abi.encode("ACCOUNT_TOTAL_LIQUIDITY")); bytes32 public constant ACCOUNT_POOL_LIQUIDITY = keccak256(abi.encode("ACCOUNT_POOL_LIQUIDITY")); bytes32 public constant ACCOUNT_TOTAL_VOLUME = keccak256(abi.encode("ACCOUNT_TOTAL_VOLUME")); bytes32 public constant ACCOUNT_POOL_VOLUME = keccak256(abi.encode("ACCOUNT_POOL_VOLUME")); bytes32 public constant POOL_POSITION_LIST = keccak256(abi.encode("POOL_POSITION_LIST")); bytes32 public constant INDEX_TOKEN_LIST = keccak256(abi.encode("INDEX_TOKEN_LIST")); bytes32 public constant STABLE_TOKEN_LIST = keccak256(abi.encode("STABLE_TOKEN_LIST")); bytes32 public constant LAST_ADDED_AT = keccak256(abi.encode("LAST_ADDED_AT")); function pricesMax(address _token) internal pure returns (bytes32) { return keccak256(abi.encode(PRICES_MAX, _token)); } function pricesMin(address _token) internal pure returns (bytes32) { return keccak256(abi.encode(PRICES_MIN, _token)); } function aumAddition(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(AUM_ADDITION, _poolToken)); } function aumDeduction(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(AUM_DEDUCTION, _poolToken)); } function assetsTokens(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(ASSETS_TOKENS, _poolToken)); } function poolAmount(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_AMOUNT, _poolToken, _token)); } function bufferAmount(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(BUFFER_AMOUNT, _poolToken, _token)); } function globalShortSize(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(GLOBAL_SHORT_SIZE, _poolToken, _token)); } function globalShortAveragePrice(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(GLOBAL_SHORT_AVERAGEPRICE, _poolToken, _token)); } function guaranteedUsd(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(GUARANTEED_USD, _poolToken, _token)); } function reservedAmount(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(RESERVED_AMOUNT, _poolToken, _token)); } function balanceAmount(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(BALANCE_AMOUNT, _poolToken, _token)); } function usdgAmount(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(USDG_AMOUNT, _poolToken, _token)); } function feeReserveTo(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(FEE_RESERVE_TO, _poolToken, _token)); } function feeReserveIn(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(FEE_RESERVE_IN, _poolToken, _token)); } function fundingRate(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(FUNDING_RATE, _poolToken, _token)); } function lastFundingTime(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(LAST_FUNDING_TIME, _poolToken, _token)); } function maxUsdgAmount(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(MAX_USDG_AMOUNT, _poolToken, _token)); } function maxGlobalLongSize(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(MAX_GLOBAL_LONG_SIZE, _poolToken, _token)); } function maxGlobalShortSize(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(MAX_GLOBAL_SHORT_SIZE, _poolToken, _token)); } function maxLeverage(address _poolToken, address _token) internal pure returns (bytes32) { return keccak256(abi.encode(MAX_LEVERAGE, _poolToken, _token)); } function lastAddedAt(address _poolToken, address _account) internal pure returns (bytes32) { return keccak256(abi.encode(LAST_ADDED_AT, _poolToken, _account)); } function tokenDecimals(address _token) internal pure returns (bytes32) { return keccak256(abi.encode(TOKEN_DECIMALS, _token)); } function stableToken(address _token) internal pure returns (bytes32) { return keccak256(abi.encode(STABLE_TOKEN, _token)); } // pool function mintFeeBasisPoints(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_MINTFEEBASISPOINTS, _poolToken)); } function burnFeeBasisPoints(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_BURNFEEBASISPOINTS, _poolToken)); } function stableTaxBasisPoints(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_STABLETAXBASISPOINTS, _poolToken)); } function taxBasisPoints(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_TAXBASISPOINTS, _poolToken)); } function stableSwapFeeBasisPoints(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_STABLESWAPFEEBASISPOINTS, _poolToken)); } function swapFeeBasisPoints(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_SWAPFEEBASISPOINTS, _poolToken)); } function marginFeeBasisPoints(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_MARGINFEEBASISPOINTS, _poolToken)); } function liquidationFeeUsd(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_LIQUIDATIONFEEUSD, _poolToken)); } function hasDynamicFees(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_HASDYNAMICFEES, _poolToken)); } function swapFeeToFactor(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_SWAPFEETOFACTOR, _poolToken)); } function positionFeeToFactor(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_POSITIONFEETOFACTOR, _poolToken)); } function borrowingFeeToFactor(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_BORROWINGFEETOFACTOR, _poolToken)); } function cumulativeFees(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_CUMULATIVEFEES, _poolToken)); } function poolInFees(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_POOLINFEES, _poolToken)); } function teamWallet(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_TEAMWALLET, _poolToken)); } function partnerWallet(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_PARTNERWALLET, _poolToken)); } function accountPositionList(address _account, address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(ACCOUNT_POSITION_LIST, _account, _poolToken)); } function accountTotalLiquidity(address _account) internal pure returns (bytes32) { return keccak256(abi.encode(ACCOUNT_TOTAL_LIQUIDITY, _account)); } function accountPoolLiquidity(address _account, address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(ACCOUNT_POOL_LIQUIDITY, _account, _poolToken)); } function accountTotalVolume(address _account) internal pure returns (bytes32) { return keccak256(abi.encode(ACCOUNT_TOTAL_VOLUME, _account)); } function accountPoolVolume(address _account, address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(ACCOUNT_POOL_VOLUME, _account, _poolToken)); } function poolPositionList(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(POOL_POSITION_LIST, _poolToken)); } function indexTokenList(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(_poolToken, INDEX_TOKEN_LIST)); } function stableTokenList(address _poolToken) internal pure returns (bytes32) { return keccak256(abi.encode(_poolToken, STABLE_TOKEN_LIST)); } }contracts/event/OrderLogger.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "../oracle/PriceLib.sol"; contract OrderLogger { address public gov; mapping (address => bool) public isHandler; event CreateIncreaseOrder( address indexed account, uint256 orderIndex, address poolToken, address purchaseToken, uint256 purchaseTokenAmount, address collateralToken, address indexToken, uint256 sizeDelta, bool isLong, uint256 triggerPrice, bool triggerAboveThreshold, uint256 executionFee, bytes32 positionKey ); event CancelIncreaseOrder( address indexed account, uint256 orderIndex, address poolToken, address purchaseToken, uint256 purchaseTokenAmount, address collateralToken, address indexToken, uint256 sizeDelta, bool isLong, uint256 triggerPrice, bool triggerAboveThreshold, uint256 executionFee ); event ExecuteIncreaseOrder( address indexed account, uint256 orderIndex, address poolToken, address purchaseToken, uint256 purchaseTokenAmount, address collateralToken, address indexToken, uint256 sizeDelta, bool isLong, uint256 triggerPrice, bool triggerAboveThreshold, uint256 executionFee, uint256 executionPrice ); event UpdateIncreaseOrder( address indexed account, uint256 orderIndex, address poolToken, address collateralToken, address indexToken, bool isLong, uint256 sizeDelta, uint256 triggerPrice, bool triggerAboveThreshold ); event CreateDecreaseOrder( address indexed account, uint256 orderIndex, address poolToken, address collateralToken, uint256 collateralDelta, address indexToken, uint256 sizeDelta, bool isLong, uint256 triggerPrice, bool triggerAboveThreshold, uint256 executionFee, bytes32 positionKey ); event CancelDecreaseOrder( address indexed account, uint256 orderIndex, address poolToken, address collateralToken, uint256 collateralDelta, address indexToken, uint256 sizeDelta, bool isLong, uint256 triggerPrice, bool triggerAboveThreshold, uint256 executionFee ); event ExecuteDecreaseOrder( address indexed account, uint256 orderIndex, address poolToken, address collateralToken, uint256 collateralDelta, address indexToken, uint256 sizeDelta, bool isLong, uint256 triggerPrice, bool triggerAboveThreshold, uint256 executionFee, uint256 executionPrice ); event UpdateDecreaseOrder( address indexed account, uint256 orderIndex, address poolToken, address collateralToken, uint256 collateralDelta, address indexToken, uint256 sizeDelta, bool isLong, uint256 triggerPrice, bool triggerAboveThreshold ); event CreateSwapOrder( address indexed account, uint256 orderIndex, address poolToken, address[] path, uint256 amountIn, uint256 minOut, uint256 triggerRatio, bool triggerAboveThreshold, bool shouldUnwrap, uint256 executionFee ); event CancelSwapOrder( address indexed account, uint256 orderIndex, address poolToken, address[] path, uint256 amountIn, uint256 minOut, uint256 triggerRatio, bool triggerAboveThreshold, bool shouldUnwrap, uint256 executionFee ); event UpdateSwapOrder( address indexed account, uint256 ordexIndex, address poolToken, address[] path, uint256 amountIn, uint256 minOut, uint256 triggerRatio, bool triggerAboveThreshold, bool shouldUnwrap, uint256 executionFee ); event ExecuteSwapOrder( address indexed account, uint256 orderIndex, address poolToken, address[] path, uint256 amountIn, uint256 minOut, uint256 amountOut, uint256 triggerRatio, bool triggerAboveThreshold, bool shouldUnwrap, uint256 executionFee ); event Initialize( address oracle, address increasePositionHandler, address decreasePositionHandler, address weth, address usdg, uint256 minExecutionFee, uint256 minPurchaseTokenAmountUsd ); event UpdateMinExecutionFee(uint256 minExecutionFee); event UpdateMinPurchaseTokenAmountUsd(uint256 minPurchaseTokenAmountUsd); event UpdateDataBase(address dataBase); event UpdateOracle(address oracle); event UpdateIncreasePositionHandler(address positionHandler); event UpdateDecreasePositionHandler(address positionHandler); event UpdateUsdg(address usdg); event UpdateRouterGov(address gov); event UpdateGov(address gov); event UpdateHandler(address handler, bool isActive); error Unauthorized(address); modifier onlyGov() { if (msg.sender != gov) { revert Unauthorized(msg.sender); } _; } modifier onlyHandler() { if (!isHandler[msg.sender]) { revert Unauthorized(msg.sender); } _; } constructor() { gov = msg.sender; } function setGov(address _gov) external onlyGov { gov = _gov; emit UpdateGov(_gov); } function setHandler(address _handler, bool _isActive) external onlyGov { isHandler[_handler] = _isActive; emit UpdateHandler(_handler, _isActive); } function emitCreateIncreaseOrder( address _account, uint256 _orderIndex, address _poolToken, address _purchaseToken, uint256 _purchaseTokenAmount, address _collateralToken, address _indexToken, uint256 _sizeDelta, bool _isLong, uint256 _triggerPrice, bool _triggerAboveThreshold, uint256 _executionFee, bytes32 _positionKey ) external onlyHandler { emit CreateIncreaseOrder(_account, _orderIndex, _poolToken, _purchaseToken, _purchaseTokenAmount, _collateralToken, _indexToken, _sizeDelta, _isLong, _triggerPrice, _triggerAboveThreshold, _executionFee, _positionKey); } function emitCancelIncreaseOrder( address _account, uint256 _orderIndex, address _poolToken, address _purchaseToken, uint256 _purchaseTokenAmount, address _collateralToken, address _indexToken, uint256 _sizeDelta, bool _isLong, uint256 _triggerPrice, bool _triggerAboveThreshold, uint256 _executionFee ) external onlyHandler { emit CancelIncreaseOrder(_account, _orderIndex, _poolToken, _purchaseToken, _purchaseTokenAmount, _collateralToken, _indexToken, _sizeDelta, _isLong, _triggerPrice, _triggerAboveThreshold, _executionFee); } function emitExecuteIncreaseOrder( address _account, uint256 _orderIndex, address _poolToken, address _purchaseToken, uint256 _purchaseTokenAmount, address _collateralToken, address _indexToken, uint256 _sizeDelta, bool _isLong, uint256 _triggerPrice, bool _triggerAboveThreshold, uint256 _executionFee, uint256 _executionPrice ) external onlyHandler { emit ExecuteIncreaseOrder(_account, _orderIndex, _poolToken, _purchaseToken, _purchaseTokenAmount, _collateralToken, _indexToken, _sizeDelta, _isLong, _triggerPrice, _triggerAboveThreshold, _executionFee, _executionPrice); } function emitUpdateIncreaseOrder( address _account, uint256 _orderIndex, address _poolToken, address _collateralToken, address _indexToken, bool _isLong, uint256 _sizeDelta, uint256 _triggerPrice, bool _triggerAboveThreshold ) external onlyHandler { emit UpdateIncreaseOrder(_account, _orderIndex, _poolToken, _collateralToken, _indexToken, _isLong, _sizeDelta, _triggerPrice, _triggerAboveThreshold); } function emitCreateDecreaseOrder( address _account, uint256 _orderIndex, address _poolToken, address _collateralToken, uint256 _collateralDelta, address _indexToken, uint256 _sizeDelta, bool _isLong, uint256 _triggerPrice, bool _triggerAboveThreshold, uint256 _executionFee, bytes32 _positionKey ) external onlyHandler { emit CreateDecreaseOrder(_account, _orderIndex, _poolToken, _collateralToken, _collateralDelta, _indexToken, _sizeDelta, _isLong, _triggerPrice, _triggerAboveThreshold, _executionFee, _positionKey); } function emitCancelDecreaseOrder( address _account, uint256 _orderIndex, address _poolToken, address _collateralToken, uint256 _collateralDelta, address _indexToken, uint256 _sizeDelta, bool _isLong, uint256 _triggerPrice, bool _triggerAboveThreshold, uint256 _executionFee ) external onlyHandler { emit CancelDecreaseOrder(_account, _orderIndex, _poolToken, _collateralToken, _collateralDelta, _indexToken, _sizeDelta, _isLong, _triggerPrice, _triggerAboveThreshold, _executionFee); } function emitExecuteDecreaseOrder( address _account, uint256 _orderIndex, address _poolToken, address _collateralToken, uint256 _collateralDelta, address _indexToken, uint256 _sizeDelta, bool _isLong, uint256 _triggerPrice, bool _triggerAboveThreshold, uint256 _executionFee, uint256 _executionPrice ) external onlyHandler { emit ExecuteDecreaseOrder(_account, _orderIndex, _poolToken, _collateralToken, _collateralDelta, _indexToken, _sizeDelta, _isLong, _triggerPrice, _triggerAboveThreshold, _executionFee, _executionPrice); } function emitUpdateDecreaseOrder( address _account, uint256 _orderIndex, address _poolToken, address _collateralToken, uint256 _collateralDelta, address _indexToken, uint256 _sizeDelta, bool _isLong, uint256 _triggerPrice, bool _triggerAboveThreshold ) external onlyHandler { emit UpdateDecreaseOrder(_account, _orderIndex, _poolToken, _collateralToken, _collateralDelta, _indexToken, _sizeDelta, _isLong, _triggerPrice, _triggerAboveThreshold); } function emitCreateSwapOrder( address _account, uint256 _orderIndex, address _poolToken, address[] memory _path, uint256 _amountIn, uint256 _minOut, uint256 _triggerRatio, bool _triggerAboveThreshold, bool _shouldUnwrap, uint256 _executionFee ) external onlyHandler { emit CreateSwapOrder(_account, _orderIndex, _poolToken, _path, _amountIn, _minOut, _triggerRatio, _triggerAboveThreshold, _shouldUnwrap, _executionFee); } function emitCancelSwapOrder( address _account, uint256 _orderIndex, address _poolToken, address[] memory _path, uint256 _amountIn, uint256 _minOut, uint256 _triggerRatio, bool _triggerAboveThreshold, bool _shouldUnwrap, uint256 _executionFee ) external onlyHandler { emit CancelSwapOrder(_account, _orderIndex, _poolToken, _path, _amountIn, _minOut, _triggerRatio, _triggerAboveThreshold, _shouldUnwrap, _executionFee); } function emitExecuteSwapOrder( address _account, uint256 _orderIndex, address _poolToken, address[] memory _path, uint256 _amountIn, uint256 _minOut, uint256 _amountOut, uint256 _triggerRatio, bool _triggerAboveThreshold, bool _shouldUnwrap, uint256 _executionFee ) external onlyHandler { emit ExecuteSwapOrder(_account, _orderIndex, _poolToken, _path, _amountIn, _minOut, _amountOut, _triggerRatio, _triggerAboveThreshold, _shouldUnwrap, _executionFee); } function emitUpdateSwapOrder( address _account, uint256 _orderIndex, address _poolToken, address[] memory _path, uint256 _amountIn, uint256 _minOut, uint256 _triggerRatio, bool _triggerAboveThreshold, bool _shouldUnwrap, uint256 _executionFee ) external onlyHandler { emit UpdateSwapOrder(_account, _orderIndex, _poolToken, _path, _amountIn, _minOut, _triggerRatio, _triggerAboveThreshold, _shouldUnwrap, _executionFee); } }contracts/exception/Errs.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.0; library Errs { // init error Initialized(); // Authorization error Unauthorized(address msgSender, string role); error UnauthorizedGov(address gov); error UnauthorizedHandler(address handler); // AccountUtils error EmptyAccount(string message); error InsufficientBalance(address account, uint256 amount); error TransferFailedNT(address from, address to, uint256 amount); // Vault error InvalidNativeTokenSender(address msgSender); error SelfTransferNotAllowed(address account); // Pool error PoolAlreadyExists(bytes32 salt, address poolAddress); // Utils error AddressNotFound(address key); error NoTokenAmountIn(address token); error NoTokenAmountOut(address token); error NoUSDGAmountIn(); error InvalidUSDGAmount(); error InvalidRedemptionAmount(address token); // Swap error DuplicateToken(address token); // Position error InvalidAveragePrice(); error InsufficientCollateralForFees(uint256 collateral, uint256 fee); error InvalidPositionDotSize(); error EmptyPosition(); error PositionSizeExceeded(); error PositionCollateralExceeded(); error InvalidIndexToken(); error InvalidStableToken(); // Liquidation error LossesExceedCollateral(); error FeesExceedCollateral(); error LiquidationFeesExceedCollateral(); error MaxLeverageExceeded(); error CannotBeLiquidated(); }@openzeppelin/contracts/interfaces/IERC165.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.0.0) (interfaces/IERC165.sol) pragma solidity ^0.8.20; import {IERC165} from "../utils/introspection/IERC165.sol";contracts/repo/Dao.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "@openzeppelin/contracts/token/ERC20/IERC20.sol"; import {DataBase} from "../repo/DataBase.sol"; import "../utils/Keys.sol"; library Dao { function wnt(DataBase _dataBase) internal view returns (address) { return _dataBase.getAddress(Keys.WNT); } function setWNT(DataBase _dataBase, address _value) internal { _dataBase.setAddress(Keys.WNT, _value); } function tokenDecimals(DataBase _dataBase, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.tokenDecimals(_token)); } function setTokenDecimals(DataBase _dataBase, address _token, uint256 _decimals) internal { _dataBase.setUint(Keys.tokenDecimals(_token), _decimals); } function stableToken(DataBase _dataBase, address _token) internal view returns (bool) { return _dataBase.getBool(Keys.stableToken(_token)); } function addStableToken(DataBase _dataBase, address _token) internal { _dataBase.setBool(Keys.stableToken(_token), true); } function removeStableToken(DataBase _dataBase, address _token) internal { _dataBase.removeBool(Keys.stableToken(_token)); } // pool token function poolAmount(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.poolAmount(_poolToken, _token)); } function setPoolAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { _dataBase.setUint(Keys.poolAmount(_poolToken, _token), _amount); } function bufferAmount(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.bufferAmount(_poolToken, _token)); } function setBufferAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { _dataBase.setUint(Keys.bufferAmount(_poolToken, _token), _amount); } function reservedAmount(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.reservedAmount(_poolToken, _token)); } function setReservedAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { _dataBase.setUint(Keys.reservedAmount(_poolToken, _token), _amount); } function guaranteedUsd(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.guaranteedUsd(_poolToken, _token)); } function setGuaranteedUsd(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(Keys.guaranteedUsd(_poolToken, _token), _value); } function globalShortSize(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.globalShortSize(_poolToken, _token)); } function setGlobalShortSize(DataBase _dataBase, address _poolToken, address _token, uint256 _size) internal { _dataBase.setUint(Keys.globalShortSize(_poolToken, _token), _size); } function globalShortAveragePrice(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.globalShortAveragePrice(_poolToken, _token)); } function setGlobalShortAveragePrice(DataBase _dataBase, address _poolToken, address _token, uint256 _price) internal { _dataBase.setUint(Keys.globalShortAveragePrice(_poolToken, _token), _price); } function usdgAmount(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.usdgAmount(_poolToken, _token)); } function setUsdgAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { _dataBase.setUint(Keys.usdgAmount(_poolToken, _token), _amount); } function feeReserveTo(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.feeReserveTo(_poolToken, _token)); } function setFeeReserveTo(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(Keys.feeReserveTo(_poolToken, _token), _value); } function feeReserveIn(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.feeReserveIn(_poolToken, _token)); } function setFeeReserveIn(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(Keys.feeReserveIn(_poolToken, _token), _value); } function balanceAmount(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.balanceAmount(_poolToken, _token)); } function setBalanceAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(Keys.balanceAmount(_poolToken, _token), _value); } function fundingRate(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.fundingRate(_poolToken, _token)); } function setFundingRate(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(Keys.fundingRate(_poolToken, _token), _value); } function lastFundingTime(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.lastFundingTime(_poolToken, _token)); } function setLastFundingTime(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(Keys.lastFundingTime(_poolToken, _token), _value); } function maxUsdgAmount(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.maxUsdgAmount(_poolToken, _token)); } function setMaxUsdgAmount(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { _dataBase.setUint(Keys.maxUsdgAmount(_poolToken, _token), _amount); } function maxGlobalLongSize(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.maxGlobalLongSize(_poolToken, _token)); } function setMaxGlobalLongSize(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { _dataBase.setUint(Keys.maxGlobalLongSize(_poolToken, _token), _amount); } function maxGlobalShortSize(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.maxGlobalShortSize(_poolToken, _token)); } function setMaxGlobalShortSize(DataBase _dataBase, address _poolToken, address _token, uint256 _amount) internal { _dataBase.setUint(Keys.maxGlobalShortSize(_poolToken, _token), _amount); } function maxLeverage(DataBase _dataBase, address _poolToken, address _token) internal view returns (uint256) { return _dataBase.getUint(Keys.maxLeverage(_poolToken, _token)); } function setMaxLeverage(DataBase _dataBase, address _poolToken, address _token, uint256 _value) internal { _dataBase.setUint(Keys.maxLeverage(_poolToken, _token), _value); } // pool function stableTaxBasisPoints(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(Keys.stableTaxBasisPoints(_poolToken)); } function setStableTaxBasisPoints(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(Keys.stableTaxBasisPoints(_poolToken), _value); } function taxBasisPoints(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(Keys.taxBasisPoints(_poolToken)); } function setTaxBasisPoints(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(Keys.taxBasisPoints(_poolToken), _value); } function mintFeeBasisPoints(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(Keys.mintFeeBasisPoints(_poolToken)); } function setMintFeeBasisPoints(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(Keys.mintFeeBasisPoints(_poolToken), _value); } function burnFeeBasisPoints(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(Keys.burnFeeBasisPoints(_poolToken)); } function setBurnFeeBasisPoints(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(Keys.burnFeeBasisPoints(_poolToken), _value); } function stableSwapFeeBasisPoints(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(Keys.stableSwapFeeBasisPoints(_poolToken)); } function setStableSwapFeeBasisPoints(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(Keys.stableSwapFeeBasisPoints(_poolToken), _value); } function swapFeeBasisPoints(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(Keys.swapFeeBasisPoints(_poolToken)); } function setSwapFeeBasisPoints(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(Keys.swapFeeBasisPoints(_poolToken), _value); } function marginFeeBasisPoints(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(Keys.marginFeeBasisPoints(_poolToken)); } function setMarginFeeBasisPoints(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(Keys.marginFeeBasisPoints(_poolToken), _value); } function liquidationFeeUsd(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(Keys.liquidationFeeUsd(_poolToken)); } function setLiquidationFeeUsd(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(Keys.liquidationFeeUsd(_poolToken), _value); } function hasDynamicFees(DataBase _dataBase, address _poolToken) internal view returns (bool) { return _dataBase.getBool(Keys.hasDynamicFees(_poolToken)); } function setHasDynamicFees(DataBase _dataBase, address _poolToken, bool _value) internal { _dataBase.setBool(Keys.hasDynamicFees(_poolToken), _value); } function swapFeeToFactor(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(Keys.swapFeeToFactor(_poolToken)); } function setSwapFeeToFactor(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(Keys.swapFeeToFactor(_poolToken), _value); } function positionFeeToFactor(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(Keys.positionFeeToFactor(_poolToken)); } function setPositionFeeToFactor(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(Keys.positionFeeToFactor(_poolToken), _value); } function cumulativeFees(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(Keys.cumulativeFees(_poolToken)); } function setCumulativeFees(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(Keys.cumulativeFees(_poolToken), _value); } function poolInFees(DataBase _dataBase, address _poolToken) internal view returns (uint256) { return _dataBase.getUint(Keys.poolInFees(_poolToken)); } function setPoolInFees(DataBase _dataBase, address _poolToken, uint256 _value) internal { _dataBase.setUint(Keys.poolInFees(_poolToken), _value); } function lastAddedAt(DataBase _dataBase, address _poolToken, address _account) internal view returns (uint256) { return _dataBase.getUint(Keys.lastAddedAt(_poolToken, _account)); } function setLastAddedAt(DataBase _dataBase, address _poolToken, address _account, uint256 _value) internal { _dataBase.setUint(Keys.lastAddedAt(_poolToken, _account), _value); } function getBytes32Count(DataBase _dataBase, bytes32 _setKey) internal view returns (uint256) { return _dataBase.getBytes32Count(_setKey); } function getBytes32ValuesAt(DataBase _dataBase, bytes32 _setKey, uint256 _start, uint256 _end) internal view returns (bytes32[] memory) { return _dataBase.getBytes32ValuesAt(_setKey, _start, _end); } function addBytes32(DataBase _dataBase, bytes32 _setKey, bytes32 _value) internal { _dataBase.addBytes32(_setKey, _value); } function removeBytes32(DataBase _dataBase, bytes32 _setKey, bytes32 _value) internal { _dataBase.removeBytes32(_setKey, _value); } function setAddress(DataBase _dataBase, bytes32 _key, address _value) internal { _dataBase.setAddress(_key, _value); } function getAddress(DataBase _dataBase, bytes32 _key) internal view returns (address) { return _dataBase.getAddress(_key); } }@openzeppelin/contracts/utils/introspection/IERC165.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (utils/introspection/IERC165.sol) pragma solidity ^0.8.20; /** * @dev Interface of the ERC-165 standard, as defined in the * https://eips.ethereum.org/EIPS/eip-165[ERC]. * * Implementers can declare support of contract interfaces, which can then be * queried by others ({ERC165Checker}). * * For an implementation, see {ERC165}. */ interface IERC165 { /** * @dev Returns true if this contract implements the interface defined by * `interfaceId`. See the corresponding * https://eips.ethereum.org/EIPS/eip-165#how-interfaces-are-identified[ERC section] * to learn more about how these ids are created. * * This function call must use less than 30 000 gas. */ function supportsInterface(bytes4 interfaceId) external view returns (bool); }contracts/order/IOrderRouter.sol
// SPDX-License-Identifier: BUSL-1.1 pragma solidity ^0.8.20; import "../oracle/PriceLib.sol"; interface IOrderRouter { function cancelDecreaseOrder(address _poolToken, uint256 _orderIndex) external; function cancelDecreaseOrderByKey(bytes32 _orderKey) external; function batchCancelDecreaseOrders(address _account, address _poolToken, address _indexToken, bool _isLong) external; function setPriceMMAndExecuteIncreaseOrder(address[] memory _tokens, PriceLib.Prices[] memory _prices, address _address, address _poolToken, uint256 _orderIndex, address payable _feeReceiver) external; function setPriceMMAndExecuteDecreaseOrder(address[] memory _tokens, PriceLib.Prices[] memory _prices, address _address, address _poolToken, uint256 _orderIndex, address payable _feeReceiver) external; }
ABI · 67 entries
json
[
{
"type": "constructor",
"inputs": [
{
"name": "_orderBase",
"type": "address",
"internalType": "contract OrderBase"
},
{
"name": "_orderVault",
"type": "address",
"internalType": "contract OrderVault"
},
{
"name": "_orderLogger",
"type": "address",
"internalType": "contract OrderLogger"
},
{
"name": "_dataBase",
"type": "address",
"internalType": "contract DataBase"
}
],
"stateMutability": "nonpayable"
},
{
"name": "AlreadyInitialized",
"type": "error",
"inputs": []
},
{
"name": "FailedTransferETHToOrderVault",
"type": "error",
"inputs": []
},
{
"name": "FailedTransferETHToReceiver",
"type": "error",
"inputs": []
},
{
"name": "IncorrectExecutionFee",
"type": "error",
"inputs": []
},
{
"name": "IncorrectTransferredValue",
"type": "error",
"inputs": []
},
{
"name": "InsufficientCollateral",
"type": "error",
"inputs": []
},
{
"name": "InsufficientExecutionFee",
"type": "error",
"inputs": []
},
{
"name": "InvalidPriceForExecution",
"type": "error",
"inputs": []
},
{
"name": "InvalidSender",
"type": "error",
"inputs": []
},
{
"name": "NonExistentOrder",
"type": "error",
"inputs": []
},
{
"name": "OnlyWethWrapped",
"type": "error",
"inputs": []
},
{
"name": "PathLengthExceeded",
"type": "error",
"inputs": []
},
{
"name": "ReentrancyGuardReentrantCall",
"type": "error",
"inputs": []
},
{
"name": "SafeERC20FailedOperation",
"type": "error",
"inputs": [
{
"name": "token",
"type": "address",
"internalType": "address"
}
]
},
{
"name": "TooShortUpdateInterval",
"type": "error",
"inputs": []
},
{
"name": "UnauthorizedGov",
"type": "error",
"inputs": []
},
{
"name": "UnauthorizedManager",
"type": "error",
"inputs": []
},
{
"name": "UnauthorizedMuticall",
"type": "error",
"inputs": []
},
{
"name": "UnsupportedPurchaseToken",
"type": "error",
"inputs": []
},
{
"name": "ZeroAddress",
"type": "error",
"inputs": []
},
{
"name": "Initialize",
"type": "event",
"inputs": [
{
"name": "oracle",
"type": "address",
"indexed": false,
"internalType": "address"
},
{
"name": "increasePositionHandler",
"type": "address",
"indexed": false,
"internalType": "address"
},
{
"name": "decreasePositionHandler",
"type": "address",
"indexed": false,
"internalType": "address"
},
{
"name": "weth",
"type": "address",
"indexed": false,
"internalType": "address"
},
{
"name": "minExecutionFee",
"type": "uint256",
"indexed": false,
"internalType": "uint256"
},
{
"name": "minPurchaseTokenAmountUsd",
"type": "uint256",
"indexed": false,
"internalType": "uint256"
}
],
"anonymous": false
},
{
"name": "UpdateDecreasePositionHandler",
"type": "event",
"inputs": [
{
"name": "positionHandler",
"type": "address",
"indexed": false,
"internalType": "address"
}
],
"anonymous": false
},
{
"name": "UpdateGov",
"type": "event",
"inputs": [
{
"name": "gov",
"type": "address",
"indexed": false,
"internalType": "address"
}
],
"anonymous": false
},
{
"name": "UpdateIncreasePositionHandler",
"type": "event",
"inputs": [
{
"name": "positionHandler",
"type": "address",
"indexed": false,
"internalType": "address"
}
],
"anonymous": false
},
{
"name": "UpdateMinExecutionFee",
"type": "event",
"inputs": [
{
"name": "minExecutionFee",
"type": "uint256",
"indexed": false,
"internalType": "uint256"
}
],
"anonymous": false
},
{
"name": "UpdateMinPurchaseTokenAmountUsd",
"type": "event",
"inputs": [
{
"name": "minPurchaseTokenAmountUsd",
"type": "uint256",
"indexed": false,
"internalType": "uint256"
}
],
"anonymous": false
},
{
"name": "MIN_UPDATE_INTERVAL",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "uint256",
"internalType": "uint256"
}
],
"stateMutability": "view"
},
{
"name": "admin",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "address"
}
],
"stateMutability": "view"
},
{
"name": "batchCancelDecreaseOrders",
"type": "function",
"inputs": [
{
"name": "_account",
"type": "address",
"internalType": "address"
},
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
},
{
"name": "_indexToken",
"type": "address",
"internalType": "address"
},
{
"name": "_isLong",
"type": "bool",
"internalType": "bool"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "cancelDecreaseOrder",
"type": "function",
"inputs": [
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
},
{
"name": "_orderIndex",
"type": "uint256",
"internalType": "uint256"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "cancelDecreaseOrderByKey",
"type": "function",
"inputs": [
{
"name": "_orderKey",
"type": "bytes32",
"internalType": "bytes32"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "cancelIncreaseOrder",
"type": "function",
"inputs": [
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
},
{
"name": "_orderIndex",
"type": "uint256",
"internalType": "uint256"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "cancelMultiple",
"type": "function",
"inputs": [
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
},
{
"name": "_swapOrderIndexes",
"type": "uint256[]",
"internalType": "uint256[]"
},
{
"name": "_increaseOrderIndexes",
"type": "uint256[]",
"internalType": "uint256[]"
},
{
"name": "_decreaseOrderIndexes",
"type": "uint256[]",
"internalType": "uint256[]"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "createDecreaseOrder",
"type": "function",
"inputs": [
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
},
{
"name": "_indexToken",
"type": "address",
"internalType": "address"
},
{
"name": "_sizeDelta",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_collateralToken",
"type": "address",
"internalType": "address"
},
{
"name": "_collateralDelta",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_isLong",
"type": "bool",
"internalType": "bool"
},
{
"name": "_triggerPrice",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_triggerAboveThreshold",
"type": "bool",
"internalType": "bool"
}
],
"outputs": [],
"stateMutability": "payable"
},
{
"name": "createDecreaseOrderTpSl",
"type": "function",
"inputs": [
{
"name": "_account",
"type": "address",
"internalType": "address"
},
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
},
{
"name": "_indexToken",
"type": "address",
"internalType": "address"
},
{
"name": "_sizeDelta",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_collateralToken",
"type": "address",
"internalType": "address"
},
{
"name": "_collateralDelta",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_isLong",
"type": "bool",
"internalType": "bool"
},
{
"name": "_triggerPrice",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_triggerAboveThreshold",
"type": "bool",
"internalType": "bool"
}
],
"outputs": [],
"stateMutability": "payable"
},
{
"name": "createIncreaseOrder",
"type": "function",
"inputs": [
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
},
{
"name": "_path",
"type": "address[]",
"internalType": "address[]"
},
{
"name": "_amountIn",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_indexToken",
"type": "address",
"internalType": "address"
},
{
"name": "_minOut",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_sizeDelta",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_collateralToken",
"type": "address",
"internalType": "address"
},
{
"name": "_isLong",
"type": "bool",
"internalType": "bool"
},
{
"name": "_triggerPrice",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_triggerAboveThreshold",
"type": "bool",
"internalType": "bool"
},
{
"name": "_executionFee",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_shouldWrap",
"type": "bool",
"internalType": "bool"
}
],
"outputs": [],
"stateMutability": "payable"
},
{
"name": "dataBase",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "contract DataBase"
}
],
"stateMutability": "view"
},
{
"name": "decreaseOrdersIndex",
"type": "function",
"inputs": [
{
"name": "_account",
"type": "address",
"internalType": "address"
},
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
}
],
"outputs": [
{
"name": "",
"type": "uint256",
"internalType": "uint256"
}
],
"stateMutability": "view"
},
{
"name": "decreasePositionHandler",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "address"
}
],
"stateMutability": "view"
},
{
"name": "gov",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "address"
}
],
"stateMutability": "view"
},
{
"name": "increaseOrdersIndex",
"type": "function",
"inputs": [
{
"name": "_account",
"type": "address",
"internalType": "address"
},
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
}
],
"outputs": [
{
"name": "",
"type": "uint256",
"internalType": "uint256"
}
],
"stateMutability": "view"
},
{
"name": "increasePositionHandler",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "address"
}
],
"stateMutability": "view"
},
{
"name": "initialize",
"type": "function",
"inputs": [
{
"name": "_oracle",
"type": "address",
"internalType": "address"
},
{
"name": "_increasePositionHandler",
"type": "address",
"internalType": "address"
},
{
"name": "_decreasePositionHandler",
"type": "address",
"internalType": "address"
},
{
"name": "_weth",
"type": "address",
"internalType": "address"
},
{
"name": "_minExecutionFee",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_minPurchaseTokenAmountUsd",
"type": "uint256",
"internalType": "uint256"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "isInitialized",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "bool",
"internalType": "bool"
}
],
"stateMutability": "view"
},
{
"name": "isManager",
"type": "function",
"inputs": [
{
"name": "",
"type": "address",
"internalType": "address"
}
],
"outputs": [
{
"name": "",
"type": "bool",
"internalType": "bool"
}
],
"stateMutability": "view"
},
{
"name": "minExecutionFee",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "uint256",
"internalType": "uint256"
}
],
"stateMutability": "view"
},
{
"name": "minPurchaseTokenAmountUsd",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "uint256",
"internalType": "uint256"
}
],
"stateMutability": "view"
},
{
"name": "multicall",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "address"
}
],
"stateMutability": "view"
},
{
"name": "oracle",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "address"
}
],
"stateMutability": "view"
},
{
"name": "orderBase",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "contract OrderBase"
}
],
"stateMutability": "view"
},
{
"name": "orderLogger",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "contract OrderLogger"
}
],
"stateMutability": "view"
},
{
"name": "orderVault",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "contract OrderVault"
}
],
"stateMutability": "view"
},
{
"name": "setDecreasePositionHandler",
"type": "function",
"inputs": [
{
"name": "_positionHandler",
"type": "address",
"internalType": "address"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "setGov",
"type": "function",
"inputs": [
{
"name": "_gov",
"type": "address",
"internalType": "address"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "setIncreasePositionHandler",
"type": "function",
"inputs": [
{
"name": "_positionHandler",
"type": "address",
"internalType": "address"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "setManager",
"type": "function",
"inputs": [
{
"name": "_manager",
"type": "address",
"internalType": "address"
},
{
"name": "_isManager",
"type": "bool",
"internalType": "bool"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "setMinExecutionFee",
"type": "function",
"inputs": [
{
"name": "_minExecutionFee",
"type": "uint256",
"internalType": "uint256"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "setMinPurchaseTokenAmountUsd",
"type": "function",
"inputs": [
{
"name": "_minPurchaseTokenAmountUsd",
"type": "uint256",
"internalType": "uint256"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "setMulticall",
"type": "function",
"inputs": [
{
"name": "_multicall",
"type": "address",
"internalType": "address"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "setPriceMMAndExecuteDecreaseOrder",
"type": "function",
"inputs": [
{
"name": "_tokens",
"type": "address[]",
"internalType": "address[]"
},
{
"name": "_prices",
"type": "tuple[]",
"components": [
{
"name": "min",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "max",
"type": "uint256",
"internalType": "uint256"
}
],
"internalType": "struct PriceLib.Prices[]"
},
{
"name": "_address",
"type": "address",
"internalType": "address"
},
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
},
{
"name": "_orderIndex",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_feeReceiver",
"type": "address",
"internalType": "address payable"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "setPriceMMAndExecuteIncreaseOrder",
"type": "function",
"inputs": [
{
"name": "_tokens",
"type": "address[]",
"internalType": "address[]"
},
{
"name": "_prices",
"type": "tuple[]",
"components": [
{
"name": "min",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "max",
"type": "uint256",
"internalType": "uint256"
}
],
"internalType": "struct PriceLib.Prices[]"
},
{
"name": "_address",
"type": "address",
"internalType": "address"
},
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
},
{
"name": "_orderIndex",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_feeReceiver",
"type": "address",
"internalType": "address payable"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "updateDecreaseOrder",
"type": "function",
"inputs": [
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
},
{
"name": "_orderIndex",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_collateralDelta",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_sizeDelta",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_triggerPrice",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_triggerAboveThreshold",
"type": "bool",
"internalType": "bool"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "updateIncreaseOrder",
"type": "function",
"inputs": [
{
"name": "_poolToken",
"type": "address",
"internalType": "address"
},
{
"name": "_orderIndex",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_sizeDelta",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_triggerPrice",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_triggerAboveThreshold",
"type": "bool",
"internalType": "bool"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "validatePositionOrderPrice",
"type": "function",
"inputs": [
{
"name": "_triggerAboveThreshold",
"type": "bool",
"internalType": "bool"
},
{
"name": "_triggerPrice",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "_indexToken",
"type": "address",
"internalType": "address"
},
{
"name": "_maximizePrice",
"type": "bool",
"internalType": "bool"
},
{
"name": "_raise",
"type": "bool",
"internalType": "bool"
}
],
"outputs": [
{
"name": "",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "",
"type": "bool",
"internalType": "bool"
}
],
"stateMutability": "view"
},
{
"name": "weth",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "address"
}
],
"stateMutability": "view"
},
{
"type": "receive",
"stateMutability": "payable"
}
]