package keeper

import (
	"encoding/base64"
	"encoding/json"
	"errors"
	"fmt"
	"os"
	"testing"
	"time"

	wasmvm "github.com/CosmWasm/wasmvm/v3"
	wasmvmtypes "github.com/CosmWasm/wasmvm/v3/types"
	dbm "github.com/cosmos/cosmos-db"
	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
	"google.golang.org/grpc/codes"
	"google.golang.org/grpc/status"

	errorsmod "cosmossdk.io/errors"
	"cosmossdk.io/log"
	storetypes "cosmossdk.io/store/types"

	sdk "github.com/cosmos/cosmos-sdk/types"
	sdkErrors "github.com/cosmos/cosmos-sdk/types/errors"
	"github.com/cosmos/cosmos-sdk/types/query"
	govv1beta1 "github.com/cosmos/cosmos-sdk/x/gov/types/v1beta1"

	"github.com/CosmWasm/wasmd/x/wasm/keeper/wasmtesting"
	"github.com/CosmWasm/wasmd/x/wasm/types"
)

func TestQueryAllContractState(t *testing.T) {
	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	keeper := keepers.WasmKeeper

	exampleContract := InstantiateHackatomExampleContract(t, ctx, keepers)
	contractAddr := exampleContract.Contract
	contractModel := []types.Model{
		{Key: []byte{0x0, 0x1}, Value: []byte(`{"count":8}`)},
		{Key: []byte("foo"), Value: []byte(`"bar"`)},
	}
	require.NoError(t, keeper.importContractState(ctx, contractAddr, contractModel))

	randomAddr := RandomBech32AccountAddress(t)

	q := Querier(keeper)
	specs := map[string]struct {
		srcQuery            *types.QueryAllContractStateRequest
		expModelContains    []types.Model
		expModelContainsNot []types.Model
		expErr              error
	}{
		"query all": {
			srcQuery:         &types.QueryAllContractStateRequest{Address: contractAddr.String()},
			expModelContains: contractModel,
		},
		"query all with unknown address": {
			srcQuery: &types.QueryAllContractStateRequest{Address: randomAddr},
			expErr:   types.ErrNoSuchContractFn(randomAddr).Wrapf("address %s", randomAddr),
		},
		"with pagination offset": {
			srcQuery: &types.QueryAllContractStateRequest{
				Address: contractAddr.String(),
				Pagination: &query.PageRequest{
					Offset: 1,
				},
			},
			expErr: errLegacyPaginationUnsupported,
		},
		"with pagination count": {
			srcQuery: &types.QueryAllContractStateRequest{
				Address: contractAddr.String(),
				Pagination: &query.PageRequest{
					CountTotal: true,
				},
			},
			expErr: errLegacyPaginationUnsupported,
		},
		"with pagination limit": {
			srcQuery: &types.QueryAllContractStateRequest{
				Address: contractAddr.String(),
				Pagination: &query.PageRequest{
					Limit: 1,
				},
			},
			expModelContains: []types.Model{
				{Key: []byte{0x0, 0x1}, Value: []byte(`{"count":8}`)},
			},
			expModelContainsNot: []types.Model{
				{Key: []byte("foo"), Value: []byte(`"bar"`)},
			},
		},
		"with pagination next key": {
			srcQuery: &types.QueryAllContractStateRequest{
				Address: contractAddr.String(),
				Pagination: &query.PageRequest{
					Key: fromBase64("Y29uZmln"),
				},
			},
			expModelContains: []types.Model{
				{Key: []byte("foo"), Value: []byte(`"bar"`)},
			},
			expModelContainsNot: []types.Model{
				{Key: []byte{0x0, 0x1}, Value: []byte(`{"count":8}`)},
			},
		},
	}
	for msg, spec := range specs {
		t.Run(msg, func(t *testing.T) {
			got, err := q.AllContractState(ctx, spec.srcQuery)

			if spec.expErr != nil {
				require.Equal(t, spec.expErr.Error(), err.Error())
				return
			}
			require.NoError(t, err)
			for _, exp := range spec.expModelContains {
				assert.Contains(t, got.Models, exp)
			}
			for _, exp := range spec.expModelContainsNot {
				assert.NotContains(t, got.Models, exp)
			}
		})
	}
}

func TestQuerySmartContractState(t *testing.T) {
	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	keeper := keepers.WasmKeeper

	exampleContract := InstantiateHackatomExampleContract(t, ctx, keepers)
	contractAddr := exampleContract.Contract.String()

	randomAddr := RandomBech32AccountAddress(t)

	q := Querier(keeper)
	specs := map[string]struct {
		srcAddr  sdk.AccAddress
		srcQuery *types.QuerySmartContractStateRequest
		expResp  string
		expErr   error
	}{
		"query smart": {
			srcQuery: &types.QuerySmartContractStateRequest{Address: contractAddr, QueryData: []byte(`{"verifier":{}}`)},
			expResp:  fmt.Sprintf(`{"verifier":"%s"}`, exampleContract.VerifierAddr.String()),
		},
		"query smart invalid request": {
			srcQuery: &types.QuerySmartContractStateRequest{Address: contractAddr, QueryData: []byte(`{"raw":{"key":"config"}}`)},
			expErr:   types.ErrQueryFailed,
		},
		"query smart with invalid json": {
			srcQuery: &types.QuerySmartContractStateRequest{Address: contractAddr, QueryData: []byte(`not a json string`)},
			expErr:   status.Error(codes.InvalidArgument, "invalid query data"),
		},
		"query smart with unknown address": {
			srcQuery: &types.QuerySmartContractStateRequest{Address: randomAddr, QueryData: []byte(`{"verifier":{}}`)},
			expErr:   types.ErrNoSuchContractFn(randomAddr),
		},
	}
	for msg, spec := range specs {
		t.Run(msg, func(t *testing.T) {
			got, err := q.SmartContractState(ctx, spec.srcQuery)
			require.True(t, errors.Is(err, spec.expErr), "but got %+v", err)
			if spec.expErr != nil {
				return
			}
			assert.JSONEq(t, string(got.Data), spec.expResp)
		})
	}
}

