From e793b2743bd02731ecb8898d4c57a098a02f4381 Mon Sep 17 00:00:00 2001 From: ginuerzh Date: Tue, 11 Jun 2024 21:32:48 +0800 Subject: [PATCH] api: fix object name --- api/config_admission.go | 1 + api/config_auther.go | 1 + api/config_bypass.go | 1 + api/config_chain.go | 1 + api/config_conn_limiter.go | 1 + api/config_hop.go | 1 + api/config_hosts.go | 1 + api/config_ingress.go | 1 + api/config_limiter.go | 1 + api/config_observer.go | 1 + api/config_rate_limiter.go | 1 + api/config_recorder.go | 1 + api/config_resolver.go | 1 + api/config_router.go | 1 + api/config_sd.go | 1 + api/config_service.go | 1 + 16 files changed, 16 insertions(+) diff --git a/api/config_admission.go b/api/config_admission.go index 2c9caa9..5f0fb93 100644 --- a/api/config_admission.go +++ b/api/config_admission.go @@ -42,6 +42,7 @@ func createAdmission(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "admission name is required")) return } + req.Data.Name = name if registry.AdmissionRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("admission %s already exists", name))) diff --git a/api/config_auther.go b/api/config_auther.go index 41ba010..1a76165 100644 --- a/api/config_auther.go +++ b/api/config_auther.go @@ -42,6 +42,7 @@ func createAuther(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "auther name is required")) return } + req.Data.Name = name if registry.AutherRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("auther %s already exists", name))) diff --git a/api/config_bypass.go b/api/config_bypass.go index ae50c73..c4e7e0f 100644 --- a/api/config_bypass.go +++ b/api/config_bypass.go @@ -42,6 +42,7 @@ func createBypass(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "bypass name is required")) return } + req.Data.Name = name if registry.BypassRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("bypass %s already exists", name))) diff --git a/api/config_chain.go b/api/config_chain.go index 92ff66c..80bbfd1 100644 --- a/api/config_chain.go +++ b/api/config_chain.go @@ -43,6 +43,7 @@ func createChain(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "chain name is required")) return } + req.Data.Name = name if registry.ChainRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("chain %s already exists", name))) diff --git a/api/config_conn_limiter.go b/api/config_conn_limiter.go index 863737b..492cd62 100644 --- a/api/config_conn_limiter.go +++ b/api/config_conn_limiter.go @@ -42,6 +42,7 @@ func createConnLimiter(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "limiter name is required")) return } + req.Data.Name = name if registry.ConnLimiterRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("limiter %s already exists", name))) diff --git a/api/config_hop.go b/api/config_hop.go index c6ee69a..28fdb3c 100644 --- a/api/config_hop.go +++ b/api/config_hop.go @@ -43,6 +43,7 @@ func createHop(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "hop name is required")) return } + req.Data.Name = name if registry.HopRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("hop %s already exists", name))) diff --git a/api/config_hosts.go b/api/config_hosts.go index 085ea56..5688690 100644 --- a/api/config_hosts.go +++ b/api/config_hosts.go @@ -42,6 +42,7 @@ func createHosts(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "hosts name is required")) return } + req.Data.Name = name if registry.HostsRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("hosts %s already exists", name))) diff --git a/api/config_ingress.go b/api/config_ingress.go index ec75692..a6bb8f7 100644 --- a/api/config_ingress.go +++ b/api/config_ingress.go @@ -42,6 +42,7 @@ func createIngress(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "ingress name is required")) return } + req.Data.Name = name if registry.IngressRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("ingress %s already exists", name))) diff --git a/api/config_limiter.go b/api/config_limiter.go index 2b31f3d..471b54a 100644 --- a/api/config_limiter.go +++ b/api/config_limiter.go @@ -42,6 +42,7 @@ func createLimiter(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "limiter name is required")) return } + req.Data.Name = name if registry.TrafficLimiterRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("limiter %s already exists", name))) diff --git a/api/config_observer.go b/api/config_observer.go index b2c9965..d3024c4 100644 --- a/api/config_observer.go +++ b/api/config_observer.go @@ -42,6 +42,7 @@ func createObserver(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "observer name is required")) return } + req.Data.Name = name if registry.ObserverRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("observer %s already exists", name))) diff --git a/api/config_rate_limiter.go b/api/config_rate_limiter.go index 5484f22..15cb0e4 100644 --- a/api/config_rate_limiter.go +++ b/api/config_rate_limiter.go @@ -42,6 +42,7 @@ func createRateLimiter(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "limiter name is required")) return } + req.Data.Name = name if registry.RateLimiterRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("limiter %s already exists", name))) diff --git a/api/config_recorder.go b/api/config_recorder.go index 7e92091..189f2c2 100644 --- a/api/config_recorder.go +++ b/api/config_recorder.go @@ -42,6 +42,7 @@ func createRecorder(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "recorder name is required")) return } + req.Data.Name = name if registry.RecorderRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("recorder %s already exists", name))) diff --git a/api/config_resolver.go b/api/config_resolver.go index 8a6e82f..f46988c 100644 --- a/api/config_resolver.go +++ b/api/config_resolver.go @@ -42,6 +42,7 @@ func createResolver(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "resolver name is required")) return } + req.Data.Name = name if registry.ResolverRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("resolver %s already exists", name))) diff --git a/api/config_router.go b/api/config_router.go index 115dccc..5ad84f5 100644 --- a/api/config_router.go +++ b/api/config_router.go @@ -42,6 +42,7 @@ func createRouter(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "router name is required")) return } + req.Data.Name = name if registry.RouterRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("router %s already exists", name))) diff --git a/api/config_sd.go b/api/config_sd.go index d625ce6..944eeb1 100644 --- a/api/config_sd.go +++ b/api/config_sd.go @@ -42,6 +42,7 @@ func createSD(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "sd name is required")) return } + req.Data.Name = name if registry.SDRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("sd %s already exists", name))) diff --git a/api/config_service.go b/api/config_service.go index ebe0351..d8c349b 100644 --- a/api/config_service.go +++ b/api/config_service.go @@ -42,6 +42,7 @@ func createService(ctx *gin.Context) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeInvalid, "service name is required")) return } + req.Data.Name = name if registry.ServiceRegistry().IsRegistered(name) { writeError(ctx, NewError(http.StatusBadRequest, ErrCodeDup, fmt.Sprintf("service %s already exists", name)))