diff --git a/node/config/version.go b/node/config/version.go index 103159d..12d90ef 100644 --- a/node/config/version.go +++ b/node/config/version.go @@ -6,15 +6,15 @@ import ( ) func GetMinimumVersionCutoff() time.Time { - return time.Date(2024, time.March, 10, 5, 30, 0, 0, time.UTC) + return time.Date(2024, time.March, 15, 4, 20, 0, 0, time.UTC) } func GetMinimumVersion() []byte { - return []byte{0x01, 0x04, 0x05} + return []byte{0x01, 0x04, 0x08} } func GetVersion() []byte { - return []byte{0x01, 0x04, 0x07} + return []byte{0x01, 0x04, 0x08} } func GetVersionString() string { diff --git a/node/consensus/ceremony/broadcast_messaging.go b/node/consensus/ceremony/broadcast_messaging.go index ce215c6..bebfa6d 100644 --- a/node/consensus/ceremony/broadcast_messaging.go +++ b/node/consensus/ceremony/broadcast_messaging.go @@ -353,11 +353,19 @@ func (e *CeremonyDataClockConsensusEngine) publishProof( "publishing frame and aggregations", zap.Uint64("frame_number", frame.FrameNumber), ) - if err := e.publishMessage(e.filter, frame); err != nil { - return errors.Wrap( - err, - "publish proof", - ) + head, err := e.dataTimeReel.Head() + if err != nil { + panic(err) + } + + peers, max, err := e.GetMostAheadPeer() + if err != nil || len(peers) == 0 || head.FrameNumber+3 > max { + if err := e.publishMessage(e.filter, frame); err != nil { + return errors.Wrap( + err, + "publish proof", + ) + } } return nil diff --git a/node/p2p/blossomsub.go b/node/p2p/blossomsub.go index f8dfa83..7705208 100644 --- a/node/p2p/blossomsub.go +++ b/node/p2p/blossomsub.go @@ -59,7 +59,7 @@ var BITMASK_ALL = []byte{ // While we iterate through these next phases, we're going to aggressively // enforce keeping updated. This will be achieved through announce strings // that will vary with each update -var ANNOUNCE = "quilibrium-1.4.5-sunset-mirage" +var ANNOUNCE = "quilibrium-1.4.8-sunset-ceasefire" func getPeerID(p2pConfig *config.P2PConfig) peer.ID { peerPrivKey, err := hex.DecodeString(p2pConfig.PeerPrivKey)