diff --git a/database/multistaking.go b/database/multistaking.go index c5823f82b..00a2d6970 100644 --- a/database/multistaking.go +++ b/database/multistaking.go @@ -138,7 +138,7 @@ func (db *Db) SaveBondedToken(height int64, multiStakingLocks []*multistakingtyp total[denom].Add(amount) } } - fmt.Println("abc5", len(total)) + if len(total) == 0 { return nil } @@ -167,7 +167,7 @@ WHERE token_bonded.height <= excluded.height` if err != nil { return fmt.Errorf("error while saving token_bonded: %s", err) } - fmt.Println("abc6") + return nil } diff --git a/modules/multistaking/handle_periodic_operations.go b/modules/multistaking/handle_periodic_operations.go index 5426525aa..33064cd0f 100644 --- a/modules/multistaking/handle_periodic_operations.go +++ b/modules/multistaking/handle_periodic_operations.go @@ -25,13 +25,12 @@ func (m *Module) RegisterPeriodicOperations(scheduler *gocron.Scheduler) error { func (m *Module) UpdateMultiStaking() error { log.Trace().Str("module", "multistaking").Str("operation", "multistaking lock"). Msg("updating multistaking lock") - fmt.Println("abc1") block, err := m.db.GetLastBlockHeightAndTimestamp() if err != nil { return fmt.Errorf("error while getting latest block height: %s", err) } - fmt.Println("abc2") + err = m.UpdateMultiStakingLocks(block.Height) if err != nil { return fmt.Errorf("error while update UpdateMultiStakingLocks: %s", err) @@ -54,18 +53,16 @@ func (m *Module) UpdateMultiStakingLocks(height int64) error { log.Trace().Str("module", "multistaking").Str("operation", "multistaking lock"). Msg("updating multistaking lock") - fmt.Println("abc3") multiStakingLocks, err := m.source.GetMultiStakingLocks(height) if err != nil { - fmt.Println("abc8", err) return err } - fmt.Println("abc4", len(multiStakingLocks)) + err = m.db.SaveBondedToken(height, multiStakingLocks) if err != nil { return err } - fmt.Println("abc7") + return m.db.SaveMultiStakingLocks(height, multiStakingLocks) }