whisper: move flags from whisper package to utils
This commit is contained in:
parent
4a1d516d78
commit
7a11e86442
|
@ -43,7 +43,7 @@ var (
|
||||||
Name: "dumpconfig",
|
Name: "dumpconfig",
|
||||||
Usage: "Show configuration values",
|
Usage: "Show configuration values",
|
||||||
ArgsUsage: "",
|
ArgsUsage: "",
|
||||||
Flags: append(append(nodeFlags, rpcFlags...), whisper.Flags...),
|
Flags: append(append(nodeFlags, rpcFlags...), whisperFlags...),
|
||||||
Category: "MISCELLANEOUS COMMANDS",
|
Category: "MISCELLANEOUS COMMANDS",
|
||||||
Description: `The dumpconfig command shows configuration values.`,
|
Description: `The dumpconfig command shows configuration values.`,
|
||||||
}
|
}
|
||||||
|
@ -140,7 +140,7 @@ func makeConfigNode(ctx *cli.Context) (*node.Node, gethConfig) {
|
||||||
|
|
||||||
// enableWhisper returns true in case one of the whisper flags is set.
|
// enableWhisper returns true in case one of the whisper flags is set.
|
||||||
func enableWhisper(ctx *cli.Context) bool {
|
func enableWhisper(ctx *cli.Context) bool {
|
||||||
for _, flag := range whisper.Flags {
|
for _, flag := range whisperFlags {
|
||||||
if ctx.GlobalIsSet(flag.GetName()) {
|
if ctx.GlobalIsSet(flag.GetName()) {
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
@ -155,13 +155,13 @@ func makeFullNode(ctx *cli.Context) *node.Node {
|
||||||
|
|
||||||
// Whisper must be explicitly enabled by specifying at least 1 whisper flag or in dev mode
|
// Whisper must be explicitly enabled by specifying at least 1 whisper flag or in dev mode
|
||||||
shhEnabled := enableWhisper(ctx)
|
shhEnabled := enableWhisper(ctx)
|
||||||
shhAutoEnabled := !ctx.GlobalIsSet(whisper.WhisperEnabledFlag.Name) && ctx.GlobalIsSet(utils.DevModeFlag.Name)
|
shhAutoEnabled := !ctx.GlobalIsSet(utils.WhisperEnabledFlag.Name) && ctx.GlobalIsSet(utils.DevModeFlag.Name)
|
||||||
if shhEnabled || shhAutoEnabled {
|
if shhEnabled || shhAutoEnabled {
|
||||||
if ctx.GlobalIsSet(whisper.MaxMessageSizeFlag.Name) {
|
if ctx.GlobalIsSet(utils.WhisperMaxMessageSizeFlag.Name) {
|
||||||
cfg.Shh.MaxMessageSize = uint32(ctx.Int(whisper.MaxMessageSizeFlag.Name))
|
cfg.Shh.MaxMessageSize = uint32(ctx.Int(utils.WhisperMaxMessageSizeFlag.Name))
|
||||||
}
|
}
|
||||||
if ctx.GlobalIsSet(whisper.MinPOWFlag.Name) {
|
if ctx.GlobalIsSet(utils.WhisperMinPOWFlag.Name) {
|
||||||
cfg.Shh.MinimumAcceptedPOW = ctx.Float64(whisper.MinPOWFlag.Name)
|
cfg.Shh.MinimumAcceptedPOW = ctx.Float64(utils.WhisperMinPOWFlag.Name)
|
||||||
}
|
}
|
||||||
utils.RegisterShhService(stack, &cfg.Shh)
|
utils.RegisterShhService(stack, &cfg.Shh)
|
||||||
}
|
}
|
||||||
|
|
|
@ -35,7 +35,6 @@ import (
|
||||||
"github.com/ethereum/go-ethereum/log"
|
"github.com/ethereum/go-ethereum/log"
|
||||||
"github.com/ethereum/go-ethereum/metrics"
|
"github.com/ethereum/go-ethereum/metrics"
|
||||||
"github.com/ethereum/go-ethereum/node"
|
"github.com/ethereum/go-ethereum/node"
|
||||||
whisper "github.com/ethereum/go-ethereum/whisper/whisperv5"
|
|
||||||
"gopkg.in/urfave/cli.v1"
|
"gopkg.in/urfave/cli.v1"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -125,6 +124,12 @@ var (
|
||||||
utils.IPCDisabledFlag,
|
utils.IPCDisabledFlag,
|
||||||
utils.IPCPathFlag,
|
utils.IPCPathFlag,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
whisperFlags = []cli.Flag{
|
||||||
|
utils.WhisperEnabledFlag,
|
||||||
|
utils.WhisperMaxMessageSizeFlag,
|
||||||
|
utils.WhisperMinPOWFlag,
|
||||||
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
func init() {
|
func init() {
|
||||||
|
@ -161,7 +166,7 @@ func init() {
|
||||||
app.Flags = append(app.Flags, rpcFlags...)
|
app.Flags = append(app.Flags, rpcFlags...)
|
||||||
app.Flags = append(app.Flags, consoleFlags...)
|
app.Flags = append(app.Flags, consoleFlags...)
|
||||||
app.Flags = append(app.Flags, debug.Flags...)
|
app.Flags = append(app.Flags, debug.Flags...)
|
||||||
app.Flags = append(app.Flags, whisper.Flags...)
|
app.Flags = append(app.Flags, whisperFlags...)
|
||||||
|
|
||||||
app.Before = func(ctx *cli.Context) error {
|
app.Before = func(ctx *cli.Context) error {
|
||||||
runtime.GOMAXPROCS(runtime.NumCPU())
|
runtime.GOMAXPROCS(runtime.NumCPU())
|
||||||
|
|
|
@ -24,7 +24,6 @@ import (
|
||||||
|
|
||||||
"github.com/ethereum/go-ethereum/cmd/utils"
|
"github.com/ethereum/go-ethereum/cmd/utils"
|
||||||
"github.com/ethereum/go-ethereum/internal/debug"
|
"github.com/ethereum/go-ethereum/internal/debug"
|
||||||
"github.com/ethereum/go-ethereum/whisper/whisperv5"
|
|
||||||
"gopkg.in/urfave/cli.v1"
|
"gopkg.in/urfave/cli.v1"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -190,7 +189,7 @@ var AppHelpFlagGroups = []flagGroup{
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
Name: "Whisper (EXPERIMENTAL)",
|
Name: "Whisper (EXPERIMENTAL)",
|
||||||
Flags: whisperv5.Flags,
|
Flags: whisperFlags,
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
Name: "DEPRECATED",
|
Name: "DEPRECATED",
|
||||||
|
|
|
@ -458,6 +458,20 @@ var (
|
||||||
Usage: "Suggested gas price is the given percentile of a set of recent transaction gas prices",
|
Usage: "Suggested gas price is the given percentile of a set of recent transaction gas prices",
|
||||||
Value: eth.DefaultConfig.GPO.Percentile,
|
Value: eth.DefaultConfig.GPO.Percentile,
|
||||||
}
|
}
|
||||||
|
WhisperEnabledFlag = cli.BoolFlag{
|
||||||
|
Name: "shh",
|
||||||
|
Usage: "Enable Whisper",
|
||||||
|
}
|
||||||
|
WhisperMaxMessageSizeFlag = cli.IntFlag{
|
||||||
|
Name: "shh.maxmessagesize",
|
||||||
|
Usage: "Max message size accepted",
|
||||||
|
Value: int(whisper.DefaultMaxMessageSize),
|
||||||
|
}
|
||||||
|
WhisperMinPOWFlag = cli.Float64Flag{
|
||||||
|
Name: "shh.pow",
|
||||||
|
Usage: "Minimum POW accepted",
|
||||||
|
Value: whisper.DefaultMinimumPoW,
|
||||||
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
// MakeDataDir retrieves the currently requested data directory, terminating
|
// MakeDataDir retrieves the currently requested data directory, terminating
|
||||||
|
@ -875,11 +889,11 @@ func checkExclusive(ctx *cli.Context, flags ...cli.Flag) {
|
||||||
|
|
||||||
// SetShhConfig applies shh-related command line flags to the config.
|
// SetShhConfig applies shh-related command line flags to the config.
|
||||||
func SetShhConfig(ctx *cli.Context, stack *node.Node, cfg *whisper.Config) {
|
func SetShhConfig(ctx *cli.Context, stack *node.Node, cfg *whisper.Config) {
|
||||||
if ctx.GlobalIsSet(whisper.MaxMessageSizeFlag.Name) {
|
if ctx.GlobalIsSet(WhisperMaxMessageSizeFlag.Name) {
|
||||||
cfg.MaxMessageSize = uint32(ctx.GlobalUint(whisper.MaxMessageSizeFlag.Name))
|
cfg.MaxMessageSize = uint32(ctx.GlobalUint(WhisperMaxMessageSizeFlag.Name))
|
||||||
}
|
}
|
||||||
if ctx.GlobalIsSet(whisper.MinPOWFlag.Name) {
|
if ctx.GlobalIsSet(WhisperMinPOWFlag.Name) {
|
||||||
cfg.MinimumAcceptedPOW = ctx.GlobalFloat64(whisper.MinPOWFlag.Name)
|
cfg.MinimumAcceptedPOW = ctx.GlobalFloat64(WhisperMinPOWFlag.Name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -16,10 +16,6 @@
|
||||||
|
|
||||||
package whisperv5
|
package whisperv5
|
||||||
|
|
||||||
import (
|
|
||||||
"gopkg.in/urfave/cli.v1"
|
|
||||||
)
|
|
||||||
|
|
||||||
type Config struct {
|
type Config struct {
|
||||||
MaxMessageSize uint32 `toml:",omitempty"`
|
MaxMessageSize uint32 `toml:",omitempty"`
|
||||||
MinimumAcceptedPOW float64 `toml:",omitempty"`
|
MinimumAcceptedPOW float64 `toml:",omitempty"`
|
||||||
|
@ -30,21 +26,4 @@ var DefaultConfig = Config{
|
||||||
MinimumAcceptedPOW: DefaultMinimumPoW,
|
MinimumAcceptedPOW: DefaultMinimumPoW,
|
||||||
}
|
}
|
||||||
|
|
||||||
var (
|
var ()
|
||||||
WhisperEnabledFlag = cli.BoolFlag{
|
|
||||||
Name: "shh",
|
|
||||||
Usage: "Enable Whisper",
|
|
||||||
}
|
|
||||||
MaxMessageSizeFlag = cli.IntFlag{
|
|
||||||
Name: "shh.maxmessagesize",
|
|
||||||
Usage: "Max message size accepted",
|
|
||||||
Value: int(DefaultMaxMessageSize),
|
|
||||||
}
|
|
||||||
MinPOWFlag = cli.Float64Flag{
|
|
||||||
Name: "shh.pow",
|
|
||||||
Usage: "Minimum POW accepted",
|
|
||||||
Value: DefaultMinimumPoW,
|
|
||||||
}
|
|
||||||
|
|
||||||
Flags = []cli.Flag{WhisperEnabledFlag, MaxMessageSizeFlag, MinPOWFlag}
|
|
||||||
)
|
|
||||||
|
|
Loading…
Reference in New Issue