feat: add reward allocation to stakers

imua-xyz · Aug 14, 2024 · fd44a24 · fd44a24
1 parent 5b8364e
commit fd44a24
Show file tree

Hide file tree

Showing 29 changed files with 447 additions and 244 deletions.
diff --git a/app/ante/cosmos/authz.go b/app/ante/cosmos/authz.go
@@ -28,6 +28,7 @@ func NewAuthzLimiterDecorator(disabledMsgTypes ...string) AuthzLimiterDecorator
 
 func (ald AuthzLimiterDecorator) AnteHandle(ctx sdk.Context, tx sdk.Tx, simulate bool, next sdk.AnteHandler) (newCtx sdk.Context, err error) {
 	if err := ald.checkDisabledMsgs(tx.GetMsgs(), false, 1); err != nil {
+		// nolint:govet
 		return ctx, errorsmod.Wrapf(errortypes.ErrUnauthorized, err.Error())
 	}
 	return next(ctx, tx, simulate)

diff --git a/precompiles/avs/avs_test.go b/precompiles/avs/avs_test.go
@@ -141,7 +141,6 @@ func (s *AVSManagerPrecompileSuite) TestRegisterAVS() {
 	for _, tc := range testcases {
 		tc := tc
 		s.Run(tc.name, func() {
-
 			baseFee := s.App.FeeMarketKeeper.GetBaseFee(s.Ctx)
 
 			// malleate testcase

diff --git a/precompiles/avs/query_test.go b/precompiles/avs/query_test.go
@@ -2,10 +2,11 @@ package avs_test
 
 import (
 	"fmt"
+	"math/big"
+
 	avsManagerPrecompile "github.com/ExocoreNetwork/exocore/precompiles/avs"
 	exocmn "github.com/ExocoreNetwork/exocore/precompiles/common"
 	"github.com/ExocoreNetwork/exocore/x/operator/types"
-	"math/big"
 
 	"github.com/ethereum/go-ethereum/core/vm"
 )
@@ -102,7 +103,6 @@ func (s *AVSManagerPrecompileSuite) TestGetOptedInOperatorAccAddrs() {
 				s.Require().NoError(err, "failed to unpack output", err)
 				s.Require().Equal(1, len(out))
 				s.Require().Equal(operatorAddress, out[0])
-
 			},
 			100000,
 			false,

diff --git a/precompiles/testutil/logs.go b/precompiles/testutil/logs.go
@@ -38,6 +38,7 @@ func CheckLogs(logArgs LogCheckArgs) error {
 		)
 	}
 
+	// nolint:govet
 	if err := CheckVMError(logArgs.Res, logArgs.ErrContains); err != nil {
 		return err
 	}

diff --git a/proto/buf.gen.pulsar.yaml b/proto/buf.gen.pulsar.yaml
diff --git a/proto/buf.gen.sta.yaml b/proto/buf.gen.sta.yaml
diff --git a/proto/buf.gen.ts.yaml b/proto/buf.gen.ts.yaml
diff --git a/proto/exocore/feedistribute/v1/distribution.proto b/proto/exocore/feedistribute/v1/distribution.proto
@@ -67,6 +67,17 @@ message ValidatorOutstandingRewards {
   ];
 }
 
+// StakerOutstandingRewards represents outstanding (un-withdrawn) rewards
+// for a staker inexpensive to track, allows simple sanity checks.
+message StakerOutstandingRewards {
+  // rewards represents the rewards for the operator
+  repeated cosmos.base.v1beta1.DecCoin rewards = 1 [
+    (gogoproto.castrepeated) = "github.com/cosmos/cosmos-sdk/types.DecCoins",
+    (gogoproto.nullable) = false,
+    (amino.dont_omitempty) = true
+  ];
+}
+
 // FeePool is the global fee pool for distribution.
 // It holds decimal coins. Once whole those coins can be burned or distributed to the community pool.
 message FeePool {

diff --git a/testutil/abci.go b/testutil/abci.go
@@ -191,6 +191,7 @@ func BroadcastTxBytes(app *app.ExocoreApp, txEncoder sdk.TxEncoder, tx sdk.Tx) (
 	req := abci.RequestDeliverTx{Tx: bz}
 	res := app.BaseApp.DeliverTx(req)
 	if res.Code != 0 {
+		// nolint:govet
 		return abci.ResponseDeliverTx{}, errorsmod.Wrapf(errortypes.ErrInvalidRequest, res.Log)
 	}
 
@@ -238,6 +239,7 @@ func checkTxBytes(app *app.ExocoreApp, txEncoder sdk.TxEncoder, tx sdk.Tx) (abci
 	req := abci.RequestCheckTx{Tx: bz}
 	res := app.BaseApp.CheckTx(req)
 	if res.Code != 0 {
+		// nolint:govet
 		return abci.ResponseCheckTx{}, errorsmod.Wrapf(errortypes.ErrInvalidRequest, res.Log)
 	}
 

diff --git a/x/assets/types/tx.pb.gw.go b/x/assets/types/tx.pb.gw.go
diff --git a/x/avs/keeper/avs_test.go b/x/avs/keeper/avs_test.go
@@ -56,7 +56,6 @@ func (suite *AVSTestSuite) TestAVS() {
 	suite.Equal(found, true)
 	suite.Equal(epoch.CurrentEpoch, int64(2))
 	suite.CommitAfter(48*time.Hour + time.Nanosecond)
-
 }
 
 func (suite *AVSTestSuite) TestAVSInfoUpdate_Register() {
@@ -157,5 +156,4 @@ func (suite *AVSTestSuite) TestAVSInfoUpdateWithOperator_Register() {
 
 	err = suite.App.AVSManagerKeeper.OperatorOptAction(suite.Ctx, operatorParams)
 	suite.NoError(err)
-
 }
diff --git a/x/avs/types/query.pb.gw.go b/x/avs/types/query.pb.gw.go
diff --git a/x/avs/types/tx.pb.gw.go b/x/avs/types/tx.pb.gw.go
diff --git a/x/delegation/keeper/delegation_state.go b/x/delegation/keeper/delegation_state.go
@@ -237,7 +237,7 @@ func (k *Keeper) DeleteStakersListForOperator(ctx sdk.Context, operator, assetID
 	return nil
 }
 
-func (k *Keeper) GetStakersByOperator(ctx sdk.Context, operator, assetID string) (delegationtype.StakerList, error) {
+func (k Keeper) GetStakersByOperator(ctx sdk.Context, operator, assetID string) (delegationtype.StakerList, error) {
 	store := prefix.NewStore(ctx.KVStore(k.storeKey), delegationtype.KeyPrefixStakersByOperator)
 	Key := assetstype.GetJoinedStoreKey(operator, assetID)
 	value := store.Get(Key)
-Original file line number
+Diff line change
@@ Expand Up / @@ -38,6 +38,7 @@ func CheckLogs(logArgs LogCheckArgs) error { @@
     		)
     	}
+    	// nolint:govet
     	if err := CheckVMError(logArgs.Res, logArgs.ErrContains); err != nil {
     		return err
     	}
@@ Expand Down @@