flags.go 23.9 KB
Newer Older
F
Felix Lange 已提交
1 2 3 4 5 6 7 8 9 10
// Copyright 2015 The go-ethereum Authors
// This file is part of go-ethereum.
//
// go-ethereum is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// go-ethereum is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
11
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
F
Felix Lange 已提交
12 13 14
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
15
// along with go-ethereum. If not, see <http://www.gnu.org/licenses/>.
F
Felix Lange 已提交
16

17 18 19 20
package utils

import (
	"crypto/ecdsa"
21
	"fmt"
22
	"io/ioutil"
23
	"math"
24
	"math/big"
25
	"os"
26
	"path/filepath"
27
	"runtime"
28
	"strconv"
29
	"strings"
30

31
	"github.com/codegangsta/cli"
32
	"github.com/ethereum/ethash"
F
Felix Lange 已提交
33
	"github.com/ethereum/go-ethereum/accounts"
Z
zelig 已提交
34
	"github.com/ethereum/go-ethereum/common"
35
	"github.com/ethereum/go-ethereum/core"
36
	"github.com/ethereum/go-ethereum/core/state"
B
Bas van Kervel 已提交
37
	"github.com/ethereum/go-ethereum/core/vm"
38 39 40 41 42
	"github.com/ethereum/go-ethereum/crypto"
	"github.com/ethereum/go-ethereum/eth"
	"github.com/ethereum/go-ethereum/ethdb"
	"github.com/ethereum/go-ethereum/event"
	"github.com/ethereum/go-ethereum/logger"
O
obscuren 已提交
43
	"github.com/ethereum/go-ethereum/logger/glog"
B
Bas van Kervel 已提交
44
	"github.com/ethereum/go-ethereum/metrics"
45 46
	"github.com/ethereum/go-ethereum/node"
	"github.com/ethereum/go-ethereum/p2p/discover"
47
	"github.com/ethereum/go-ethereum/p2p/nat"
48
	"github.com/ethereum/go-ethereum/params"
49
	"github.com/ethereum/go-ethereum/rpc"
50
	"github.com/ethereum/go-ethereum/whisper"
51 52
)

53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78
func init() {
	cli.AppHelpTemplate = `{{.Name}} {{if .Flags}}[global options] {{end}}command{{if .Flags}} [command options]{{end}} [arguments...]

VERSION:
   {{.Version}}

COMMANDS:
   {{range .Commands}}{{.Name}}{{with .ShortName}}, {{.}}{{end}}{{ "\t" }}{{.Usage}}
   {{end}}{{if .Flags}}
GLOBAL OPTIONS:
   {{range .Flags}}{{.}}
   {{end}}{{end}}
`

	cli.CommandHelpTemplate = `{{.Name}}{{if .Subcommands}} command{{end}}{{if .Flags}} [command options]{{end}} [arguments...]
{{if .Description}}{{.Description}}
{{end}}{{if .Subcommands}}
SUBCOMMANDS:
	{{range .Subcommands}}{{.Name}}{{with .ShortName}}, {{.}}{{end}}{{ "\t" }}{{.Usage}}
	{{end}}{{end}}{{if .Flags}}
OPTIONS:
	{{range .Flags}}{{.}}
	{{end}}{{end}}
`
}

F
Felix Lange 已提交
79 80 81
// NewApp creates an app with sane defaults.
func NewApp(version, usage string) *cli.App {
	app := cli.NewApp()
82
	app.Name = filepath.Base(os.Args[0])
F
Felix Lange 已提交
83
	app.Author = ""
O
obscuren 已提交
84
	//app.Authors = nil
F
Felix Lange 已提交
85 86 87 88 89 90
	app.Email = ""
	app.Version = version
	app.Usage = usage
	return app
}

91 92 93 94 95 96 97 98 99
// These are all the command line flags we support.
// If you add to this list, please remember to include the
// flag in the appropriate command definition.
//
// The flags are defined here so their names and help texts
// are the same for all commands.

