aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--ethereal/Makefile (renamed from Makefile)0
-rw-r--r--ethereal/assets/facet.png (renamed from facet.png)bin27302 -> 27302 bytes
-rw-r--r--ethereal/assets/net.png (renamed from net.png)bin4669 -> 4669 bytes
-rw-r--r--ethereal/assets/network.png (renamed from network.png)bin2900 -> 2900 bytes
-rw-r--r--ethereal/assets/new.png (renamed from new.png)bin4776 -> 4776 bytes
-rw-r--r--ethereal/assets/qml/test_app.qml (renamed from qml/test_app.qml)0
-rw-r--r--ethereal/assets/qml/transactions.qml (renamed from qml/transactions.qml)0
-rw-r--r--ethereal/assets/qml/wallet.qml (renamed from qml/wallet.qml)0
-rw-r--r--ethereal/assets/tx.png (renamed from tx.png)bin4070 -> 4070 bytes
-rw-r--r--ethereal/config.go34
-rw-r--r--ethereal/ethereum.go110
-rw-r--r--ethereal/ui/gui.go (renamed from ui/gui.go)0
-rw-r--r--ethereal/ui/library.go (renamed from ui/library.go)0
-rw-r--r--ethereal/ui/ui_lib.go (renamed from ui/ui_lib.go)4
-rw-r--r--ethereum.go215
-rw-r--r--node/config.go (renamed from config.go)5
-rw-r--r--node/dev_console.go (renamed from dev_console.go)0
-rw-r--r--node/ethereum.go158
-rwxr-xr-xnode/nodebin0 -> 8154988 bytes
-rw-r--r--test_runner.go35
-rw-r--r--test_runner_test.go36
-rw-r--r--testing.go33
-rw-r--r--utils/keys.go50
23 files changed, 357 insertions, 323 deletions
diff --git a/Makefile b/ethereal/Makefile
index 02d127963..02d127963 100644
--- a/Makefile
+++ b/ethereal/Makefile
diff --git a/facet.png b/ethereal/assets/facet.png
index 49a266e96..49a266e96 100644
--- a/facet.png
+++ b/ethereal/assets/facet.png
Binary files differ
diff --git a/net.png b/ethereal/assets/net.png
index 65a20ea00..65a20ea00 100644
--- a/net.png
+++ b/ethereal/assets/net.png
Binary files differ
diff --git a/network.png b/ethereal/assets/network.png
index 0a9ffe2ec..0a9ffe2ec 100644
--- a/network.png
+++ b/ethereal/assets/network.png
Binary files differ
diff --git a/new.png b/ethereal/assets/new.png
index e80096748..e80096748 100644
--- a/new.png
+++ b/ethereal/assets/new.png
Binary files differ
diff --git a/qml/test_app.qml b/ethereal/assets/qml/test_app.qml
index aace4e881..aace4e881 100644
--- a/qml/test_app.qml
+++ b/ethereal/assets/qml/test_app.qml
diff --git a/qml/transactions.qml b/ethereal/assets/qml/transactions.qml
index e9a035a85..e9a035a85 100644
--- a/qml/transactions.qml
+++ b/ethereal/assets/qml/transactions.qml
diff --git a/qml/wallet.qml b/ethereal/assets/qml/wallet.qml
index 7fc7f5447..7fc7f5447 100644
--- a/qml/wallet.qml
+++ b/ethereal/assets/qml/wallet.qml
diff --git a/tx.png b/ethereal/assets/tx.png
index 62204c315..62204c315 100644
--- a/tx.png
+++ b/ethereal/assets/tx.png
Binary files differ
diff --git a/ethereal/config.go b/ethereal/config.go
new file mode 100644
index 000000000..a534bb182
--- /dev/null
+++ b/ethereal/config.go
@@ -0,0 +1,34 @@
+package main
+
+import (
+ "flag"
+)
+
+var StartConsole bool
+var StartMining bool
+var UseUPnP bool
+var OutboundPort string
+var ShowGenesis bool
+var AddPeer string
+var MaxPeer int
+var GenAddr bool
+var UseSeed bool
+var ImportKey string
+var ExportKey bool
+var DataDir string
+
+func Init() {
+ flag.BoolVar(&StartConsole, "c", false, "debug and testing console")
+ flag.BoolVar(&StartMining, "m", false, "start dagger mining")
+ flag.BoolVar(&ShowGenesis, "g", false, "prints genesis header and exits")
+ flag.BoolVar(&UseUPnP, "upnp", false, "enable UPnP support")
+ flag.BoolVar(&UseSeed, "seed", true, "seed peers")
+ flag.BoolVar(&GenAddr, "genaddr", false, "create a new priv/pub key")
+ flag.BoolVar(&ExportKey, "export", false, "export private key")
+ flag.StringVar(&OutboundPort, "p", "30303", "listening port")
+ flag.StringVar(&DataDir, "dir", ".ethereal", "ethereum data directory")
+ flag.StringVar(&ImportKey, "import", "", "imports the given private key (hex)")
+ flag.IntVar(&MaxPeer, "x", 5, "maximum desired peers")
+
+ flag.Parse()
+}
diff --git a/ethereal/ethereum.go b/ethereal/ethereum.go
new file mode 100644
index 000000000..618d2b00f
--- /dev/null
+++ b/ethereal/ethereum.go
@@ -0,0 +1,110 @@
+package main
+
+import (
+ "fmt"
+ "github.com/ethereum/eth-go"
+ "github.com/ethereum/eth-go/ethchain"
+ "github.com/ethereum/eth-go/ethutil"
+ "github.com/ethereum/go-ethereum/ethereal/ui"
+ "github.com/ethereum/go-ethereum/utils"
+ "github.com/niemeyer/qml"
+ "log"
+ "os"
+ "os/signal"
+ "runtime"
+)
+
+const Debug = true
+
+// Register interrupt handlers so we can stop the ethereum
+func RegisterInterupts(s *eth.Ethereum) {
+ // Buffered chan of one is enough
+ c := make(chan os.Signal, 1)
+ // Notify about interrupts for now
+ signal.Notify(c, os.Interrupt)
+ go func() {
+ for sig := range c {
+ fmt.Printf("Shutting down (%v) ... \n", sig)
+
+ s.Stop()
+ }
+ }()
+}
+
+func main() {
+ Init()
+
+ qml.Init(nil)
+
+ runtime.GOMAXPROCS(runtime.NumCPU())
+
+ ethchain.InitFees()
+ ethutil.ReadConfig(DataDir)
+ ethutil.Config.Seed = UseSeed
+
+ // Instantiated a eth stack
+ ethereum, err := eth.New(eth.CapDefault, UseUPnP)
+ if err != nil {
+ log.Println("eth start err:", err)
+ return
+ }
+ ethereum.Port = OutboundPort
+
+ if GenAddr {
+ fmt.Println("This action overwrites your old private key. Are you sure? (y/n)")
+
+ var r string
+ fmt.Scanln(&r)
+ for ; ; fmt.Scanln(&r) {
+ if r == "n" || r == "y" {
+ break
+ } else {
+ fmt.Printf("Yes or no?", r)
+ }
+ }
+
+ if r == "y" {
+ utils.CreateKeyPair(true)
+ }
+ os.Exit(0)
+ } else {
+ if len(ImportKey) > 0 {
+ fmt.Println("This action overwrites your old private key. Are you sure? (y/n)")
+ var r string
+ fmt.Scanln(&r)
+ for ; ; fmt.Scanln(&r) {
+ if r == "n" || r == "y" {
+ break
+ } else {
+ fmt.Printf("Yes or no?", r)
+ }
+ }
+
+ if r == "y" {
+ utils.ImportPrivateKey(ImportKey)
+ os.Exit(0)
+ }
+ } else {
+ utils.CreateKeyPair(false)
+ }
+ }
+
+ if ExportKey {
+ key := ethutil.Config.Db.GetKeys()[0]
+ fmt.Printf("%x\n", key.PrivateKey)
+ os.Exit(0)
+ }
+
+ if ShowGenesis {
+ fmt.Println(ethereum.BlockChain().Genesis())
+ os.Exit(0)
+ }
+
+ log.Printf("Starting Ethereum v%s\n", ethutil.Config.Ver)
+
+ // Set the max peers
+ ethereum.MaxPeers = MaxPeer
+
+ gui := ethui.New(ethereum)
+ gui.Start()
+}
diff --git a/ui/gui.go b/ethereal/ui/gui.go
index c8f4bedab..c8f4bedab 100644
--- a/ui/gui.go
+++ b/ethereal/ui/gui.go
diff --git a/ui/library.go b/ethereal/ui/library.go
index 05fffd579..05fffd579 100644
--- a/ui/library.go
+++ b/ethereal/ui/library.go
diff --git a/ui/ui_lib.go b/ethereal/ui/ui_lib.go
index 83e8bf2d1..3997191fa 100644
--- a/ui/ui_lib.go
+++ b/ethereal/ui/ui_lib.go
@@ -55,8 +55,8 @@ func AssetPath(p string) string {
// assume a debug build and use the source directory as
// asset directory.
pwd, _ := os.Getwd()
- if pwd == path.Join(os.Getenv("GOPATH"), "src", "github.com", "ethereum", "go-ethereum") {
- base = pwd
+ if pwd == path.Join(os.Getenv("GOPATH"), "src", "github.com", "ethereum", "go-ethereum", "ethereal") {
+ base = path.Join(pwd, "assets")
} else {
switch runtime.GOOS {
case "darwin":
diff --git a/ethereum.go b/ethereum.go
deleted file mode 100644
index ac1de5af4..000000000
--- a/ethereum.go
+++ /dev/null
@@ -1,215 +0,0 @@
-package main
-
-import (
- "fmt"
- "github.com/ethereum/eth-go"
- "github.com/ethereum/eth-go/ethchain"
- "github.com/ethereum/eth-go/ethutil"
- "github.com/ethereum/eth-go/ethwire"
- "github.com/ethereum/go-ethereum/ui"
- "github.com/niemeyer/qml"
- "github.com/obscuren/secp256k1-go"
- "log"
- "os"
- "os/signal"
- "runtime"
-)
-
-const Debug = true
-
-// Register interrupt handlers so we can stop the ethereum
-func RegisterInterupts(s *eth.Ethereum) {
- // Buffered chan of one is enough
- c := make(chan os.Signal, 1)
- // Notify about interrupts for now
- signal.Notify(c, os.Interrupt)
- go func() {
- for sig := range c {
- fmt.Printf("Shutting down (%v) ... \n", sig)
-
- s.Stop()
- }
- }()
-}
-
-func CreateKeyPair(force bool) {
- data, _ := ethutil.Config.Db.Get([]byte("KeyRing"))
- if len(data) == 0 || force {
- pub, prv := secp256k1.GenerateKeyPair()
- pair := &ethutil.Key{PrivateKey: prv, PublicKey: pub}
- ethutil.Config.Db.Put([]byte("KeyRing"), pair.RlpEncode())
-
- fmt.Printf(`
-Generating new address and keypair.
-Please keep your keys somewhere save.
-
-++++++++++++++++ KeyRing +++++++++++++++++++
-addr: %x
-prvk: %x
-pubk: %x
-++++++++++++++++++++++++++++++++++++++++++++
-
-`, pair.Address(), prv, pub)
-
- }
-}
-
-func ImportPrivateKey(prvKey string) {
- key := ethutil.FromHex(prvKey)
- msg := []byte("tmp")
- // Couldn't think of a better way to get the pub key
- sig, _ := secp256k1.Sign(msg, key)
- pub, _ := secp256k1.RecoverPubkey(msg, sig)
- pair := &ethutil.Key{PrivateKey: key, PublicKey: pub}
- ethutil.Config.Db.Put([]byte("KeyRing"), pair.RlpEncode())
-
- fmt.Printf(`
-Importing private key
-
-++++++++++++++++ KeyRing +++++++++++++++++++
-addr: %x
-prvk: %x
-pubk: %x
-++++++++++++++++++++++++++++++++++++++++++++
-
-`, pair.Address(), key, pub)
-}
-
-func main() {
- Init()
-
- // Qt has to be initialized in the main thread or it will throw errors
- // It has to be called BEFORE setting the maximum procs.
- if UseGui {
- qml.Init(nil)
- }
-
- runtime.GOMAXPROCS(runtime.NumCPU())
-
- ethchain.InitFees()
- ethutil.ReadConfig(DataDir)
- ethutil.Config.Seed = UseSeed
-
- // Instantiated a eth stack
- ethereum, err := eth.New(eth.CapDefault, UseUPnP)
- if err != nil {
- log.Println("eth start err:", err)
- return
- }
- ethereum.Port = OutboundPort
-
- if GenAddr {
- fmt.Println("This action overwrites your old private key. Are you sure? (y/n)")
-
- var r string
- fmt.Scanln(&r)
- for ; ; fmt.Scanln(&r) {
- if r == "n" || r == "y" {
- break
- } else {
- fmt.Printf("Yes or no?", r)
- }
- }
-
- if r == "y" {
- CreateKeyPair(true)
- }
- os.Exit(0)
- } else {
- if len(ImportKey) > 0 {
- fmt.Println("This action overwrites your old private key. Are you sure? (y/n)")
- var r string
- fmt.Scanln(&r)
- for ; ; fmt.Scanln(&r) {
- if r == "n" || r == "y" {
- break
- } else {
- fmt.Printf("Yes or no?", r)
- }
- }
-
- if r == "y" {
- ImportPrivateKey(ImportKey)
- os.Exit(0)
- }
- } else {
- CreateKeyPair(false)
- }
- }
-
- if ExportKey {
- key := ethutil.Config.Db.GetKeys()[0]
- fmt.Printf("%x\n", key.PrivateKey)
- os.Exit(0)
- }
-
- if ShowGenesis {
- fmt.Println(ethereum.BlockChain().Genesis())
- os.Exit(0)
- }
-
- log.Printf("Starting Ethereum v%s\n", ethutil.Config.Ver)
-
- // Set the max peers
- ethereum.MaxPeers = MaxPeer
-
- if StartConsole {
- err := os.Mkdir(ethutil.Config.ExecPath, os.ModePerm)
- // Error is OK if the error is ErrExist
- if err != nil && !os.IsExist(err) {
- log.Panic("Unable to create EXECPATH:", err)
- }
-
- console := NewConsole(ethereum)
- go console.Start()
- }
-
- if UseGui {
- gui := ethui.New(ethereum)
- gui.Start()
- //ethereum.Stop()
- } else {
- RegisterInterupts(ethereum)
- ethereum.Start()
-
- if StartMining {
- log.Printf("Miner started\n")
-
- // Fake block mining. It broadcasts a new block every 5 seconds
- go func() {
- pow := &ethchain.EasyPow{}
- data, _ := ethutil.Config.Db.Get([]byte("KeyRing"))
- keyRing := ethutil.NewValueFromBytes(data)
- addr := keyRing.Get(1).Bytes()
-
- for {
- txs := ethereum.TxPool().Flush()
- // Create a new block which we're going to mine
- block := ethereum.BlockChain().NewBlock(addr, txs)
- log.Println("Mining on new block. Includes", len(block.Transactions()), "transactions")
- // Apply all transactions to the block
- ethereum.StateManager().ApplyTransactions(block, block.Transactions())
-
- ethereum.StateManager().Prepare(block.State(), block.State())
- ethereum.StateManager().AccumelateRewards(block)
-
- // Search the nonce
- block.Nonce = pow.Search(block)
- ethereum.Broadcast(ethwire.MsgBlockTy, []interface{}{block.Value().Val})
-
- ethereum.StateManager().PrepareDefault(block)
- err := ethereum.StateManager().ProcessBlock(block)
- if err != nil {
- log.Println(err)
- } else {
- log.Println("\n+++++++ MINED BLK +++++++\n", ethereum.BlockChain().CurrentBlock)
- log.Printf("🔨 Mined block %x\n", block.Hash())
- }
- }
- }()
- }
-
- // Wait for shutdown
- ethereum.WaitForShutdown()
- }
-}
diff --git a/config.go b/node/config.go
index bafc3e300..e4935dfed 100644
--- a/config.go
+++ b/node/config.go
@@ -15,14 +15,15 @@ var GenAddr bool
var UseSeed bool
var ImportKey string
var ExportKey bool
-var UseGui bool
+
+//var UseGui bool
var DataDir string
func Init() {
flag.BoolVar(&StartConsole, "c", false, "debug and testing console")
flag.BoolVar(&StartMining, "m", false, "start dagger mining")
flag.BoolVar(&ShowGenesis, "g", false, "prints genesis header and exits")
- flag.BoolVar(&UseGui, "gui", true, "use the gui")
+ //flag.BoolVar(&UseGui, "gui", true, "use the gui")
flag.BoolVar(&UseUPnP, "upnp", false, "enable UPnP support")
flag.BoolVar(&UseSeed, "seed", true, "seed peers")
flag.BoolVar(&GenAddr, "genaddr", false, "create a new priv/pub key")
diff --git a/dev_console.go b/node/dev_console.go
index ead4b55e5..ead4b55e5 100644
--- a/dev_console.go
+++ b/node/dev_console.go
diff --git a/node/ethereum.go b/node/ethereum.go
new file mode 100644
index 000000000..3f5e4a8f5
--- /dev/null
+++ b/node/ethereum.go
@@ -0,0 +1,158 @@
+package main
+
+import (
+ "fmt"
+ "github.com/ethereum/eth-go"
+ "github.com/ethereum/eth-go/ethchain"
+ "github.com/ethereum/eth-go/ethutil"
+ "github.com/ethereum/eth-go/ethwire"
+ "github.com/ethereum/go-ethereum/utils"
+ "log"
+ "os"
+ "os/signal"
+ "runtime"
+)
+
+const Debug = true
+
+// Register interrupt handlers so we can stop the ethereum
+func RegisterInterupts(s *eth.Ethereum) {
+ // Buffered chan of one is enough
+ c := make(chan os.Signal, 1)
+ // Notify about interrupts for now
+ signal.Notify(c, os.Interrupt)
+ go func() {
+ for sig := range c {
+ fmt.Printf("Shutting down (%v) ... \n", sig)
+
+ s.Stop()
+ }
+ }()
+}
+
+func main() {
+ Init()
+
+ runtime.GOMAXPROCS(runtime.NumCPU())
+
+ ethchain.InitFees()
+ ethutil.ReadConfig(DataDir)
+ ethutil.Config.Seed = UseSeed
+
+ // Instantiated a eth stack
+ ethereum, err := eth.New(eth.CapDefault, UseUPnP)
+ if err != nil {
+ log.Println("eth start err:", err)
+ return
+ }
+ ethereum.Port = OutboundPort
+
+ if GenAddr {
+ fmt.Println("This action overwrites your old private key. Are you sure? (y/n)")
+
+ var r string
+ fmt.Scanln(&r)
+ for ; ; fmt.Scanln(&r) {
+ if r == "n" || r == "y" {
+ break
+ } else {
+ fmt.Printf("Yes or no?", r)
+ }
+ }
+
+ if r == "y" {
+ utils.CreateKeyPair(true)
+ }
+ os.Exit(0)
+ } else {
+ if len(ImportKey) > 0 {
+ fmt.Println("This action overwrites your old private key. Are you sure? (y/n)")
+ var r string
+ fmt.Scanln(&r)
+ for ; ; fmt.Scanln(&r) {
+ if r == "n" || r == "y" {
+ break
+ } else {
+ fmt.Printf("Yes or no?", r)
+ }
+ }
+
+ if r == "y" {
+ utils.ImportPrivateKey(ImportKey)
+ os.Exit(0)
+ }
+ } else {
+ utils.CreateKeyPair(false)
+ }
+ }
+
+ if ExportKey {
+ key := ethutil.Config.Db.GetKeys()[0]
+ fmt.Printf("%x\n", key.PrivateKey)
+ os.Exit(0)
+ }
+
+ if ShowGenesis {
+ fmt.Println(ethereum.BlockChain().Genesis())
+ os.Exit(0)
+ }
+
+ log.Printf("Starting Ethereum v%s\n", ethutil.Config.Ver)
+
+ // Set the max peers
+ ethereum.MaxPeers = MaxPeer
+
+ if StartConsole {
+ err := os.Mkdir(ethutil.Config.ExecPath, os.ModePerm)
+ // Error is OK if the error is ErrExist
+ if err != nil && !os.IsExist(err) {
+ log.Panic("Unable to create EXECPATH:", err)
+ }
+
+ console := NewConsole(ethereum)
+ go console.Start()
+ }
+
+ RegisterInterupts(ethereum)
+ ethereum.Start()
+
+ if StartMining {
+ log.Printf("Miner started\n")
+
+ // Fake block mining. It broadcasts a new block every 5 seconds
+ go func() {
+ pow := &ethchain.EasyPow{}
+ data, _ := ethutil.Config.Db.Get([]byte("KeyRing"))
+ keyRing := ethutil.NewValueFromBytes(data)
+ addr := keyRing.Get(1).Bytes()
+
+ for {
+ txs := ethereum.TxPool().Flush()
+ // Create a new block which we're going to mine
+ block := ethereum.BlockChain().NewBlock(addr, txs)
+ log.Println("Mining on new block. Includes", len(block.Transactions()), "transactions")
+ // Apply all transactions to the block
+ ethereum.StateManager().ApplyTransactions(block, block.Transactions())
+
+ ethereum.StateManager().Prepare(block.State(), block.State())
+ ethereum.StateManager().AccumelateRewards(block)
+
+ // Search the nonce
+ block.Nonce = pow.Search(block)
+ ethereum.Broadcast(ethwire.MsgBlockTy, []interface{}{block.Value().Val})
+
+ ethereum.StateManager().PrepareDefault(block)
+ err := ethereum.StateManager().ProcessBlock(block)
+ if err != nil {
+ log.Println(err)
+ } else {
+ log.Println("\n+++++++ MINED BLK +++++++\n", ethereum.BlockChain().CurrentBlock)
+ log.Printf("🔨 Mined block %x\n", block.Hash())
+ }
+ }
+ }()
+ }
+
+ // Wait for shutdown
+ ethereum.WaitForShutdown()
+}
diff --git a/node/node b/node/node
new file mode 100755
index 000000000..48452886c
--- /dev/null
+++ b/node/node
Binary files differ
diff --git a/test_runner.go b/test_runner.go
deleted file mode 100644
index e8a1698ce..000000000
--- a/test_runner.go
+++ /dev/null
@@ -1,35 +0,0 @@
-package main
-
-import (
- "encoding/json"
- "fmt"
- "testing"
-)
-
-type TestSource struct {
- Inputs map[string]string
- Expectation string
-}
-
-func NewTestSource(source string) *TestSource {
- s := &TestSource{}
- err := json.Unmarshal([]byte(source), s)
- if err != nil {
- fmt.Println(err)
- }
-
- return s
-}
-
-type TestRunner struct {
- source *TestSource
-}
-
-func NewTestRunner(t *testing.T) *TestRunner {
- return &TestRunner{}
-}
-
-func (runner *TestRunner) RunFromString(input string, Cb func(*TestSource)) {
- source := NewTestSource(input)
- Cb(source)
-}
diff --git a/test_runner_test.go b/test_runner_test.go
deleted file mode 100644
index a5672eb7a..000000000
--- a/test_runner_test.go
+++ /dev/null
@@ -1,36 +0,0 @@
-package main
-
-/*
-import (
- "encoding/hex"
- _ "fmt"
- "github.com/ethereum/ethdb-go"
- "github.com/ethereum/ethutil-go"
- "testing"
-)
-
-var testsource = `
-{
- "inputs":{
- "doe": "reindeer",
- "dog": "puppy",
- "dogglesworth": "cat"
- },
- "expectation":"e378927bfc1bd4f01a2e8d9f59bd18db8a208bb493ac0b00f93ce51d4d2af76c"
-}`
-
-func TestTestRunner(t *testing.T) {
- db, _ := ethdb.NewMemDatabase()
- trie := ethutil.NewTrie(db, "")
-
- runner := NewTestRunner(t)
- runner.RunFromString(testsource, func(source *TestSource) {
- for key, value := range source.Inputs {
- trie.Update(key, value)
- }
- if hex.EncodeToString(trie.Root.([]byte)) != source.Expectation {
- t.Error("trie root did not match")
- }
- })
-}
-*/
diff --git a/testing.go b/testing.go
deleted file mode 100644
index 849089a5d..000000000
--- a/testing.go
+++ /dev/null
@@ -1,33 +0,0 @@
-package main
-
-/*
-
-import (
- _"fmt"
-)
-
-// This will eventually go away
-var Db *MemDatabase
-
-func Testing() {
- db, _ := NewMemDatabase()
- Db = db
-
- bm := NewBlockManager()
-
- tx := NewTransaction("\x00", 20, []string{"PUSH"})
- txData := tx.RlpEncode()
- //fmt.Printf("%q\n", txData)
-
- copyTx := &Transaction{}
- copyTx.RlpDecode(txData)
- //fmt.Println(tx)
- //fmt.Println(copyTx)
-
- tx2 := NewTransaction("\x00", 20, []string{"SET 10 6", "LD 10 10"})
-
- blck := CreateTestBlock([]*Transaction{tx2, tx})
-
- bm.ProcessBlock( blck )
-}
-*/
diff --git a/utils/keys.go b/utils/keys.go
new file mode 100644
index 000000000..910c8c477
--- /dev/null
+++ b/utils/keys.go
@@ -0,0 +1,50 @@
+package utils
+
+import (
+ "fmt"
+ "github.com/ethereum/eth-go/ethutil"
+ "github.com/obscuren/secp256k1-go"
+)
+
+func CreateKeyPair(force bool) {
+ data, _ := ethutil.Config.Db.Get([]byte("KeyRing"))
+ if len(data) == 0 || force {
+ pub, prv := secp256k1.GenerateKeyPair()
+ pair := &ethutil.Key{PrivateKey: prv, PublicKey: pub}
+ ethutil.Config.Db.Put([]byte("KeyRing"), pair.RlpEncode())
+
+ fmt.Printf(`
+Generating new address and keypair.
+Please keep your keys somewhere save.
+
+++++++++++++++++ KeyRing +++++++++++++++++++
+addr: %x
+prvk: %x
+pubk: %x
+++++++++++++++++++++++++++++++++++++++++++++
+
+`, pair.Address(), prv, pub)
+
+ }
+}
+
+func ImportPrivateKey(prvKey string) {
+ key := ethutil.FromHex(prvKey)
+ msg := []byte("tmp")
+ // Couldn't think of a better way to get the pub key
+ sig, _ := secp256k1.Sign(msg, key)
+ pub, _ := secp256k1.RecoverPubkey(msg, sig)
+ pair := &ethutil.Key{PrivateKey: key, PublicKey: pub}
+ ethutil.Config.Db.Put([]byte("KeyRing"), pair.RlpEncode())
+
+ fmt.Printf(`
+Importing private key
+
+++++++++++++++++ KeyRing +++++++++++++++++++
+addr: %x
+prvk: %x
+pubk: %x
+++++++++++++++++++++++++++++++++++++++++++++
+
+`, pair.Address(), key, pub)
+}