This commit is contained in:
Neil Alexander 2021-07-28 16:26:21 +01:00
parent 946d15f976
commit 3dd80d4cd2
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
2 changed files with 6 additions and 2 deletions

View file

@ -68,7 +68,6 @@ func (s *crossSigningKeysStatements) SelectCrossSigningKeysForUser(
return nil, err
}
defer internal.CloseAndLogIfError(ctx, rows, "selectCrossSigningKeysForUserStmt: rows.close() failed")
r = api.CrossSigningKeyMap{}
for rows.Next() {
var keyType gomatrixserverlib.CrossSigningKeyPurpose
var keyID gomatrixserverlib.KeyID
@ -76,6 +75,9 @@ func (s *crossSigningKeysStatements) SelectCrossSigningKeysForUser(
if err := rows.Scan(&keyType, &keyID, &keyData); err != nil {
return nil, err
}
if _, ok := r[keyType]; !ok {
r[keyType] = map[gomatrixserverlib.KeyID]gomatrixserverlib.Base64Bytes{}
}
r[keyType][keyID] = keyData
}
return

View file

@ -68,7 +68,6 @@ func (s *crossSigningKeysStatements) SelectCrossSigningKeysForUser(
return nil, err
}
defer internal.CloseAndLogIfError(ctx, rows, "selectCrossSigningKeysForUserStmt: rows.close() failed")
r = api.CrossSigningKeyMap{}
for rows.Next() {
var keyType gomatrixserverlib.CrossSigningKeyPurpose
var keyID gomatrixserverlib.KeyID
@ -76,6 +75,9 @@ func (s *crossSigningKeysStatements) SelectCrossSigningKeysForUser(
if err := rows.Scan(&keyType, &keyID, &keyData); err != nil {
return nil, err
}
if _, ok := r[keyType]; !ok {
r[keyType] = map[gomatrixserverlib.KeyID]gomatrixserverlib.Base64Bytes{}
}
r[keyType][keyID] = keyData
}
return