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"
  }
]