func TestQuerySmartContractPanics(t *testing.T) {
	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	contractAddr := BuildContractAddressClassic(1, 1)
	keepers.WasmKeeper.mustStoreCodeInfo(ctx, 1, types.CodeInfo{})
	keepers.WasmKeeper.mustStoreContractInfo(ctx, contractAddr, &types.ContractInfo{
		CodeID:  1,
		Created: types.NewAbsoluteTxPosition(ctx),
	})
	gasLimit := types.DefaultInstanceCost + 5000

	specs := map[string]struct {
		doInContract func()
		expErr       *errorsmod.Error
	}{
		"out of gas": {
			doInContract: func() {
				ctx.GasMeter().ConsumeGas(gasLimit+1, "test - consume more than limit")
			},
			expErr: sdkErrors.ErrOutOfGas,
		},
		"other panic": {
			doInContract: func() {
				panic("my panic")
			},
			expErr: sdkErrors.ErrPanic,
		},
	}
	for msg, spec := range specs {
		t.Run(msg, func(t *testing.T) {
			// reset gas meter
			ctx = ctx.WithGasMeter(storetypes.NewGasMeter(gasLimit)).WithLogger(log.NewTestLogger(t))

			keepers.WasmKeeper.wasmVM = &wasmtesting.MockWasmEngine{QueryFn: func(checksum wasmvm.Checksum, env wasmvmtypes.Env, queryMsg []byte, store wasmvm.KVStore, goapi wasmvm.GoAPI, querier wasmvm.Querier, gasMeter wasmvm.GasMeter, gasLimit uint64, deserCost wasmvmtypes.UFraction) (*wasmvmtypes.QueryResult, uint64, error) {
				spec.doInContract()
				return &wasmvmtypes.QueryResult{}, 0, nil
			}}
			// when
			q := Querier(keepers.WasmKeeper)
			got, err := q.SmartContractState(ctx, &types.QuerySmartContractStateRequest{
				Address:   contractAddr.String(),
				QueryData: types.RawContractMessage("{}"),
			})
			require.True(t, spec.expErr.Is(err), "got error: %+v", err)
			assert.Nil(t, got)
		})
	}
}

func TestQueryRawContractState(t *testing.T) {
	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	keeper := keepers.WasmKeeper

	exampleContract := InstantiateHackatomExampleContract(t, ctx, keepers)
	contractAddr := exampleContract.Contract.String()
	contractModel := []types.Model{
		{Key: []byte("foo"), Value: []byte(`"bar"`)},
		{Key: []byte{0x0, 0x1}, Value: []byte(`{"count":8}`)},
	}
	require.NoError(t, keeper.importContractState(ctx, exampleContract.Contract, contractModel))

	randomAddr := RandomBech32AccountAddress(t)

	q := Querier(keeper)
	specs := map[string]struct {
		srcQuery *types.QueryRawContractStateRequest
		expData  []byte
		expErr   error
	}{
		"query raw key": {
			srcQuery: &types.QueryRawContractStateRequest{Address: contractAddr, QueryData: []byte("foo")},
			expData:  []byte(`"bar"`),
		},
		"query raw contract binary key": {
			srcQuery: &types.QueryRawContractStateRequest{Address: contractAddr, QueryData: []byte{0x0, 0x1}},
			expData:  []byte(`{"count":8}`),
		},
		"query non-existent raw key": {
			srcQuery: &types.QueryRawContractStateRequest{Address: contractAddr, QueryData: []byte("not existing key")},
			expData:  nil,
		},
		"query empty raw key": {
			srcQuery: &types.QueryRawContractStateRequest{Address: contractAddr, QueryData: []byte("")},
			expData:  nil,
		},
		"query nil raw key": {
			srcQuery: &types.QueryRawContractStateRequest{Address: contractAddr},
			expData:  nil,
		},
		"query raw with unknown address": {
			srcQuery: &types.QueryRawContractStateRequest{Address: randomAddr, QueryData: []byte("foo")},
			expErr:   types.ErrNoSuchContractFn(randomAddr).Wrapf("address %s", randomAddr),
		},
	}
	for msg, spec := range specs {
		t.Run(msg, func(t *testing.T) {
			got, err := q.RawContractState(ctx, spec.srcQuery)
			if spec.expErr != nil {
				assert.Equal(t, spec.expErr.Error(), err.Error())
				return
			}
			assert.Equal(t, spec.expData, got.Data)
		})
	}
}

