Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
20 changes: 12 additions & 8 deletions loadtest/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -137,7 +137,7 @@ func (c *LoadTestClient) generateMessage(config Config, key cryptotypes.PrivKey,
case randNum <= 0.66:
msg = &tokenfactorytypes.MsgMint{
Sender: denomCreatorAddr,
Amount: sdk.Coin{Denom: denom, Amount: sdk.NewInt(1000000)},
Amount: sdk.Coin{Denom: denom, Amount: sdk.NewInt(10000000000000)},
}
default:
msg = &tokenfactorytypes.MsgBurn{
Expand Down Expand Up @@ -218,22 +218,26 @@ func (c *LoadTestClient) generateMessage(config Config, key cryptotypes.PrivKey,
return msg, false
}

func generateDexOrderPlacements(config Config, key cryptotypes.PrivKey, batchSize uint64, price sdk.Dec, quantity sdk.Dec) []*dextypes.Order {
orderPlacements := []*dextypes.Order{}
var orderType dextypes.OrderType
func sampleDexOrderType(config Config) (orderType dextypes.OrderType) {
if config.MessageType == "failure_bank_malformed" {
orderType = -1
} else {
dexMsgType := config.MsgTypeDistr.SampleDexMsgs()
switch dexMsgType {
msgType := config.MsgTypeDistr.SampleDexMsgs()
switch msgType {
case Limit:
orderType = dextypes.OrderType_LIMIT
case Market:
orderType = dextypes.OrderType_MARKET
default:
panic(fmt.Sprintf("Unknown message type %s\n", dexMsgType))
panic(fmt.Sprintf("Unknown message type %s\n", msgType))
}
}
return orderType
}

func generateDexOrderPlacements(config Config, key cryptotypes.PrivKey, msgPerTx uint64, price sdk.Dec, quantity sdk.Dec) (orderPlacements []*dextypes.Order) {
orderType := sampleDexOrderType(config)

var direction dextypes.PositionDirection
if rand.Float64() < 0.5 {
direction = dextypes.PositionDirection_LONG
Expand All @@ -242,7 +246,7 @@ func generateDexOrderPlacements(config Config, key cryptotypes.PrivKey, batchSiz
}

contract := config.ContractDistr.Sample()
for j := 0; j < int(batchSize); j++ {
for j := 0; j < int(msgPerTx); j++ {
orderPlacements = append(orderPlacements, &dextypes.Order{
Account: sdk.AccAddress(key.PubKey().Address()).String(),
ContractAddr: contract,
Expand Down
4 changes: 2 additions & 2 deletions x/oracle/simulation/operations.go
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ func WeightedOperations(
}

// SimulateMsgAggregateExchangeRateVote generates a MsgAggregateExchangeRateVote with random values.
// nolint: funlen
//nolint: funlen
func SimulateMsgAggregateExchangeRateVote(ak types.AccountKeeper, bk types.BankKeeper, k keeper.Keeper) simtypes.Operation {
return func(
r *rand.Rand, app *baseapp.BaseApp, ctx sdk.Context, accs []simtypes.Account, chainID string,
Expand Down Expand Up @@ -122,7 +122,7 @@ func SimulateMsgAggregateExchangeRateVote(ak types.AccountKeeper, bk types.BankK
}

// SimulateMsgDelegateFeedConsent generates a MsgDelegateFeedConsent with random values.
// nolint: funlen
//nolint: funlen
func SimulateMsgDelegateFeedConsent(ak types.AccountKeeper, bk types.BankKeeper, k keeper.Keeper) simtypes.Operation {
return func(
r *rand.Rand, app *baseapp.BaseApp, ctx sdk.Context, accs []simtypes.Account, chainID string,
Expand Down