Add member key and SetMember func

x/market/keeper/member.go

@@ -0,0 +1,27 @@
+package keeper
+
+import (
+	"github.com/cosmos/cosmos-sdk/runtime"
+
+	"context"
+	"onex/x/market/types"
+)
+
+// GetParams get all parameters as types.Params
+func (k Keeper) GetMember(
+	ctx context.Context,
+	denomA string,
+	denomB string,
+) (member types.Member, found bool) {
+	store := runtime.KVStoreAdapter(k.storeService.OpenKVStore(ctx))
+	bz := store.Get(types.MemberKey(
+		denomA,
+		denomB,
+	))
+	if bz == nil {
+		return member, false
+	}
+
+	k.cdc.MustUnmarshal(bz, &member)
+	return member, true
+}

x/market/keeper/msg_server_create_pool.go

@@ -31,6 +31,14 @@ func (k msgServer) CreatePool(goCtx context.Context, msg *types.MsgCreatePool) (
 	denom2 := coinPair.GetDenomByIndex(1)
 	pair := strings.Join([]string{denom1, denom2}, ",")
 
+	// Test if pool either exists and active or exists and inactive
+	// Inactive pool will be dry or have no drops
+	member1, _ := k.GetMember(ctx, denom2, denom1)
+
+	member2, _ := k.GetMember(ctx, denom1, denom2)
+
+	_ = member1
+	_ = member2
 	_ = pair
 	_ = ctx
 

x/market/types/key_member.go

@@ -0,0 +1,24 @@
+package types
+
+const (
+	// MemberKeyPrefix is the prefix to retrieve all Member
+	MemberKeyPrefix = "Member/value/"
+)
+
+// MemberKey returns the store key to retrieve a Member from the index fields
+func MemberKey(
+	denomA string,
+	denomB string,
+) []byte {
+	var key []byte
+
+	denomABytes := []byte(denomA)
+	key = append(key, denomABytes...)
+	key = append(key, []byte("/")...)
+
+	denomBBytes := []byte(denomB)
+	key = append(key, denomBBytes...)
+	key = append(key, []byte("/")...)
+
+	return key
+}