11package clientidentity_test
22
33import (
4- "context"
54 "testing"
65 "time"
76
@@ -38,7 +37,7 @@ func TestIdentity(t *testing.T) {
3837 }, clientidentity .DefaultExpiration )
3938 require .NoError (t , err )
4039
41- ctx := metadata .NewIncomingContext (context . Background (), metadata .Pairs (authutil .ClientIdentityHeaderName , headerValue ))
40+ ctx := metadata .NewIncomingContext (t . Context (), metadata .Pairs (authutil .ClientIdentityHeaderName , headerValue ))
4241 ctx , err = sis .ValidateIncomingIdentity (ctx )
4342 require .NoError (t , err )
4443
@@ -63,7 +62,7 @@ func TestDuplicateHeaders(t *testing.T) {
6362 headers := metadata .Pairs (
6463 authutil .ClientIdentityHeaderName , headerValue ,
6564 authutil .ClientIdentityHeaderName , headerValue )
66- ctx := metadata .NewIncomingContext (context . Background (), headers )
65+ ctx := metadata .NewIncomingContext (t . Context (), headers )
6766 ctx , err = sis .ValidateIncomingIdentity (ctx )
6867 require .NoError (t , err )
6968
@@ -80,7 +79,7 @@ func TestMultipleHeaders(t *testing.T) {
8079 headers := metadata .Pairs (
8180 authutil .ClientIdentityHeaderName , "value1" ,
8281 authutil .ClientIdentityHeaderName , "value2" )
83- ctx := metadata .NewIncomingContext (context . Background (), headers )
82+ ctx := metadata .NewIncomingContext (t . Context (), headers )
8483 _ , err := sis .ValidateIncomingIdentity (ctx )
8584 require .Error (t , err )
8685 require .True (t , status .IsPermissionDeniedError (err ))
@@ -106,7 +105,7 @@ func TestStaleIdentity(t *testing.T) {
106105
107106 clock .Advance (clientidentity .DefaultExpiration + time .Second )
108107
109- ctx := metadata .NewIncomingContext (context . Background (), metadata .Pairs (authutil .ClientIdentityHeaderName , headerValue ))
108+ ctx := metadata .NewIncomingContext (t . Context (), metadata .Pairs (authutil .ClientIdentityHeaderName , headerValue ))
110109 _ , err = sis .ValidateIncomingIdentity (ctx )
111110 require .Error (t , err )
112111}
@@ -127,11 +126,11 @@ func TestRequired(t *testing.T) {
127126
128127 headers := metadata .Pairs (
129128 authutil .ClientIdentityHeaderName , headerValue )
130- ctx := metadata .NewIncomingContext (context . Background (), headers )
129+ ctx := metadata .NewIncomingContext (t . Context (), headers )
131130 _ , err = sis .ValidateIncomingIdentity (ctx )
132131 require .NoError (t , err )
133132
134- ctx = metadata .NewIncomingContext (context . Background (), nil )
133+ ctx = metadata .NewIncomingContext (t . Context (), nil )
135134 _ , err = sis .ValidateIncomingIdentity (ctx )
136135 require .Error (t , err )
137136}
@@ -146,7 +145,7 @@ func TestClearIdentity(t *testing.T) {
146145 }, clientidentity .DefaultExpiration )
147146 require .NoError (t , err )
148147
149- ctx := metadata .NewIncomingContext (context . Background (), metadata .Pairs (authutil .ClientIdentityHeaderName , headerValue ))
148+ ctx := metadata .NewIncomingContext (t . Context (), metadata .Pairs (authutil .ClientIdentityHeaderName , headerValue ))
150149 ctx , err = sis .ValidateIncomingIdentity (ctx )
151150 require .NoError (t , err )
152151 _ , err = sis .IdentityFromContext (ctx )
@@ -170,7 +169,7 @@ func TestOverridePropagated_DefaultTrue(t *testing.T) {
170169 }, clientidentity .DefaultExpiration )
171170 require .NoError (t , err )
172171
173- ctx := metadata .NewOutgoingContext (context . Background (), metadata .Pairs (authutil .ClientIdentityHeaderName , existingHeader ))
172+ ctx := metadata .NewOutgoingContext (t . Context (), metadata .Pairs (authutil .ClientIdentityHeaderName , existingHeader ))
174173 ctx , err = sis .AddIdentityToContext (ctx )
175174 require .NoError (t , err )
176175
@@ -194,7 +193,7 @@ func TestOverridePropagated_False_PreservesExisting(t *testing.T) {
194193 }, clientidentity .DefaultExpiration )
195194 require .NoError (t , err )
196195
197- ctx := metadata .NewOutgoingContext (context . Background (), metadata .Pairs (authutil .ClientIdentityHeaderName , existingHeader ))
196+ ctx := metadata .NewOutgoingContext (t . Context (), metadata .Pairs (authutil .ClientIdentityHeaderName , existingHeader ))
198197 ctx , err = sis .AddIdentityToContext (ctx )
199198 require .NoError (t , err )
200199
@@ -214,7 +213,7 @@ func TestOverridePropagated_False_AddsWhenMissing(t *testing.T) {
214213 flags .Set (t , "app.client_identity.origin" , "local-origin" )
215214
216215 // No existing identity header in the outgoing context.
217- ctx := context . Background ()
216+ ctx := t . Context ()
218217 ctx , err := sis .AddIdentityToContext (ctx )
219218 require .NoError (t , err )
220219
@@ -228,7 +227,7 @@ func TestOverridePropagated_False_AddsWhenMissing(t *testing.T) {
228227func BenchmarkAddIdentityToContext (b * testing.B ) {
229228 sis := newService (b , clockwork .NewRealClock ())
230229
231- ctx := context . Background ()
230+ ctx := b . Context ()
232231 b .ReportAllocs ()
233232 b .ResetTimer ()
234233 b .RunParallel (func (pb * testing.PB ) {
0 commit comments