diff --git a/app/config/config.go b/app/config/config.go index ec95169..c09b27f 100644 --- a/app/config/config.go +++ b/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 { diff --git a/cmd/thalos/main.go b/cmd/thalos/main.go index 3eb17e2..b74d1e5 100644 --- a/cmd/thalos/main.go +++ b/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, diff --git a/config.example.yml b/config.example.yml index 1bf5ff0..caf4a10 100644 --- a/config.example.yml +++ b/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