mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-20 20:43:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix linter issues

Browse source
This commit is contained in:
Till Faelligen 2022-11-09 12:09:08 +01:00
parent 57273b9345
commit adef1e8690
No known key found for this signature in database
GPG key ID: ACCDC9606D472758
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
federationapi/consumers/roomserver.go
View file

@ -255,7 +255,8 @@ func (s *OutputRoomEventConsumer) sendPresence(roomID string, addedJoined []type
msg := nats.NewMsg(s.topicPresence) msg := nats.NewMsg(s.topicPresence)
msg.Header.Set(jetstream.UserID, ev.Sender) msg.Header.Set(jetstream.UserID, ev.Sender)
presence, err := s.natsClient.RequestMsg(msg, time.Second*10) var presence *nats.Msg
presence, err = s.natsClient.RequestMsg(msg, time.Second*10)
if err != nil { if err != nil {
log.WithError(err).Errorf("unable to get presence") log.WithError(err).Errorf("unable to get presence")
continue continue
@ -266,7 +267,8 @@ func (s *OutputRoomEventConsumer) sendPresence(roomID string, addedJoined []type
if e != "" { if e != "" {
continue continue
} }
lastActive, err := strconv.Atoi(presence.Header.Get("last_active_ts")) var lastActive int
lastActive, err = strconv.Atoi(presence.Header.Get("last_active_ts"))
if err != nil { if err != nil {
continue continue
} }