api: fix object name

This commit is contained in:
ginuerzh 2024-06-11 21:32:48 +08:00
parent ce60160cd7
commit e793b2743b
16 changed files with 16 additions and 0 deletions

View File

@ -42,6 +42,7 @@ func createAdmission(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "admission name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "admission name is required"))
return return
} }
req.Data.Name = name
if registry.AdmissionRegistry().IsRegistered(name) { if registry.AdmissionRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("admission %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("admission %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createAuther(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "auther name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "auther name is required"))
return return
} }
req.Data.Name = name
if registry.AutherRegistry().IsRegistered(name) { if registry.AutherRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("auther %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("auther %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createBypass(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "bypass name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "bypass name is required"))
return return
} }
req.Data.Name = name
if registry.BypassRegistry().IsRegistered(name) { if registry.BypassRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("bypass %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("bypass %s already exists", name)))

View File

@ -43,6 +43,7 @@ func createChain(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "chain name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "chain name is required"))
return return
} }
req.Data.Name = name
if registry.ChainRegistry().IsRegistered(name) { if registry.ChainRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("chain %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("chain %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createConnLimiter(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "limiter name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "limiter name is required"))
return return
} }
req.Data.Name = name
if registry.ConnLimiterRegistry().IsRegistered(name) { if registry.ConnLimiterRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("limiter %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("limiter %s already exists", name)))

View File

@ -43,6 +43,7 @@ func createHop(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "hop name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "hop name is required"))
return return
} }
req.Data.Name = name
if registry.HopRegistry().IsRegistered(name) { if registry.HopRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("hop %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("hop %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createHosts(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "hosts name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "hosts name is required"))
return return
} }
req.Data.Name = name
if registry.HostsRegistry().IsRegistered(name) { if registry.HostsRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("hosts %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("hosts %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createIngress(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "ingress name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "ingress name is required"))
return return
} }
req.Data.Name = name
if registry.IngressRegistry().IsRegistered(name) { if registry.IngressRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("ingress %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("ingress %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createLimiter(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "limiter name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "limiter name is required"))
return return
} }
req.Data.Name = name
if registry.TrafficLimiterRegistry().IsRegistered(name) { if registry.TrafficLimiterRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("limiter %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("limiter %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createObserver(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "observer name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "observer name is required"))
return return
} }
req.Data.Name = name
if registry.ObserverRegistry().IsRegistered(name) { if registry.ObserverRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("observer %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("observer %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createRateLimiter(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "limiter name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "limiter name is required"))
return return
} }
req.Data.Name = name
if registry.RateLimiterRegistry().IsRegistered(name) { if registry.RateLimiterRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("limiter %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("limiter %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createRecorder(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "recorder name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "recorder name is required"))
return return
} }
req.Data.Name = name
if registry.RecorderRegistry().IsRegistered(name) { if registry.RecorderRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("recorder %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("recorder %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createResolver(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "resolver name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "resolver name is required"))
return return
} }
req.Data.Name = name
if registry.ResolverRegistry().IsRegistered(name) { if registry.ResolverRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("resolver %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("resolver %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createRouter(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "router name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "router name is required"))
return return
} }
req.Data.Name = name
if registry.RouterRegistry().IsRegistered(name) { if registry.RouterRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("router %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("router %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createSD(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "sd name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "sd name is required"))
return return
} }
req.Data.Name = name
if registry.SDRegistry().IsRegistered(name) { if registry.SDRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("sd %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("sd %s already exists", name)))

View File

@ -42,6 +42,7 @@ func createService(ctx *gin.Context) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "service name is required")) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "service name is required"))
return return
} }
req.Data.Name = name
if registry.ServiceRegistry().IsRegistered(name) { if registry.ServiceRegistry().IsRegistered(name) {
writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("service %s already exists", name))) writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("service %s already exists", name)))