-
Notifications
You must be signed in to change notification settings - Fork 170
/
api.go
96 lines (80 loc) · 2.73 KB
/
api.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
package api
import (
"github.com/Dataman-Cloud/crane/src/plugins/auth"
rauth "github.com/Dataman-Cloud/crane/src/plugins/registryauth"
"github.com/Dataman-Cloud/crane/src/utils/cranerror"
"github.com/Dataman-Cloud/crane/src/utils/httpresponse"
log "github.com/Sirupsen/logrus"
"github.com/gin-gonic/gin"
)
const (
CodeCreateRegistryAuthParamError = "400-17001"
CodeGetRegistryAuthExistError = "400-17002"
CodeDeleteRegistryAuthParamError = "400-17003"
CodeRegistryAuthInvalidUserError = "401-17004"
)
func (api *RegistryAuthApi) Create(ctx *gin.Context) {
account, ok := ctx.Get("account")
if !ok {
log.Error("get registryAuths invalid user")
httpresponse.Error(ctx, cranerror.NewError(CodeRegistryAuthInvalidUserError, "invalid user"))
return
}
var registryAuth rauth.RegistryAuth
if err := ctx.BindJSON(®istryAuth); err != nil {
log.Errorf("create registryAuth param error: %v", err)
httpresponse.Error(ctx, cranerror.NewError(CodeCreateRegistryAuthParamError, err.Error()))
return
}
rs, err := rauth.List(&rauth.RegistryAuth{Name: registryAuth.Name, AccountId: registryAuth.AccountId})
if err != nil {
httpresponse.Error(ctx, err)
return
}
if len(rs) > 0 {
httpresponse.Error(ctx, cranerror.NewError(CodeGetRegistryAuthExistError, "registryAuth exists"))
return
}
registryAuth.AccountId = account.(auth.Account).ID
if err := rauth.Create(®istryAuth); err != nil {
log.Errorf("create registryAuth operation error: %v", err)
httpresponse.Error(ctx, err)
return
}
httpresponse.Ok(ctx, "create success")
}
func (api *RegistryAuthApi) List(ctx *gin.Context) {
account, ok := ctx.Get("account")
if !ok {
log.Error("get registryAuths invalid user")
httpresponse.Error(ctx, cranerror.NewError(CodeRegistryAuthInvalidUserError, "invalid user"))
return
}
registryAuth, err := rauth.List(&rauth.RegistryAuth{AccountId: account.(auth.Account).ID})
if err != nil {
log.Errorf("get registryAuth by name error: %v", err)
httpresponse.Error(ctx, err)
return
}
httpresponse.Ok(ctx, registryAuth)
}
func (api *RegistryAuthApi) Delete(ctx *gin.Context) {
account, ok := ctx.Get("account")
if !ok {
log.Error("delete registryAuth invalid user")
httpresponse.Error(ctx, cranerror.NewError(CodeRegistryAuthInvalidUserError, "invalid user"))
return
}
name := ctx.Param("rauth_name")
if name == "" {
log.Errorf("get registryAuth name invalid")
httpresponse.Error(ctx, cranerror.NewError(CodeDeleteRegistryAuthParamError, "registryAuth name invalid"))
return
}
if err := rauth.Delete(&rauth.RegistryAuth{Name: name, AccountId: account.(auth.Account).ID}); err != nil {
log.Errorf("delete registryAuth error: %v", err)
httpresponse.Error(ctx, err)
return
}
httpresponse.Ok(ctx, "delete success")
}