lug/matterbridge
10
0
Fork 2
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

router: minor handleReceive tweak

Browse Source
This commit is contained in:
Qais Patankar
2019-06-19 13:59:21 +01:00
parent fba2749b0b
commit 84c6e96c9d
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
gateway/router.go
View File

@@ -125,7 +125,8 @@ func (r *Router) handleReceive() {
r.handleEventGetChannelMembers(&msg) r.handleEventGetChannelMembers(&msg)
r.handleEventFailure(&msg) r.handleEventFailure(&msg)
r.handleEventRejoinChannels(&msg) r.handleEventRejoinChannels(&msg)
idx := 0
filesHandled := false
for _, gw := range r.Gateways { for _, gw := range r.Gateways {
// record all the message ID's of the different bridges // record all the message ID's of the different bridges
var msgIDs []*BrMsgID var msgIDs []*BrMsgID
@@ -134,8 +135,9 @@ func (r *Router) handleReceive() {
} }
msg.Timestamp = time.Now() msg.Timestamp = time.Now()
gw.modifyMessage(&msg) gw.modifyMessage(&msg)
if idx == 0 { if !filesHandled {
gw.handleFiles(&msg) gw.handleFiles(&msg)
filesHandled = true
} }
for _, br := range gw.Bridges { for _, br := range gw.Bridges {
msgIDs = append(msgIDs, gw.handleMessage(&msg, br)...) msgIDs = append(msgIDs, gw.handleMessage(&msg, br)...)
@@ -144,8 +146,6 @@ func (r *Router) handleReceive() {
// Always add/update the message ID. This is necessary as msgIDs // Always add/update the message ID. This is necessary as msgIDs
// will change if a bridge returns a different ID in response to edits. // will change if a bridge returns a different ID in response to edits.
gw.Messages.Add(msg.Protocol+" "+msg.ID, msgIDs) gw.Messages.Add(msg.Protocol+" "+msg.ID, msgIDs)
idx++
} }
} }
} }