add

diff --git a/cmd/fedd/main.go b/cmd/fedd/main.go
index f59557d..4130488 100644 (file)
--- a/cmd/fedd/main.go
+++ b/cmd/fedd/main.go
@@ -20,8 +20,8 @@ func main() {
        }
 
        txCh := make(chan *orm.CrossTransaction)
-       go synchron.NewMainchainKeeper(db, &cfg.Mainchain).Run()
-       go synchron.NewSidechainKeeper(db, &cfg.Sidechain).Run()
+       go synchron.NewMainchainKeeper(db, &cfg.Mainchain, txCh).Run()
+       go synchron.NewSidechainKeeper(db, &cfg.Sidechain, txCh).Run()
        go federation.NewWarder(txCh).Run()
 
        // keep the main func running in case of terminating goroutines

diff --git a/federation/synchron/mainchain_keeper.go b/federation/synchron/mainchain_keeper.go
index 50f7a03..e0cfc93 100644 (file)
--- a/federation/synchron/mainchain_keeper.go
+++ b/federation/synchron/mainchain_keeper.go
@@ -31,15 +31,17 @@ type mainchainKeeper struct {
        node       *service.Node
        chainName  string
        assetCache *database.AssetCache
+       txCh       chan *orm.CrossTransaction
 }
 
-func NewMainchainKeeper(db *gorm.DB, chainCfg *config.Chain) *mainchainKeeper {
+func NewMainchainKeeper(db *gorm.DB, chainCfg *config.Chain, txCh chan *orm.CrossTransaction) *mainchainKeeper {
        return &mainchainKeeper{
                cfg:        chainCfg,
                db:         db,
                node:       service.NewNode(chainCfg.Upstream),
                chainName:  chainCfg.Name,
                assetCache: database.NewAssetCache(),
+               txCh:       txCh,
        }
 }
 

diff --git a/federation/synchron/sidechain_keeper.go b/federation/synchron/sidechain_keeper.go
index fed458e..5da38bc 100644 (file)
--- a/federation/synchron/sidechain_keeper.go
+++ b/federation/synchron/sidechain_keeper.go
@@ -26,15 +26,17 @@ type sidechainKeeper struct {
        node       *service.Node
        chainName  string
        assetCache *database.AssetCache
+       txCh       chan *orm.CrossTransaction
 }
 
-func NewSidechainKeeper(db *gorm.DB, chainCfg *config.Chain) *sidechainKeeper {
+func NewSidechainKeeper(db *gorm.DB, chainCfg *config.Chain, txCh chan *orm.CrossTransaction) *sidechainKeeper {
        return &sidechainKeeper{
                cfg:        chainCfg,
                db:         db,
                node:       service.NewNode(chainCfg.Upstream),
                chainName:  chainCfg.Name,
                assetCache: database.NewAssetCache(),
+               txCh:       txCh,
        }
 }