Incoming value limiting with exponent (with migration)

CHANGELOG.md

@@ -67,6 +67,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Fixed
 
+* [#757](https://github.com/allora-network/allora-chain/pull/757) Incoming value limiting
+
 ### Security
 
 # v0.9.0

Dockerfile.upgrade

@@ -2,8 +2,8 @@ FROM golang:1.22-bookworm AS builder
 
 ENV GO111MODULE=on
 ENV GOMODCACHE=/gocache
-ENV BASELINE_VERSION_TAG=v0.8.0 
-ENV UPGRADE_VERSION_TAG=v0.9.0
+ENV BASELINE_VERSION_TAG=v0.9.0 
+ENV UPGRADE_VERSION_TAG=v0.10.0
 ENV GIT_STASH_MESSAGE="Docker build"
 
 

app/upgrades.go

@@ -6,6 +6,7 @@ import (
 	upgradetypes "cosmossdk.io/x/upgrade/types"
 	"github.com/allora-network/allora-chain/app/keepers"
 	"github.com/allora-network/allora-chain/app/upgrades"
+	"github.com/allora-network/allora-chain/app/upgrades/v0_10_0"
 	"github.com/allora-network/allora-chain/app/upgrades/v0_3_0"
 	"github.com/allora-network/allora-chain/app/upgrades/v0_4_0"
 	"github.com/allora-network/allora-chain/app/upgrades/v0_5_0"
@@ -23,6 +24,7 @@ var upgradeHandlers = []upgrades.Upgrade{
 	v0_7_0.Upgrade,
 	v0_8_0.Upgrade,
 	v0_9_0.Upgrade,
+	v0_10_0.Upgrade,
 	// Add more upgrade handlers here
 	// ...
 }

app/upgrades/v0_10_0/upgrades.go

@@ -0,0 +1,40 @@
+package v0_10_0 //nolint:revive // var-naming: don't use an underscore in package name
+
+import (
+	"context"
+
+	storetypes "cosmossdk.io/store/types"
+	upgradetypes "cosmossdk.io/x/upgrade/types"
+	"github.com/allora-network/allora-chain/app/keepers"
+	"github.com/allora-network/allora-chain/app/upgrades"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	"github.com/cosmos/cosmos-sdk/types/module"
+)
+
+const (
+	UpgradeName = "v0.10.0"
+)
+
+var Upgrade = upgrades.Upgrade{
+	UpgradeName:          UpgradeName,
+	CreateUpgradeHandler: CreateUpgradeHandler,
+	StoreUpgrades:        storetypes.StoreUpgrades{Added: nil, Renamed: nil, Deleted: nil},
+}
+
+func CreateUpgradeHandler(
+	moduleManager *module.Manager,
+	configurator module.Configurator,
+	keepers *keepers.AppKeepers,
+) upgradetypes.UpgradeHandler {
+	return func(ctx context.Context, plan upgradetypes.Plan, vm module.VersionMap) (module.VersionMap, error) {
+		sdkCtx := sdk.UnwrapSDKContext(ctx)
+		sdkCtx.Logger().Info("RUN MIGRATIONS")
+		vm, err := moduleManager.RunMigrations(ctx, configurator, vm)
+		if err != nil {
+			return vm, err
+		}
+
+		sdkCtx.Logger().Info("MIGRATIONS COMPLETED")
+		return vm, nil
+	}
+}

test/integration/update_params_test.go

@@ -96,6 +96,7 @@ func UpdateParamsChecks(m testCommon.TestConfig) {
 			GlobalAdminWhitelistAppended:        nil,
 			MaxWhitelistInputArrayLength:        nil,
 			MinWeightThresholdForStdnorm:        nil,
+			DataLimitExponent:                   nil,
 		},
 	}
 	txResp, err := m.Client.BroadcastTx(ctx, m.AliceAcc, updateParamRequest)
@@ -163,6 +164,7 @@ func UpdateParamsChecks(m testCommon.TestConfig) {
 			GlobalAdminWhitelistAppended:        nil,
 			MaxWhitelistInputArrayLength:        nil,
 			MinWeightThresholdForStdnorm:        nil,
+			DataLimitExponent:                   nil,
 		},
 	}
 	_, err = m.Client.BroadcastTx(ctx, m.BobAcc, updateParamRequest)
