[Perpetual]: add stop loss price

proto/elys/perpetual/tx.proto

@@ -19,7 +19,8 @@ service Msg {
   rpc Whitelist           (MsgWhitelist          ) returns (MsgWhitelistResponse          );
   rpc Dewhitelist         (MsgDewhitelist        ) returns (MsgDewhitelistResponse        );
   rpc AddCollateral       (MsgAddCollateral      ) returns (MsgAddCollateralResponse      );
-  rpc BrokerAddCollateral (MsgBrokerAddCollateral) returns (MsgAddCollateralResponse);
+  rpc BrokerAddCollateral (MsgBrokerAddCollateral) returns (MsgAddCollateralResponse      );
+  rpc UpdateStopLoss      (MsgUpdateStopLoss     ) returns (MsgUpdateStopLossResponse     );
 }
 message MsgOpen {
   string                   creator           = 1;
@@ -28,6 +29,10 @@ message MsgOpen {
   string                   trading_asset     = 4;
   cosmos.base.v1beta1.Coin collateral        = 5 [(gogoproto.nullable)   = false                                   ] ;
   string                   take_profit_price = 6 [(gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec", (gogoproto.nullable) = false];
+  string stop_loss_price = 28 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable) = false
+  ];
 }
 
 message MsgBrokerOpen {
@@ -38,6 +43,10 @@ message MsgBrokerOpen {
   cosmos.base.v1beta1.Coin collateral        = 5 [(gogoproto.nullable)   = false                                   ] ;
   string                   take_profit_price = 6 [(gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec", (gogoproto.nullable) = false];
   string                   owner             = 7;
+  string stop_loss_price = 28 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable) = false
+  ];
 }
 
 message MsgOpenResponse {
@@ -101,3 +110,11 @@ message MsgBrokerAddCollateral {
   int32  id      = 3;
   string owner   = 4;
 }
+
+message MsgUpdateStopLoss {
+  string creator = 1;
+  uint64 id = 2;
+  string price = 3 [(gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec", (gogoproto.nullable) = false];
+}
+
+message MsgUpdateStopLossResponse {}

proto/elys/perpetual/types.proto

@@ -99,6 +99,99 @@ message MTP {
     (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
     (gogoproto.nullable) = false
   ];
+  string stop_loss_price = 28 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable) = false
+  ];
+}
+
+message LegacyMTP {
+  string address = 1;
+  string collateral_asset = 2;
+  string trading_asset = 3;
+  string liabilities_asset = 4;
+  string custody_asset = 5;
+  string collateral = 6 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  string liabilities = 7 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  string borrow_interest_paid_collateral = 8 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  string borrow_interest_paid_custody = 9 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  string borrow_interest_unpaid_collateral = 10 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  string custody = 11 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  string take_profit_liabilities = 12 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  string take_profit_custody = 13 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  string leverage = 14 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable) = false
+  ];
+  string mtp_health = 15 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable) = false
+  ];
+  Position position = 16;
+  uint64 id = 17;
+  uint64 amm_pool_id = 18;
+  string consolidate_leverage = 19 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable) = false
+  ];
+  string sum_collateral = 20 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  string take_profit_price = 21 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable) = false
+  ];
+  string take_profit_borrow_rate = 22 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable) = false
+  ];
+  // funding fee paid
+  string funding_fee_paid_collateral = 23 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  string funding_fee_paid_custody = 24 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  // funding fee received
+  string funding_fee_received_collateral = 25 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  string funding_fee_received_custody = 26 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Int",
+    (gogoproto.nullable) = false
+  ];
+  string open_price = 27 [
+    (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+    (gogoproto.nullable) = false
+  ];
 }
 
 message WhiteList {

x/perpetual/client/cli/query_mtp_test.go

@@ -59,6 +59,7 @@ func networkWithMTPObjects(t *testing.T, n int) (*network.Network, []*types.MTP)
 			FundingFeeReceivedCollateral:   sdk.NewInt(0),
 			FundingFeeReceivedCustody:      sdk.NewInt(0),
 			OpenPrice:                      sdk.NewDec(0),
+			StopLossPrice:                  sdk.NewDec(0),
 		}
 
 		mtps = append(mtps, &mtp)

x/perpetual/client/cli/tx.go

@@ -30,6 +30,7 @@
 	cmd.AddCommand(CmdWhitelist())
 	cmd.AddCommand(CmdDewhitelist())
 	cmd.AddCommand(CmdAddCollateral())
+	cmd.AddCommand(CmdUpdateStopLoss())
 	// this line is used by starport scaffolding # 1
 
 	return cmd

x/perpetual/client/cli/tx_open.go

