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

206 207 208 209 210 211 212 213 214 215 216 217 218 219
	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 已提交
220
	// logging and debug settings
221 222
	MetricsEnabledFlag = cli.BoolFlag{
		Name:  metrics.MetricsEnabledFlag,
223
		Usage: "Enable metrics collection and reporting",
224
	}
225 226 227 228

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

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

	// Gas price oracle settings
Z
zsfelfoldi 已提交
349 350 351
	GpoMinGasPriceFlag = cli.StringFlag{
		Name:  "gpomin",
		Usage: "Minimum suggested gas price",
352
		Value: new(big.Int).Mul(big.NewInt(20), common.Shannon).String(),
Z
zsfelfoldi 已提交
353 354 355 356
	}
	GpoMaxGasPriceFlag = cli.StringFlag{
		Name:  "gpomax",
		Usage: "Maximum suggested gas price",
357
		Value: new(big.Int).Mul(big.NewInt(500), common.Shannon).String(),
Z
zsfelfoldi 已提交
358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378
	}
	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,
	}
379 380
)

381 382 383 384 385 386 387 388 389
// 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
390
	}
391 392
	Fatalf("Cannot determine default data directory, please set manually (--datadir)")
	return ""
393 394
}

K
Kobi Gurkan 已提交
395 396 397 398 399 400 401 402 403 404
// MakeKeyStoreDir resolves the folder to use for storing the account keys from the
// set command line flags, returning the explicitly requested path, or one inside
// the data directory otherwise.
func MakeKeyStoreDir(datadir string, ctx *cli.Context) string {
	if path := ctx.GlobalString(KeyStoreDirFlag.Name); path != "" {
		return path
	}
	return filepath.Join(datadir, "keystore")
}

405
// MakeIPCPath creates an IPC path configuration from the set command line flags,
406
// returning an empty string if IPC was explicitly disabled, or the set path.
407
func MakeIPCPath(ctx *cli.Context) string {
408 409 410 411 412 413
	if ctx.GlobalBool(IPCDisabledFlag.Name) {
		return ""
	}
	return ctx.GlobalString(IPCPathFlag.Name)
}

414 415 416 417 418 419 420 421 422 423 424
// 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
	)
425 426 427
	switch {
	case file != "" && hex != "":
		Fatalf("Options %q and %q are mutually exclusive", NodeKeyFileFlag.Name, NodeKeyHexFlag.Name)
428

429 430 431 432
	case file != "":
		if key, err = crypto.LoadECDSA(file); err != nil {
			Fatalf("Option %q: %v", NodeKeyFileFlag.Name, err)
		}
433

434 435 436 437 438 439 440 441
	case hex != "":
		if key, err = crypto.HexToECDSA(hex); err != nil {
			Fatalf("Option %q: %v", NodeKeyHexFlag.Name, err)
		}
	}
	return key
}

442 443 444 445 446 447 448 449
// 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"
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 478 479 480 481 482 483 484 485 486
	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))
487
	if err != nil {
488 489 490 491 492
		Fatalf("Option %s: %v", NATFlag.Name, err)
	}
	return natif
}

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

502
// MakeWSRpcHost creates the WebSocket RPC listener interface string from the set
503
// command line flags, returning empty if the HTTP endpoint is disabled.
504
func MakeWSRpcHost(ctx *cli.Context) string {
505 506 507 508 509 510
	if !ctx.GlobalBool(WSEnabledFlag.Name) {
		return ""
	}
	return ctx.GlobalString(WSListenAddrFlag.Name)
}

511 512 513 514 515 516 517 518 519 520 521 522 523 524
// 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)
}

525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540
// MakeDatabaseHandles raises out the number of allowed file handles per process
// for Geth and returns half of the allowance to assign to the database.
func MakeDatabaseHandles() int {
	if err := raiseFdLimit(2048); err != nil {
		Fatalf("Failed to raise file descriptor allowance: %v", err)
	}
	limit, err := getFdLimit()
	if err != nil {
		Fatalf("Failed to retrieve file descriptor allowance: %v", err)
	}
	if limit > 2048 { // cap database file descriptors even if more is available
		limit = 2048
	}
	return limit / 2 // Leave half for networking and other stuff
}

541 542 543 544 545 546 547 548 549 550 551 552
// 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 (
K
Kobi Gurkan 已提交
553 554 555
		datadir     = MustMakeDataDir(ctx)
		keystoredir = MakeKeyStoreDir(datadir, ctx)
		keystore    = crypto.NewKeyStorePassphrase(keystoredir, scryptN, scryptP)
556 557 558 559 560 561
	)
	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.
562
func MakeAddress(accman *accounts.Manager, account string) (a common.Address, err error) {
563 564
	// If the specified account is a valid address, return it
	if common.IsHexAddress(account) {
565
		return common.HexToAddress(account), nil
566 567 568 569
	}
	// Otherwise try to interpret the account as a keystore index
	index, err := strconv.Atoi(account)
	if err != nil {
570
		return a, fmt.Errorf("invalid account address or index %q", account)
571 572 573
	}
	hex, err := accman.AddressByIndex(index)
	if err != nil {
574
		return a, fmt.Errorf("can't get account #%d (%v)", index, err)
575
	}
576
	return common.HexToAddress(hex), nil
577 578 579 580 581 582
}

// 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()
583
	if !ctx.GlobalIsSet(EtherbaseFlag.Name) && len(accounts) == 0 {
584
		glog.V(logger.Error).Infoln("WARNING: No etherbase set and no accounts found as default")
585 586
		return common.Address{}
	}
