forked from crescent-network/crescent
-
Notifications
You must be signed in to change notification settings - Fork 0
/
msg_server.go
130 lines (94 loc) 路 3.68 KB
/
msg_server.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
package keeper
import (
"context"
sdk "github.com/cosmos/cosmos-sdk/types"
"github.com/jesse-pinkman-cre/crescent/x/liquidity/types"
)
type msgServer struct {
Keeper
}
// NewMsgServerImpl returns an implementation of the MsgServer interface
// for the provided Keeper.
func NewMsgServerImpl(keeper Keeper) types.MsgServer {
return &msgServer{Keeper: keeper}
}
var _ types.MsgServer = msgServer{}
// CreatePair defines a method to create a pair.
func (m msgServer) CreatePair(goCtx context.Context, msg *types.MsgCreatePair) (*types.MsgCreatePairResponse, error) {
ctx := sdk.UnwrapSDKContext(goCtx)
if _, err := m.Keeper.CreatePair(ctx, msg); err != nil {
return nil, err
}
return &types.MsgCreatePairResponse{}, nil
}
// CreatePool defines a method to create a liquidity pool.
func (m msgServer) CreatePool(goCtx context.Context, msg *types.MsgCreatePool) (*types.MsgCreatePoolResponse, error) {
ctx := sdk.UnwrapSDKContext(goCtx)
if _, err := m.Keeper.CreatePool(ctx, msg); err != nil {
return nil, err
}
return &types.MsgCreatePoolResponse{}, nil
}
func (m msgServer) CreateRangedPool(goCtx context.Context, msg *types.MsgCreateRangedPool) (*types.MsgCreateRangedPoolResponse, error) {
ctx := sdk.UnwrapSDKContext(goCtx)
if _, err := m.Keeper.CreateRangedPool(ctx, msg); err != nil {
return nil, err
}
return &types.MsgCreateRangedPoolResponse{}, nil
}
// Deposit defines a method to deposit coins to the pool.
func (m msgServer) Deposit(goCtx context.Context, msg *types.MsgDeposit) (*types.MsgDepositResponse, error) {
ctx := sdk.UnwrapSDKContext(goCtx)
if _, err := m.Keeper.Deposit(ctx, msg); err != nil {
return nil, err
}
return &types.MsgDepositResponse{}, nil
}
// Withdraw defines a method to withdraw pool coin from the pool.
func (m msgServer) Withdraw(goCtx context.Context, msg *types.MsgWithdraw) (*types.MsgWithdrawResponse, error) {
ctx := sdk.UnwrapSDKContext(goCtx)
if _, err := m.Keeper.Withdraw(ctx, msg); err != nil {
return nil, err
}
return &types.MsgWithdrawResponse{}, nil
}
// LimitOrder defines a method to make a limit order.
func (m msgServer) LimitOrder(goCtx context.Context, msg *types.MsgLimitOrder) (*types.MsgLimitOrderResponse, error) {
ctx := sdk.UnwrapSDKContext(goCtx)
if _, err := m.Keeper.LimitOrder(ctx, msg); err != nil {
return nil, err
}
return &types.MsgLimitOrderResponse{}, nil
}
// MarketOrder defines a method to make a market order.
func (m msgServer) MarketOrder(goCtx context.Context, msg *types.MsgMarketOrder) (*types.MsgMarketOrderResponse, error) {
ctx := sdk.UnwrapSDKContext(goCtx)
if _, err := m.Keeper.MarketOrder(ctx, msg); err != nil {
return nil, err
}
return &types.MsgMarketOrderResponse{}, nil
}
// MMOrder defines a method to make a MM(market making) order.
func (m msgServer) MMOrder(goCtx context.Context, msg *types.MsgMMOrder) (*types.MsgMMOrderResponse, error) {
ctx := sdk.UnwrapSDKContext(goCtx)
if _, err := m.Keeper.MMOrder(ctx, msg); err != nil {
return nil, err
}
return &types.MsgMMOrderResponse{}, nil
}
// CancelOrder defines a method to cancel an order.
func (m msgServer) CancelOrder(goCtx context.Context, msg *types.MsgCancelOrder) (*types.MsgCancelOrderResponse, error) {
ctx := sdk.UnwrapSDKContext(goCtx)
if err := m.Keeper.CancelOrder(ctx, msg); err != nil {
return nil, err
}
return &types.MsgCancelOrderResponse{}, nil
}
// CancelAllOrders defines a method to cancel all orders.
func (m msgServer) CancelAllOrders(goCtx context.Context, msg *types.MsgCancelAllOrders) (*types.MsgCancelAllOrdersResponse, error) {
ctx := sdk.UnwrapSDKContext(goCtx)
if err := m.Keeper.CancelAllOrders(ctx, msg); err != nil {
return nil, err
}
return &types.MsgCancelAllOrdersResponse{}, nil
}