deduped metrics registration

Author: adranwit

gateway/route_metric.go

@@ -2,6 +2,7 @@ package gateway
 
 import (
 	"context"
+	"fmt"
 	"github.com/viant/datly/repository/contract"
 	"github.com/viant/gmetric"
 	"net/http"
@@ -17,6 +18,7 @@ func (r *Router) NewMetricRoute(URI string) *Route {
 		pathURI += "*"
 	}
 	return &Route{
+
 		Path: contract.NewPath(http.MethodGet, pathURI),
 		Handler: func(ctx context.Context, response http.ResponseWriter, req *http.Request) {
 			r.handleMetrics(response, req, URI)

gateway/router.go

@@ -313,6 +313,7 @@ func (r *Router) newMatcher(ctx context.Context) (*matcher.Matcher, []*contract.
 	paths := make([]*contract.Path, 0, len(routes))
 	container := r.repository.Container()
 
+	unique := map[string]bool{}
 	var openAPIs = map[string][]*repository.Provider{}
 	var optionsPaths = map[string][]*path.Path{}
 	for _, anItem := range container.Items {
@@ -340,14 +341,16 @@ func (r *Router) newMatcher(ctx context.Context) (*matcher.Matcher, []*contract.
 					optionsPaths[aPath.URI] = append(optionsPaths[aPath.URI], aPath)
 				}
 				routes = append(routes, r.NewViewMetaHandler(r.routeURL(r.config.Meta.ViewURI, aPath.URI), provider))
-
 				key := r.routeURL(r.config.Meta.OpenApiURI, aPath.URI)
 				openAPIs[key] = append(openAPIs[key], provider)
-				//				//routes = append(routes, r.NewOpenAPIRoute(r.routeURL(r.config.Meta.OpenApiURI, aPath.URI), r.repository, provider))
 
-				routes = append(routes, r.NewStructRoute(r.routeURL(r.config.Meta.StructURI, aPath.URI), provider))
-				routes = append(routes, r.NewStateRoute(r.routeURL(r.config.Meta.StateURI, aPath.URI), provider))
-				routes = append(routes, r.NewMetricRoute(r.metricURL(r.config.Meta.MetricURI, aPath.URI)))
+				if !unique[aPath.URI] {
+					unique[aPath.URI] = true
+					//				//routes = append(routes, r.NewOpenAPIRoute(r.routeURL(r.config.Meta.OpenApiURI, aPath.URI), r.repository, provider))
+					routes = append(routes, r.NewStructRoute(r.routeURL(r.config.Meta.StructURI, aPath.URI), provider))
+					routes = append(routes, r.NewStateRoute(r.routeURL(r.config.Meta.StateURI, aPath.URI), provider))
+					routes = append(routes, r.NewMetricRoute(r.metricURL(r.config.Meta.MetricURI, aPath.URI)))
+				}
 
 				//TODO extend path.Path with cache info to pre exract cacheable view
 				//if views := router.ExtractCacheableViews(route); len(views) > 0 {

internal/plugin/info.go

@@ -35,8 +35,7 @@ const (
 
 type (
 	Info struct {
-		fs afs.Service
-
+		fs                  afs.Service
 		URL                 string
 		Mod                 *modfile.File
 		ModLocation         string