diff --git a/pkg/mining/events.go b/pkg/mining/events.go index 26b342a..235b81d 100644 --- a/pkg/mining/events.go +++ b/pkg/mining/events.go @@ -348,24 +348,24 @@ func (client *wsClient) readPump() { } // Parse client message - var msg struct { + var clientMessage struct { Type string `json:"type"` Miners []string `json:"miners,omitempty"` } - if err := UnmarshalJSON(message, &msg); err != nil { + if err := UnmarshalJSON(message, &clientMessage); err != nil { continue } - switch msg.Type { + switch clientMessage.Type { case "subscribe": // Update miner subscription (protected by mutex) client.minersMutex.Lock() client.miners = make(map[string]bool) - for _, m := range msg.Miners { + for _, m := range clientMessage.Miners { client.miners[m] = true } client.minersMutex.Unlock() - logging.Debug("client subscribed to miners", logging.Fields{"miners": msg.Miners}) + logging.Debug("client subscribed to miners", logging.Fields{"miners": clientMessage.Miners}) case "ping": // Respond with pong