@@ -161,7 +161,7 @@ func (g *gForkStateMigration) Migrate(
161
161
162
162
lastMigratedUTXO , _ , err := next .getLastMigratedUTXO ()
163
163
if err != nil {
164
- return nil , fmt .Errorf ("failed to get last migrated UTXO : %w" , err )
164
+ return nil , fmt .Errorf ("failed to get last migrated utxo : %w" , err )
165
165
}
166
166
167
167
for utxo , err := range prevState .UTXOs (lastMigratedUTXO ) {
@@ -172,7 +172,7 @@ func (g *gForkStateMigration) Migrate(
172
172
next .AddUTXO (utxo )
173
173
utxoID := utxo .InputID ()
174
174
if err := prevUTXODB .Delete (utxoID [:]); err != nil {
175
- return nil , fmt .Errorf ("failed to delete utxo: %w" , err )
175
+ return nil , fmt .Errorf ("failed to delete migrated utxo: %w" , err )
176
176
}
177
177
178
178
if err := next .putLastMigratedUTXO (utxo .InputID ()); err != nil {
@@ -201,7 +201,7 @@ func (g *gForkStateMigration) Migrate(
201
201
}
202
202
203
203
if err := prevTXDB .Delete (itr .Key ()); err != nil {
204
- return nil , fmt .Errorf ("failed to migrate tx: %w" , err )
204
+ return nil , fmt .Errorf ("failed to delete migrated tx: %w" , err )
205
205
}
206
206
207
207
if err := g .commit (baseDB ); err != nil {
@@ -244,15 +244,17 @@ func (g *gForkStateMigration) Migrate(
244
244
}
245
245
246
246
if ok {
247
- // TODO skips
248
247
startingBlkHeightKey = database .PackUInt64 (lastMigratedBlkHeight )
249
248
}
250
249
251
- //TODO check that this is migrated
252
250
for itr := prevBlockIDDB .NewIteratorWithStart (startingBlkHeightKey ); itr .Next (); {
253
251
if err := next .state .BlockIDDB .Put (itr .Key (), itr .Value ()); err != nil {
254
252
return nil , fmt .Errorf ("failed to migrate block height: %w" , err )
255
253
}
254
+
255
+ if err := prevBlockIDDB .Delete (itr .Key ()); err != nil {
256
+ return nil , fmt .Errorf ("failed to delete migrated block height: %w" , err )
257
+ }
256
258
}
257
259
258
260
g .log .Debug ("migrating singletons" )
0 commit comments