Overview
ETH Balance
0 ETH
Eth Value
$0.00More Info
Private Name Tags
ContractCreator
Latest 25 from a total of 209 transactions
Transaction Hash |
Method
|
Block
|
From
|
To
|
|||||
---|---|---|---|---|---|---|---|---|---|
Collect | 18283498 | 379 days ago | IN | 0 ETH | 0.00050942 | ||||
Collect | 17134920 | 540 days ago | IN | 0 ETH | 0.00157965 | ||||
Collect | 17134918 | 540 days ago | IN | 0 ETH | 0.00293542 | ||||
Set Splits | 17090196 | 546 days ago | IN | 0 ETH | 0.0029617 | ||||
Set Splits | 16933825 | 569 days ago | IN | 0 ETH | 0.00164938 | ||||
Set Splits | 16933825 | 569 days ago | IN | 0 ETH | 0.00195852 | ||||
Set Drips | 16537093 | 624 days ago | IN | 0 ETH | 0.00666518 | ||||
Set Splits | 16419071 | 641 days ago | IN | 0 ETH | 0.00071052 | ||||
Set Splits | 16419050 | 641 days ago | IN | 0 ETH | 0.0011464 | ||||
Set Splits | 16340749 | 652 days ago | IN | 0 ETH | 0.00124418 | ||||
Collect | 16330517 | 653 days ago | IN | 0 ETH | 0.00131603 | ||||
Collect | 16249285 | 664 days ago | IN | 0 ETH | 0.00166027 | ||||
Collect | 16070672 | 689 days ago | IN | 0 ETH | 0.00090819 | ||||
Set Drips | 16038113 | 694 days ago | IN | 0 ETH | 0.00078002 | ||||
Collect | 16038109 | 694 days ago | IN | 0 ETH | 0.00102186 | ||||
Collect | 15999741 | 699 days ago | IN | 0 ETH | 0.002903 | ||||
Collect | 15883838 | 715 days ago | IN | 0 ETH | 0.00201385 | ||||
Collect | 15872194 | 717 days ago | IN | 0 ETH | 0.00074189 | ||||
Set Splits | 15838117 | 722 days ago | IN | 0 ETH | 0.00179998 | ||||
Set Drips | 15753584 | 734 days ago | IN | 0 ETH | 0.0008359 | ||||
Set Splits | 15724257 | 738 days ago | IN | 0 ETH | 0.00445792 | ||||
Collect | 15710008 | 740 days ago | IN | 0 ETH | 0.00188158 | ||||
Set Drips | 15710008 | 740 days ago | IN | 0 ETH | 0.00458076 | ||||
Collect | 15689056 | 743 days ago | IN | 0 ETH | 0.00121036 | ||||
Set Drips | 15689030 | 743 days ago | IN | 0 ETH | 0.00126393 |
View more zero value Internal Transactions in Advanced View mode
Advanced mode:
Loading...
Loading
Contract Name:
ManagedDripsHubProxy
Compiler Version
v0.8.7+commit.e28d00a7
Optimization Enabled:
Yes with 10000 runs
Other Settings:
default evmVersion
Contract Source Code (Solidity)
/** *Submitted for verification at Etherscan.io on 2021-12-14 */ // Verified using https://dapp.tools // hevm: flattened sources of lib/radicle-drips-hub/src/ManagedDripsHub.sol // SPDX-License-Identifier: MIT AND GPL-3.0-only pragma solidity >=0.8.0 <0.9.0 >=0.8.2 <0.9.0 >=0.8.7 <0.9.0; ////// lib/openzeppelin-contracts/contracts/proxy/beacon/IBeacon.sol /* pragma solidity ^0.8.0; */ /** * @dev This is the interface that {BeaconProxy} expects of its beacon. */ interface IBeacon { /** * @dev Must return an address that can be used as a delegate call target. * * {BeaconProxy} will check that this address is a contract. */ function implementation() external view returns (address); } ////// lib/openzeppelin-contracts/contracts/utils/Address.sol /* pragma solidity ^0.8.0; */ /** * @dev Collection of functions related to the address type */ library Address { /** * @dev Returns true if `account` is a contract. * * [IMPORTANT] * ==== * It is unsafe to assume that an address for which this function returns * false is an externally-owned account (EOA) and not a contract. * * Among others, `isContract` will return false for the following * types of addresses: * * - an externally-owned account * - a contract in construction * - an address where a contract will be created * - an address where a contract lived, but was destroyed * ==== */ function isContract(address account) internal view returns (bool) { // 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; 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"); (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-Address-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-Address-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-Address-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"); (bool success, bytes memory returndata) = target.call{value: value}(data); return verifyCallResult(success, returndata, errorMessage); } /** * @dev Same as {xref-Address-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-Address-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"); (bool success, bytes memory returndata) = target.staticcall(data); return verifyCallResult(success, returndata, errorMessage); } /** * @dev Same as {xref-Address-functionCall-address-bytes-}[`functionCall`], * but performing a delegate call. * * _Available since v3.4._ */ 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-Address-functionCall-address-bytes-string-}[`functionCall`], * but performing a delegate call. * * _Available since v3.4._ */ function functionDelegateCall( address target, bytes memory data, string memory errorMessage ) internal returns (bytes memory) { require(isContract(target), "Address: delegate call to non-contract"); (bool success, bytes memory returndata) = target.delegatecall(data); return verifyCallResult(success, returndata, errorMessage); } /** * @dev Tool to verifies that a low level call was successful, and revert if it wasn't, either by bubbling the * revert reason using the provided one. * * _Available since v4.3._ */ function verifyCallResult( bool success, bytes memory returndata, string memory errorMessage ) internal 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 assembly { let returndata_size := mload(returndata) revert(add(32, returndata), returndata_size) } } else { revert(errorMessage); } } } } ////// lib/openzeppelin-contracts/contracts/utils/StorageSlot.sol /* pragma solidity ^0.8.0; */ /** * @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 ERC1967 implementation slot: * ``` * contract ERC1967 { * bytes32 internal constant _IMPLEMENTATION_SLOT = 0x360894a13ba1a3210667c828492db98dca3e2076cc3735a920a3ca505d382bbc; * * function _getImplementation() internal view returns (address) { * return StorageSlot.getAddressSlot(_IMPLEMENTATION_SLOT).value; * } * * function _setImplementation(address newImplementation) internal { * require(Address.isContract(newImplementation), "ERC1967: new implementation is not a contract"); * StorageSlot.getAddressSlot(_IMPLEMENTATION_SLOT).value = newImplementation; * } * } * ``` * * _Available since v4.1 for `address`, `bool`, `bytes32`, and `uint256`._ */ library StorageSlot { struct AddressSlot { address value; } struct BooleanSlot { bool value; } struct Bytes32Slot { bytes32 value; } struct Uint256Slot { uint256 value; } /** * @dev Returns an `AddressSlot` with member `value` located at `slot`. */ function getAddressSlot(bytes32 slot) internal pure returns (AddressSlot storage r) { assembly { r.slot := slot } } /** * @dev Returns an `BooleanSlot` with member `value` located at `slot`. */ function getBooleanSlot(bytes32 slot) internal pure returns (BooleanSlot storage r) { assembly { r.slot := slot } } /** * @dev Returns an `Bytes32Slot` with member `value` located at `slot`. */ function getBytes32Slot(bytes32 slot) internal pure returns (Bytes32Slot storage r) { assembly { r.slot := slot } } /** * @dev Returns an `Uint256Slot` with member `value` located at `slot`. */ function getUint256Slot(bytes32 slot) internal pure returns (Uint256Slot storage r) { assembly { r.slot := slot } } } ////// lib/openzeppelin-contracts/contracts/proxy/ERC1967/ERC1967Upgrade.sol /* pragma solidity ^0.8.2; */ /* import "../beacon/IBeacon.sol"; */ /* import "../../utils/Address.sol"; */ /* import "../../utils/StorageSlot.sol"; */ /** * @dev This abstract contract provides getters and event emitting update functions for * https://eips.ethereum.org/EIPS/eip-1967[EIP1967] slots. * * _Available since v4.1._ * * @custom:oz-upgrades-unsafe-allow delegatecall */ abstract contract ERC1967Upgrade { // This is the keccak-256 hash of "eip1967.proxy.rollback" subtracted by 1 bytes32 private constant _ROLLBACK_SLOT = 0x4910fdfa16fed3260ed0e7147f7cc6da11a60208b5b9406d12a635614ffd9143; /** * @dev Storage slot with the address of the current implementation. * This is the keccak-256 hash of "eip1967.proxy.implementation" subtracted by 1, and is * validated in the constructor. */ bytes32 internal constant _IMPLEMENTATION_SLOT = 0x360894a13ba1a3210667c828492db98dca3e2076cc3735a920a3ca505d382bbc; /** * @dev Emitted when the implementation is upgraded. */ event Upgraded(address indexed implementation); /** * @dev Returns the current implementation address. */ function _getImplementation() internal view returns (address) { return StorageSlot.getAddressSlot(_IMPLEMENTATION_SLOT).value; } /** * @dev Stores a new address in the EIP1967 implementation slot. */ function _setImplementation(address newImplementation) private { require(Address.isContract(newImplementation), "ERC1967: new implementation is not a contract"); StorageSlot.getAddressSlot(_IMPLEMENTATION_SLOT).value = newImplementation; } /** * @dev Perform implementation upgrade * * Emits an {Upgraded} event. */ function _upgradeTo(address newImplementation) internal { _setImplementation(newImplementation); emit Upgraded(newImplementation); } /** * @dev Perform implementation upgrade with additional setup call. * * Emits an {Upgraded} event. */ function _upgradeToAndCall( address newImplementation, bytes memory data, bool forceCall ) internal { _upgradeTo(newImplementation); if (data.length > 0 || forceCall) { Address.functionDelegateCall(newImplementation, data); } } /** * @dev Perform implementation upgrade with security checks for UUPS proxies, and additional setup call. * * Emits an {Upgraded} event. */ function _upgradeToAndCallSecure( address newImplementation, bytes memory data, bool forceCall ) internal { address oldImplementation = _getImplementation(); // Initial upgrade and setup call _setImplementation(newImplementation); if (data.length > 0 || forceCall) { Address.functionDelegateCall(newImplementation, data); } // Perform rollback test if not already in progress StorageSlot.BooleanSlot storage rollbackTesting = StorageSlot.getBooleanSlot(_ROLLBACK_SLOT); if (!rollbackTesting.value) { // Trigger rollback using upgradeTo from the new implementation rollbackTesting.value = true; Address.functionDelegateCall( newImplementation, abi.encodeWithSignature("upgradeTo(address)", oldImplementation) ); rollbackTesting.value = false; // Check rollback was effective require(oldImplementation == _getImplementation(), "ERC1967Upgrade: upgrade breaks further upgrades"); // Finally reset to the new implementation and log the upgrade _upgradeTo(newImplementation); } } /** * @dev Storage slot with the admin of the contract. * This is the keccak-256 hash of "eip1967.proxy.admin" subtracted by 1, and is * validated in the constructor. */ bytes32 internal constant _ADMIN_SLOT = 0xb53127684a568b3173ae13b9f8a6016e243e63b6e8ee1178d6a717850b5d6103; /** * @dev Emitted when the admin account has changed. */ event AdminChanged(address previousAdmin, address newAdmin); /** * @dev Returns the current admin. */ function _getAdmin() internal view returns (address) { return StorageSlot.getAddressSlot(_ADMIN_SLOT).value; } /** * @dev Stores a new address in the EIP1967 admin slot. */ function _setAdmin(address newAdmin) private { require(newAdmin != address(0), "ERC1967: new admin is the zero address"); StorageSlot.getAddressSlot(_ADMIN_SLOT).value = newAdmin; } /** * @dev Changes the admin of the proxy. * * Emits an {AdminChanged} event. */ function _changeAdmin(address newAdmin) internal { emit AdminChanged(_getAdmin(), newAdmin); _setAdmin(newAdmin); } /** * @dev The storage slot of the UpgradeableBeacon contract which defines the implementation for this proxy. * This is bytes32(uint256(keccak256('eip1967.proxy.beacon')) - 1)) and is validated in the constructor. */ bytes32 internal constant _BEACON_SLOT = 0xa3f0ad74e5423aebfd80d3ef4346578335a9a72aeaee59ff6cb3582b35133d50; /** * @dev Emitted when the beacon is upgraded. */ event BeaconUpgraded(address indexed beacon); /** * @dev Returns the current beacon. */ function _getBeacon() internal view returns (address) { return StorageSlot.getAddressSlot(_BEACON_SLOT).value; } /** * @dev Stores a new beacon in the EIP1967 beacon slot. */ function _setBeacon(address newBeacon) private { require(Address.isContract(newBeacon), "ERC1967: new beacon is not a contract"); require( Address.isContract(IBeacon(newBeacon).implementation()), "ERC1967: beacon implementation is not a contract" ); StorageSlot.getAddressSlot(_BEACON_SLOT).value = newBeacon; } /** * @dev Perform beacon upgrade with additional setup call. Note: This upgrades the address of the beacon, it does * not upgrade the implementation contained in the beacon (see {UpgradeableBeacon-_setImplementation} for that). * * Emits a {BeaconUpgraded} event. */ function _upgradeBeaconToAndCall( address newBeacon, bytes memory data, bool forceCall ) internal { _setBeacon(newBeacon); emit BeaconUpgraded(newBeacon); if (data.length > 0 || forceCall) { Address.functionDelegateCall(IBeacon(newBeacon).implementation(), data); } } } ////// lib/openzeppelin-contracts/contracts/proxy/Proxy.sol /* pragma solidity ^0.8.0; */ /** * @dev This abstract contract provides a fallback function that delegates all calls to another contract using the EVM * instruction `delegatecall`. We refer to the second contract as the _implementation_ behind the proxy, and it has to * be specified by overriding the virtual {_implementation} function. * * Additionally, delegation to the implementation can be triggered manually through the {_fallback} function, or to a * different contract through the {_delegate} function. * * The success and return data of the delegated call will be returned back to the caller of the proxy. */ abstract contract Proxy { /** * @dev Delegates the current call to `implementation`. * * This function does not return to its internall call site, it will return directly to the external caller. */ function _delegate(address implementation) internal virtual { assembly { // Copy msg.data. We take full control of memory in this inline assembly // block because it will not return to Solidity code. We overwrite the // Solidity scratch pad at memory position 0. calldatacopy(0, 0, calldatasize()) // Call the implementation. // out and outsize are 0 because we don't know the size yet. let result := delegatecall(gas(), implementation, 0, calldatasize(), 0, 0) // Copy the returned data. returndatacopy(0, 0, returndatasize()) switch result // delegatecall returns 0 on error. case 0 { revert(0, returndatasize()) } default { return(0, returndatasize()) } } } /** * @dev This is a virtual function that should be overriden so it returns the address to which the fallback function * and {_fallback} should delegate. */ function _implementation() internal view virtual returns (address); /** * @dev Delegates the current call to the address returned by `_implementation()`. * * This function does not return to its internall call site, it will return directly to the external caller. */ function _fallback() internal virtual { _beforeFallback(); _delegate(_implementation()); } /** * @dev Fallback function that delegates calls to the address returned by `_implementation()`. Will run if no other * function in the contract matches the call data. */ fallback() external payable virtual { _fallback(); } /** * @dev Fallback function that delegates calls to the address returned by `_implementation()`. Will run if call data * is empty. */ receive() external payable virtual { _fallback(); } /** * @dev Hook that is called before falling back to the implementation. Can happen as part of a manual `_fallback` * call, or as part of the Solidity `fallback` or `receive` functions. * * If overriden should call `super._beforeFallback()`. */ function _beforeFallback() internal virtual {} } ////// lib/openzeppelin-contracts/contracts/proxy/ERC1967/ERC1967Proxy.sol /* pragma solidity ^0.8.0; */ /* import "../Proxy.sol"; */ /* import "./ERC1967Upgrade.sol"; */ /** * @dev This contract implements an upgradeable proxy. It is upgradeable because calls are delegated to an * implementation address that can be changed. This address is stored in storage in the location specified by * https://eips.ethereum.org/EIPS/eip-1967[EIP1967], so that it doesn't conflict with the storage layout of the * implementation behind the proxy. */ contract ERC1967Proxy is Proxy, ERC1967Upgrade { /** * @dev Initializes the upgradeable proxy with an initial implementation specified by `_logic`. * * If `_data` is nonempty, it's used as data in a delegate call to `_logic`. This will typically be an encoded * function call, and allows initializating the storage of the proxy like a Solidity constructor. */ constructor(address _logic, bytes memory _data) payable { assert(_IMPLEMENTATION_SLOT == bytes32(uint256(keccak256("eip1967.proxy.implementation")) - 1)); _upgradeToAndCall(_logic, _data, false); } /** * @dev Returns the current implementation address. */ function _implementation() internal view virtual override returns (address impl) { return ERC1967Upgrade._getImplementation(); } } ////// lib/openzeppelin-contracts/contracts/proxy/utils/UUPSUpgradeable.sol /* pragma solidity ^0.8.0; */ /* import "../ERC1967/ERC1967Upgrade.sol"; */ /** * @dev An upgradeability mechanism designed for UUPS proxies. The functions included here can perform an upgrade of an * {ERC1967Proxy}, when this contract is set as the implementation behind such a proxy. * * A security mechanism ensures that an upgrade does not turn off upgradeability accidentally, although this risk is * reinstated if the upgrade retains upgradeability but removes the security mechanism, e.g. by replacing * `UUPSUpgradeable` with a custom implementation of upgrades. * * The {_authorizeUpgrade} function must be overridden to include access restriction to the upgrade mechanism. * * _Available since v4.1._ */ abstract contract UUPSUpgradeable is ERC1967Upgrade { /// @custom:oz-upgrades-unsafe-allow state-variable-immutable state-variable-assignment address private immutable __self = address(this); /** * @dev Check that the execution is being performed through a delegatecall call and that the execution context is * a proxy contract with an implementation (as defined in ERC1967) pointing to self. This should only be the case * for UUPS and transparent proxies that are using the current contract as their implementation. Execution of a * function through ERC1167 minimal proxies (clones) would not normally pass this test, but is not guaranteed to * fail. */ modifier onlyProxy() { require(address(this) != __self, "Function must be called through delegatecall"); require(_getImplementation() == __self, "Function must be called through active proxy"); _; } /** * @dev Upgrade the implementation of the proxy to `newImplementation`. * * Calls {_authorizeUpgrade}. * * Emits an {Upgraded} event. */ function upgradeTo(address newImplementation) external virtual onlyProxy { _authorizeUpgrade(newImplementation); _upgradeToAndCallSecure(newImplementation, new bytes(0), false); } /** * @dev Upgrade the implementation of the proxy to `newImplementation`, and subsequently execute the function call * encoded in `data`. * * Calls {_authorizeUpgrade}. * * Emits an {Upgraded} event. */ function upgradeToAndCall(address newImplementation, bytes memory data) external payable virtual onlyProxy { _authorizeUpgrade(newImplementation); _upgradeToAndCallSecure(newImplementation, data, true); } /** * @dev Function that should revert when `msg.sender` is not authorized to upgrade the contract. Called by * {upgradeTo} and {upgradeToAndCall}. * * Normally, this function will use an xref:access.adoc[access control] modifier such as {Ownable-onlyOwner}. * * ```solidity * function _authorizeUpgrade(address) internal override onlyOwner {} * ``` */ function _authorizeUpgrade(address newImplementation) internal virtual; } ////// lib/radicle-drips-hub/src/Structs.sol /* pragma solidity ^0.8.7; */ struct DripsReceiver { address receiver; uint128 amtPerSec; } struct SplitsReceiver { address receiver; uint32 weight; } ////// lib/radicle-drips-hub/src/DripsHub.sol /* pragma solidity ^0.8.7; */ /* import {DripsReceiver, SplitsReceiver} from "./Structs.sol"; */ /// @notice Drips hub contract. Automatically drips and splits funds between users. /// /// The user can transfer some funds to their drips balance in the contract /// and configure a list of receivers, to whom they want to drip these funds. /// As soon as the drips balance is enough to cover at least 1 second of dripping /// to the configured receivers, the funds start dripping automatically. /// Every second funds are deducted from the drips balance and moved to their receivers' accounts. /// The process stops automatically when the drips balance is not enough to cover another second. /// /// The user can have any number of independent configurations and drips balances by using accounts. /// An account is identified by the user address and an account identifier. /// Accounts of different users are separate entities, even if they have the same identifiers. /// An account can be used to drip or give, but not to receive funds. /// /// Every user has a receiver balance, in which they have funds received from other users. /// The dripped funds are added to the receiver balances in global cycles. /// Every `cycleSecs` seconds the drips hub adds dripped funds to the receivers' balances, /// so recently dripped funds may not be collectable immediately. /// `cycleSecs` is a constant configured when the drips hub is deployed. /// The receiver balance is independent from the drips balance, /// to drip received funds they need to be first collected and then added to the drips balance. /// /// The user can share collected funds with other users by using splits. /// When collecting, the user gives each of their splits receivers a fraction of the received funds. /// Funds received from splits are available for collection immediately regardless of the cycle. /// They aren't exempt from being split, so they too can be split when collected. /// Users can build chains and networks of splits between each other. /// Anybody can request collection of funds for any user, /// which can be used to enforce the flow of funds in the network of splits. /// /// The concept of something happening periodically, e.g. every second or every `cycleSecs` are /// only high-level abstractions for the user, Ethereum isn't really capable of scheduling work. /// The actual implementation emulates that behavior by calculating the results of the scheduled /// events based on how many seconds have passed and only when the user needs their outcomes. /// /// The contract assumes that all amounts in the system can be stored in signed 128-bit integers. /// It's guaranteed to be safe only when working with assets with supply lower than `2 ^ 127`. abstract contract DripsHub { /// @notice On every timestamp `T`, which is a multiple of `cycleSecs`, the receivers /// gain access to drips collected during `T - cycleSecs` to `T - 1`. uint64 public immutable cycleSecs; /// @notice Timestamp at which all drips must be finished uint64 internal constant MAX_TIMESTAMP = type(uint64).max - 2; /// @notice Maximum number of drips receivers of a single user. /// Limits cost of changes in drips configuration. uint32 public constant MAX_DRIPS_RECEIVERS = 100; /// @notice Maximum number of splits receivers of a single user. /// Limits cost of collecting. uint32 public constant MAX_SPLITS_RECEIVERS = 200; /// @notice The total splits weight of a user uint32 public constant TOTAL_SPLITS_WEIGHT = 1_000_000; /// @notice The ERC-1967 storage slot for the contract. /// It holds a single `DripsHubStorage` structure. bytes32 private constant SLOT_STORAGE = bytes32(uint256(keccak256("eip1967.dripsHub.storage")) - 1); /// @notice Emitted when drips from a user to a receiver are updated. /// Funds are being dripped on every second between the event block's timestamp (inclusively) /// and`endTime` (exclusively) or until the timestamp of the next drips update (exclusively). /// @param user The dripping user /// @param receiver The receiver of the updated drips /// @param amtPerSec The new amount per second dripped from the user /// to the receiver or 0 if the drips are stopped /// @param endTime The timestamp when dripping will stop, /// always larger than the block timestamp or equal to it if the drips are stopped event Dripping( address indexed user, address indexed receiver, uint128 amtPerSec, uint64 endTime ); /// @notice Emitted when drips from a user's account to a receiver are updated. /// Funds are being dripped on every second between the event block's timestamp (inclusively) /// and`endTime` (exclusively) or until the timestamp of the next drips update (exclusively). /// @param user The user /// @param account The dripping account /// @param receiver The receiver of the updated drips /// @param amtPerSec The new amount per second dripped from the user's account /// to the receiver or 0 if the drips are stopped /// @param endTime The timestamp when dripping will stop, /// always larger than the block timestamp or equal to it if the drips are stopped event Dripping( address indexed user, uint256 indexed account, address indexed receiver, uint128 amtPerSec, uint64 endTime ); /// @notice Emitted when the drips configuration of a user is updated. /// @param user The user /// @param balance The new drips balance. These funds will be dripped to the receivers. /// @param receivers The new list of the drips receivers. event DripsUpdated(address indexed user, uint128 balance, DripsReceiver[] receivers); /// @notice Emitted when the drips configuration of a user's account is updated. /// @param user The user /// @param account The account /// @param balance The new drips balance. These funds will be dripped to the receivers. /// @param receivers The new list of the drips receivers. event DripsUpdated( address indexed user, uint256 indexed account, uint128 balance, DripsReceiver[] receivers ); /// @notice Emitted when the user's splits are updated. /// @param user The user /// @param receivers The list of the user's splits receivers. event SplitsUpdated(address indexed user, SplitsReceiver[] receivers); /// @notice Emitted when a user collects funds /// @param user The user /// @param collected The collected amount /// @param split The amount split to the user's splits receivers event Collected(address indexed user, uint128 collected, uint128 split); /// @notice Emitted when funds are split from a user to a receiver. /// This is caused by the user collecting received funds. /// @param user The user /// @param receiver The splits receiver /// @param amt The amount split to the receiver event Split(address indexed user, address indexed receiver, uint128 amt); /// @notice Emitted when funds are given from the user to the receiver. /// @param user The address of the user /// @param receiver The receiver /// @param amt The given amount event Given(address indexed user, address indexed receiver, uint128 amt); /// @notice Emitted when funds are given from the user's account to the receiver. /// @param user The address of the user /// @param account The user's account /// @param receiver The receiver /// @param amt The given amount event Given( address indexed user, uint256 indexed account, address indexed receiver, uint128 amt ); struct ReceiverState { // The amount collectable independently from cycles uint128 collectable; // The next cycle to be collected uint64 nextCollectedCycle; // --- SLOT BOUNDARY // The changes of collected amounts on specific cycle. // The keys are cycles, each cycle `C` becomes collectable on timestamp `C * cycleSecs`. // Values for cycles before `nextCollectedCycle` are guaranteed to be zeroed. // This means that the value of `amtDeltas[nextCollectedCycle].thisCycle` is always // relative to 0 or in other words it's an absolute value independent from other cycles. mapping(uint64 => AmtDelta) amtDeltas; } struct AmtDelta { // Amount delta applied on this cycle int128 thisCycle; // Amount delta applied on the next cycle int128 nextCycle; } struct UserOrAccount { bool isAccount; address user; uint256 account; } struct DripsHubStorage { /// @notice Users' splits configuration hashes, see `hashSplits`. /// The key is the user address. mapping(address => bytes32) splitsHash; /// @notice Users' drips configuration hashes, see `hashDrips`. /// The key is the user address. mapping(address => bytes32) userDripsHashes; /// @notice Users' accounts' configuration hashes, see `hashDrips`. /// The key are the user address and the account. mapping(address => mapping(uint256 => bytes32)) accountDripsHashes; /// @notice Users' receiver states. /// The key is the user address. mapping(address => ReceiverState) receiverStates; } /// @param _cycleSecs The length of cycleSecs to be used in the contract instance. /// Low value makes funds more available by shortening the average time of funds being frozen /// between being taken from the users' drips balances and being collectable by their receivers. /// High value makes collecting cheaper by making it process less cycles for a given time range. constructor(uint64 _cycleSecs) { cycleSecs = _cycleSecs; } /// @notice Returns the contract storage. /// @return dripsHubStorage The storage. function _storage() internal pure returns (DripsHubStorage storage dripsHubStorage) { bytes32 slot = SLOT_STORAGE; // solhint-disable-next-line no-inline-assembly assembly { // Based on OpenZeppelin's StorageSlot dripsHubStorage.slot := slot } } /// @notice Returns amount of received funds available for collection for a user. /// @param user The user /// @param currReceivers The list of the user's current splits receivers. /// @return collected The collected amount /// @return split The amount split to the user's splits receivers function collectable(address user, SplitsReceiver[] memory currReceivers) public view returns (uint128 collected, uint128 split) { ReceiverState storage receiver = _storage().receiverStates[user]; _assertCurrSplits(user, currReceivers); // Collectable independently from cycles collected = receiver.collectable; // Collectable from cycles uint64 collectedCycle = receiver.nextCollectedCycle; uint64 currFinishedCycle = _currTimestamp() / cycleSecs; if (collectedCycle != 0 && collectedCycle <= currFinishedCycle) { int128 cycleAmt = 0; for (; collectedCycle <= currFinishedCycle; collectedCycle++) { cycleAmt += receiver.amtDeltas[collectedCycle].thisCycle; collected += uint128(cycleAmt); cycleAmt += receiver.amtDeltas[collectedCycle].nextCycle; } } // split when collected if (collected > 0 && currReceivers.length > 0) { uint32 splitsWeight = 0; for (uint256 i = 0; i < currReceivers.length; i++) { splitsWeight += currReceivers[i].weight; } split = uint128((uint160(collected) * splitsWeight) / TOTAL_SPLITS_WEIGHT); collected -= split; } } /// @notice Collects all received funds available for the user /// and transfers them out of the drips hub contract to that user's wallet. /// @param user The user /// @param currReceivers The list of the user's current splits receivers. /// @return collected The collected amount /// @return split The amount split to the user's splits receivers function collect(address user, SplitsReceiver[] memory currReceivers) public virtual returns (uint128 collected, uint128 split) { (collected, split) = _collectInternal(user, currReceivers); _transfer(user, int128(collected)); } /// @notice Counts cycles which will need to be analyzed when collecting or flushing. /// This function can be used to detect that there are too many cycles /// to analyze in a single transaction and flushing is needed. /// @param user The user /// @return flushable The number of cycles which can be flushed function flushableCycles(address user) public view returns (uint64 flushable) { uint64 nextCollectedCycle = _storage().receiverStates[user].nextCollectedCycle; if (nextCollectedCycle == 0) return 0; uint64 currFinishedCycle = _currTimestamp() / cycleSecs; return currFinishedCycle + 1 - nextCollectedCycle; } /// @notice Flushes uncollected cycles of the user. /// Flushed cycles won't need to be analyzed when the user collects from them. /// Calling this function does not collect and does not affect the collectable amount. /// /// This function is needed when collecting funds received over a period so long, that the gas /// needed for analyzing all the uncollected cycles can't fit in a single transaction. /// Calling this function allows spreading the analysis cost over multiple transactions. /// A cycle is never flushed more than once, even if this function is called many times. /// @param user The user /// @param maxCycles The maximum number of flushed cycles. /// If too low, flushing will be cheap, but will cut little gas from the next collection. /// If too high, flushing may become too expensive to fit in a single transaction. /// @return flushable The number of cycles which can be flushed function flushCycles(address user, uint64 maxCycles) public virtual returns (uint64 flushable) { flushable = flushableCycles(user); uint64 cycles = maxCycles < flushable ? maxCycles : flushable; flushable -= cycles; uint128 collected = _flushCyclesInternal(user, cycles); if (collected > 0) _storage().receiverStates[user].collectable += collected; } /// @notice Collects all received funds available for the user, /// but doesn't transfer them to the user's wallet. /// @param user The user /// @param currReceivers The list of the user's current splits receivers. /// @return collected The collected amount /// @return split The amount split to the user's splits receivers function _collectInternal(address user, SplitsReceiver[] memory currReceivers) internal returns (uint128 collected, uint128 split) { mapping(address => ReceiverState) storage receiverStates = _storage().receiverStates; ReceiverState storage receiver = receiverStates[user]; _assertCurrSplits(user, currReceivers); // Collectable independently from cycles collected = receiver.collectable; if (collected > 0) receiver.collectable = 0; // Collectable from cycles uint64 cycles = flushableCycles(user); collected += _flushCyclesInternal(user, cycles); // split when collected if (collected > 0 && currReceivers.length > 0) { uint32 splitsWeight = 0; for (uint256 i = 0; i < currReceivers.length; i++) { splitsWeight += currReceivers[i].weight; uint128 splitsAmt = uint128( (uint160(collected) * splitsWeight) / TOTAL_SPLITS_WEIGHT - split ); split += splitsAmt; address splitsReceiver = currReceivers[i].receiver; receiverStates[splitsReceiver].collectable += splitsAmt; emit Split(user, splitsReceiver, splitsAmt); } collected -= split; } emit Collected(user, collected, split); } /// @notice Collects and clears user's cycles /// @param user The user /// @param count The number of flushed cycles. /// @return collectedAmt The collected amount function _flushCyclesInternal(address user, uint64 count) internal returns (uint128 collectedAmt) { if (count == 0) return 0; ReceiverState storage receiver = _storage().receiverStates[user]; uint64 cycle = receiver.nextCollectedCycle; int128 cycleAmt = 0; for (uint256 i = 0; i < count; i++) { cycleAmt += receiver.amtDeltas[cycle].thisCycle; collectedAmt += uint128(cycleAmt); cycleAmt += receiver.amtDeltas[cycle].nextCycle; delete receiver.amtDeltas[cycle]; cycle++; } // The next cycle delta must be relative to the last collected cycle, which got zeroed. // In other words the next cycle delta must be an absolute value. if (cycleAmt != 0) receiver.amtDeltas[cycle].thisCycle += cycleAmt; receiver.nextCollectedCycle = cycle; } /// @notice Gives funds from the user or their account to the receiver. /// The receiver can collect them immediately. /// Transfers the funds to be given from the user's wallet to the drips hub contract. /// @param userOrAccount The user or their account /// @param receiver The receiver /// @param amt The given amount function _give( UserOrAccount memory userOrAccount, address receiver, uint128 amt ) internal { _storage().receiverStates[receiver].collectable += amt; if (userOrAccount.isAccount) { emit Given(userOrAccount.user, userOrAccount.account, receiver, amt); } else { emit Given(userOrAccount.user, receiver, amt); } _transfer(userOrAccount.user, -int128(amt)); } /// @notice Current user's drips hash, see `hashDrips`. /// @param user The user /// @return currDripsHash The current user's drips hash function dripsHash(address user) public view returns (bytes32 currDripsHash) { return _storage().userDripsHashes[user]; } /// @notice Current user account's drips hash, see `hashDrips`. /// @param user The user /// @param account The account /// @return currDripsHash The current user account's drips hash function dripsHash(address user, uint256 account) public view returns (bytes32 currDripsHash) { return _storage().accountDripsHashes[user][account]; } /// @notice Sets the user's or the account's drips configuration. /// Transfers funds between the user's wallet and the drips hub contract /// to fulfill the change of the drips balance. /// @param userOrAccount The user or their account /// @param lastUpdate The timestamp of the last drips update of the user or the account. /// If this is the first update, pass zero. /// @param lastBalance The drips balance after the last drips update of the user or the account. /// If this is the first update, pass zero. /// @param currReceivers The list of the drips receivers set in the last drips update /// of the user or the account. /// If this is the first update, pass an empty array. /// @param balanceDelta The drips balance change to be applied. /// Positive to add funds to the drips balance, negative to remove them. /// @param newReceivers The list of the drips receivers of the user or the account to be set. /// Must be sorted by the receivers' addresses, deduplicated and without 0 amtPerSecs. /// @return newBalance The new drips balance of the user or the account. /// Pass it as `lastBalance` when updating that user or the account for the next time. /// @return realBalanceDelta The actually applied drips balance change. function _setDrips( UserOrAccount memory userOrAccount, uint64 lastUpdate, uint128 lastBalance, DripsReceiver[] memory currReceivers, int128 balanceDelta, DripsReceiver[] memory newReceivers ) internal returns (uint128 newBalance, int128 realBalanceDelta) { _assertCurrDrips(userOrAccount, lastUpdate, lastBalance, currReceivers); uint128 newAmtPerSec = _assertDripsReceiversValid(newReceivers); uint128 currAmtPerSec = _totalDripsAmtPerSec(currReceivers); uint64 currEndTime = _dripsEndTime(lastUpdate, lastBalance, currAmtPerSec); (newBalance, realBalanceDelta) = _updateDripsBalance( lastUpdate, lastBalance, currEndTime, currAmtPerSec, balanceDelta ); uint64 newEndTime = _dripsEndTime(_currTimestamp(), newBalance, newAmtPerSec); _updateDripsReceiversStates( userOrAccount, currReceivers, currEndTime, newReceivers, newEndTime ); _storeNewDrips(userOrAccount, newBalance, newReceivers); _emitDripsUpdated(userOrAccount, newBalance, newReceivers); _transfer(userOrAccount.user, -realBalanceDelta); } /// @notice Validates a list of drips receivers. /// @param receivers The list of drips receivers. /// Must be sorted by the receivers' addresses, deduplicated and without 0 amtPerSecs. /// @return totalAmtPerSec The total amount per second of all drips receivers. function _assertDripsReceiversValid(DripsReceiver[] memory receivers) internal pure returns (uint128 totalAmtPerSec) { require(receivers.length <= MAX_DRIPS_RECEIVERS, "Too many drips receivers"); uint256 amtPerSec = 0; address prevReceiver; for (uint256 i = 0; i < receivers.length; i++) { uint128 amt = receivers[i].amtPerSec; require(amt != 0, "Drips receiver amtPerSec is zero"); amtPerSec += amt; address receiver = receivers[i].receiver; if (i > 0) { require(prevReceiver != receiver, "Duplicate drips receivers"); require(prevReceiver < receiver, "Drips receivers not sorted by address"); } prevReceiver = receiver; } require(amtPerSec <= type(uint128).max, "Total drips receivers amtPerSec too high"); return uint128(amtPerSec); } /// @notice Calculates the total amount per second of all the drips receivers. /// @param receivers The list of the receivers. /// It must have passed `_assertDripsReceiversValid` in the past. /// @return totalAmtPerSec The total amount per second of all the drips receivers function _totalDripsAmtPerSec(DripsReceiver[] memory receivers) internal pure returns (uint128 totalAmtPerSec) { uint256 length = receivers.length; uint256 i = 0; while (i < length) { // Safe, because `receivers` passed `_assertDripsReceiversValid` in the past unchecked { totalAmtPerSec += receivers[i++].amtPerSec; } } } /// @notice Updates drips balance. /// @param lastUpdate The timestamp of the last drips update. /// If this is the first update, pass zero. /// @param lastBalance The drips balance after the last drips update. /// If this is the first update, pass zero. /// @param currEndTime Time when drips were supposed to end according to the last drips update. /// @param currAmtPerSec The total amount per second of all drips receivers /// according to the last drips update. /// @param balanceDelta The drips balance change to be applied. /// Positive to add funds to the drips balance, negative to remove them. /// @return newBalance The new drips balance. /// Pass it as `lastBalance` when updating for the next time. /// @return realBalanceDelta The actually applied drips balance change. /// If positive, this is the amount which should be transferred from the user to the drips hub, /// or if negative, from the drips hub to the user. function _updateDripsBalance( uint64 lastUpdate, uint128 lastBalance, uint64 currEndTime, uint128 currAmtPerSec, int128 balanceDelta ) internal view returns (uint128 newBalance, int128 realBalanceDelta) { if (currEndTime > _currTimestamp()) currEndTime = _currTimestamp(); uint128 dripped = (currEndTime - lastUpdate) * currAmtPerSec; int128 currBalance = int128(lastBalance - dripped); int136 balance = currBalance + int136(balanceDelta); if (balance < 0) balance = 0; return (uint128(uint136(balance)), int128(balance - currBalance)); } /// @notice Emit an event when drips are updated. /// @param userOrAccount The user or their account /// @param balance The new drips balance. /// @param receivers The new list of the drips receivers. function _emitDripsUpdated( UserOrAccount memory userOrAccount, uint128 balance, DripsReceiver[] memory receivers ) internal { if (userOrAccount.isAccount) { emit DripsUpdated(userOrAccount.user, userOrAccount.account, balance, receivers); } else { emit DripsUpdated(userOrAccount.user, balance, receivers); } } /// @notice Updates the user's or the account's drips receivers' states. /// It applies the effects of the change of the drips configuration. /// @param userOrAccount The user or their account /// @param currReceivers The list of the drips receivers set in the last drips update /// of the user or the account. /// If this is the first update, pass an empty array. /// @param currEndTime Time when drips were supposed to end according to the last drips update. /// @param newReceivers The list of the drips receivers of the user or the account to be set. /// Must be sorted by the receivers' addresses, deduplicated and without 0 amtPerSecs. /// @param newEndTime Time when drips will end according to the new drips configuration. function _updateDripsReceiversStates( UserOrAccount memory userOrAccount, DripsReceiver[] memory currReceivers, uint64 currEndTime, DripsReceiver[] memory newReceivers, uint64 newEndTime ) internal { // Skip iterating over `currReceivers` if dripping has run out uint256 currIdx = currEndTime > _currTimestamp() ? 0 : currReceivers.length; // Skip iterating over `newReceivers` if no new dripping is started uint256 newIdx = newEndTime > _currTimestamp() ? 0 : newReceivers.length; while (true) { // Each iteration gets the next drips update and applies it on the receiver state. // A drips update is composed of two drips receiver configurations, // one current and one new, or from a single drips receiver configuration // if the drips receiver is being added or removed. bool pickCurr = currIdx < currReceivers.length; bool pickNew = newIdx < newReceivers.length; if (!pickCurr && !pickNew) break; if (pickCurr && pickNew) { // There are two candidate drips receiver configurations to create a drips update. // Pick both if they describe the same receiver or the one with a lower address. // The one with a higher address won't be used in this iteration. // Because drips receivers lists are sorted by addresses and deduplicated, // all matching pairs of drips receiver configurations will be found. address currReceiver = currReceivers[currIdx].receiver; address newReceiver = newReceivers[newIdx].receiver; pickCurr = currReceiver <= newReceiver; pickNew = newReceiver <= currReceiver; } // The drips update parameters address receiver; int128 currAmtPerSec = 0; int128 newAmtPerSec = 0; if (pickCurr) { receiver = currReceivers[currIdx].receiver; currAmtPerSec = int128(currReceivers[currIdx].amtPerSec); // Clear the obsolete drips end _setDelta(receiver, currEndTime, currAmtPerSec); currIdx++; } if (pickNew) { receiver = newReceivers[newIdx].receiver; newAmtPerSec = int128(newReceivers[newIdx].amtPerSec); // Apply the new drips end _setDelta(receiver, newEndTime, -newAmtPerSec); newIdx++; } // Apply the drips update since now _setDelta(receiver, _currTimestamp(), newAmtPerSec - currAmtPerSec); _emitDripping(userOrAccount, receiver, uint128(newAmtPerSec), newEndTime); // The receiver may have never been used if (!pickCurr) { ReceiverState storage receiverState = _storage().receiverStates[receiver]; // The receiver has never been used, initialize it if (receiverState.nextCollectedCycle == 0) { receiverState.nextCollectedCycle = _currTimestamp() / cycleSecs + 1; } } } } /// @notice Emit an event when drips from a user to a receiver are updated. /// @param userOrAccount The user or their account /// @param receiver The receiver /// @param amtPerSec The new amount per second dripped from the user or the account /// to the receiver or 0 if the drips are stopped /// @param endTime The timestamp when dripping will stop function _emitDripping( UserOrAccount memory userOrAccount, address receiver, uint128 amtPerSec, uint64 endTime ) internal { if (amtPerSec == 0) endTime = _currTimestamp(); if (userOrAccount.isAccount) { emit Dripping(userOrAccount.user, userOrAccount.account, receiver, amtPerSec, endTime); } else { emit Dripping(userOrAccount.user, receiver, amtPerSec, endTime); } } /// @notice Calculates the timestamp when dripping will end. /// @param startTime Time when dripping is started. /// @param startBalance The drips balance when dripping is started. /// @param totalAmtPerSec The total amount per second of all the drips receivers /// @return dripsEndTime The dripping end time. function _dripsEndTime( uint64 startTime, uint128 startBalance, uint128 totalAmtPerSec ) internal pure returns (uint64 dripsEndTime) { if (totalAmtPerSec == 0) return startTime; uint256 endTime = startTime + uint256(startBalance / totalAmtPerSec); return endTime > MAX_TIMESTAMP ? MAX_TIMESTAMP : uint64(endTime); } /// @notice Asserts that the drips configuration is the currently used one. /// @param userOrAccount The user or their account /// @param lastUpdate The timestamp of the last drips update of the user or the account. /// If this is the first update, pass zero. /// @param lastBalance The drips balance after the last drips update of the user or the account. /// If this is the first update, pass zero. /// @param currReceivers The list of the drips receivers set in the last drips update /// of the user or the account. /// If this is the first update, pass an empty array. function _assertCurrDrips( UserOrAccount memory userOrAccount, uint64 lastUpdate, uint128 lastBalance, DripsReceiver[] memory currReceivers ) internal view { bytes32 expectedHash; if (userOrAccount.isAccount) { expectedHash = _storage().accountDripsHashes[userOrAccount.user][userOrAccount.account]; } else { expectedHash = _storage().userDripsHashes[userOrAccount.user]; } bytes32 actualHash = hashDrips(lastUpdate, lastBalance, currReceivers); require(actualHash == expectedHash, "Invalid current drips configuration"); } /// @notice Stores the hash of the new drips configuration to be used in `_assertCurrDrips`. /// @param userOrAccount The user or their account /// @param newBalance The user or the account drips balance. /// @param newReceivers The list of the drips receivers of the user or the account. /// Must be sorted by the receivers' addresses, deduplicated and without 0 amtPerSecs. function _storeNewDrips( UserOrAccount memory userOrAccount, uint128 newBalance, DripsReceiver[] memory newReceivers ) internal { bytes32 newDripsHash = hashDrips(_currTimestamp(), newBalance, newReceivers); if (userOrAccount.isAccount) { _storage().accountDripsHashes[userOrAccount.user][userOrAccount.account] = newDripsHash; } else { _storage().userDripsHashes[userOrAccount.user] = newDripsHash; } } /// @notice Calculates the hash of the drips configuration. /// It's used to verify if drips configuration is the previously set one. /// @param update The timestamp of the drips update. /// If the drips have never been updated, pass zero. /// @param balance The drips balance. /// If the drips have never been updated, pass zero. /// @param receivers The list of the drips receivers. /// Must be sorted by the receivers' addresses, deduplicated and without 0 amtPerSecs. /// If the drips have never been updated, pass an empty array. /// @return dripsConfigurationHash The hash of the drips configuration function hashDrips( uint64 update, uint128 balance, DripsReceiver[] memory receivers ) public pure returns (bytes32 dripsConfigurationHash) { if (update == 0 && balance == 0 && receivers.length == 0) return bytes32(0); return keccak256(abi.encode(receivers, update, balance)); } /// @notice Collects funds received by the user and sets their splits. /// The collected funds are split according to `currReceivers`. /// @param user The user /// @param currReceivers The list of the user's splits receivers which is currently in use. /// If this function is called for the first time for the user, should be an empty array. /// @param newReceivers The new list of the user's splits receivers. /// Must be sorted by the splits receivers' addresses, deduplicated and without 0 weights. /// Each splits receiver will be getting `weight / TOTAL_SPLITS_WEIGHT` /// share of the funds collected by the user. /// @return collected The collected amount /// @return split The amount split to the user's splits receivers function _setSplits( address user, SplitsReceiver[] memory currReceivers, SplitsReceiver[] memory newReceivers ) internal returns (uint128 collected, uint128 split) { (collected, split) = _collectInternal(user, currReceivers); _assertSplitsValid(newReceivers); _storage().splitsHash[user] = hashSplits(newReceivers); emit SplitsUpdated(user, newReceivers); _transfer(user, int128(collected)); } /// @notice Validates a list of splits receivers /// @param receivers The list of splits receivers /// Must be sorted by the splits receivers' addresses, deduplicated and without 0 weights. function _assertSplitsValid(SplitsReceiver[] memory receivers) internal pure { require(receivers.length <= MAX_SPLITS_RECEIVERS, "Too many splits receivers"); uint64 totalWeight = 0; address prevReceiver; for (uint256 i = 0; i < receivers.length; i++) { uint32 weight = receivers[i].weight; require(weight != 0, "Splits receiver weight is zero"); totalWeight += weight; address receiver = receivers[i].receiver; if (i > 0) { require(prevReceiver != receiver, "Duplicate splits receivers"); require(prevReceiver < receiver, "Splits receivers not sorted by address"); } prevReceiver = receiver; } require(totalWeight <= TOTAL_SPLITS_WEIGHT, "Splits weights sum too high"); } /// @notice Current user's splits hash, see `hashSplits`. /// @param user The user /// @return currSplitsHash The current user's splits hash function splitsHash(address user) public view returns (bytes32 currSplitsHash) { return _storage().splitsHash[user]; } /// @notice Asserts that the list of splits receivers is the user's currently used one. /// @param user The user /// @param currReceivers The list of the user's current splits receivers. function _assertCurrSplits(address user, SplitsReceiver[] memory currReceivers) internal view { require( hashSplits(currReceivers) == _storage().splitsHash[user], "Invalid current splits receivers" ); } /// @notice Calculates the hash of the list of splits receivers. /// @param receivers The list of the splits receivers. /// Must be sorted by the splits receivers' addresses, deduplicated and without 0 weights. /// @return receiversHash The hash of the list of splits receivers. function hashSplits(SplitsReceiver[] memory receivers) public pure returns (bytes32 receiversHash) { if (receivers.length == 0) return bytes32(0); return keccak256(abi.encode(receivers)); } /// @notice Called when funds need to be transferred between the user and the drips hub. /// The function must be called no more than once per transaction. /// @param user The user /// @param amt The transferred amount. /// Positive to transfer funds to the user, negative to transfer from them. function _transfer(address user, int128 amt) internal virtual; /// @notice Sets amt delta of a user on a given timestamp /// @param user The user /// @param timestamp The timestamp from which the delta takes effect /// @param amtPerSecDelta Change of the per-second receiving rate function _setDelta( address user, uint64 timestamp, int128 amtPerSecDelta ) internal { if (amtPerSecDelta == 0) return; mapping(uint64 => AmtDelta) storage amtDeltas = _storage().receiverStates[user].amtDeltas; // In order to set a delta on a specific timestamp it must be introduced in two cycles. // The cycle delta is split proportionally based on how much this cycle is affected. // The next cycle has the rest of the delta applied, so the update is fully completed. uint64 thisCycle = timestamp / cycleSecs + 1; uint64 nextCycleSecs = timestamp % cycleSecs; uint64 thisCycleSecs = cycleSecs - nextCycleSecs; amtDeltas[thisCycle].thisCycle += int128(uint128(thisCycleSecs)) * amtPerSecDelta; amtDeltas[thisCycle].nextCycle += int128(uint128(nextCycleSecs)) * amtPerSecDelta; } function _userOrAccount(address user) internal pure returns (UserOrAccount memory) { return UserOrAccount({isAccount: false, user: user, account: 0}); } function _userOrAccount(address user, uint256 account) internal pure returns (UserOrAccount memory) { return UserOrAccount({isAccount: true, user: user, account: account}); } function _currTimestamp() internal view returns (uint64) { return uint64(block.timestamp); } } ////// lib/radicle-drips-hub/src/ManagedDripsHub.sol /* pragma solidity ^0.8.7; */ /* import {UUPSUpgradeable} from "openzeppelin-contracts/proxy/utils/UUPSUpgradeable.sol"; */ /* import {ERC1967Proxy} from "openzeppelin-contracts/proxy/ERC1967/ERC1967Proxy.sol"; */ /* import {ERC1967Upgrade} from "openzeppelin-contracts/proxy/ERC1967/ERC1967Upgrade.sol"; */ /* import {StorageSlot} from "openzeppelin-contracts/utils/StorageSlot.sol"; */ /* import {DripsHub, SplitsReceiver} from "./DripsHub.sol"; */ /// @notice The DripsHub which is UUPS-upgradable, pausable and has an admin. /// It can't be used directly, only via a proxy. /// /// ManagedDripsHub uses the ERC-1967 admin slot to store the admin address. /// All instances of the contracts are owned by address `0x00`. /// While this contract is capable of updating the admin, /// the proxy is expected to set up the initial value of the ERC-1967 admin. /// /// All instances of the contracts are paused and can't be unpaused. /// When a proxy uses such contract via delegation, it's initially unpaused. abstract contract ManagedDripsHub is DripsHub, UUPSUpgradeable { /// @notice The ERC-1967 storage slot for the contract. /// It holds a single boolean indicating if the contract is paused. bytes32 private constant SLOT_PAUSED = bytes32(uint256(keccak256("eip1967.managedDripsHub.paused")) - 1); /// @notice Emitted when the pause is triggered. /// @param account The account which triggered the change. event Paused(address account); /// @notice Emitted when the pause is lifted. /// @param account The account which triggered the change. event Unpaused(address account); /// @notice Initializes the contract in paused state and with no admin. /// The contract instance can be used only as a call delegation target for a proxy. /// @param cycleSecs The length of cycleSecs to be used in the contract instance. /// Low value makes funds more available by shortening the average time of funds being frozen /// between being taken from the users' drips balances and being collectable by their receivers. /// High value makes collecting cheaper by making it process less cycles for a given time range. constructor(uint64 cycleSecs) DripsHub(cycleSecs) { _pausedSlot().value = true; } /// @notice Collects all received funds available for the user /// and transfers them out of the drips hub contract to that user's wallet. /// @param user The user /// @param currReceivers The list of the user's current splits receivers. /// @return collected The collected amount /// @return split The amount split to the user's splits receivers function collect(address user, SplitsReceiver[] memory currReceivers) public override whenNotPaused returns (uint128 collected, uint128 split) { return super.collect(user, currReceivers); } /// @notice Flushes uncollected cycles of the user. /// Flushed cycles won't need to be analyzed when the user collects from them. /// Calling this function does not collect and does not affect the collectable amount. /// /// This function is needed when collecting funds received over a period so long, that the gas /// needed for analyzing all the uncollected cycles can't fit in a single transaction. /// Calling this function allows spreading the analysis cost over multiple transactions. /// A cycle is never flushed more than once, even if this function is called many times. /// @param user The user /// @param maxCycles The maximum number of flushed cycles. /// If too low, flushing will be cheap, but will cut little gas from the next collection. /// If too high, flushing may become too expensive to fit in a single transaction. /// @return flushable The number of cycles which can be flushed function flushCycles(address user, uint64 maxCycles) public override whenNotPaused returns (uint64 flushable) { return super.flushCycles(user, maxCycles); } /// @notice Authorizes the contract upgrade. See `UUPSUpgradable` docs for more details. function _authorizeUpgrade(address newImplementation) internal view override onlyAdmin { newImplementation; } /// @notice Returns the address of the current admin. function admin() public view returns (address) { return _getAdmin(); } /// @notice Changes the admin of the contract. /// Can only be called by the current admin. function changeAdmin(address newAdmin) public onlyAdmin { _changeAdmin(newAdmin); } /// @notice Throws if called by any account other than the admin. modifier onlyAdmin() { require(admin() == msg.sender, "Caller is not the admin"); _; } /// @notice Returns true if the contract is paused, and false otherwise. function paused() public view returns (bool isPaused) { return _pausedSlot().value; } /// @notice Triggers stopped state. function pause() public whenNotPaused onlyAdmin { _pausedSlot().value = true; emit Paused(msg.sender); } /// @notice Returns to normal state. function unpause() public whenPaused onlyAdmin { _pausedSlot().value = false; emit Unpaused(msg.sender); } /// @notice Modifier to make a function callable only when the contract is not paused. modifier whenNotPaused() { require(!paused(), "Contract paused"); _; } /// @notice Modifier to make a function callable only when the contract is paused. modifier whenPaused() { require(paused(), "Contract not paused"); _; } /// @notice Gets the storage slot holding the paused flag. function _pausedSlot() private pure returns (StorageSlot.BooleanSlot storage) { return StorageSlot.getBooleanSlot(SLOT_PAUSED); } } /// @notice A generic ManagedDripsHub proxy. contract ManagedDripsHubProxy is ERC1967Proxy { constructor(ManagedDripsHub hubLogic, address admin) ERC1967Proxy(address(hubLogic), new bytes(0)) { _changeAdmin(admin); } }
Contract Security Audit
- No Contract Security Audit Submitted- Submit Audit Here
[{"inputs":[{"internalType":"contract ManagedDripsHub","name":"hubLogic","type":"address"},{"internalType":"address","name":"admin","type":"address"}],"stateMutability":"nonpayable","type":"constructor"},{"anonymous":false,"inputs":[{"indexed":false,"internalType":"address","name":"previousAdmin","type":"address"},{"indexed":false,"internalType":"address","name":"newAdmin","type":"address"}],"name":"AdminChanged","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"internalType":"address","name":"beacon","type":"address"}],"name":"BeaconUpgraded","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"internalType":"address","name":"implementation","type":"address"}],"name":"Upgraded","type":"event"},{"stateMutability":"payable","type":"fallback"},{"stateMutability":"payable","type":"receive"}]
Contract Creation Code
608060405234801561001057600080fd5b506040516108db3803806108db83398101604081905261002f91610435565b604080516000815260208101909152829061006b60017f360894a13ba1a3210667c828492db98dca3e2076cc3735a920a3ca505d382bbd6104be565b600080516020610894833981519152146100875761008761050f565b610093828260006100a6565b5061009f9050816100dc565b505061053a565b6100af83610133565b6000825111806100bc5750805b156100d7576100d5838361017360201b6100291760201c565b505b505050565b7f7e644d79422f17c01e4894b5f4f588d331ebfa28653d42ae832dc59e38c9798f61010561019f565b604080516001600160a01b03928316815291841660208301520160405180910390a1610130816101d4565b50565b61013c81610284565b6040516001600160a01b038216907fbc7cd75a20ee27fd9adebab32041f755214dbc6bffa90cc0225b39da2e5c2d3b90600090a250565b606061019883836040518060600160405280602781526020016108b46027913961031e565b9392505050565b60006101c560008051602061087483398151915260001b6103f360201b6100551760201c565b546001600160a01b0316919050565b6001600160a01b03811661023e5760405162461bcd60e51b815260206004820152602660248201527f455243313936373a206e65772061646d696e20697320746865207a65726f206160448201526564647265737360d01b60648201526084015b60405180910390fd5b8061026360008051602061087483398151915260001b6103f360201b6100551760201c565b80546001600160a01b0319166001600160a01b039290921691909117905550565b610297816103f660201b6100581760201c565b6102f95760405162461bcd60e51b815260206004820152602d60248201527f455243313936373a206e657720696d706c656d656e746174696f6e206973206e60448201526c1bdd08184818dbdb9d1c9858dd609a1b6064820152608401610235565b8061026360008051602061089483398151915260001b6103f360201b6100551760201c565b6060833b61037d5760405162461bcd60e51b815260206004820152602660248201527f416464726573733a2064656c65676174652063616c6c20746f206e6f6e2d636f6044820152651b9d1c9858dd60d21b6064820152608401610235565b600080856001600160a01b031685604051610398919061046f565b600060405180830381855af49150503d80600081146103d3576040519150601f19603f3d011682016040523d82523d6000602084013e6103d8565b606091505b5090925090506103e98282866103fc565b9695505050505050565b90565b3b151590565b6060831561040b575081610198565b82511561041b5782518084602001fd5b8160405162461bcd60e51b8152600401610235919061048b565b6000806040838503121561044857600080fd5b825161045381610525565b602084015190925061046481610525565b809150509250929050565b600082516104818184602087016104e3565b9190910192915050565b60208152600082518060208401526104aa8160408501602087016104e3565b601f01601f19169190910160400192915050565b6000828210156104de57634e487b7160e01b600052601160045260246000fd5b500390565b60005b838110156104fe5781810151838201526020016104e6565b838111156100d55750506000910152565b634e487b7160e01b600052600160045260246000fd5b6001600160a01b038116811461013057600080fd5b61032b806105496000396000f3fe60806040523661001357610011610017565b005b6100115b61002761002261005e565b6100a3565b565b606061004e83836040518060600160405280602781526020016102cf602791396100c7565b9392505050565b90565b3b151590565b600061009e7f360894a13ba1a3210667c828492db98dca3e2076cc3735a920a3ca505d382bbc5473ffffffffffffffffffffffffffffffffffffffff1690565b905090565b3660008037600080366000845af43d6000803e8080156100c2573d6000f35b3d6000fd5b6060833b61015c576040517f08c379a000000000000000000000000000000000000000000000000000000000815260206004820152602660248201527f416464726573733a2064656c65676174652063616c6c20746f206e6f6e2d636f60448201527f6e7472616374000000000000000000000000000000000000000000000000000060648201526084015b60405180910390fd5b6000808573ffffffffffffffffffffffffffffffffffffffff16856040516101849190610231565b600060405180830381855af49150503d80600081146101bf576040519150601f19603f3d011682016040523d82523d6000602084013e6101c4565b606091505b50915091506101d48282866101de565b9695505050505050565b606083156101ed57508161004e565b8251156101fd5782518084602001fd5b816040517f08c379a0000000000000000000000000000000000000000000000000000000008152600401610153919061024d565b6000825161024381846020870161029e565b9190910192915050565b602081526000825180602084015261026c81604085016020870161029e565b601f017fffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffe0169190910160400192915050565b60005b838110156102b95781810151838201526020016102a1565b838111156102c8576000848401525b5050505056fe416464726573733a206c6f772d6c6576656c2064656c65676174652063616c6c206661696c6564a2646970667358221220d6f4509629e930a298561f0d47a1a66892c38232c1663a51b390bc96f12f78cd64736f6c63430008070033b53127684a568b3173ae13b9f8a6016e243e63b6e8ee1178d6a717850b5d6103360894a13ba1a3210667c828492db98dca3e2076cc3735a920a3ca505d382bbc416464726573733a206c6f772d6c6576656c2064656c65676174652063616c6c206661696c65640000000000000000000000008d321e80487356c846f34456d31ce761776ef697000000000000000000000000abadefe1ce7bb6f1d5146f3f476701f791b18c6c
Deployed Bytecode
0x60806040523661001357610011610017565b005b6100115b61002761002261005e565b6100a3565b565b606061004e83836040518060600160405280602781526020016102cf602791396100c7565b9392505050565b90565b3b151590565b600061009e7f360894a13ba1a3210667c828492db98dca3e2076cc3735a920a3ca505d382bbc5473ffffffffffffffffffffffffffffffffffffffff1690565b905090565b3660008037600080366000845af43d6000803e8080156100c2573d6000f35b3d6000fd5b6060833b61015c576040517f08c379a000000000000000000000000000000000000000000000000000000000815260206004820152602660248201527f416464726573733a2064656c65676174652063616c6c20746f206e6f6e2d636f60448201527f6e7472616374000000000000000000000000000000000000000000000000000060648201526084015b60405180910390fd5b6000808573ffffffffffffffffffffffffffffffffffffffff16856040516101849190610231565b600060405180830381855af49150503d80600081146101bf576040519150601f19603f3d011682016040523d82523d6000602084013e6101c4565b606091505b50915091506101d48282866101de565b9695505050505050565b606083156101ed57508161004e565b8251156101fd5782518084602001fd5b816040517f08c379a0000000000000000000000000000000000000000000000000000000008152600401610153919061024d565b6000825161024381846020870161029e565b9190910192915050565b602081526000825180602084015261026c81604085016020870161029e565b601f017fffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffe0169190910160400192915050565b60005b838110156102b95781810151838201526020016102a1565b838111156102c8576000848401525b5050505056fe416464726573733a206c6f772d6c6576656c2064656c65676174652063616c6c206661696c6564a2646970667358221220d6f4509629e930a298561f0d47a1a66892c38232c1663a51b390bc96f12f78cd64736f6c63430008070033
Constructor Arguments (ABI-Encoded and is the last bytes of the Contract Creation Code above)
0000000000000000000000008d321e80487356c846f34456d31ce761776ef697000000000000000000000000abadefe1ce7bb6f1d5146f3f476701f791b18c6c
-----Decoded View---------------
Arg [0] : hubLogic (address): 0x8d321e80487356c846F34456d31cE761776eF697
Arg [1] : admin (address): 0xAbadeFE1CE7bB6f1D5146f3f476701F791b18c6C
-----Encoded View---------------
2 Constructor Arguments found :
Arg [0] : 0000000000000000000000008d321e80487356c846f34456d31ce761776ef697
Arg [1] : 000000000000000000000000abadefe1ce7bb6f1d5146f3f476701f791b18c6c
Loading...
Loading
Loading...
Loading
Multichain Portfolio | 27 Chains
Chain | Token | Portfolio % | Price | Amount | Value |
---|
Loading...
Loading
[ Download: CSV Export ]
A contract address hosts a smart contract, which is a set of code stored on the blockchain that runs when predetermined conditions are met. Learn more about addresses in our Knowledge Base.