Method ServeHTTPToNestedClient

engine/server/session.go:1055–1118

ServeHTTPToNestedClient serves nested clients, including module function calls.

(
	w http.ResponseWriter,
	r *http.Request,
	nestedClientMetadata *engine.ClientMetadata,
	callerClientID string,
	hostServiceProxyToCaller bool,
	moduleCtx dagql.AnyObjectResult,
	functionCall dagql.Typed,
	envCtx dagql.AnyObjectResult,
)

// ServeHTTPToNestedClient serves nested clients, including module function calls.
func (srv *Server) ServeHTTPToNestedClient(
	w http.ResponseWriter,
	r *http.Request,
	nestedClientMetadata *engine.ClientMetadata,
	callerClientID string,
	hostServiceProxyToCaller bool,
	moduleCtx dagql.AnyObjectResult,
	functionCall dagql.Typed,
	envCtx dagql.AnyObjectResult,
) {
	if nestedClientMetadata == nil {
		http.Error(w, "nested client metadata is nil", http.StatusInternalServerError)
		return
	}
	clientMetadata := nestedClientMetadataForRequest(r.Header, nestedClientMetadata)

	var moduleContext dagql.ObjectResult[*core.Module]
	if moduleCtx != nil {
		typed, ok := moduleCtx.(dagql.ObjectResult[*core.Module])
		if !ok {
			http.Error(w, fmt.Sprintf("nested client module context is %T, not Module", moduleCtx), http.StatusInternalServerError)
			return
		}
		if typed.Self() != nil {
			moduleContext = typed
		}
	}

	var fnCall *core.FunctionCall
	if functionCall != nil {
		typed, ok := functionCall.(*core.FunctionCall)
		if !ok {
			http.Error(w, fmt.Sprintf("nested client function call is %T, not FunctionCall", functionCall), http.StatusInternalServerError)
			return
		}
		fnCall = typed
	}

	var envContext dagql.ObjectResult[*core.Env]
	if envCtx != nil {
		typed, ok := envCtx.(dagql.ObjectResult[*core.Env])
		if !ok {
			http.Error(w, fmt.Sprintf("nested client env context is %T, not Env", envCtx), http.StatusInternalServerError)
			return
		}
		if typed.Self() != nil {
			envContext = typed
		}
	}

	var hostServiceProxyClientID string
	if hostServiceProxyToCaller {
		hostServiceProxyClientID = callerClientID
	}

	httpHandlerFunc(srv.serveHTTPToClient, &ClientInitOpts{
		ClientMetadata:           clientMetadata,
		CallerClientID:           callerClientID,