var (
	// General settings
100
	DataDirFlag = DirectoryFlag{
101
		Name:  "datadir",
102
		Usage: "Data directory for the databases and keystore",
103
		Value: DirectoryString{common.DefaultDataDir()},
104
	}
Z
zelig 已提交
105 106
	NetworkIdFlag = cli.IntFlag{
		Name:  "networkid",
107
		Usage: "Network identifier (integer, 0=Olympic, 1=Frontier, 2=Morden)",
Z
zelig 已提交
108 109
		Value: eth.NetworkId,
	}
110 111 112
	OlympicFlag = cli.BoolFlag{
		Name:  "olympic",
		Usage: "Olympic network: pre-configured pre-release test network",
O
obscuren 已提交
113
	}
114 115 116
	TestNetFlag = cli.BoolFlag{
		Name:  "testnet",
		Usage: "Morden network: pre-configured test network with modified starting nonces (replay protection)",
117
	}
118 119
	DevModeFlag = cli.BoolFlag{
		Name:  "dev",
120
		Usage: "Developer mode: pre-configured private network with several debugging flags",
121
	}
122 123 124
	GenesisFileFlag = cli.StringFlag{
		Name:  "genesis",
		Usage: "Insert/overwrite the genesis block (JSON format)",
125
	}
126 127
	IdentityFlag = cli.StringFlag{
		Name:  "identity",
128
		Usage: "Custom node name",
129
	}
130 131 132 133
	NatspecEnabledFlag = cli.BoolFlag{
		Name:  "natspec",
		Usage: "Enable NatSpec confirmation notice",
	}
Z
zelig 已提交
134 135 136 137 138
	DocRootFlag = DirectoryFlag{
		Name:  "docroot",
		Usage: "Document Root for HTTPClient file scheme",
		Value: DirectoryString{common.HomeDir()},
	}
139 140
	CacheFlag = cli.IntFlag{
		Name:  "cache",
141
		Usage: "Megabytes of memory allocated to internal caching (min 16MB / database forced)",
142 143
		Value: 0,
	}
144 145 146 147
	BlockchainVersionFlag = cli.IntFlag{
		Name:  "blockchainversion",
		Usage: "Blockchain version (integer)",
		Value: core.BlockChainVersion,
148
	}
149 150
	FastSyncFlag = cli.BoolFlag{
		Name:  "fast",
151
		Usage: "Enable fast syncing through state downloads",
152
	}
153 154
	LightKDFFlag = cli.BoolFlag{
		Name:  "lightkdf",
155
		Usage: "Reduce key-derivation RAM & CPU usage at some expense of KDF strength",
156
	}
157
	// Miner settings
158
	// TODO: refactor CPU vs GPU mining flags
159 160 161
	MiningEnabledFlag = cli.BoolFlag{
		Name:  "mine",
		Usage: "Enable mining",
162
	}
163 164
	MinerThreadsFlag = cli.IntFlag{
		Name:  "minerthreads",
165
		Usage: "Number of CPU threads to use for mining",
166 167
		Value: runtime.NumCPU(),
	}
168 169 170
	MiningGPUFlag = cli.StringFlag{
		Name:  "minergpus",
		Usage: "List of GPUs to use for mining (e.g. '0,1' will use the first two GPUs found)",
171
	}
172 173 174 175
	AutoDAGFlag = cli.BoolFlag{
		Name:  "autodag",
		Usage: "Enable automatic DAG pregeneration",
	}
Z
zelig 已提交
176
	EtherbaseFlag = cli.StringFlag{
O
obscuren 已提交
177
		Name:  "etherbase",
178
		Usage: "Public address for block mining rewards (default = first account created)",
179
		Value: "0",
Z
zelig 已提交
180
	}
181 182
	GasPriceFlag = cli.StringFlag{
		Name:  "gasprice",
183
		Usage: "Minimal gas price to accept for mining a transactions",
184
		Value: new(big.Int).Mul(big.NewInt(20), common.Shannon).String(),
185
	}
Z
zelig 已提交
186 187
	ExtraDataFlag = cli.StringFlag{
		Name:  "extradata",
188
		Usage: "Block extra data set by the miner (default = client version)",
Z
zelig 已提交
189
	}
190
	// Account settings
Z
zelig 已提交
191 192
	UnlockedAccountFlag = cli.StringFlag{
		Name:  "unlock",
193
		Usage: "Comma separated list of accounts to unlock",
Z
zelig 已提交
194 195 196 197
		Value: "",
	}
	PasswordFileFlag = cli.StringFlag{
		Name:  "password",
198
		Usage: "Password file to use for non-inteactive password input",
Z
zelig 已提交
199
		Value: "",
Z
zelig 已提交
200
	}
201

202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220
	// vm flags
	VMDebugFlag = cli.BoolFlag{
		Name:  "vmdebug",
		Usage: "Virtual Machine debug output",
	}
	VMForceJitFlag = cli.BoolFlag{
		Name:  "forcejit",
		Usage: "Force the JIT VM to take precedence",
	}
	VMJitCacheFlag = cli.IntFlag{
		Name:  "jitcache",
		Usage: "Amount of cached JIT VM programs",
		Value: 64,
	}
	VMEnableJitFlag = cli.BoolFlag{
		Name:  "jitvm",
		Usage: "Enable the JIT VM",
	}

Z
zelig 已提交
221
	// logging and debug settings
222 223
	MetricsEnabledFlag = cli.BoolFlag{
		Name:  metrics.MetricsEnabledFlag,
224
		Usage: "Enable metrics collection and reporting",
225
	}
226 227 228 229

	// RPC settings
	RPCEnabledFlag = cli.BoolFlag{
		Name:  "rpc",
230
		Usage: "Enable the HTTP-RPC server",
231 232 233
	}
	RPCListenAddrFlag = cli.StringFlag{
		Name:  "rpcaddr",
234
		Usage: "HTTP-RPC server listening interface",
235
		Value: common.DefaultHTTPHost,
236 237 238
	}
	RPCPortFlag = cli.IntFlag{
		Name:  "rpcport",
239
		Usage: "HTTP-RPC server listening port",
240
		Value: common.DefaultHTTPPort,
241
	}
242 243
	RPCCORSDomainFlag = cli.StringFlag{
		Name:  "rpccorsdomain",
244
		Usage: "Domains from which to accept cross origin requests (browser enforced)",
245 246
		Value: "",
	}
247
	RPCApiFlag = cli.StringFlag{
248
		Name:  "rpcapi",
249
		Usage: "API's offered over the HTTP-RPC interface",
250
		Value: rpc.DefaultHTTPApis,
251
	}
B
Bas van Kervel 已提交
252 253 254 255 256 257
	IPCDisabledFlag = cli.BoolFlag{
		Name:  "ipcdisable",
		Usage: "Disable the IPC-RPC server",
	}
	IPCApiFlag = cli.StringFlag{
		Name:  "ipcapi",
258
		Usage: "API's offered over the IPC-RPC interface",
259
		Value: rpc.DefaultIPCApis,
B
Bas van Kervel 已提交
260 261 262
	}
	IPCPathFlag = DirectoryFlag{
		Name:  "ipcpath",
263
		Usage: "Filename for IPC socket/pipe within the datadir (explicit paths escape it)",
264
		Value: DirectoryString{common.DefaultIPCSocket},
B
Bas van Kervel 已提交
265
	}
266
	WSEnabledFlag = cli.BoolFlag{
267
		Name:  "ws",
268 269 270 271 272
		Usage: "Enable the WS-RPC server",
	}
	WSListenAddrFlag = cli.StringFlag{
		Name:  "wsaddr",
		Usage: "WS-RPC server listening interface",
273
		Value: common.DefaultWSHost,
274 275 276 277
	}
	WSPortFlag = cli.IntFlag{
		Name:  "wsport",
		Usage: "WS-RPC server listening port",
278
		Value: common.DefaultWSPort,
279 280 281 282
	}
	WSApiFlag = cli.StringFlag{
		Name:  "wsapi",
		Usage: "API's offered over the WS-RPC interface",
283
		Value: rpc.DefaultHTTPApis,
284 285 286
	}
	WSAllowedDomainsFlag = cli.StringFlag{
		Name:  "wsdomains",
287
		Usage: "Domains from which to accept websockets requests (can be spoofed)",
288
		Value: "",
289
	}
290 291
	ExecFlag = cli.StringFlag{
		Name:  "exec",
292
		Usage: "Execute JavaScript statement (only in combination with console/attach)",
293
	}
294

295 296 297
	// Network Settings
	MaxPeersFlag = cli.IntFlag{
		Name:  "maxpeers",
298
		Usage: "Maximum number of network peers (network disabled if set to 0)",
299
		Value: 25,
300
	}
301 302 303 304 305
	MaxPendingPeersFlag = cli.IntFlag{
		Name:  "maxpendpeers",
		Usage: "Maximum number of pending connection attempts (defaults used if set to 0)",
		Value: 0,
	}
306 307 308 309 310 311 312
	ListenPortFlag = cli.IntFlag{
		Name:  "port",
		Usage: "Network listening port",
		Value: 30303,
	}
	BootnodesFlag = cli.StringFlag{
		Name:  "bootnodes",
313
		Usage: "Comma separated enode URLs for P2P discovery bootstrap",
314 315 316 317 318 319 320 321 322 323 324 325
		Value: "",
	}
	NodeKeyFileFlag = cli.StringFlag{
		Name:  "nodekey",
		Usage: "P2P node key file",
	}
	NodeKeyHexFlag = cli.StringFlag{
		Name:  "nodekeyhex",
		Usage: "P2P node key as hex (for testing)",
	}
	NATFlag = cli.StringFlag{
		Name:  "nat",
326
		Usage: "NAT port mapping mechanism (any|none|upnp|pmp|extip:<IP>)",
327 328
		Value: "any",
	}
329 330 331 332
	NoDiscoverFlag = cli.BoolFlag{
		Name:  "nodiscover",
		Usage: "Disables the peer discovery mechanism (manual peer addition)",
	}
333 334
	WhisperEnabledFlag = cli.BoolFlag{
		Name:  "shh",
335
		Usage: "Enable Whisper",
336
	}
337
	// ATM the url is left to the user and deployment to
Z
CLI:  
zelig 已提交
338 339
	JSpathFlag = cli.StringFlag{
		Name:  "jspath",
I
Isidoro Ghezzi 已提交
340
		Usage: "JavaScript root path for `loadScript` and document root for `admin.httpGet`",
Z
CLI:  
zelig 已提交
341 342
		Value: ".",
	}
343 344
	SolcPathFlag = cli.StringFlag{
		Name:  "solc",
345
		Usage: "Solidity compiler command to be used",
346 347
		Value: "solc",
	}
348 349

	// Gas price oracle settings
Z
zsfelfoldi 已提交
350 351 352
	GpoMinGasPriceFlag = cli.StringFlag{
		Name:  "gpomin",
		Usage: "Minimum suggested gas price",
353
		Value: new(big.Int).Mul(big.NewInt(20), common.Shannon).String(),
Z
zsfelfoldi 已提交
354 355 356 357
	}
	GpoMaxGasPriceFlag = cli.StringFlag{
		Name:  "gpomax",
		Usage: "Maximum suggested gas price",
358
		Value: new(big.Int).Mul(big.NewInt(500), common.Shannon).String(),
Z
zsfelfoldi 已提交
359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379
	}
	GpoFullBlockRatioFlag = cli.IntFlag{
		Name:  "gpofull",
		Usage: "Full block threshold for gas price calculation (%)",
		Value: 80,
	}
	GpobaseStepDownFlag = cli.IntFlag{
		Name:  "gpobasedown",
		Usage: "Suggested gas price base step down ratio (1/1000)",
		Value: 10,
	}
	GpobaseStepUpFlag = cli.IntFlag{
		Name:  "gpobaseup",
		Usage: "Suggested gas price base step up ratio (1/1000)",
		Value: 100,
	}
	GpobaseCorrectionFactorFlag = cli.IntFlag{
		Name:  "gpobasecf",
		Usage: "Suggested gas price base correction factor (%)",
		Value: 110,
	}
380 381
)

