mirror of
https://github.com/status-im/codex-contracts-eth.git
synced 2025-02-12 00:17:34 +00:00
move activeslots to separate contract
This commit is contained in:
parent
74c2d91b69
commit
20111c2ec1
28
contracts/ActiveSlots.sol
Normal file
28
contracts/ActiveSlots.sol
Normal file
@ -0,0 +1,28 @@
|
|||||||
|
// SPDX-License-Identifier: MIT
|
||||||
|
pragma solidity ^0.8.8;
|
||||||
|
|
||||||
|
import "@openzeppelin/contracts/utils/structs/EnumerableSet.sol";
|
||||||
|
|
||||||
|
contract ActiveSlots {
|
||||||
|
mapping(bytes32 =>
|
||||||
|
mapping(address =>
|
||||||
|
mapping(uint8 =>
|
||||||
|
EnumerableSet.Bytes32Set))) private activeSlots;
|
||||||
|
mapping(bytes32 => uint8) private activeSlotsIdx;
|
||||||
|
|
||||||
|
function _activeSlotsForHost(address host, bytes32 requestId)
|
||||||
|
internal
|
||||||
|
view
|
||||||
|
returns (EnumerableSet.Bytes32Set storage)
|
||||||
|
{
|
||||||
|
uint8 id = activeSlotsIdx[requestId];
|
||||||
|
return activeSlots[requestId][host][id];
|
||||||
|
}
|
||||||
|
|
||||||
|
/// @notice Clears active slots for a request
|
||||||
|
/// @dev Because there are no efficient ways to clear an EnumerableSet, an index is updated that points to a new instance.
|
||||||
|
/// @param requestId request for which to clear the active slots
|
||||||
|
function _clearActiveSlots(bytes32 requestId) internal {
|
||||||
|
activeSlotsIdx[requestId]++;
|
||||||
|
}
|
||||||
|
}
|
@ -6,8 +6,9 @@ import "@openzeppelin/contracts/utils/math/Math.sol";
|
|||||||
import "@openzeppelin/contracts/utils/structs/EnumerableSet.sol";
|
import "@openzeppelin/contracts/utils/structs/EnumerableSet.sol";
|
||||||
import "./Collateral.sol";
|
import "./Collateral.sol";
|
||||||
import "./Proofs.sol";
|
import "./Proofs.sol";
|
||||||
|
import "./ActiveSlots.sol";
|
||||||
|
|
||||||
contract Marketplace is Collateral, Proofs {
|
contract Marketplace is Collateral, Proofs, ActiveSlots {
|
||||||
using EnumerableSet for EnumerableSet.Bytes32Set;
|
using EnumerableSet for EnumerableSet.Bytes32Set;
|
||||||
|
|
||||||
type RequestId is bytes32;
|
type RequestId is bytes32;
|
||||||
@ -19,11 +20,6 @@ contract Marketplace is Collateral, Proofs {
|
|||||||
mapping(RequestId => RequestContext) private requestContexts;
|
mapping(RequestId => RequestContext) private requestContexts;
|
||||||
mapping(SlotId => Slot) private slots;
|
mapping(SlotId => Slot) private slots;
|
||||||
mapping(address => EnumerableSet.Bytes32Set) private activeRequests;
|
mapping(address => EnumerableSet.Bytes32Set) private activeRequests;
|
||||||
mapping(RequestId =>
|
|
||||||
mapping(address =>
|
|
||||||
mapping(uint8 =>
|
|
||||||
EnumerableSet.Bytes32Set))) private activeSlots;
|
|
||||||
mapping(RequestId => uint8) private activeSlotsIdx;
|
|
||||||
|
|
||||||
constructor(
|
constructor(
|
||||||
IERC20 _token,
|
IERC20 _token,
|
||||||
@ -34,6 +30,7 @@ contract Marketplace is Collateral, Proofs {
|
|||||||
)
|
)
|
||||||
Collateral(_token)
|
Collateral(_token)
|
||||||
Proofs(_proofPeriod, _proofTimeout, _proofDowntime)
|
Proofs(_proofPeriod, _proofTimeout, _proofDowntime)
|
||||||
|
ActiveSlots()
|
||||||
marketplaceInvariant
|
marketplaceInvariant
|
||||||
{
|
{
|
||||||
collateral = _collateral;
|
collateral = _collateral;
|
||||||
@ -46,30 +43,14 @@ contract Marketplace is Collateral, Proofs {
|
|||||||
function mySlots(RequestId requestId)
|
function mySlots(RequestId requestId)
|
||||||
public
|
public
|
||||||
view
|
view
|
||||||
returns (SlotId[] memory)
|
returns (SlotId[] memory)
|
||||||
{
|
{
|
||||||
EnumerableSet.Bytes32Set storage slotIds = _activeSlotsForHost(msg.sender,
|
EnumerableSet.Bytes32Set
|
||||||
requestId);
|
storage
|
||||||
|
slotIds = _activeSlotsForHost(msg.sender, RequestId.unwrap(requestId));
|
||||||
return _toSlotIds(slotIds.values());
|
return _toSlotIds(slotIds.values());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function _activeSlotsForHost(address host, RequestId requestId)
|
|
||||||
internal
|
|
||||||
view
|
|
||||||
returns (EnumerableSet.Bytes32Set storage)
|
|
||||||
{
|
|
||||||
uint8 id = activeSlotsIdx[requestId];
|
|
||||||
return activeSlots[requestId][host][id];
|
|
||||||
}
|
|
||||||
|
|
||||||
/// @notice Clears active slots for a request
|
|
||||||
/// @dev Because there are no efficient ways to clear an EnumerableSet, an index is updated that points to a new instance.
|
|
||||||
/// @param requestId request for which to clear the active slots
|
|
||||||
function _clearActiveSlots(RequestId requestId) internal {
|
|
||||||
activeSlotsIdx[requestId]++;
|
|
||||||
}
|
|
||||||
|
|
||||||
function _equals(RequestId a, RequestId b) internal pure returns (bool) {
|
function _equals(RequestId a, RequestId b) internal pure returns (bool) {
|
||||||
return RequestId.unwrap(a) == RequestId.unwrap(b);
|
return RequestId.unwrap(a) == RequestId.unwrap(b);
|
||||||
}
|
}
|
||||||
@ -125,7 +106,8 @@ contract Marketplace is Collateral, Proofs {
|
|||||||
slot.requestId = requestId;
|
slot.requestId = requestId;
|
||||||
RequestContext storage context = _context(requestId);
|
RequestContext storage context = _context(requestId);
|
||||||
context.slotsFilled += 1;
|
context.slotsFilled += 1;
|
||||||
_activeSlotsForHost(slot.host, requestId).add(SlotId.unwrap(slotId));
|
_activeSlotsForHost(slot.host, RequestId.unwrap(requestId))
|
||||||
|
.add(SlotId.unwrap(slotId));
|
||||||
emit SlotFilled(requestId, slotIndex, slotId);
|
emit SlotFilled(requestId, slotIndex, slotId);
|
||||||
if (context.slotsFilled == request.ask.slots) {
|
if (context.slotsFilled == request.ask.slots) {
|
||||||
context.state = RequestState.Started;
|
context.state = RequestState.Started;
|
||||||
@ -152,7 +134,8 @@ contract Marketplace is Collateral, Proofs {
|
|||||||
|
|
||||||
_unexpectProofs(_toProofId(slotId));
|
_unexpectProofs(_toProofId(slotId));
|
||||||
|
|
||||||
_activeSlotsForHost(slot.host, requestId).remove(SlotId.unwrap(slotId));
|
_activeSlotsForHost(slot.host, RequestId.unwrap(requestId))
|
||||||
|
.remove(SlotId.unwrap(slotId));
|
||||||
slot.host = address(0);
|
slot.host = address(0);
|
||||||
slot.requestId = RequestId.wrap(0);
|
slot.requestId = RequestId.wrap(0);
|
||||||
context.slotsFilled -= 1;
|
context.slotsFilled -= 1;
|
||||||
@ -168,7 +151,7 @@ contract Marketplace is Collateral, Proofs {
|
|||||||
_setProofEnd(_toEndId(requestId), block.timestamp - 1);
|
_setProofEnd(_toEndId(requestId), block.timestamp - 1);
|
||||||
context.endsAt = block.timestamp - 1;
|
context.endsAt = block.timestamp - 1;
|
||||||
activeRequests[request.client].remove(RequestId.unwrap(requestId));
|
activeRequests[request.client].remove(RequestId.unwrap(requestId));
|
||||||
_clearActiveSlots(requestId);
|
_clearActiveSlots(RequestId.unwrap(requestId));
|
||||||
emit RequestFailed(requestId);
|
emit RequestFailed(requestId);
|
||||||
|
|
||||||
// TODO: burn all remaining slot collateral (note: slot collateral not
|
// TODO: burn all remaining slot collateral (note: slot collateral not
|
||||||
@ -189,7 +172,8 @@ contract Marketplace is Collateral, Proofs {
|
|||||||
SlotId slotId = _toSlotId(requestId, slotIndex);
|
SlotId slotId = _toSlotId(requestId, slotIndex);
|
||||||
Slot storage slot = _slot(slotId);
|
Slot storage slot = _slot(slotId);
|
||||||
require(!slot.hostPaid, "Already paid");
|
require(!slot.hostPaid, "Already paid");
|
||||||
_activeSlotsForHost(slot.host, requestId).remove(SlotId.unwrap(slotId));
|
_activeSlotsForHost(slot.host, RequestId.unwrap(requestId))
|
||||||
|
.remove(SlotId.unwrap(slotId));
|
||||||
uint256 amount = pricePerSlot(requests[requestId]);
|
uint256 amount = pricePerSlot(requests[requestId]);
|
||||||
funds.sent += amount;
|
funds.sent += amount;
|
||||||
funds.balance -= amount;
|
funds.balance -= amount;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user