Method SendDeviceListUpdate

federationapi/producers/syncapi.go:167–180

(
	ctx context.Context, deviceListUpdate *gomatrixserverlib.DeviceListUpdateEvent,
)

}

func (p *SyncAPIProducer) SendDeviceListUpdate(
	ctx context.Context, deviceListUpdate *gomatrixserverlib.DeviceListUpdateEvent,
) (err error) {
	m := nats.NewMsg(p.TopicDeviceListUpdate)
	m.Header.Set(jetstream.UserID, deviceListUpdate.UserID)
	m.Data, err = json.Marshal(deviceListUpdate)
	if err != nil {
		return fmt.Errorf("json.Marshal: %w", err)
	}

	log.Debugf("Sending device list update: %+v", m.Header)
	_, err = p.JetStream.PublishMsg(m, nats.Context(ctx))
	return err
}