Blockchain / Global / Address
Contract
0x267cb4b4E941Cba853B4Bc8BFCEffD6F5d0C0ae1
- Balance
- 0 SOMI
- Transactions sent
- 1
- Type
- Contract · 7,423 bytes of code
ProphecyOracleAdapter Verified
- Compiler
- solc 0.8.28+commit.7893614a
- Language
- Solidity
- Optimization
- Yes, 200 runs
- EVM version
- cancun
- License
- —
- Verified
- 2026-10-12
src/adapters/ProphecyOracleAdapter.sol
and 19 more files
Solidity
// SPDX-License-Identifier: MIT
pragma solidity ^0.8.20;
import {ERC165Upgradeable} from "@openzeppelin/contracts-upgradeable/utils/introspection/ERC165Upgradeable.sol";
import {IERC165} from "@openzeppelin/contracts/utils/introspection/IERC165.sol";
import {UUPSUpgradeable} from "@openzeppelin/contracts-upgradeable/proxy/utils/UUPSUpgradeable.sol";
import {Ownable2StepUpgradeable} from "@openzeppelin/contracts-upgradeable/access/Ownable2StepUpgradeable.sol";
import {IOracleAdapter} from "../interfaces/IOracleAdapter.sol";
import {IOracleAnswerReceiver} from "../interfaces/IOracleAnswerReceiver.sol";
import {IProphecyOracle} from "../interfaces/IProphecyOracle.sol";
import {ISomniaReactivityPrecompile, ISomniaEventHandler} from "../interfaces/ISomniaReactivityPrecompile.sol";
import {Answer, QuestionDefinition} from "../types/OracleTypes.sol";
/// @title ProphecyOracleAdapter
/// @notice Wraps ProphecyOracle + Somnia reactivity into the IOracleAdapter interface.
/// Owns the reactivity subscription and calls router.onOracleAnswer when
/// AnswerPosted fires. The native-token bond required by the reactivity
/// precompile is held by this contract, not the router.
/// UUPS-upgradeable so gas params and logic can be updated without losing
/// the subscription ID or the on-chain address.
contract ProphecyOracleAdapter is ERC165Upgradeable, ISomniaEventHandler, IOracleAdapter, UUPSUpgradeable, Ownable2StepUpgradeable {
error NotReactivity();
error WrongEmitter();
error WrongEvent();
error WithdrawFailed();
error AlreadySubscribed();
error NotSubscribed();
error NoPrecompile();
error InvalidReceiver();
// Immutables — baked into implementation bytecode; accessible via delegatecall.
IProphecyOracle public immutable ORACLE;
address public immutable ORACLE_CORE;
ISomniaReactivityPrecompile public immutable REACTIVITY;
IOracleAnswerReceiver public immutable ROUTER;
// Mutable gas params — can be updated via setGasParams() without redeploying.
uint64 public priorityFeePerGas;
uint64 public maxFeePerGas;
uint64 public gasLimit;
uint256 public subscriptionId;
uint256[48] private __gap;
bytes32 public constant ANSWER_POSTED_TOPIC =
keccak256("AnswerPosted(uint256,uint8,string,int256,bool,uint256[])");
event Deposited(address indexed from, uint256 amount);
event Withdrawn(address indexed to, uint256 amount);
event GasParamsUpdated(uint64 priorityFeePerGas, uint64 maxFeePerGas, uint64 gasLimit);
event Subscribed(uint256 indexed subscriptionId);
event Unsubscribed(uint256 indexed subscriptionId);
/// @dev Set immutables and disable initializers on the implementation.
/// The receiver is validated here so misconfigured implementations
/// are caught at deployment rather than at resolution time.
constructor(
IProphecyOracle oracle_,
address oracleCore_,
ISomniaReactivityPrecompile reactivity_,
IOracleAnswerReceiver router_
) {
_disableInitializers();
try router_.supportsInterface(type(IOracleAnswerReceiver).interfaceId) returns (bool ok) {
if (!ok) revert InvalidReceiver();
} catch {
revert InvalidReceiver();
}
ORACLE = oracle_;
ORACLE_CORE = oracleCore_;
REACTIVITY = reactivity_;
ROUTER = router_;
}
/// @notice Initialize proxy storage. Called once via the ERC1967 proxy constructor.
/// @param admin_ Address granted owner and upgrade authority.
/// @param priorityFeePerGas_ Miner tip (wei) passed to the reactivity precompile for callbacks.
/// @param maxFeePerGas_ EIP-1559 fee cap (wei) for reactivity callbacks.
/// @param gasLimit_ Gas budget allocated to each reactivity callback invocation.
function initialize(
address admin_,
uint64 priorityFeePerGas_,
uint64 maxFeePerGas_,
uint64 gasLimit_
) external initializer {
__ERC165_init();
__Ownable_init(admin_);
__UUPSUpgradeable_init();
priorityFeePerGas = priorityFeePerGas_;
maxFeePerGas = maxFeePerGas_;
gasLimit = gasLimit_;
}
function _authorizeUpgrade(address) internal override onlyOwner {}
receive() external payable {
emit Deposited(msg.sender, msg.value);
}
/// @notice Update reactivity gas parameters. Takes effect on the next
/// `enableReactivity()` call; existing subscriptions are unaffected.
function setGasParams(uint64 priorityFeePerGas_, uint64 maxFeePerGas_, uint64 gasLimit_) external onlyOwner {
priorityFeePerGas = priorityFeePerGas_;
maxFeePerGas = maxFeePerGas_;
gasLimit = gasLimit_;
emit GasParamsUpdated(priorityFeePerGas_, maxFeePerGas_, gasLimit_);
}
/// @notice Register the Somnia reactivity subscription. Admin-gated, one-shot:
/// reverts if a subscription id is already stored. Use `resubscribe()`
/// to replace an existing — or precompile-cancelled — subscription.
function enableReactivity() external onlyOwner returns (uint256) {
if (subscriptionId != 0) revert AlreadySubscribed();
if (address(REACTIVITY) == address(0)) revert NoPrecompile();
uint256 id = _subscribe();
subscriptionId = id;
emit Subscribed(id);
return id;
}
/// @notice Replace the reactivity subscription with a fresh one to recover
/// auto-resolution after the precompile cancelled the subscription
/// for bond depletion (running out of native token).
/// @dev Admin-gated and idempotent — safe to call whether the stored
/// subscription is still live or already cancelled:
/// 1. Refill the native bond first (send SOMI to this contract).
/// 2. The stored subscription is unsubscribed on a best-effort basis.
/// A subscription the precompile already dropped reverts on
/// `unsubscribe`; that revert is swallowed so recovery proceeds.
/// 3. A fresh subscription is created with the current gas params —
/// call `setGasParams` first if they need correcting.
/// Emits `Unsubscribed` (only if an old sub was cleared) then `Subscribed`.
function resubscribe() external onlyOwner returns (uint256) {
if (address(REACTIVITY) == address(0)) revert NoPrecompile();
uint256 old = subscriptionId;
if (old != 0) {
subscriptionId = 0;
try REACTIVITY.unsubscribe(old) {
emit Unsubscribed(old);
} catch {
// Subscription already cancelled by the precompile (bond
// depleted) — nothing to unsubscribe; create a fresh one below.
}
}
uint256 id = _subscribe();
subscriptionId = id;
emit Subscribed(id);
return id;
}
/// @notice Cancel the reactivity subscription and clear the stored id, without
/// creating a new one. Stops AnswerPosted callbacks (auto-resolution)
/// until reactivity is re-enabled.
/// @dev Admin-gated. Best-effort like `resubscribe` — swallows the revert if
/// the precompile has already dropped the subscription. Because the id is
/// reset to 0, the one-shot `enableReactivity()` becomes callable again,
/// so the clean lifecycle is `disableReactivity` → (`setGasParams`) →
/// `enableReactivity`. Reclaiming native is a separate `withdraw` — the
/// precompile debits the adapter's own balance per callback rather than
/// escrowing a bond, so there is nothing to refund on unsubscribe.
function disableReactivity() external onlyOwner {
if (address(REACTIVITY) == address(0)) revert NoPrecompile();
uint256 old = subscriptionId;
if (old == 0) revert NotSubscribed();
subscriptionId = 0;
try REACTIVITY.unsubscribe(old) {
emit Unsubscribed(old);
} catch {
// Already cancelled by the precompile (bond depleted) — the stored
// id is stale; clearing it above is the only state change needed.
}
}
/// @dev Build the AnswerPosted subscription with the current gas params and
/// register it with the precompile. Shared by `enableReactivity` and
/// `resubscribe`; the caller is responsible for storing the returned id.
function _subscribe() internal returns (uint256) {
ISomniaReactivityPrecompile.SubscriptionData memory sub;
sub.eventTopics[0] = ANSWER_POSTED_TOPIC;
sub.emitter = ORACLE_CORE;
sub.handlerContractAddress = address(this);
sub.handlerFunctionSelector = ISomniaEventHandler.onEvent.selector;
sub.priorityFeePerGas = priorityFeePerGas;
sub.maxFeePerGas = maxFeePerGas;
sub.gasLimit = gasLimit;
sub.isGuaranteed = true;
sub.isCoalesced = false;
return REACTIVITY.subscribe(sub);
}
/// @notice Withdraw native balance (reactivity bond). Pass amount=0 to drain.
/// @param amount Wei to withdraw; pass 0 to withdraw the entire contract balance.
/// @param to Recipient address; must be able to receive native token.
function withdraw(uint256 amount, address payable to) external onlyOwner {
uint256 wd = amount == 0 ? address(this).balance : amount;
(bool ok,) = to.call{value: wd}("");
if (!ok) revert WithdrawFailed();
emit Withdrawn(to, wd);
}
// ---- ISomniaEventHandler ----------------------------------------
/// @notice Called by the Somnia reactivity precompile when an AnswerPosted event fires on ProphecyOracle.
/// @dev Reverts if called by any address other than the reactivity precompile, or if the event
/// emitter or topic does not match the expected oracle contract and signature.
/// @param emitter Contract that emitted the log; must equal ORACLE_CORE.
/// @param eventTopics Indexed log topics; topics[0] is the event selector, topics[1] is the oracle question ID.
/// @param data ABI-encoded non-indexed fields: (outcomeIdx, label, numericValue, voided, auxData).
function onEvent(address emitter, bytes32[] calldata eventTopics, bytes calldata data) external override {
if (msg.sender != address(REACTIVITY)) revert NotReactivity();
if (emitter != ORACLE_CORE) revert WrongEmitter();
if (eventTopics.length < 2 || eventTopics[0] != ANSWER_POSTED_TOPIC) revert WrongEvent();
uint256 oracleQuestionId = uint256(eventTopics[1]);
(uint8 outcomeIdx,,, bool voided,) = abi.decode(data, (uint8, string, int256, bool, uint256[]));
ROUTER.onOracleAnswer(oracleQuestionId, outcomeIdx, voided);
}
// ---- ERC-165 -----------------------------------------------------
/// @notice Returns true for IOracleAdapter and ERC-165 itself; false for everything else.
function supportsInterface(bytes4 interfaceId) public view override(ERC165Upgradeable, IERC165) returns (bool) {
return interfaceId == type(IOracleAdapter).interfaceId || super.supportsInterface(interfaceId);
}
// ---- IOracleAdapter ----------------------------------------------
/// @notice Returns the number of outcome slots for a ProphecyOracle question.
/// @param oracleQuestionId Numeric question ID as stored in ProphecyOracle.
/// @return Number of discrete outcomes; equals the length of the question's outcome-label array.
function getSlotCount(uint256 oracleQuestionId) external view override returns (uint8) {
return uint8(ORACLE.getOutcomeLabels(oracleQuestionId).length);
}
/// @notice Pulls the settled answer directly from ProphecyOracle (pull-fallback path).
/// @param oracleQuestionId Numeric question ID as stored in ProphecyOracle.
/// @return outcomeIdx Zero-based index of the winning outcome.
/// @return voided True if the question was voided rather than resolved normally.
function pullAnswer(uint256 oracleQuestionId) external view override returns (uint8 outcomeIdx, bool voided) {
Answer memory a = ORACLE.getAnswer(oracleQuestionId);
return (a.outcomeIdx, a.voided);
}
/// @notice Submit a new question to ProphecyOracle, forwarding all attached native token as the scheduling fee.
/// @param def Full question definition; see QuestionDefinition for field semantics.
/// @return Oracle-assigned question ID used in all subsequent adapter calls.
function scheduleQuestion(QuestionDefinition calldata def) external payable override returns (uint256) {
return ORACLE.submitQuestion{value: msg.value}(def);
}
/// @notice Returns the native-token fee ProphecyOracle requires to schedule the given question.
/// @param def Question definition to price; the oracle may vary cost based on resolution time or other fields.
/// @return Fee in wei that must be attached when calling scheduleQuestion.
function getSchedulingCost(QuestionDefinition calldata def) external view override returns (uint256) {
return ORACLE.getSubmissionCost(def);
}
}
Other files
lib/openzeppelin-contracts-upgradeable/contracts/access/Ownable2StepUpgradeable.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (access/Ownable2Step.sol) pragma solidity ^0.8.20; import {OwnableUpgradeable} from "./OwnableUpgradeable.sol"; import {Initializable} from "../proxy/utils/Initializable.sol"; /** * @dev Contract module which provides access control mechanism, where * there is an account (an owner) that can be granted exclusive access to * specific functions. * * This extension of the {Ownable} contract includes a two-step mechanism to transfer * ownership, where the new owner must call {acceptOwnership} in order to replace the * old one. This can help prevent common mistakes, such as transfers of ownership to * incorrect accounts, or to contracts that are unable to interact with the * permission system. * * The initial owner is specified at deployment time in the constructor for `Ownable`. This * can later be changed with {transferOwnership} and {acceptOwnership}. * * This module is used through inheritance. It will make available all functions * from parent (Ownable). */ abstract contract Ownable2StepUpgradeable is Initializable, OwnableUpgradeable { /// @custom:storage-location erc7201:openzeppelin.storage.Ownable2Step struct Ownable2StepStorage { address _pendingOwner; } // keccak256(abi.encode(uint256(keccak256("openzeppelin.storage.Ownable2Step")) - 1)) & ~bytes32(uint256(0xff)) bytes32 private constant Ownable2StepStorageLocation = 0x237e158222e3e6968b72b9db0d8043aacf074ad9f650f0d1606b4d82ee432c00; function _getOwnable2StepStorage() private pure returns (Ownable2StepStorage storage $) { assembly { $.slot := Ownable2StepStorageLocation } } event OwnershipTransferStarted(address indexed previousOwner, address indexed newOwner); function __Ownable2Step_init() internal onlyInitializing { } function __Ownable2Step_init_unchained() internal onlyInitializing { } /** * @dev Returns the address of the pending owner. */ function pendingOwner() public view virtual returns (address) { Ownable2StepStorage storage $ = _getOwnable2StepStorage(); return $._pendingOwner; } /** * @dev Starts the ownership transfer of the contract to a new account. Replaces the pending transfer if there is one. * Can only be called by the current owner. * * Setting `newOwner` to the zero address is allowed; this can be used to cancel an initiated ownership transfer. */ function transferOwnership(address newOwner) public virtual override onlyOwner { Ownable2StepStorage storage $ = _getOwnable2StepStorage(); $._pendingOwner = newOwner; emit OwnershipTransferStarted(owner(), newOwner); } /** * @dev Transfers ownership of the contract to a new account (`newOwner`) and deletes any pending owner. * Internal function without access restriction. */ function _transferOwnership(address newOwner) internal virtual override { Ownable2StepStorage storage $ = _getOwnable2StepStorage(); delete $._pendingOwner; super._transferOwnership(newOwner); } /** * @dev The new owner accepts the ownership transfer. */ function acceptOwnership() public virtual { address sender = _msgSender(); if (pendingOwner() != sender) { revert OwnableUnauthorizedAccount(sender); } _transferOwnership(sender); } }lib/openzeppelin-contracts-upgradeable/contracts/access/OwnableUpgradeable.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.0.0) (access/Ownable.sol) pragma solidity ^0.8.20; import {ContextUpgradeable} from "../utils/ContextUpgradeable.sol"; import {Initializable} from "../proxy/utils/Initializable.sol"; /** * @dev Contract module which provides a basic access control mechanism, where * there is an account (an owner) that can be granted exclusive access to * specific functions. * * The initial owner is set to the address provided by the deployer. This can * later be changed with {transferOwnership}. * * This module is used through inheritance. It will make available the modifier * `onlyOwner`, which can be applied to your functions to restrict their use to * the owner. */ abstract contract OwnableUpgradeable is Initializable, ContextUpgradeable { /// @custom:storage-location erc7201:openzeppelin.storage.Ownable struct OwnableStorage { address _owner; } // keccak256(abi.encode(uint256(keccak256("openzeppelin.storage.Ownable")) - 1)) & ~bytes32(uint256(0xff)) bytes32 private constant OwnableStorageLocation = 0x9016d09d72d40fdae2fd8ceac6b6234c7706214fd39c1cd1e609a0528c199300; function _getOwnableStorage() private pure returns (OwnableStorage storage $) { assembly { $.slot := OwnableStorageLocation } } /** * @dev The caller account is not authorized to perform an operation. */ error OwnableUnauthorizedAccount(address account); /** * @dev The owner is not a valid owner account. (eg. `address(0)`) */ error OwnableInvalidOwner(address owner); event OwnershipTransferred(address indexed previousOwner, address indexed newOwner); /** * @dev Initializes the contract setting the address provided by the deployer as the initial owner. */ function __Ownable_init(address initialOwner) internal onlyInitializing { __Ownable_init_unchained(initialOwner); } function __Ownable_init_unchained(address initialOwner) internal onlyInitializing { if (initialOwner == address(0)) { revert OwnableInvalidOwner(address(0)); } _transferOwnership(initialOwner); } /** * @dev Throws if called by any account other than the owner. */ modifier onlyOwner() { _checkOwner(); _; } /** * @dev Returns the address of the current owner. */ function owner() public view virtual returns (address) { OwnableStorage storage $ = _getOwnableStorage(); return $._owner; } /** * @dev Throws if the sender is not the owner. */ function _checkOwner() internal view virtual { if (owner() != _msgSender()) { revert OwnableUnauthorizedAccount(_msgSender()); } } /** * @dev Leaves the contract without owner. It will not be possible to call * `onlyOwner` functions. Can only be called by the current owner. * * NOTE: Renouncing ownership will leave the contract without an owner, * thereby disabling any functionality that is only available to the owner. */ function renounceOwnership() public virtual onlyOwner { _transferOwnership(address(0)); } /** * @dev Transfers ownership of the contract to a new account (`newOwner`). * Can only be called by the current owner. */ function transferOwnership(address newOwner) public virtual onlyOwner { if (newOwner == address(0)) { revert OwnableInvalidOwner(address(0)); } _transferOwnership(newOwner); } /** * @dev Transfers ownership of the contract to a new account (`newOwner`). * Internal function without access restriction. */ function _transferOwnership(address newOwner) internal virtual { OwnableStorage storage $ = _getOwnableStorage(); address oldOwner = $._owner; $._owner = newOwner; emit OwnershipTransferred(oldOwner, newOwner); } }lib/openzeppelin-contracts-upgradeable/contracts/proxy/utils/Initializable.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.0.0) (proxy/utils/Initializable.sol) pragma solidity ^0.8.20; /** * @dev This is a base contract to aid in writing upgradeable contracts, or any kind of contract that will be deployed * behind a proxy. Since proxied contracts do not make use of a constructor, it's common to move constructor logic to an * external initializer function, usually called `initialize`. It then becomes necessary to protect this initializer * function so it can only be called once. The {initializer} modifier provided by this contract will have this effect. * * The initialization functions use a version number. Once a version number is used, it is consumed and cannot be * reused. This mechanism prevents re-execution of each "step" but allows the creation of new initialization steps in * case an upgrade adds a module that needs to be initialized. * * For example: * * [.hljs-theme-light.nopadding] * ```solidity * contract MyToken is ERC20Upgradeable { * function initialize() initializer public { * __ERC20_init("MyToken", "MTK"); * } * } * * contract MyTokenV2 is MyToken, ERC20PermitUpgradeable { * function initializeV2() reinitializer(2) public { * __ERC20Permit_init("MyToken"); * } * } * ``` * * TIP: To avoid leaving the proxy in an uninitialized state, the initializer function should be called as early as * possible by providing the encoded function call as the `_data` argument to {ERC1967Proxy-constructor}. * * CAUTION: When used with inheritance, manual care must be taken to not invoke a parent initializer twice, or to ensure * that all initializers are idempotent. This is not verified automatically as constructors are by Solidity. * * [CAUTION] * ==== * Avoid leaving a contract uninitialized. * * An uninitialized contract can be taken over by an attacker. This applies to both a proxy and its implementation * contract, which may impact the proxy. To prevent the implementation contract from being used, you should invoke * the {_disableInitializers} function in the constructor to automatically lock it when it is deployed: * * [.hljs-theme-light.nopadding] * ``` * /// @custom:oz-upgrades-unsafe-allow constructor * constructor() { * _disableInitializers(); * } * ``` * ==== */ abstract contract Initializable { /** * @dev Storage of the initializable contract. * * It's implemented on a custom ERC-7201 namespace to reduce the risk of storage collisions * when using with upgradeable contracts. * * @custom:storage-location erc7201:openzeppelin.storage.Initializable */ struct InitializableStorage { /** * @dev Indicates that the contract has been initialized. */ uint64 _initialized; /** * @dev Indicates that the contract is in the process of being initialized. */ bool _initializing; } // keccak256(abi.encode(uint256(keccak256("openzeppelin.storage.Initializable")) - 1)) & ~bytes32(uint256(0xff)) bytes32 private constant INITIALIZABLE_STORAGE = 0xf0c57e16840df040f15088dc2f81fe391c3923bec73e23a9662efc9c229c6a00; /** * @dev The contract is already initialized. */ error InvalidInitialization(); /** * @dev The contract is not initializing. */ error NotInitializing(); /** * @dev Triggered when the contract has been initialized or reinitialized. */ event Initialized(uint64 version); /** * @dev A modifier that defines a protected initializer function that can be invoked at most once. In its scope, * `onlyInitializing` functions can be used to initialize parent contracts. * * Similar to `reinitializer(1)`, except that in the context of a constructor an `initializer` may be invoked any * number of times. This behavior in the constructor can be useful during testing and is not expected to be used in * production. * * Emits an {Initialized} event. */ modifier initializer() { // solhint-disable-next-line var-name-mixedcase InitializableStorage storage $ = _getInitializableStorage(); // Cache values to avoid duplicated sloads bool isTopLevelCall = !$._initializing; uint64 initialized = $._initialized; // Allowed calls: // - initialSetup: the contract is not in the initializing state and no previous version was // initialized // - construction: the contract is initialized at version 1 (no reininitialization) and the // current contract is just being deployed bool initialSetup = initialized == 0 && isTopLevelCall; bool construction = initialized == 1 && address(this).code.length == 0; if (!initialSetup && !construction) { revert InvalidInitialization(); } $._initialized = 1; if (isTopLevelCall) { $._initializing = true; } _; if (isTopLevelCall) { $._initializing = false; emit Initialized(1); } } /** * @dev A modifier that defines a protected reinitializer function that can be invoked at most once, and only if the * contract hasn't been initialized to a greater version before. In its scope, `onlyInitializing` functions can be * used to initialize parent contracts. * * A reinitializer may be used after the original initialization step. This is essential to configure modules that * are added through upgrades and that require initialization. * * When `version` is 1, this modifier is similar to `initializer`, except that functions marked with `reinitializer` * cannot be nested. If one is invoked in the context of another, execution will revert. * * Note that versions can jump in increments greater than 1; this implies that if multiple reinitializers coexist in * a contract, executing them in the right order is up to the developer or operator. * * WARNING: Setting the version to 2**64 - 1 will prevent any future reinitialization. * * Emits an {Initialized} event. */ modifier reinitializer(uint64 version) { // solhint-disable-next-line var-name-mixedcase InitializableStorage storage $ = _getInitializableStorage(); if ($._initializing || $._initialized >= version) { revert InvalidInitialization(); } $._initialized = version; $._initializing = true; _; $._initializing = false; emit Initialized(version); } /** * @dev Modifier to protect an initialization function so that it can only be invoked by functions with the * {initializer} and {reinitializer} modifiers, directly or indirectly. */ modifier onlyInitializing() { _checkInitializing(); _; } /** * @dev Reverts if the contract is not in an initializing state. See {onlyInitializing}. */ function _checkInitializing() internal view virtual { if (!_isInitializing()) { revert NotInitializing(); } } /** * @dev Locks the contract, preventing any future reinitialization. This cannot be part of an initializer call. * Calling this in the constructor of a contract will prevent that contract from being initialized or reinitialized * to any version. It is recommended to use this to lock implementation contracts that are designed to be called * through proxies. * * Emits an {Initialized} event the first time it is successfully executed. */ function _disableInitializers() internal virtual { // solhint-disable-next-line var-name-mixedcase InitializableStorage storage $ = _getInitializableStorage(); if ($._initializing) { revert InvalidInitialization(); } if ($._initialized != type(uint64).max) { $._initialized = type(uint64).max; emit Initialized(type(uint64).max); } } /** * @dev Returns the highest version that has been initialized. See {reinitializer}. */ function _getInitializedVersion() internal view returns (uint64) { return _getInitializableStorage()._initialized; } /** * @dev Returns `true` if the contract is currently initializing. See {onlyInitializing}. */ function _isInitializing() internal view returns (bool) { return _getInitializableStorage()._initializing; } /** * @dev Returns a pointer to the storage namespace. */ // solhint-disable-next-line var-name-mixedcase function _getInitializableStorage() private pure returns (InitializableStorage storage $) { assembly { $.slot := INITIALIZABLE_STORAGE } } }lib/openzeppelin-contracts-upgradeable/contracts/proxy/utils/UUPSUpgradeable.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (proxy/utils/UUPSUpgradeable.sol) pragma solidity ^0.8.20; import {IERC1822Proxiable} from "@openzeppelin/contracts/interfaces/draft-IERC1822.sol"; import {ERC1967Utils} from "@openzeppelin/contracts/proxy/ERC1967/ERC1967Utils.sol"; import {Initializable} from "./Initializable.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. */ abstract contract UUPSUpgradeable is Initializable, IERC1822Proxiable { /// @custom:oz-upgrades-unsafe-allow state-variable-immutable address private immutable __self = address(this); /** * @dev The version of the upgrade interface of the contract. If this getter is missing, both `upgradeTo(address)` * and `upgradeToAndCall(address,bytes)` are present, and `upgradeTo` must be used if no function should be called, * while `upgradeToAndCall` will invoke the `receive` function if the second argument is the empty byte string. * If the getter returns `"5.0.0"`, only `upgradeToAndCall(address,bytes)` is present, and the second argument must * be the empty byte string if no function should be called, making it impossible to invoke the `receive` function * during an upgrade. */ string public constant UPGRADE_INTERFACE_VERSION = "5.0.0"; /** * @dev The call is from an unauthorized context. */ error UUPSUnauthorizedCallContext(); /** * @dev The storage `slot` is unsupported as a UUID. */ error UUPSUnsupportedProxiableUUID(bytes32 slot); /** * @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 ERC-1967) 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 ERC-1167 minimal proxies (clones) would not normally pass this test, but is not guaranteed to * fail. */ modifier onlyProxy() { _checkProxy(); _; } /** * @dev Check that the execution is not being performed through a delegate call. This allows a function to be * callable on the implementing contract but not through proxies. */ modifier notDelegated() { _checkNotDelegated(); _; } function __UUPSUpgradeable_init() internal onlyInitializing { } function __UUPSUpgradeable_init_unchained() internal onlyInitializing { } /** * @dev Implementation of the ERC-1822 {proxiableUUID} function. This returns the storage slot used by the * implementation. It is used to validate the implementation's compatibility when performing an upgrade. * * IMPORTANT: A proxy pointing at a proxiable contract should not be considered proxiable itself, because this risks * bricking a proxy that upgrades to it, by delegating to itself until out of gas. Thus it is critical that this * function revert if invoked through a proxy. This is guaranteed by the `notDelegated` modifier. */ function proxiableUUID() external view virtual notDelegated returns (bytes32) { return ERC1967Utils.IMPLEMENTATION_SLOT; } /** * @dev Upgrade the implementation of the proxy to `newImplementation`, and subsequently execute the function call * encoded in `data`. * * Calls {_authorizeUpgrade}. * * Emits an {Upgraded} event. * * @custom:oz-upgrades-unsafe-allow-reachable delegatecall */ function upgradeToAndCall(address newImplementation, bytes memory data) public payable virtual onlyProxy { _authorizeUpgrade(newImplementation); _upgradeToAndCallUUPS(newImplementation, data); } /** * @dev Reverts if the execution is not performed via delegatecall or the execution * context is not of a proxy with an ERC-1967 compliant implementation pointing to self. * See {_onlyProxy}. */ function _checkProxy() internal view virtual { if ( address(this) == __self || // Must be called through delegatecall ERC1967Utils.getImplementation() != __self // Must be called through an active proxy ) { revert UUPSUnauthorizedCallContext(); } } /** * @dev Reverts if the execution is performed via delegatecall. * See {notDelegated}. */ function _checkNotDelegated() internal view virtual { if (address(this) != __self) { // Must not be called through delegatecall revert UUPSUnauthorizedCallContext(); } } /** * @dev Function that should revert when `msg.sender` is not authorized to upgrade the contract. Called by * {upgradeToAndCall}. * * Normally, this function will use an xref:access.adoc[access control] modifier such as {Ownable-onlyOwner}. * * ```solidity * function _authorizeUpgrade(address) internal onlyOwner {} * ``` */ function _authorizeUpgrade(address newImplementation) internal virtual; /** * @dev Performs an implementation upgrade with a security check for UUPS proxies, and additional setup call. * * As a security check, {proxiableUUID} is invoked in the new implementation, and the return value * is expected to be the implementation slot in ERC-1967. * * Emits an {IERC1967-Upgraded} event. */ function _upgradeToAndCallUUPS(address newImplementation, bytes memory data) private { try IERC1822Proxiable(newImplementation).proxiableUUID() returns (bytes32 slot) { if (slot != ERC1967Utils.IMPLEMENTATION_SLOT) { revert UUPSUnsupportedProxiableUUID(slot); } ERC1967Utils.upgradeToAndCall(newImplementation, data); } catch { // The implementation is not UUPS revert ERC1967Utils.ERC1967InvalidImplementation(newImplementation); } } }lib/openzeppelin-contracts-upgradeable/contracts/utils/ContextUpgradeable.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.0.1) (utils/Context.sol) pragma solidity ^0.8.20; import {Initializable} from "../proxy/utils/Initializable.sol"; /** * @dev Provides information about the current execution context, including the * sender of the transaction and its data. While these are generally available * via msg.sender and msg.data, they should not be accessed in such a direct * manner, since when dealing with meta-transactions the account sending and * paying for execution may not be the actual sender (as far as an application * is concerned). * * This contract is only required for intermediate, library-like contracts. */ abstract contract ContextUpgradeable is Initializable { function __Context_init() internal onlyInitializing { } function __Context_init_unchained() internal onlyInitializing { } function _msgSender() internal view virtual returns (address) { return msg.sender; } function _msgData() internal view virtual returns (bytes calldata) { return msg.data; } function _contextSuffixLength() internal view virtual returns (uint256) { return 0; } }lib/openzeppelin-contracts-upgradeable/contracts/utils/introspection/ERC165Upgradeable.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (utils/introspection/ERC165.sol) pragma solidity ^0.8.20; import {IERC165} from "@openzeppelin/contracts/utils/introspection/IERC165.sol"; import {Initializable} from "../../proxy/utils/Initializable.sol"; /** * @dev Implementation of the {IERC165} interface. * * Contracts that want to implement ERC-165 should inherit from this contract and override {supportsInterface} to check * for the additional interface id that will be supported. For example: * * ```solidity * function supportsInterface(bytes4 interfaceId) public view virtual override returns (bool) { * return interfaceId == type(MyInterface).interfaceId || super.supportsInterface(interfaceId); * } * ``` */ abstract contract ERC165Upgradeable is Initializable, IERC165 { function __ERC165_init() internal onlyInitializing { } function __ERC165_init_unchained() internal onlyInitializing { } /** * @dev See {IERC165-supportsInterface}. */ function supportsInterface(bytes4 interfaceId) public view virtual returns (bool) { return interfaceId == type(IERC165).interfaceId; } }lib/openzeppelin-contracts/contracts/interfaces/IERC1967.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.0.0) (interfaces/IERC1967.sol) pragma solidity ^0.8.20; /** * @dev ERC-1967: Proxy Storage Slots. This interface contains the events defined in the ERC. */ interface IERC1967 { /** * @dev Emitted when the implementation is upgraded. */ event Upgraded(address indexed implementation); /** * @dev Emitted when the admin account has changed. */ event AdminChanged(address previousAdmin, address newAdmin); /** * @dev Emitted when the beacon is changed. */ event BeaconUpgraded(address indexed beacon); }lib/openzeppelin-contracts/contracts/interfaces/draft-IERC1822.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (interfaces/draft-IERC1822.sol) pragma solidity ^0.8.20; /** * @dev ERC-1822: Universal Upgradeable Proxy Standard (UUPS) documents a method for upgradeability through a simplified * proxy whose upgrades are fully controlled by the current implementation. */ interface IERC1822Proxiable { /** * @dev Returns the storage slot that the proxiable contract assumes is being used to store the implementation * address. * * IMPORTANT: A proxy pointing at a proxiable contract should not be considered proxiable itself, because this risks * bricking a proxy that upgrades to it, by delegating to itself until out of gas. Thus it is critical that this * function revert if invoked through a proxy. */ function proxiableUUID() external view returns (bytes32); }lib/openzeppelin-contracts/contracts/proxy/ERC1967/ERC1967Utils.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (proxy/ERC1967/ERC1967Utils.sol) pragma solidity ^0.8.21; import {IBeacon} from "../beacon/IBeacon.sol"; import {IERC1967} from "../../interfaces/IERC1967.sol"; import {Address} from "../../utils/Address.sol"; import {StorageSlot} from "../../utils/StorageSlot.sol"; /** * @dev This library provides getters and event emitting update functions for * https://eips.ethereum.org/EIPS/eip-1967[ERC-1967] slots. */ library ERC1967Utils { /** * @dev Storage slot with the address of the current implementation. * This is the keccak-256 hash of "eip1967.proxy.implementation" subtracted by 1. */ // solhint-disable-next-line private-vars-leading-underscore bytes32 internal constant IMPLEMENTATION_SLOT = 0x360894a13ba1a3210667c828492db98dca3e2076cc3735a920a3ca505d382bbc; /** * @dev The `implementation` of the proxy is invalid. */ error ERC1967InvalidImplementation(address implementation); /** * @dev The `admin` of the proxy is invalid. */ error ERC1967InvalidAdmin(address admin); /** * @dev The `beacon` of the proxy is invalid. */ error ERC1967InvalidBeacon(address beacon); /** * @dev An upgrade function sees `msg.value > 0` that may be lost. */ error ERC1967NonPayable(); /** * @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 ERC-1967 implementation slot. */ function _setImplementation(address newImplementation) private { if (newImplementation.code.length == 0) { revert ERC1967InvalidImplementation(newImplementation); } StorageSlot.getAddressSlot(IMPLEMENTATION_SLOT).value = newImplementation; } /** * @dev Performs implementation upgrade with additional setup call if data is nonempty. * This function is payable only if the setup call is performed, otherwise `msg.value` is rejected * to avoid stuck value in the contract. * * Emits an {IERC1967-Upgraded} event. */ function upgradeToAndCall(address newImplementation, bytes memory data) internal { _setImplementation(newImplementation); emit IERC1967.Upgraded(newImplementation); if (data.length > 0) { Address.functionDelegateCall(newImplementation, data); } else { _checkNonPayable(); } } /** * @dev Storage slot with the admin of the contract. * This is the keccak-256 hash of "eip1967.proxy.admin" subtracted by 1. */ // solhint-disable-next-line private-vars-leading-underscore bytes32 internal constant ADMIN_SLOT = 0xb53127684a568b3173ae13b9f8a6016e243e63b6e8ee1178d6a717850b5d6103; /** * @dev Returns the current admin. * * TIP: To get this value clients can read directly from the storage slot shown below (specified by ERC-1967) using * the https://eth.wiki/json-rpc/API#eth_getstorageat[`eth_getStorageAt`] RPC call. * `0xb53127684a568b3173ae13b9f8a6016e243e63b6e8ee1178d6a717850b5d6103` */ function getAdmin() internal view returns (address) { return StorageSlot.getAddressSlot(ADMIN_SLOT).value; } /** * @dev Stores a new address in the ERC-1967 admin slot. */ function _setAdmin(address newAdmin) private { if (newAdmin == address(0)) { revert ERC1967InvalidAdmin(address(0)); } StorageSlot.getAddressSlot(ADMIN_SLOT).value = newAdmin; } /** * @dev Changes the admin of the proxy. * * Emits an {IERC1967-AdminChanged} event. */ function changeAdmin(address newAdmin) internal { emit IERC1967.AdminChanged(getAdmin(), newAdmin); _setAdmin(newAdmin); } /** * @dev The storage slot of the UpgradeableBeacon contract which defines the implementation for this proxy. * This is the keccak-256 hash of "eip1967.proxy.beacon" subtracted by 1. */ // solhint-disable-next-line private-vars-leading-underscore bytes32 internal constant BEACON_SLOT = 0xa3f0ad74e5423aebfd80d3ef4346578335a9a72aeaee59ff6cb3582b35133d50; /** * @dev Returns the current beacon. */ function getBeacon() internal view returns (address) { return StorageSlot.getAddressSlot(BEACON_SLOT).value; } /** * @dev Stores a new beacon in the ERC-1967 beacon slot. */ function _setBeacon(address newBeacon) private { if (newBeacon.code.length == 0) { revert ERC1967InvalidBeacon(newBeacon); } StorageSlot.getAddressSlot(BEACON_SLOT).value = newBeacon; address beaconImplementation = IBeacon(newBeacon).implementation(); if (beaconImplementation.code.length == 0) { revert ERC1967InvalidImplementation(beaconImplementation); } } /** * @dev Change the beacon and trigger a setup call if data is nonempty. * This function is payable only if the setup call is performed, otherwise `msg.value` is rejected * to avoid stuck value in the contract. * * Emits an {IERC1967-BeaconUpgraded} event. * * CAUTION: Invoking this function has no effect on an instance of {BeaconProxy} since v5, since * it uses an immutable beacon without looking at the value of the ERC-1967 beacon slot for * efficiency. */ function upgradeBeaconToAndCall(address newBeacon, bytes memory data) internal { _setBeacon(newBeacon); emit IERC1967.BeaconUpgraded(newBeacon); if (data.length > 0) { Address.functionDelegateCall(IBeacon(newBeacon).implementation(), data); } else { _checkNonPayable(); } } /** * @dev Reverts if `msg.value` is not zero. It can be used to avoid `msg.value` stuck in the contract * if an upgrade doesn't perform an initialization call. */ function _checkNonPayable() private { if (msg.value > 0) { revert ERC1967NonPayable(); } } }lib/openzeppelin-contracts/contracts/proxy/beacon/IBeacon.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.0.0) (proxy/beacon/IBeacon.sol) pragma solidity ^0.8.20; /** * @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. * * {UpgradeableBeacon} will check that this address is a contract. */ function implementation() external view returns (address); }lib/openzeppelin-contracts/contracts/utils/Address.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (utils/Address.sol) pragma solidity ^0.8.20; import {Errors} from "./Errors.sol"; /** * @dev Collection of functions related to the address type */ library Address { /** * @dev There's no code at `target` (it is not a contract). */ error AddressEmptyCode(address target); /** * @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://consensys.net/diligence/blog/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.8.20/security-considerations.html#use-the-checks-effects-interactions-pattern[checks-effects-interactions pattern]. */ function sendValue(address payable recipient, uint256 amount) internal { if (address(this).balance < amount) { revert Errors.InsufficientBalance(address(this).balance, amount); } (bool success, ) = recipient.call{value: amount}(""); if (!success) { revert Errors.FailedCall(); } } /** * @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 or custom error, it is bubbled * up by this function (like regular Solidity function calls). However, if * the call reverted with no returned reason, this function reverts with a * {Errors.FailedCall} error. * * 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. */ function functionCall(address target, bytes memory data) internal returns (bytes memory) { return functionCallWithValue(target, data, 0); } /** * @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`. */ function functionCallWithValue(address target, bytes memory data, uint256 value) internal returns (bytes memory) { if (address(this).balance < value) { revert Errors.InsufficientBalance(address(this).balance, value); } (bool success, bytes memory returndata) = target.call{value: value}(data); return verifyCallResultFromTarget(target, success, returndata); } /** * @dev Same as {xref-Address-functionCall-address-bytes-}[`functionCall`], * but performing a static call. */ function functionStaticCall(address target, bytes memory data) internal view returns (bytes memory) { (bool success, bytes memory returndata) = target.staticcall(data); return verifyCallResultFromTarget(target, success, returndata); } /** * @dev Same as {xref-Address-functionCall-address-bytes-}[`functionCall`], * but performing a delegate call. */ function functionDelegateCall(address target, bytes memory data) internal returns (bytes memory) { (bool success, bytes memory returndata) = target.delegatecall(data); return verifyCallResultFromTarget(target, success, returndata); } /** * @dev Tool to verify that a low level call to smart-contract was successful, and reverts if the target * was not a contract or bubbling up the revert reason (falling back to {Errors.FailedCall}) in case * of an unsuccessful call. */ function verifyCallResultFromTarget( address target, bool success, bytes memory returndata ) internal view returns (bytes memory) { if (!success) { _revert(returndata); } else { // only check if target is a contract if the call was successful and the return data is empty // otherwise we already know that it was a contract if (returndata.length == 0 && target.code.length == 0) { revert AddressEmptyCode(target); } return returndata; } } /** * @dev Tool to verify that a low level call was successful, and reverts if it wasn't, either by bubbling the * revert reason or with a default {Errors.FailedCall} error. */ function verifyCallResult(bool success, bytes memory returndata) internal pure returns (bytes memory) { if (!success) { _revert(returndata); } else { return returndata; } } /** * @dev Reverts with returndata if present. Otherwise reverts with {Errors.FailedCall}. */ function _revert(bytes memory returndata) private pure { // 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 ("memory-safe") { let returndata_size := mload(returndata) revert(add(32, returndata), returndata_size) } } else { revert Errors.FailedCall(); } } }lib/openzeppelin-contracts/contracts/utils/Errors.sol
// SPDX-License-Identifier: MIT // OpenZeppelin Contracts (last updated v5.1.0) (utils/Errors.sol) pragma solidity ^0.8.20; /** * @dev Collection of common custom errors used in multiple contracts * * IMPORTANT: Backwards compatibility is not guaranteed in future versions of the library. * It is recommended to avoid relying on the error API for critical functionality. * * _Available since v5.1._ */ library Errors { /** * @dev The ETH balance of the account is not enough to perform the operation. */ error InsufficientBalance(uint256 balance, uint256 needed); /** * @dev A call to an address target failed. The target may have reverted. */ error FailedCall(); /** * @dev The deployment failed. */ error FailedDeployment(); /** * @dev A necessary precompile is missing. */ error MissingPrecompile(address); }lib/openzeppelin-contracts/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 } } }lib/openzeppelin-contracts/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); }src/interfaces/IOracleAdapter.sol
// SPDX-License-Identifier: MIT pragma solidity ^0.8.20; import {IERC165} from "@openzeppelin/contracts/utils/introspection/IERC165.sol"; import {QuestionDefinition} from "../types/OracleTypes.sol"; /// @title IOracleAdapter /// @notice Interface that oracle adapters must implement. Each adapter normalises a /// specific oracle's interface into a standard surface the router can call. /// The adapter also owns the Somnia reactivity subscription for its oracle /// and calls `IOracleAnswerReceiver.onOracleAnswer` when an answer is posted. /// /// Implements ERC-165. The router validates `supportsInterface` at market /// creation, so passing a non-conforming address reverts. interface IOracleAdapter is IERC165 { /// @notice Returns the number of outcome slots for a given oracle question. /// Called by the router at market creation to determine outcomeSlotCount. function getSlotCount(uint256 oracleQuestionId) external view returns (uint8); /// @notice Pulls the current answer from the oracle. Used as the pull-fallback /// path (replaces the router reading the oracle directly in pokeOracle). /// Must revert if no answer is available yet. function pullAnswer(uint256 oracleQuestionId) external view returns (uint8 outcomeIdx, bool voided); /// @notice Schedules a new oracle question. Optional — adapters that do not /// support scheduling should revert on this call. function scheduleQuestion(QuestionDefinition calldata def) external payable returns (uint256 oracleQuestionId); /// @notice Returns the cost in native token to schedule a question. /// Returns 0 if scheduling is not supported by this adapter. function getSchedulingCost(QuestionDefinition calldata def) external view returns (uint256); }src/interfaces/IOracleAnswerReceiver.sol
// SPDX-License-Identifier: MIT pragma solidity ^0.8.20; import {IERC165} from "@openzeppelin/contracts/utils/introspection/IERC165.sol"; /// @title IOracleAnswerReceiver /// @notice Implemented by the router. Called by oracle adapters when a question /// has been answered. Only the adapter registered for a given market may /// call this. /// /// Implements ERC-165 so adapters can verify the receiver at construction /// time rather than discovering a misconfiguration at resolution time. interface IOracleAnswerReceiver is IERC165 { /// @notice Notify the router that an oracle question has been answered. /// Called by the registered adapter for the market bound to `oracleQuestionId`. function onOracleAnswer(uint256 oracleQuestionId, uint8 outcomeIdx, bool voided) external; }src/interfaces/IProphecyOracle.sol
// SPDX-License-Identifier: MIT pragma solidity ^0.8.20; import {Answer, QuestionDefinition, QuestionStatus} from "../types/OracleTypes.sol"; /// @title IProphecyOracle /// @notice Subset of the OracleEntryPoint interface that the adapter depends on. /// - submitQuestion / getSubmissionCost: route through the entry point. /// - getAnswer / getOutcomeLabels: view aggregators that delegate to the /// active OracleCore via the entry point's oracleCoreFor mapping. /// - AnswerPosted: emitted by OracleCore (not the entry point). The /// adapter subscribes to the OracleCore address for this event and /// passes that address as ORACLE_CORE in the constructor. interface IProphecyOracle { event AnswerPosted( uint256 indexed questionId, uint8 outcomeIdx, string outcomeLabel, int256 numericValue, bool voided, uint256[] receiptIds ); function submitQuestion(QuestionDefinition calldata def) external payable returns (uint256 questionId); function getSubmissionCost(QuestionDefinition calldata def) external view returns (uint256); function getStatus(uint256 questionId) external view returns (QuestionStatus); function getAnswer(uint256 questionId) external view returns (Answer memory); function getOutcomeLabels(uint256 questionId) external view returns (string[] memory); }src/interfaces/ISomniaReactivityPrecompile.sol
// SPDX-License-Identifier: MIT pragma solidity ^0.8.20; /// @notice Interface a contract must implement to receive reactivity callbacks. interface ISomniaEventHandler { function onEvent(address emitter, bytes32[] calldata eventTopics, bytes calldata data) external; } /// @notice Somnia Reactivity precompile, sourced from the chain spec. interface ISomniaReactivityPrecompile { struct SubscriptionData { bytes32[4] eventTopics; address origin; address caller; address emitter; address handlerContractAddress; bytes4 handlerFunctionSelector; uint64 priorityFeePerGas; uint64 maxFeePerGas; uint64 gasLimit; bool isGuaranteed; bool isCoalesced; } event BlockTick(uint64 indexed blockNumber); event Schedule(uint256 indexed timestampMillis); function subscribe(SubscriptionData calldata data) external returns (uint256 subscriptionId); function unsubscribe(uint256 subscriptionId) external; function getSubscriptionInfo(uint256 subscriptionId) external view returns (SubscriptionData memory, address owner); } library SomniaExtensions { address constant SOMNIA_REACTIVITY_PRECOMPILE_ADDRESS = address(0x0100); }src/types/OracleTypes.sol
// SPDX-License-Identifier: MIT pragma solidity ^0.8.20; /// @notice Minimal stubs for the ProphecyOracle's external types. Matches the /// oracle's OracleTypes.sol exactly so ABI encoding is compatible. enum AnswerType { NumericAnswer, DiscreteAnswer } /// @notice Inclusive numeric range. `low <= aggregatedValue <= high` matches the bucket. struct Interval { int256 low; int256 high; } struct ValidAnswers { AnswerType answerType; string[] discreteOutcomes; Interval[] numericIntervals; uint64 numericDecimals; } enum QuestionSourceType { Website, JSON, Contract } struct QuestionSource { QuestionSourceType sourceType; bytes params; } enum QuestionStatus { None, Scheduled, AwaitingAnswer, Resolved, Voided } struct QuestionDefinition { string questionText; QuestionSource[] sources; ValidAnswers validAnswers; uint256 resolutionTime; uint256 minAgreement; uint256 subcommitteeSize; uint256 subcommitteeThreshold; } struct Answer { uint64 timestamp; bool voided; uint8 outcomeIdx; int256 numericValue; uint256[] receiptIds; } struct Question { address creator; AnswerType answerType; string[] discreteOutcomes; Interval[] numericIntervals; uint64 numericDecimals; uint256[] sourceIds; uint256 asyncSourceCount; uint256 resolutionTime; uint256 minAgreement; uint256 subcommitteeSize; uint256 subcommitteeThreshold; QuestionStatus status; bool answerPosted; bool voided; string questionText; }
ABI · 58 entries
json
[
{
"type": "constructor",
"inputs": [
{
"name": "oracle_",
"type": "address",
"internalType": "contract IProphecyOracle"
},
{
"name": "oracleCore_",
"type": "address",
"internalType": "address"
},
{
"name": "reactivity_",
"type": "address",
"internalType": "contract ISomniaReactivityPrecompile"
},
{
"name": "router_",
"type": "address",
"internalType": "contract IOracleAnswerReceiver"
}
],
"stateMutability": "nonpayable"
},
{
"name": "AddressEmptyCode",
"type": "error",
"inputs": [
{
"name": "target",
"type": "address",
"internalType": "address"
}
]
},
{
"name": "AlreadySubscribed",
"type": "error",
"inputs": []
},
{
"name": "ERC1967InvalidImplementation",
"type": "error",
"inputs": [
{
"name": "implementation",
"type": "address",
"internalType": "address"
}
]
},
{
"name": "ERC1967NonPayable",
"type": "error",
"inputs": []
},
{
"name": "FailedCall",
"type": "error",
"inputs": []
},
{
"name": "InvalidInitialization",
"type": "error",
"inputs": []
},
{
"name": "InvalidReceiver",
"type": "error",
"inputs": []
},
{
"name": "NoPrecompile",
"type": "error",
"inputs": []
},
{
"name": "NotInitializing",
"type": "error",
"inputs": []
},
{
"name": "NotReactivity",
"type": "error",
"inputs": []
},
{
"name": "NotSubscribed",
"type": "error",
"inputs": []
},
{
"name": "OwnableInvalidOwner",
"type": "error",
"inputs": [
{
"name": "owner",
"type": "address",
"internalType": "address"
}
]
},
{
"name": "OwnableUnauthorizedAccount",
"type": "error",
"inputs": [
{
"name": "account",
"type": "address",
"internalType": "address"
}
]
},
{
"name": "UUPSUnauthorizedCallContext",
"type": "error",
"inputs": []
},
{
"name": "UUPSUnsupportedProxiableUUID",
"type": "error",
"inputs": [
{
"name": "slot",
"type": "bytes32",
"internalType": "bytes32"
}
]
},
{
"name": "WithdrawFailed",
"type": "error",
"inputs": []
},
{
"name": "WrongEmitter",
"type": "error",
"inputs": []
},
{
"name": "WrongEvent",
"type": "error",
"inputs": []
},
{
"name": "Deposited",
"type": "event",
"inputs": [
{
"name": "from",
"type": "address",
"indexed": true,
"internalType": "address"
},
{
"name": "amount",
"type": "uint256",
"indexed": false,
"internalType": "uint256"
}
],
"anonymous": false
},
{
"name": "GasParamsUpdated",
"type": "event",
"inputs": [
{
"name": "priorityFeePerGas",
"type": "uint64",
"indexed": false,
"internalType": "uint64"
},
{
"name": "maxFeePerGas",
"type": "uint64",
"indexed": false,
"internalType": "uint64"
},
{
"name": "gasLimit",
"type": "uint64",
"indexed": false,
"internalType": "uint64"
}
],
"anonymous": false
},
{
"name": "Initialized",
"type": "event",
"inputs": [
{
"name": "version",
"type": "uint64",
"indexed": false,
"internalType": "uint64"
}
],
"anonymous": false
},
{
"name": "OwnershipTransferStarted",
"type": "event",
"inputs": [
{
"name": "previousOwner",
"type": "address",
"indexed": true,
"internalType": "address"
},
{
"name": "newOwner",
"type": "address",
"indexed": true,
"internalType": "address"
}
],
"anonymous": false
},
{
"name": "OwnershipTransferred",
"type": "event",
"inputs": [
{
"name": "previousOwner",
"type": "address",
"indexed": true,
"internalType": "address"
},
{
"name": "newOwner",
"type": "address",
"indexed": true,
"internalType": "address"
}
],
"anonymous": false
},
{
"name": "Subscribed",
"type": "event",
"inputs": [
{
"name": "subscriptionId",
"type": "uint256",
"indexed": true,
"internalType": "uint256"
}
],
"anonymous": false
},
{
"name": "Unsubscribed",
"type": "event",
"inputs": [
{
"name": "subscriptionId",
"type": "uint256",
"indexed": true,
"internalType": "uint256"
}
],
"anonymous": false
},
{
"name": "Upgraded",
"type": "event",
"inputs": [
{
"name": "implementation",
"type": "address",
"indexed": true,
"internalType": "address"
}
],
"anonymous": false
},
{
"name": "Withdrawn",
"type": "event",
"inputs": [
{
"name": "to",
"type": "address",
"indexed": true,
"internalType": "address"
},
{
"name": "amount",
"type": "uint256",
"indexed": false,
"internalType": "uint256"
}
],
"anonymous": false
},
{
"name": "ANSWER_POSTED_TOPIC",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "bytes32",
"internalType": "bytes32"
}
],
"stateMutability": "view"
},
{
"name": "ORACLE",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "contract IProphecyOracle"
}
],
"stateMutability": "view"
},
{
"name": "ORACLE_CORE",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "address"
}
],
"stateMutability": "view"
},
{
"name": "REACTIVITY",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "contract ISomniaReactivityPrecompile"
}
],
"stateMutability": "view"
},
{
"name": "ROUTER",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "contract IOracleAnswerReceiver"
}
],
"stateMutability": "view"
},
{
"name": "UPGRADE_INTERFACE_VERSION",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "string",
"internalType": "string"
}
],
"stateMutability": "view"
},
{
"name": "acceptOwnership",
"type": "function",
"inputs": [],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "disableReactivity",
"type": "function",
"inputs": [],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "enableReactivity",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "uint256",
"internalType": "uint256"
}
],
"stateMutability": "nonpayable"
},
{
"name": "gasLimit",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "uint64",
"internalType": "uint64"
}
],
"stateMutability": "view"
},
{
"name": "getSchedulingCost",
"type": "function",
"inputs": [
{
"name": "def",
"type": "tuple",
"components": [
{
"name": "questionText",
"type": "string",
"internalType": "string"
},
{
"name": "sources",
"type": "tuple[]",
"components": [
{
"name": "sourceType",
"type": "uint8",
"internalType": "enum QuestionSourceType"
},
{
"name": "params",
"type": "bytes",
"internalType": "bytes"
}
],
"internalType": "struct QuestionSource[]"
},
{
"name": "validAnswers",
"type": "tuple",
"components": [
{
"name": "answerType",
"type": "uint8",
"internalType": "enum AnswerType"
},
{
"name": "discreteOutcomes",
"type": "string[]",
"internalType": "string[]"
},
{
"name": "numericIntervals",
"type": "tuple[]",
"components": [
{
"name": "low",
"type": "int256",
"internalType": "int256"
},
{
"name": "high",
"type": "int256",
"internalType": "int256"
}
],
"internalType": "struct Interval[]"
},
{
"name": "numericDecimals",
"type": "uint64",
"internalType": "uint64"
}
],
"internalType": "struct ValidAnswers"
},
{
"name": "resolutionTime",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "minAgreement",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "subcommitteeSize",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "subcommitteeThreshold",
"type": "uint256",
"internalType": "uint256"
}
],
"internalType": "struct QuestionDefinition"
}
],
"outputs": [
{
"name": "",
"type": "uint256",
"internalType": "uint256"
}
],
"stateMutability": "view"
},
{
"name": "getSlotCount",
"type": "function",
"inputs": [
{
"name": "oracleQuestionId",
"type": "uint256",
"internalType": "uint256"
}
],
"outputs": [
{
"name": "",
"type": "uint8",
"internalType": "uint8"
}
],
"stateMutability": "view"
},
{
"name": "initialize",
"type": "function",
"inputs": [
{
"name": "admin_",
"type": "address",
"internalType": "address"
},
{
"name": "priorityFeePerGas_",
"type": "uint64",
"internalType": "uint64"
},
{
"name": "maxFeePerGas_",
"type": "uint64",
"internalType": "uint64"
},
{
"name": "gasLimit_",
"type": "uint64",
"internalType": "uint64"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "maxFeePerGas",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "uint64",
"internalType": "uint64"
}
],
"stateMutability": "view"
},
{
"name": "onEvent",
"type": "function",
"inputs": [
{
"name": "emitter",
"type": "address",
"internalType": "address"
},
{
"name": "eventTopics",
"type": "bytes32[]",
"internalType": "bytes32[]"
},
{
"name": "data",
"type": "bytes",
"internalType": "bytes"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "owner",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "address"
}
],
"stateMutability": "view"
},
{
"name": "pendingOwner",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "address",
"internalType": "address"
}
],
"stateMutability": "view"
},
{
"name": "priorityFeePerGas",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "uint64",
"internalType": "uint64"
}
],
"stateMutability": "view"
},
{
"name": "proxiableUUID",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "bytes32",
"internalType": "bytes32"
}
],
"stateMutability": "view"
},
{
"name": "pullAnswer",
"type": "function",
"inputs": [
{
"name": "oracleQuestionId",
"type": "uint256",
"internalType": "uint256"
}
],
"outputs": [
{
"name": "outcomeIdx",
"type": "uint8",
"internalType": "uint8"
},
{
"name": "voided",
"type": "bool",
"internalType": "bool"
}
],
"stateMutability": "view"
},
{
"name": "renounceOwnership",
"type": "function",
"inputs": [],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "resubscribe",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "uint256",
"internalType": "uint256"
}
],
"stateMutability": "nonpayable"
},
{
"name": "scheduleQuestion",
"type": "function",
"inputs": [
{
"name": "def",
"type": "tuple",
"components": [
{
"name": "questionText",
"type": "string",
"internalType": "string"
},
{
"name": "sources",
"type": "tuple[]",
"components": [
{
"name": "sourceType",
"type": "uint8",
"internalType": "enum QuestionSourceType"
},
{
"name": "params",
"type": "bytes",
"internalType": "bytes"
}
],
"internalType": "struct QuestionSource[]"
},
{
"name": "validAnswers",
"type": "tuple",
"components": [
{
"name": "answerType",
"type": "uint8",
"internalType": "enum AnswerType"
},
{
"name": "discreteOutcomes",
"type": "string[]",
"internalType": "string[]"
},
{
"name": "numericIntervals",
"type": "tuple[]",
"components": [
{
"name": "low",
"type": "int256",
"internalType": "int256"
},
{
"name": "high",
"type": "int256",
"internalType": "int256"
}
],
"internalType": "struct Interval[]"
},
{
"name": "numericDecimals",
"type": "uint64",
"internalType": "uint64"
}
],
"internalType": "struct ValidAnswers"
},
{
"name": "resolutionTime",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "minAgreement",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "subcommitteeSize",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "subcommitteeThreshold",
"type": "uint256",
"internalType": "uint256"
}
],
"internalType": "struct QuestionDefinition"
}
],
"outputs": [
{
"name": "",
"type": "uint256",
"internalType": "uint256"
}
],
"stateMutability": "payable"
},
{
"name": "setGasParams",
"type": "function",
"inputs": [
{
"name": "priorityFeePerGas_",
"type": "uint64",
"internalType": "uint64"
},
{
"name": "maxFeePerGas_",
"type": "uint64",
"internalType": "uint64"
},
{
"name": "gasLimit_",
"type": "uint64",
"internalType": "uint64"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "subscriptionId",
"type": "function",
"inputs": [],
"outputs": [
{
"name": "",
"type": "uint256",
"internalType": "uint256"
}
],
"stateMutability": "view"
},
{
"name": "supportsInterface",
"type": "function",
"inputs": [
{
"name": "interfaceId",
"type": "bytes4",
"internalType": "bytes4"
}
],
"outputs": [
{
"name": "",
"type": "bool",
"internalType": "bool"
}
],
"stateMutability": "view"
},
{
"name": "transferOwnership",
"type": "function",
"inputs": [
{
"name": "newOwner",
"type": "address",
"internalType": "address"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"name": "upgradeToAndCall",
"type": "function",
"inputs": [
{
"name": "newImplementation",
"type": "address",
"internalType": "address"
},
{
"name": "data",
"type": "bytes",
"internalType": "bytes"
}
],
"outputs": [],
"stateMutability": "payable"
},
{
"name": "withdraw",
"type": "function",
"inputs": [
{
"name": "amount",
"type": "uint256",
"internalType": "uint256"
},
{
"name": "to",
"type": "address",
"internalType": "address payable"
}
],
"outputs": [],
"stateMutability": "nonpayable"
},
{
"type": "receive",
"stateMutability": "payable"
}
]