mirror of
https://github.com/luxfi/tss.git
synced 2026-10-30 15:14:51 +00:00
87 lines
2.3 KiB
Go
87 lines
2.3 KiB
Go
// Copyright © 2019 Binance
|
|
//
|
|
// This file is part of Binance. The full Binance copyright notice, including
|
|
// terms governing use, modification, and redistribution, is contained in the
|
|
// file LICENSE at the root of the source code distribution tree.
|
|
|
|
package resharing
|
|
|
|
import (
|
|
"errors"
|
|
"math/big"
|
|
|
|
"github.com/luxfi/tss/v2/common"
|
|
"github.com/luxfi/tss/v2/tss"
|
|
)
|
|
|
|
func (round *round5) Start() *tss.Error {
|
|
if round.started {
|
|
return round.WrapError(errors.New("round already started"))
|
|
}
|
|
round.number = 5
|
|
round.started = true
|
|
|
|
round.allOldOK()
|
|
round.allNewOK()
|
|
|
|
Pi := round.PartyID()
|
|
i := Pi.Index
|
|
|
|
if round.IsNewCommittee() {
|
|
// 21.
|
|
// for this P: SAVE data
|
|
ContextI := append(round.temp.ssid, big.NewInt(int64(i)).Bytes()...)
|
|
round.save.BigXj = round.temp.newBigXjs
|
|
round.save.ShareID = round.PartyID().KeyInt()
|
|
round.save.Xi = round.temp.newXi
|
|
round.save.Ks = round.temp.newKs
|
|
|
|
// misc: build list of paillier public keys to save
|
|
for j, msg := range round.temp.dgRound2Message1s {
|
|
if j == i {
|
|
continue
|
|
}
|
|
r2msg1 := msg.Content().(*DGRound2Message1)
|
|
round.save.PaillierPKs[j] = r2msg1.UnmarshalPaillierPK()
|
|
}
|
|
for j, msg := range round.temp.dgRound4Message1s {
|
|
if j == i {
|
|
continue
|
|
}
|
|
r4msg1 := msg.Content().(*DGRound4Message1)
|
|
proof, err := r4msg1.UnmarshalFacProof()
|
|
if err != nil && round.Parameters.NoProofFac() {
|
|
common.Logger.Warningf("facProof verify failed for party %s", msg.GetFrom(), err)
|
|
} else {
|
|
if err != nil {
|
|
common.Logger.Warningf("facProof verify failed for party %s", msg.GetFrom(), err)
|
|
return round.WrapError(err, round.NewParties().IDs()[j])
|
|
}
|
|
if ok := proof.Verify(ContextI, round.EC(), round.save.PaillierPKs[j].N, round.save.NTildei,
|
|
round.save.H1i, round.save.H2i); !ok {
|
|
common.Logger.Warningf("facProof verify failed for party %s", msg.GetFrom(), err)
|
|
return round.WrapError(err, round.NewParties().IDs()[j])
|
|
}
|
|
}
|
|
|
|
}
|
|
} else if round.IsOldCommittee() {
|
|
round.input.Xi.SetInt64(0)
|
|
}
|
|
|
|
round.end <- round.save
|
|
return nil
|
|
}
|
|
|
|
func (round *round5) CanAccept(msg tss.ParsedMessage) bool {
|
|
return false
|
|
}
|
|
|
|
func (round *round5) Update() (bool, *tss.Error) {
|
|
return false, nil
|
|
}
|
|
|
|
func (round *round5) NextRound() tss.Round {
|
|
return nil // both committees are finished!
|
|
}
|