feat: implement oracle genesis

Makefile

@@ -36,7 +36,7 @@ build-all: proto-lint proto-gen update-swagger-docs build
 ### Analyzing
 
 lint:
-	GO111MODULE=off go get github.com/golangci/golangci-lint/cmd/golangci-lint
+	#GO111MODULE=off go get github.com/golangci/golangci-lint/cmd/golangci-lint
 	golangci-lint run --timeout 5m0s --allow-parallel-runners
 	find . -name '*.go' -type f -not -path "./vendor*" -not -path "*.git*" | xargs gofmt -d -s
 	go mod verify

app/app.go

@@ -9,6 +9,9 @@ import (
 	"strings"
 
 	"github.com/cosmos/cosmos-sdk/x/authz"
+	"github.com/medibloc/panacea-core/v2/x/oracle"
+	oraclekeeper "github.com/medibloc/panacea-core/v2/x/oracle/keeper"
+	oracletypes "github.com/medibloc/panacea-core/v2/x/oracle/types"
 
 	"github.com/CosmWasm/wasmd/x/wasm"
 	wasmclient "github.com/CosmWasm/wasmd/x/wasm/client"
@@ -188,6 +191,7 @@ var (
 		aol.AppModuleBasic{},
 		did.AppModuleBasic{},
 		burn.AppModuleBasic{},
+		oracle.AppModuleBasic{},
 		wasm.AppModuleBasic{},
 		feegrantmodule.AppModuleBasic{},
 		authzmodule.AppModuleBasic{},
@@ -261,10 +265,11 @@ type App struct {
 	ScopedTransferKeeper capabilitykeeper.ScopedKeeper
 	ScopedWasmKeeper     capabilitykeeper.ScopedKeeper
 
-	aolKeeper  aolkeeper.Keeper
-	didKeeper  didkeeper.Keeper
-	burnKeeper burnkeeper.Keeper
-	wasmKeeper wasm.Keeper
+	aolKeeper    aolkeeper.Keeper
+	didKeeper    didkeeper.Keeper
+	burnKeeper   burnkeeper.Keeper
+	wasmKeeper   wasm.Keeper
+	oracleKeeper oraclekeeper.Keeper
 
 	// the module manager
 	mm *module.Manager
@@ -307,6 +312,7 @@ func New(
 		aoltypes.StoreKey,
 		didtypes.StoreKey,
 		burntypes.StoreKey,
+		oracletypes.StoreKey,
 		wasm.StoreKey,
 		feegrant.StoreKey,
 	)
@@ -421,6 +427,13 @@ func New(
 		app.BankKeeper,
 	)
 
+	app.oracleKeeper = *oraclekeeper.NewKeeper(
+		appCodec,
+		keys[oracletypes.StoreKey],
+		keys[oracletypes.MemStoreKey],
+		app.GetSubspace(oracletypes.ModuleName),
+	)
+
 	wasmDir := filepath.Join(homePath, wasm.ModuleName)
 	wasmConfig, err := wasm.ReadWasmConfig(appOpts)
 	if err != nil {
@@ -499,6 +512,7 @@ func New(
 		aol.NewAppModule(appCodec, app.aolKeeper),
 		did.NewAppModule(appCodec, app.didKeeper),
 		burn.NewAppModule(appCodec, app.burnKeeper),
+		oracle.NewAppModule(appCodec, app.oracleKeeper),
 		wasm.NewAppModule(appCodec, &app.wasmKeeper, app.StakingKeeper),
 	)
 
@@ -523,6 +537,7 @@ func New(
 		authtypes.ModuleName,
 		aoltypes.ModuleName,
 		didtypes.ModuleName,
+		oracletypes.ModuleName,
 		wasm.ModuleName,
 		banktypes.ModuleName,
 		crisistypes.ModuleName,
@@ -551,6 +566,7 @@ func New(
 		slashingtypes.ModuleName,
 		ibctransfertypes.ModuleName,
 		aoltypes.ModuleName,
+		oracletypes.ModuleName,
 		wasm.ModuleName,
 		paramstypes.ModuleName,
 		authz.ModuleName,
@@ -579,6 +595,7 @@ func New(
 		aoltypes.ModuleName,
 		didtypes.ModuleName,
 		burntypes.ModuleName,
+		oracletypes.ModuleName,
 		wasm.ModuleName,
 		paramstypes.ModuleName,
 		upgradetypes.ModuleName,
@@ -807,6 +824,7 @@ func initParamsKeeper(appCodec codec.Codec, legacyAmino *codec.LegacyAmino, key,
 	paramsKeeper.Subspace(aoltypes.ModuleName)
 	paramsKeeper.Subspace(didtypes.ModuleName)
 	paramsKeeper.Subspace(burntypes.ModuleName)
+	paramsKeeper.Subspace(oracletypes.ModuleName)
 	paramsKeeper.Subspace(wasm.ModuleName)
 
 	return paramsKeeper

proto/panacea/oracle/v2/tx.proto

@@ -47,8 +47,9 @@ message MsgApproveOracleRegistration {
 // ApproveOracleRegistration defines for oracle registration approval
 message ApproveOracleRegistration {
   string unique_id = 1;
-  string target_oracle_address = 2;
-  bytes encrypted_oracle_priv_key = 3;
+  string approved_oracle_address = 2;
+  string target_oracle_address = 3;
+  bytes encrypted_oracle_priv_key = 4;
 }
 
 // MsgApproveOracleRegistrationResponse defines the Msg/ApproveOracleRegistration

types/testsuite/suite.go

@@ -34,6 +34,8 @@ import (
 	aoltypes "github.com/medibloc/panacea-core/v2/x/aol/types"
 	burnkeeper "github.com/medibloc/panacea-core/v2/x/burn/keeper"
 	burntypes "github.com/medibloc/panacea-core/v2/x/burn/types"
+	oraclekeeper "github.com/medibloc/panacea-core/v2/x/oracle/keeper"
+	oracletypes "github.com/medibloc/panacea-core/v2/x/oracle/types"
 	"github.com/stretchr/testify/suite"
 	"github.com/tendermint/tendermint/crypto/secp256k1"
 	"github.com/tendermint/tendermint/libs/log"
@@ -65,6 +67,8 @@ type TestSuite struct {
 	TransferKeeper   ibctransferkeeper.Keeper
 	DIDMsgServer     didtypes.MsgServer
 	DIDKeeper        didkeeper.Keeper
+	OracleKeeper     oraclekeeper.Keeper
+	OracleMsgServer  oracletypes.MsgServer
 	WasmKeeper       wasm.Keeper
 	UpgradeKeeper    upgradekeeper.Keeper
 }
@@ -76,6 +80,7 @@ func (suite *TestSuite) SetupTest() {
 		banktypes.StoreKey,
 		paramstypes.StoreKey,
 		didtypes.StoreKey,
+		oracletypes.StoreKey,
 		wasm.StoreKey,
 		ibchost.StoreKey,
 		capabilitytypes.StoreKey,
@@ -202,6 +207,15 @@ func (suite *TestSuite) SetupTest() {
 		memKeys[didtypes.MemStoreKey],
 	)
 	suite.DIDMsgServer = didkeeper.NewMsgServerImpl(suite.DIDKeeper)
+
+	suite.OracleKeeper = *oraclekeeper.NewKeeper(
+		cdc.Marshaler,
+		keyParams[oracletypes.StoreKey],
+		memKeys[oracletypes.MemStoreKey],
+		paramsKeeper.Subspace(oracletypes.ModuleName),
+	)
+
+	suite.OracleMsgServer = oraclekeeper.NewMsgServerImpl(suite.OracleKeeper)
 }
 
 func (suite *TestSuite) BeforeTest(suiteName, testName string) {

x/oracle/client/cli/query.go

@@ -18,5 +18,8 @@ func GetQueryCmd(queryRoute string) *cobra.Command {
 		SuggestionsMinimumDistance: 2,
 		RunE:                       client.ValidateCmd,
 	}
+
+	cmd.AddCommand(CmdGetParams())
+
 	return cmd
 }

x/oracle/client/cli/queryParams.go

@@ -0,0 +1,34 @@
+package cli
+
+import (
+	"github.com/cosmos/cosmos-sdk/client"
+	"github.com/cosmos/cosmos-sdk/client/flags"
+	"github.com/medibloc/panacea-core/v2/x/oracle/types"
+	"github.com/spf13/cobra"
+)
+
+func CmdGetParams() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "params",
+		Short: "Query params of oracle module",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			clientCtx, err := client.GetClientQueryContext(cmd)
+			if err != nil {
+				return err
+			}
+
+			queryClient := types.NewQueryClient(clientCtx)
+
+			res, err := queryClient.Params(cmd.Context(), &types.QueryOracleParamsRequest{})
+			if err != nil {
+				return err
+			}
+
+			return clientCtx.PrintProto(res)
+		},
+	}
+
+	flags.AddQueryFlagsToCmd(cmd)
+
+	return cmd
+}

x/oracle/client/cli/tx.go

@@ -18,5 +18,7 @@ func GetTxCmd() *cobra.Command {
 		RunE:                       client.ValidateCmd,
 	}
 
+	cmd.AddCommand(CmdRegisterOracle())
+
 	return cmd
 }

x/oracle/client/cli/txRegisterOracle.go

@@ -0,0 +1,83 @@
+package cli
+
+import (
+	"encoding/base64"
+	"encoding/hex"
+	"fmt"
+	"strconv"
+
+	"github.com/cosmos/cosmos-sdk/client"
+	"github.com/cosmos/cosmos-sdk/client/flags"
+	"github.com/cosmos/cosmos-sdk/client/tx"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	"github.com/medibloc/panacea-core/v2/x/oracle/types"
+	"github.com/spf13/cobra"
+)
+
+func CmdRegisterOracle() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "register-oracle [unique ID] [node public key] [node public key remote report] [trusted block height] [trusted block hash] [endpoint] [oracle's commission rate]",
+		Short: "Register a new oracle",
+		Args:  cobra.ExactArgs(7),
+		RunE: func(cmd *cobra.Command, args []string) error {
+			clientCtx, err := client.GetClientTxContext(cmd)
+			if err != nil {
+				return err
+			}
+
+			oracleAddress := clientCtx.GetFromAddress().String()
+			nodePubKey, err := base64.StdEncoding.DecodeString(args[1])
+			if err != nil {
+				return err
+			}
+
+			nodePubKeyRemoteReport, err := base64.StdEncoding.DecodeString(args[2])
+			if err != nil {
+				return err
+			}
+
+			trustedBlockHeight, err := strconv.ParseInt(args[3], 10, 64)
+			if err != nil {
+				return err
+			}
+
+			trustedBlockHash, err := hex.DecodeString(args[4])
+			if err != nil {
+				return err
+			}
+
+			endpoint := args[5]
+
+			oracleCommissionRateStr := args[6]
+
+			if len(oracleCommissionRateStr) == 0 {
+				return fmt.Errorf("oracleCommissionRate is empty")
+			}
+
+			oracleCommissionRate, err := sdk.NewDecFromStr(oracleCommissionRateStr)
+			if err != nil {
+				return err
+			}
+
+			msg := types.NewMsgRegisterOracle(
+				args[0],
+				oracleAddress,
+				nodePubKey,
+				nodePubKeyRemoteReport,
+				trustedBlockHeight,
+				trustedBlockHash,
+				endpoint,
+				oracleCommissionRate,
+			)
+			if err := msg.ValidateBasic(); err != nil {
+				return err
+			}
+
+			return tx.GenerateOrBroadcastTxCLI(clientCtx, cmd.Flags(), msg)
+		},
+	}
+
+	flags.AddTxFlagsToCmd(cmd)
+
+	return cmd
+}

x/oracle/genesis.go

@@ -9,12 +9,38 @@ import (
 // InitGenesis initializes the capability module's state from a provided genesis
 // state.
 func InitGenesis(ctx sdk.Context, k keeper.Keeper, genState types.GenesisState) {
-	//TODO implement me
-	panic("implement me")
+	for _, oracle := range genState.Oracles {
+		if err := k.SetOracle(ctx, &oracle); err != nil {
+			panic(err)
+		}
+	}
+
+	for _, oracleRegistration := range genState.OracleRegistrations {
+		if err := k.SetOracleRegistration(ctx, &oracleRegistration); err != nil {
+			panic(err)
+		}
+	}
+
+	k.SetParams(ctx, genState.Params)
 }
 
 // ExportGenesis returns the capability module's exported genesis.
 func ExportGenesis(ctx sdk.Context, k keeper.Keeper) *types.GenesisState {
-	//TODO implement me
-	panic("implement me")
+	genesis := types.DefaultGenesis()
+
+	oracles, err := k.GetAllOracleList(ctx)
+	if err != nil {
+		panic(err)
+	}
+	genesis.Oracles = oracles
+
+	oracleRegistrations, err := k.GetAllOracleRegistrationList(ctx)
+	if err != nil {
+		panic(err)
+	}
+	genesis.OracleRegistrations = oracleRegistrations
+
+	genesis.Params = k.GetParams(ctx)
+
+	return genesis
 }