382 383 384 385 386 387 388 389 390
// MustMakeDataDir retrieves the currently requested data directory, terminating
// if none (or the empty string) is specified. If the node is starting a testnet,
// the a subdirectory of the specified datadir will be used.
func MustMakeDataDir(ctx *cli.Context) string {
	if path := ctx.GlobalString(DataDirFlag.Name); path != "" {
		if ctx.GlobalBool(TestNetFlag.Name) {
			return filepath.Join(path, "/testnet")
		}
		return path
391
	}
392 393
	Fatalf("Cannot determine default data directory, please set manually (--datadir)")
	return ""
394 395
}

396
// MakeIPCPath creates an IPC path configuration from the set command line flags,
397
// returning an empty string if IPC was explicitly disabled, or the set path.
398
func MakeIPCPath(ctx *cli.Context) string {
399 400 401 402 403 404
	if ctx.GlobalBool(IPCDisabledFlag.Name) {
		return ""
	}
	return ctx.GlobalString(IPCPathFlag.Name)
}

405 406 407 408 409 410 411 412 413 414 415
// MakeNodeKey creates a node key from set command line flags, either loading it
// from a file or as a specified hex value. If neither flags were provided, this
// method returns nil and an emphemeral key is to be generated.
func MakeNodeKey(ctx *cli.Context) *ecdsa.PrivateKey {
	var (
		hex  = ctx.GlobalString(NodeKeyHexFlag.Name)
		file = ctx.GlobalString(NodeKeyFileFlag.Name)

		key *ecdsa.PrivateKey
		err error
	)
416 417 418
	switch {
	case file != "" && hex != "":
		Fatalf("Options %q and %q are mutually exclusive", NodeKeyFileFlag.Name, NodeKeyHexFlag.Name)
419

420 421 422 423
	case file != "":
		if key, err = crypto.LoadECDSA(file); err != nil {
			Fatalf("Option %q: %v", NodeKeyFileFlag.Name, err)
		}
424

425 426 427 428 429 430 431 432
	case hex != "":
		if key, err = crypto.HexToECDSA(hex); err != nil {
			Fatalf("Option %q: %v", NodeKeyHexFlag.Name, err)
		}
	}
	return key
}

