Fix SQLite

This commit is contained in:
Neil Alexander 2021-07-15 15:25:50 +01:00
parent 5ef94156f5
commit bd5eccb945
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944

View file

@ -23,7 +23,6 @@ import (
"sort" "sort"
"strings" "strings"
"github.com/lib/pq"
"github.com/matrix-org/dendrite/internal" "github.com/matrix-org/dendrite/internal"
"github.com/matrix-org/dendrite/internal/sqlutil" "github.com/matrix-org/dendrite/internal/sqlutil"
"github.com/matrix-org/dendrite/roomserver/storage/shared" "github.com/matrix-org/dendrite/roomserver/storage/shared"
@ -597,11 +596,15 @@ func (s *eventStatements) SelectEventAuthEventNIDs(
result := make(map[types.EventNID][]types.EventNID) result := make(map[types.EventNID][]types.EventNID)
for rows.Next() { for rows.Next() {
var eventNID types.EventNID var eventNID types.EventNID
var authEventNIDs pq.Int64Array var authEventNIDs string
if err = rows.Scan(&authEventNIDs); err != nil { if err = rows.Scan(&authEventNIDs); err != nil {
return nil, err return nil, err
} }
for _, a := range authEventNIDs { var authEventNIDsArray []int64
if err := json.Unmarshal([]byte(authEventNIDs), &authEventNIDsArray); err != nil {
return nil, err
}
for _, a := range authEventNIDsArray {
result[eventNID] = append(result[eventNID], types.EventNID(a)) result[eventNID] = append(result[eventNID], types.EventNID(a))
} }
} }