func TestQueryContractsByCode(t *testing.T) {
	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	keeper := keepers.WasmKeeper

	deposit := sdk.NewCoins(sdk.NewInt64Coin("denom", 1000000))
	topUp := sdk.NewCoins(sdk.NewInt64Coin("denom", 500))
	creator := keepers.Faucet.NewFundedRandomAccount(ctx, deposit...)
	anyAddr := keepers.Faucet.NewFundedRandomAccount(ctx, topUp...)

	wasmCode, err := os.ReadFile("./testdata/hackatom.wasm")
	require.NoError(t, err)

	codeID, _, err := keepers.ContractKeeper.Create(ctx, creator, wasmCode, nil)
	require.NoError(t, err)

	_, bob := keyPubAddr()
	initMsg := HackatomExampleInitMsg{
		Verifier:    anyAddr,
		Beneficiary: bob,
	}
	initMsgBz, err := json.Marshal(initMsg)
	require.NoError(t, err)

	// manage some realistic block settings
	var h int64 = 10
	setBlock := func(ctx sdk.Context, height int64) sdk.Context {
		ctx = ctx.WithBlockHeight(height)
		meter := storetypes.NewGasMeter(1000000)
		ctx = ctx.WithGasMeter(meter)
		ctx = ctx.WithBlockGasMeter(meter)
		return ctx
	}

	contractAddrs := make([]string, 0, 10)
	// create 10 contracts with real block/gas setup
	for i := 0; i < 10; i++ {
		// 3 tx per block, so we ensure both comparisons work
		if i%3 == 0 {
			ctx = setBlock(ctx, h)
			h++
		}
		addr, _, err := keepers.ContractKeeper.Instantiate(ctx, codeID, creator, nil, initMsgBz, fmt.Sprintf("contract %d", i), topUp)
		contractAddrs = append(contractAddrs, addr.String())
		require.NoError(t, err)
	}

	q := Querier(keeper)
	specs := map[string]struct {
		req     *types.QueryContractsByCodeRequest
		expAddr []string
		expErr  error
	}{
		"with empty request": {
			req:    nil,
			expErr: status.Error(codes.InvalidArgument, "empty request"),
		},
		"req.CodeId=0": {
			req:    &types.QueryContractsByCodeRequest{CodeId: 0},
			expErr: errorsmod.Wrap(types.ErrInvalid, "code id"),
		},
		"not exist codeID": {
			req:     &types.QueryContractsByCodeRequest{CodeId: codeID + 1},
			expAddr: []string{},
		},
		"query all and check the results are properly sorted": {
			req: &types.QueryContractsByCodeRequest{
				CodeId: codeID,
			},
			expAddr: contractAddrs,
		},
		"with pagination offset": {
			req: &types.QueryContractsByCodeRequest{
				CodeId: codeID,
				Pagination: &query.PageRequest{
					Offset: 5,
				},
			},
			expErr: errLegacyPaginationUnsupported,
		},
		"with invalid pagination key": {
			req: &types.QueryContractsByCodeRequest{
				CodeId: codeID,
				Pagination: &query.PageRequest{
					Offset: 1,
					Key:    []byte("test"),
				},
			},
			expErr: errLegacyPaginationUnsupported,
		},
		"with pagination limit": {
			req: &types.QueryContractsByCodeRequest{
				CodeId: codeID,
				Pagination: &query.PageRequest{
					Limit: 5,
				},
			},
			expAddr: contractAddrs[0:5],
		},
		"with pagination next key": {
			req: &types.QueryContractsByCodeRequest{
				CodeId: codeID,
				Pagination: &query.PageRequest{
					Key: fromBase64("AAAAAAAAAAoAAAAAAAOc/4cuhNIMvyvID4NhhfROlbQNuZ0fl0clmBPoWHtKYazH"),
				},
			},
			expAddr: contractAddrs[1:10],
		},
	}
	for msg, spec := range specs {
		t.Run(msg, func(t *testing.T) {
			got, err := q.ContractsByCode(ctx, spec.req)

			if spec.expErr != nil {
				assert.NotNil(t, err)
				assert.EqualError(t, err, spec.expErr.Error())
				return
			}
			assert.NotNil(t, got)
			assert.Equal(t, spec.expAddr, got.Contracts)
		})
	}
}

