aboutsummaryrefslogtreecommitdiffstats
path: root/rpc/api/personal.go
diff options
context:
space:
mode:
authorBas van Kervel <bas@ethdev.com>2015-06-09 16:59:44 +0800
committerBas van Kervel <basvankervel@gmail.com>2015-06-11 20:01:41 +0800
commit08d72a9245ce6f1e11f84a6b59d66cb083bea9f9 (patch)
treeb265308ff4e6991be1ebdb74c4618759b30e22b4 /rpc/api/personal.go
parent09d0d55fc579701191ff34f38cc20b437ee23577 (diff)
downloaddexon-08d72a9245ce6f1e11f84a6b59d66cb083bea9f9.tar.gz
dexon-08d72a9245ce6f1e11f84a6b59d66cb083bea9f9.tar.zst
dexon-08d72a9245ce6f1e11f84a6b59d66cb083bea9f9.zip
added personal API
Diffstat (limited to 'rpc/api/personal.go')
-rw-r--r--rpc/api/personal.go118
1 files changed, 118 insertions, 0 deletions
diff --git a/rpc/api/personal.go b/rpc/api/personal.go
new file mode 100644
index 000000000..d00363627
--- /dev/null
+++ b/rpc/api/personal.go
@@ -0,0 +1,118 @@
+package api
+
+import (
+ "time"
+
+ "github.com/ethereum/go-ethereum/common"
+ "github.com/ethereum/go-ethereum/eth"
+ "github.com/ethereum/go-ethereum/rpc/codec"
+ "github.com/ethereum/go-ethereum/rpc/shared"
+ "github.com/ethereum/go-ethereum/xeth"
+)
+
+var (
+ // mapping between methods and handlers
+ personalMapping = map[string]personalhandler{
+ "personal_listAccounts": (*personal).ListAccounts,
+ "personal_newAccount": (*personal).NewAccount,
+ "personal_deleteAccount": (*personal).DeleteAccount,
+ "personal_unlockAccount": (*personal).UnlockAccount,
+ }
+)
+
+// net callback handler
+type personalhandler func(*personal, *shared.Request) (interface{}, error)
+
+// net api provider
+type personal struct {
+ xeth *xeth.XEth
+ ethereum *eth.Ethereum
+ methods map[string]personalhandler
+ codec codec.ApiCoder
+}
+
+// create a new net api instance
+func NewPersonal(xeth *xeth.XEth, eth *eth.Ethereum, coder codec.Codec) *personal {
+ return &personal{
+ xeth: xeth,
+ ethereum: eth,
+ methods: personalMapping,
+ codec: coder.New(nil),
+ }
+}
+
+// collection with supported methods
+func (self *personal) Methods() []string {
+ methods := make([]string, len(self.methods))
+ i := 0
+ for k := range self.methods {
+ methods[i] = k
+ i++
+ }
+ return methods
+}
+
+// Execute given request
+func (self *personal) Execute(req *shared.Request) (interface{}, error) {
+ if callback, ok := self.methods[req.Method]; ok {
+ return callback(self, req)
+ }
+
+ return nil, shared.NewNotImplementedError(req.Method)
+}
+
+func (self *personal) Name() string {
+ return PersonalApiName
+}
+
+func (self *personal) ListAccounts(req *shared.Request) (interface{}, error) {
+ return self.xeth.Accounts(), nil
+}
+
+func (self *personal) NewAccount(req *shared.Request) (interface{}, error) {
+ args := new(NewAccountArgs)
+ if err := self.codec.Decode(req.Params, &args); err != nil {
+ return nil, shared.NewDecodeParamError(err.Error())
+ }
+
+ am := self.ethereum.AccountManager()
+ acc, err := am.NewAccount(args.Passphrase)
+ return acc.Address.Hex(), err
+}
+
+func (self *personal) DeleteAccount(req *shared.Request) (interface{}, error) {
+ args := new(DeleteAccountArgs)
+ if err := self.codec.Decode(req.Params, &args); err != nil {
+ return nil, shared.NewDecodeParamError(err.Error())
+ }
+
+ addr := common.HexToAddress(args.Address)
+ am := self.ethereum.AccountManager()
+ if err := am.DeleteAccount(addr, args.Passphrase); err == nil {
+ return true, nil
+ } else {
+ return false, err
+ }
+}
+
+func (self *personal) UnlockAccount(req *shared.Request) (interface{}, error) {
+ args := new(UnlockAccountArgs)
+ if err := self.codec.Decode(req.Params, &args); err != nil {
+ return nil, shared.NewDecodeParamError(err.Error())
+ }
+
+ var err error
+ am := self.ethereum.AccountManager()
+ addr := common.HexToAddress(args.Address)
+
+ if args.Duration == -1 {
+ err = am.Unlock(addr, args.Passphrase)
+ } else {
+ err = am.TimedUnlock(addr, args.Passphrase, time.Duration(args.Duration)*time.Second)
+ }
+
+ if err == nil {
+ return true, nil
+ }
+ return false, err
+}