Files
proto/p/block/proposal_block.go
zeekay f480e48e39 run on the native fleet
Adds .hanzo/workflows/cicd.yml calling the canonical pipeline and drops the
GitHub-hosted workflows it replaces. Lands here because this is where the repo
is written — git.hanzo.ai is upstream and github.com is its push mirror, so the
same change made on github.com never reaches the runner fleet.
2026-08-20 20:20:25 -07:00

61 lines
1.5 KiB
Go

// Copyright (C) 2019-2026, Lux Industries Inc. All rights reserved.
// See the file LICENSE for licensing terms.
package block
import (
"time"
"github.com/luxfi/ids"
"github.com/luxfi/proto/p/txs"
)
var _ Block = (*ProposalBlock)(nil)
// ProposalBlock is the canonical P-Chain proposal block. It carries a
// per-block timestamp, a tail of decision txs (stored as the u32 length list +
// blob), and a single proposal Tx that commits atomically with them.
type ProposalBlock struct {
commonZapBlock
}
// Tx returns the single proposal tx.
func (b *ProposalBlock) Tx() *txs.Tx {
tx, _ := readProposalTx(b.msg.Root())
return tx
}
// Txs returns the decision txs followed by the proposal Tx (last), matching
// the canonical block ordering.
func (b *ProposalBlock) Txs() []*txs.Tx {
decision, _ := readTxList(b.msg.Root(), offBlkTxLengths, offBlkTxBlob)
proposal := b.Tx()
if proposal == nil {
return decision
}
out := make([]*txs.Tx, len(decision)+1)
copy(out, decision)
out[len(decision)] = proposal
return out
}
func (b *ProposalBlock) Visit(v Visitor) error { return v.ProposalBlock(b) }
func NewProposalBlock(
timestamp time.Time,
parentID ids.ID,
height uint64,
proposalTx *txs.Tx,
decisionTxs []*txs.Tx,
) (*ProposalBlock, error) {
bytes, err := buildBlock(blkProposal, parentID, height, uint64(timestamp.Unix()), decisionTxs, proposalTx)
if err != nil {
return nil, err
}
blk := &ProposalBlock{}
if err := blk.setID(bytes); err != nil {
return nil, err
}
return blk, nil
}