mirror of
https://github.com/logos-messaging/logos-messaging-rlnv2-contract.git
synced 2026-01-10 18:03:06 +00:00
chore: add the initial contract after few optimizations
This commit is contained in:
parent
7dc47c88e4
commit
4918392ea4
@ -1,13 +1,13 @@
|
||||
// SPDX-License-Identifier: UNLICENSED
|
||||
pragma solidity >=0.8.19 <=0.9.0;
|
||||
|
||||
import { Foo } from "../src/Foo.sol";
|
||||
import { WakuRlnV2 } from "../src/WakuRlnV2.sol";
|
||||
import { BaseScript } from "./Base.s.sol";
|
||||
import { DeploymentConfig } from "./DeploymentConfig.s.sol";
|
||||
|
||||
contract Deploy is BaseScript {
|
||||
function run() public returns (Foo foo, DeploymentConfig deploymentConfig) {
|
||||
function run() public returns (WakuRlnV2 w, DeploymentConfig deploymentConfig) {
|
||||
deploymentConfig = new DeploymentConfig(broadcaster);
|
||||
foo = new Foo();
|
||||
w = new WakuRlnV2(0, 20, 20);
|
||||
}
|
||||
}
|
||||
|
||||
@ -1,8 +0,0 @@
|
||||
// SPDX-License-Identifier: UNLICENSED
|
||||
pragma solidity >=0.8.19;
|
||||
|
||||
contract Foo {
|
||||
function id(uint256 value) external pure returns (uint256) {
|
||||
return value;
|
||||
}
|
||||
}
|
||||
194
src/WakuRlnV2.sol
Normal file
194
src/WakuRlnV2.sol
Normal file
@ -0,0 +1,194 @@
|
||||
// SPDX-License-Identifier: MIT
|
||||
|
||||
pragma solidity 0.8.19;
|
||||
|
||||
import { LazyIMT, LazyIMTData } from "@zk-kit/imt.sol/LazyIMT.sol";
|
||||
import { PoseidonT3 } from "poseidon-solidity/PoseidonT3.sol";
|
||||
|
||||
/// The tree is full
|
||||
error FullTree();
|
||||
|
||||
/// Invalid deposit amount
|
||||
/// @param required The required deposit amount
|
||||
/// @param provided The provided deposit amount
|
||||
error InsufficientDeposit(uint256 required, uint256 provided);
|
||||
|
||||
/// Member is already registered
|
||||
error DuplicateIdCommitment();
|
||||
|
||||
/// Failed validation on registration/slashing
|
||||
error FailedValidation();
|
||||
|
||||
/// Invalid idCommitment
|
||||
error InvalidIdCommitment(uint256 idCommitment);
|
||||
|
||||
/// Invalid userMessageLimit
|
||||
error InvalidUserMessageLimit(uint256 messageLimit);
|
||||
|
||||
/// Invalid receiver address, when the receiver is the contract itself or 0x0
|
||||
error InvalidReceiverAddress(address to);
|
||||
|
||||
/// Member is not registered
|
||||
error MemberNotRegistered(uint256 idCommitment);
|
||||
|
||||
/// Member has no stake
|
||||
error MemberHasNoStake(uint256 idCommitment);
|
||||
|
||||
/// User has insufficient balance to withdraw
|
||||
error InsufficientWithdrawalBalance();
|
||||
|
||||
/// Contract has insufficient balance to return
|
||||
error InsufficientContractBalance();
|
||||
|
||||
/// Invalid proof
|
||||
error InvalidProof();
|
||||
|
||||
/// Invalid pagination query
|
||||
error InvalidPaginationQuery(uint256 startIndex, uint256 endIndex);
|
||||
|
||||
contract WakuRlnV2 {
|
||||
/// @notice The Field
|
||||
uint256 public constant Q =
|
||||
21_888_242_871_839_275_222_246_405_745_257_275_088_548_364_400_416_034_343_698_204_186_575_808_495_617;
|
||||
|
||||
/// @notice The max message limit per epoch
|
||||
uint256 public immutable MAX_MESSAGE_LIMIT;
|
||||
|
||||
/// @notice The deposit amount required to register as a member
|
||||
uint256 public immutable MEMBERSHIP_DEPOSIT;
|
||||
|
||||
/// @notice The depth of the merkle tree
|
||||
uint256 public immutable DEPTH;
|
||||
|
||||
/// @notice The size of the merkle tree, i.e 2^depth
|
||||
uint256 public immutable SET_SIZE;
|
||||
|
||||
/// @notice The index of the next member to be registered
|
||||
uint32 public idCommitmentIndex = 0;
|
||||
|
||||
struct MembershipInfo {
|
||||
/// @notice the user message limit of each member
|
||||
uint32 userMessageLimit;
|
||||
/// @notice The amount of eth staked by each member
|
||||
uint256 stakedAmount;
|
||||
}
|
||||
|
||||
/// maps from idCommitment to their index in the set
|
||||
mapping(uint256 => uint32) public members;
|
||||
|
||||
/// @notice The membership status of each member
|
||||
mapping(uint256 => bool) public memberExists;
|
||||
|
||||
/// @notice the member metadata
|
||||
mapping(uint256 => MembershipInfo) public memberInfo;
|
||||
|
||||
/// @notice the deployed block number
|
||||
uint32 public immutable deployedBlockNumber;
|
||||
|
||||
/// @notice the stored imt data
|
||||
LazyIMTData public imtData;
|
||||
|
||||
/// Emitted when a new member is added to the set
|
||||
/// @param idCommitment The idCommitment of the member
|
||||
/// @param userMessageLimit the user message limit of the member
|
||||
/// @param index The index of the member in the set
|
||||
event MemberRegistered(uint256 idCommitment, uint32 userMessageLimit, uint256 index);
|
||||
|
||||
/// Emitted when a member is removed from the set
|
||||
/// @param idCommitment The idCommitment of the member
|
||||
/// @param index The index of the member in the set
|
||||
event MemberWithdrawn(uint256 idCommitment, uint256 index);
|
||||
|
||||
modifier onlyValidIdCommitment(uint256 idCommitment) {
|
||||
if (!isValidCommitment(idCommitment)) revert InvalidIdCommitment(idCommitment);
|
||||
_;
|
||||
}
|
||||
|
||||
modifier onlyValidUserMessageLimit(uint256 messageLimit) {
|
||||
if (messageLimit > MAX_MESSAGE_LIMIT) revert InvalidUserMessageLimit(messageLimit);
|
||||
if (messageLimit == 0) revert InvalidUserMessageLimit(messageLimit);
|
||||
_;
|
||||
}
|
||||
|
||||
constructor(uint256 membershipDeposit, uint256 depth, uint256 maxMessageLimit) {
|
||||
MEMBERSHIP_DEPOSIT = membershipDeposit;
|
||||
MAX_MESSAGE_LIMIT = maxMessageLimit;
|
||||
DEPTH = depth;
|
||||
SET_SIZE = 1 << depth;
|
||||
deployedBlockNumber = uint32(block.number);
|
||||
LazyIMT.init(imtData, 20);
|
||||
}
|
||||
|
||||
/// Returns the deposit amount required to register as a member
|
||||
/// @param userMessageLimit The message limit of the member
|
||||
/// TODO: update this function as per tokenomics design
|
||||
function getDepositAmount(uint32 userMessageLimit) public view returns (uint256) {
|
||||
return userMessageLimit * MEMBERSHIP_DEPOSIT;
|
||||
}
|
||||
|
||||
/// Allows a user to register as a member
|
||||
/// @param idCommitment The idCommitment of the member
|
||||
/// @param userMessageLimit The message limit of the member
|
||||
function register(
|
||||
uint256 idCommitment,
|
||||
uint32 userMessageLimit
|
||||
)
|
||||
external
|
||||
payable
|
||||
virtual
|
||||
onlyValidIdCommitment(idCommitment)
|
||||
onlyValidUserMessageLimit(userMessageLimit)
|
||||
{
|
||||
uint256 requiredDeposit = getDepositAmount(userMessageLimit);
|
||||
if (msg.value != requiredDeposit) {
|
||||
revert InsufficientDeposit(MEMBERSHIP_DEPOSIT, msg.value);
|
||||
}
|
||||
_register(idCommitment, userMessageLimit, msg.value);
|
||||
}
|
||||
|
||||
/// Registers a member
|
||||
/// @param idCommitment The idCommitment of the member
|
||||
/// @param userMessageLimit The message limit of the member
|
||||
/// @param stake The amount of eth staked by the member
|
||||
function _register(uint256 idCommitment, uint32 userMessageLimit, uint256 stake) internal virtual {
|
||||
if (memberExists[idCommitment]) revert DuplicateIdCommitment();
|
||||
if (idCommitmentIndex >= SET_SIZE) revert FullTree();
|
||||
|
||||
MembershipInfo memory member = MembershipInfo({
|
||||
userMessageLimit: uint32(userMessageLimit),
|
||||
stakedAmount: stake
|
||||
});
|
||||
|
||||
members[idCommitment] = idCommitmentIndex;
|
||||
uint256 rateCommitment = PoseidonT3.hash([idCommitment, userMessageLimit]);
|
||||
LazyIMT.insert(imtData, rateCommitment);
|
||||
memberExists[idCommitment] = true;
|
||||
memberInfo[idCommitment] = member;
|
||||
|
||||
emit MemberRegistered(idCommitment, userMessageLimit, idCommitmentIndex);
|
||||
idCommitmentIndex += 1;
|
||||
}
|
||||
|
||||
function isValidCommitment(uint256 idCommitment) public pure returns (bool) {
|
||||
return idCommitment != 0 && idCommitment < Q;
|
||||
}
|
||||
|
||||
function getCommitments(uint256 startIndex, uint256 endIndex) public view returns (uint256[] memory) {
|
||||
if (startIndex >= endIndex) revert InvalidPaginationQuery(startIndex, endIndex);
|
||||
if (endIndex > idCommitmentIndex) revert InvalidPaginationQuery(startIndex, endIndex);
|
||||
|
||||
uint256[] memory commitments = new uint256[](endIndex - startIndex);
|
||||
for (uint256 i = startIndex; i < endIndex; i++) {
|
||||
commitments[i - startIndex] = imtData.elements[LazyIMT.indexForElement(uint8(i), imtData.numberOfLeaves)];
|
||||
}
|
||||
return commitments;
|
||||
}
|
||||
|
||||
function root() external view returns (uint256) {
|
||||
return LazyIMT.root(imtData, 20);
|
||||
}
|
||||
|
||||
function merkleProofElements(uint40 index) public view returns (uint256[] memory) {
|
||||
return LazyIMT.merkleProofElements(imtData, index, 20);
|
||||
}
|
||||
}
|
||||
@ -5,22 +5,19 @@ import { Test, console } from "forge-std/Test.sol";
|
||||
|
||||
import { Deploy } from "../script/Deploy.s.sol";
|
||||
import { DeploymentConfig } from "../script/DeploymentConfig.s.sol";
|
||||
import { Foo } from "../src/Foo.sol";
|
||||
import { WakuRlnV2 } from "../src/WakuRlnV2.sol";
|
||||
|
||||
contract FooTest is Test {
|
||||
Foo internal foo;
|
||||
contract WakuRlnV2Test is Test {
|
||||
WakuRlnV2 internal w;
|
||||
DeploymentConfig internal deploymentConfig;
|
||||
|
||||
address internal deployer;
|
||||
|
||||
function setUp() public virtual {
|
||||
Deploy deployment = new Deploy();
|
||||
(foo, deploymentConfig) = deployment.run();
|
||||
(w, deploymentConfig) = deployment.run();
|
||||
}
|
||||
|
||||
function test_Example() external {
|
||||
console.log("Hello World");
|
||||
uint256 x = 42;
|
||||
assertEq(foo.id(x), x, "value mismatch");
|
||||
function test__ValidRegistration() external {
|
||||
}
|
||||
}
|
||||
Loading…
x
Reference in New Issue
Block a user