Bootstrap ctrl

ctrl/cmd/main.go

@@ -7,7 +7,7 @@ import (
 	"runtime/debug"
 
 	config "code.fbi.h-da.de/danet/costaquanta/ctrl/internal"
-	"code.fbi.h-da.de/danet/costaquanta/ctrl/internal/core/application"
+	"code.fbi.h-da.de/danet/costaquanta/ctrl/internal/application"
 	pb "code.fbi.h-da.de/danet/costaquanta/gen/go/ctrl/v1"
 	"code.fbi.h-da.de/danet/costaquanta/libs/logging"
 	"code.fbi.h-da.de/danet/costaquanta/libs/tracing"
@@ -100,5 +100,10 @@ func main() {
 	app := application.NewApplication(log, traceProvider)
 
 	pb.RegisterHealthCtrlServer(grpcServer, app.HealthServer)
-	_ = grpcServer.Serve(listen)
+	pb.RegisterCtrlRoutingServiceServer(grpcServer, app.RoutingServer)
+
+	err = grpcServer.Serve(listen)
+	if err != nil {
+		panic(err)
+	}
 }

ctrl/internal/core/application/app.go → ctrl/internal/application/app.go

@@ -8,17 +8,23 @@ import (
 )
 
 type Application struct {
-	tracer       *sdktrace.TracerProvider
-	HealthServer *interaction.HealthServer
+	tracer        *sdktrace.TracerProvider
+	HealthServer  *interaction.HealthServer
+	RoutingServer *interaction.RoutingServer
 }
 
 func NewApplication(log *zap.Logger, tracer *sdktrace.TracerProvider) *Application {
-	healthServerLogger := logging.CreateChildLogger(log, "healthServer")
-	childTracer := tracer.Tracer("healthServer")
-	healthSrv := interaction.NewHealthServer(healthServerLogger, childTracer)
+	healthLogger := logging.CreateChildLogger(log, "healthServer")
+	healthTracer := tracer.Tracer("healthServer")
+	healthSrv := interaction.NewHealthServer(healthLogger, healthTracer)
+
+	routingLogger := logging.CreateChildLogger(log, "routingServer")
+	routingTracer := tracer.Tracer("routingServer")
+	routerSrv := interaction.NewRoutingServer(routingLogger, routingTracer)
 
 	return &Application{
-		HealthServer: healthSrv,
-		tracer:       tracer,
+		tracer:        tracer,
+		HealthServer:  healthSrv,
+		RoutingServer: routerSrv,
 	}
 }

ctrl/internal/infrastructure/interaction/health.go

@@ -15,6 +15,15 @@ type HealthServer struct {
 	tracer trace.Tracer
 }
 
+func NewHealthServer(logger *zap.SugaredLogger, tracer trace.Tracer) *HealthServer {
+	s := &HealthServer{
+		logger: logger,
+		tracer: tracer,
+	}
+
+	return s
+}
+
 func (h *HealthServer) Health(
 	ctx context.Context,
 	request *pb.HealthRequest,
@@ -28,12 +37,3 @@ func (h *HealthServer) Health(
 		Message: request.Message,
 	}, nil
 }
-
-func NewHealthServer(logger *zap.SugaredLogger, tracer trace.Tracer) *HealthServer {
-	s := &HealthServer{
-		logger: logger,
-		tracer: tracer,
-	}
-
-	return s
-}

ctrl/internal/infrastructure/interaction/routing.go

+package interaction
+
+import (
+	pb "code.fbi.h-da.de/danet/costaquanta/gen/go/ctrl/v1"
+	"go.opentelemetry.io/otel/trace"
+	"go.uber.org/zap"
+)
+
+type RoutingServer struct {
+	pb.UnimplementedCtrlRoutingServiceServer
+
+	logger *zap.SugaredLogger
+	tracer trace.Tracer
+}
+
+func NewRoutingServer(logger *zap.SugaredLogger, tracer trace.Tracer) *RoutingServer {
+	s := &RoutingServer{
+		logger: logger,
+		tracer: tracer,
+	}
+
+	return s
+}