genofire
/
unified-push-xmpp
2
1
Fork 1
Code Issues 6 Pull Requests 3 Projects Releases Activity

Compare commits

base: genofire:main
Branches Tags
genofire:main
genofire:license
genofire:docs-service-discovery
karmanyaahm:history
karmanyaahm:main
karmanyaahm:history_old
karmanyaahm:h
..
compare: karmanyaahm:main
Branches Tags
karmanyaahm:history
karmanyaahm:main
karmanyaahm:history_old
karmanyaahm:h
genofire:main
genofire:license
genofire:docs-service-discovery

No commits in common. "main" and "main" have entirely different histories.
main ... main

2 changed files with 5 additions and 4 deletions
Show Stats Expand all files Collapse all files

2
distributor/go.mod
View File

@ -36,3 +36,5 @@ require (
)
replace dev.sum7.eu/genofire/unified-push-xmpp/messages => ../messages
replace mellium.im/xmpp => ../../../../mellium.im/xmpp

7
distributor/xmpp.go
View File

@ -6,7 +6,6 @@ import (
"encoding/xml"
"errors"
"io"
"strings"
"time"
"github.com/bdlm/log"
@ -113,7 +112,7 @@ func (s *XMPPService) message(msgHead stanza.Message, t xmlstream.TokenReadEncod
return nil
}
from := msgHead.From.String()
if settings := strings.Split(conn.Settings, ":"); !(len(settings) > 1 && settings[0] == from) {
if from != conn.Settings {
log.WithField("from", from).Info("message not from gateway, that is no notification")
return nil
}
@ -179,7 +178,7 @@ func (s *XMPPService) selectGateway() {
if s.KeepGateway {
return
}
conns := s.store.GetUnequalSettings(s.gateway.String() + ":" + s.session.LocalAddr().Bare().String())
conns := s.store.GetUnequalSettings(s.gateway.String())
if len(conns) <= 0 {
return
}
@ -243,7 +242,7 @@ func (s *XMPPService) Register(appID, appToken string) (string, string, error) {
"appID": appID,
"appToken": appToken,
})
conn := s.store.NewConnection(appID, appToken, s.gateway.String()+":"+s.session.LocalAddr().Bare().String())
conn := s.store.NewConnection(appID, appToken, s.gateway.String())
if conn == nil {
errStr := "error to store public token"
err := errors.New(errStr)