Skip to content

Commit

Permalink
Rename ledgerstate pkg to ledger and LedgerState interface to Ledger
Browse files Browse the repository at this point in the history
  • Loading branch information
@alexsporn
alexsporn committed Mar 8, 2023
1 parent 319fb5b commit 4d140e1
Show file tree
Hide file tree
Showing 19 changed files with 52 additions and 52 deletions.
2 changes: 1 addition & 1 deletion packages/core/snapshotcreator/snapshotcreator.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ import (
"github.com/iotaledger/goshimmer/packages/core/confirmation"
"github.com/iotaledger/goshimmer/packages/protocol/engine"
"github.com/iotaledger/goshimmer/packages/protocol/engine/clock/blocktime"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate/ondiskledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger/ondiskledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/notarization"
"github.com/iotaledger/goshimmer/packages/protocol/engine/sybilprotection/dpos"
"github.com/iotaledger/goshimmer/packages/protocol/engine/throughputquota/mana1"
Expand Down
2 changes: 1 addition & 1 deletion packages/protocol/congestioncontrol/icca/scheduler/testframework.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import (
"github.com/iotaledger/goshimmer/packages/protocol/engine/clock/blocktime"
"github.com/iotaledger/goshimmer/packages/protocol/engine/consensus/blockgadget"
"github.com/iotaledger/goshimmer/packages/protocol/engine/eviction"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate/ondiskledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger/ondiskledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/sybilprotection/dpos"
"github.com/iotaledger/goshimmer/packages/protocol/engine/tangle"
"github.com/iotaledger/goshimmer/packages/protocol/engine/tangle/blockdag"
Expand Down
6 changes: 3 additions & 3 deletions packages/protocol/engine/engine.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ import (
"github.com/iotaledger/goshimmer/packages/protocol/engine/consensus/blockgadget"
"github.com/iotaledger/goshimmer/packages/protocol/engine/eviction"
"github.com/iotaledger/goshimmer/packages/protocol/engine/filter"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger"
"github.com/iotaledger/goshimmer/packages/protocol/engine/notarization"
"github.com/iotaledger/goshimmer/packages/protocol/engine/sybilprotection"
"github.com/iotaledger/goshimmer/packages/protocol/engine/tangle"
Expand Down Expand Up @@ -43,7 +43,7 @@ type Engine struct {
SybilProtection sybilprotection.SybilProtection
ThroughputQuota throughputquota.ThroughputQuota
Ledger mempool.MemPool
LedgerState ledgerstate.LedgerState
LedgerState ledger.Ledger
Filter *filter.Filter
EvictionState *eviction.State
BlockRequester *eventticker.EventTicker[models.BlockID]
Expand Down Expand Up @@ -76,7 +76,7 @@ func New(
storageInstance *storage.Storage,
clockProvider module.Provider[*Engine, clock.Clock],
ledger module.Provider[*Engine, mempool.MemPool],
ledgerState module.Provider[*Engine, ledgerstate.LedgerState],
ledgerState module.Provider[*Engine, ledger.Ledger],
sybilProtection module.Provider[*Engine, sybilprotection.SybilProtection],
throughputQuota module.Provider[*Engine, throughputquota.ThroughputQuota],
opts ...options.Option[Engine],
Expand Down
6 changes: 3 additions & 3 deletions ...rotocol/engine/ledgerstate/ledgerstate.go → ...ges/protocol/engine/ledger/ledgerstate.go
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ledgerstate
package ledger

import (
"io"
Expand All @@ -7,8 +7,8 @@ import (
"github.com/iotaledger/hive.go/core/slot"
)

// LedgerState is an engine module that provides access to the persistent ledger state.
type LedgerState interface {
// Ledger is an engine module that provides access to the persistent ledger state.
type Ledger interface {
// UnspentOutputs returns the unspent outputs of the ledger state.
UnspentOutputs() UnspentOutputs

Expand Down
12 changes: 6 additions & 6 deletions ...gerstate/ondiskledgerstate/ledgerstate.go → ...e/ledger/ondiskledgerstate/ledgerstate.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import (

"github.com/iotaledger/goshimmer/packages/core/module"
"github.com/iotaledger/goshimmer/packages/protocol/engine"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger"
"github.com/iotaledger/goshimmer/packages/protocol/mempool"
"github.com/iotaledger/hive.go/core/slot"
"github.com/iotaledger/hive.go/lo"
Expand All @@ -25,8 +25,8 @@ type LedgerState struct {
module.Module
}

func NewProvider(opts ...options.Option[LedgerState]) module.Provider[*engine.Engine, ledgerstate.LedgerState] {
return module.Provide(func(e *engine.Engine) ledgerstate.LedgerState {
func NewProvider(opts ...options.Option[LedgerState]) module.Provider[*engine.Engine, ledger.Ledger] {
return module.Provide(func(e *engine.Engine) ledger.Ledger {
return options.Apply(&LedgerState{
engine: e,
stateDiffs: NewStateDiffs(e),
Expand All @@ -46,11 +46,11 @@ func NewProvider(opts ...options.Option[LedgerState]) module.Provider[*engine.En
})
}

func (l *LedgerState) UnspentOutputs() ledgerstate.UnspentOutputs {
func (l *LedgerState) UnspentOutputs() ledger.UnspentOutputs {
return l.unspentOutputs
}

func (l *LedgerState) StateDiffs() ledgerstate.StateDiffs {
func (l *LedgerState) StateDiffs() ledger.StateDiffs {
return l.stateDiffs
}

Expand Down Expand Up @@ -184,4 +184,4 @@ func (l *LedgerState) onTransactionInclusionUpdated(inclusionUpdatedEvent *mempo
}
}

var _ ledgerstate.LedgerState = new(LedgerState)
var _ ledger.Ledger = new(LedgerState)
4 changes: 2 additions & 2 deletions ...dgerstate/ondiskledgerstate/statediffs.go → ...ne/ledger/ondiskledgerstate/statediffs.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import (

"github.com/iotaledger/goshimmer/packages/core/stream"
"github.com/iotaledger/goshimmer/packages/protocol/engine"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger"
"github.com/iotaledger/goshimmer/packages/protocol/mempool"
"github.com/iotaledger/goshimmer/packages/protocol/mempool/utxo"
"github.com/iotaledger/goshimmer/packages/storage"
Expand Down Expand Up @@ -319,6 +319,6 @@ func (s *StateDiffs) moveTransactionToOtherSlot(txMeta *mempool.TransactionMetad
})
}

var _ ledgerstate.StateDiffs = new(StateDiffs)
var _ ledger.StateDiffs = new(StateDiffs)

// endregion ///////////////////////////////////////////////////////////////////////////////////////////////////////////
28 changes: 14 additions & 14 deletions ...state/ondiskledgerstate/unspentoutputs.go → ...edger/ondiskledgerstate/unspentoutputs.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ import (
"github.com/iotaledger/goshimmer/packages/core/stream"
"github.com/iotaledger/goshimmer/packages/core/traits"
"github.com/iotaledger/goshimmer/packages/protocol/engine"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger"
"github.com/iotaledger/goshimmer/packages/protocol/mempool"
"github.com/iotaledger/goshimmer/packages/protocol/mempool/utxo"
"github.com/iotaledger/hive.go/ads"
Expand All @@ -25,9 +25,9 @@ type UnspentOutputs struct {
ids *ads.Set[utxo.OutputID, *utxo.OutputID]

memPool mempool.MemPool
consumers map[ledgerstate.UnspentOutputsSubscriber]types.Empty
consumers map[ledger.UnspentOutputsSubscriber]types.Empty
consumersMutex sync.RWMutex
batchConsumers map[ledgerstate.UnspentOutputsSubscriber]types.Empty
batchConsumers map[ledger.UnspentOutputsSubscriber]types.Empty
batchCreatedOutputIDs utxo.OutputIDs
batchSpentOutputIDs utxo.OutputIDs

Expand All @@ -42,7 +42,7 @@ const (

func NewUnspentOutputs(e *engine.Engine) (unspentOutputs *UnspentOutputs) {
return options.Apply(&UnspentOutputs{
consumers: make(map[ledgerstate.UnspentOutputsSubscriber]types.Empty),
consumers: make(map[ledger.UnspentOutputsSubscriber]types.Empty),
}, nil, func(u *UnspentOutputs) {
e.HookConstructed(func() {
u.BatchCommittable = traits.NewBatchCommittable(e.Storage.UnspentOutputIDs(), PrefixUnspentOutputsLatestCommittedIndex)
Expand All @@ -52,14 +52,14 @@ func NewUnspentOutputs(e *engine.Engine) (unspentOutputs *UnspentOutputs) {
})
}

func (u *UnspentOutputs) Subscribe(consumer ledgerstate.UnspentOutputsSubscriber) {
func (u *UnspentOutputs) Subscribe(consumer ledger.UnspentOutputsSubscriber) {
u.consumersMutex.Lock()
defer u.consumersMutex.Unlock()

u.consumers[consumer] = types.Void
}

func (u *UnspentOutputs) Unsubscribe(consumer ledgerstate.UnspentOutputsSubscriber) {
func (u *UnspentOutputs) Unsubscribe(consumer ledger.UnspentOutputsSubscriber) {
u.consumersMutex.Lock()
defer u.consumersMutex.Unlock()

Expand All @@ -81,7 +81,7 @@ func (u *UnspentOutputs) Begin(newSlot slot.Index) (lastCommittedSlot slot.Index

u.batchCreatedOutputIDs = utxo.NewOutputIDs()
u.batchSpentOutputIDs = utxo.NewOutputIDs()
u.batchConsumers = make(map[ledgerstate.UnspentOutputsSubscriber]types.Empty)
u.batchConsumers = make(map[ledger.UnspentOutputsSubscriber]types.Empty)

if err = u.preparePendingConsumers(lastCommittedSlot, newSlot); err != nil {
return lastCommittedSlot, errors.Wrap(err, "failed to get pending state diff consumers")
Expand All @@ -108,7 +108,7 @@ func (u *UnspentOutputs) Commit() (ctx context.Context) {
}

func (u *UnspentOutputs) ApplyCreatedOutput(output *mempool.OutputWithMetadata) (err error) {
var targetConsumers map[ledgerstate.UnspentOutputsSubscriber]types.Empty
var targetConsumers map[ledger.UnspentOutputsSubscriber]types.Empty
if !u.BatchedStateTransitionStarted() {
u.ids.Add(output.Output().ID())

Expand All @@ -123,15 +123,15 @@ func (u *UnspentOutputs) ApplyCreatedOutput(output *mempool.OutputWithMetadata)
targetConsumers = u.batchConsumers
}

if err = u.notifyConsumers(targetConsumers, output, ledgerstate.UnspentOutputsSubscriber.ApplyCreatedOutput); err != nil {
if err = u.notifyConsumers(targetConsumers, output, ledger.UnspentOutputsSubscriber.ApplyCreatedOutput); err != nil {
return errors.Wrap(err, "failed to apply created output to consumers")
}

return
}

func (u *UnspentOutputs) ApplySpentOutput(output *mempool.OutputWithMetadata) (err error) {
var targetConsumers map[ledgerstate.UnspentOutputsSubscriber]types.Empty
var targetConsumers map[ledger.UnspentOutputsSubscriber]types.Empty
if !u.BatchedStateTransitionStarted() {
panic("cannot apply a spent output without a batched state transition")
} else {
Expand All @@ -142,7 +142,7 @@ func (u *UnspentOutputs) ApplySpentOutput(output *mempool.OutputWithMetadata) (e
targetConsumers = u.batchConsumers
}

if err = u.notifyConsumers(targetConsumers, output, ledgerstate.UnspentOutputsSubscriber.ApplySpentOutput); err != nil {
if err = u.notifyConsumers(targetConsumers, output, ledger.UnspentOutputsSubscriber.ApplySpentOutput); err != nil {
return errors.Wrap(err, "failed to apply spent output to consumers")
}

Expand Down Expand Up @@ -203,7 +203,7 @@ func (u *UnspentOutputs) Import(reader io.ReadSeeker, targetSlot slot.Index) (er
return
}

func (u *UnspentOutputs) Consumers() (consumers []ledgerstate.UnspentOutputsSubscriber) {
func (u *UnspentOutputs) Consumers() (consumers []ledger.UnspentOutputsSubscriber) {
u.consumersMutex.RLock()
defer u.consumersMutex.RUnlock()

Expand Down Expand Up @@ -246,7 +246,7 @@ func (u *UnspentOutputs) preparePendingConsumers(currentSlot, targetSlot slot.In
return
}

func (u *UnspentOutputs) notifyConsumers(consumer map[ledgerstate.UnspentOutputsSubscriber]types.Empty, output *mempool.OutputWithMetadata, callback func(self ledgerstate.UnspentOutputsSubscriber, output *mempool.OutputWithMetadata) (err error)) (err error) {
func (u *UnspentOutputs) notifyConsumers(consumer map[ledger.UnspentOutputsSubscriber]types.Empty, output *mempool.OutputWithMetadata, callback func(self ledger.UnspentOutputsSubscriber, output *mempool.OutputWithMetadata) (err error)) (err error) {
for consumer := range consumer {
if err = callback(consumer, output); err != nil {
return errors.Wrap(err, "failed to apply changes to consumer")
Expand Down Expand Up @@ -285,4 +285,4 @@ func (u *UnspentOutputs) importOutputIntoMemPoolStorage(output *mempool.OutputWi
u.memPool.Events().OutputCreated.Trigger(output.ID())
}

var _ ledgerstate.UnspentOutputs = new(UnspentOutputs)
var _ ledger.UnspentOutputs = new(UnspentOutputs)
2 changes: 1 addition & 1 deletion ...protocol/engine/ledgerstate/statediffs.go → ...ages/protocol/engine/ledger/statediffs.go
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ledgerstate
package ledger

import (
"github.com/iotaledger/goshimmer/packages/protocol/mempool"
Expand Down
2 changes: 1 addition & 1 deletion ...ocol/engine/ledgerstate/unspentoutputs.go → .../protocol/engine/ledger/unspentoutputs.go
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ledgerstate
package ledger

import (
"github.com/iotaledger/goshimmer/packages/core/module"
Expand Down
2 changes: 1 addition & 1 deletion ...e/ledgerstate/unspentoutputssubscriber.go → ...engine/ledger/unspentoutputssubscriber.go
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package ledgerstate
package ledger

import (
"context"
Expand Down
6 changes: 3 additions & 3 deletions packages/protocol/engine/notarization/manager.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import (

"github.com/iotaledger/goshimmer/packages/core/commitment"
"github.com/iotaledger/goshimmer/packages/core/module"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger"
"github.com/iotaledger/goshimmer/packages/protocol/engine/sybilprotection"
"github.com/iotaledger/goshimmer/packages/protocol/mempool"
"github.com/iotaledger/goshimmer/packages/protocol/models"
Expand All @@ -31,7 +31,7 @@ type Manager struct {
Attestations *Attestations

storage *storage.Storage
ledgerState ledgerstate.LedgerState
ledgerState ledger.Ledger
commitmentMutex sync.RWMutex

acceptanceTime time.Time
Expand All @@ -43,7 +43,7 @@ type Manager struct {
}

// NewManager creates a new notarization Manager.
func NewManager(storageInstance *storage.Storage, ledgerState ledgerstate.LedgerState, weights *sybilprotection.Weights, opts ...options.Option[Manager]) *Manager {
func NewManager(storageInstance *storage.Storage, ledgerState ledger.Ledger, weights *sybilprotection.Weights, opts ...options.Option[Manager]) *Manager {
return options.Apply(&Manager{
Events: NewEvents(),
SlotMutations: NewSlotMutations(weights, storageInstance.Settings.LatestCommitment().Index()),
Expand Down
4 changes: 2 additions & 2 deletions packages/protocol/engine/sybilprotection/dpos/sybilprotection.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import (
"github.com/iotaledger/goshimmer/packages/core/module"
"github.com/iotaledger/goshimmer/packages/core/traits"
"github.com/iotaledger/goshimmer/packages/protocol/engine"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger"
"github.com/iotaledger/goshimmer/packages/protocol/engine/notarization"
"github.com/iotaledger/goshimmer/packages/protocol/engine/sybilprotection"
"github.com/iotaledger/goshimmer/packages/protocol/engine/tangle/blockdag"
Expand Down Expand Up @@ -209,4 +209,4 @@ func (s *SybilProtection) markValidatorInactive(id identity.ID) {
s.validators.Delete(id)
}

var _ ledgerstate.UnspentOutputsSubscriber = &SybilProtection{}
var _ ledger.UnspentOutputsSubscriber = &SybilProtection{}
6 changes: 3 additions & 3 deletions packages/protocol/engine/testframework.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import (
"github.com/iotaledger/goshimmer/packages/core/module"
"github.com/iotaledger/goshimmer/packages/protocol/engine/clock"
"github.com/iotaledger/goshimmer/packages/protocol/engine/consensus/blockgadget"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger"
"github.com/iotaledger/goshimmer/packages/protocol/engine/sybilprotection"
"github.com/iotaledger/goshimmer/packages/protocol/engine/tangle"
"github.com/iotaledger/goshimmer/packages/protocol/engine/tangle/blockdag"
Expand Down Expand Up @@ -42,7 +42,7 @@ type TestFramework struct {
func NewTestEngine(t *testing.T, workers *workerpool.Group, storage *storage.Storage,
clock module.Provider[*Engine, clock.Clock],
ledger module.Provider[*Engine, mempool.MemPool],
ledgerState module.Provider[*Engine, ledgerstate.LedgerState],
ledgerState module.Provider[*Engine, ledger.Ledger],
sybilProtection module.Provider[*Engine, sybilprotection.SybilProtection],
throughputQuota module.Provider[*Engine, throughputquota.ThroughputQuota],
opts ...options.Option[Engine]) *Engine {
Expand Down Expand Up @@ -71,7 +71,7 @@ func NewTestFramework(test *testing.T, workers *workerpool.Group, engine *Engine
func NewDefaultTestFramework(t *testing.T, workers *workerpool.Group,
clock module.Provider[*Engine, clock.Clock],
ledger module.Provider[*Engine, mempool.MemPool],
ledgerState module.Provider[*Engine, ledgerstate.LedgerState],
ledgerState module.Provider[*Engine, ledger.Ledger],
sybilProtection module.Provider[*Engine, sybilprotection.SybilProtection],
throughputQuota module.Provider[*Engine, throughputquota.ThroughputQuota],
optsEngine ...options.Option[Engine]) *TestFramework {
Expand Down
6 changes: 3 additions & 3 deletions packages/protocol/enginemanager/enginemanager.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ import (
"github.com/iotaledger/goshimmer/packages/core/module"
"github.com/iotaledger/goshimmer/packages/protocol/engine"
"github.com/iotaledger/goshimmer/packages/protocol/engine/clock"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger"
"github.com/iotaledger/goshimmer/packages/protocol/engine/sybilprotection"
"github.com/iotaledger/goshimmer/packages/protocol/engine/throughputquota"
"github.com/iotaledger/goshimmer/packages/protocol/mempool"
Expand Down Expand Up @@ -42,7 +42,7 @@ type EngineManager struct {
engineOptions []options.Option[engine.Engine]
clockProvider module.Provider[*engine.Engine, clock.Clock]
ledgerProvider module.Provider[*engine.Engine, mempool.MemPool]
ledgerStateProvider module.Provider[*engine.Engine, ledgerstate.LedgerState]
ledgerStateProvider module.Provider[*engine.Engine, ledger.Ledger]
sybilProtectionProvider module.Provider[*engine.Engine, sybilprotection.SybilProtection]
throughputQuotaProvider module.Provider[*engine.Engine, throughputquota.ThroughputQuota]

Expand All @@ -57,7 +57,7 @@ func New(
engineOptions []options.Option[engine.Engine],
clockProvider module.Provider[*engine.Engine, clock.Clock],
ledgerProvider module.Provider[*engine.Engine, mempool.MemPool],
ledgerStateProvider module.Provider[*engine.Engine, ledgerstate.LedgerState],
ledgerStateProvider module.Provider[*engine.Engine, ledger.Ledger],
sybilProtectionProvider module.Provider[*engine.Engine, sybilprotection.SybilProtection],
throughputQuotaProvider module.Provider[*engine.Engine, throughputquota.ThroughputQuota]) *EngineManager {
return &EngineManager{
Expand Down
2 changes: 1 addition & 1 deletion packages/protocol/enginemanager/testframework_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ import (
"github.com/iotaledger/goshimmer/packages/protocol"
"github.com/iotaledger/goshimmer/packages/protocol/engine"
"github.com/iotaledger/goshimmer/packages/protocol/engine/clock/blocktime"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate/ondiskledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger/ondiskledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/sybilprotection/dpos"
"github.com/iotaledger/goshimmer/packages/protocol/engine/throughputquota/mana1"
"github.com/iotaledger/goshimmer/packages/protocol/enginemanager"
Expand Down
8 changes: 4 additions & 4 deletions packages/protocol/protocol.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,8 @@ import (
"github.com/iotaledger/goshimmer/packages/protocol/engine/clock"
"github.com/iotaledger/goshimmer/packages/protocol/engine/clock/blocktime"
"github.com/iotaledger/goshimmer/packages/protocol/engine/consensus/blockgadget"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate/ondiskledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger/ondiskledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/notarization"
"github.com/iotaledger/goshimmer/packages/protocol/engine/sybilprotection"
"github.com/iotaledger/goshimmer/packages/protocol/engine/sybilprotection/dpos"
Expand Down Expand Up @@ -69,7 +69,7 @@ type Protocol struct {

optsClockProvider module.Provider[*engine.Engine, clock.Clock]
optsLedgerProvider module.Provider[*engine.Engine, mempool.MemPool]
optsLedgerStateProvider module.Provider[*engine.Engine, ledgerstate.LedgerState]
optsLedgerStateProvider module.Provider[*engine.Engine, ledger.Ledger]
optsSybilProtectionProvider module.Provider[*engine.Engine, sybilprotection.SybilProtection]
optsThroughputQuotaProvider module.Provider[*engine.Engine, throughputquota.ThroughputQuota]
}
Expand Down Expand Up @@ -609,7 +609,7 @@ func WithLedgerProvider(optsLedgerProvider module.Provider[*engine.Engine, mempo
}
}

func WithLedgerStateProvider(optsLedgerStateProvider module.Provider[*engine.Engine, ledgerstate.LedgerState]) options.Option[Protocol] {
func WithLedgerStateProvider(optsLedgerStateProvider module.Provider[*engine.Engine, ledger.Ledger]) options.Option[Protocol] {
return func(n *Protocol) {
n.optsLedgerStateProvider = optsLedgerStateProvider
}
Expand Down
2 changes: 1 addition & 1 deletion packages/protocol/protocol_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ import (
"github.com/iotaledger/goshimmer/packages/protocol"
"github.com/iotaledger/goshimmer/packages/protocol/engine"
"github.com/iotaledger/goshimmer/packages/protocol/engine/clock/blocktime"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledgerstate/ondiskledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/ledger/ondiskledgerstate"
"github.com/iotaledger/goshimmer/packages/protocol/engine/notarization"
"github.com/iotaledger/goshimmer/packages/protocol/engine/sybilprotection/dpos"
"github.com/iotaledger/goshimmer/packages/protocol/engine/tangle"
Expand Down
Loading

0 comments on commit 4d140e1

Please sign in to comment.