587 588 589
	etherbase := ctx.GlobalString(EtherbaseFlag.Name)
	if etherbase == "" {
		return common.Address{}
590
	}
591 592
	// If the specified etherbase is a valid address, return it
	addr, err := MakeAddress(accman, etherbase)
593
	if err != nil {
594
		Fatalf("Option %q: %v", EtherbaseFlag.Name, err)
595
	}
596
	return addr
597 598 599 600 601 602 603
}

// 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))
604
	}
605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644
	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),
645 646 647 648 649 650 651 652 653
		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), ","),
654 655 656 657 658 659
	}
	// Configure the Ethereum service
	accman := MakeAccountManager(ctx)

	ethConf := &eth.Config{
		Genesis:                 MakeGenesisBlock(ctx),
660
		FastSync:                ctx.GlobalBool(FastSyncFlag.Name),
Z
zsfelfoldi 已提交
661
		BlockChainVersion:       ctx.GlobalInt(BlockchainVersionFlag.Name),
662
		DatabaseCache:           ctx.GlobalInt(CacheFlag.Name),
663
		DatabaseHandles:         MakeDatabaseHandles(),
Z
zsfelfoldi 已提交
664
		NetworkId:               ctx.GlobalInt(NetworkIdFlag.Name),
665 666
		AccountManager:          accman,
		Etherbase:               MakeEtherbase(accman, ctx),
Z
zsfelfoldi 已提交
667
		MinerThreads:            ctx.GlobalInt(MinerThreadsFlag.Name),
668
		ExtraData:               MakeMinerExtra(extra, ctx),
Z
zsfelfoldi 已提交
669
		NatSpec:                 ctx.GlobalBool(NatspecEnabledFlag.Name),
Z
zelig 已提交
670
		DocRoot:                 ctx.GlobalString(DocRootFlag.Name),
671 672
		EnableJit:               ctx.GlobalBool(VMEnableJitFlag.Name),
		ForceJit:                ctx.GlobalBool(VMForceJitFlag.Name),
Z
zsfelfoldi 已提交
673 674 675 676 677 678 679 680 681
		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),
682
	}
683 684
	// Configure the Whisper service
	shhEnable := ctx.GlobalBool(WhisperEnabledFlag.Name)
685

686 687 688 689 690 691 692 693 694
	// 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()
		}
695

696 697 698 699 700 701 702 703
	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)
704 705
		// overwrite homestead block
		params.HomesteadBlock = params.TestNetHomesteadBlock
706

707 708 709 710
	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")
711 712
		}
		if !ctx.GlobalIsSet(MaxPeersFlag.Name) {
713
			stackConf.MaxPeers = 0
714 715
		}
		if !ctx.GlobalIsSet(ListenPortFlag.Name) {
716 717 718 719 720 721 722 723
			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)
724 725
		}
		if !ctx.GlobalIsSet(WhisperEnabledFlag.Name) {
726
			shhEnable = true
727
		}
728
		ethConf.PowTest = true
729
	}
730 731 732 733 734
	// Assemble and return the protocol stack
	stack, err := node.New(stackConf)
	if err != nil {
		Fatalf("Failed to create the protocol stack: %v", err)
	}
735
	if err := stack.Register(func(ctx *node.ServiceContext) (node.Service, error) {
736 737 738 739 740
		return eth.New(ctx, ethConf)
	}); err != nil {
		Fatalf("Failed to register the Ethereum service: %v", err)
	}
	if shhEnable {
741
		if err := stack.Register(func(*node.ServiceContext) (node.Service, error) { return whisper.New(), nil }); err != nil {
742 743 744
			Fatalf("Failed to register the Whisper service: %v", err)
		}
	}
745

746
	return stack
747 748
}

749 750 751 752 753 754 755 756 757 758 759 760 761 762
// 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)
	}
}

763 764
// SetupVM configured the VM package's global settings
func SetupVM(ctx *cli.Context) {
765
	vm.EnableJit = ctx.GlobalBool(VMEnableJitFlag.Name)
766 767 768 769
	vm.ForceJit = ctx.GlobalBool(VMForceJitFlag.Name)
	vm.SetJITCacheSize(ctx.GlobalInt(VMJitCacheFlag.Name))
}

770
// MakeChain creates a chain manager from set command line flags.
771
func MakeChain(ctx *cli.Context) (chain *core.BlockChain, chainDb ethdb.Database) {
772
	datadir := MustMakeDataDir(ctx)
773
	cache := ctx.GlobalInt(CacheFlag.Name)
774
	handles := MakeDatabaseHandles()
775

776
	var err error
777
	if chainDb, err = ethdb.NewLDBDatabase(filepath.Join(datadir, "chaindata"), cache, handles); err != nil {
778 779
		Fatalf("Could not open database: %v", err)
	}
780
	if ctx.GlobalBool(OlympicFlag.Name) {
781
		_, err := core.WriteTestNetGenesisBlock(chainDb)
782 783 784 785
		if err != nil {
			glog.Fatalln(err)
		}
	}
786 787

	eventMux := new(event.TypeMux)
788
	pow := ethash.New()
789
	//genesis := core.GenesisBlock(uint64(ctx.GlobalInt(GenesisNonceFlag.Name)), blockDB)
790
	chain, err = core.NewBlockChain(chainDb, pow, eventMux)
O
obscuren 已提交
791 792 793
	if err != nil {
		Fatalf("Could not start chainmanager: %v", err)
	}
794
	return chain, chainDb
795
}