433 434 435 436 437 438 439 440
// MakeNodeName creates a node name from a base set and the command line flags.
func MakeNodeName(client, version string, ctx *cli.Context) string {
	name := common.MakeName(client, version)
	if identity := ctx.GlobalString(IdentityFlag.Name); len(identity) > 0 {
		name += "/" + identity
	}
	if ctx.GlobalBool(VMEnableJitFlag.Name) {
		name += "/JIT"
441
	}
442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477
	return name
}

// MakeBootstrapNodes creates a list of bootstrap nodes from the command line
// flags, reverting to pre-configured ones if none have been specified.
func MakeBootstrapNodes(ctx *cli.Context) []*discover.Node {
	// Return pre-configured nodes if none were manually requested
	if !ctx.GlobalIsSet(BootnodesFlag.Name) {
		if ctx.GlobalBool(TestNetFlag.Name) {
			return TestNetBootNodes
		}
		return FrontierBootNodes
	}
	// Otherwise parse and use the CLI bootstrap nodes
	bootnodes := []*discover.Node{}

	for _, url := range strings.Split(ctx.GlobalString(BootnodesFlag.Name), ",") {
		node, err := discover.ParseNode(url)
		if err != nil {
			glog.V(logger.Error).Infof("Bootstrap URL %s: %v\n", url, err)
			continue
		}
		bootnodes = append(bootnodes, node)
	}
	return bootnodes
}

