From d6a3661830f80ef57be208cec457d49c44a8d435 Mon Sep 17 00:00:00 2001
From: Meng-Ying Yang <garfield@dexon.org>
Date: Thu, 27 Dec 2018 19:22:41 +0800
Subject: indexer: support data exporting/forwarding (#103)

To support more effective and flexible blockchain info exploring, we add
`indexer` package, defines the flow of indexer dameon, and integrate
into dex.Dexon fullnode.

For more export options, we use Golang built-in `plugin` package to
support mulitple implementations.
---
 cmd/gdex/main.go   |  2 ++
 cmd/gdex/usage.go  |  7 +++++++
 cmd/utils/flags.go | 23 +++++++++++++++++++++++
 3 files changed, 32 insertions(+)

(limited to 'cmd')

diff --git a/cmd/gdex/main.go b/cmd/gdex/main.go
index 28e918f84..df1be3083 100644
--- a/cmd/gdex/main.go
+++ b/cmd/gdex/main.go
@@ -137,6 +137,8 @@ var (
 		utils.GpoPercentileFlag,
 		utils.EWASMInterpreterFlag,
 		utils.EVMInterpreterFlag,
+		utils.IndexerEnableFlag,
+		utils.IndexerPluginFlag,
 		configFileFlag,
 	}
 
diff --git a/cmd/gdex/usage.go b/cmd/gdex/usage.go
index e657e032b..df63460d0 100644
--- a/cmd/gdex/usage.go
+++ b/cmd/gdex/usage.go
@@ -238,6 +238,13 @@ var AppHelpFlagGroups = []flagGroup{
 			utils.MetricsInfluxDBHostTagFlag,
 		},
 	},
+	{
+		Name: "INDEXER",
+		Flags: []cli.Flag{
+			utils.IndexerEnableFlag,
+			utils.IndexerPluginFlag,
+		},
+	},
 	{
 		Name:  "WHISPER (EXPERIMENTAL)",
 		Flags: whisperFlags,
diff --git a/cmd/utils/flags.go b/cmd/utils/flags.go
index f262d0786..4ecc2865d 100644
--- a/cmd/utils/flags.go
+++ b/cmd/utils/flags.go
@@ -643,6 +643,17 @@ var (
 		Usage: "External EVM configuration (default = built-in interpreter)",
 		Value: "",
 	}
+
+	// Data sources options.
+	IndexerEnableFlag = cli.BoolFlag{
+		Name:  "indexer",
+		Usage: "Enable indexer",
+	}
+	IndexerPluginFlag = cli.StringFlag{
+		Name:  "indexer.plugin",
+		Usage: "External indexer plugin shared object path",
+		Value: "",
+	}
 )
 
 // MakeDataDir retrieves the currently requested data directory, terminating
@@ -1274,6 +1285,18 @@ func SetDexConfig(ctx *cli.Context, stack *node.Node, cfg *dex.Config) {
 			now.Hour(), now.Minute(), (now.Second()/5+1)*5,
 			0, now.Location()).Unix()
 	}
+
+	// Set indexer config.
+	setIndexerConfig(ctx, cfg)
+}
+
+func setIndexerConfig(ctx *cli.Context, cfg *dex.Config) {
+	cfg.Indexer.Enable = ctx.GlobalBool(IndexerEnableFlag.Name)
+	if !cfg.Indexer.Enable {
+		return
+	}
+
+	cfg.Indexer.Plugin = ctx.GlobalString(IndexerPluginFlag.Name)
 }
 
 // SetDashboardConfig applies dashboard related command line flags to the config.
-- 
cgit v1.2.3