// 加入一个新的区块到区块链中
func (bc *BlockChain) AddBlock(data string) {
var (
lastHash []byte
err error
)
// 获取最后区块的hash值
err = bc.db.View(func(tx1 *bolt.Tx) error {
b := tx1.Bucket([]byte(BLOCKS_BUCKET))
lastHash = b.Get([]byte(LAST_HASH))
return nil
})
// 计算新的区块
newBlock := NewBlock(data, lastHash)
bc.lastHash = newBlock.Hash
// 将新的区块加入到数据库区块链中
err = bc.db.Update(func(tx *bolt.Tx) error {
b := tx.Bucket([]byte(BLOCKS_BUCKET))
err = b.Put(newBlock.Hash, newBlock.Serialize())
// 将新的区块置为最后一个区块
err = b.Put([]byte(LAST_HASH), newBlock.Hash)
return err
})
if err != nil {
log.Panic("failed to add new block:",err)
}
}