staker source realm

 1const (
 2	// Basic configuration
 3	StoreKeyUnDelegationLockupPeriod = "unDelegationLockupPeriod"
 4	StoreKeyTotalDelegatedAmount     = "totalDelegatedAmount"
 5	StoreKeyTotalLockedAmount        = "totalLockedAmount"
 6
 7	// Counters
 8	StoreKeyDelegationNextID = "delegationNextID"
 9
10	// Complex data structures
11	StoreKeyDelegations            = "delegations"            // BPTree of delegations
12	StoreKeyTotalDelegationHistory = "totalDelegationHistory" // UintTree: timestamp -> int64 (cumulative total)
13	StoreKeyUserDelegationHistory  = "userDelegationHistory"  // BPTree: address -> *UintTree[timestamp -> int64]
14
15	// Manager states
16	StoreKeyEmissionRewardManager    = "emissionRewardManager"
17	StoreKeyProtocolFeeRewardManager = "protocolFeeRewardManager"
18	StoreKeyDelegationManager        = "delegationManager"
19	StoreKeyLaunchpadProjectDeposits = "launchpadProjectDeposits"
20)

1const ErrSpoofedRealm = "rlm does not match the current crossing frame"

1const (
2	DelegateType   DelegationType = "DELEGATE"
3	UnDelegateType DelegationType = "UNDELEGATE"
4)

1func CleanStakerDelegationSnapshotByAdmin(cur realm, threshold int64, target address)

1func CollectEmissionReward(cur realm)

1func CollectEmissionRewardFromLaunchPad(cur realm, to address)

1func CollectProtocolFeeReward(cur realm, tokenPath string)

1func CollectProtocolFeeRewardFromLaunchPad(cur realm, to address, tokenPath string)

1func CollectReward(cur realm)

1func CollectRewardFromLaunchPad(cur realm, to address)

1func CollectUndelegatedGns(cur realm) int64

1func DecodeInt64(s string) int64

1func DecodeUint(s string) uint64

1func Delegate(cur realm, to address, amount int64, referrer string) int64

1func EncodeInt64(num int64) string

1func EncodeUint(num uint64) string

1func ExistsDelegation(delegationID int64) bool

1func GetClaimableRewardByAddress(addr address) (int64, map[string]int64, error)

1func GetClaimableRewardByLaunchpad(addr address) (int64, map[string]int64, error)

1func GetClaimableRewardByRewardID(rewardID string) (int64, map[string]int64, error)

1func GetCollectableWithdrawAmount(delegationID int64) int64

1func GetDelegationCount() int

1func GetDelegationIDs(offset, count int) []int64

1func GetDelegationWithdrawCount(delegationID int64) int

1func GetDelegatorDelegateeCount(delegator address) int

1func GetEmissionAccumulatedTimestamp() int64

1func GetEmissionAccumulatedX128PerStake() *u256.Uint

1func GetEmissionDistributedAmount() int64

1func GetImplementationPackagePath() string

1func GetLaunchpadProjectDeposit(projectAddr string) (int64, bool)

1func GetProtocolFeeAccumulatedTimestamp() int64

1func GetProtocolFeeAccumulatedX128PerStake(tokenPath string) *u256.Uint

1func GetProtocolFeeAmount(tokenPath string) int64

1func GetTotalDelegated() int64

1func GetTotalDelegationAmountAtSnapshot(snapshotTime int64) (int64, bool)

1func GetTotalLockedAmount() int64

1func GetTotalxGnsSupply() int64

1func GetUnDelegationLockupPeriod() int64

1func GetUserDelegationAmountAtSnapshot(userAddr address, snapshotTime int64) (int64, bool)

1func GetUserDelegationCount(delegator address, delegatee address) int

1func GetUserDelegationIDs(delegator address, delegatee address) []int64

1func HasDelegationSnapshotsKey() bool

1func NewDelegationTree() *bptree.BPTree

1func NewUserDelegationTree() *bptree.BPTree

1func Redelegate(cur realm, delegatee, newDelegatee address, amount int64) int64

1func RegisterInitializer(cur realm, initializer func(_ int, rlm realm, govStakerStore IGovStakerStore) IGovStaker)

1func SetAmountByProjectWallet(cur realm, addr address, amount int64, add bool)

1func SetUnDelegationLockupPeriodByAdmin(cur realm, period int64)

1func Undelegate(cur realm, from address, amount int64) int64

1func UpgradeImpl(cur realm, packagePath string)

1func NewCounter() *Counter

1func GetDelegation(delegationID int64) (*Delegation, error)

1func NewDelegation(
2	id int64,
3	delegateFrom, delegateTo address,
4	delegateAmount, createdHeight, createdAt int64,
5) *Delegation

1func NewDelegationManager() *DelegationManager

1func GetDelegationWithdraws(delegationID int64, offset, count int) ([]DelegationWithdraw, error)

1func NewDelegationWithdraw(
2	delegationID,
3	unDelegateAmount,
4	createdHeight,
5	createdAt,
6	unDelegationLockupPeriod int64,
7) DelegationWithdraw

