Method TestSystemGoProxy

core/integration/proxy_test.go:470–595

(ctx context.Context, t *testctx.T)

}

func (ContainerSuite) TestSystemGoProxy(ctx context.Context, t *testctx.T) {
	c := connect(ctx, t)

	// Just a subset of modules we expect to be downloaded since trying to go one to one would
	// be too fragile whenever the SDK changes.
	// NOTE: this is also impacted by engine pre-caching of SDK deps, so what shows up here are
	// deps in testGitModuleRef that aren't pre-cached.
	// If updating this test becomes a nuisance, we might want to use a custom test git module ref
	// that specifically has some extra deps not in the Go SDK.
	expectedGoModDownloads := []string{
		"github.com/andreyvit/diff",
		"github.com/davecgh/go-spew",
		"github.com/go-logr/logr",
	}

	executeTestEnvName := fmt.Sprintf("DAGGER_TEST_%s", strings.ToUpper(t.Name()))
	if os.Getenv(executeTestEnvName) == "" {
		const goProxyAlias = "goproxy"
		const goProxyPort = 8080
		goProxySetting := fmt.Sprintf("http://%s:%d", goProxyAlias, goProxyPort)

		fetcher := &goProxyFetcher{dlPaths: make(map[string]struct{})}
		proxy := &goproxy.Goproxy{Fetcher: fetcher}

		l, err := net.Listen("tcp", "127.0.0.1:0")
		require.NoError(t, err)
		t.Cleanup(func() {
			l.Close()
		})
		port := l.Addr().(*net.TCPAddr).Port

		goProxyCtx, cancelGoProxy := context.WithCancel(ctx)
		t.Cleanup(cancelGoProxy)
		srv := http.Server{
			Handler:           proxy,
			ReadHeaderTimeout: 30 * time.Second,
			BaseContext: func(net.Listener) context.Context {
				return goProxyCtx
			},
		}
		t.Cleanup(func() {
			srv.Shutdown(context.Background())
		})

		goProxyDone := make(chan error, 1)
		go func() {
			goProxyDone <- srv.Serve(l)
		}()

		goProxySvc := c.Host().Service([]dagger.PortForward{{
			Backend:  port,
			Frontend: goProxyPort,
		}})

		devEngine := devEngineContainer(c, func(ctr *dagger.Container) *dagger.Container {
			return ctr.
				WithServiceBinding(goProxyAlias, goProxySvc).
				WithEnvVariable("_DAGGER_ENGINE_SYSTEMENV_GOPROXY", goProxySetting)