Method replySetAux

server/topic.go:3101–3126

replyGetAux returns topic's auxiliary set of key-value pairs.

(sess *Session, asUid types.Uid, msg *ClientComMessage)

// replyGetAux returns topic's auxiliary set of key-value pairs.
func (t *Topic) replySetAux(sess *Session, asUid types.Uid, msg *ClientComMessage) error {
	now := types.TimeNow()

	if t.cat != types.TopicCatP2P && t.cat != types.TopicCatGrp && t.cat != types.TopicCatSlf {
		sess.queueOut(ErrOperationNotAllowedReply(msg, now))
		return errors.New("invalid topic category to assign aux")
	}

	if userData := t.perUser[asUid]; !(userData.modeGiven & userData.modeWant).IsAdmin() {
		sess.queueOut(ErrPermissionDeniedReply(msg, now))
		return errors.New("aux update by non-admin")
	}

	if aux, changed := mergeMaps(copyMap(t.aux), msg.Set.Aux); changed {
		err := store.Topics.Update(t.name, map[string]any{"Aux": aux, "UpdatedAt": now})
		if err == nil {
			t.aux = aux
			t.presSubsOnline("aux", "", nilPresParams, nilPresFilters, sess.sid)
		}
		sess.queueOut(decodeStoreErrorExplicitTs(err, msg.Set.Id, t.original(asUid), now, msg.Timestamp, nil))
		return err
	}

	sess.queueOut(InfoNotModifiedReply(msg, now))
	return nil
}

// replyGetDel is a response to a get[what=del] request: load a list of deleted message ids, send them to
// a session as {meta}