Skip to content

Commit 75b2271

Browse files
committed
migrate merkle to child
1 parent 3cc9494 commit 75b2271

File tree

1 file changed

+20
-3
lines changed

1 file changed

+20
-3
lines changed

executor/db.go

Lines changed: 20 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -270,6 +270,24 @@ func Migration0110(db types.DB) error {
270270
}
271271

272272
func Migration0111(db types.DB) error {
273+
childDB := db.WithPrefix([]byte(types.ChildName))
274+
merkleDB := db.WithPrefix([]byte(types.MerkleName))
275+
276+
err := merkleDB.Iterate(nil, nil, func(key, value []byte) (bool, error) {
277+
err := childDB.Set(key, value)
278+
if err != nil {
279+
return true, err
280+
}
281+
err = merkleDB.Delete(key)
282+
if err != nil {
283+
return true, err
284+
}
285+
return false, nil
286+
})
287+
if err != nil {
288+
return err
289+
}
290+
273291
DAHostName := "da_host"
274292
DACelestiaName := "da_celestia"
275293

@@ -314,8 +332,7 @@ func Migration0111(db types.DB) error {
314332
}
315333

316334
// change WithdrawalPrefix to WithdrawalSequencePrefix or WithdrawalAddressPrefix
317-
childDB := db.WithPrefix([]byte(types.ChildName))
318-
err := childDB.Iterate(executortypes.WithdrawalPrefix, nil, func(key, value []byte) (bool, error) {
335+
err = childDB.Iterate(dbtypes.AppendSplitter(executortypes.WithdrawalPrefix), nil, func(key, value []byte) (bool, error) {
319336
if len(key) == len(executortypes.WithdrawalPrefix)+1+8 {
320337
err := childDB.Set(append(executortypes.WithdrawalSequencePrefix, key[len(executortypes.WithdrawalPrefix):]...), value)
321338
if err != nil {
@@ -338,7 +355,7 @@ func Migration0111(db types.DB) error {
338355
return err
339356
}
340357

341-
return childDB.Iterate(merkletypes.WorkingTreePrefix, nil, func(key, value []byte) (bool, error) {
358+
return childDB.Iterate(dbtypes.AppendSplitter(merkletypes.WorkingTreePrefix), nil, func(key, value []byte) (bool, error) {
342359
version, err := merkletypes.ParseWorkingTreeKey(key)
343360
if err != nil {
344361
return true, errors.Wrap(err, "failed to parse working tree key")

0 commit comments

Comments
 (0)