|
|
@ -320,12 +320,6 @@ func (p *EthereumApi) NewWhisperFilter(args *WhisperFilterArgs, reply *interface |
|
|
|
return nil |
|
|
|
return nil |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func (p *EthereumApi) UninstallWhisperFilter(id int, reply *interface{}) error { |
|
|
|
|
|
|
|
delete(p.messages, id) |
|
|
|
|
|
|
|
*reply = true |
|
|
|
|
|
|
|
return nil |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func (self *EthereumApi) MessagesChanged(id int, reply *interface{}) error { |
|
|
|
func (self *EthereumApi) MessagesChanged(id int, reply *interface{}) error { |
|
|
|
self.messagesMut.Lock() |
|
|
|
self.messagesMut.Lock() |
|
|
|
defer self.messagesMut.Unlock() |
|
|
|
defer self.messagesMut.Unlock() |
|
|
@ -725,7 +719,12 @@ func (p *EthereumApi) GetRequestReply(req *RpcRequest, reply *interface{}) error |
|
|
|
if err := json.Unmarshal(req.Params, &args); err != nil { |
|
|
|
if err := json.Unmarshal(req.Params, &args); err != nil { |
|
|
|
return err |
|
|
|
return err |
|
|
|
} |
|
|
|
} |
|
|
|
return p.UninstallWhisperFilter(args.Id, reply) |
|
|
|
|
|
|
|
|
|
|
|
if _, ok := p.messages[args.Id]; ok { |
|
|
|
|
|
|
|
delete(p.messages, args.Id) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
*reply = true |
|
|
|
case "shh_getFilterChanges": |
|
|
|
case "shh_getFilterChanges": |
|
|
|
args := new(FilterIdArgs) |
|
|
|
args := new(FilterIdArgs) |
|
|
|
if err := json.Unmarshal(req.Params, &args); err != nil { |
|
|
|
if err := json.Unmarshal(req.Params, &args); err != nil { |
|
|
|