Skip to content

Commit d2e6185

Browse files
author
colinlyguo
committed
update get block hash by chunk
1 parent 93d1c17 commit d2e6185

File tree

1 file changed

+8
-9
lines changed

1 file changed

+8
-9
lines changed

coordinator/internal/orm/l2_block.go

Lines changed: 8 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -54,23 +54,22 @@ func (*L2Block) TableName() string {
5454
func (o *L2Block) GetL2BlockHashesByChunkHash(ctx context.Context, chunkHash string) ([]common.Hash, error) {
5555
db := o.db.WithContext(ctx)
5656
db = db.Model(&L2Block{})
57-
db = db.Select("header")
57+
db = db.Select("hash")
5858
db = db.Where("chunk_hash = ?", chunkHash)
5959
db = db.Order("number ASC")
6060

61-
var l2Blocks []L2Block
62-
if err := db.Find(&l2Blocks).Error; err != nil {
61+
var hashes []string
62+
if err := db.Pluck("hash", &hashes).Error; err != nil {
6363
return nil, fmt.Errorf("L2Block.GetL2BlockHashesByChunkHash error: %w, chunk hash: %v", err, chunkHash)
6464
}
6565

6666
var blockHashes []common.Hash
67-
for _, v := range l2Blocks {
68-
var header gethTypes.Header
69-
if err := json.Unmarshal([]byte(v.Header), &header); err != nil {
70-
return nil, fmt.Errorf("L2Block.GetL2BlockHashesByChunkHash error: %w, chunk hash: %v", err, chunkHash)
71-
}
72-
blockHashes = append(blockHashes, header.Hash())
67+
for _, h := range hashes {
68+
blockHashes = append(blockHashes, common.HexToHash(h))
7369
}
70+
71+
log.Info("retrieved block hashes by chunk hash", "chunk hash", chunkHash, "block hashes", hashes)
72+
7473
return blockHashes, nil
7574
}
7675

0 commit comments

Comments
 (0)