From 509ad08c6d808b1d6524ffab5ad67efb98a221bd Mon Sep 17 00:00:00 2001 From: Chris Gianelloni Date: Thu, 21 Nov 2024 14:27:01 -0500 Subject: [PATCH] chore: golines Signed-off-by: Chris Gianelloni --- database/database.go | 4 +++- database/types.go | 10 ++++++++-- state/chainsync.go | 23 ++++++++++++++++++----- state/eras/byron.go | 4 +++- state/eras/shelley.go | 4 +++- state/state.go | 17 ++++++++++++++--- 6 files changed, 49 insertions(+), 13 deletions(-) diff --git a/database/database.go b/database/database.go index c434be2e..c8e79699 100644 --- a/database/database.go +++ b/database/database.go @@ -194,7 +194,9 @@ func NewPersistent( // WAL journal mode, disable sync on write, increase cache size to 50MB (from 2MB) metadataConnOpts := "_pragma=journal_mode(WAL)&_pragma=sync(OFF)&_pragma=cache_size(-50000)" metadataDb, err := gorm.Open( - sqlite.Open(fmt.Sprintf("file:%s?%s", metadataDbPath, metadataConnOpts)), + sqlite.Open( + fmt.Sprintf("file:%s?%s", metadataDbPath, metadataConnOpts), + ), &gorm.Config{ Logger: gormlogger.Discard, }, diff --git a/database/types.go b/database/types.go index 05b541b9..879dbfde 100644 --- a/database/types.go +++ b/database/types.go @@ -38,7 +38,10 @@ func (r *Rat) Scan(val any) error { } v, ok := val.(string) if !ok { - return fmt.Errorf("value was not expected type, wanted string, got %T", val) + return fmt.Errorf( + "value was not expected type, wanted string, got %T", + val, + ) } if _, ok := r.SetString(v); !ok { return fmt.Errorf("failed to set big.Rat value from string: %s", v) @@ -55,7 +58,10 @@ func (u Uint64) Value() (driver.Value, error) { func (u *Uint64) Scan(val any) error { v, ok := val.(string) if !ok { - return fmt.Errorf("value was not expected type, wanted string, got %T", val) + return fmt.Errorf( + "value was not expected type, wanted string, got %T", + val, + ) } tmpUint, err := strconv.ParseUint(v, 10, 64) if err != nil { diff --git a/state/chainsync.go b/state/chainsync.go index 44548abe..a459d203 100644 --- a/state/chainsync.go +++ b/state/chainsync.go @@ -65,7 +65,10 @@ func (ls *LedgerState) handleEventBlockfetch(evt event.Event) { if err := ls.handleEventBlockfetchBatchDone(e); err != nil { // TODO: actually handle this error ls.config.Logger.Error( - fmt.Sprintf("ledger: failed to handle blockfetch batch done: %s", err), + fmt.Sprintf( + "ledger: failed to handle blockfetch batch done: %s", + err, + ), ) } } else if e.Block != nil { @@ -104,7 +107,10 @@ func (ls *LedgerState) handleEventChainsyncBlockHeader(e ChainsyncEvent) error { ls.chainsyncBlockfetchBusy = false ls.chainsyncBlockfetchWaiting = false ls.config.Logger.Warn( - fmt.Sprintf("blockfetch operation timed out after %s", blockfetchBusyTimeout), + fmt.Sprintf( + "blockfetch operation timed out after %s", + blockfetchBusyTimeout, + ), "component", "ledger", ) @@ -180,7 +186,10 @@ func (ls *LedgerState) processBlockEvents() error { return nil } -func (ls *LedgerState) processBlockEvent(txn *database.Txn, e BlockfetchEvent) error { +func (ls *LedgerState) processBlockEvent( + txn *database.Txn, + e BlockfetchEvent, +) error { tmpBlock := models.Block{ Slot: e.Point.Slot, Hash: e.Point.Hash, @@ -203,7 +212,9 @@ func (ls *LedgerState) processBlockEvent(txn *database.Txn, e BlockfetchEvent) e } } // Create initial epoch record - epochSlotLength, epochLength, err := ls.currentEra.EpochLengthFunc(ls.config.CardanoNodeConfig) + epochSlotLength, epochLength, err := ls.currentEra.EpochLengthFunc( + ls.config.CardanoNodeConfig, + ) if err != nil { return err } @@ -233,7 +244,9 @@ func (ls *LedgerState) processBlockEvent(txn *database.Txn, e BlockfetchEvent) e return err } // Create next epoch record - epochSlotLength, epochLength, err := ls.currentEra.EpochLengthFunc(ls.config.CardanoNodeConfig) + epochSlotLength, epochLength, err := ls.currentEra.EpochLengthFunc( + ls.config.CardanoNodeConfig, + ) if err != nil { return err } diff --git a/state/eras/byron.go b/state/eras/byron.go index 190415cc..77371c76 100644 --- a/state/eras/byron.go +++ b/state/eras/byron.go @@ -25,7 +25,9 @@ var ByronEraDesc = EraDesc{ EpochLengthFunc: EpochLengthByron, } -func EpochLengthByron(nodeConfig *cardano.CardanoNodeConfig) (uint, uint, error) { +func EpochLengthByron( + nodeConfig *cardano.CardanoNodeConfig, +) (uint, uint, error) { byronGenesis, err := nodeConfig.ByronGenesis() if err != nil { return 0, 0, err diff --git a/state/eras/shelley.go b/state/eras/shelley.go index 749104a6..ceba80fd 100644 --- a/state/eras/shelley.go +++ b/state/eras/shelley.go @@ -82,7 +82,9 @@ func HardForkShelley( return ret, nil } -func EpochLengthShelley(nodeConfig *cardano.CardanoNodeConfig) (uint, uint, error) { +func EpochLengthShelley( + nodeConfig *cardano.CardanoNodeConfig, +) (uint, uint, error) { shelleyGenesis, err := nodeConfig.ShelleyGenesis() if err != nil { return 0, 0, err diff --git a/state/state.go b/state/state.go index cb1d0e83..81b9384a 100644 --- a/state/state.go +++ b/state/state.go @@ -340,7 +340,12 @@ func (ls *LedgerState) rollback(point ocommon.Point) error { return nil } -func (ls *LedgerState) transitionToEra(txn *database.Txn, nextEraId uint, startEpoch uint, addedSlot uint64) error { +func (ls *LedgerState) transitionToEra( + txn *database.Txn, + nextEraId uint, + startEpoch uint, + addedSlot uint64, +) error { nextEra := eras.Eras[nextEraId] if nextEra.HardForkFunc != nil { // Perform hard fork @@ -377,7 +382,11 @@ func (ls *LedgerState) transitionToEra(txn *database.Txn, nextEraId uint, startE return nil } -func (ls *LedgerState) applyPParamUpdates(txn *database.Txn, currentEpoch uint, addedSlot uint64) error { +func (ls *LedgerState) applyPParamUpdates( + txn *database.Txn, + currentEpoch uint, + addedSlot uint64, +) error { // Check for pparam updates that apply at the end of the epoch var pparamUpdates []models.PParamUpdate result := txn.Metadata(). @@ -568,7 +577,9 @@ func (ls *LedgerState) loadTip() error { // Update metrics ls.metrics.blockNum.Set(float64(ls.currentTip.BlockNumber)) ls.metrics.slotNum.Set(float64(ls.currentTip.Point.Slot)) - ls.metrics.slotInEpoch.Set(float64(ls.currentTip.Point.Slot - ls.currentEpoch.StartSlot)) + ls.metrics.slotInEpoch.Set( + float64(ls.currentTip.Point.Slot - ls.currentEpoch.StartSlot), + ) return nil }