From f8c35e5a090634d4d34b3cccb39dc1366bce53b3 Mon Sep 17 00:00:00 2001 From: Magic Cat Date: Mon, 22 Jan 2024 10:33:16 +0700 Subject: [PATCH] updated migrator --- database/legacy/msgexec/migrate.go | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/database/legacy/msgexec/migrate.go b/database/legacy/msgexec/migrate.go index 744489d0..ef66a3c1 100644 --- a/database/legacy/msgexec/migrate.go +++ b/database/legacy/msgexec/migrate.go @@ -26,8 +26,9 @@ func (db *Migrator) Migrate() error { log.Info().Msg("** migrating transactions **") log.Debug().Int("tx count", len(msgTypes)).Msg("processing total transactions") - for _, msgType := range msgTypes { + for i, msgType := range msgTypes { log.Debug().Str("tx hash", msgType.TransactionHash).Msg("getting transaction....") + fmt.Printf("\n processing %d/%d transaction \n", i, len(msgTypes)) tx, err := db.getMsgExecTransactionsFromDatabase(msgType.TransactionHash) if err != nil { @@ -38,7 +39,8 @@ func (db *Migrator) Migrate() error { var msgs sdk.ABCIMessageLogs err = json.Unmarshal([]byte(tx.Logs), &msgs) if err != nil { - return fmt.Errorf("error while unmarshaling tx logs: %s", err) + skipped++ + continue } var addresses []string @@ -48,9 +50,7 @@ func (db *Migrator) Migrate() error { for _, attribute := range event.Attributes { if strings.HasPrefix(attribute.Value, "quick1") || strings.HasPrefix(attribute.Value, "quickvaloper") { addresses = append(addresses, attribute.Value) - } - } } } @@ -67,7 +67,9 @@ func (db *Migrator) Migrate() error { msgType.Height), msgType.PartitionID) if err != nil { - return fmt.Errorf("error while storing updated message: %s", err) + fmt.Printf("error while storing updated message: %s", err) + skipped++ + continue } } else { skipped++ @@ -85,7 +87,7 @@ func (db *Migrator) Migrate() error { func (db *Migrator) getAllMsgExecStoredInDatabase() ([]dbtypes.MessageRow, error) { const msgType = "cosmos.authz.v1beta1.MsgExec" var rows []dbtypes.MessageRow - err := db.SQL.Select(&rows, `SELECT * FROM message WHERE type = $1`, msgType) + err := db.SQL.Select(&rows, `SELECT * FROM message WHERE type = $1 ORDER BY height ASC`, msgType) if err != nil { return nil, err }