2016-06-15 19:50:35 +00:00
|
|
|
package main
|
|
|
|
|
|
|
|
import (
|
2016-06-20 15:21:45 +00:00
|
|
|
"errors"
|
2016-06-15 19:50:35 +00:00
|
|
|
"fmt"
|
2016-06-22 18:56:27 +00:00
|
|
|
"io/ioutil"
|
|
|
|
"time"
|
2016-06-15 19:50:35 +00:00
|
|
|
|
|
|
|
"github.com/ethereum/go-ethereum/accounts"
|
2016-06-21 18:29:38 +00:00
|
|
|
"github.com/ethereum/go-ethereum/cmd/utils"
|
2016-06-22 18:56:27 +00:00
|
|
|
"github.com/ethereum/go-ethereum/common"
|
2016-06-21 14:34:38 +00:00
|
|
|
"github.com/ethereum/go-ethereum/crypto"
|
|
|
|
errextra "github.com/pkg/errors"
|
2016-06-15 19:50:35 +00:00
|
|
|
)
|
|
|
|
|
|
|
|
var (
|
2016-06-30 12:53:17 +00:00
|
|
|
scryptN = 4096
|
|
|
|
scryptP = 6
|
2016-06-15 19:50:35 +00:00
|
|
|
)
|
|
|
|
|
2016-06-21 14:07:24 +00:00
|
|
|
// createAccount creates an internal geth account
|
2016-07-01 13:23:39 +00:00
|
|
|
func createAccount(password string) (string, string, error) {
|
2016-06-15 19:50:35 +00:00
|
|
|
|
2016-06-29 11:32:04 +00:00
|
|
|
if currentNode != nil {
|
|
|
|
|
|
|
|
w := true
|
2016-07-03 19:44:31 +00:00
|
|
|
keydir := datadir + "/testnet/keystore"
|
2016-07-01 15:43:55 +00:00
|
|
|
accman := accounts.NewManager(keydir, scryptN, scryptP, accountSync)
|
2016-06-29 11:32:04 +00:00
|
|
|
|
|
|
|
// generate the account
|
|
|
|
account, err := accman.NewAccount(password, w)
|
|
|
|
if err != nil {
|
|
|
|
return "", "", errextra.Wrap(err, "Account manager could not create the account")
|
|
|
|
}
|
|
|
|
address := fmt.Sprintf("%x", account.Address)
|
|
|
|
|
|
|
|
// recover the public key to return
|
|
|
|
keyContents, err := ioutil.ReadFile(account.File)
|
|
|
|
if err != nil {
|
|
|
|
return address, "", errextra.Wrap(err, "Could not load the key contents")
|
|
|
|
}
|
|
|
|
key, err := accounts.DecryptKey(keyContents, password)
|
|
|
|
if err != nil {
|
|
|
|
return address, "", errextra.Wrap(err, "Could not recover the key")
|
|
|
|
}
|
|
|
|
pubKey := common.ToHex(crypto.FromECDSAPub(&key.PrivateKey.PublicKey))
|
|
|
|
|
|
|
|
return address, pubKey, nil
|
2016-06-22 18:56:27 +00:00
|
|
|
|
2016-06-21 14:34:38 +00:00
|
|
|
}
|
|
|
|
|
2016-06-29 11:32:04 +00:00
|
|
|
return "", "", errors.New("No running node detected for account creation")
|
2016-06-15 19:50:35 +00:00
|
|
|
|
|
|
|
}
|
2016-06-20 15:21:45 +00:00
|
|
|
|
2016-06-21 18:29:38 +00:00
|
|
|
// unlockAccount unlocks an existing account for a certain duration and
|
|
|
|
// inject the account as a whisper identity if the account was created as
|
|
|
|
// a whisper enabled account
|
2016-06-22 18:56:27 +00:00
|
|
|
func unlockAccount(address, password string, seconds int) error {
|
2016-06-21 18:29:38 +00:00
|
|
|
|
|
|
|
if currentNode != nil {
|
|
|
|
|
2016-07-01 15:43:55 +00:00
|
|
|
accman := utils.MakeAccountManager(c, accountSync)
|
2016-06-21 18:29:38 +00:00
|
|
|
account, err := utils.MakeAddress(accman, address)
|
|
|
|
if err != nil {
|
|
|
|
return errextra.Wrap(err, "Could not retrieve account from address")
|
|
|
|
}
|
|
|
|
|
2016-06-22 18:56:27 +00:00
|
|
|
err = accman.TimedUnlock(account, password, time.Duration(seconds)*time.Second)
|
2016-06-21 18:29:38 +00:00
|
|
|
if err != nil {
|
|
|
|
return errextra.Wrap(err, "Could not decrypt account")
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
return errors.New("No running node detected for account unlock")
|
|
|
|
|
|
|
|
}
|
|
|
|
|
2016-06-21 14:07:24 +00:00
|
|
|
// createAndStartNode creates a node entity and starts the
|
|
|
|
// node running locally
|
2016-07-01 13:23:39 +00:00
|
|
|
func createAndStartNode(inputDir string) error {
|
2016-06-20 15:21:45 +00:00
|
|
|
|
2016-07-01 13:23:39 +00:00
|
|
|
currentNode = MakeNode(inputDir)
|
2016-06-20 15:21:45 +00:00
|
|
|
if currentNode != nil {
|
2016-06-29 11:32:04 +00:00
|
|
|
RunNode(currentNode)
|
2016-06-20 15:21:45 +00:00
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
return errors.New("Could not create the in-memory node object")
|
|
|
|
|
|
|
|
}
|