mirror of
https://github.com/status-im/status-go.git
synced 2025-01-21 20:20:29 +00:00
fa390a52ae
* refactor TestRequestMessageFromMailboxAsync to use s.requestHistoricMessages helper * send p2pRequestResponseCode from mailserver * send p2p message response to after sending all historic messages * mailserver sends `whisper.NewSentMessage` as response * add mailserver Client and p2pRequestAckCode watchers * send event with envelopeFeed when p2pRequestAckCode is received * test request completed event in tracker * rename mailserver response events and code to RequestCompleteCode * wait for mailserver response in e2e test * use SendHistoricMessageResponse method name for mailserver response * fix lint warnings * add mailserver request expiration * send mailserver response without envelope * add `ttl` to Request struct in shhext_requestMessages * test that tracker calls handler.MailServerRequestExpired * add geth patch * rename TTL to Timeout * split tracker.handleEvent in multiple methods
30 lines
997 B
Go
30 lines
997 B
Go
package shhext
|
|
|
|
import (
|
|
"github.com/ethereum/go-ethereum/common"
|
|
"github.com/status-im/status-go/signal"
|
|
)
|
|
|
|
// EnvelopeSignalHandler sends signals when envelope is sent or expired.
|
|
type EnvelopeSignalHandler struct{}
|
|
|
|
// EnvelopeSent triggered when envelope delivered atleast to 1 peer.
|
|
func (h EnvelopeSignalHandler) EnvelopeSent(hash common.Hash) {
|
|
signal.SendEnvelopeSent(hash)
|
|
}
|
|
|
|
// EnvelopeExpired triggered when envelope is expired but wasn't delivered to any peer.
|
|
func (h EnvelopeSignalHandler) EnvelopeExpired(hash common.Hash) {
|
|
signal.SendEnvelopeExpired(hash)
|
|
}
|
|
|
|
// MailServerRequestCompleted triggered when mailserver send a ack with a requesID sent previously
|
|
func (h EnvelopeSignalHandler) MailServerRequestCompleted(hash common.Hash) {
|
|
signal.SendMailServerRequestCompleted(hash)
|
|
}
|
|
|
|
// MailServerRequestExpired triggered when mail server request expires
|
|
func (h EnvelopeSignalHandler) MailServerRequestExpired(hash common.Hash) {
|
|
signal.SendMailServerRequestExpired(hash)
|
|
}
|