Clarify what went wrong for event length mismatches

This commit is contained in:
Kegan Dougal 2017-04-05 12:04:46 +01:00
parent 37c804fa90
commit aee6420cc0
2 changed files with 3 additions and 3 deletions

View file

@ -72,7 +72,7 @@ func (s *outputRoomEventsStatements) Events(txn *sql.Tx, eventIDs []string) ([]g
}
defer rows.Close()
result := make([]gomatrixserverlib.Event, len(eventIDs))
var result []gomatrixserverlib.Event
i := 0
for ; rows.Next(); i++ {
var eventBytes []byte
@ -86,7 +86,7 @@ func (s *outputRoomEventsStatements) Events(txn *sql.Tx, eventIDs []string) ([]g
result = append(result, ev)
}
if i != len(eventIDs) {
return nil, fmt.Errorf("failed to map all event IDs to events: (%d != %d)", i, len(eventIDs))
return nil, fmt.Errorf("failed to map all event IDs to events: (got %d, wanted, %d)", i, len(eventIDs))
}
return result, nil
}

View file

@ -2,7 +2,7 @@
consumer_uris: ["localhost:9092"]
# The name of the topic which the sync server will consume events from.
roomserver_topic: "roomserverOutput"
roomserver_topic: "roomserverOutput2"
# The database URI to store sync server information.
database: "postgres://dendrite:itsasecret@localhost/syncserver?sslmode=disable"