Function newRuntimeServer

admin/testadmin/testadmin.go:366–406

(ctx context.Context, t *testing.T, group *errgroup.Group, runtimePort int, externalURL, runtimeExternalURL string, logger *zap.Logger)

}

func newRuntimeServer(ctx context.Context, t *testing.T, group *errgroup.Group, runtimePort int, externalURL, runtimeExternalURL string, logger *zap.Logger) *runtimeServerFixture {
	// Create runtime server options
	runtimeServerOpts := &runtimeserver.Options{
		HTTPPort:        runtimePort,
		GRPCPort:        runtimePort,
		AllowedOrigins:  []string{"*"},
		SessionKeyPairs: [][]byte{randomBytes(), randomBytes()},
		AuthEnable:      true,
		AuthIssuerURL:   externalURL,        // Admin server as issuer
		AuthAudienceURL: runtimeExternalURL, // Runtime's own URL
	}

	// Create runtime
	rt := testruntime.New(t, false)

	// Create runtime server
	rtSrv, err := runtimeserver.NewServer(ctx, runtimeServerOpts, rt, logger, ratelimit.NewNoop(), activity.NewNoopClient())
	require.NoError(t, err)
	t.Cleanup(func() { rtSrv.Close() })

	// Start runtime server in the background
	group.Go(func() error {
		return rtSrv.ServeHTTP(ctx, nil, false)
	})

	// Wait for runtime server to be ready
	require.Eventually(t, func() bool {
		resp, err := http.Get(fmt.Sprintf("%s/v1/ping", runtimeExternalURL))
		if err != nil {
			return false
		}
		defer resp.Body.Close()
		return resp.StatusCode == http.StatusOK
	}, 15*time.Second, 100*time.Millisecond, "runtime server failed to start")

	return &runtimeServerFixture{
		Runtime:           rt,
		RuntimeServer:     rtSrv,
		RuntimeServerOpts: runtimeServerOpts,
	}
}

// findTwoPorts finds two different available ports.
func findTwoPorts(t *testing.T) (int, int) {