@@ -13,13 +13,13 @@
 
 func CmdOpen() *cobra.Command {
 	cmd := &cobra.Command{
-		Use:   "open [position] [leverage] [trading-asset] [collateral] [flags]",
+		Use:   "open [position] [leverage] [trading-asset] [collateral] [stop-loss-price] [flags]",
 		Short: "Open perpetual position",
 		Example: `Infinte profitability:
-elysd tx perpetual open long 5 uatom 100000000uusdc --from=treasury --keyring-backend=test --chain-id=elystestnet-1 --yes --gas=1000000
+elysd tx perpetual open long 5 uatom 100000000uusdc 100.0 --from=treasury --keyring-backend=test --chain-id=elystestnet-1 --yes --gas=1000000
 Finite profitability:
-elysd tx perpetual open short 5 uatom 100000000uusdc --take-profit 100 --from=treasury --keyring-backend=test --chain-id=elystestnet-1 --yes --gas=1000000`,
-		Args: cobra.ExactArgs(4),
+elysd tx perpetual open short 5 uatom 100000000uusdc 100.0 --take-profit 100 --from=treasury --keyring-backend=test --chain-id=elystestnet-1 --yes --gas=1000000`,
+		Args: cobra.ExactArgs(5),
 		RunE: func(cmd *cobra.Command, args []string) (err error) {
 			clientCtx, err := client.GetClientTxContext(cmd)
 			if err != nil {
@@ -50,6 +50,11 @@
 				return err
 			}
 
+			stopLossPrice, err := sdk.NewDecFromStr(args[4])
+			if err != nil {
+				return err
+			}
+
 			var takeProfitPrice sdk.Dec
 			if takeProfitPriceStr != types.InfinitePriceString {
 				takeProfitPrice, err = sdk.NewDecFromStr(takeProfitPriceStr)
@@ -70,6 +75,7 @@
 				argTradingAsset,
 				argCollateral,
 				takeProfitPrice,
+				stopLossPrice,
 			)
 
 			if err := msg.ValidateBasic(); err != nil {

x/perpetual/client/cli/tx_open_test.go

@@ -31,6 +31,7 @@ func TestOpenPosition(t *testing.T) {
 		"1.5",
 		"uatom",
 		"1000" + ptypes.BaseCurrency,
+		"100.0",
 		"--from=" + val.Address.String(),
 		"-y",
 	}

x/perpetual/client/cli/tx_update_stop_loss.go

@@ -0,0 +1,51 @@
+package cli
+
+import (
+	"errors"
+	"strconv"
+
+	"cosmossdk.io/math"
+	"github.com/cosmos/cosmos-sdk/client"
+	"github.com/cosmos/cosmos-sdk/client/flags"
+	"github.com/cosmos/cosmos-sdk/client/tx"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	"github.com/elys-network/elys/x/perpetual/types"
+	"github.com/spf13/cobra"
+)
+
+func CmdUpdateStopLoss() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "update-stop-loss [id] [amount]",
+		Short: "Broadcast message update-stop-loss",
+		Args:  cobra.ExactArgs(2),
+		RunE: func(cmd *cobra.Command, args []string) (err error) {
+			argPrice, err := sdk.NewDecFromStr(args[0])
+			if err!=nil {
+				return errors.New("invalid stoploss amount")
+			}
+			positionId, err := strconv.Atoi(args[1])
+			if err != nil {
+				return err
+			}
+
+			clientCtx, err := client.GetClientTxContext(cmd)
+			if err != nil {
+				return err
+			}
+
+			msg := types.NewMsgUpdateStopLoss(
+				clientCtx.GetFromAddress().String(),
+				uint64(positionId),
+			    math.LegacyDec(argPrice),
+			)
+			if err := msg.ValidateBasic(); err != nil {
+				return err
+			}
+			return tx.GenerateOrBroadcastTxCLI(clientCtx, cmd.Flags(), msg)
+		},
+	}
+
+	flags.AddTxFlagsToCmd(cmd)
+
+	return cmd
+}

x/perpetual/client/cli/tx_update_stop_loss_test.go

@@ -0,0 +1,30 @@
+package cli_test
+
+import (
+	"testing"
+
+	clitestutil "github.com/cosmos/cosmos-sdk/testutil/cli"
+	"github.com/stretchr/testify/require"
+
+	"github.com/elys-network/elys/x/perpetual/client/cli"
+)
+
+func TestUpdatestopLoss(t *testing.T) {
+	net := setupNetwork(t)
+	ctx := net.Validators[0].ClientCtx
+	val := net.Validators[0]
+
+	// Use baseURL to make API HTTP requests or use val.RPCClient to make direct
+	// Tendermint RPC calls.
+	// ...
+
+	args := []string{
+		"100.0",
+		"1",
+		"--from=" + val.Address.String(),
+		"-y",
+	}
+
+	_, err := clitestutil.ExecTestCLICmd(ctx, cli.CmdUpdateStopLoss(), args)
+	require.NoError(t, err)
+}

x/perpetual/keeper/check_same_asset_position_test.go

@@ -28,6 +28,7 @@ func TestCheckSameAssetPosition_NewPosition(t *testing.T) {
 		Leverage:     sdk.NewDec(1),
 		TradingAsset: ptypes.ATOM,
 		Collateral:   sdk.NewCoin(ptypes.ATOM, sdk.NewInt(100)),
+		StopLossPrice: sdk.NewDec(100),
 	}
 
 	mtp = k.CheckSameAssetPosition(ctx, msg)

x/perpetual/keeper/invariant_check_test.go

@@ -100,6 +100,7 @@ func TestCheckBalanceInvariant_InvalidBalance(t *testing.T) {
 		ptypes.ATOM,
 		sdk.NewCoin(ptypes.BaseCurrency, sdk.NewInt(100000000)),
 		sdk.MustNewDecFromStr(perpetualtypes.TakeProfitPriceDefault),
+		sdk.NewDec(100),
 	)
 
 	_, err = mk.Open(ctx, msg2, false)

x/perpetual/keeper/msg_server_broker_open.go

@@ -21,7 +21,7 @@
 		return nil, errors.Wrap(types.ErrUnauthorised, "creator must be broker address")
 	}
 
-	msgOpen := types.NewMsgOpen(msg.Owner, msg.Position, msg.Leverage, msg.TradingAsset, msg.Collateral, msg.TakeProfitPrice)
+	msgOpen := types.NewMsgOpen(msg.Owner, msg.Position, msg.Leverage, msg.TradingAsset, msg.Collateral, msg.TakeProfitPrice, msg.StopLossPrice)
 
 	return k.Keeper.Open(ctx, msgOpen, true)
 }

x/perpetual/keeper/msg_server_update_stop_loss.go

@@ -0,0 +1,43 @@
+package keeper
+
+import (
+	"context"
+	"fmt"
+	"strconv"
+
+	errorsmod "cosmossdk.io/errors"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	"github.com/elys-network/elys/x/perpetual/types"
+)
+
+func (k msgServer) UpdateStopLoss(goCtx context.Context, msg *types.MsgUpdateStopLoss) (*types.MsgUpdateStopLossResponse, error) {
+	ctx := sdk.UnwrapSDKContext(goCtx)
+
+	// Load existing mtp
+	mtp, err := k.GetMTP(ctx, msg.Creator, msg.Id)
+	if err != nil {
+		return nil, err
+	}
+
+	poolId := mtp.AmmPoolId
+	pool, found := k.GetPool(ctx, poolId)
+	if !found {
+		return nil, errorsmod.Wrap(types.ErrPoolDoesNotExist, fmt.Sprintf("poolId: %d", poolId))
+	}
+
+	if !pool.Enabled {
+		return nil, errorsmod.Wrap(types.ErrPerpetualDisabled, fmt.Sprintf("poolId: %d", poolId))
+	}
+
+	mtp.StopLossPrice = msg.Price
+	k.SetMTP(ctx, &mtp)
+
+	event := sdk.NewEvent(types.EventOpen,
+		sdk.NewAttribute("id", strconv.FormatInt(int64(mtp.Id), 10)),
+		sdk.NewAttribute("address", mtp.Address),
+		sdk.NewAttribute("stop_loss", mtp.StopLossPrice.String()),
+	)
+	ctx.EventManager().EmitEvent(event)
+
+	return &types.MsgUpdateStopLossResponse{}, nil
+}

x/perpetual/keeper/mtp.go

@@ -197,3 +197,36 @@
 	}
 	return count
 }
+
+
+func (k Keeper) DeleteLegacyMTP(ctx sdk.Context, mtpaddress string, id uint64) error {
+	store := ctx.KVStore(k.storeKey)
+	key := types.GetMTPKey(mtpaddress, id)
+	if !store.Has(key) {
+		return types.ErrMTPDoesNotExist
+	}
+	store.Delete(key)
+	return nil
+}
+
+func (k Keeper) GetAllLegacyMTP(ctx sdk.Context) []types.LegacyMTP {
+	var mtps []types.LegacyMTP
+	iterator := k.GetMTPIterator(ctx)
+	defer func(iterator sdk.Iterator) {
+		err := iterator.Close()
+		if err != nil {
+			panic(err)
+		}
+	}(iterator)
+
+	for ; iterator.Valid(); iterator.Next() {
+		var mtp types.LegacyMTP
+		bytesValue := iterator.Value()
+		err := k.cdc.Unmarshal(bytesValue, &mtp)
+		if err == nil {
+			mtps = append(mtps, mtp)
+		}
+	}
+
+	return mtps
+}