Adding additional frontend connector apis for merging listeners

quesma/frontend_connectors/basic_http_frontend_connector.go

@@ -31,6 +31,7 @@ type BasicHTTPFrontendConnector struct {
 	debugInfoCollector diag.DebugInfoCollector
 	logger             quesma_api.QuesmaLogger
 	middlewares        []http.Handler
+	currentListener    quesma_api.FrontendConnector
 }
 
 func (h *BasicHTTPFrontendConnector) GetChildComponents() []interface{} {
@@ -182,3 +183,11 @@ func (h *BasicHTTPFrontendConnector) GetRouterInstance() *RouterV2 {
 func (h *BasicHTTPFrontendConnector) AddMiddleware(middleware http.Handler) {
 	h.middlewares = append(h.middlewares, middleware)
 }
+
+func (h *BasicHTTPFrontendConnector) SetListener(listener quesma_api.FrontendConnector) {
+	h.currentListener = listener
+}
+
+func (h *BasicHTTPFrontendConnector) Listener() quesma_api.FrontendConnector {
+	return h.currentListener
+}

quesma/main.go

@@ -209,7 +209,7 @@ func constructQuesma(cfg *config.QuesmaConfiguration, sl clickhouse.TableDiscove
 	if cfg.TransparentProxy {
 		return quesma.NewQuesmaTcpProxy(cfg, quesmaManagementConsole, logChan, false)
 	} else {
-		const quesma_v2 = false
+		const quesma_v2 = true
 		return quesma.NewHttpProxy(phoneHomeAgent, lm, ip, sl, im, schemaRegistry, cfg, quesmaManagementConsole, abResultsrepository, indexRegistry, quesma_v2)
 	}
 }

quesma/v2/core/quesma_apis.go

@@ -25,6 +25,8 @@ type Router interface {
 
 type FrontendConnector interface {
 	InstanceNamer
+	SetListener(listener FrontendConnector)
+	Listener() FrontendConnector
 	Listen() error // Start listening on the endpoint
 	GetEndpoint() string
 	Stop(ctx context.Context) error // Stop listening

quesma/v2/core/quesma_builder.go

@@ -80,14 +80,16 @@ func (quesma *Quesma) buildInternal() (QuesmaBuilder, error) {
 			for _, conn := range pipeline.GetFrontendConnectors() {
 				if httpConn, ok := conn.(HTTPFrontendConnector); ok {
 					router := httpConn.GetRouter().Clone().(Router)
-					if len(endpoints) == 1 {
-						router.SetHandlers(handlers)
-					}
+					router.SetHandlers(handlers)
 					httpConn.AddRouter(router)
-
 				}
 			}
 		}
+		for pipelineIndex, _ := range quesma.pipelines {
+			for frontendConnectorIndex := range quesma.pipelines[pipelineIndex].GetFrontendConnectors() {
+				quesma.pipelines[pipelineIndex].GetFrontendConnectors()[frontendConnectorIndex].SetListener(quesma.pipelines[0].GetFrontendConnectors()[0])
+			}
+		}
 	}
 
 	for _, pipeline := range quesma.pipelines {

quesma/v2/core/quesma_pipeline.go

@@ -71,7 +71,7 @@ func (p *Pipeline) Start() {
 	// however, bind error remains
 	for _, conn := range p.FrontendConnectors {
 		p.logger.Info().Msgf("Starting frontend connector %s", conn)
-		go conn.Listen()
+		go conn.Listener().Listen()
 	}
 }