feat: add oracle module

CHANGELOG.md

@@ -52,6 +52,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 * [#801](https://github.com/NibiruChain/nibiru/pull/801) - remove unused pair constants
 * [#788](https://github.com/NibiruChain/nibiru/pull/788) - add --overwrite flag to the nibid init call of localnet.sh
 
+### Features
+* [#791](https://github.com/NibiruChain/nibiru/pull/791) Add the x/oracle module
+
 ## [v0.12.1](https://github.com/NibiruChain/nibiru/releases/tag/v0.12.1) - 2022-08-04
 
 * [#796](https://github.com/NibiruChain/nibiru/pull/796) - fix bug that caused that epochKeeper was nil when running epoch hook from Perp module

app/ante.go

@@ -13,7 +13,9 @@ type AnteHandlerOptions struct {
 	IBCKeeper *ibckeeper.Keeper
 }
 
-/* NewAnteHandler returns and AnteHandler that checks and increments sequence
+/*
+	NewAnteHandler returns and AnteHandler that checks and increments sequence
+
 numbers, checks signatures and account numbers, and deducts fees from the first signer.
 */
 func NewAnteHandler(options AnteHandlerOptions) (sdk.AnteHandler, error) {

app/export.go

@@ -46,7 +46,8 @@ func (app *NibiruApp) ExportAppStateAndValidators(
 
 // prepare for fresh start at zero height
 // NOTE zero height genesis is a temporary feature which will be deprecated
-//      in favor of export at a block height
+//
+//	in favor of export at a block height
 func (app *NibiruApp) prepForZeroHeightGenesis(ctx sdk.Context, jailAllowedAddrs []string) {
 	applyAllowedAddrs := false
 

app/ibc_test.go

@@ -23,8 +23,11 @@ import (
 	"github.com/NibiruChain/nibiru/x/testutil/testapp"
 )
 
-/* SetupTestingApp returns the TestingApp and default genesis state used to
-   initialize the testing app. */
+/*
+SetupTestingApp returns the TestingApp and default genesis state used to
+
+	initialize the testing app.
+*/
 func SetupNibiruTestingApp() (
 	testingApp ibctesting.TestingApp,
 	defaultGenesis map[string]json.RawMessage,
@@ -86,11 +89,13 @@ func TestIBCTestSuite(t *testing.T) {
 	suite.Run(t, new(IBCTestSuite))
 }
 
-/* NewIBCTestingTransferPath returns a "path" for testing.
-   A path contains two endpoints, 'EndpointA' and 'EndpointB' that correspond
-   to the order of the chains passed into the ibctesting.NewPath function.
-   A path is a pointer, and its values will be filled in as necessary during
-   the setup portion of testing.
+/*
+NewIBCTestingTransferPath returns a "path" for testing.
+
+	A path contains two endpoints, 'EndpointA' and 'EndpointB' that correspond
+	to the order of the chains passed into the ibctesting.NewPath function.
+	A path is a pointer, and its values will be filled in as necessary during
+	the setup portion of testing.
 */
 func NewIBCTestingTransferPath(
 	chainA, chainB *ibctesting.TestChain,

cmd/nibid/cmd/root.go

@@ -147,10 +147,11 @@ commands, then builds the rosetta root command given a protocol buffers
 serializer/deserializer.
 
 Args:
-  rootCmd: The root command called once in the 'main.go' of 'nibid'.
-  encodingConfig: EncodingConfig specifies the concrete encoding types to use
-    for a given app. This is provided for compatibility between protobuf and
-    amino implementations.
+
+	rootCmd: The root command called once in the 'main.go' of 'nibid'.
+	encodingConfig: EncodingConfig specifies the concrete encoding types to use
+	  for a given app. This is provided for compatibility between protobuf and
+	  amino implementations.
 */
 func initRootCmd(rootCmd *cobra.Command, encodingConfig params.EncodingConfig) {
 	cfg := sdk.GetConfig()

proto/oracle/v1beta1/genesis.proto

@@ -0,0 +1,43 @@
+syntax = "proto3";
+package nibiru.oracle.v1beta1;
+
+import "gogoproto/gogo.proto";
+import "oracle/v1beta1/oracle.proto";
+import "cosmos/base/v1beta1/coin.proto";
+
+option go_package = "github.com/NibiruChain/nibiru/x/oracle/types";
+
+// GenesisState defines the oracle module's genesis state.
+message GenesisState {
+  Params                     params             = 1 [(gogoproto.nullable) = false];
+  repeated FeederDelegation  feeder_delegations = 2 [(gogoproto.nullable) = false];
+  repeated ExchangeRateTuple exchange_rates     = 3
+      [(gogoproto.castrepeated) = "ExchangeRateTuples", (gogoproto.nullable) = false];
+  repeated MissCounter                  miss_counters                    = 4 [(gogoproto.nullable) = false];
+  repeated AggregateExchangeRatePrevote aggregate_exchange_rate_prevotes = 5 [(gogoproto.nullable) = false];
+  repeated AggregateExchangeRateVote    aggregate_exchange_rate_votes    = 6 [(gogoproto.nullable) = false];
+  repeated TobinTax                     tobin_taxes                      = 7 [(gogoproto.nullable) = false];
+}
+
+// FeederDelegation is the address for where oracle feeder authority are
+// delegated to. By default this struct is only used at genesis to feed in
+// default feeder addresses.
+message FeederDelegation {
+  string feeder_address    = 1;
+  string validator_address = 2;
+}
+
+// MissCounter defines an miss counter and validator address pair used in
+// oracle module's genesis state
+message MissCounter {
+  string validator_address = 1;
+  uint64 miss_counter      = 2;
+}
+
+// TobinTax defines a pair and tobin_tax pair used in
+// oracle module's genesis state
+message TobinTax {
+  string pair     = 1;
+  string tobin_tax = 2
+      [(gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec", (gogoproto.nullable) = false];
+}

proto/oracle/v1beta1/oracle.proto

@@ -0,0 +1,99 @@
+syntax = "proto3";
+package nibiru.oracle.v1beta1;
+
+import "gogoproto/gogo.proto";
+import "cosmos/base/v1beta1/coin.proto";
+
+option go_package = "github.com/NibiruChain/nibiru/x/oracle/types";
+
+// Params defines the parameters for the oracle module.
+message Params {
+  option (gogoproto.equal)            = true;
+  option (gogoproto.goproto_stringer) = false;
+
+  uint64 vote_period    = 1 [(gogoproto.moretags) = "yaml:\"vote_period\""];
+  string vote_threshold = 2 [
+    (gogoproto.moretags)   = "yaml:\"vote_threshold\"",
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable)   = false
+  ];
+  string reward_band = 3 [
+    (gogoproto.moretags)   = "yaml:\"reward_band\"",
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable)   = false
+  ];
+  uint64         reward_distribution_window = 4 [(gogoproto.moretags) = "yaml:\"reward_distribution_window\""];
+  repeated Pair whitelist                  = 5 [
+    (gogoproto.moretags)     = "yaml:\"whitelist\"",
+    (gogoproto.castrepeated) = "PairList",
+    (gogoproto.nullable)     = false
+  ];
+  string slash_fraction = 6 [
+    (gogoproto.moretags)   = "yaml:\"slash_fraction\"",
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable)   = false
+  ];
+  uint64 slash_window         = 7 [(gogoproto.moretags) = "yaml:\"slash_window\""];
+  string min_valid_per_window = 8 [
+    (gogoproto.moretags)   = "yaml:\"min_valid_per_window\"",
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable)   = false
+  ];
+}
+
+// Pair is the object that holds configuration of each pair.
+message Pair {
+  option (gogoproto.equal)            = false;
+  option (gogoproto.goproto_getters)  = false;
+  option (gogoproto.goproto_stringer) = false;
+
+  string name      = 1 [(gogoproto.moretags) = "yaml:\"name\""];
+  string tobin_tax = 2 [
+    (gogoproto.moretags)   = "yaml:\"tobin_tax\"",
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable)   = false
+  ];
+}
+
+// struct for aggregate prevoting on the ExchangeRateVote.
+// The purpose of aggregate prevote is to hide vote exchange rates with hash
+// which is formatted as hex string in SHA256("{salt}:({pair},{exchange_rate})|...,({pair},{exchange_rate}):{voter}")
+message AggregateExchangeRatePrevote {
+  option (gogoproto.equal)            = false;
+  option (gogoproto.goproto_getters)  = false;
+  option (gogoproto.goproto_stringer) = false;
+
+  string hash         = 1 [(gogoproto.moretags) = "yaml:\"hash\""];
+  string voter        = 2 [(gogoproto.moretags) = "yaml:\"voter\""];
+  uint64 submit_block = 3 [(gogoproto.moretags) = "yaml:\"submit_block\""];
+}
+
+// MsgAggregateExchangeRateVote - struct for voting on
+// the exchange rates different assets.
+message AggregateExchangeRateVote {
+  option (gogoproto.equal)            = false;
+  option (gogoproto.goproto_getters)  = false;
+  option (gogoproto.goproto_stringer) = false;
+
+  repeated ExchangeRateTuple exchange_rate_tuples = 1 [
+    (gogoproto.moretags)     = "yaml:\"exchange_rate_tuples\"",
+    (gogoproto.castrepeated) = "ExchangeRateTuples",
+    (gogoproto.nullable)     = false
+  ];
+
+  string voter = 2 [(gogoproto.moretags) = "yaml:\"voter\""];
+}
+
+// ExchangeRateTuple - struct to store interpreted exchange rates data to store
+message ExchangeRateTuple {
+  option (gogoproto.equal)            = false;
+  option (gogoproto.goproto_getters)  = false;
+  option (gogoproto.goproto_stringer) = false;
+
+  string pair        = 1 [(gogoproto.moretags) = "yaml:\"pair\""];
+  string exchange_rate = 2 [
+    (gogoproto.moretags)   = "yaml:\"exchange_rate\"",
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable)   = false
+  ];
+}