mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-25 15:53:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Remove dead code

Browse source 
Use key for timestamp
This commit is contained in:
Till Faelligen 2020-10-18 11:30:29 +02:00
parent 1a10566f28
commit 9e3dff34fb
2 changed files with 1 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
federationsender/consumers/eduserver.go
View file

@ -189,13 +189,6 @@ func (t *OutputEDUConsumer) onTypingEvent(msg *sarama.ConsumerMessage) error {
return t.queues.SendEDU(edu, t.ServerName, names) 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 // onReceiptEvent is called in response to a message received on the receipt
// events topic from the EDU server. // events topic from the EDU server.
func (t *OutputEDUConsumer) onReceiptEvent(msg *sarama.ConsumerMessage) error { func (t *OutputEDUConsumer) onReceiptEvent(msg *sarama.ConsumerMessage) error {

2
syncapi/storage/shared/syncserver.go
View file

@ -604,7 +604,7 @@ func (d *Database) addReceiptDeltaToResponse(
User: make(map[string]eduAPI.ReceiptTS), User: make(map[string]eduAPI.ReceiptTS),
} }
for _, receipt := range receipts { 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 content[receipt.EventID] = read
} }
ev.Content, err = json.Marshal(content) ev.Content, err = json.Marshal(content)