This commit is contained in:
Neil Alexander 2022-09-28 13:58:30 +01:00
parent 232d69512c
commit d6cfce2e22
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
6 changed files with 7 additions and 7 deletions

View file

@ -454,7 +454,7 @@ func (s *OutputRoomEventConsumer) updateStateEvent(event *gomatrixserverlib.Head
if err != nil {
return nil, err
}
defer snapshot.Rollback() // nolint:err
defer snapshot.Rollback() // nolint:errcheck
prevEvent, err := snapshot.GetStateEvent(
s.ctx, event.RoomID(), event.Type(), stateKey,

View file

@ -323,7 +323,7 @@ func (n *Notifier) Load(ctx context.Context, db storage.Database) error {
if err != nil {
return err
}
defer snapshot.Rollback() // nolint:err
defer snapshot.Rollback() // nolint:errcheck
roomToUsers, err := snapshot.AllJoinedUsersInRooms(ctx)
if err != nil {
@ -349,7 +349,7 @@ func (n *Notifier) LoadRooms(ctx context.Context, db storage.Database, roomIDs [
if err != nil {
return err
}
defer snapshot.Rollback() // nolint:err
defer snapshot.Rollback() // nolint:errcheck
roomToUsers, err := snapshot.AllJoinedUsersInRoom(ctx, roomIDs)
if err != nil {

View file

@ -55,7 +55,7 @@ func Context(
if err != nil {
return jsonerror.InternalServerError()
}
defer snapshot.Rollback() // nolint:err
defer snapshot.Rollback() // nolint:errcheck
filter, err := parseRoomEventFilter(req)
if err != nil {

View file

@ -49,7 +49,7 @@ func GetFilter(
if err != nil {
return jsonerror.InternalServerError()
}
defer snapshot.Rollback() // nolint:err
defer snapshot.Rollback() // nolint:errcheck
filter := gomatrixserverlib.DefaultFilter()
if err := snapshot.GetFilter(req.Context(), &filter, localpart, filterID); err != nil {

View file

@ -75,7 +75,7 @@ func OnIncomingMessagesRequest(
if err != nil {
return jsonerror.InternalServerError()
}
defer snapshot.Rollback() // nolint:err
defer snapshot.Rollback() // nolint:errcheck
// check if the user has already forgotten about this room
isForgotten, roomExists, err := checkIsRoomForgotten(req.Context(), roomID, device.UserID, rsAPI)

View file

@ -65,7 +65,7 @@ func Search(req *http.Request, device *api.Device, syncDB storage.Database, fts
if err != nil {
return jsonerror.InternalServerError()
}
defer snapshot.Rollback() // nolint:err
defer snapshot.Rollback() // nolint:errcheck
// only search rooms the user is actually joined to
joinedRooms, err := snapshot.RoomIDsWithMembership(ctx, device.UserID, "join")