func TestQueryContractHistory(t *testing.T) {
	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	keeper := keepers.WasmKeeper

	var (
		myContractBech32Addr = RandomBech32AccountAddress(t)
		otherBech32Addr      = RandomBech32AccountAddress(t)
	)

	specs := map[string]struct {
		srcHistory []types.ContractCodeHistoryEntry
		req        types.QueryContractHistoryRequest
		expContent []types.ContractCodeHistoryEntry
		expErr     error
	}{
		"response with internal fields cleared": {
			srcHistory: []types.ContractCodeHistoryEntry{{
				Operation: types.ContractCodeHistoryOperationTypeGenesis,
				CodeID:    1,
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 1, TxIndex: 2},
				Msg:       []byte(`"init message"`),
			}},
			req: types.QueryContractHistoryRequest{Address: myContractBech32Addr},
			expContent: []types.ContractCodeHistoryEntry{{
				Operation: types.ContractCodeHistoryOperationTypeGenesis,
				CodeID:    1,
				Msg:       []byte(`"init message"`),
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 1, TxIndex: 2},
			}},
		},
		"response with multiple entries": {
			srcHistory: []types.ContractCodeHistoryEntry{{
				Operation: types.ContractCodeHistoryOperationTypeInit,
				CodeID:    1,
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 1, TxIndex: 2},
				Msg:       []byte(`"init message"`),
			}, {
				Operation: types.ContractCodeHistoryOperationTypeMigrate,
				CodeID:    2,
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 3, TxIndex: 4},
				Msg:       []byte(`"migrate message 1"`),
			}, {
				Operation: types.ContractCodeHistoryOperationTypeMigrate,
				CodeID:    3,
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 5, TxIndex: 6},
				Msg:       []byte(`"migrate message 2"`),
			}},
			req: types.QueryContractHistoryRequest{Address: myContractBech32Addr},
			expContent: []types.ContractCodeHistoryEntry{{
				Operation: types.ContractCodeHistoryOperationTypeInit,
				CodeID:    1,
				Msg:       []byte(`"init message"`),
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 1, TxIndex: 2},
			}, {
				Operation: types.ContractCodeHistoryOperationTypeMigrate,
				CodeID:    2,
				Msg:       []byte(`"migrate message 1"`),
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 3, TxIndex: 4},
			}, {
				Operation: types.ContractCodeHistoryOperationTypeMigrate,
				CodeID:    3,
				Msg:       []byte(`"migrate message 2"`),
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 5, TxIndex: 6},
			}},
		},
		"with pagination offset": {
			srcHistory: []types.ContractCodeHistoryEntry{{
				Operation: types.ContractCodeHistoryOperationTypeInit,
				CodeID:    1,
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 1, TxIndex: 2},
				Msg:       []byte(`"init message"`),
			}, {
				Operation: types.ContractCodeHistoryOperationTypeMigrate,
				CodeID:    2,
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 3, TxIndex: 4},
				Msg:       []byte(`"migrate message 1"`),
			}},
			req: types.QueryContractHistoryRequest{
				Address: myContractBech32Addr,
				Pagination: &query.PageRequest{
					Offset: 1,
				},
			},
			expErr: errLegacyPaginationUnsupported,
		},
		"with pagination limit": {
			srcHistory: []types.ContractCodeHistoryEntry{{
				Operation: types.ContractCodeHistoryOperationTypeInit,
				CodeID:    1,
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 1, TxIndex: 2},
				Msg:       []byte(`"init message"`),
			}, {
				Operation: types.ContractCodeHistoryOperationTypeMigrate,
				CodeID:    2,
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 3, TxIndex: 4},
				Msg:       []byte(`"migrate message 1"`),
			}},
			req: types.QueryContractHistoryRequest{
				Address: myContractBech32Addr,
				Pagination: &query.PageRequest{
					Limit: 1,
				},
			},
			expContent: []types.ContractCodeHistoryEntry{{
				Operation: types.ContractCodeHistoryOperationTypeInit,
				CodeID:    1,
				Msg:       []byte(`"init message"`),
				Updated:   &types.AbsoluteTxPosition{BlockHeight: 1, TxIndex: 2},
			}},
		},
		"unknown contract address": {
			req: types.QueryContractHistoryRequest{Address: otherBech32Addr},
			srcHistory: []types.ContractCodeHistoryEntry{{
				Operation: types.ContractCodeHistoryOperationTypeGenesis,
				CodeID:    1,
				Updated:   types.NewAbsoluteTxPosition(ctx),
				Msg:       []byte(`"init message"`),
			}},
			expContent: []types.ContractCodeHistoryEntry{},
		},
	}
	for msg, spec := range specs {
		t.Run(msg, func(t *testing.T) {
			xCtx, _ := ctx.CacheContext()

			cAddr, _ := sdk.AccAddressFromBech32(myContractBech32Addr)
			require.NoError(t, keeper.appendToContractHistory(xCtx, cAddr, spec.srcHistory...))

			// when
			q := Querier(keeper)
			got, gotErr := q.ContractHistory(xCtx, &spec.req) //nolint:gosec

			// then
			if spec.expErr != nil {
				require.Error(t, gotErr)
				assert.ErrorIs(t, gotErr, spec.expErr)
				return
			}
			require.NoError(t, gotErr)
			assert.Equal(t, spec.expContent, got.Entries)
		})
	}
}

func TestQueryCodeList(t *testing.T) {
	wasmCode, err := os.ReadFile("./testdata/hackatom.wasm")
	require.NoError(t, err)

	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	keeper := keepers.WasmKeeper

	specs := map[string]struct {
		storedCodeIDs []uint64
		req           types.QueryCodesRequest
		expCodeIDs    []uint64
		expErr        error
	}{
		"none": {},
		"no gaps": {
			storedCodeIDs: []uint64{1, 2, 3},
			expCodeIDs:    []uint64{1, 2, 3},
		},
		"with gaps": {
			storedCodeIDs: []uint64{2, 4, 6},
			expCodeIDs:    []uint64{2, 4, 6},
		},
		"with pagination offset": {
			storedCodeIDs: []uint64{1, 2, 3},
			req: types.QueryCodesRequest{
				Pagination: &query.PageRequest{
					Offset: 1,
				},
			},
			expErr: errLegacyPaginationUnsupported,
		},
		"with pagination limit": {
			storedCodeIDs: []uint64{1, 2, 3},
			req: types.QueryCodesRequest{
				Pagination: &query.PageRequest{
					Limit: 2,
				},
			},
			expCodeIDs: []uint64{1, 2},
		},
		"with pagination next key": {
			storedCodeIDs: []uint64{1, 2, 3},
			req: types.QueryCodesRequest{
				Pagination: &query.PageRequest{
					Key: fromBase64("AAAAAAAAAAI="),
				},
			},
			expCodeIDs: []uint64{2, 3},
		},
	}

	for msg, spec := range specs {
		t.Run(msg, func(t *testing.T) {
			xCtx, _ := ctx.CacheContext()

			for _, codeID := range spec.storedCodeIDs {
				require.NoError(t, keeper.importCode(xCtx, codeID,
					types.CodeInfoFixture(types.WithSHA256CodeHash(wasmCode)),
					wasmCode),
				)
			}
			// when
			q := Querier(keeper)
			got, gotErr := q.Codes(xCtx, &spec.req) //nolint:gosec

			// then
			if spec.expErr != nil {
				require.Error(t, gotErr)
				require.ErrorIs(t, gotErr, spec.expErr)
				return
			}
			require.NoError(t, gotErr)
			require.NotNil(t, got.CodeInfos)
			require.Len(t, got.CodeInfos, len(spec.expCodeIDs))
			for i, exp := range spec.expCodeIDs {
				assert.EqualValues(t, exp, got.CodeInfos[i].CodeID)
			}
		})
	}
}

