Fix origin on device list update EDUs
MODIFY
federationapi/producers/syncapi.go
federationapi/producers/syncapi.go
@@ -163,10 +163,10 @@ func (p *SyncAPIProducer) SendPresence(
}
func (p *SyncAPIProducer) SendDeviceListUpdate(
- ctx context.Context, deviceListUpdate gomatrixserverlib.RawJSON, origin string,
+ ctx context.Context, deviceListUpdate gomatrixserverlib.RawJSON, origin gomatrixserverlib.ServerName,
) (err error) {
m := nats.NewMsg(p.TopicDeviceListUpdate)
- m.Header.Set("origin", origin)
+ m.Header.Set("origin", string(origin))
m.Data = deviceListUpdate
log.Debugf("Sending device list update: %+v", m.Header)
_, err = p.JetStream.PublishMsg(m, nats.Context(ctx))

MODIFY
federationapi/routing/send.go
federationapi/routing/send.go
@@ -359,7 +359,7 @@ func (t *txnReq) processEDUs(ctx context.Context) {
}
}
case gomatrixserverlib.MDeviceListUpdate:
- if err := t.producer.SendDeviceListUpdate(ctx, e.Content, e.Origin); err != nil {
+ if err := t.producer.SendDeviceListUpdate(ctx, e.Content, t.Origin); err != nil {
util.GetLogger(ctx).WithError(err).Error("failed to InputDeviceListUpdate")
}
case gomatrixserverlib.MReceipt:

Fix origin on device list update EDUs