Skip to content

Commit e4dc0c5

Browse files
committed
ut fix
1 parent 67c298b commit e4dc0c5

File tree

4 files changed

+41
-14
lines changed

4 files changed

+41
-14
lines changed

lib/reversetunnel/localsite_test.go

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -481,11 +481,6 @@ func Test_shouldDialAndForward(t *testing.T) {
481481
nil,
482482
)
483483
require.NoError(t, err)
484-
gitHubServer, err := types.NewGitHubServer(types.GitHubServerMetadata{
485-
Integration: "org1",
486-
Organization: "org1",
487-
})
488-
require.NoError(t, err)
489484

490485
tests := []struct {
491486
name string
@@ -509,14 +504,6 @@ func Test_shouldDialAndForward(t *testing.T) {
509504
recConfig: recordAtNode,
510505
check: require.True,
511506
},
512-
{
513-
name: "Git server",
514-
params: reversetunnelclient.DialParams{
515-
TargetServer: gitHubServer,
516-
},
517-
recConfig: recordAtNode,
518-
check: require.True,
519-
},
520507
{
521508
name: "node",
522509
params: reversetunnelclient.DialParams{

lib/srv/authhandlers_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,7 @@ func TestRBAC(t *testing.T) {
154154
name: "forwarding git",
155155
component: teleport.ComponentForwardingGit,
156156
targetServer: gitServer,
157-
assertRBACCheck: require.True,
157+
assertRBACCheck: require.False,
158158
},
159159
}
160160

lib/srv/regular/sshserver_test.go

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1672,6 +1672,7 @@ func TestProxyRoundRobin(t *testing.T) {
16721672
Emitter: proxyClient,
16731673
LockWatcher: lockWatcher,
16741674
NodeWatcher: nodeWatcher,
1675+
GitServerWatcher: newGitServerWatcher(ctx, t, proxyClient),
16751676
CertAuthorityWatcher: caWatcher,
16761677
CircuitBreakerConfig: breaker.NoopBreakerConfig(),
16771678
})
@@ -1807,6 +1808,7 @@ func TestProxyDirectAccess(t *testing.T) {
18071808
Emitter: proxyClient,
18081809
LockWatcher: lockWatcher,
18091810
NodeWatcher: nodeWatcher,
1811+
GitServerWatcher: newGitServerWatcher(ctx, t, proxyClient),
18101812
CertAuthorityWatcher: caWatcher,
18111813
CircuitBreakerConfig: breaker.NoopBreakerConfig(),
18121814
})
@@ -2493,6 +2495,7 @@ func TestParseSubsystemRequest(t *testing.T) {
24932495
Emitter: proxyClient,
24942496
LockWatcher: lockWatcher,
24952497
NodeWatcher: nodeWatcher,
2498+
GitServerWatcher: newGitServerWatcher(ctx, t, proxyClient),
24962499
CertAuthorityWatcher: caWatcher,
24972500
})
24982501
require.NoError(t, err)
@@ -2754,6 +2757,7 @@ func TestIgnorePuTTYSimpleChannel(t *testing.T) {
27542757
Emitter: proxyClient,
27552758
LockWatcher: lockWatcher,
27562759
NodeWatcher: nodeWatcher,
2760+
GitServerWatcher: newGitServerWatcher(ctx, t, proxyClient),
27572761
CertAuthorityWatcher: caWatcher,
27582762
})
27592763
require.NoError(t, err)
@@ -3093,6 +3097,19 @@ func newNodeWatcher(ctx context.Context, t *testing.T, client *authclient.Client
30933097
return nodeWatcher
30943098
}
30953099