func TestQueryContractInfo(t *testing.T) {
	var (
		contractAddr = RandomAccountAddress(t)
		anyDate      = time.Now().UTC()
	)
	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	// register an example extension. must be protobuf
	keepers.EncodingConfig.InterfaceRegistry.RegisterImplementations(
		(*types.ContractInfoExtension)(nil),
		&govv1beta1.Proposal{},
	)
	govv1beta1.RegisterInterfaces(keepers.EncodingConfig.InterfaceRegistry)

	k := keepers.WasmKeeper
	querier := NewGrpcQuerier(k.cdc, k.storeService, k, k.queryGasLimit)
	myExtension := func(info *types.ContractInfo) {
		// abuse gov proposal as a random protobuf extension with an Any type
		myExt, err := govv1beta1.NewProposal(&govv1beta1.TextProposal{Title: "foo", Description: "bar"}, 1, anyDate, anyDate)
		require.NoError(t, err)
		myExt.TotalDeposit = nil
		err = info.SetExtension(&myExt)
		require.NoError(t, err)
	}
	specs := map[string]struct {
		src    *types.QueryContractInfoRequest
		stored types.ContractInfo
		expRsp *types.QueryContractInfoResponse
		expErr bool
	}{
		"found": {
			src:    &types.QueryContractInfoRequest{Address: contractAddr.String()},
			stored: types.ContractInfoFixture(),
			expRsp: &types.QueryContractInfoResponse{
				Address:      contractAddr.String(),
				ContractInfo: types.ContractInfoFixture(),
			},
		},
		"with extension": {
			src:    &types.QueryContractInfoRequest{Address: contractAddr.String()},
			stored: types.ContractInfoFixture(myExtension),
			expRsp: &types.QueryContractInfoResponse{
				Address:      contractAddr.String(),
				ContractInfo: types.ContractInfoFixture(myExtension),
			},
		},
		"not found": {
			src:    &types.QueryContractInfoRequest{Address: RandomBech32AccountAddress(t)},
			stored: types.ContractInfoFixture(),
			expErr: true,
		},
	}
	for name, spec := range specs {
		t.Run(name, func(t *testing.T) {
			xCtx, _ := ctx.CacheContext()
			k.mustStoreContractInfo(xCtx, contractAddr, &spec.stored) //nolint:gosec
			// when
			gotRsp, gotErr := querier.ContractInfo(xCtx, spec.src)
			if spec.expErr {
				require.Error(t, gotErr)
				return
			}
			require.NoError(t, gotErr)
			assert.Equal(t, spec.expRsp, gotRsp)
		})
	}
}

func TestQueryWasmLimitsConfig(t *testing.T) {
	cfg := types.VMConfig{}

	fifteen := uint32(15)

	specs := map[string]struct {
		limits  wasmvmtypes.WasmLimits
		expJSON []byte
	}{
		"all 15": {
			limits: wasmvmtypes.WasmLimits{
				InitialMemoryLimitPages: &fifteen,
				TableSizeLimitElements:  &fifteen,
				MaxImports:              &fifteen,
				MaxFunctions:            &fifteen,
				MaxFunctionParams:       &fifteen,
				MaxTotalFunctionParams:  &fifteen,
				MaxFunctionResults:      &fifteen,
			},
			expJSON: []byte(`{"initial_memory_limit_pages":15,"table_size_limit_elements":15,"max_imports":15,"max_functions":15,"max_function_params":15,"max_total_function_params":15,"max_function_results":15}`),
		},
		"empty": {
			limits:  wasmvmtypes.WasmLimits{},
			expJSON: []byte("{}"),
		},
	}

	for name, spec := range specs {
		t.Run(name, func(t *testing.T) {
			cfg.WasmLimits = spec.limits

			ctx, keepers := createTestInput(t, false, AvailableCapabilities, types.DefaultNodeConfig(), cfg, dbm.NewMemDB())
			keeper := keepers.WasmKeeper

			q := Querier(keeper)

			response, err := q.WasmLimitsConfig(ctx, &types.QueryWasmLimitsConfigRequest{})
			require.NoError(t, err)
			require.NotNil(t, response)

			assert.Equal(t, string(spec.expJSON), response.Config)
			// assert.Equal(t, spec.expJSON, []byte(response.Config))
		})
	}
}

func TestQueryPinnedCodes(t *testing.T) {
	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	keeper := keepers.WasmKeeper

	exampleContract1 := InstantiateHackatomExampleContract(t, ctx, keepers)
	exampleContract2 := InstantiateIBCReflectContract(t, ctx, keepers)
	require.NoError(t, keeper.pinCode(ctx, exampleContract1.CodeID))
	require.NoError(t, keeper.pinCode(ctx, exampleContract2.CodeID))

	q := Querier(keeper)
	specs := map[string]struct {
		srcQuery   *types.QueryPinnedCodesRequest
		expCodeIDs []uint64
		expErr     error
	}{
		"query all": {
			srcQuery:   &types.QueryPinnedCodesRequest{},
			expCodeIDs: []uint64{exampleContract1.CodeID, exampleContract2.CodeID},
		},
		"with pagination offset": {
			srcQuery: &types.QueryPinnedCodesRequest{
				Pagination: &query.PageRequest{
					Offset: 1,
				},
			},
			expErr: errLegacyPaginationUnsupported,
		},
		"with pagination limit": {
			srcQuery: &types.QueryPinnedCodesRequest{
				Pagination: &query.PageRequest{
					Limit: 1,
				},
			},
			expCodeIDs: []uint64{exampleContract1.CodeID},
		},
		"with pagination next key": {
			srcQuery: &types.QueryPinnedCodesRequest{
				Pagination: &query.PageRequest{
					Key: fromBase64("AAAAAAAAAAM="),
				},
			},
			expCodeIDs: []uint64{exampleContract2.CodeID},
		},
	}
	for msg, spec := range specs {
		t.Run(msg, func(t *testing.T) {
			got, gotErr := q.PinnedCodes(ctx, spec.srcQuery)
			if spec.expErr != nil {
				require.Error(t, gotErr)
				assert.ErrorIs(t, gotErr, spec.expErr)
				return
			}
			require.NoError(t, gotErr)
			require.NotNil(t, got)
			assert.Equal(t, spec.expCodeIDs, got.CodeIDs)
		})
	}
}