// MakeListenAddress creates a TCP listening address string from set command
// line flags.
func MakeListenAddress(ctx *cli.Context) string {
	return fmt.Sprintf(":%d", ctx.GlobalInt(ListenPortFlag.Name))
}

// MakeNAT creates a port mapper from set command line flags.
func MakeNAT(ctx *cli.Context) nat.Interface {
	natif, err := nat.Parse(ctx.GlobalString(NATFlag.Name))
478
	if err != nil {
479 480 481 482 483
		Fatalf("Option %s: %v", NATFlag.Name, err)
	}
	return natif
}

484
// MakeHTTPRpcHost creates the HTTP RPC listener interface string from the set
485
// command line flags, returning empty if the HTTP endpoint is disabled.
486
func MakeHTTPRpcHost(ctx *cli.Context) string {
487 488 489 490 491 492
	if !ctx.GlobalBool(RPCEnabledFlag.Name) {
		return ""
	}
	return ctx.GlobalString(RPCListenAddrFlag.Name)
}

493
// MakeWSRpcHost creates the WebSocket RPC listener interface string from the set
494
// command line flags, returning empty if the HTTP endpoint is disabled.
495
func MakeWSRpcHost(ctx *cli.Context) string {
496 497 498 499 500 501
	if !ctx.GlobalBool(WSEnabledFlag.Name) {
		return ""
	}
	return ctx.GlobalString(WSListenAddrFlag.Name)
}

502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535
// MakeGenesisBlock loads up a genesis block from an input file specified in the
// command line, or returns the empty string if none set.
func MakeGenesisBlock(ctx *cli.Context) string {
	genesis := ctx.GlobalString(GenesisFileFlag.Name)
	if genesis == "" {
		return ""
	}
	data, err := ioutil.ReadFile(genesis)
	if err != nil {
		Fatalf("Failed to load custom genesis file: %v", err)
	}
	return string(data)
}

