refactor: rename state package to ledger

blockfetch.go

@@ -19,9 +19,9 @@ import (
 	"time"
 
 	"github.com/blinklabs-io/dingo/event"
-	"github.com/blinklabs-io/dingo/state"
+	"github.com/blinklabs-io/dingo/ledger"
 	ouroboros "github.com/blinklabs-io/gouroboros"
-	"github.com/blinklabs-io/gouroboros/ledger"
+	gledger "github.com/blinklabs-io/gouroboros/ledger"
 	"github.com/blinklabs-io/gouroboros/protocol/blockfetch"
 	ocommon "github.com/blinklabs-io/gouroboros/protocol/common"
 )
@@ -106,14 +106,14 @@ func (n *Node) blockfetchClientRequestRange(
 func (n *Node) blockfetchClientBlock(
 	ctx blockfetch.CallbackContext,
 	blockType uint,
-	block ledger.Block,
+	block gledger.Block,
 ) error {
 	// Generate event
 	n.eventBus.Publish(
-		state.BlockfetchEventType,
+		ledger.BlockfetchEventType,
 		event.NewEvent(
-			state.BlockfetchEventType,
-			state.BlockfetchEvent{
+			ledger.BlockfetchEventType,
+			ledger.BlockfetchEvent{
 				Point: ocommon.NewPoint(block.SlotNumber(), block.Hash().Bytes()),
 				Type:  blockType,
 				Block: block,
@@ -128,10 +128,10 @@ func (n *Node) blockfetchClientBatchDone(
 ) error {
 	// Generate event
 	n.eventBus.Publish(
-		state.BlockfetchEventType,
+		ledger.BlockfetchEventType,
 		event.NewEvent(
-			state.BlockfetchEventType,
-			state.BlockfetchEvent{
+			ledger.BlockfetchEventType,
+			ledger.BlockfetchEvent{
 				ConnectionId: ctx.ConnectionId,
 				BatchDone:    true,
 			},

chainsync.go

@@ -18,9 +18,9 @@ import (
 	"fmt"
 
 	"github.com/blinklabs-io/dingo/event"
-	"github.com/blinklabs-io/dingo/state"
+	"github.com/blinklabs-io/dingo/ledger"
 	ouroboros "github.com/blinklabs-io/gouroboros"
-	"github.com/blinklabs-io/gouroboros/ledger"
+	gledger "github.com/blinklabs-io/gouroboros/ledger"
 	ochainsync "github.com/blinklabs-io/gouroboros/protocol/chainsync"
 	ocommon "github.com/blinklabs-io/gouroboros/protocol/common"
 )
@@ -180,10 +180,10 @@ func (n *Node) chainsyncClientRollBackward(
 ) error {
 	// Generate event
 	n.eventBus.Publish(
-		state.ChainsyncEventType,
+		ledger.ChainsyncEventType,
 		event.NewEvent(
-			state.ChainsyncEventType,
-			state.ChainsyncEvent{
+			ledger.ChainsyncEventType,
+			ledger.ChainsyncEvent{
 				Rollback: true,
 				Point:    point,
 				Tip:      tip,
@@ -200,14 +200,14 @@ func (n *Node) chainsyncClientRollForward(
 	tip ochainsync.Tip,
 ) error {
 	switch v := blockData.(type) {
-	case ledger.BlockHeader:
+	case gledger.BlockHeader:
 		blockSlot := v.SlotNumber()
 		blockHash := v.Hash().Bytes()
 		n.eventBus.Publish(
-			state.ChainsyncEventType,
+			ledger.ChainsyncEventType,
 			event.NewEvent(
-				state.ChainsyncEventType,
-				state.ChainsyncEvent{
+				ledger.ChainsyncEventType,
+				ledger.ChainsyncEvent{
 					ConnectionId: ctx.ConnectionId,
 					Point:        ocommon.NewPoint(blockSlot, blockHash),
 					Type:         blockType,

chainsync/chainsync.go

@@ -19,7 +19,7 @@ import (
 
 	"github.com/blinklabs-io/dingo/chain"
 	"github.com/blinklabs-io/dingo/event"
-	"github.com/blinklabs-io/dingo/state"
+	"github.com/blinklabs-io/dingo/ledger"
 	ouroboros "github.com/blinklabs-io/gouroboros"
 	"github.com/blinklabs-io/gouroboros/connection"
 	ocommon "github.com/blinklabs-io/gouroboros/protocol/common"
@@ -34,14 +34,14 @@ type ChainsyncClientState struct {
 type State struct {
 	sync.Mutex
 	eventBus     *event.EventBus
-	ledgerState  *state.LedgerState
+	ledgerState  *ledger.LedgerState
 	clients      map[ouroboros.ConnectionId]*ChainsyncClientState
 	clientConnId *ouroboros.ConnectionId // TODO: replace with handling of multiple chainsync clients (#385)
 }
 
 func NewState(
 	eventBus *event.EventBus,
-	ledgerState *state.LedgerState,
+	ledgerState *ledger.LedgerState,
 ) *State {
 	s := &State{
 		eventBus:    eventBus,

internal/node/load.go

@@ -24,8 +24,8 @@ import (
 	"github.com/blinklabs-io/dingo/database/immutable"
 	"github.com/blinklabs-io/dingo/event"
 	"github.com/blinklabs-io/dingo/internal/config"
-	"github.com/blinklabs-io/dingo/state"
-	"github.com/blinklabs-io/gouroboros/ledger"
+	"github.com/blinklabs-io/dingo/ledger"
+	gledger "github.com/blinklabs-io/gouroboros/ledger"
 )
 
 func Load(logger *slog.Logger, immutableDir string) error {
@@ -50,8 +50,8 @@ func Load(logger *slog.Logger, immutableDir string) error {
 	}
 	// Load state
 	eventBus := event.NewEventBus(nil)
-	ls, err := state.NewLedgerState(
-		state.LedgerStateConfig{
+	ls, err := ledger.NewLedgerState(
+		ledger.LedgerStateConfig{
 			DataDir:           cfg.DatabasePath,
 			Logger:            logger,
 			CardanoNodeConfig: nodeCfg,
@@ -80,7 +80,7 @@ func Load(logger *slog.Logger, immutableDir string) error {
 		return fmt.Errorf("failed to get immutable DB iterator: %w", err)
 	}
 	var blocksCopied int
-	blockBatch := make([]ledger.Block, 0, 500)
+	blockBatch := make([]gledger.Block, 0, 500)
 	for {
 		for {
 			next, err := iter.Next()
@@ -91,7 +91,7 @@ func Load(logger *slog.Logger, immutableDir string) error {
 			if next == nil {
 				break
 			}
-			tmpBlock, err := ledger.NewBlockFromCbor(next.Type, next.Cbor)
+			tmpBlock, err := gledger.NewBlockFromCbor(next.Type, next.Cbor)
 			if err != nil {
 				return err
 			}

state/certs.go → ledger/certs.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package state
+package ledger
 
 import (
 	"fmt"

state/chainsync.go → ledger/chainsync.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package state
+package ledger
 
 import (
 	"encoding/hex"
@@ -25,7 +25,7 @@ import (
 	"github.com/blinklabs-io/dingo/chain"
 	"github.com/blinklabs-io/dingo/database"
 	"github.com/blinklabs-io/dingo/event"
-	"github.com/blinklabs-io/dingo/state/eras"
+	"github.com/blinklabs-io/dingo/ledger/eras"
 	ouroboros "github.com/blinklabs-io/gouroboros"
 	"github.com/blinklabs-io/gouroboros/cbor"
 	"github.com/blinklabs-io/gouroboros/ledger"

state/error.go → ledger/error.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package state
+package ledger
 
 import "errors"
 

state/event.go → ledger/event.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package state
+package ledger
 
 import (
 	"github.com/blinklabs-io/dingo/event"

state/metrics.go → ledger/metrics.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package state
+package ledger
 
 import (
 	"github.com/prometheus/client_golang/prometheus"

state/queries.go → ledger/queries.go

@@ -12,15 +12,15 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package state
+package ledger
 
 import (
 	"errors"
 	"fmt"
 	"math/big"
 
 	"github.com/blinklabs-io/dingo/database"
-	"github.com/blinklabs-io/dingo/state/eras"
+	"github.com/blinklabs-io/dingo/ledger/eras"
 	"github.com/blinklabs-io/gouroboros/cbor"
 	"github.com/blinklabs-io/gouroboros/ledger"
 	olocalstatequery "github.com/blinklabs-io/gouroboros/protocol/localstatequery"

state/state.go → ledger/state.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package state
+package ledger
 
 import (
 	"encoding/hex"
@@ -28,7 +28,7 @@ import (
 	"github.com/blinklabs-io/dingo/config/cardano"
 	"github.com/blinklabs-io/dingo/database"
 	"github.com/blinklabs-io/dingo/event"
-	"github.com/blinklabs-io/dingo/state/eras"
+	"github.com/blinklabs-io/dingo/ledger/eras"
 	ouroboros "github.com/blinklabs-io/gouroboros"
 	"github.com/blinklabs-io/gouroboros/cbor"
 	"github.com/blinklabs-io/gouroboros/ledger"

state/view.go → ledger/view.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package state
+package ledger
 
 import (
 	"github.com/blinklabs-io/dingo/database"

mempool/mempool.go

@@ -23,9 +23,9 @@ import (
 
 	"github.com/blinklabs-io/dingo/chain"
 	"github.com/blinklabs-io/dingo/event"
-	"github.com/blinklabs-io/dingo/state"
+	"github.com/blinklabs-io/dingo/ledger"
 	ouroboros "github.com/blinklabs-io/gouroboros"
-	"github.com/blinklabs-io/gouroboros/ledger"
+	gledger "github.com/blinklabs-io/gouroboros/ledger"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promauto"
 )
@@ -56,7 +56,7 @@ type Mempool struct {
 	sync.RWMutex
 	logger         *slog.Logger
 	eventBus       *event.EventBus
-	ledgerState    *state.LedgerState
+	ledgerState    *ledger.LedgerState
 	consumers      map[ouroboros.ConnectionId]*MempoolConsumer
 	consumersMutex sync.Mutex
 	transactions   []*MempoolTransaction
@@ -71,7 +71,7 @@ func NewMempool(
 	logger *slog.Logger,
 	eventBus *event.EventBus,
 	promRegistry prometheus.Registerer,
-	ledgerState *state.LedgerState,
+	ledgerState *ledger.LedgerState,
 ) *Mempool {
 	m := &Mempool{
 		eventBus:    eventBus,
@@ -153,7 +153,7 @@ func (m *Mempool) processChainEvents() {
 		for i := len(m.transactions) - 1; i >= 0; i-- {
 			tx := m.transactions[i]
 			// Decode transaction
-			tmpTx, err := ledger.NewTransactionFromCbor(tx.Type, tx.Cbor)
+			tmpTx, err := gledger.NewTransactionFromCbor(tx.Type, tx.Cbor)
 			if err != nil {
 				m.removeTransactionByIndex(i)
 				m.logger.Error(
@@ -181,7 +181,7 @@ func (m *Mempool) processChainEvents() {
 
 func (m *Mempool) AddTransaction(txType uint, txBytes []byte) error {
 	// Decode transaction
-	tmpTx, err := ledger.NewTransactionFromCbor(txType, txBytes)
+	tmpTx, err := gledger.NewTransactionFromCbor(txType, txBytes)
 	if err != nil {
 		return err
 	}

node.go

@@ -23,9 +23,9 @@ import (
 	"github.com/blinklabs-io/dingo/chainsync"
 	"github.com/blinklabs-io/dingo/connmanager"
 	"github.com/blinklabs-io/dingo/event"
+	"github.com/blinklabs-io/dingo/ledger"
 	"github.com/blinklabs-io/dingo/mempool"
 	"github.com/blinklabs-io/dingo/peergov"
-	"github.com/blinklabs-io/dingo/state"
 	"github.com/blinklabs-io/dingo/utxorpc"
 	ouroboros "github.com/blinklabs-io/gouroboros"
 	oblockfetch "github.com/blinklabs-io/gouroboros/protocol/blockfetch"
@@ -44,7 +44,7 @@ type Node struct {
 	chainsyncState *chainsync.State
 	eventBus       *event.EventBus
 	mempool        *mempool.Mempool
-	ledgerState    *state.LedgerState
+	ledgerState    *ledger.LedgerState
 	utxorpc        *utxorpc.Utxorpc
 	shutdownFuncs  []func(context.Context) error
 }
@@ -72,8 +72,8 @@ func (n *Node) Run() error {
 		}
 	}
 	// Load state
-	state, err := state.NewLedgerState(
-		state.LedgerStateConfig{
+	state, err := ledger.NewLedgerState(
+		ledger.LedgerStateConfig{
 			DataDir:                    n.config.dataDir,
 			EventBus:                   n.eventBus,
 			Logger:                     n.config.logger,