func TestQueryParams(t *testing.T) {
	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	keeper := keepers.WasmKeeper

	q := Querier(keeper)

	paramsResponse, err := q.Params(ctx, &types.QueryParamsRequest{})
	require.NoError(t, err)
	require.NotNil(t, paramsResponse)

	defaultParams := types.DefaultParams()

	require.Equal(t, paramsResponse.Params.CodeUploadAccess, defaultParams.CodeUploadAccess)
	require.Equal(t, paramsResponse.Params.InstantiateDefaultPermission, defaultParams.InstantiateDefaultPermission)

	err = keeper.SetParams(ctx, types.Params{
		CodeUploadAccess:             types.AllowNobody,
		InstantiateDefaultPermission: types.AccessTypeNobody,
	})
	require.NoError(t, err)

	paramsResponse, err = q.Params(ctx, &types.QueryParamsRequest{})
	require.NoError(t, err)
	require.NotNil(t, paramsResponse)

	require.Equal(t, paramsResponse.Params.CodeUploadAccess, types.AllowNobody)
	require.Equal(t, paramsResponse.Params.InstantiateDefaultPermission, types.AccessTypeNobody)
}

func TestQueryCodeInfo(t *testing.T) {
	wasmCode, err := os.ReadFile("./testdata/hackatom.wasm")
	require.NoError(t, err)

	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	keeper := keepers.WasmKeeper

	anyAddress, err := sdk.AccAddressFromBech32("cosmos100dejzacpanrldpjjwksjm62shqhyss44jf5xz")
	require.NoError(t, err)
	specs := map[string]struct {
		codeID       uint64
		accessConfig types.AccessConfig
	}{
		"everybody": {
			codeID:       1,
			accessConfig: types.AllowEverybody,
		},
		"nobody": {
			codeID:       10,
			accessConfig: types.AllowNobody,
		},
		"with_address": {
			codeID:       20,
			accessConfig: types.AccessTypeAnyOfAddresses.With(anyAddress),
		},
	}
	for msg, spec := range specs {
		t.Run(msg, func(t *testing.T) {
			codeInfo := types.CodeInfoFixture(types.WithSHA256CodeHash(wasmCode))
			codeInfo.InstantiateConfig = spec.accessConfig
			require.NoError(t, keeper.importCode(ctx, spec.codeID,
				codeInfo,
				wasmCode),
			)

			q := Querier(keeper)
			got, err := q.CodeInfo(ctx, &types.QueryCodeInfoRequest{
				CodeId: spec.codeID,
			})
			require.NoError(t, err)
			expectedResponse := &types.QueryCodeInfoResponse{
				CodeID:                spec.codeID,
				Creator:               codeInfo.Creator,
				Checksum:              codeInfo.CodeHash,
				InstantiatePermission: spec.accessConfig,
			}
			require.NotNil(t, got)
			require.EqualValues(t, expectedResponse, got)
		})
	}
}

func TestQueryCode(t *testing.T) {
	wasmCode, err := os.ReadFile("./testdata/hackatom.wasm")
	require.NoError(t, err)

	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	keeper := keepers.WasmKeeper

	anyAddress, err := sdk.AccAddressFromBech32("cosmos100dejzacpanrldpjjwksjm62shqhyss44jf5xz")
	require.NoError(t, err)
	specs := map[string]struct {
		codeID       uint64
		accessConfig types.AccessConfig
	}{
		"everybody": {
			codeID:       1,
			accessConfig: types.AllowEverybody,
		},
		"nobody": {
			codeID:       10,
			accessConfig: types.AllowNobody,
		},
		"with_address": {
			codeID:       20,
			accessConfig: types.AccessTypeAnyOfAddresses.With(anyAddress),
		},
	}
	for msg, spec := range specs {
		t.Run(msg, func(t *testing.T) {
			codeInfo := types.CodeInfoFixture(types.WithSHA256CodeHash(wasmCode))
			codeInfo.InstantiateConfig = spec.accessConfig
			require.NoError(t, keeper.importCode(ctx, spec.codeID,
				codeInfo,
				wasmCode),
			)

			q := Querier(keeper)
			got, err := q.Code(ctx, &types.QueryCodeRequest{
				CodeId: spec.codeID,
			})
			require.NoError(t, err)
			expectedResponse := &types.QueryCodeResponse{
				CodeInfoResponse: &types.CodeInfoResponse{
					CodeID:                spec.codeID,
					Creator:               codeInfo.Creator,
					DataHash:              codeInfo.CodeHash,
					InstantiatePermission: spec.accessConfig,
				},
				Data: wasmCode,
			}
			require.NotNil(t, got.CodeInfoResponse)
			require.EqualValues(t, expectedResponse, got)
		})
	}
}