1func NewDelegationWithdrawWithoutLockup(
2	delegationID,
3	unDelegateAmount,
4	createdHeight,
5	createdAt int64,
6) DelegationWithdraw

1func NewEmissionRewardManager() *EmissionRewardManager

1func NewEmissionRewardState(accumulatedRewardX128PerStake *u256.Uint) *EmissionRewardState

1func NewGovStakerStore(kvStore store.KVStore) IGovStakerStore

1func NewLaunchpadProjectDeposits() *LaunchpadProjectDeposits

1func NewProtocolFeeRewardManager() *ProtocolFeeRewardManager

1func NewProtocolFeeRewardState(accumulatedProtocolFeeX128PerStake map[string]*u256.Uint) *ProtocolFeeRewardState

1func NewUintTree() *UintTree

1type Counter struct {
2	id int64
3}

 1type Delegation struct {
 2	id               int64
 3	delegateAmount   int64
 4	unDelegateAmount int64
 5	collectedAmount  int64
 6	delegateFrom     address
 7	delegateTo       address
 8	createdHeight    int64
 9	createdAt        int64
10	withdraws        []DelegationWithdraw
11}

1type DelegationManager struct {
2	// userDelegations maps delegator address -> *bptree.BPTree (delegatee address -> list of delegation IDs)
3	// Using BPTree instead of map to handle unbounded growth of delegators efficiently
4	userDelegations *bptree.BPTree
5}

1type DelegationType string

 1type DelegationWithdraw struct {
 2	// delegationID is the unique identifier of the associated delegation
 3	delegationID int64
 4	// unDelegateAmount is the total amount that was undelegated
 5	unDelegateAmount int64
 6	// unDelegatedHeight is the height when the undelegation occurred
 7	unDelegatedHeight int64
 8	// unDelegatedAt is the timestamp when the undelegation occurred
 9	unDelegatedAt int64
10	// collectedAmount is the amount that has already been collected
11	collectedAmount int64
12	// collectableTime is the timestamp when collection becomes available
13	collectableTime int64
14	// collectedAt is the timestamp when collection occurred
15	collectedAt int64
16	// collected indicates whether the withdrawal has been fully collected
17	collected bool
18}

 1type EmissionRewardManager struct {
 2	// rewardStates maps address to EmissionRewardState for tracking individual staker rewards
 3	rewardStates *bptree.BPTree // address -> EmissionRewardState
 4
 5	// accumulatedRewardX128PerStake tracks the cumulative reward per unit of stake with 128-bit precision
 6	accumulatedRewardX128PerStake *u256.Uint
 7	// distributedAmount tracks the total amount of rewards distributed
 8	distributedAmount int64
 9	// accumulatedTimestamp tracks the last timestamp when rewards were accumulated
10	accumulatedTimestamp int64
11	// totalStakedAmount tracks the total amount of tokens staked in the system
12	totalStakedAmount int64
13}

 1type EmissionRewardState struct {
 2	// rewardDebtX128 represents the reward debt with 128-bit precision scaling
 3	// Used to calculate rewards earned since the last update
 4	rewardDebtX128 *u256.Uint
 5	// accumulatedRewardAmount is the total rewards accumulated but not yet claimed
 6	accumulatedRewardAmount int64
 7	// accumulatedTimestamp is the last timestamp when rewards were accumulated
 8	accumulatedTimestamp int64
 9	// claimedRewardAmount is the total amount of rewards that have been claimed
10	claimedRewardAmount int64
11	// claimedTimestamp is the last timestamp when rewards were claimed
12	claimedTimestamp int64
13	// stakedAmount is the current amount of tokens staked by this address
14	stakedAmount int64
15}

1type IGovStaker interface {
2	IGovStakerDelegation
3	IGovStakerReward
4	IGovStakerGetter
5	IGovStakerAdmin
6}

1type IGovStakerAdmin interface {
2	CleanStakerDelegationSnapshotByAdmin(_ int, rlm realm, snapshotTime int64, target address)
3	SetUnDelegationLockupPeriodByAdmin(_ int, rlm realm, period int64)
4}

