diff --git a/pkg/channels/manager.go b/pkg/channels/manager.go index 495243c39..dad7d82f6 100644 --- a/pkg/channels/manager.go +++ b/pkg/channels/manager.go @@ -215,7 +215,7 @@ func (m *Manager) initChannels() error { logger.InfoC("channels", "WebSocket channel enabled successfully") } } - + logger.InfoCF("channels", "Channel initialization completed", map[string]interface{}{ "enabled_channels": len(m.channels), }) diff --git a/pkg/channels/websocket/channel.go b/pkg/channels/websocket/channel.go index 4dca72ad8..1bfb636a1 100644 --- a/pkg/channels/websocket/channel.go +++ b/pkg/channels/websocket/channel.go @@ -27,11 +27,11 @@ var logoImage []byte // Channel implements the Channel interface for WebSocket connections type Channel struct { - config config.WebSocketConfig - bus *bus.MessageBus - running bool - allowList []string - server *http.Server + config config.WebSocketConfig + bus *bus.MessageBus + running bool + allowList []string + server *http.Server upgrader websocket.Upgrader clients sync.Map // map[string]*websocket.Conn clientsMu sync.RWMutex