Method presPubTopicOnline

server/topic.go:962–996

This is a newly created topic (!me or generic), announce topic presence

()

// This is a newly created topic (!me or generic), announce topic presence
func (t *Topic) presPubTopicOnline() error {

	// Load the list of users interested in this topic
	// Blocking call
	subs, err := store.Topics.GetSubs(t.appid, t.name, nil)
	if err != nil {
		log.Println("Presence: topic: error loading topic sharing ", err)
		return err
	}

	var count = 0
	if len(subs) > 0 {
		// Publish update to subscribers
		t.pushTo = make(map[types.Uid]bool)
		update := &MsgServerPres{Topic: "me", What: "on", User: t.name}
		var uid types.Uid

		for _, sub := range subs {
			if (sub.ModeGiven & sub.ModeWant & types.ModePres) != 0 {
				uid.UnmarshalText([]byte(sub.User))
				t.pushTo[uid] = true
				globals.hub.route <- &ServerComMessage{Pres: update, appid: t.appid,
					rcptto: "usr" + sub.User}
				count++
			}
		}

		log.Printf("Presence: topic '%s' came online, updated %d listeners", t.name, count)

	} else {
		log.Println("Presence: orphaned topic:", t.name)
	}

	return nil
}

// Publish presence announcement
func (t *Topic) presPubChange(action string) {