Add drop fields

x/market/keeper/msg_server_create_pool.go

@@ -36,6 +36,8 @@ func (k msgServer) CreatePool(goCtx context.Context, msg *types.MsgCreatePool) (
 	// The sorted pair joined by "," is used as the key for the pool.
 	denom1 := coinPair.GetDenomByIndex(0)
 	denom2 := coinPair.GetDenomByIndex(1)
+	coin1 := coinPair[0]
+	coin2 := coinPair[1]
 	pair := strings.Join([]string{denom1, denom2}, ",")
 
 	// Test if pool either exists and active or exists and inactive
@@ -89,14 +91,14 @@ func (k msgServer) CreatePool(goCtx context.Context, msg *types.MsgCreatePool) (
 		pool.Drops = drops
 		pool.Leaders = []*types.Leader{&leader}
 		pool.LastDrop = count
-		member1.Balance = coinPair.AmountOf(denom1)
-		member2.Balance = coinPair.AmountOf(denom2)
+		member1.Balance = coin1.Amount
+		member2.Balance = coin2.Amount
 	} else {
 		pool = types.Pool{
 			Pair:    pair,
 			Leaders: []*types.Leader{&leader},
-			Denom1:  coinPair.GetDenomByIndex(0),
-			Denom2:  coinPair.GetDenomByIndex(1),
+			Denom1:  denom1,
+			Denom2:  denom2,
 			Volume1: &types.Volume{
 				Denom:  coinPair.GetDenomByIndex(0),
 				Amount: sdk.ZeroInt(),
@@ -114,7 +116,7 @@ func (k msgServer) CreatePool(goCtx context.Context, msg *types.MsgCreatePool) (
 			Pair:    pair,
 			DenomA:  denom2,
 			DenomB:  denom1,
-			Balance: coinPair.AmountOf(denom1),
+			Balance: coin1.Amount,
 			Limit:   0,
 			Stop:    0,
 		}
@@ -123,19 +125,22 @@ func (k msgServer) CreatePool(goCtx context.Context, msg *types.MsgCreatePool) (
 			Pair:    pair,
 			DenomA:  denom1,
 			DenomB:  denom2,
-			Balance: coinPair.AmountOf(denom2),
+			Balance: coin2.Amount,
 			Limit:   0,
 			Stop:    0,
 		}
 	}
 
 	var drop = types.Drop{
-		Uid:     count,
-		Owner:   msg.Creator,
-		Pair:    pair,
-		Drops:   drops,
-		Product: drops,
-		Active:  true,
+		Uid:        count,
+		Owner:      msg.Creator,
+		Pair:       pair,
+		Drops:      drops,
+		TimeBeg:    ctx.BlockHeader().Time.Unix(),
+		ProductBeg: drops,
+		Coin1Beg:   coin1,
+		Coin2Beg:   coin2,
+		Active:     true,
 	}
 
 	k.SetPool(
@@ -167,5 +172,12 @@ func (k msgServer) CreatePool(goCtx context.Context, msg *types.MsgCreatePool) (
 	// Update drop uid count
 	k.SetUidCount(ctx, count+1)
 
-	return &types.MsgCreatePoolResponse{}, nil
+	return &types.MsgCreatePoolResponse{
+		Creator: msg.Creator,
+		DropUid: drop.Uid,
+		Pair:    pair,
+		Drops:   drop.Drops.String(),
+		Coin1:   coin1.String(),
+		Coin2:   coin2.String(),
+	}, nil
 }