Process pubsub messages

pubsubprocess.go

// subchans is a map[string]chan *nats.Msg


func (h *Hub) PubsubProcess() {
    for {
        select {
        case msg := <-h.pubsub.subchans["lobby.>"]:
            h.sendToRealm(LobbyRealm, msg.Data)
        case msg := <-h.pubsub.subchans["user.>"]:
            // Send the message to every socket belonging to this user.
          subtopics := strings.Split(msg.Subject, ".")
          userID := subtopics[1]
            for client := range h.clientsByUserID[userID] {
                client.send <- msg.Data
            }
        case msg := <-h.pubsub.subchans["gametv.>"]:
          // A gametv message is meant for people who are observing a user's games.
          log.Debug().Str("topic", msg.Subject).Msg("got gametv message, forwarding along")
          subtopics := strings.Split(msg.Subject, ".")
          gameID := subtopics[1]
          h.sendToRealm(Realm("gametv-"+gameID), msg.Data)
        
          // Handle more messages here...
        }
    }
}