/
handler_player.go
121 lines (105 loc) · 2.84 KB
/
handler_player.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
package server
import (
"encoding/json"
"io"
"net/url"
"strings"
"github.com/dyninc/qstring"
"github.com/globalsign/mgo/bson"
"go.uber.org/zap"
"gopkg.in/go-playground/validator.v9"
"github.com/TradeWars/warehouse/types"
)
func (app *App) playerRoutes() []Route {
return []Route{
{
"playerCreate",
"POST",
"/store/playerCreate",
types.ExamplePlayer(),
types.ExampleStatus(bson.NewObjectId(), true),
app.playerCreate,
},
{
"playerGet",
"GET",
"/store/playerGet",
"?name=John, ?id=" + bson.NewObjectId(),
types.ExamplePlayer(),
app.playerGet,
},
{
"playerUpdate",
"PATCH",
"/store/playerUpdate",
types.ExamplePlayer(),
types.ExampleStatus(nil, true),
app.playerUpdate,
},
}
}
func (app *App) playerCreate(r io.Reader, query url.Values) (status types.Status, err error) {
var player types.Player
err = json.NewDecoder(r).Decode(&player)
if err != nil {
return
}
err = app.validator.Struct(player)
if err != nil {
return types.NewStatusValidationError(err.(validator.ValidationErrors)), nil
}
logger.Debug("received request playerCreate",
zap.Any("player", player))
id, err := app.store.PlayerCreate(player)
if err != nil && strings.HasPrefix(err.Error(), "E11000") {
return types.NewStatus(nil, false, "player name already registered"), nil
}
return types.NewStatus(id, true, ""), err
}
type playerGetParams struct {
Name string
ID string
}
func (app *App) playerGet(r io.Reader, query url.Values) (status types.Status, err error) {
params := playerGetParams{}
err = qstring.Unmarshal(query, ¶ms)
if err != nil {
return
}
logger.Debug("received request playerGet",
zap.Any("params", params))
var player types.Player
if params.Name != "" {
player, err = app.store.PlayerGetByName(params.Name)
} else if params.ID != "" {
if !bson.IsObjectIdHex(params.ID) {
status = types.NewStatus(nil, false, "invalid id format")
return
}
player, err = app.store.PlayerGetByID(bson.ObjectIdHex(params.ID))
} else {
status = types.NewStatus(nil, false, "id or name not specified")
return
}
if err == nil {
status = types.NewStatus(player, true, "")
} else if err.Error() == "not found" {
err = nil
status = types.NewStatus(nil, false, "not found")
}
return
}
func (app *App) playerUpdate(r io.Reader, query url.Values) (status types.Status, err error) {
var player types.Player
err = json.NewDecoder(r).Decode(&player)
if err != nil {
return
}
err = app.validator.Struct(player)
if err != nil {
return types.NewStatusValidationError(err.(validator.ValidationErrors)), nil
}
logger.Debug("received request playerUpdate",
zap.Any("player", player))
return types.NewStatus(nil, true, ""), app.store.PlayerUpdate(player.ID, player)
}