diff options
author | Wei-Ning Huang <w@cobinhood.com> | 2018-10-12 11:08:15 +0800 |
---|---|---|
committer | Wei-Ning Huang <w@dexon.org> | 2018-12-19 20:54:27 +0800 |
commit | 43d1d9f257f17efa3000ae3ad80585c7b33d91ac (patch) | |
tree | ed8dc132aaee678112ace3efca8aba120b1bf619 | |
parent | 2da6350c8775cdfca8f4284b549ca47a83ad9ab4 (diff) | |
download | dexon-43d1d9f257f17efa3000ae3ad80585c7b33d91ac.tar dexon-43d1d9f257f17efa3000ae3ad80585c7b33d91ac.tar.gz dexon-43d1d9f257f17efa3000ae3ad80585c7b33d91ac.tar.bz2 dexon-43d1d9f257f17efa3000ae3ad80585c7b33d91ac.tar.lz dexon-43d1d9f257f17efa3000ae3ad80585c7b33d91ac.tar.xz dexon-43d1d9f257f17efa3000ae3ad80585c7b33d91ac.tar.zst dexon-43d1d9f257f17efa3000ae3ad80585c7b33d91ac.zip |
dex: update application interface
-rw-r--r-- | dex/app.go | 47 |
1 files changed, 27 insertions, 20 deletions
diff --git a/dex/app.go b/dex/app.go index cdbcdbda6..b34c9f553 100644 --- a/dex/app.go +++ b/dex/app.go @@ -19,11 +19,13 @@ package dex import ( "bytes" - "github.com/dexon-foundation/dexon/core/rawdb" "math/big" "sync" "time" + "github.com/dexon-foundation/dexon/core/rawdb" + + coreCommon "github.com/dexon-foundation/dexon-consensus-core/common" coreTypes "github.com/dexon-foundation/dexon-consensus-core/core/types" "github.com/dexon-foundation/dexon/common" @@ -232,26 +234,31 @@ func (d *DexconApp) VerifyBlock(block *coreTypes.Block) bool { return true } +func (d *DexconApp) BlockConfirmed(block coreTypes.Block) { +} + // BlockDelivered is called when a block is add to the compaction chain. -func (d *DexconApp) BlockDelivered(block coreTypes.Block) { - var transactions types.Transactions - err := rlp.Decode(bytes.NewReader(block.Payload), &transactions) - if err != nil { - return - } +func (d *DexconApp) BlockDelivered(blockHash coreCommon.Hash, result coreTypes.FinalizationResult) { + /* + var transactions types.Transactions + err := rlp.Decode(bytes.NewReader(block.Payload), &transactions) + if err != nil { + return + } - _, err = d.blockchain.InsertChain( - []*types.Block{types.NewBlock(&types.Header{ - ParentHash: common.Hash(block.ParentHash), - Number: new(big.Int).SetUint64(block.ConsensusHeight), - Time: new(big.Int).SetInt64(block.ConsensusTimestamp.Unix()), - TxHash: types.DeriveSha(transactions), - Coinbase: common.BytesToAddress(block.ProposerID.Hash[:]), - }, transactions, nil, nil)}) - if err != nil { - // do something - return - } + _, err = d.blockchain.InsertChain( + []*types.Block{types.NewBlock(&types.Header{ + ParentHash: common.Hash(block.ParentHash), + Number: new(big.Int).SetUint64(result.Height), + Time: new(big.Int).SetInt64(result.Timestamp.Unix()), + TxHash: types.DeriveSha(transactions), + Coinbase: common.BytesToAddress(block.ProposerID.Hash[:]), + }, transactions, nil, nil)}) + if err != nil { + // do something + return + } - d.notify(block.ConsensusHeight) + d.notify(result.Height) + */ } |