@@ -10,7 +10,10 @@ import (
10
10
"github.com/rs/zerolog/log"
11
11
"golang.org/x/sync/errgroup"
12
12
13
+ "github.com/onflow/flow-go-sdk/crypto"
14
+
13
15
migrators "github.com/onflow/flow-go/cmd/util/ledger/migrations"
16
+ "github.com/onflow/flow-go/cmd/util/ledger/reporters"
14
17
"github.com/onflow/flow-go/cmd/util/ledger/util"
15
18
"github.com/onflow/flow-go/ledger"
16
19
"github.com/onflow/flow-go/ledger/common/hash"
@@ -356,3 +359,37 @@ func createTrieFromPayloads(logger zerolog.Logger, payloads []*ledger.Payload) (
356
359
357
360
return newTrie , nil
358
361
}
362
+
363
+ func addMigrationMainnetKeysMigration (
364
+ log zerolog.Logger ,
365
+ outputDir string ,
366
+ workerCount int ,
367
+ chainID flow.ChainID ,
368
+ ) []migrators.NamedMigration {
369
+
370
+ log .Info ().Msg ("initializing add-migrationmainnet-keys migrations ..." )
371
+
372
+ rwf := reporters .NewReportFileWriterFactory (outputDir , log )
373
+
374
+ key , err := crypto .DecodePublicKeyHex (crypto .ECDSA_P256 , "711d4cd9930d695ef5c79b668d321f92ba00ed8280fded52c0fa2b15501411d026fe6fb4be3ec894facd3a00f04e32e2db5f5696d3b2b3419e4fba89fb95dca8" )
375
+ if err != nil {
376
+ panic ("failed to decode key" )
377
+ }
378
+
379
+ namedMigrations := []migrators.NamedMigration {
380
+ {
381
+ Name : "add-migrationmainnet-keys" ,
382
+ Migrate : migrators .NewAccountBasedMigration (
383
+ log ,
384
+ workerCount ,
385
+ []migrators.AccountBasedMigration {
386
+ migrators .NewAddKeyMigration (chainID , key , rwf ),
387
+ },
388
+ ),
389
+ },
390
+ }
391
+
392
+ log .Info ().Msg ("initialized migrations" )
393
+
394
+ return namedMigrations
395
+ }
0 commit comments