func TestQueryCodeInfoList(t *testing.T) {
	wasmCode, err := os.ReadFile("./testdata/hackatom.wasm")
	require.NoError(t, err)

	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	keeper := keepers.WasmKeeper

	anyAddress, err := sdk.AccAddressFromBech32("cosmos100dejzacpanrldpjjwksjm62shqhyss44jf5xz")
	require.NoError(t, err)
	codeInfoWithConfig := func(accessConfig types.AccessConfig) types.CodeInfo {
		codeInfo := types.CodeInfoFixture(types.WithSHA256CodeHash(wasmCode))
		codeInfo.InstantiateConfig = accessConfig
		return codeInfo
	}

	codes := []struct {
		name     string
		codeID   uint64
		codeInfo types.CodeInfo
	}{
		{
			name:     "everybody",
			codeID:   1,
			codeInfo: codeInfoWithConfig(types.AllowEverybody),
		},
		{
			codeID:   10,
			name:     "nobody",
			codeInfo: codeInfoWithConfig(types.AllowNobody),
		},
		{
			name:     "with_address",
			codeID:   20,
			codeInfo: codeInfoWithConfig(types.AccessTypeAnyOfAddresses.With(anyAddress)),
		},
	}

	allCodesResponse := make([]types.CodeInfoResponse, 0)
	for _, code := range codes {
		t.Run(fmt.Sprintf("import_%s", code.name), func(t *testing.T) {
			require.NoError(t, keeper.importCode(ctx, code.codeID,
				code.codeInfo,
				wasmCode),
			)
		})

		allCodesResponse = append(allCodesResponse, types.CodeInfoResponse{
			CodeID:                code.codeID,
			Creator:               code.codeInfo.Creator,
			DataHash:              code.codeInfo.CodeHash,
			InstantiatePermission: code.codeInfo.InstantiateConfig,
		})
	}
	q := Querier(keeper)
	got, err := q.Codes(ctx, &types.QueryCodesRequest{
		Pagination: &query.PageRequest{
			Limit: 3,
		},
	})
	require.NoError(t, err)
	require.Len(t, got.CodeInfos, 3)
	require.EqualValues(t, allCodesResponse, got.CodeInfos)
}

func TestQueryContractsByCreatorList(t *testing.T) {
	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)

	deposit := sdk.NewCoins(sdk.NewInt64Coin("denom", 1000000))
	topUp := sdk.NewCoins(sdk.NewInt64Coin("denom", 500))
	creator := keepers.Faucet.NewFundedRandomAccount(ctx, deposit...)
	anyAddr := keepers.Faucet.NewFundedRandomAccount(ctx, topUp...)

	wasmCode, err := os.ReadFile("./testdata/hackatom.wasm")
	require.NoError(t, err)

	codeID, _, err := keepers.ContractKeeper.Create(ctx, creator, wasmCode, nil)
	require.NoError(t, err)

	_, bob := keyPubAddr()
	initMsg := HackatomExampleInitMsg{
		Verifier:    anyAddr,
		Beneficiary: bob,
	}
	initMsgBz, err := json.Marshal(initMsg)
	require.NoError(t, err)

	// manage some realistic block settings
	var h int64 = 10
	setBlock := func(ctx sdk.Context, height int64) sdk.Context {
		ctx = ctx.WithBlockHeight(height)
		meter := storetypes.NewGasMeter(1000000)
		ctx = ctx.WithGasMeter(meter)
		ctx = ctx.WithBlockGasMeter(meter)
		return ctx
	}

	var allExpectedContracts []string
	// create 10 contracts with real block/gas setup
	for i := 0; i < 10; i++ {
		ctx = setBlock(ctx, h)
		h++
		contract, _, err := keepers.ContractKeeper.Instantiate(ctx, codeID, creator, nil, initMsgBz, fmt.Sprintf("contract %d", i), topUp)
		allExpectedContracts = append(allExpectedContracts, contract.String())
		require.NoError(t, err)
	}

	specs := map[string]struct {
		srcQuery        *types.QueryContractsByCreatorRequest
		expContractAddr []string
		expErr          error
	}{
		"query all": {
			srcQuery: &types.QueryContractsByCreatorRequest{
				CreatorAddress: creator.String(),
			},
			expContractAddr: allExpectedContracts,
			expErr:          nil,
		},
		"with pagination offset": {
			srcQuery: &types.QueryContractsByCreatorRequest{
				CreatorAddress: creator.String(),
				Pagination: &query.PageRequest{
					Offset: 1,
				},
			},
			expErr: errLegacyPaginationUnsupported,
		},
		"with pagination limit": {
			srcQuery: &types.QueryContractsByCreatorRequest{
				CreatorAddress: creator.String(),
				Pagination: &query.PageRequest{
					Limit: 1,
				},
			},
			expContractAddr: allExpectedContracts[0:1],
			expErr:          nil,
		},
		"nil creator": {
			srcQuery: &types.QueryContractsByCreatorRequest{
				Pagination: &query.PageRequest{},
			},
			expContractAddr: allExpectedContracts,
			expErr:          errors.New("empty address string is not allowed"),
		},
		"nil req": {
			srcQuery:        nil,
			expContractAddr: allExpectedContracts,
			expErr:          status.Error(codes.InvalidArgument, "empty request"),
		},
	}

	q := Querier(keepers.WasmKeeper)
	for msg, spec := range specs {
		t.Run(msg, func(t *testing.T) {
			got, gotErr := q.ContractsByCreator(ctx, spec.srcQuery)
			if spec.expErr != nil {
				require.Error(t, gotErr)
				assert.ErrorContains(t, gotErr, spec.expErr.Error())
				return
			}
			require.NoError(t, gotErr)
			require.NotNil(t, got)
			assert.Equal(t, spec.expContractAddr, got.ContractAddresses)
		})
	}
}

func fromBase64(s string) []byte {
	r, err := base64.StdEncoding.DecodeString(s)
	if err != nil {
		panic(err)
	}
	return r
}

