Skip to content

Commit 4f33ca8

Browse files
committed
fix: Ensure t.Cleanup is not aborted by require
1 parent a1576b2 commit 4f33ca8

File tree

3 files changed

+16
-11
lines changed

3 files changed

+16
-11
lines changed

cli/configssh_test.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -134,9 +134,6 @@ func TestConfigSSH(t *testing.T) {
134134
go io.Copy(ssh, conn)
135135
}
136136
}()
137-
t.Cleanup(func() {
138-
_ = listener.Close()
139-
})
140137

141138
sshConfigFile, _ := sshConfigFileNames(t)
142139

coderd/coderd_test.go

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,8 @@ func TestAuthorizeAllEndpoints(t *testing.T) {
9494
t.Cleanup(func() { close(tickerCh) })
9595

9696
ctx, cancelFunc := context.WithCancel(context.Background())
97+
t.Cleanup(cancelFunc)
98+
9799
lifecycleExecutor := executor.New(
98100
ctx,
99101
db,
@@ -109,9 +111,13 @@ func TestAuthorizeAllEndpoints(t *testing.T) {
109111
srv.Start()
110112
serverURL, err := url.Parse(srv.URL)
111113
require.NoError(t, err)
114+
t.Cleanup(srv.Close)
112115

113116
turnServer, err := turnconn.New(nil)
114117
require.NoError(t, err)
118+
t.Cleanup(func() {
119+
_ = turnServer.Close()
120+
})
115121

116122
validator, err := idtoken.NewValidator(ctx, option.WithoutAuthentication())
117123
require.NoError(t, err)
@@ -138,9 +144,6 @@ func TestAuthorizeAllEndpoints(t *testing.T) {
138144

139145
_ = coderdtest.NewProvisionerDaemon(t, coderAPI)
140146
t.Cleanup(func() {
141-
cancelFunc()
142-
_ = turnServer.Close()
143-
srv.Close()
144147
_ = coderAPI.Close()
145148
})
146149

coderd/coderdtest/coderdtest.go

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -143,6 +143,8 @@ func newWithCloser(t *testing.T, options *Options) (*codersdk.Client, io.Closer)
143143
}
144144

145145
ctx, cancelFunc := context.WithCancel(context.Background())
146+
t.Cleanup(cancelFunc)
147+
146148
lifecycleExecutor := executor.New(
147149
ctx,
148150
db,
@@ -156,6 +158,8 @@ func newWithCloser(t *testing.T, options *Options) (*codersdk.Client, io.Closer)
156158
return ctx
157159
}
158160
srv.Start()
161+
t.Cleanup(srv.Close)
162+
159163
serverURL, err := url.Parse(srv.URL)
160164
require.NoError(t, err)
161165

@@ -166,6 +170,9 @@ func newWithCloser(t *testing.T, options *Options) (*codersdk.Client, io.Closer)
166170

167171
turnServer, err := turnconn.New(nil)
168172
require.NoError(t, err)
173+
t.Cleanup(func() {
174+
_ = turnServer.Close()
175+
})
169176

170177
// We set the handler after server creation for the access URL.
171178
coderAPI := coderd.New(&coderd.Options{
@@ -188,18 +195,16 @@ func newWithCloser(t *testing.T, options *Options) (*codersdk.Client, io.Closer)
188195
Authorizer: options.Authorizer,
189196
Telemetry: telemetry.NewNoop(),
190197
})
198+
t.Cleanup(func() {
199+
_ = coderAPI.Close()
200+
})
191201
srv.Config.Handler = coderAPI.Handler
192202

193203
var provisionerCloser io.Closer = nopcloser{}
194204
if options.IncludeProvisionerD {
195205
provisionerCloser = NewProvisionerDaemon(t, coderAPI)
196206
}
197-
198207
t.Cleanup(func() {
199-
cancelFunc()
200-
_ = turnServer.Close()
201-
srv.Close()
202-
_ = coderAPI.Close()
203208
_ = provisionerCloser.Close()
204209
})
205210

0 commit comments

Comments
 (0)