narayana/go-xmpp
2
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Changelog and doc

Browse source
This commit is contained in:
rcorniere 2020-03-09 17:19:29 +01:00
parent 7a932d0504
commit 477a2b114c
2 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
CHANGELOG.md
View file

@ -8,6 +8,8 @@
- Added message queue : when using "SendX" methods on a client, messages are also stored in a queue. When requesting - Added message queue : when using "SendX" methods on a client, messages are also stored in a queue. When requesting
acks from the server, sent messages will be discarded, and unsent ones will be sent again. (see https://xmpp.org/extensions/xep-0198.html#acking) acks from the server, sent messages will be discarded, and unsent ones will be sent again. (see https://xmpp.org/extensions/xep-0198.html#acking)
- Added support for stanza_errors (see https://xmpp.org/rfcs/rfc3920.html#def C.2. Stream error namespace and https://xmpp.org/rfcs/rfc6120.html#schemas-streamerror) - Added support for stanza_errors (see https://xmpp.org/rfcs/rfc3920.html#def C.2. Stream error namespace and https://xmpp.org/rfcs/rfc6120.html#schemas-streamerror)
- Added separate hooks for connection and reconnection on the client. One can now specify different actions to get triggered on client connect
and reconnect, at client init time.
- Client state update is now thread safe - Client state update is now thread safe
- Changed the Config struct to use pointer semantics - Changed the Config struct to use pointer semantics
- Tests - Tests

3
router.go
View file

@ -81,6 +81,7 @@ func (r *Router) route(s Sender, p stanza.Packet) {
} }
} }
// SendMissingStz sends all stanzas that did not reach the server, according to the response to an ack request (see XEP-0198, acks)
func SendMissingStz(lastSent int, s Sender, uaq *stanza.UnAckQueue) error { func SendMissingStz(lastSent int, s Sender, uaq *stanza.UnAckQueue) error {
uaq.RWMutex.Lock() uaq.RWMutex.Lock()
if len(uaq.Uslice) <= 0 { if len(uaq.Uslice) <= 0 {
@ -100,7 +101,7 @@ func SendMissingStz(lastSent int, s Sender, uaq *stanza.UnAckQueue) error {
} }
} }
// Ask for updates on stanzas we just sent to the entity // Ask for updates on stanzas we just sent to the entity. Not sure I should leave this. Maybe let users call ack again by themselves ?
s.Send(stanza.SMRequest{}) s.Send(stanza.SMRequest{})
} }
uaq.RWMutex.Unlock() uaq.RWMutex.Unlock()