// MakeAccountManager creates an account manager from set command line flags.
func MakeAccountManager(ctx *cli.Context) *accounts.Manager {
	// Create the keystore crypto primitive, light if requested
	scryptN := crypto.StandardScryptN
	scryptP := crypto.StandardScryptP

	if ctx.GlobalBool(LightKDFFlag.Name) {
		scryptN = crypto.LightScryptN
		scryptP = crypto.LightScryptP
	}
	// Assemble an account manager using the configured datadir
	var (
		datadir  = MustMakeDataDir(ctx)
		keystore = crypto.NewKeyStorePassphrase(filepath.Join(datadir, "keystore"), scryptN, scryptP)
	)
	return accounts.NewManager(keystore)
}

// MakeAddress converts an account specified directly as a hex encoded string or
// a key index in the key store to an internal account representation.
536
func MakeAddress(accman *accounts.Manager, account string) (a common.Address, err error) {
537 538
	// If the specified account is a valid address, return it
	if common.IsHexAddress(account) {
539
		return common.HexToAddress(account), nil
540 541 542 543
	}
	// Otherwise try to interpret the account as a keystore index
	index, err := strconv.Atoi(account)
	if err != nil {
544
		return a, fmt.Errorf("invalid account address or index %q", account)
545 546 547
	}
	hex, err := accman.AddressByIndex(index)
	if err != nil {
548
		return a, fmt.Errorf("can't get account #%d (%v)", index, err)
549
	}
550
	return common.HexToAddress(hex), nil
551 552 553 554 555 556
}

// MakeEtherbase retrieves the etherbase either from the directly specified
// command line flags or from the keystore if CLI indexed.
func MakeEtherbase(accman *accounts.Manager, ctx *cli.Context) common.Address {
	accounts, _ := accman.Accounts()
557
	if !ctx.GlobalIsSet(EtherbaseFlag.Name) && len(accounts) == 0 {
558
		glog.V(logger.Error).Infoln("WARNING: No etherbase set and no accounts found as default")
559 560
		return common.Address{}
	}
561 562 563
	etherbase := ctx.GlobalString(EtherbaseFlag.Name)
	if etherbase == "" {
		return common.Address{}
564
	}
565 566
	// If the specified etherbase is a valid address, return it
	addr, err := MakeAddress(accman, etherbase)
567
	if err != nil {
568
		Fatalf("Option %q: %v", EtherbaseFlag.Name, err)
569
	}
570
	return addr
571 572 573 574 575 576 577
}

// MakeMinerExtra resolves extradata for the miner from the set command line flags
// or returns a default one composed on the client, runtime and OS metadata.
func MakeMinerExtra(extra []byte, ctx *cli.Context) []byte {
	if ctx.GlobalIsSet(ExtraDataFlag.Name) {
		return []byte(ctx.GlobalString(ExtraDataFlag.Name))
578
	}
579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618
	return extra
}

// MakePasswordList loads up a list of password from a file specified by the
// command line flags.
func MakePasswordList(ctx *cli.Context) []string {
	if path := ctx.GlobalString(PasswordFileFlag.Name); path != "" {
		blob, err := ioutil.ReadFile(path)
		if err != nil {
			Fatalf("Failed to read password file: %v", err)
		}
		return strings.Split(string(blob), "\n")
	}
	return nil
}

