Method initializeDaggerClient

engine/server/session.go:530–722

requires that client.stateMu is held

(
	ctx context.Context,
	client *daggerClient,
	opts *ClientInitOpts,
)

// requires that client.stateMu is held
func (srv *Server) initializeDaggerClient(
	ctx context.Context,
	client *daggerClient,
	opts *ClientInitOpts,
) error {
	slog := slog.With(
		"isMainClient", client.clientID == client.daggerSession.mainClientCallerID,
		"sessionID", client.daggerSession.sessionID,
		"clientID", client.clientID,
		"mainClientID", client.daggerSession.mainClientCallerID,
	)
	slog.Info("initializing new client")
	var callerG singleflight.Group[string, engineutil.SessionCaller]
	client.getClientCaller = func(ctx context.Context, id string) (engineutil.SessionCaller, error) {
		ctx, cancel := context.WithTimeout(context.WithoutCancel(ctx), 10*time.Second)
		defer cancel()
		caller, _, err := callerG.Do(ctx, id, func(ctx context.Context) (engineutil.SessionCaller, error) {
			return client.daggerSession.attachables.Wait(ctx, id)
		})
		return caller, err
	}
	client.hostServiceProxyClientID = opts.HostServiceProxyClientID
	client.getHostServiceCaller = func(ctx context.Context, id string) (engineutil.SessionCaller, error) {
		return client.resolveHostServiceCaller(ctx, id)
	}

	var err error
	client.dialer = &net.Dialer{
		Resolver: &net.Resolver{
			PreferGo: true,
			Dial: func(ctx context.Context, network, address string) (net.Conn, error) {
				if len(srv.dns.Nameservers) == 0 {
					return nil, errors.New("no nameservers configured")
				}

				var errs []error
				for _, ns := range srv.dns.Nameservers {
					conn, err := client.dialer.DialContext(ctx, network, net.JoinHostPort(ns, "53"))
					if err != nil {
						errs = append(errs, err)
						continue
					}

					return conn, nil
				}

				return nil, errors.Join(errs...)
			},
		},
	}

	engineUtilOpts := *srv.engineUtilOpts
	engineUtilOpts.Dialer = client.dialer
	engineUtilOpts.GetClientCaller = client.getClientCaller
	engineUtilOpts.GetHostServiceCaller = client.getHostServiceCaller
	engineUtilOpts.GetMainClientCaller = client.getMainClientCaller
	engineUtilOpts.GetRegistryResolver = srv.RegistryResolver
	engineUtilOpts.Interactive = client.daggerSession.interactive