Function TestIntegration

integrationtest/integration_test.go:354–439

(t *testing.T)

}

func TestIntegration(t *testing.T) {
	overwriteFlag := flag.Bool("overwrite", false, "Overwrite test output")
	flag.Parse()

	tt := []TestCase{
		TC1(t), TC2(t), TC3(t),
	}

	for _, tc := range tt {
		t.Run(tc.Name, func(t *testing.T) {
			ctx, app := test.CreateTestAppClpFromGenesis(false, func(app *sifapp.SifchainApp, genesisState sifapp.GenesisState) sifapp.GenesisState {
				// Initialise token registry
				trGs := &tokenregistrytypes.GenesisState{
					Registry: &tokenregistrytypes.Registry{
						Entries: []*tokenregistrytypes.RegistryEntry{
							{Denom: "atom", BaseDenom: "atom", Decimals: 6, Permissions: []tokenregistrytypes.Permission{tokenregistrytypes.Permission_CLP}},
							{Denom: "cusdc", BaseDenom: "cusdc", Decimals: 6, Permissions: []tokenregistrytypes.Permission{tokenregistrytypes.Permission_CLP}},
							{Denom: "rowan", BaseDenom: "rowan", Decimals: 18, Permissions: []tokenregistrytypes.Permission{tokenregistrytypes.Permission_CLP}},
						},
					},
				}
				bz, _ := app.AppCodec().MarshalJSON(trGs)
				genesisState["tokenregistry"] = bz

				// Initialise wallet
				bankGs := banktypes.DefaultGenesisState()
				bankGs.Balances = append(bankGs.Balances, tc.Setup.Accounts...)
				bz, _ = app.AppCodec().MarshalJSON(bankGs)
				genesisState["bank"] = bz

				// Set enabled margin pools
				marginGs := margintypes.DefaultGenesis()
				marginGs.Params.Pools = append(marginGs.Params.Pools, []string{"cusdc", "atom"}...)
				bz, _ = app.AppCodec().MarshalJSON(marginGs)
				genesisState["margin"] = bz

				return genesisState
			})

			app.ClpKeeper.SetRewardParams(ctx, &tc.Setup.RewardsParams)                 //nolint
			app.ClpKeeper.SetLiquidityProtectionParams(ctx, &tc.Setup.ProtectionParams) //nolint
			app.ClpKeeper.SetPmtpParams(ctx, &tc.Setup.ShiftingParams)                  //nolint
			app.ClpKeeper.SetProviderDistributionParams(ctx, &tc.Setup.ProviderParams)  //nolint

			clpSrv := clpkeeper.NewMsgServerImpl(app.ClpKeeper)
			marginSrv := marginkeeper.NewMsgServerImpl(app.MarginKeeper)

			for i, msg := range tc.Messages {
				ctx = ctx.WithBlockHeight(int64(i))
				app.BeginBlocker(ctx, abci.RequestBeginBlock{Header: types.Header{Height: ctx.BlockHeight()}})
				switch msg := msg.(type) {
				case *clptypes.MsgCreatePool:
					_, err := clpSrv.CreatePool(sdk.WrapSDKContext(ctx), msg)
					require.NoError(t, err)
				case *clptypes.MsgAddLiquidity:
					_, err := clpSrv.AddLiquidity(sdk.WrapSDKContext(ctx), msg)
					require.NoError(t, err)
				case *clptypes.MsgRemoveLiquidity: