fix: where HTTP node URL, JSON text, and raw text template rendering could not find the corresponding rendering variables (coze-dev#745)

Author: zhuangjie1125

backend/api/handler/coze/workflow_service_test.go

@@ -4655,7 +4655,7 @@ func TestJsonSerializationDeserializationWithWarning(t *testing.T) {
 	})
 }
 
-func TestSetAppVariablesFOrSubProcesses(t *testing.T) {
+func TestSetAppVariablesForSubProcesses(t *testing.T) {
 	mockey.PatchConvey("app variables for sub_process", t, func() {
 		r := newWfTestRunner(t)
 		defer r.closeFn()
@@ -4672,3 +4672,79 @@ func TestSetAppVariablesFOrSubProcesses(t *testing.T) {
 
 	})
 }
+
+func TestHttpImplicitDependencies(t *testing.T) {
+	mockey.PatchConvey("test http implicit dependencies", t, func() {
+		r := newWfTestRunner(t)
+		defer r.closeFn()
+
+		r.appVarS.EXPECT().Get(gomock.Any(), gomock.Any(), gomock.Any()).Return("1.0", nil).AnyTimes()
+
+		idStr := r.load("httprequester/http_implicit_dependencies.json")
+
+		r.publish(idStr, "v0.0.1", true)
+
+		runner := mockcode.NewMockRunner(r.ctrl)
+		runner.EXPECT().Run(gomock.Any(), gomock.Any()).DoAndReturn(func(ctx context.Context, request *coderunner.RunRequest) (*coderunner.RunResponse, error) {
+			in := request.Params["input"]
+			_ = in
+			result := make(map[string]any)
+			err := sonic.UnmarshalString(in.(string), &result)
+			if err != nil {
+				return nil, err
+			}
+
+			return &coderunner.RunResponse{
+				Result: result,
+			}, nil
+		}).AnyTimes()
+
+		code.SetCodeRunner(runner)
+
+		mockey.PatchConvey("test http node implicit dependencies", func() {
+			input := map[string]string{
+				"input": "a",
+			}
+			result, _ := r.openapiSyncRun(idStr, input)
+
+			batchRets := result["batch"].([]any)
+			loopRets := result["loop"].([]any)
+
+			for _, r := range batchRets {
+				assert.Contains(t, []any{
+					"http://echo.apifox.com/anything?aa=1.0&cc=1",
+					"http://echo.apifox.com/anything?aa=1.0&cc=2",
+				}, r)
+			}
+			for _, r := range loopRets {
+				assert.Contains(t, []any{
+					"http://echo.apifox.com/anything?a=1&m=123",
+					"http://echo.apifox.com/anything?a=2&m=123",
+				}, r)
+			}
+
+		})
+
+		mockey.PatchConvey("node debug http node implicit dependencies", func() {
+			exeID := r.nodeDebug(idStr, "109387",
+				withNDInput(map[string]string{
+					"__apiInfo_url_87fc7c69536cae843fa7f5113cf0067b":        "m",
+					"__apiInfo_url_ac86361e3cd503952e71986dc091fa6f":        "a",
+					"__body_bodyData_json_ac86361e3cd503952e71986dc091fa6f": "b",
+					"__body_bodyData_json_f77817a7cf8441279e1cfd8af4eeb1da": "1",
+				}))
+
+			e := r.getProcess(idStr, exeID, withSpecificNodeID("109387"))
+			e.assertSuccess()
+
+			ret := make(map[string]any)
+			err := sonic.UnmarshalString(e.output, &ret)
+			assert.Nil(t, err)
+			err = sonic.UnmarshalString(ret["body"].(string), &ret)
+			assert.Nil(t, err)
+			assert.Equal(t, ret["url"].(string), "http://echo.apifox.com/anything?a=a&m=m")
+
+		})
+
+	})
+}

backend/domain/workflow/internal/canvas/convert/type_convert.go

@@ -144,7 +144,7 @@ func CanvasBlockInputToTypeInfo(b *vo.BlockInput) (tInfo *vo.TypeInfo, err error
 					}
 					tInfo.Properties[subV.Name] = subTInfo
 				} else if b.Value.Type == vo.BlockInputValueTypeObjectRef {
-					subV, err := parseParam(subVAny)
+					subV, err := ParseParam(subVAny)
 					if err != nil {
 						return nil, err
 					}
@@ -195,7 +195,7 @@ func CanvasBlockInputToFieldInfo(b *vo.BlockInput, path einoCompose.FieldPath, p
 
 		for i := range paramList {
 			paramAny := paramList[i]
-			param, err := parseParam(paramAny)
+			param, err := ParseParam(paramAny)
 			if err != nil {
 				return nil, err
 			}
@@ -343,7 +343,7 @@ func parseBlockInputRef(content any) (*vo.BlockInputReference, error) {
 	return p, nil
 }
 
-func parseParam(v any) (*vo.Param, error) {
+func ParseParam(v any) (*vo.Param, error) {
 	if pa, ok := v.(*vo.Param); ok {
 		return pa, nil
 	}
@@ -497,7 +497,7 @@ func SetOutputTypesForNodeSchema(n *vo.Node, ns *schema.NodeSchema) error {
 
 func SetOutputsForNodeSchema(n *vo.Node, ns *schema.NodeSchema) error {
 	for _, vAny := range n.Data.Outputs {
-		param, err := parseParam(vAny)
+		param, err := ParseParam(vAny)
 		if err != nil {
 			return err
 		}
@@ -565,7 +565,7 @@ func BlockInputToNamedTypeInfo(name string, b *vo.BlockInput) (*vo.NamedTypeInfo
 					}
 					tInfo.Properties = append(tInfo.Properties, subNInfo)
 				} else if b.Value.Type == vo.BlockInputValueTypeObjectRef {
-					subV, err := parseParam(subVAny)
+					subV, err := ParseParam(subVAny)
 					if err != nil {
 						return nil, err
 					}