diff --git a/pkg/mining/container.go b/pkg/mining/container.go index 21ff380..fdde0f6 100644 --- a/pkg/mining/container.go +++ b/pkg/mining/container.go @@ -118,8 +118,8 @@ func (c *Container) Initialize(ctx context.Context) error { c.eventHub = NewEventHub() // Wire up event hub to manager - if mgr, ok := c.manager.(*Manager); ok { - mgr.SetEventHub(c.eventHub) + if concreteManager, ok := c.manager.(*Manager); ok { + concreteManager.SetEventHub(c.eventHub) } c.initialized = true @@ -184,8 +184,8 @@ func (c *Container) Shutdown(ctx context.Context) error { } // 4. Stop miner manager - if mgr, ok := c.manager.(*Manager); ok { - mgr.Stop() + if concreteManager, ok := c.manager.(*Manager); ok { + concreteManager.Stop() } // 5. Close database diff --git a/pkg/mining/service.go b/pkg/mining/service.go index 747ab26..7389d47 100644 --- a/pkg/mining/service.go +++ b/pkg/mining/service.go @@ -428,8 +428,8 @@ func NewService(manager ManagerInterface, listenAddr string, displayAddr string, go eventHub.Run() // Wire up event hub to manager for miner events - if mgr, ok := manager.(*Manager); ok { - mgr.SetEventHub(eventHub) + if concreteManager, ok := manager.(*Manager); ok { + concreteManager.SetEventHub(eventHub) } // Set up state provider for WebSocket state sync on reconnect