move DesignateNodePrependPath to internal

Change-Id: I4fe923cdf2fc8e44ee2e1c895ad93b75ba30b2e9

Author: shentongmartin

compose/graph.go

@@ -28,6 +28,7 @@ import (
 	"github.com/cloudwego/eino/components/model"
 	"github.com/cloudwego/eino/components/prompt"
 	"github.com/cloudwego/eino/components/retriever"
+	"github.com/cloudwego/eino/internal/compose"
 	"github.com/cloudwego/eino/internal/generic"
 	"github.com/cloudwego/eino/internal/gmap"
 	"github.com/cloudwego/eino/schema"
@@ -1121,9 +1122,7 @@ func validateDAG(chanSubscribeTo map[string]*chanCall, invertedEdges map[string]
 }
 
 func NewNodePath(path ...string) *NodePath {
-	return &NodePath{path: path}
+	return compose.NewNodePath(path...)
 }
 
-type NodePath struct {
-	path []string
-}
+type NodePath = compose.NodePath

compose/graph_call_options.go

@@ -80,22 +80,8 @@ func (o Option) DesignateNodeWithPath(path ...*NodePath) Option {
 	return o
 }
 
-// DesignateNodePrependPath prepends the prefix to the path of the node(s) to which the option will be applied to.
-// Useful when you already have an Option designated to a graph's node, and now you want to add this graph as a subgraph.
-// e.g.
-// Your subgraph has a Node with key "A", and your subgraph's NodeKey is "sub_graph", you can specify option to A using:
-//
-// option := WithCallbacks(...).DesignateNode("A").DesignateNodePrependPath("sub_graph")
-// Note: as an End User, you probably don't need to use this method, as DesignateNodeWithPath will be sufficient in most use cases.
-// Note: as a Flow author, if you define your own Option type, and at the same time your flow can be exported to graph and added as GraphNode,
-// you can use this method to prepend your Option's designated path with the GraphNode's path.
-func (o Option) DesignateNodePrependPath(prefix *NodePath) Option {
-	for i := range o.paths {
-		p := o.paths[i]
-		p.path = append(prefix.path, p.path...)
-	}
-
-	return o
+func (o Option) Paths() []*NodePath {
+	return o.paths
 }
 
 // WithEmbeddingOption is a functional option type for embedding component.

compose/utils.go

@@ -238,7 +238,7 @@ func initNodeCallbacks(ctx context.Context, key string, info *nodeInfo, meta *ex
 		if len(opts[i].handler) != 0 {
 			if len(opts[i].paths) != 0 {
 				for _, k := range opts[i].paths {
-					if len(k.path) == 1 && k.path[0] == key {
+					if len(k.Path()) == 1 && k.Path()[0] == key {
 						cbs = append(cbs, opts[i].handler...)
 						break
 					}
@@ -314,18 +314,18 @@ func extractOption(nodes map[string]*chanCall, opts ...Option) (map[string][]any
 			}
 		}
 		for _, path := range opt.paths {
-			if len(path.path) == 0 {
+			if len(path.Path()) == 0 {
 				return nil, fmt.Errorf("call option has designated an empty path")
 			}
 
 			var curNode *chanCall
 			var ok bool
-			if curNode, ok = nodes[path.path[0]]; !ok {
+			if curNode, ok = nodes[path.Path()[0]]; !ok {
 				return nil, fmt.Errorf("option has designated an unknown node: %s", path)
 			}
-			curNodeKey := path.path[0]
+			curNodeKey := path.Path()[0]
 
-			if len(path.path) == 1 {
+			if len(path.Path()) == 1 {
 				if len(opt.options) == 0 {
 					// sub graph common callbacks has been added to ctx in initNodeCallback and won't be passed to subgraph only pass options
 					// node callback also won't be passed
@@ -350,7 +350,7 @@ func extractOption(nodes map[string]*chanCall, opts ...Option) (map[string][]any
 				}
 				// designate to sub graph's nodes
 				nOpt := opt.deepCopy()
-				nOpt.paths = []*NodePath{NewNodePath(path.path[1:]...)}
+				nOpt.paths = []*NodePath{NewNodePath(path.Path()[1:]...)}
 				optMap[curNodeKey] = append(optMap[curNodeKey], nOpt)
 			}
 		}

flow/agent/multiagent/host/options.go

@@ -21,6 +21,7 @@ import (
 	"github.com/cloudwego/eino/components/model"
 	"github.com/cloudwego/eino/compose"
 	"github.com/cloudwego/eino/flow/agent"
+	agent2 "github.com/cloudwego/eino/internal/flow/agent"
 )
 
 type options struct {
@@ -86,15 +87,15 @@ func ConvertOptions(nodePath *compose.NodePath, opts ...agent.AgentOption) []com
 	composeOpts := agent.GetImplSpecificOptions(&options{}, opts...).composeOptions
 	if nodePath != nil {
 		for i := range composeOpts {
-			composeOpts[i] = composeOpts[i].DesignateNodePrependPath(nodePath)
+			composeOpts[i] = agent2.DesignateNodePrependPath(composeOpts[i], nodePath)
 		}
 	}
 
 	convertedCallbackHandler := convertCallbacks(opts...)
 	if convertedCallbackHandler != nil {
 		callbackOpt := compose.WithCallbacks(convertedCallbackHandler).DesignateNode(defaultHostNodeKey)
 		if nodePath != nil {
-			return append(composeOpts, callbackOpt.DesignateNodePrependPath(nodePath))
+			return append(composeOpts, agent2.DesignateNodePrependPath(callbackOpt, nodePath))
 		}
 		return append(composeOpts, callbackOpt)
 	}

flow/agent/react/options.go

@@ -22,6 +22,7 @@ import (
 	"github.com/cloudwego/eino/components/tool"
 	"github.com/cloudwego/eino/compose"
 	"github.com/cloudwego/eino/flow/agent"
+	agent2 "github.com/cloudwego/eino/internal/flow/agent"
 )
 
 type options struct {
@@ -78,7 +79,7 @@ func ConvertOptions(nodePath *compose.NodePath, opts ...agent.AgentOption) []com
 	composeOpts := agent.GetImplSpecificOptions(&options{}, opts...).composeOptions
 	if nodePath != nil {
 		for i := range composeOpts {
-			composeOpts[i] = composeOpts[i].DesignateNodePrependPath(nodePath)
+			composeOpts[i] = agent2.DesignateNodePrependPath(composeOpts[i], nodePath)
 		}
 	}
 

internal/compose/option.go

@@ -0,0 +1,34 @@
+/*
+ * Copyright 2025 CloudWeGo Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package compose
+
+type NodePath struct {
+	path []string
+}
+
+func NewNodePath(path ...string) *NodePath {
+	return &NodePath{path: path}
+}
+
+func (n *NodePath) Path() []string {
+	return n.path
+}
+
+func (n *NodePath) Prepend(n1 *NodePath) *NodePath {
+	n.path = append(n1.path, n.path...)
+	return n
+}

internal/flow/agent/option.go

@@ -0,0 +1,47 @@
+/*
+ * Copyright 2025 CloudWeGo Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package agent
+
+import (
+	"github.com/cloudwego/eino/compose"
+)
+
+// DesignateNodePrependPath prepends the prefix to the path of the node(s) to which the option will be applied to.
+// Useful when you already have an Option designated to a graph's node, and now you want to add this graph as a subgraph.
+// e.g.
+// Your subgraph has a Node with key "A", and your subgraph's NodeKey is "sub_graph", you can specify option to A using:
+//
+// option := WithCallbacks(...).DesignateNode("A").DesignateNodePrependPath("sub_graph")
+// Note: as an End User, you probably don't need to use this method, as DesignateNodeWithPath will be sufficient in most use cases.
+// Note: as a Flow author, if you define your own Option type, and at the same time your flow can be exported to graph and added as GraphNode,
+// you can use this method to prepend your Option's designated path with the GraphNode's path.
+func DesignateNodePrependPath(o compose.Option, prefix *compose.NodePath) compose.Option {
+	if prefix == nil || len(prefix.Path()) == 0 {
+		return o
+	}
+
+	paths := o.Paths()
+	if len(paths) == 0 {
+		return o.DesignateNodeWithPath(prefix)
+	}
+
+	for i := range paths {
+		paths[i] = paths[i].Prepend(prefix)
+	}
+
+	return o
+}