Compare commits
1 commit
main
...
s7evink/ro
Author | SHA1 | Date | |
---|---|---|---|
4a868f1687 |
|
@ -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 {
|
||||||
|
|
Loading…
Reference in a new issue