1type IGovStakerDelegation interface {
2	// Main delegation operations
3	Delegate(_ int, rlm realm, to address, amount int64, referrer string) int64
4	Undelegate(_ int, rlm realm, from address, amount int64) int64
5	Redelegate(_ int, rlm realm, delegatee, newDelegatee address, amount int64) int64
6	CollectUndelegatedGns(_ int, rlm realm) int64
7}

 1type IGovStakerGetter interface {
 2	// Store data getters
 3	GetUnDelegationLockupPeriod() int64
 4
 5	// Delegation getters
 6	GetTotalxGnsSupply() int64
 7	GetTotalDelegated() int64
 8	GetTotalLockedAmount() int64
 9	GetDelegationCount() int
10	GetDelegationIDs(offset, count int) []int64
11	ExistsDelegation(delegationID int64) bool
12	GetDelegation(delegationID int64) (*Delegation, error)
13	GetDelegatorDelegateeCount(delegator address) int
14	GetDelegatorDelegateeAddresses(delegator address, offset, count int) []address
15	GetUserDelegationCount(delegator address, delegatee address) int
16	GetUserDelegationIDs(delegator address, delegatee address) []int64
17	HasDelegationSnapshotsKey() bool
18	GetTotalDelegationAmountAtSnapshot(snapshotTime int64) (int64, bool)
19	GetUserDelegationAmountAtSnapshot(userAddr address, snapshotTime int64) (int64, bool)
20
21	// Reward getters
22	GetClaimableRewardByAddress(addr address) (int64, map[string]int64, error)
23	GetClaimableRewardByLaunchpad(addr address) (int64, map[string]int64, error)
24	GetClaimableRewardByRewardID(rewardID string) (int64, map[string]int64, error)
25
26	// Launchpad getters
27	GetLaunchpadProjectDeposit(projectAddr string) (int64, bool)
28
29	// Withdraw getters
30	GetDelegationWithdrawCount(delegationID int64) int
31	GetDelegationWithdraws(delegationID int64, offset, count int) ([]DelegationWithdraw, error)
32	GetCollectableWithdrawAmount(delegationID int64) int64
33
34	// Protocol fee reward getters
35	GetProtocolFeeAccumulatedX128PerStake(tokenPath string) *uint256.Uint
36	GetProtocolFeeAmount(tokenPath string) int64
37	GetProtocolFeeAccumulatedTimestamp() int64
38
39	// Emission reward getters
40	GetEmissionAccumulatedX128PerStake() *uint256.Uint
41	GetEmissionDistributedAmount() int64
42	GetEmissionAccumulatedTimestamp() int64
43}

 1type IGovStakerReward interface {
 2	// Reward collection
 3	CollectReward(_ int, rlm realm)
 4	CollectEmissionReward(_ int, rlm realm)
 5	CollectProtocolFeeReward(_ int, rlm realm, tokenPath string)
 6	CollectRewardFromLaunchPad(_ int, rlm realm, to address)
 7	CollectEmissionRewardFromLaunchPad(_ int, rlm realm, to address)
 8	CollectProtocolFeeRewardFromLaunchPad(_ int, rlm realm, to address, tokenPath string)
 9	SetAmountByProjectWallet(_ int, rlm realm, addr address, amount int64, add bool)
10}

 1type IGovStakerStore interface {
 2	// Basic configuration
 3	HasUnDelegationLockupPeriodStoreKey() bool
 4	GetUnDelegationLockupPeriod() int64
 5	SetUnDelegationLockupPeriod(_ int, rlm realm, period int64) error
 6
 7	HasTotalDelegatedAmountStoreKey() bool
 8	GetTotalDelegatedAmount() int64
 9	SetTotalDelegatedAmount(_ int, rlm realm, amount int64) error
10
11	HasTotalLockedAmountStoreKey() bool
12	GetTotalLockedAmount() int64
13	SetTotalLockedAmount(_ int, rlm realm, amount int64) error
14
15	// Delegation management
16	HasDelegation(id int64) bool
17	GetDelegation(id int64) (*Delegation, bool)
18	SetDelegation(_ int, rlm realm, id int64, delegation *Delegation) error
19	RemoveDelegation(_ int, rlm realm, id int64) error
20
21	HasDelegationsStoreKey() bool
22	SetDelegations(_ int, rlm realm, delegations *bptree.BPTree) error
23	GetAllDelegations() *bptree.BPTree
24
25	HasDelegationCounterStoreKey() bool
26	GetDelegationCounter() *Counter
27	SetDelegationCounter(_ int, rlm realm, counter *Counter) error
28
29	// Total delegation history (timestamp -> int64)
30	HasTotalDelegationHistoryStoreKey() bool
31	GetTotalDelegationHistory() *UintTree
32	SetTotalDelegationHistory(_ int, rlm realm, history *UintTree) error
33
34	// User delegation history (address -> *UintTree[timestamp -> int64])
35	HasUserDelegationHistoryStoreKey() bool
36	GetUserDelegationHistory() *bptree.BPTree
37	SetUserDelegationHistory(_ int, rlm realm, history *bptree.BPTree) error
38
39	// Manager states
40	HasEmissionRewardManagerStoreKey() bool
41	GetEmissionRewardManager() *EmissionRewardManager
42	SetEmissionRewardManager(_ int, rlm realm, manager *EmissionRewardManager) error
43
44	HasProtocolFeeRewardManagerStoreKey() bool
45	GetProtocolFeeRewardManager() *ProtocolFeeRewardManager
46	SetProtocolFeeRewardManager(_ int, rlm realm, manager *ProtocolFeeRewardManager) error
47
48	HasDelegationManagerStoreKey() bool
49	GetDelegationManager() *DelegationManager
50	SetDelegationManager(_ int, rlm realm, manager *DelegationManager) error
51
52	HasLaunchpadProjectDepositsStoreKey() bool
53	GetLaunchpadProjectDeposits() *LaunchpadProjectDeposits
54	SetLaunchpadProjectDeposits(_ int, rlm realm, deposits *LaunchpadProjectDeposits) error
55}