// MakeSystemNode sets up a local node, configures the services to launch and
// assembles the P2P protocol stack.
func MakeSystemNode(name, version string, extra []byte, ctx *cli.Context) *node.Node {
	// Avoid conflicting network flags
	networks, netFlags := 0, []cli.BoolFlag{DevModeFlag, TestNetFlag, OlympicFlag}
	for _, flag := range netFlags {
		if ctx.GlobalBool(flag.Name) {
			networks++
		}
	}
	if networks > 1 {
		Fatalf("The %v flags are mutually exclusive", netFlags)
	}
	// Configure the node's service container
	stackConf := &node.Config{
		DataDir:         MustMakeDataDir(ctx),
		PrivateKey:      MakeNodeKey(ctx),
		Name:            MakeNodeName(name, version, ctx),
		NoDiscovery:     ctx.GlobalBool(NoDiscoverFlag.Name),
		BootstrapNodes:  MakeBootstrapNodes(ctx),
		ListenAddr:      MakeListenAddress(ctx),
		NAT:             MakeNAT(ctx),
		MaxPeers:        ctx.GlobalInt(MaxPeersFlag.Name),
		MaxPendingPeers: ctx.GlobalInt(MaxPendingPeersFlag.Name),
619 620 621 622 623 624 625 626 627
		IPCPath:         MakeIPCPath(ctx),
		HTTPHost:        MakeHTTPRpcHost(ctx),
		HTTPPort:        ctx.GlobalInt(RPCPortFlag.Name),
		HTTPCors:        ctx.GlobalString(RPCCORSDomainFlag.Name),
		HTTPModules:     strings.Split(ctx.GlobalString(RPCApiFlag.Name), ","),
		WSHost:          MakeWSRpcHost(ctx),
		WSPort:          ctx.GlobalInt(WSPortFlag.Name),
		WSDomains:       ctx.GlobalString(WSAllowedDomainsFlag.Name),
		WSModules:       strings.Split(ctx.GlobalString(WSApiFlag.Name), ","),
628 629 630 631 632 633
	}
	// Configure the Ethereum service
	accman := MakeAccountManager(ctx)

	ethConf := &eth.Config{
		Genesis:                 MakeGenesisBlock(ctx),
634
		FastSync:                ctx.GlobalBool(FastSyncFlag.Name),
Z
zsfelfoldi 已提交
635
		BlockChainVersion:       ctx.GlobalInt(BlockchainVersionFlag.Name),
636
		DatabaseCache:           ctx.GlobalInt(CacheFlag.Name),
Z
zsfelfoldi 已提交
637
		NetworkId:               ctx.GlobalInt(NetworkIdFlag.Name),
638 639
		AccountManager:          accman,
		Etherbase:               MakeEtherbase(accman, ctx),
Z
zsfelfoldi 已提交
640
		MinerThreads:            ctx.GlobalInt(MinerThreadsFlag.Name),
641
		ExtraData:               MakeMinerExtra(extra, ctx),
Z
zsfelfoldi 已提交
642
		NatSpec:                 ctx.GlobalBool(NatspecEnabledFlag.Name),
Z
zelig 已提交
643
		DocRoot:                 ctx.GlobalString(DocRootFlag.Name),
Z
zsfelfoldi 已提交
644 645 646 647 648 649 650 651 652
		GasPrice:                common.String2Big(ctx.GlobalString(GasPriceFlag.Name)),
		GpoMinGasPrice:          common.String2Big(ctx.GlobalString(GpoMinGasPriceFlag.Name)),
		GpoMaxGasPrice:          common.String2Big(ctx.GlobalString(GpoMaxGasPriceFlag.Name)),
		GpoFullBlockRatio:       ctx.GlobalInt(GpoFullBlockRatioFlag.Name),
		GpobaseStepDown:         ctx.GlobalInt(GpobaseStepDownFlag.Name),
		GpobaseStepUp:           ctx.GlobalInt(GpobaseStepUpFlag.Name),
		GpobaseCorrectionFactor: ctx.GlobalInt(GpobaseCorrectionFactorFlag.Name),
		SolcPath:                ctx.GlobalString(SolcPathFlag.Name),
		AutoDAG:                 ctx.GlobalBool(AutoDAGFlag.Name) || ctx.GlobalBool(MiningEnabledFlag.Name),
653
	}
654 655
	// Configure the Whisper service
	shhEnable := ctx.GlobalBool(WhisperEnabledFlag.Name)
656

657 658 659 660 661 662 663 664 665
	// Override any default configs in dev mode or the test net
	switch {
	case ctx.GlobalBool(OlympicFlag.Name):
		if !ctx.GlobalIsSet(NetworkIdFlag.Name) {
			ethConf.NetworkId = 1
		}
		if !ctx.GlobalIsSet(GenesisFileFlag.Name) {
			ethConf.Genesis = core.OlympicGenesisBlock()
		}
666

667 668 669 670 671 672 673 674
	case ctx.GlobalBool(TestNetFlag.Name):
		if !ctx.GlobalIsSet(NetworkIdFlag.Name) {
			ethConf.NetworkId = 2
		}
		if !ctx.GlobalIsSet(GenesisFileFlag.Name) {
			ethConf.Genesis = core.TestNetGenesisBlock()
		}
		state.StartingNonce = 1048576 // (2**20)
675 676
		// overwrite homestead block
		params.HomesteadBlock = params.TestNetHomesteadBlock
677

678 679 680 681
	case ctx.GlobalBool(DevModeFlag.Name):
		// Override the base network stack configs
		if !ctx.GlobalIsSet(DataDirFlag.Name) {
			stackConf.DataDir = filepath.Join(os.TempDir(), "/ethereum_dev_mode")
682 683
		}
		if !ctx.GlobalIsSet(MaxPeersFlag.Name) {
684
			stackConf.MaxPeers = 0
685 686
		}
		if !ctx.GlobalIsSet(ListenPortFlag.Name) {
687 688 689 690 691 692 693 694
			stackConf.ListenAddr = ":0"
		}
		// Override the Ethereum protocol configs
		if !ctx.GlobalIsSet(GenesisFileFlag.Name) {
			ethConf.Genesis = core.OlympicGenesisBlock()
		}
		if !ctx.GlobalIsSet(GasPriceFlag.Name) {
			ethConf.GasPrice = new(big.Int)
695 696
		}
		if !ctx.GlobalIsSet(WhisperEnabledFlag.Name) {
697
			shhEnable = true
698
		}
699 700
		if !ctx.GlobalIsSet(VMDebugFlag.Name) {
			vm.Debug = true
701
		}
702
		ethConf.PowTest = true
703
	}
704 705 706 707 708
	// Assemble and return the protocol stack
	stack, err := node.New(stackConf)
	if err != nil {
		Fatalf("Failed to create the protocol stack: %v", err)
	}
709
	if err := stack.Register(func(ctx *node.ServiceContext) (node.Service, error) {
710 711 712 713 714
		return eth.New(ctx, ethConf)
	}); err != nil {
		Fatalf("Failed to register the Ethereum service: %v", err)
	}
	if shhEnable {
715
		if err := stack.Register(func(*node.ServiceContext) (node.Service, error) { return whisper.New(), nil }); err != nil {
716 717 718
			Fatalf("Failed to register the Whisper service: %v", err)
		}
	}
719

720
	return stack
721 722
}

