61 lines
1.6 KiB
Go
61 lines
1.6 KiB
Go
|
package whisper
|
||
|
|
||
|
import (
|
||
|
"bytes"
|
||
|
"io/ioutil"
|
||
|
"net/http"
|
||
|
"testing"
|
||
|
|
||
|
"github.com/status-im/status-go/e2e"
|
||
|
"github.com/status-im/status-go/geth/node"
|
||
|
"github.com/status-im/status-go/geth/params"
|
||
|
"github.com/stretchr/testify/suite"
|
||
|
)
|
||
|
|
||
|
func TestMailServiceSuite(t *testing.T) {
|
||
|
suite.Run(t, new(MailServiceSuite))
|
||
|
}
|
||
|
|
||
|
type MailServiceSuite struct {
|
||
|
e2e.NodeManagerTestSuite
|
||
|
}
|
||
|
|
||
|
func (s *MailServiceSuite) SetupTest() {
|
||
|
s.NodeManager = node.NewNodeManager()
|
||
|
}
|
||
|
|
||
|
// TestShhRequestMessagesRPCMethodAvailability tests if `shh_requestMessages` is available
|
||
|
// through inproc and HTTP interfaces.
|
||
|
func (s *MailServiceSuite) TestShhRequestMessagesRPCMethodAvailability() {
|
||
|
r := s.Require()
|
||
|
|
||
|
s.StartTestNode(func(config *params.NodeConfig) {
|
||
|
config.RPCEnabled = true
|
||
|
})
|
||
|
defer s.StopTestNode()
|
||
|
|
||
|
client := s.NodeManager.RPCClient()
|
||
|
r.NotNil(client)
|
||
|
|
||
|
// This error means that the method is available through inproc communication
|
||
|
// as the validation of params occurred.
|
||
|
err := client.Call(nil, "shh_requestMessages", map[string]interface{}{})
|
||
|
r.EqualError(err, `invalid mailServerPeer value: invalid URL scheme, want "enode"`)
|
||
|
|
||
|
// Do the same but using HTTP interface.
|
||
|
req, err := http.NewRequest("POST", "http://localhost:8645", bytes.NewBuffer([]byte(`{
|
||
|
"jsonrpc": "2.0",
|
||
|
"id": 1,
|
||
|
"method": "shh_requestMessages",
|
||
|
"params": [{}]
|
||
|
}`)))
|
||
|
r.NoError(err)
|
||
|
resp, err := http.DefaultClient.Do(req)
|
||
|
r.NoError(err)
|
||
|
defer resp.Body.Close()
|
||
|
r.Equal(200, resp.StatusCode)
|
||
|
data, err := ioutil.ReadAll(resp.Body)
|
||
|
r.NoError(err)
|
||
|
r.Contains(string(data), `invalid mailServerPeer value`)
|
||
|
}
|