Skip to content

Commit 0760fcd

Browse files
committed
improve usage of context
Signed-off-by: Joshua Kim <20001595+joshua-kim@users.noreply.github.com>
1 parent 81c9487 commit 0760fcd

File tree

2 files changed

+6
-10
lines changed

2 files changed

+6
-10
lines changed

network/p2p/acp118/aggregator.go

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -71,15 +71,12 @@ type SignatureAggregator struct {
7171
// provided message. Validators are issued requests in the caller-specified
7272
// order.
7373
func (s *SignatureAggregator) AggregateSignatures(
74-
parentCtx context.Context,
74+
ctx context.Context,
7575
message *warp.UnsignedMessage,
7676
justification []byte,
7777
validators []Validator,
7878
stakeWeightThreshold uint64,
7979
) (*warp.Message, error) {
80-
ctx, cancel := context.WithCancel(parentCtx)
81-
defer cancel()
82-
8380
request := &sdk.SignatureRequest{
8481
Message: message.Bytes(),
8582
Justification: justification,

network/p2p/acp118/aggregator_test.go

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ func TestVerifier_Verify(t *testing.T) {
5454
wantVerifyErr error
5555
}{
5656
{
57-
name: "pass - gets signatures from sufficient stake",
57+
name: "gets signatures from sufficient stake",
5858
handler: NewHandler(&testVerifier{}, signer),
5959
ctx: context.Background(),
6060
validators: []Validator{
@@ -84,7 +84,7 @@ func TestVerifier_Verify(t *testing.T) {
8484
quorumDen: 1,
8585
},
8686
{
87-
name: "fail - gets signatures from insufficient stake",
87+
name: "gets signatures from insufficient stake",
8888
handler: NewHandler(&testVerifier{}, signer),
8989
ctx: context.Background(),
9090
validators: []Validator{
@@ -169,10 +169,9 @@ func TestVerifier_Verify(t *testing.T) {
169169
t.Run(tt.name, func(t *testing.T) {
170170
require := require.New(t)
171171

172-
ctx := context.Background()
173172
message, err := warp.NewUnsignedMessage(networkID, chainID, []byte("payload"))
174173
require.NoError(err)
175-
client := p2ptest.NewClient(t, ctx, tt.handler, ids.GenerateTestNodeID(), nodeID0)
174+
client := p2ptest.NewClient(t, context.Background(), tt.handler, ids.GenerateTestNodeID(), nodeID0)
176175
verifier := NewSignatureAggregator(logging.NoLog{}, client, 1)
177176

178177
signedMessage, err := verifier.AggregateSignatures(
@@ -184,12 +183,12 @@ func TestVerifier_Verify(t *testing.T) {
184183
)
185184
require.ErrorIs(err, tt.wantAggregateSignaturesErr)
186185

187-
if signedMessage == nil {
186+
if tt.wantAggregateSignaturesErr != nil {
188187
return
189188
}
190189

191190
err = signedMessage.Signature.Verify(
192-
ctx,
191+
context.Background(),
193192
&signedMessage.UnsignedMessage,
194193
networkID,
195194
tt.pChainState,

0 commit comments

Comments
 (0)