aboutsummaryrefslogtreecommitdiffstats
path: root/utils
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-07-02 02:09:37 +0800
committerobscuren <geffobscura@gmail.com>2014-07-02 02:09:37 +0800
commitdd869064a678918544678c9cb8413d1e9a94de89 (patch)
treefc2354d02af43f7298ff280b2b3b39713b67ce23 /utils
parent7a2a63f32b209f0358fa6be1e76b49319d8f309f (diff)
downloaddexon-dd869064a678918544678c9cb8413d1e9a94de89.tar
dexon-dd869064a678918544678c9cb8413d1e9a94de89.tar.gz
dexon-dd869064a678918544678c9cb8413d1e9a94de89.tar.bz2
dexon-dd869064a678918544678c9cb8413d1e9a94de89.tar.lz
dexon-dd869064a678918544678c9cb8413d1e9a94de89.tar.xz
dexon-dd869064a678918544678c9cb8413d1e9a94de89.tar.zst
dexon-dd869064a678918544678c9cb8413d1e9a94de89.zip
delete?
Diffstat (limited to 'utils')
-rw-r--r--utils/cmd.go253
1 files changed, 0 insertions, 253 deletions
diff --git a/utils/cmd.go b/utils/cmd.go
deleted file mode 100644
index dc435a700..000000000
--- a/utils/cmd.go
+++ /dev/null
@@ -1,253 +0,0 @@
-package utils
-
-import (
- "fmt"
- "github.com/ethereum/eth-go"
- "github.com/ethereum/eth-go/ethcrypto"
- "github.com/ethereum/eth-go/ethdb"
- "github.com/ethereum/eth-go/ethlog"
- "github.com/ethereum/eth-go/ethminer"
- "github.com/ethereum/eth-go/ethpub"
- "github.com/ethereum/eth-go/ethrpc"
- "github.com/ethereum/eth-go/ethutil"
- "io"
- "log"
- "os"
- "os/signal"
- "path"
- "time"
-)
-
-var logger = ethlog.NewLogger("CLI")
-var interruptCallbacks = []func(os.Signal){}
-
-// Register interrupt handlers callbacks
-func RegisterInterrupt(cb func(os.Signal)) {
- interruptCallbacks = append(interruptCallbacks, cb)
-}
-
-// go routine that call interrupt handlers in order of registering
-func HandleInterrupt() {
- c := make(chan os.Signal, 1)
- go func() {
- signal.Notify(c, os.Interrupt)
- for sig := range c {
- logger.Errorf("Shutting down (%v) ... \n", sig)
- RunInterruptCallbacks(sig)
- }
- }()
-}
-
-func RunInterruptCallbacks(sig os.Signal) {
- for _, cb := range interruptCallbacks {
- cb(sig)
- }
-}
-
-func AbsolutePath(Datadir string, filename string) string {
- if path.IsAbs(filename) {
- return filename
- }
- return path.Join(Datadir, filename)
-}
-
-func openLogFile(Datadir string, filename string) *os.File {
- path := AbsolutePath(Datadir, filename)
- file, err := os.OpenFile(path, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0666)
- if err != nil {
- panic(fmt.Sprintf("error opening log file '%s': %v", filename, err))
- }
- return file
-}
-
-func confirm(message string) bool {
- fmt.Println(message, "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)
- }
- }
- return r == "y"
-}
-
-func InitDataDir(Datadir string) {
- _, err := os.Stat(Datadir)
- if err != nil {
- if os.IsNotExist(err) {
- fmt.Printf("Data directory '%s' doesn't exist, creating it\n", Datadir)
- os.Mkdir(Datadir, 0777)
- }
- }
-}
-
-func InitLogging(Datadir string, LogFile string, LogLevel int, DebugFile string) {
- var writer io.Writer
- if LogFile == "" {
- writer = os.Stdout
- } else {
- writer = openLogFile(Datadir, LogFile)
- }
- ethlog.AddLogSystem(ethlog.NewStdLogSystem(writer, log.LstdFlags, ethlog.LogLevel(LogLevel)))
- if DebugFile != "" {
- writer = openLogFile(Datadir, DebugFile)
- ethlog.AddLogSystem(ethlog.NewStdLogSystem(writer, log.LstdFlags, ethlog.DebugLevel))
- }
-}
-
-func InitConfig(ConfigFile string, Datadir string, Identifier string, EnvPrefix string) {
- InitDataDir(Datadir)
- ethutil.ReadConfig(ConfigFile, Datadir, Identifier, EnvPrefix)
-}
-
-func exit(err error) {
- status := 0
- if err != nil {
- logger.Errorln("Fatal: ", err)
- status = 1
- }
- ethlog.Flush()
- os.Exit(status)
-}
-
-func NewDatabase() ethutil.Database {
- db, err := ethdb.NewLDBDatabase("database")
- if err != nil {
- exit(err)
- }
- return db
-}
-
-func NewEthereum(db ethutil.Database, keyManager *ethcrypto.KeyManager, usePnp bool, OutboundPort string, MaxPeer int) *eth.Ethereum {
- ethereum, err := eth.New(db, keyManager, eth.CapDefault, usePnp)
- if err != nil {
- logger.Fatalln("eth start err:", err)
- }
- ethereum.Port = OutboundPort
- ethereum.MaxPeers = MaxPeer
- return ethereum
-}
-
-func StartEthereum(ethereum *eth.Ethereum, UseSeed bool) {
- logger.Infof("Starting Ethereum v%s", ethutil.Config.Ver)
- ethereum.Start(UseSeed)
- RegisterInterrupt(func(sig os.Signal) {
- ethereum.Stop()
- ethlog.Flush()
- })
-}
-
-func ShowGenesis(ethereum *eth.Ethereum) {
- logger.Infoln(ethereum.BlockChain().Genesis())
- exit(nil)
-}
-
-func NewKeyManager(KeyStore string, Datadir string, db ethutil.Database) *ethcrypto.KeyManager {
- var keyManager *ethcrypto.KeyManager
- switch {
- case KeyStore == "db":
- keyManager = ethcrypto.NewDBKeyManager(db)
- case KeyStore == "file":
- keyManager = ethcrypto.NewFileKeyManager(Datadir)
- default:
- exit(fmt.Errorf("unknown keystore type: %s", KeyStore))
- }
- return keyManager
-}
-
-func KeyTasks(keyManager *ethcrypto.KeyManager, KeyRing string, GenAddr bool, SecretFile string, ExportDir string, NonInteractive bool) {
- var err error
- switch {
- case GenAddr:
- if NonInteractive || confirm("This action overwrites your old private key.") {
- err = keyManager.Init(KeyRing, 0, true)
- }
- exit(err)
- case len(SecretFile) > 0:
- if NonInteractive || confirm("This action overwrites your old private key.") {
- err = keyManager.InitFromSecretsFile(KeyRing, 0, SecretFile)
- }
- exit(err)
- case len(ExportDir) > 0:
- err = keyManager.Init(KeyRing, 0, false)
- if err == nil {
- err = keyManager.Export(ExportDir)
- }
- exit(err)
- default:
- // Creates a keypair if none exists
- err = keyManager.Init(KeyRing, 0, false)
- if err != nil {
- exit(err)
- }
- }
-}
-
-func StartRpc(ethereum *eth.Ethereum, RpcPort int) {
- var err error
- ethereum.RpcServer, err = ethrpc.NewJsonRpcServer(ethpub.NewPEthereum(ethereum), RpcPort)
- if err != nil {
- logger.Errorf("Could not start RPC interface (port %v): %v", RpcPort, err)
- } else {
- go ethereum.RpcServer.Start()
- }
-}
-
-var miner ethminer.Miner
-
-func StartMining(ethereum *eth.Ethereum) bool {
- if !ethereum.Mining {
- ethereum.Mining = true
-
- addr := ethereum.KeyManager().Address()
-
- go func() {
- miner = ethminer.NewDefaultMiner(addr, ethereum)
- // Give it some time to connect with peers
- time.Sleep(3 * time.Second)
- for !ethereum.IsUpToDate() == false {
- time.Sleep(5 * time.Second)
- }
-
- logger.Infoln("Miner started")
- miner := ethminer.NewDefaultMiner(addr, ethereum)
- miner.Start()
- }()
- RegisterInterrupt(func(os.Signal) {
- StopMining(ethereum)
- })
- return true
- }
- return false
-}
-
-func StopMining(ethereum *eth.Ethereum) bool {
- if ethereum.Mining {
- miner.Stop()
- logger.Infoln("Miner stopped")
- ethereum.Mining = false
- return true
- }
- return false
-}
-
-// Replay block
-func BlockDo(ethereum *eth.Ethereum, hash []byte) error {
- block := ethereum.BlockChain().GetBlock(hash)
- if block == nil {
- return fmt.Errorf("unknown block %x", hash)
- }
-
- parent := ethereum.BlockChain().GetBlock(block.PrevHash)
-
- _, err := ethereum.StateManager().ApplyDiff(parent.State(), parent, block)
- if err != nil {
- return err
- }
-
- return nil
-
-}