code style

db/query/querys.go

@@ -3,11 +3,15 @@ package query
 type EndpointQuery struct {
 	Query
 
+	Enabled     *bool
 	WorkspaceId *string
 }
 
 func (q *EndpointQuery) WhereMap() map[string]interface{} {
 	maps := make(map[string]interface{})
+	if q.Enabled != nil {
+		maps["enabled"] = *q.Enabled
+	}
 	if q.WorkspaceId != nil {
 		maps["ws_id"] = *q.WorkspaceId
 	}

dispatcher/dispatcher.go

@@ -187,12 +187,15 @@ func listWorkspaceEndpoints(ctx context.Context, db *db.DB, wid string) ([]*enti
 	endpoints, err := mcache.Load(ctx, cacheKey, nil, func(ctx context.Context, id string) (*[]*entities.Endpoint, error) {
 		var q query.EndpointQuery
 		q.WorkspaceId = &wid
-		//q.Enabled = true
+		q.Enabled = utils.Pointer(true)
 		endpoints, err := db.Endpoints.List(ctx, &q)
 		if err != nil {
 			return nil, err
 		}
 		return &endpoints, nil
 	}, wid)
+	if err != nil {
+		return nil, err
+	}
 	return *endpoints, err
 }

proxy/gateway.go

@@ -47,9 +47,8 @@ type Gateway struct {
 	log *zap.SugaredLogger
 	s   *http.Server
 
-	router          *router.Router // TODO: happens-before
-	routerVersion   string
-	routerLastBuild time.Time
+	router        *router.Router // TODO: happens-before
+	routerVersion string
 
 	db *db.DB
 
@@ -109,7 +108,7 @@ func NewGateway(cfg *config.ProxyConfig,
 }
 
 func (gw *Gateway) buildRouter(version string) {
-	gw.log.Debugf("creating router")
+	gw.log.Debugf("[proxy] creating router")
 
 	sources, err := gw.db.Sources.List(context.TODO(), &query.SourceQuery{})
 	if err != nil {
@@ -128,7 +127,6 @@ func (gw *Gateway) buildRouter(version string) {
 	}
 	gw.router = router.NewRouter(routes)
 	gw.routerVersion = version
-	gw.routerLastBuild = time.Now()
 }
 
 func (gw *Gateway) Handle(w http.ResponseWriter, r *http.Request) {

worker/worker.go

@@ -431,5 +431,8 @@ func listEndpointPlugins(ctx context.Context, db *db.DB, endpointId string) ([]*
 		}
 		return &plugins, nil
 	}, endpointId)
+	if err != nil {
+		return nil, err
+	}
 	return *plugins, err
 }