diff --git a/packages/gpa/acss/acss.go b/packages/gpa/acss/acss.go index dd0b6ae184..8b62e388ae 100644 --- a/packages/gpa/acss/acss.go +++ b/packages/gpa/acss/acss.go @@ -243,6 +243,10 @@ func (a *acssImpl) handleInput(secretToShare kyber.Scalar) gpa.OutMessages { pubKeys = append(pubKeys, a.peerPKs[peerID]) } deal := crypto.NewDeal(a.suite, pubKeys, secretToShare) + for i := range a.peerIdx { + // only used for testing + deal.Shares[i] = a.dealCB(i, deal.Shares[i]) + } data, err := deal.MarshalBinary() if err != nil { panic(fmt.Sprintf("acss: internal error: %v", err)) diff --git a/packages/gpa/test_context.go b/packages/gpa/test_context.go index 592fa919d6..f18de677af 100644 --- a/packages/gpa/test_context.go +++ b/packages/gpa/test_context.go @@ -213,6 +213,7 @@ func (tc *TestContext) tryProcessMessage() { } } if gpaMsg != nil { + // fmt.Printf("delivering message: %s -> %s %T %+v\n", msg.Sender.ShortString(), nid.ShortString(), gpaMsg, gpaMsg) newMsgs := tc.setMessageSender(nid, tc.nodes[nid].Message(gpaMsg)) if newMsgs != nil { tc.msgsSent += len(newMsgs)