init run

diff --git a/federation/synchron/block_keeper.go b/federation/synchron/block_keeper.go
new file mode 100644 (file)
index 0000000..31b84b3
--- /dev/null
+++ b/federation/synchron/block_keeper.go
@@ -0,0 +1,28 @@
+package synchron
+
+import (
+       // "time"
+
+       // "github.com/bytom/errors"
+       // "github.com/bytom/protocol/bc"
+       // "github.com/bytom/protocol/bc/types"
+       "github.com/jinzhu/gorm"
+       // log "github.com/sirupsen/logrus"
+
+       // "github.com/vapor/federation/config"
+       // "github.com/blockcenter/database"
+       // "github.com/blockcenter/database/orm"
+       "github.com/vapor/federation/service"
+)
+
+type blockKeeper struct {
+       // cfg      *config.Config
+       db *gorm.DB
+       // cache    *database.RedisDB
+       node *service.Node
+       // coinName string
+}
+
+func (b *blockKeeper) Run() {
+
+}

diff --git a/federation/synchron/db_keeper.go b/federation/synchron/db_keeper.go
index f5d709b..ba2a339 100644 (file)
--- a/federation/synchron/db_keeper.go
+++ b/federation/synchron/db_keeper.go
@@ -16,16 +16,27 @@ import (
 )
 
 type DbKeeper struct {
-       db   *gorm.DB
-       node *service.Node
+       // db   *gorm.DB
+       // node *service.Node
+       blockKeeper         *blockKeeper
+       unconfirmedTxKeeper *unconfirmedTxKeeper
 }
 
 func NewDbKeeper(db *gorm.DB, chainCfg *config.Chain) *DbKeeper {
-       return &DbKeeper{
+       blockKeeper := &blockKeeper{
                db:   db,
                node: service.NewNode(chainCfg.Upstream.RPC),
        }
+
+       unconfirmedTxKeeper := &unconfirmedTxKeeper{
+               db:          db,
+               processTxCh: make(chan *service.WSResponse, maxRawTxSize),
+       }
+
+       return &DbKeeper{blockKeeper, unconfirmedTxKeeper}
 }
 
 func (d *DbKeeper) Run() {
+       d.blockKeeper.Run()
+       d.unconfirmedTxKeeper.Run()
 }

diff --git a/federation/synchron/unconfirmed_tx_keeper.go b/federation/synchron/unconfirmed_tx_keeper.go
new file mode 100644 (file)
index 0000000..b9c875d
--- /dev/null
+++ b/federation/synchron/unconfirmed_tx_keeper.go
@@ -0,0 +1,29 @@
+package synchron
+
+import (
+       // "time"
+
+       // "github.com/bytom/errors"
+       // "github.com/bytom/protocol/bc"
+       // "github.com/bytom/protocol/bc/types"
+       "github.com/jinzhu/gorm"
+       // log "github.com/sirupsen/logrus"
+
+       // "github.com/vapor/federation/config"
+       // "github.com/blockcenter/database"
+       // "github.com/blockcenter/database/orm"
+       "github.com/vapor/federation/service"
+)
+
+const maxRawTxSize = 1 << 16
+
+type unconfirmedTxKeeper struct {
+       // cfg         *config.Config
+       db *gorm.DB
+       // coinName    string
+       processTxCh chan *service.WSResponse
+}
+
+func (u *unconfirmedTxKeeper) Run() {
+
+}