mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-12-17 20:03:10 -06:00
sqlite: Ensure we return exactly the number of events found in the database
Previously we would return exactly the number of *requested* events, which meant that several zero-initialised events would bubble through the system, failing at JSON serialisation time.
This commit is contained in:
parent
07128b8423
commit
18b0889a25
|
|
@ -253,12 +253,13 @@ func (d *Database) Events(
|
||||||
) ([]types.Event, error) {
|
) ([]types.Event, error) {
|
||||||
var eventJSONs []eventJSONPair
|
var eventJSONs []eventJSONPair
|
||||||
var err error
|
var err error
|
||||||
results := make([]types.Event, len(eventNIDs))
|
var results []types.Event
|
||||||
err = common.WithTransaction(d.db, func(txn *sql.Tx) error {
|
err = common.WithTransaction(d.db, func(txn *sql.Tx) error {
|
||||||
eventJSONs, err = d.statements.bulkSelectEventJSON(ctx, txn, eventNIDs)
|
eventJSONs, err = d.statements.bulkSelectEventJSON(ctx, txn, eventNIDs)
|
||||||
if err != nil || len(eventJSONs) == 0 {
|
if err != nil || len(eventJSONs) == 0 {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
results = make([]types.Event, len(eventJSONs))
|
||||||
for i, eventJSON := range eventJSONs {
|
for i, eventJSON := range eventJSONs {
|
||||||
result := &results[i]
|
result := &results[i]
|
||||||
result.EventNID = eventJSON.EventNID
|
result.EventNID = eventJSON.EventNID
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue