fix: file ext trim prefix (#2173)

backend/domain/workflow/internal/compose/workflow_tool.go

@@ -25,6 +25,8 @@ import (
 	"github.com/cloudwego/eino/components/tool"
 	einoCompose "github.com/cloudwego/eino/compose"
 	"github.com/cloudwego/eino/schema"
+	workflowModel "github.com/coze-dev/coze-studio/backend/api/model/crossdomain/workflow"
+	"github.com/coze-dev/coze-studio/backend/pkg/lang/slices"
 
 	wf "github.com/coze-dev/coze-studio/backend/domain/workflow"
 	"github.com/coze-dev/coze-studio/backend/domain/workflow/entity"
@@ -91,6 +93,9 @@ func (wt *workflowTool) prepare(ctx context.Context, rInfo *entity.ResumeRequest
 	lastEventChan <-chan *execute.Event, callOpts []einoCompose.Option, err error) {
 	cfg := execute.GetExecuteConfig(opts...)
 
+	cfg.InputFileFields = slices.ToMap(wt.sc.GetAllNodesInputFileFields(ctx), func(e *workflowModel.FileInfo) (string, *workflowModel.FileInfo) {
+		return e.FileURL, e
+	})
 	var runOpts []WorkflowRunnerOption
 	if rInfo != nil && !rInfo.Resumed {
 		runOpts = append(runOpts, WithResumeReq(rInfo))
@@ -121,12 +126,19 @@ func (wt *workflowTool) prepare(ctx context.Context, rInfo *entity.ResumeRequest
 		if entryNode == nil {
 			panic("entry node not found in tool workflow")
 		}
-		input, ws, err = nodes.ConvertInputs(ctx, input, entryNode.OutputTypes)
+		collectFileFields := make(map[string]*workflowModel.FileInfo, 0)
+		input, ws, err = nodes.ConvertInputs(ctx, input, entryNode.OutputTypes, nodes.WithCollectFileFields(collectFileFields))
 		if err != nil {
 			return
 		} else if ws != nil {
 			logs.CtxWarnf(ctx, "convert inputs warnings: %v", *ws)
 		}
+
+		if len(collectFileFields) > 0 {
+			for k, v := range collectFileFields {
+				cfg.InputFileFields[k] = v
+			}
+		}
 	}
 
 	cancelCtx, executeID, callOpts, lastEventChan, err = NewWorkflowRunner(wt.wfEntity.GetBasic(), wt.sc, cfg, runOpts...).Prepare(ctx)

backend/domain/workflow/internal/nodes/knowledge/knowledge_indexer.go

@@ -163,7 +163,7 @@ func parseToFileNameAndFileExtension(ctx context.Context, fileURL string) (strin
 		if err != nil {
 			return "", "", err
 		}
-		fileExt := filepath.Ext(strings.ToLower(strings.TrimPrefix(u.Path, ".")))
+		fileExt := strings.TrimPrefix(strings.ToLower(filepath.Ext(u.Path)), ".")
 		ext, support := parser.ValidateFileExtension(fileExt)
 		if !support {
 			return "", "", fmt.Errorf("unsupported file type: %s", fileExt)