commit ec351f78ad68f079993aa258760e4b9bd3992a1d
Author: Wim <wim@42.be>
Date: Wed Feb 27 20:52:05 2019 +0000
Handle file upload/download only once for each message (#742)
diff --git a/gateway/router.go b/gateway/router.go
index 7d16b07..613a2c4 100644
--- a/gateway/router.go
+++ b/gateway/router.go
@@ -1256 +1257 @@ func (r *Router) handleReceive() {
r.handleEventGetChannelMembers(&msg)
r.handleEventFailure(&msg)
r.handleEventRejoinChannels(&msg)
+ idx := 0
for _, gw := range r.Gateways {
// record all the message ID's of the different bridges
var msgIDs []*BrMsgID
@@ -1337 +1349 @@ func (r *Router) handleReceive() {
}
msg.Timestamp = time.Now()
gw.modifyMessage(&msg)
- gw.handleFiles(&msg)
+ if idx == 0 {
+ gw.handleFiles(&msg)
+ }
for _, br := range gw.Bridges {
msgIDs = append(msgIDs, gw.handleMessage(&msg, br)...)
}
@@ -1416 +1447 @@ func (r *Router) handleReceive() {
if _, ok := gw.Messages.Get(msg.Protocol + " " + msg.ID); !ok && msg.ID != "" {
gw.Messages.Add(msg.Protocol+" "+msg.ID, msgIDs)
}
+ idx++
}
}
}
