I'm trying to send/receive custom JSON messages. There are 3 cases in which the JSON struct changes, therefore I have 3 different structs. I have to access the room string which is sent as RawMessage. My question is what type should the channel Broadcast be?
type Message struct {
Type int64 `json:"type"`
Msg json.RawMessage
}
Broadcast chan interface{} // ??? RawMessage or maybe interface
case m := <-r.Broadcast:
// What type should chan Broadcast be?
// If m is of type json.RawMessage should I deal with unmarshalling here?
connections := r.Clients[m.Room] //
for c := range connections {
select {
case c.send <- m:
default:
close(c.send)
delete(connections, c)
if len(connections) == 0 {
delete(r.Clients, m.Room)
}
}
}
for {
msg := &Message{}
err := c.conn.ReadJSON(&msg)
// _, msg, err := c.conn.ReadMessage()
if err != nil {
if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) {
log.Printf("error: %v", err)
}
break
}
if msg.Type == 0 {
newVideo := &NewVideo{}
if err = json.Unmarshal(msg.Msg, &newVideo); err != nil {
fmt.Println(err)
}
Roomb.Broadcast <- msg.Msg // ??? should i send the RawMessage
online[msg.Room] = msg
} else if msg.Type == 1 {
if _, ok := online[msg.Room]; ok {
online[msg.Room].Start = float64(time.Now().Unix() - online[msg.Room].Timestamp)
c.send <- online[msg.Room]
}
} else if msg.Type == 2 {
Roomb.Broadcast <- msg.Msg // ??? should i send the RawMessage
}
fmt.Println(msg)
}