-
Notifications
You must be signed in to change notification settings - Fork 7
/
Copy pathLagrangeService.sol
127 lines (107 loc) · 5.12 KB
/
LagrangeService.sol
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
// SPDX-License-Identifier: UNLICENSED
pragma solidity ^0.8.12;
import "@openzeppelin-upgrades/contracts/proxy/utils/Initializable.sol";
import "@openzeppelin-upgrades/contracts/access/OwnableUpgradeable.sol";
import {ISignatureUtils} from "eigenlayer-contracts/src/contracts/interfaces/ISignatureUtils.sol";
import {IAVSDirectory} from "eigenlayer-contracts/src/contracts/interfaces/IAVSDirectory.sol";
import {IStakeManager} from "../interfaces/IStakeManager.sol";
import {ILagrangeCommittee} from "../interfaces/ILagrangeCommittee.sol";
import {ILagrangeService} from "../interfaces/ILagrangeService.sol";
import {IVoteWeigher} from "../interfaces/IVoteWeigher.sol";
contract LagrangeService is Initializable, OwnableUpgradeable, ILagrangeService {
mapping(address => bool) public operatorWhitelist;
ILagrangeCommittee public immutable committee;
IStakeManager public immutable stakeManager;
IAVSDirectory public immutable avsDirectory;
IVoteWeigher public immutable voteWeigher;
event OperatorRegistered(address indexed operator, uint32 serveUntilBlock);
event OperatorDeregistered(address indexed operator);
event OperatorSubscribed(address indexed operator, uint32 indexed chainID);
event OperatorUnsubscribed(address indexed operator, uint32 indexed chainID);
modifier onlyWhitelisted() {
require(operatorWhitelist[msg.sender], "Operator is not whitelisted");
_;
}
constructor(
ILagrangeCommittee _committee,
IStakeManager _stakeManager,
address _avsDirectoryAddress,
IVoteWeigher _voteWeigher
) {
committee = _committee;
stakeManager = _stakeManager;
avsDirectory = IAVSDirectory(_avsDirectoryAddress);
voteWeigher = _voteWeigher;
_disableInitializers();
}
function initialize(address initialOwner) external initializer {
_transferOwnership(initialOwner);
}
/// Add the operator to the whitelist.
function addOperatorsToWhitelist(address[] calldata operators) external onlyOwner {
for (uint256 i; i < operators.length; i++) {
operatorWhitelist[operators[i]] = true;
}
}
/// Remove the operator from the whitelist.
function removeOperatorsFromWhitelist(address[] calldata operators) external onlyOwner {
for (uint256 i; i < operators.length; i++) {
delete operatorWhitelist[operators[i]];
}
}
/// Add the operator to the service.
function register(
address signAddress,
uint256[2][] calldata blsPubKeys,
ISignatureUtils.SignatureWithSaltAndExpiry memory operatorSignature
) external onlyWhitelisted {
address _operator = msg.sender;
committee.addOperator(_operator, signAddress, blsPubKeys);
uint32 serveUntilBlock = type(uint32).max;
stakeManager.lockStakeUntil(_operator, serveUntilBlock);
avsDirectory.registerOperatorToAVS(_operator, operatorSignature);
emit OperatorRegistered(_operator, serveUntilBlock);
}
/// Add extra BlsPubKeys
function addBlsPubKeys(uint256[2][] calldata additionalBlsPubKeys) external onlyWhitelisted {
address _operator = msg.sender;
committee.addBlsPubKeys(_operator, additionalBlsPubKeys);
uint32 serveUntilBlock = type(uint32).max;
stakeManager.lockStakeUntil(_operator, serveUntilBlock);
emit OperatorRegistered(_operator, serveUntilBlock);
}
/// Subscribe the dedicated chain.
function subscribe(uint32 chainID) external onlyWhitelisted {
committee.subscribeChain(msg.sender, chainID);
emit OperatorSubscribed(msg.sender, chainID);
}
/// Unsubscribe the dedicated chain.
function unsubscribe(uint32 chainID) external onlyWhitelisted {
committee.unsubscribeChain(msg.sender, chainID);
emit OperatorUnsubscribed(msg.sender, chainID);
}
/// Deregister the operator from the service.
function deregister() external onlyWhitelisted {
address _operator = msg.sender;
(bool possible, uint256 unsubscribeBlockNumber) = committee.isUnregisterable(_operator);
require(possible, "The operator is not able to deregister");
stakeManager.lockStakeUntil(_operator, unsubscribeBlockNumber);
avsDirectory.deregisterOperatorFromAVS(_operator);
emit OperatorDeregistered(_operator);
}
function owner() public view override(OwnableUpgradeable, ILagrangeService) returns (address) {
return OwnableUpgradeable.owner();
}
// Updates the metadata URI for the AVS
function updateAVSMetadataURI(string calldata _metadataURI) public virtual onlyOwner {
avsDirectory.updateAVSMetadataURI(_metadataURI);
}
// Returns the list of strategies that the operator has potentially restaked on the AVS
function getOperatorRestakedStrategies(address operator) external view returns (address[] memory) {
return committee.getTokenListForOperator(operator);
}
// Returns the list of strategies that the AVS supports for restaking
function getRestakeableStrategies() external view returns (address[] memory) {
return voteWeigher.getTokenList();
}
}