Function NewChain

protocol/protocol.go:130–177

NewChain returns a new Chain using store as the underlying storage.

(ctx context.Context, initialBlock *bc.Block, store Store, heights <-chan uint64)

// NewChain returns a new Chain using store as the underlying storage.
func NewChain(ctx context.Context, initialBlock *bc.Block, store Store, heights <-chan uint64) (*Chain, error) {
	c := &Chain{
		InitialBlockHash:  initialBlock.Hash(),
		bb:                NewBlockBuilder(),
		store:             store,
		pendingSnapshots:  make(chan *state.Snapshot, 1),
		blocksPerSnapshot: defaultBlocksPerSnapshot,
	}

	c.state.cond.L = new(sync.Mutex)
	c.state.snapshot = state.Empty()

	var err error
	c.state.height, err = store.Height(ctx)
	if err != nil {
		return nil, errors.Wrap(err, "looking up blockchain height")
	}

	// Note that c.state.height may still be zero here.
	if heights != nil {
		go func() {
			for {
				select {
				case <-ctx.Done():
					return
				case h := <-heights:
					c.setHeight(h)
				}
			}
		}()
	}

	go func() {
		for {
			select {
			case <-ctx.Done():
				return
			case s := <-c.pendingSnapshots:
				err = store.SaveSnapshot(ctx, s)
				if err != nil {
					log.Error(ctx, err, "at", "saving snapshot")
				}
			}
		}
	}()

	return c, nil
}

// Height returns the current height of the blockchain.
func (c *Chain) Height() uint64 {