/
msg_server.go
48 lines (40 loc) · 1.26 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
package keeper
import (
"context"
"errors"
"fmt"
"cosmossdk.io/collections"
"github.com/alice/checkers"
"github.com/alice/checkers/rules"
)
type msgServer struct {
k Keeper
}
var _ checkers.MsgServer = msgServer{}
// NewMsgServerImpl returns an implementation of the module MsgServer interface.
func NewMsgServerImpl(keeper Keeper) checkers.MsgServer {
return &msgServer{k: keeper}
}
// CreateGame defines the handler for the MsgCreateGame message.
func (ms msgServer) CreateGame(ctx context.Context, msg *checkers.MsgCreateGame) (*checkers.MsgCreateGameResponse, error) {
if length := len([]byte(msg.Index)); checkers.MaxIndexLength < length || length < 1 {
return nil, checkers.ErrIndexTooLong
}
if _, err := ms.k.StoredGames.Get(ctx, msg.Index); err == nil || errors.Is(err, collections.ErrEncoding) {
return nil, fmt.Errorf("game already exists at index: %s", msg.Index)
}
newBoard := rules.New()
storedGame := checkers.StoredGame{
Board: newBoard.String(),
Turn: rules.PieceStrings[newBoard.Turn],
Black: msg.Black,
Red: msg.Red,
}
if err := storedGame.Validate(); err != nil {
return nil, err
}
if err := ms.k.StoredGames.Set(ctx, msg.Index, storedGame); err != nil {
return nil, err
}
return &checkers.MsgCreateGameResponse{}, nil
}