Merge pull request #17 from eosswedenorg/15-support-chain-names

support chain names

app/config/config.go

@@ -30,6 +30,7 @@ type ShipConfig struct {
 	MaxMessagesInFlight uint32 `yaml:"max_messages_in_flight"`
 	StartBlockNum       uint32 `yaml:"start_block_num"`
 	EndBlockNum         uint32 `yaml:"end_block_num"`
+	Chain               string `yaml:"chain"`
 }
 
 type Config struct {

cmd/thalos/main.go

@@ -137,6 +137,13 @@ func init() {
 	log.SetFormatter(&formatter)
 }
 
+func getChain(def string) string {
+	if len(conf.Ship.Chain) > 0 {
+		return conf.Ship.Chain
+	}
+	return def
+}
+
 func main() {
 	var err error
 	var chainInfo *eos.InfoResp
@@ -255,7 +262,7 @@ func main() {
 		shClient,
 		api_redis.NewPublisher(rdb, api_redis.Namespace{
 			Prefix:  conf.Redis.Prefix,
-			ChainID: chainInfo.ChainID.String(),
+			ChainID: getChain(chainInfo.ChainID.String()),
 		}),
 		abi.NewAbiManager(rdb, eosClient, conf.Redis.CacheID),
 		codec,

config.example.yml

@@ -29,6 +29,10 @@ ship:
   # Url to ship api.
   url: "ws://127.0.0.1:8089"
 
+  # Name of chain. Note that this is just a name to be used in channel namespace.
+  # If unset, chain id from api is used.
+  # chain: wax
+
   # Fetch irreversible blocks only
   # irreversible_only: true