func TestEnsurePaginationParams(t *testing.T) {
	specs := map[string]struct {
		src    *query.PageRequest
		exp    *query.PageRequest
		expErr error
	}{
		"custom limit": {
			src: &query.PageRequest{Limit: 10},
			exp: &query.PageRequest{Limit: 10},
		},
		"limit not set": {
			src: &query.PageRequest{},
			exp: &query.PageRequest{Limit: 100},
		},
		"limit > max": {
			src: &query.PageRequest{Limit: 101},
			exp: &query.PageRequest{Limit: 100},
		},
		"no pagination params set": {
			exp: &query.PageRequest{Limit: 100},
		},
		"non empty offset": {
			src:    &query.PageRequest{Offset: 1},
			expErr: errLegacyPaginationUnsupported,
		},
		"count enabled": {
			src:    &query.PageRequest{CountTotal: true},
			expErr: errLegacyPaginationUnsupported,
		},
	}
	for name, spec := range specs {
		t.Run(name, func(t *testing.T) {
			got, gotErr := ensurePaginationParams(spec.src)
			if spec.expErr != nil {
				require.Error(t, gotErr)
				assert.ErrorIs(t, gotErr, spec.expErr)
				return
			}
			require.NoError(t, gotErr)
			assert.Equal(t, spec.exp, got)
		})
	}
}

func TestQueryBuildAddress(t *testing.T) {
	specs := map[string]struct {
		src    *types.QueryBuildAddressRequest
		exp    *types.QueryBuildAddressResponse
		expErr error
	}{
		"empty request": {
			src:    nil,
			expErr: status.Error(codes.InvalidArgument, "empty request"),
		},
		"invalid code hash": {
			src: &types.QueryBuildAddressRequest{
				CodeHash:       "invalid",
				CreatorAddress: "cosmos100dejzacpanrldpjjwksjm62shqhyss44jf5xz",
				Salt:           "61",
				InitArgs:       nil,
			},
			expErr: fmt.Errorf("invalid code hash"),
		},
		"invalid creator address": {
			src: &types.QueryBuildAddressRequest{
				CodeHash:       "13a1fc994cc6d1c81b746ee0c0ff6f90043875e0bf1d9be6b7d779fc978dc2a5",
				CreatorAddress: "invalid",
				Salt:           "61",
				InitArgs:       nil,
			},
			expErr: fmt.Errorf("invalid creator address"),
		},
		"invalid salt": {
			src: &types.QueryBuildAddressRequest{
				CodeHash:       "13a1fc994cc6d1c81b746ee0c0ff6f90043875e0bf1d9be6b7d779fc978dc2a5",
				CreatorAddress: "cosmos100dejzacpanrldpjjwksjm62shqhyss44jf5xz",
				Salt:           "invalid",
				InitArgs:       nil,
			},
			expErr: fmt.Errorf("invalid salt"),
		},
		"empty salt": {
			src: &types.QueryBuildAddressRequest{
				CodeHash:       "13a1fc994cc6d1c81b746ee0c0ff6f90043875e0bf1d9be6b7d779fc978dc2a5",
				CreatorAddress: "cosmos100dejzacpanrldpjjwksjm62shqhyss44jf5xz",
				Salt:           "",
				InitArgs:       nil,
			},
			expErr: status.Error(codes.InvalidArgument, "empty salt"),
		},
		"invalid init args": {
			src: &types.QueryBuildAddressRequest{
				CodeHash:       "13a1fc994cc6d1c81b746ee0c0ff6f90043875e0bf1d9be6b7d779fc978dc2a5",
				CreatorAddress: "cosmos100dejzacpanrldpjjwksjm62shqhyss44jf5xz",
				Salt:           "61",
				InitArgs:       []byte(`invalid`),
			},
			expErr: fmt.Errorf("invalid"),
		},
		"valid - without init args": {
			src: &types.QueryBuildAddressRequest{
				CodeHash:       "13a1fc994cc6d1c81b746ee0c0ff6f90043875e0bf1d9be6b7d779fc978dc2a5",
				CreatorAddress: "cosmos100dejzacpanrldpjjwksjm62shqhyss44jf5xz",
				Salt:           "61",
				InitArgs:       nil,
			},
			exp: &types.QueryBuildAddressResponse{
				Address: "cosmos165fz7lnnt6e08knjqsz6fnz9drs7gewezyq3pl5uspc3zgt5lldq4ge3pl",
			},
			expErr: nil,
		},
		"valid - with init args": {
			src: &types.QueryBuildAddressRequest{
				CodeHash:       "13a1fc994cc6d1c81b746ee0c0ff6f90043875e0bf1d9be6b7d779fc978dc2a5",
				CreatorAddress: "cosmos100dejzacpanrldpjjwksjm62shqhyss44jf5xz",
				Salt:           "61",
				InitArgs:       []byte(`{"verifier":"cosmos100dejzacpanrldpjjwksjm62shqhyss44jf5xz"}`),
			},
			exp: &types.QueryBuildAddressResponse{
				Address: "cosmos150kq3ggdvc9lftcv6ns75t3v6lcpxdmvuwtqr6e9fc029z6h4maqepgss6",
			},
			expErr: nil,
		},
	}

	ctx, keepers := CreateTestInput(t, false, AvailableCapabilities)
	keeper := keepers.WasmKeeper

	q := Querier(keeper)
	for msg, spec := range specs {
		t.Run(msg, func(t *testing.T) {
			got, gotErr := q.BuildAddress(ctx, spec.src)
			if spec.expErr != nil {
				require.Error(t, gotErr)
				assert.ErrorContains(t, gotErr, spec.expErr.Error())
				return
			}
			require.NoError(t, gotErr)
			require.NotNil(t, got)
			assert.Equal(t, spec.exp.Address, got.Address)
		})
	}
}