diff --git a/cmd/utils/flags.go b/cmd/utils/flags.go
index afaa7214b140e7664b9444e4b018195b8c0bff4a..e9b0d86a41a9c63dbe47246b6ad237ed337e3c2e 100644
--- a/cmd/utils/flags.go
+++ b/cmd/utils/flags.go
@@ -52,7 +52,7 @@ import (
"github.com/ethereum/go-ethereum/p2p/nat"
"github.com/ethereum/go-ethereum/p2p/netutil"
"github.com/ethereum/go-ethereum/params"
- whisper "github.com/ethereum/go-ethereum/whisper/whisperv2"
+ whisper "github.com/ethereum/go-ethereum/whisper/whisperv5"
"gopkg.in/urfave/cli.v1"
)
diff --git a/cmd/wnode/main.go b/cmd/wnode/main.go
index f9b689b65ffda61abc57f787fe01f4bc4467a1c9..f18025dff85285fe56b0df5ed0084a1e597fec57 100644
--- a/cmd/wnode/main.go
+++ b/cmd/wnode/main.go
@@ -183,7 +183,7 @@ func initialize() {
if *testMode {
symPass = "wwww" // ascii code: 0x77777777
- msPassword = "mail server test password"
+ msPassword = "wwww"
}
if *bootstrapMode {
@@ -330,7 +330,7 @@ func configureNode() {
if !*asymmetricMode && !*forwarderMode {
if len(symPass) == 0 {
- symPass, err = console.Stdin.PromptPassword("Please enter the password: ")
+ symPass, err = console.Stdin.PromptPassword("Please enter the password for symmetric encryption: ")
if err != nil {
utils.Fatalf("Failed to read passphrase: %v", err)
}
@@ -347,6 +347,8 @@ func configureNode() {
if len(*argTopic) == 0 {
generateTopic([]byte(symPass))
}
+
+ fmt.Printf("Filter is configured for the topic: %x \n", topic)
}
if *mailServerMode {
@@ -365,7 +367,6 @@ func configureNode() {
if err != nil {
utils.Fatalf("Failed to install filter: %s", err)
}
- fmt.Printf("Filter is configured for the topic: %x \n", topic)
}
func generateTopic(password []byte) {
diff --git a/internal/web3ext/web3ext.go b/internal/web3ext/web3ext.go
index c9cac125d535013fb9ada01e99a2d5f472636c4b..e35d74ae12ab13b4c335ee45cddbf7b74765ab84 100644
--- a/internal/web3ext/web3ext.go
+++ b/internal/web3ext/web3ext.go
@@ -525,7 +525,105 @@ web3._extend({
const Shh_JS = `
web3._extend({
property: 'shh',
- methods: [],
+ methods: [
+ new web3._extend.Method({
+ name: 'info',
+ call: 'shh_info'
+ }),
+ new web3._extend.Method({
+ name: 'setMaxMessageLength',
+ call: 'shh_setMaxMessageLength',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'setMinimumPoW',
+ call: 'shh_setMinimumPoW',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'allowP2PMessagesFromPeer',
+ call: 'shh_allowP2PMessagesFromPeer',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'hasKeyPair',
+ call: 'shh_hasKeyPair',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'deleteKeyPair',
+ call: 'shh_deleteKeyPair',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'newKeyPair',
+ call: 'shh_newKeyPair'
+ }),
+ new web3._extend.Method({
+ name: 'getPublicKey',
+ call: 'shh_getPublicKey',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'getPrivateKey',
+ call: 'shh_getPrivateKey',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'generateSymmetricKey',
+ call: 'shh_generateSymmetricKey',
+ }),
+ new web3._extend.Method({
+ name: 'addSymmetricKeyDirect',
+ call: 'shh_addSymmetricKeyDirect',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'addSymmetricKeyFromPassword',
+ call: 'shh_addSymmetricKeyFromPassword',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'hasSymmetricKey',
+ call: 'shh_hasSymmetricKey',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'getSymmetricKey',
+ call: 'shh_getSymmetricKey',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'deleteSymmetricKey',
+ call: 'shh_deleteSymmetricKey',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'subscribe',
+ call: 'shh_subscribe',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'unsubscribe',
+ call: 'shh_unsubscribe',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'getNewSubscriptionMessages',
+ call: 'shh_getNewSubscriptionMessages',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'getFloatingMessages',
+ call: 'shh_getFloatingMessages',
+ params: 1
+ }),
+ new web3._extend.Method({
+ name: 'post',
+ call: 'shh_post',
+ params: 1
+ })
+ ],
properties:
[
new web3._extend.Property({
@@ -536,6 +634,7 @@ web3._extend({
]
});
`
+
const SWARMFS_JS = `
web3._extend({
property: 'swarmfs',
diff --git a/mobile/geth.go b/mobile/geth.go
index 4d679fb539d540f0ce162838d69027294ad718de..f254d39bbf25c9971cac78fe7ec6328ad8f32a63 100644
--- a/mobile/geth.go
+++ b/mobile/geth.go
@@ -34,7 +34,7 @@ import (
"github.com/ethereum/go-ethereum/p2p"
"github.com/ethereum/go-ethereum/p2p/nat"
"github.com/ethereum/go-ethereum/params"
- whisper "github.com/ethereum/go-ethereum/whisper/whisperv2"
+ whisper "github.com/ethereum/go-ethereum/whisper/whisperv5"
)
// NodeConfig represents the collection of configuration values to fine tune the Geth
diff --git a/whisper/whisperv5/api.go b/whisper/whisperv5/api.go
index 841bbc2babc29d005b42b18a57cc1cfc7c099bea..1a4e4d87992d8b566df85daf837748a082194d7c 100644
--- a/whisper/whisperv5/api.go
+++ b/whisper/whisperv5/api.go
@@ -231,14 +231,14 @@ func (api *PublicWhisperAPI) Subscribe(args WhisperFilterArgs) (string, error) {
return "", errors.New("subscribe: " + err.Error())
}
- if len(args.SignedWith) > 0 {
- sb := common.FromHex(args.SignedWith)
+ if len(args.Sig) > 0 {
+ sb := common.FromHex(args.Sig)
if sb == nil {
- return "", errors.New("subscribe: SignedWith parameter is invalid")
+ return "", errors.New("subscribe: sig parameter is invalid")
}
filter.Src = crypto.ToECDSAPub(sb)
if !ValidatePublicKey(filter.Src) {
- return "", errors.New("subscribe: invalid 'SignedWith' field")
+ return "", errors.New("subscribe: invalid 'sig' field")
}
}
@@ -319,8 +319,8 @@ func (api *PublicWhisperAPI) Post(args PostArgs) error {
return errors.New("post: key is missing")
}
- if len(args.SignWith) > 0 {
- params.Src, err = api.whisper.GetPrivateKey(args.SignWith)
+ if len(args.Sig) > 0 {
+ params.Src, err = api.whisper.GetPrivateKey(args.Sig)
if err != nil {
return err
}
@@ -391,7 +391,7 @@ func (api *PublicWhisperAPI) Post(args PostArgs) error {
type PostArgs struct {
Type string `json:"type"` // "sym"/"asym" (symmetric or asymmetric)
TTL uint32 `json:"ttl"` // time-to-live in seconds
- SignWith string `json:"signWith"` // id of the signing key
+ Sig string `json:"sig"` // id of the signing key
Key string `json:"key"` // key id (in case of sym) or public key (in case of asym)
Topic hexutil.Bytes `json:"topic"` // topic (4 bytes)
Padding hexutil.Bytes `json:"padding"` // optional padding bytes
@@ -402,12 +402,12 @@ type PostArgs struct {
}
type WhisperFilterArgs struct {
- Symmetric bool // encryption type
- Key string // id of the key to be used for decryption
- SignedWith string // public key of the sender to be verified
- MinPoW float64 // minimal PoW requirement
- Topics [][]byte // list of topics (up to 4 bytes each) to match
- AllowP2P bool // indicates wheather direct p2p messages are allowed for this filter
+ Symmetric bool // encryption type
+ Key string // id of the key to be used for decryption
+ Sig string // public key of the sender to be verified
+ MinPoW float64 // minimal PoW requirement
+ Topics [][]byte // list of topics (up to 4 bytes each) to match
+ AllowP2P bool // indicates wheather direct p2p messages are allowed for this filter
}
// UnmarshalJSON implements the json.Unmarshaler interface, invoked to convert a
@@ -415,12 +415,12 @@ type WhisperFilterArgs struct {
func (args *WhisperFilterArgs) UnmarshalJSON(b []byte) (err error) {
// Unmarshal the JSON message and sanity check
var obj struct {
- Type string `json:"type"`
- Key string `json:"key"`
- SignedWith string `json:"signedWith"`
- MinPoW float64 `json:"minPoW"`
- Topics []interface{} `json:"topics"`
- AllowP2P bool `json:"allowP2P"`
+ Type string `json:"type"`
+ Key string `json:"key"`
+ Sig string `json:"sig"`
+ MinPoW float64 `json:"minPoW"`
+ Topics []interface{} `json:"topics"`
+ AllowP2P bool `json:"allowP2P"`
}
if err := json.Unmarshal(b, &obj); err != nil {
return err
@@ -436,7 +436,7 @@ func (args *WhisperFilterArgs) UnmarshalJSON(b []byte) (err error) {
}
args.Key = obj.Key
- args.SignedWith = obj.SignedWith
+ args.Sig = obj.Sig
args.MinPoW = obj.MinPoW
args.AllowP2P = obj.AllowP2P
@@ -472,7 +472,7 @@ type WhisperMessage struct {
Topic string `json:"topic"`
Payload string `json:"payload"`
Padding string `json:"padding"`
- Src string `json:"signedWith"`
+ Src string `json:"sig"`
Dst string `json:"recipientPublicKey"`
Timestamp uint32 `json:"timestamp"`
TTL uint32 `json:"ttl"`
diff --git a/whisper/whisperv5/api_test.go b/whisper/whisperv5/api_test.go
index c837b0a145662c085f5203e98f809538005f8a46..a6d82d85050175382a85e6c7e8172cda78bb4998 100644
--- a/whisper/whisperv5/api_test.go
+++ b/whisper/whisperv5/api_test.go
@@ -173,7 +173,7 @@ func TestUnmarshalFilterArgs(t *testing.T) {
s := []byte(`{
"type":"sym",
"key":"0x70c87d191324e6712a591f304b4eedef6ad9bb9d",
- "signedWith":"0x9b2055d370f73ec7d8a03e965129118dc8f5bf83",
+ "sig":"0x9b2055d370f73ec7d8a03e965129118dc8f5bf83",
"minPoW":2.34,
"topics":["0x00000000", "0x007f80ff", "0xff807f00", "0xf26e7779"],
"allowP2P":true
@@ -191,8 +191,8 @@ func TestUnmarshalFilterArgs(t *testing.T) {
if f.Key != "0x70c87d191324e6712a591f304b4eedef6ad9bb9d" {
t.Fatalf("wrong key: %s.", f.Key)
}
- if f.SignedWith != "0x9b2055d370f73ec7d8a03e965129118dc8f5bf83" {
- t.Fatalf("wrong SignedWith: %s.", f.SignedWith)
+ if f.Sig != "0x9b2055d370f73ec7d8a03e965129118dc8f5bf83" {
+ t.Fatalf("wrong sig: %s.", f.Sig)
}
if f.MinPoW != 2.34 {
t.Fatalf("wrong MinPoW: %f.", f.MinPoW)
@@ -229,7 +229,7 @@ func TestUnmarshalPostArgs(t *testing.T) {
s := []byte(`{
"type":"sym",
"ttl":12345,
- "signWith":"0x70c87d191324e6712a591f304b4eedef6ad9bb9d",
+ "sig":"0x70c87d191324e6712a591f304b4eedef6ad9bb9d",
"key":"0x9b2055d370f73ec7d8a03e965129118dc8f5bf83",
"topic":"0xf26e7779",
"padding":"0x74686973206973206D79207465737420737472696E67",
@@ -251,8 +251,8 @@ func TestUnmarshalPostArgs(t *testing.T) {
if a.TTL != 12345 {
t.Fatalf("wrong ttl: %d.", a.TTL)
}
- if a.SignWith != "0x70c87d191324e6712a591f304b4eedef6ad9bb9d" {
- t.Fatalf("wrong From: %s.", a.SignWith)
+ if a.Sig != "0x70c87d191324e6712a591f304b4eedef6ad9bb9d" {
+ t.Fatalf("wrong From: %s.", a.Sig)
}
if a.Key != "0x9b2055d370f73ec7d8a03e965129118dc8f5bf83" {
t.Fatalf("wrong Key: %s.", a.Key)
@@ -347,7 +347,7 @@ func TestIntegrationAsym(t *testing.T) {
var f WhisperFilterArgs
f.Symmetric = false
f.Key = key
- f.SignedWith = sigPubKey.String()
+ f.Sig = sigPubKey.String()
f.Topics = make([][]byte, 2)
f.Topics[0] = topics[0][:]
f.Topics[1] = topics[1][:]
@@ -362,7 +362,7 @@ func TestIntegrationAsym(t *testing.T) {
var p PostArgs
p.Type = "asym"
p.TTL = 2
- p.SignWith = sig
+ p.Sig = sig
p.Key = dstPubKey.String()
p.Padding = []byte("test string")
p.Payload = []byte("extended test string")
@@ -449,7 +449,7 @@ func TestIntegrationSym(t *testing.T) {
f.Topics[0] = topics[0][:]
f.Topics[1] = topics[1][:]
f.MinPoW = DefaultMinimumPoW / 2
- f.SignedWith = sigPubKey.String()
+ f.Sig = sigPubKey.String()
f.AllowP2P = false
id, err := api.Subscribe(f)
@@ -461,7 +461,7 @@ func TestIntegrationSym(t *testing.T) {
p.Type = "sym"
p.TTL = 1
p.Key = symKeyID
- p.SignWith = sig
+ p.Sig = sig
p.Padding = []byte("test string")
p.Payload = []byte("extended test string")
p.PowTarget = DefaultMinimumPoW
@@ -547,7 +547,7 @@ func TestIntegrationSymWithFilter(t *testing.T) {
f.Topics[0] = topics[0][:]
f.Topics[1] = topics[1][:]
f.MinPoW = DefaultMinimumPoW / 2
- f.SignedWith = sigPubKey.String()
+ f.Sig = sigPubKey.String()
f.AllowP2P = false
id, err := api.Subscribe(f)
@@ -559,7 +559,7 @@ func TestIntegrationSymWithFilter(t *testing.T) {
p.Type = "sym"
p.TTL = 1
p.Key = symKeyID
- p.SignWith = sigKeyID
+ p.Sig = sigKeyID
p.Padding = []byte("test string")
p.Payload = []byte("extended test string")
p.PowTarget = DefaultMinimumPoW