Compare commits

...

1 commit

Author SHA1 Message Date
Till Faelligen 4a868f1687
Always try to get a roomInfo, avoid empty roomVersion? 2023-03-08 13:42:55 +01:00

View file

@ -333,12 +333,10 @@ func (r *Inputer) processRoomEvent(
} }
} }
if roomInfo == nil {
roomInfo, err = r.DB.GetOrCreateRoomInfo(ctx, event) roomInfo, err = r.DB.GetOrCreateRoomInfo(ctx, event)
if err != nil { if err != nil {
return fmt.Errorf("r.DB.GetOrCreateRoomInfo: %w", err) return fmt.Errorf("r.DB.GetOrCreateRoomInfo: %w", err)
} }
}
eventTypeNID, err := r.DB.GetOrCreateEventTypeNID(ctx, event.Type()) eventTypeNID, err := r.DB.GetOrCreateEventTypeNID(ctx, event.Type())
if err != nil { if err != nil {
@ -704,12 +702,10 @@ nextAuthEvent:
logger.WithError(err).Warnf("Auth event %s rejected", authEvent.EventID()) logger.WithError(err).Warnf("Auth event %s rejected", authEvent.EventID())
} }
if roomInfo == nil {
roomInfo, err = r.DB.GetOrCreateRoomInfo(ctx, authEvent) roomInfo, err = r.DB.GetOrCreateRoomInfo(ctx, authEvent)
if err != nil { if err != nil {
return fmt.Errorf("r.DB.GetOrCreateRoomInfo: %w", err) return fmt.Errorf("r.DB.GetOrCreateRoomInfo: %w", err)
} }
}
eventTypeNID, err := r.DB.GetOrCreateEventTypeNID(ctx, authEvent.Type()) eventTypeNID, err := r.DB.GetOrCreateEventTypeNID(ctx, authEvent.Type())
if err != nil { if err != nil {