diff --git a/federationsender/consumers/eduserver.go b/federationsender/consumers/eduserver.go index 3956abde5..9d7574e68 100644 --- a/federationsender/consumers/eduserver.go +++ b/federationsender/consumers/eduserver.go @@ -189,13 +189,6 @@ func (t *OutputEDUConsumer) onTypingEvent(msg *sarama.ConsumerMessage) error { return t.queues.SendEDU(edu, t.ServerName, names) } -type userData struct { - Data struct { - Ts gomatrixserverlib.Timestamp `json:"ts"` - } `json:"data"` - EventIds []string `json:"event_ids"` -} - // onReceiptEvent is called in response to a message received on the receipt // events topic from the EDU server. func (t *OutputEDUConsumer) onReceiptEvent(msg *sarama.ConsumerMessage) error { diff --git a/syncapi/storage/shared/syncserver.go b/syncapi/storage/shared/syncserver.go index c93ff3306..d83a6c13d 100644 --- a/syncapi/storage/shared/syncserver.go +++ b/syncapi/storage/shared/syncserver.go @@ -604,7 +604,7 @@ func (d *Database) addReceiptDeltaToResponse( User: make(map[string]eduAPI.ReceiptTS), } for _, receipt := range receipts { - read.User[receipt.UserID] = eduAPI.ReceiptTS{receipt.Timestamp} + read.User[receipt.UserID] = eduAPI.ReceiptTS{TS: receipt.Timestamp} content[receipt.EventID] = read } ev.Content, err = json.Marshal(content)