3100+
func newGitServerWatcher(ctx context.Context, t *testing.T, client *authclient.Client) *services.GenericWatcher[types.Server, readonly.Server] {
3101+
watcher, err := services.NewGitServerWatcher(ctx, services.GitServerWatcherConfig{
3102+
ResourceWatcherConfig: services.ResourceWatcherConfig{
3103+
Component: "test",
3104+
Client: client,
3105+
},
3106+
GitServerGetter: client,
3107+
})
3108+
require.NoError(t, err)
3109+
t.Cleanup(watcher.Close)
3110+
return watcher
3111+
}
3112+
30963113
func newCertAuthorityWatcher(ctx context.Context, t *testing.T, client types.Events) *services.CertAuthorityWatcher {
30973114
caWatcher, err := services.NewCertAuthorityWatcher(ctx, services.CertAuthorityWatcherConfig{
30983115
ResourceWatcherConfig: services.ResourceWatcherConfig{
@@ -3174,6 +3191,7 @@ func TestHostUserCreationProxy(t *testing.T) {
31743191
Emitter: proxyClient,
31753192
LockWatcher: lockWatcher,
31763193
NodeWatcher: nodeWatcher,
3194+
GitServerWatcher: newGitServerWatcher(ctx, t, proxyClient),
31773195
CertAuthorityWatcher: caWatcher,
31783196
CircuitBreakerConfig: breaker.NoopBreakerConfig(),
31793197
})

lib/web/apiserver_test.go

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -399,6 +399,16 @@ func newWebSuiteWithConfig(t *testing.T, cfg webSuiteConfig) *WebSuite {
399399
require.NoError(t, err)
400400
defer caWatcher.Close()
401401

402+
proxyGitServerWatcher, err := services.NewGitServerWatcher(ctx, services.GitServerWatcherConfig{
403+
ResourceWatcherConfig: services.ResourceWatcherConfig{
404+
Component: teleport.ComponentProxy,
405+
Client: s.proxyClient,
406+
},
407+
GitServerGetter: s.proxyClient,
408+
})
409+
require.NoError(t, err)
410+
t.Cleanup(proxyGitServerWatcher.Close)
411+
402412
revTunServer, err := reversetunnel.NewServer(reversetunnel.Config{
403413
ID: node.ID(),
404414
Listener: revTunListener,
@@ -414,6 +424,7 @@ func newWebSuiteWithConfig(t *testing.T, cfg webSuiteConfig) *WebSuite {
414424
DataDir: t.TempDir(),
415425
LockWatcher: proxyLockWatcher,
416426
NodeWatcher: proxyNodeWatcher,
427+
GitServerWatcher: proxyGitServerWatcher,
417428
CertAuthorityWatcher: caWatcher,
418429
CircuitBreakerConfig: breaker.NoopBreakerConfig(),
419430
LocalAuthAddresses: []string{s.server.TLS.Listener.Addr().String()},
@@ -8160,6 +8171,16 @@ func createProxy(ctx context.Context, t *testing.T, proxyID string, node *regula
81608171
require.NoError(t, err)
81618172
t.Cleanup(proxyNodeWatcher.Close)
81628173

8174+
proxyGitServerWatcher, err := services.NewGitServerWatcher(ctx, services.GitServerWatcherConfig{
8175+
ResourceWatcherConfig: services.ResourceWatcherConfig{
8176+
Component: teleport.ComponentProxy,
8177+
Client: client,
8178+
},
8179+
GitServerGetter: client,
8180+
})
8181+
require.NoError(t, err)
8182+
t.Cleanup(proxyGitServerWatcher.Close)
8183+
81638184
revTunServer, err := reversetunnel.NewServer(reversetunnel.Config{
81648185
ID: node.ID(),
81658186
Listener: revTunListener,
@@ -8175,6 +8196,7 @@ func createProxy(ctx context.Context, t *testing.T, proxyID string, node *regula
81758196
DataDir: t.TempDir(),
81768197
LockWatcher: proxyLockWatcher,
81778198
NodeWatcher: proxyNodeWatcher,
8199+
GitServerWatcher: proxyGitServerWatcher,
81788200
CertAuthorityWatcher: proxyCAWatcher,
81798201
CircuitBreakerConfig: breaker.NoopBreakerConfig(),
81808202
LocalAuthAddresses: []string{authServer.Listener.Addr().String()},

0 commit comments

Comments
 (0)