723 724 725 726 727 728 729 730 731 732 733 734 735 736
// SetupNetwork configures the system for either the main net or some test network.
func SetupNetwork(ctx *cli.Context) {
	switch {
	case ctx.GlobalBool(OlympicFlag.Name):
		params.DurationLimit = big.NewInt(8)
		params.GenesisGasLimit = big.NewInt(3141592)
		params.MinGasLimit = big.NewInt(125000)
		params.MaximumExtraDataSize = big.NewInt(1024)
		NetworkIdFlag.Value = 0
		core.BlockReward = big.NewInt(1.5e+18)
		core.ExpDiffPeriod = big.NewInt(math.MaxInt64)
	}
}

737 738
// SetupVM configured the VM package's global settings
func SetupVM(ctx *cli.Context) {
739
	vm.EnableJit = ctx.GlobalBool(VMEnableJitFlag.Name)
740 741
	vm.ForceJit = ctx.GlobalBool(VMForceJitFlag.Name)
	vm.SetJITCacheSize(ctx.GlobalInt(VMJitCacheFlag.Name))
742 743 744
	if ctx.GlobalIsSet(VMDebugFlag.Name) {
		vm.Debug = ctx.GlobalBool(VMDebugFlag.Name)
	}
745 746
}

747
// MakeChain creates a chain manager from set command line flags.
748
func MakeChain(ctx *cli.Context) (chain *core.BlockChain, chainDb ethdb.Database) {
749
	datadir := MustMakeDataDir(ctx)
750 751
	cache := ctx.GlobalInt(CacheFlag.Name)

752
	var err error
753
	if chainDb, err = ethdb.NewLDBDatabase(filepath.Join(datadir, "chaindata"), cache); err != nil {
754 755
		Fatalf("Could not open database: %v", err)
	}
756
	if ctx.GlobalBool(OlympicFlag.Name) {
757
		_, err := core.WriteTestNetGenesisBlock(chainDb)
758 759 760 761
		if err != nil {
			glog.Fatalln(err)
		}
	}
762 763

	eventMux := new(event.TypeMux)
764
	pow := ethash.New()
765
	//genesis := core.GenesisBlock(uint64(ctx.GlobalInt(GenesisNonceFlag.Name)), blockDB)
766
	chain, err = core.NewBlockChain(chainDb, pow, eventMux)
O
obscuren 已提交
767 768 769
	if err != nil {
		Fatalf("Could not start chainmanager: %v", err)
	}
770
	return chain, chainDb
771
}