"github.com/jinzhu/gorm"
// log "github.com/sirupsen/logrus"
- // "github.com/vapor/federation/config"
+ "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
+ cfg *config.Chain
+ db *gorm.DB
node *service.Node
+ // cache *database.RedisDB
// coinName string
}
)
type DbKeeper struct {
- // db *gorm.DB
- // node *service.Node
blockKeeper *blockKeeper
unconfirmedTxKeeper *unconfirmedTxKeeper
}
func NewDbKeeper(db *gorm.DB, chainCfg *config.Chain) *DbKeeper {
blockKeeper := &blockKeeper{
+ cfg: chainCfg,
db: db,
node: service.NewNode(chainCfg.Upstream.RPC),
}
unconfirmedTxKeeper := &unconfirmedTxKeeper{
+ cfg: chainCfg,
db: db,
processTxCh: make(chan *service.WSResponse, maxRawTxSize),
}
"github.com/jinzhu/gorm"
// log "github.com/sirupsen/logrus"
- // "github.com/vapor/federation/config"
+ "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
+ cfg *config.Chain
+ db *gorm.DB
processTxCh chan *service.WSResponse
+ // coinName string
}
func (u *unconfirmedTxKeeper) Run() {