mirror of
https://github.com/jwetzell/showbridge-go.git
synced 2026-04-26 21:05:30 +00:00
move router to module New func
This commit is contained in:
@@ -75,7 +75,7 @@ func NewRouter(ctx context.Context, config config.Config) (*Router, []ModuleErro
|
||||
}
|
||||
|
||||
if !moduleInstanceExists {
|
||||
moduleInstance, err := moduleInfo.New(moduleDecl)
|
||||
moduleInstance, err := moduleInfo.New(moduleDecl, &router)
|
||||
if err != nil {
|
||||
if moduleErrors == nil {
|
||||
moduleErrors = []ModuleError{}
|
||||
@@ -110,18 +110,12 @@ func NewRouter(ctx context.Context, config config.Config) (*Router, []ModuleErro
|
||||
router.RouteInstances = append(router.RouteInstances, route)
|
||||
}
|
||||
|
||||
for _, moduleInstance := range router.ModuleInstances {
|
||||
slog.Debug("registering router with module", "id", moduleInstance.Id())
|
||||
moduleInstance.RegisterRouter(&router)
|
||||
}
|
||||
|
||||
return &router, moduleErrors, routeErrors
|
||||
}
|
||||
|
||||
func (r *Router) Run() {
|
||||
slog.Info("running router")
|
||||
for _, moduleInstance := range r.ModuleInstances {
|
||||
moduleInstance.RegisterRouter(r)
|
||||
r.moduleWait.Add(1)
|
||||
go func() {
|
||||
err := moduleInstance.Run()
|
||||
|
||||
Reference in New Issue
Block a user