ceremonyclient/consensus/models/proposal.go
Cassandra Heart c797d482f9
v2.1.0.5 (#457)
* wip: conversion of hotstuff from flow into Q-oriented model

* bulk of tests

* remaining non-integration tests

* add integration test, adjust log interface, small tweaks

* further adjustments, restore full pacemaker shape

* add component lifecycle management+supervisor

* further refinements

* resolve timeout hanging

* mostly finalized state for consensus

* bulk of engine swap out

* lifecycle-ify most types

* wiring nearly complete, missing needed hooks for proposals

* plugged in, vetting message validation paths

* global consensus, plugged in and verified

* app shard now wired in too

* do not decode empty keys.yml (#456)

* remove obsolete engine.maxFrames config parameter (#454)

* default to Info log level unless debug is enabled (#453)

* respect config's  "logging" section params, remove obsolete single-file logging (#452)

* Trivial code cleanup aiming to reduce Go compiler warnings (#451)

* simplify range traversal

* simplify channel read for single select case

* delete rand.Seed() deprecated in Go 1.20 and no-op as of Go 1.24

* simplify range traversal

* simplify channel read for single select case

* remove redundant type from array

* simplify range traversal

* simplify channel read for single select case

* RC slate

* finalize 2.1.0.5

* Update comments in StrictMonotonicCounter

Fix comment formatting and clarify description.

---------

Co-authored-by: Black Swan <3999712+blacks1ne@users.noreply.github.com>
2025-11-11 05:00:17 -06:00

46 lines
983 B
Go

package models
import (
"errors"
)
type Proposal[StateT Unique] struct {
State *State[StateT]
PreviousRankTimeoutCertificate TimeoutCertificate
}
func ProposalFrom[StateT Unique](
state *State[StateT],
prevTC TimeoutCertificate,
) *Proposal[StateT] {
return &Proposal[StateT]{
State: state,
PreviousRankTimeoutCertificate: prevTC,
}
}
type SignedProposal[StateT Unique, VoteT Unique] struct {
Proposal[StateT]
Vote *VoteT
}
func (p *SignedProposal[StateT, VoteT]) ProposerVote() (*VoteT, error) {
if p.Vote == nil {
return nil, errors.New("missing vote")
}
return p.Vote, nil
}
func SignedProposalFromState[StateT Unique, VoteT Unique](
p *Proposal[StateT],
v *VoteT,
) *SignedProposal[StateT, VoteT] {
return &SignedProposal[StateT, VoteT]{
Proposal: Proposal[StateT]{
State: p.State,
PreviousRankTimeoutCertificate: p.PreviousRankTimeoutCertificate,
},
Vote: v,
}
}