Skip to content

Commit 7dc4693

Browse files
authored
Provide Link authority to checkpoint fixtures (#573)
1 parent e8f5ccd commit 7dc4693

3 files changed

Lines changed: 3 additions & 3 deletions

File tree

‎services/core/tests/integration/environment_initialization_test.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ func TestUserManagedPreparationUsesAuthenticatedRuntimeWithoutAllocation(t *test
7474
t.Fatal(err)
7575
}
7676
registry := runtimegateway.NewRegistry()
77-
handler := runtimegateway.NewHandler(runtimegateway.HandlerConfig{Authenticator: runtimegateway.NewAuthenticator(sessionAdapter(s)), Registry: registry})
77+
handler := runtimegateway.NewHandler(runtimegateway.HandlerConfig{Authenticator: runtimegateway.NewAuthenticator(sessionAdapter(s)), Registry: registry, Links: runtimegateway.NewLinkAuthority(sessionAdapter(s))})
7878
server := httptest.NewServer(http.HandlerFunc(handler.WS))
7979
defer server.Close()
8080
link := sandboxlinktest.StartRelay(t, runtimegateway.NewLinkAuthority(sessionAdapter(s)))

‎services/core/tests/integration/runtime_compute_lifecycle_test.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ func newFakeCheckpointProvider(t *testing.T, s *Store) *fakeCheckpointProvider {
5454
t.Helper()
5555
p := &fakeCheckpointProvider{t: t, lifecycleProvider: lifecycleProvider{resources: map[string]sandbox.Info{}}, computes: map[string]sandbox.ComputeState{}, snapshots: map[string]sandbox.SnapshotIdentity{}, bootstraps: map[string]sandbox.Bootstrap{}, serving: map[string]*linkServe{},
5656
host: registerAgentHost(t, s), registry: runtimegateway.NewRegistry(), link: sandboxlinktest.StartRelay(t, runtimegateway.NewLinkAuthority(sessionAdapter(s)))}
57-
handler := runtimegateway.NewHandler(runtimegateway.HandlerConfig{Authenticator: runtimegateway.NewAuthenticator(sessionAdapter(s)), Registry: p.registry})
57+
handler := runtimegateway.NewHandler(runtimegateway.HandlerConfig{Authenticator: runtimegateway.NewAuthenticator(sessionAdapter(s)), Registry: p.registry, Links: runtimegateway.NewLinkAuthority(sessionAdapter(s))})
5858
server := httptest.NewServer(http.HandlerFunc(handler.WS))
5959
p.endpoint = "ws" + strings.TrimPrefix(server.URL, "http")
6060
t.Cleanup(func() {

‎services/core/tests/integration/runtime_lifecycle_test.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ func managedWorkerMode(t *testing.T, s *Store, key string, p sandbox.SandboxProv
8282
if peer, ok := p.(interface {
8383
setRuntimeGateway(*testing.T, *Store, string, *runtimegateway.Registry, *sandboxlinktest.Server)
8484
}); ok {
85-
handler := runtimegateway.NewHandler(runtimegateway.HandlerConfig{Authenticator: runtimegateway.NewAuthenticator(sessionAdapter(s)), Registry: dispatcher.Registry})
85+
handler := runtimegateway.NewHandler(runtimegateway.HandlerConfig{Authenticator: runtimegateway.NewAuthenticator(sessionAdapter(s)), Registry: dispatcher.Registry, Links: runtimegateway.NewLinkAuthority(sessionAdapter(s))})
8686
server := httptest.NewServer(http.HandlerFunc(handler.WS))
8787
t.Cleanup(server.Close)
8888
link := sandboxlinktest.StartRelay(t, runtimegateway.NewLinkAuthority(sessionAdapter(s)))

0 commit comments

Comments
 (0)