Method replySetInfo

server/topic.go:690–807

replySetInfo updates topic metadata, saves it to DB, replies to the caller as {ctrl} message, generates {pres} update if necessary

(sess *Session, set *MsgClientSet)

// replySetInfo updates topic metadata, saves it to DB,
// replies to the caller as {ctrl} message, generates {pres} update if necessary
func (t *Topic) replySetInfo(sess *Session, set *MsgClientSet) error {
	now := time.Now().UTC().Round(time.Millisecond)

	assignAccess := func(upd map[string]interface{}, mode *MsgDefaultAcsMode) error {
		if auth, anon, err := parseTopicAccess(mode, types.ModeInvalid, types.ModeInvalid); err != nil {
			return err
		} else if auth&types.ModeOwner != 0 || anon&types.ModeOwner != 0 {
			return errors.New("default 'O' access is not permitted")
		} else {
			access := make(map[string]interface{})
			if auth != types.ModeInvalid {
				access["Auth"] = auth
			}
			if anon != types.ModeInvalid {
				access["Anon"] = anon
			}
			if len(access) > 0 {
				upd["Access"] = access
			}
		}
		return nil
	}

	assignPubPriv := func(upd map[string]interface{}, what string, p interface{}) {
		if isNullValue(p) {
			upd[what] = nil
		} else {
			upd[what] = p
		}
	}

	updateCached := func(upd map[string]interface{}) {
		if tmp, ok := upd["Access"]; ok {
			access := tmp.(map[string]interface{})
			if auth, ok := access["Auth"]; ok {
				t.accessAuth = auth.(types.AccessMode)
			}
			if anon, ok := access["Anon"]; ok {
				t.accessAnon = anon.(types.AccessMode)
			}
		}
		if public, ok := upd["Public"]; ok {
			t.public = public
		}
	}

	var err error

	user := make(map[string]interface{})
	topic := make(map[string]interface{})
	sub := make(map[string]interface{})
	if t.cat == TopicCat_Me {
		// Update current user
		if set.Info.DefaultAcs != nil {
			err = assignAccess(user, set.Info.DefaultAcs)
		}
		if set.Info.Public != nil {
			assignPubPriv(user, "Public", set.Info.Public)