Method processDeviceListUpdate

federationapi/routing/send.go:491–507

(ctx context.Context, e gomatrixserverlib.EDU)

}

func (t *txnReq) processDeviceListUpdate(ctx context.Context, e gomatrixserverlib.EDU) {
	var payload gomatrixserverlib.DeviceListUpdateEvent
	if err := json.Unmarshal(e.Content, &payload); err != nil {
		util.GetLogger(ctx).WithError(err).Error("Failed to unmarshal device list update event")
		return
	}
	if _, serverName, err := gomatrixserverlib.SplitID('@', payload.UserID); err != nil {
		return
	} else if serverName == t.ourServerName {
		return
	} else if serverName != t.Origin {
		return
	}
	if err := t.producer.SendDeviceListUpdate(ctx, &payload); err != nil {
		util.GetLogger(ctx).WithError(err).WithField("user_id", payload.UserID).Error("failed to InputDeviceListUpdate")
	}
}