mirror of
https://github.com/kaspanet/kaspad.git
synced 2025-09-15 05:50:10 +00:00
8a4ece1101
* [NOD-1223] Move all network stuff into a new network package. * [NOD-1223] Delete the unused package testutil. * [NOD-1223] Move infrastructure stuff into a new instrastructure package. * [NOD-1223] Move domain stuff into a new domain package.
62 lines
2.1 KiB
Go
62 lines
2.1 KiB
Go
// Copyright (c) 2016 The btcsuite developers
|
|
// Use of this source code is governed by an ISC
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package indexers
|
|
|
|
import (
|
|
"github.com/kaspanet/kaspad/domain/blockdag"
|
|
"github.com/kaspanet/kaspad/infrastructure/dbaccess"
|
|
"github.com/kaspanet/kaspad/util/daghash"
|
|
)
|
|
|
|
// Manager defines an index manager that manages multiple optional indexes and
|
|
// implements the blockdag.IndexManager interface so it can be seamlessly
|
|
// plugged into normal DAG processing.
|
|
type Manager struct {
|
|
enabledIndexes []Indexer
|
|
}
|
|
|
|
// Ensure the Manager type implements the blockdag.IndexManager interface.
|
|
var _ blockdag.IndexManager = (*Manager)(nil)
|
|
|
|
// Init initializes the enabled indexes.
|
|
// This is part of the blockdag.IndexManager interface.
|
|
func (m *Manager) Init(dag *blockdag.BlockDAG, databaseContext *dbaccess.DatabaseContext) error {
|
|
for _, indexer := range m.enabledIndexes {
|
|
if err := indexer.Init(dag, databaseContext); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// ConnectBlock must be invoked when a block is added to the DAG. It
|
|
// keeps track of the state of each index it is managing, performs some sanity
|
|
// checks, and invokes each indexer.
|
|
//
|
|
// This is part of the blockdag.IndexManager interface.
|
|
func (m *Manager) ConnectBlock(dbContext *dbaccess.TxContext, blockHash *daghash.Hash, txsAcceptanceData blockdag.MultiBlockTxsAcceptanceData) error {
|
|
|
|
// Call each of the currently active optional indexes with the block
|
|
// being connected so they can update accordingly.
|
|
for _, index := range m.enabledIndexes {
|
|
// Notify the indexer with the connected block so it can index it.
|
|
if err := index.ConnectBlock(dbContext, blockHash, txsAcceptanceData); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// NewManager returns a new index manager with the provided indexes enabled.
|
|
//
|
|
// The manager returned satisfies the blockdag.IndexManager interface and thus
|
|
// cleanly plugs into the normal blockdag processing path.
|
|
func NewManager(enabledIndexes []Indexer) *Manager {
|
|
return &Manager{
|
|
enabledIndexes: enabledIndexes,
|
|
}
|
|
}
|