@@ -234,6 +236,7 @@ func UpdateParamsChecks(m testCommon.TestConfig) {
 			GlobalAdminWhitelistAppended:        nil,
 			MaxWhitelistInputArrayLength:        nil,
 			MinWeightThresholdForStdnorm:        nil,
+			DataLimitExponent:                   nil,
 		},
 	}
 	txResp, err = m.Client.BroadcastTx(ctx, m.AliceAcc, updateParamRequest)

test/integration/upgrade_test.go

@@ -6,7 +6,7 @@ import (
 	"time"
 
 	upgradetypes "cosmossdk.io/x/upgrade/types"
-	v0_9_0 "github.com/allora-network/allora-chain/app/upgrades/v0_9_0"
+	v0_10_0 "github.com/allora-network/allora-chain/app/upgrades/v0_10_0"
 	testCommon "github.com/allora-network/allora-chain/test/common"
 	sdktypes "github.com/cosmos/cosmos-sdk/types"
 	authtypes "github.com/cosmos/cosmos-sdk/x/auth/types"
@@ -57,7 +57,7 @@ func voteOnProposal(m testCommon.TestConfig, proposalId uint64) {
 // propose an upgrade to the v0.5.0 software version
 func proposeUpgrade(m testCommon.TestConfig) (proposalId uint64, proposalHeight int64) {
 	ctx := context.Background()
-	name := v0_9_0.UpgradeName
+	name := v0_10_0.UpgradeName
 	summary := "Upgrade to " + name + " software version"
 
 	currHeight, err := m.Client.BlockHeight(ctx)
@@ -162,7 +162,7 @@ func getAppliedVersionHeight(m testCommon.TestConfig, version string) int64 {
 }
 
 func UpgradeChecks(m testCommon.TestConfig) {
-	versionName := v0_9_0.UpgradeName
+	versionName := v0_10_0.UpgradeName
 	m.T.Log("--- Getting Emissions Module Version Before Upgrade ---")
 	emissionsVersionBefore := getEmissionsVersion(m)
 	m.T.Logf("--- Propose Upgrade to %s software version from v0 (%d) ---", versionName, emissionsVersionBefore)

x/emissions/README.md

@@ -13,7 +13,7 @@ docker
 go mod tidy
 
 # rebuild the autogenerated protobuf files
-make proto-gen
+make proto-all
 
 # build the module, making sure the source compiles
 make
@@ -25,5 +25,5 @@ cd ../minimal-chain
 go mod tidy
 make install
 make init
-minid start
+allorad start
 ```

x/emissions/api/emissions/v8/codec.go

@@ -0,0 +1,47 @@
+package emissionsv8
+
+import (
+	"github.com/cosmos/cosmos-sdk/codec"
+	"github.com/cosmos/cosmos-sdk/codec/types"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+)
+
+// nolint: exhaustruct
+func RegisterInterfaces(registry types.InterfaceRegistry) {
+	registry.RegisterImplementations((*sdk.Msg)(nil),
+		&UpdateParamsRequest{},
+		&CreateNewTopicRequest{},
+		&RegisterRequest{},
+		&RemoveRegistrationRequest{},
+		&AddStakeRequest{},
+		&RemoveStakeRequest{},
+		&CancelRemoveStakeRequest{},
+		&DelegateStakeRequest{},
+		&RewardDelegateStakeRequest{},
+		&RemoveDelegateStakeRequest{},
+		&CancelRemoveDelegateStakeRequest{},
+		&FundTopicRequest{},
+		&AddToWhitelistAdminRequest{},
+		&RemoveFromWhitelistAdminRequest{},
+		&InsertWorkerPayloadRequest{},
+		&InsertReputerPayloadRequest{},
+		&AddToGlobalWhitelistRequest{},
+		&RemoveFromGlobalWhitelistRequest{},
+		&EnableTopicWorkerWhitelistRequest{},
+		&DisableTopicWorkerWhitelistRequest{},
+		&EnableTopicReputerWhitelistRequest{},
+		&DisableTopicReputerWhitelistRequest{},
+		&AddToTopicCreatorWhitelistRequest{},
+		&RemoveFromTopicCreatorWhitelistRequest{},
+		&AddToTopicWorkerWhitelistRequest{},
+		&RemoveFromTopicWorkerWhitelistRequest{},
+		&AddToTopicReputerWhitelistRequest{},
+		&RemoveFromTopicReputerWhitelistRequest{},
+	)
+}
+
+// So we need to register types like:
+func RegisterTypes(registry *codec.LegacyAmino) {
+	// Internal types used by requests
+	registry.RegisterConcrete(&OptionalParams{}, "emissions/v8/OptionalParams", nil) //nolint:exhaustruct
+}