feat: init improvements

.github/CODEOWNERS

@@ -150,7 +150,6 @@
 /frontend/packages/studio/publish-manage-hooks/ @duwenhan2byte @evan-crash
 /frontend/packages/foundation/layout/ @evan-crash @duwenhan2byte
 /frontend/packages/studio/open-platform/open-auth/ @evan-crash @DingGao-Devin
-/frontend/packages/studio/open-platform/open-chat/ @tomasyu985 @DingGao-Devin
 /frontend/packages/agent-ide/entry-adapter/ @Hezi-crypto @duwenhan2byte @catee @evan-crash @haozhenfei
 /frontend/packages/agent-ide/entry/ @soonco @duwenhan2byte @catee @evan-crash
 /frontend/packages/agent-ide/bot-config-area-adapter/ @haozhenfei @Hezi-crypto @duwenhan2byte @catee @evan-crash

CONTRIBUTING.md

@@ -28,7 +28,7 @@ Before you submit your Pull Request (PR) consider the following guidelines:
 3. [Fork](https://docs.github.com/en/github/getting-started-with-github/fork-a-repo) the coze-dev {project_name} repo.
 4. In your forked repository, make your changes in a new git branch:
     ```
-    git checkout -b my-fix-branch main
+    git checkout -b my-fix-branch develop
     ```
 5. Create your patch, including appropriate test cases.
 6. Follow our [Style Guides](#code-style-guides).
@@ -38,7 +38,7 @@ Before you submit your Pull Request (PR) consider the following guidelines:
     ```
     git push origin my-fix-branch
     ```
-9. In GitHub, send a pull request to `{project_name}:main`
+9. In GitHub, send a pull request to `{project_name}:develop`
 
 ## Contribution Prerequisites
 - Our development environment keeps up with [Go Official](https://golang.org/project/).

Makefile

@@ -28,7 +28,7 @@ fe:
 	@echo "Building frontend..."
 	@bash $(BUILD_FE_SCRIPT)
 
-server: env setup_es_index
+server: env 
 	@if [ ! -d "$(STATIC_DIR)" ]; then \
 		echo "Static directory '$(STATIC_DIR)' not found, building frontend..."; \
 		$(MAKE) fe; \

backend/api/model/crossdomain/plugin/toolinfo.go

@@ -263,7 +263,6 @@ func toAPIParameter(paramMeta paramMetaInfo, sc *openapi3.Schema) (*common.APIPa
 	}
 
 	if sc.Default != nil {
-		apiParam.GlobalDefault = ptr.Of(fmt.Sprintf("%v", sc.Default))
 		apiParam.LocalDefault = ptr.Of(fmt.Sprintf("%v", sc.Default))
 	}
 

backend/application/base/pluginutil/api.go

@@ -20,9 +20,10 @@ import (
 	"net/http"
 	"strconv"
 
-	"github.com/coze-dev/coze-studio/backend/domain/plugin/entity"
 	"github.com/getkin/kin-openapi/openapi3"
 
+	"github.com/coze-dev/coze-studio/backend/domain/plugin/entity"
+
 	"github.com/coze-dev/coze-studio/backend/api/model/crossdomain/plugin"
 	common "github.com/coze-dev/coze-studio/backend/api/model/plugin_develop_common"
 	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
@@ -32,6 +33,14 @@ import (
 func APIParamsToOpenapiOperation(reqParams, respParams []*common.APIParameter) (*openapi3.Operation, error) {
 	op := &openapi3.Operation{}
 
+	if reqParams != nil && len(reqParams) == 0 {
+		op.Parameters = []*openapi3.ParameterRef{}
+		op.RequestBody = entity.DefaultOpenapi3RequestBody()
+	}
+	if respParams != nil && len(respParams) == 0 {
+		op.Responses = entity.DefaultOpenapi3Responses()
+	}
+
 	hasSetReqBody := false
 	hasSetParams := false
 
@@ -127,16 +136,6 @@ func APIParamsToOpenapiOperation(reqParams, respParams []*common.APIParameter) (
 		}
 	}
 
-	if op.Parameters == nil {
-		op.Parameters = []*openapi3.ParameterRef{}
-	}
-	if op.RequestBody == nil {
-		op.RequestBody = entity.DefaultOpenapi3RequestBody()
-	}
-	if op.Responses == nil {
-		op.Responses = entity.DefaultOpenapi3Responses()
-	}
-
 	return op, nil
 }
 

backend/application/knowledge/init.go

@@ -36,7 +36,6 @@ import (
 	"github.com/cloudwego/eino-ext/components/model/qwen"
 	"github.com/cloudwego/eino/components/prompt"
 	"github.com/cloudwego/eino/schema"
-	"github.com/coze-dev/coze-studio/backend/infra/impl/embedding/http"
 	"github.com/milvus-io/milvus/client/v2/milvusclient"
 	"github.com/volcengine/volc-sdk-golang/service/vikingdb"
 	"github.com/volcengine/volc-sdk-golang/service/visual"
@@ -372,21 +371,6 @@ func getEmbedding(ctx context.Context) (embedding.Embedder, error) {
 			return nil, fmt.Errorf("init ollama embedding failed, err=%w", err)
 		}
 
-
-	case "http":
-		var (
-			httpEmbeddingBaseURL = os.Getenv("HTTP_EMBEDDING_ADDR")
-			httpEmbeddingDims    = os.Getenv("HTTP_EMBEDDING_DIMS")
-		)
-		dims, err := strconv.ParseInt(httpEmbeddingDims, 10, 64)
-		if err != nil {
-			return nil, fmt.Errorf("init http embedding dims failed, err=%w", err)
-		}
-		emb, err = http.NewEmbedding(httpEmbeddingBaseURL, dims)
-		if err != nil {
-			return nil, fmt.Errorf("init http embedding failed, err=%w", err)
-		}
-
 	default:
 		return nil, fmt.Errorf("init knowledge embedding failed, type not configured")
 	}

backend/application/plugin/plugin.go

@@ -250,7 +250,7 @@ func (p *PluginApplicationService) RegisterPluginMeta(ctx context.Context, req *
 		if req.GetLocation() == common.AuthorizationServiceLocation_Query {
 			loc = model.ParamInQuery
 		} else if req.GetLocation() == common.AuthorizationServiceLocation_Header {
-			loc = model.ParamInHeader
+			loc = model.ParamInPath
 		} else {
 			return nil, fmt.Errorf("invalid location '%s'", req.GetLocation())
 		}

backend/domain/knowledge/service/knowledge_integration_test.go

@@ -145,7 +145,7 @@ func (suite *KnowledgeTestSuite) SetupSuite() {
 		panic(err)
 	}
 
-	emb, err := hembed.NewEmbedding(embEndpoint, 1024)
+	emb, err := hembed.NewEmbedding(embEndpoint)
 	if err != nil {
 		panic(err)
 	}

backend/domain/plugin/entity/plugin.go

@@ -157,6 +157,7 @@ func NewDefaultPluginManifest() *PluginManifest {
 					Value: "Coze/1.0",
 				},
 			},
+			model.ParamInPath:  {},
 			model.ParamInQuery: {},
 		},
 	}

backend/domain/plugin/service/exec_tool.go

@@ -29,7 +29,6 @@ import (
 
 	"github.com/bytedance/sonic"
 	"github.com/getkin/kin-openapi/openapi3"
-	"github.com/tidwall/sjson"
 
 	einoCompose "github.com/cloudwego/eino/compose"
 
@@ -480,6 +479,11 @@ func (t *toolExecutor) execute(ctx context.Context, argumentsInJson string) (res
 		return nil, err
 	}
 
+	requestStr, err := sonic.MarshalString(args)
+	if err != nil {
+		return nil, err
+	}
+
 	httpReq, err := t.buildHTTPRequest(ctx, args)
 	if err != nil {
 		return nil, err
@@ -500,29 +504,18 @@ func (t *toolExecutor) execute(ctx context.Context, argumentsInJson string) (res
 	}
 
 	var reqBodyBytes []byte
-	if httpReq.GetBody != nil {
-		reqBody, err := httpReq.GetBody()
+	if httpReq.Body != nil {
+		reqBodyBytes, err = io.ReadAll(httpReq.Body)
 		if err != nil {
 			return nil, err
 		}
-		defer reqBody.Close()
-
-		reqBodyBytes, err = io.ReadAll(reqBody)
-		if err != nil {
-			return nil, err
-		}
-	}
-
-	requestStr, err := genRequestString(httpReq, reqBodyBytes)
-	if err != nil {
-		return nil, err
 	}
 
 	restyReq := t.svc.httpCli.NewRequest()
 	restyReq.Header = httpReq.Header
 	restyReq.Method = httpReq.Method
 	restyReq.URL = httpReq.URL.String()
-	if reqBodyBytes != nil {
+	if len(reqBodyBytes) > 0 {
 		restyReq.SetBody(reqBodyBytes)
 	}
 	restyReq.SetContext(ctx)
@@ -566,46 +559,6 @@ func (t *toolExecutor) execute(ctx context.Context, argumentsInJson string) (res
 	}, nil
 }
 
-func genRequestString(req *http.Request, body []byte) (string, error) {
-	type Request struct {
-		Path   string            `json:"path"`
-		Header map[string]string `json:"header"`
-		Query  map[string]string `json:"query"`
-		Body   *[]byte           `json:"body"`
-	}
-
-	req_ := &Request{
-		Path:   req.URL.Path,
-		Header: map[string]string{},
-		Query:  map[string]string{},
-	}
-
-	if len(req.Header) > 0 {
-		for k, v := range req.Header {
-			req_.Header[k] = v[0]
-		}
-	}
-	if len(req.URL.Query()) > 0 {
-		for k, v := range req.URL.Query() {
-			req_.Query[k] = v[0]
-		}
-	}
-
-	requestStr, err := sonic.MarshalString(req_)
-	if err != nil {
-		return "", fmt.Errorf("[genRequestString] marshal failed, err=%s", err)
-	}
-
-	if body != nil {
-		requestStr, err = sjson.SetRaw(requestStr, "body", string(body))
-		if err != nil {
-			return "", fmt.Errorf("[genRequestString] set body failed, err=%s", err)
-		}
-	}
-
-	return requestStr, nil
-}
-
 func (t *toolExecutor) preprocessArgumentsInJson(ctx context.Context, argumentsInJson string) (args map[string]any, err error) {
 	args, err = t.prepareArguments(ctx, argumentsInJson)
 	if err != nil {
@@ -700,13 +653,23 @@ func (t *toolExecutor) buildHTTPRequest(ctx context.Context, argMaps map[string]
 		return nil, err
 	}
 
-	commonParams := t.plugin.Manifest.CommonParams
-
-	reqURL, err := locArgs.buildHTTPRequestURL(ctx, rawURL, commonParams)
+	reqURL, err := locArgs.buildHTTPRequestURL(ctx, rawURL)
 	if err != nil {
 		return nil, err
 	}
 
+	httpReq, err = http.NewRequestWithContext(ctx, tool.GetMethod(), reqURL.String(), nil)
+	if err != nil {
+		return nil, err
+	}
+
+	header, err := locArgs.buildHTTPRequestHeader(ctx)
+	if err != nil {
+		return nil, err
+	}
+
+	httpReq.Header = header
+
 	bodyArgs := map[string]any{}
 	for k, v := range argMaps {
 		if _, ok := locArgs.header[k]; ok {
@@ -721,27 +684,13 @@ func (t *toolExecutor) buildHTTPRequest(ctx context.Context, argMaps map[string]
 		bodyArgs[k] = v
 	}
 
-	commonBody := commonParams[model.ParamInBody]
-	bodyBytes, contentType, err := t.buildRequestBody(ctx, tool.Operation, bodyArgs, commonBody)
+	bodyBytes, contentType, err := t.buildRequestBody(ctx, tool.Operation, bodyArgs)
 	if err != nil {
 		return nil, err
 	}
-
-	httpReq, err = http.NewRequestWithContext(ctx, tool.GetMethod(), reqURL.String(), bytes.NewBuffer(bodyBytes))
-	if err != nil {
-		return nil, err
-	}
-
-	commonHeader := commonParams[model.ParamInHeader]
-	header, err := locArgs.buildHTTPRequestHeader(ctx, commonHeader)
-	if err != nil {
-		return nil, err
-	}
-
-	httpReq.Header = header
-
 	if len(bodyBytes) > 0 {
 		httpReq.Header.Set("Content-Type", contentType)
+		httpReq.Body = io.NopCloser(bytes.NewReader(bodyBytes))
 	}
 
 	return httpReq, nil
@@ -749,6 +698,13 @@ func (t *toolExecutor) buildHTTPRequest(ctx context.Context, argMaps map[string]
 
 func (t *toolExecutor) prepareArguments(_ context.Context, argumentsInJson string) (map[string]any, error) {
 	args := map[string]any{}
+	for loc, params := range t.plugin.Manifest.CommonParams {
+		for _, p := range params {
+			if loc != model.ParamInBody {
+				args[p.Name] = p.Value
+			}
+		}
+	}
 
 	decoder := sonic.ConfigDefault.NewDecoder(bytes.NewBufferString(argumentsInJson))
 	decoder.UseNumber()
@@ -1219,9 +1175,7 @@ type valueWithSchema struct {
 	paramSchema *openapi3.Parameter
 }
 
-func (l *locationArguments) buildHTTPRequestURL(_ context.Context, rawURL string,
-	commonParams map[model.HTTPParamLocation][]*common.CommonParamSchema) (reqURL *url.URL, err error) {
-
+func (l *locationArguments) buildHTTPRequestURL(_ context.Context, rawURL string) (reqURL *url.URL, err error) {
 	if len(l.path) > 0 {
 		for k, v := range l.path {
 			vStr, err := encoder.EncodeParameter(v.paramSchema, v.argValue)
@@ -1232,8 +1186,9 @@ func (l *locationArguments) buildHTTPRequestURL(_ context.Context, rawURL string
 		}
 	}
 
-	query := url.Values{}
+	encodeQuery := ""
 	if len(l.query) > 0 {
+		query := url.Values{}
 		for k, val := range l.query {
 			switch v := val.argValue.(type) {
 			case []any:
@@ -1244,18 +1199,10 @@ func (l *locationArguments) buildHTTPRequestURL(_ context.Context, rawURL string
 				query.Add(k, encoder.MustString(v))
 			}
 		}
-	}
 
-	commonQuery := commonParams[model.ParamInQuery]
-	for _, v := range commonQuery {
-		if _, ok := l.query[v.Name]; ok {
-			continue
-		}
-		query.Add(v.Name, v.Value)
+		encodeQuery = query.Encode()
 	}
 
-	encodeQuery := query.Encode()
-
 	reqURL, err = url.Parse(rawURL)
 	if err != nil {
 		return nil, err
@@ -1270,7 +1217,7 @@ func (l *locationArguments) buildHTTPRequestURL(_ context.Context, rawURL string
 	return reqURL, nil
 }
 
-func (l *locationArguments) buildHTTPRequestHeader(_ context.Context, commonHeaders []*common.CommonParamSchema) (http.Header, error) {
+func (l *locationArguments) buildHTTPRequestHeader(_ context.Context) (http.Header, error) {
 	header := http.Header{}
 	if len(l.header) > 0 {
 		for k, v := range l.header {
@@ -1285,64 +1232,44 @@ func (l *locationArguments) buildHTTPRequestHeader(_ context.Context, commonHead
 		}
 	}
 
-	for _, h := range commonHeaders {
-		if header.Get(h.Name) != "" {
-			continue
-		}
-		header.Add(h.Name, h.Value)
-	}
-
 	return header, nil
 }
 
-func (t *toolExecutor) buildRequestBody(ctx context.Context, op *model.Openapi3Operation, bodyArgs map[string]any,
-	commonBody []*common.CommonParamSchema) (body []byte, contentType string, err error) {
-
-	var bodyMap map[string]any
-
+func (t *toolExecutor) buildRequestBody(ctx context.Context, op *model.Openapi3Operation, bodyArgs map[string]any) (body []byte, contentType string, err error) {
 	contentType, bodySchema := t.getReqBodySchema(op)
-	if bodySchema != nil && len(bodySchema.Value.Properties) > 0 {
-		bodyMap, err = t.injectRequestBodyDefaultValue(ctx, bodySchema.Value, bodyArgs)
+	if bodySchema == nil || bodySchema.Value == nil {
+		return nil, "", nil
+	}
+
+	if len(bodySchema.Value.Properties) == 0 {
+		return nil, "", nil
+	}
+
+	bodyMap, err := t.injectRequestBodyDefaultValue(ctx, bodySchema.Value, bodyArgs)
+	if err != nil {
+		return nil, "", err
+	}
+
+	for paramName, prop := range bodySchema.Value.Properties {
+		value, ok := bodyMap[paramName]
+		if !ok {
+			continue
+		}
+
+		_value, err := encoder.TryFixValueType(paramName, prop, value)
 		if err != nil {
 			return nil, "", err
 		}
 
-		for paramName, prop := range bodySchema.Value.Properties {
-			value, ok := bodyMap[paramName]
-			if !ok {
-				continue
-			}
-
-			_value, err := encoder.TryFixValueType(paramName, prop, value)
-			if err != nil {
-				return nil, "", err
-			}
-
-			bodyMap[paramName] = _value
-		}
-
-		body, err = encoder.EncodeBodyWithContentType(contentType, bodyMap)
-		if err != nil {
-			return nil, "", fmt.Errorf("[buildRequestBody] EncodeBodyWithContentType failed, err=%v", err)
-		}
+		bodyMap[paramName] = _value
 	}
 
-	commonBody_ := make([]*common.CommonParamSchema, 0, len(commonBody))
-	for _, v := range commonBody {
-		if _, ok := bodyMap[v.Name]; ok {
-			continue
-		}
-		commonBody_ = append(commonBody_, v)
+	reqBodyStr, err := encoder.EncodeBodyWithContentType(contentType, bodyMap)
+	if err != nil {
+		return nil, "", fmt.Errorf("[buildRequestBody] EncodeBodyWithContentType failed, err=%v", err)
 	}
 
-	for _, v := range commonBody_ {
-		body, err = sjson.SetRawBytes(body, v.Name, []byte(v.Value))
-		if err != nil {
-			return nil, "", fmt.Errorf("[buildRequestBody] SetRawBytes failed, err=%v", err)
-		}
-	}
-
-	return body, contentType, nil
+	return reqBodyStr, contentType, nil
 }
 
 func (t *toolExecutor) injectRequestBodyDefaultValue(ctx context.Context, sc *openapi3.Schema, vals map[string]any) (newVals map[string]any, err error) {
@@ -1400,7 +1327,7 @@ func (t *toolExecutor) injectRequestBodyDefaultValue(ctx context.Context, sc *op
 }
 
 func (t *toolExecutor) getReqBodySchema(op *model.Openapi3Operation) (string, *openapi3.SchemaRef) {
-	if op.RequestBody == nil || len(op.RequestBody.Value.Content) == 0 {
+	if op.RequestBody == nil || op.RequestBody.Value == nil || len(op.RequestBody.Value.Content) == 0 {
 		return "", nil
 	}
 

backend/domain/plugin/service/exec_tool_test.go

@@ -1,49 +0,0 @@
-/*
- * Copyright 2025 coze-dev 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 service
-
-import (
-	"net/http"
-	"net/url"
-	"testing"
-
-	. "github.com/bytedance/mockey"
-	"github.com/stretchr/testify/assert"
-)
-
-func TestGenRequestString(t *testing.T) {
-	PatchConvey("", t, func() {
-		requestStr, err := genRequestString(&http.Request{
-			Header: http.Header{
-				"Content-Type": []string{"application/json"},
-			},
-			Method: http.MethodPost,
-			URL:    &url.URL{Path: "/test"},
-		}, []byte(`{"a": 1}`))
-		assert.NoError(t, err)
-		assert.Equal(t, `{"header":{"Content-Type":["application/json"]},"query":null,"path":"/test","body":{"a": 1}}`, requestStr)
-	})
-
-	PatchConvey("", t, func() {
-		var body []byte
-		requestStr, err := genRequestString(&http.Request{
-			URL: &url.URL{Path: "/test"},
-		}, body)
-		assert.NoError(t, err)
-		assert.Equal(t, `{"header":null,"query":null,"path":"/test","body":null}`, requestStr)
-	})
-}

backend/domain/plugin/service/plugin_draft.go

@@ -46,7 +46,6 @@ import (
 
 func (p *pluginServiceImpl) CreateDraftPlugin(ctx context.Context, req *CreateDraftPluginRequest) (pluginID int64, err error) {
 	mf := entity.NewDefaultPluginManifest()
-	mf.CommonParams = map[model.HTTPParamLocation][]*plugin_develop_common.CommonParamSchema{}
 	mf.NameForHuman = req.Name
 	mf.NameForModel = req.Name
 	mf.DescriptionForHuman = req.Desc
@@ -66,11 +65,11 @@ func (p *pluginServiceImpl) CreateDraftPlugin(ctx context.Context, req *CreateDr
 			return 0, fmt.Errorf("invalid location '%s'", loc.String())
 		}
 		for _, param := range params {
-			mf.CommonParams[location] = append(mf.CommonParams[location],
-				&plugin_develop_common.CommonParamSchema{
-					Name:  param.Name,
-					Value: param.Value,
-				})
+			mParams := mf.CommonParams[location]
+			mParams = append(mParams, &plugin_develop_common.CommonParamSchema{
+				Name:  param.Name,
+				Value: param.Value,
+			})
 		}
 	}
 

backend/domain/plugin/service/plugin_oauth.go

@@ -194,7 +194,7 @@ func (p *pluginServiceImpl) getAccessTokenByAuthorizationCode(ctx context.Contex
 	meta := ci.Meta
 	info, exist, err := p.oauthRepo.GetAuthorizationCode(ctx, ci.Meta)
 	if err != nil {
-		return "", errorx.Wrapf(err, "GetAuthorizationCode failed, userID=%s, pluginID=%d, isDraft=%t",
+		return "", errorx.Wrapf(err, "GetAuthorizationCode failed, userID=%s, pluginID=%d, isDraft=%p",
 			meta.UserID, meta.PluginID, meta.IsDraft)
 	}
 	if !exist {

backend/go.mod

@@ -54,12 +54,11 @@ require github.com/alicebob/miniredis/v2 v2.34.0
 
 require (
 	github.com/DATA-DOG/go-sqlmock v1.5.2
-	github.com/aws/aws-sdk-go-v2/service/s3 v1.84.1
 	github.com/cloudwego/eino-ext/components/embedding/ark v0.0.0-20250522060253-ddb617598b09
 	github.com/cloudwego/eino-ext/components/embedding/ollama v0.0.0-20250728060543-79ec300857b8
 	github.com/cloudwego/eino-ext/components/embedding/openai v0.0.0-20250522060253-ddb617598b09
 	github.com/cloudwego/eino-ext/components/model/gemini v0.1.2
-	github.com/cloudwego/eino-ext/components/model/ollama v0.1.0
+	github.com/cloudwego/eino-ext/components/model/ollama v0.0.0-20250610035057-2c4e7c8488a5
 	github.com/cloudwego/eino-ext/components/model/qwen v0.0.0-20250612061754-5a3deb091dc5
 	github.com/dimchansky/utfbom v1.1.1
 	github.com/elastic/go-elasticsearch/v7 v7.17.10
@@ -85,6 +84,7 @@ require (
 	github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.37 // indirect
 	github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.7.5 // indirect
 	github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.18.18 // indirect
+	github.com/aws/aws-sdk-go-v2/service/s3 v1.84.1 // indirect
 	github.com/cloudwego/gopkg v0.1.4 // indirect
 	github.com/evanphx/json-patch v4.12.0+incompatible // indirect
 	github.com/extrame/ole2 v0.0.0-20160812065207-d69429661ad7 // indirect
@@ -111,10 +111,10 @@ require (
 require (
 	github.com/anthropics/anthropic-sdk-go v1.4.0 // indirect
 	github.com/avast/retry-go v3.0.0+incompatible // indirect
-	github.com/aws/aws-sdk-go-v2 v1.36.6
+	github.com/aws/aws-sdk-go-v2 v1.36.6 // indirect
 	github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.11 // indirect
-	github.com/aws/aws-sdk-go-v2/config v1.29.1
-	github.com/aws/aws-sdk-go-v2/credentials v1.17.54
+	github.com/aws/aws-sdk-go-v2/config v1.29.1 // indirect
+	github.com/aws/aws-sdk-go-v2/credentials v1.17.54 // indirect
 	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.24 // indirect
 	github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.37 // indirect
 	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.37 // indirect

backend/go.sum

@@ -822,8 +822,12 @@ github.com/avast/retry-go v3.0.0+incompatible h1:4SOWQ7Qs+oroOTQOYnAHqelpCO0biHS
 github.com/avast/retry-go v3.0.0+incompatible/go.mod h1:XtSnn+n/sHqQIpZ10K1qAevBhOOCWBLXXy3hyiqqBrY=
 github.com/aws/aws-sdk-go v1.40.45/go.mod h1:585smgzpB/KqRA+K3y/NL/oYRqQvpNJYvLm+LY1U59Q=
 github.com/aws/aws-sdk-go-v2 v1.9.1/go.mod h1:cK/D0BBs0b/oWPIcX/Z/obahJK1TT7IPVjy53i/mX/4=
+github.com/aws/aws-sdk-go-v2 v1.33.0 h1:Evgm4DI9imD81V0WwD+TN4DCwjUMdc94TrduMLbgZJs=
+github.com/aws/aws-sdk-go-v2 v1.33.0/go.mod h1:P5WJBrYqqbWVaOxgH0X/FYYD47/nooaPOZPlQdmiN2U=
 github.com/aws/aws-sdk-go-v2 v1.36.6 h1:zJqGjVbRdTPojeCGWn5IR5pbJwSQSBh5RWFTQcEQGdU=
 github.com/aws/aws-sdk-go-v2 v1.36.6/go.mod h1:EYrzvCCN9CMUTa5+6lf6MM4tq3Zjp8UhSGR/cBsjai0=
+github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.3 h1:tW1/Rkad38LA15X4UQtjXZXNKsCgkshC3EbmcUmghTg=
+github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.3/go.mod h1:UbnqO+zjqk3uIt9yCACHJ9IVNhyhOCnYk8yA19SAWrM=
 github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.11 h1:12SpdwU8Djs+YGklkinSSlcrPyj3H4VifVsKf78KbwA=
 github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.11/go.mod h1:dd+Lkp6YmMryke+qxW/VnKyhMBDTYP41Q2Bb+6gNZgY=
 github.com/aws/aws-sdk-go-v2/config v1.29.1 h1:JZhGawAyZ/EuJeBtbQYnaoftczcb2drR2Iq36Wgz4sQ=
@@ -832,8 +836,12 @@ github.com/aws/aws-sdk-go-v2/credentials v1.17.54 h1:4UmqeOqJPvdvASZWrKlhzpRahAu
 github.com/aws/aws-sdk-go-v2/credentials v1.17.54/go.mod h1:RTdfo0P0hbbTxIhmQrOsC/PquBZGabEPnCaxxKRPSnI=
 github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.24 h1:5grmdTdMsovn9kPZPI23Hhvp0ZyNm5cRO+IZFIYiAfw=
 github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.24/go.mod h1:zqi7TVKTswH3Ozq28PkmBmgzG1tona7mo9G2IJg4Cis=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.28 h1:igORFSiH3bfq4lxKFkTSYDhJEUCYo6C8VKiWJjYwQuQ=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.28/go.mod h1:3So8EA/aAYm36L7XIvCVwLa0s5N0P7o2b1oqnx/2R4g=
 github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.37 h1:osMWfm/sC/L4tvEdQ65Gri5ZZDCUpuYJZbTTDrsn4I0=
 github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.37/go.mod h1:ZV2/1fbjOPr4G4v38G3Ww5TBT4+hmsK45s/rxu1fGy0=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.28 h1:1mOW9zAUMhTSrMDssEHS/ajx8JcAj/IcftzcmNlmVLI=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.28/go.mod h1:kGlXVIWDfvt2Ox5zEaNglmq0hXPHgQFNMix33Tw22jA=
 github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.37 h1:v+X21AvTb2wZ+ycg1gx+orkB/9U6L7AOp93R7qYxsxM=
 github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.37/go.mod h1:G0uM1kyssELxmJ2VZEfG0q2npObR3BAkF3c1VsfVnfs=
 github.com/aws/aws-sdk-go-v2/internal/ini v1.8.1 h1:VaRN3TlFdd6KxX1x3ILT5ynH6HvKgqdiXoTxAF4HQcQ=
@@ -841,10 +849,14 @@ github.com/aws/aws-sdk-go-v2/internal/ini v1.8.1/go.mod h1:FbtygfRFze9usAadmnGJN
 github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.37 h1:XTZZ0I3SZUHAtBLBU6395ad+VOblE0DwQP6MuaNeics=
 github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.37/go.mod h1:Pi6ksbniAWVwu2S8pEzcYPyhUkAcLaufxN7PfAUQjBk=
 github.com/aws/aws-sdk-go-v2/service/cloudwatch v1.8.1/go.mod h1:CM+19rL1+4dFWnOQKwDc7H1KwXTz+h61oUSHyhV0b3o=
+github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.1 h1:iXtILhvDxB6kPvEXgsDhGaZCSC6LQET5ZHSdJozeI0Y=
+github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.1/go.mod h1:9nu0fVANtYiAePIBh2/pFUSwtJ402hLnp854CNoDOeE=
 github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.4 h1:CXV68E2dNqhuynZJPB80bhPQwAKqBWVer887figW6Jc=
 github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.4/go.mod h1:/xFi9KtvBXP97ppCz1TAEvU1Uf66qvid89rbem3wCzQ=
 github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.7.5 h1:M5/B8JUaCI8+9QD+u3S/f4YHpvqE9RpSkV3rf0Iks2w=
 github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.7.5/go.mod h1:Bktzci1bwdbpuLiu3AOksiNPMl/LLKmX1TWmqp2xbvs=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.9 h1:TQmKDyETFGiXVhZfQ/I0cCFziqqX58pi4tKJGYGFSz0=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.9/go.mod h1:HVLPK2iHQBUx7HfZeOQSEu3v2ubZaAY2YPbAm5/WUyY=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.18 h1:vvbXsA2TVO80/KT7ZqCbx934dt6PY+vQ8hZpUZ/cpYg=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.18/go.mod h1:m2JJHledjBGNMsLOF1g9gbAxprzq3KjC8e4lxtn+eWg=
 github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.18.18 h1:OS2e0SKqsU2LiJPqL8u9x41tKc6MMEHrWjLVLn3oysg=
@@ -858,6 +870,8 @@ github.com/aws/aws-sdk-go-v2/service/ssooidc v1.28.10/go.mod h1:Fzsj6lZEb8AkTE5S
 github.com/aws/aws-sdk-go-v2/service/sts v1.33.9 h1:BRVDbewN6VZcwr+FBOszDKvYeXY1kJ+GGMCcpghlw0U=
 github.com/aws/aws-sdk-go-v2/service/sts v1.33.9/go.mod h1:f6vjfZER1M17Fokn0IzssOTMT2N8ZSq+7jnNF0tArvw=
 github.com/aws/smithy-go v1.8.0/go.mod h1:SObp3lf9smib00L/v3U2eAKG8FyQ7iLrJnQiAmR5n+E=
+github.com/aws/smithy-go v1.22.1 h1:/HPHZQ0g7f4eUeK6HKglFz8uwVfZKgoI25rb/J+dnro=
+github.com/aws/smithy-go v1.22.1/go.mod h1:irrKGvNn1InZwb2d7fkIRNucdfwR8R+Ts3wxYa/cJHg=
 github.com/aws/smithy-go v1.22.4 h1:uqXzVZNuNexwc/xrh6Tb56u89WDlJY6HS+KC0S4QSjw=
 github.com/aws/smithy-go v1.22.4/go.mod h1:t1ufH5HMublsJYulve2RKmHDC15xu1f26kHCp/HgceI=
 github.com/aymerick/raymond v2.0.3-0.20180322193309-b565731e1464+incompatible/go.mod h1:osfaiScAUVup+UC9Nfq76eWqDhXlp+4UYaA8uhTBO6g=
@@ -942,8 +956,6 @@ github.com/cloudwego/eino-ext/components/model/gemini v0.1.2 h1:bt9xftOQhP0Nuh1P
 github.com/cloudwego/eino-ext/components/model/gemini v0.1.2/go.mod h1:1tv89uZ9hR/4AyQ+9yxFWLn52GaJDKtPXdEY7WZdyZc=
 github.com/cloudwego/eino-ext/components/model/ollama v0.0.0-20250610035057-2c4e7c8488a5 h1:GkAAQHQkb1cOTwm6uRokj4lM//wrt/3AkMwTxyFJUg4=
 github.com/cloudwego/eino-ext/components/model/ollama v0.0.0-20250610035057-2c4e7c8488a5/go.mod h1:giNUFqA+V7xrm/EDvH7JFnDqoWI+e2m1SVAnReU+Fd8=
-github.com/cloudwego/eino-ext/components/model/ollama v0.1.0 h1:FW067iMfg3EZbUaZIo8v3i2ILBAZDzY23/9pbprvE0M=
-github.com/cloudwego/eino-ext/components/model/ollama v0.1.0/go.mod h1:+qA5kkUCM0mIrXGSNzxLcjxh6K1AghPNigtEyyMdkOc=
 github.com/cloudwego/eino-ext/components/model/openai v0.0.0-20250715055739-0d0e28441a2f h1:ovS39vuN2JW+C/O9jtEmOUuLEY4fw0yYh8//yhMfJNM=
 github.com/cloudwego/eino-ext/components/model/openai v0.0.0-20250715055739-0d0e28441a2f/go.mod h1:2mFQQnlhJrNgbW6YX1MOUUfXkGSbTz9Ylx37fbR0xBo=
 github.com/cloudwego/eino-ext/components/model/qwen v0.0.0-20250612061754-5a3deb091dc5 h1:4zAZiNo/PkeVc0Gw8YLpzpbR8zDzccL7H5PLqTuGhv4=

backend/infra/impl/cache/redis/redis.go

@@ -27,11 +27,9 @@ type Client = redis.Client
 
 func New() *redis.Client {
 	addr := os.Getenv("REDIS_ADDR")
-        password := os.Getenv("REDIS_PASSWORD")
 	rdb := redis.NewClient(&redis.Options{
 		Addr: addr, // Redis地址
 		DB:   0,    // 默认数据库
-		Password: password,
 		// 连接池配置
 		PoolSize:        100,             // 最大连接数（建议设置为CPU核心数*10）
 		MinIdleConns:    10,              // 最小空闲连接

backend/infra/impl/document/ocr/veocr/ve_ocr.go

@@ -24,12 +24,12 @@ import (
 	"net/url"
 	"strconv"
 
+	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
+	"github.com/coze-dev/coze-studio/backend/types/errno"
 	"github.com/volcengine/volc-sdk-golang/service/visual"
 	"github.com/volcengine/volcengine-go-sdk/service/arkruntime/model"
 
 	"github.com/coze-dev/coze-studio/backend/infra/contract/document/ocr"
-	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
-	"github.com/coze-dev/coze-studio/backend/types/errno"
 )
 
 type Config struct {

backend/infra/impl/document/parser/builtin/py_parser_protocol.go

@@ -249,11 +249,6 @@ func formatTablesInDocument(input []*schema.Document) (output []*schema.Document
 				values = append(values, col.Name)
 			}
 			write(values)
-			if colOnly, err := document.GetDocumentColumnsOnly(doc); err != nil {
-				return nil, err
-			} else if colOnly {
-				break
-			}
 		}
 
 		data, err := document.GetDocumentColumnData(doc)

backend/infra/impl/embedding/ark/ark.go

@@ -25,12 +25,12 @@ import (
 
 	"github.com/cloudwego/eino-ext/components/embedding/ark"
 	"github.com/cloudwego/eino/components/embedding"
+	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
+	"github.com/coze-dev/coze-studio/backend/types/errno"
 	"github.com/volcengine/volcengine-go-sdk/service/arkruntime/model"
 
 	contract "github.com/coze-dev/coze-studio/backend/infra/contract/embedding"
-	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
 	"github.com/coze-dev/coze-studio/backend/pkg/lang/slices"
-	"github.com/coze-dev/coze-studio/backend/types/errno"
 )
 
 func NewArkEmbedder(ctx context.Context, config *ark.EmbeddingConfig, dimensions int64) (contract.Embedder, error) {

backend/infra/impl/embedding/http/http.go

@@ -22,6 +22,7 @@ import (
 	"encoding/json"
 	"io"
 	"net/http"
+	"strconv"
 	"time"
 
 	opt "github.com/cloudwego/eino/components/embedding"
@@ -29,7 +30,10 @@ import (
 	"github.com/coze-dev/coze-studio/backend/infra/contract/embedding"
 )
 
-const pathEmbed = "/embedding"
+const (
+	pathDim   = "/dimension"
+	pathEmbed = "/embedding"
+)
 
 type embedReq struct {
 	Texts      []string `json:"texts"`
@@ -41,12 +45,32 @@ type embedResp struct {
 	Sparse []map[int]float64 `json:"sparse"`
 }
 
-func NewEmbedding(addr string, dims int64) (embedding.Embedder, error) {
+func NewEmbedding(addr string) (embedding.Embedder, error) {
 	cli := &http.Client{Timeout: time.Second * 30}
+	req, err := http.NewRequest(http.MethodGet, addr+pathDim, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	resp, err := cli.Do(req)
+	if err != nil {
+		return nil, err
+	}
+	defer resp.Body.Close()
+	b, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, err
+	}
+
+	dim, err := strconv.ParseInt(string(b), 10, 64)
+	if err != nil {
+		return nil, err
+	}
+
 	return &embedder{
 		cli:  cli,
 		addr: addr,
-		dim:  dims,
+		dim:  dim,
 	}, nil
 }
 

backend/infra/impl/embedding/http/http_test.go

@@ -31,7 +31,7 @@ func TestHTTPEmbedding(t *testing.T) {
 	}
 
 	ctx := context.Background()
-	emb, err := NewEmbedding("http://127.0.0.1:6543", 1024)
+	emb, err := NewEmbedding("http://127.0.0.1:6543")
 	assert.NoError(t, err)
 	texts := []string{
 		"hello",

backend/infra/impl/embedding/wrap/ollama.go

@@ -20,7 +20,6 @@ import (
 	"context"
 
 	"github.com/cloudwego/eino-ext/components/embedding/ollama"
-
 	contract "github.com/coze-dev/coze-studio/backend/infra/contract/embedding"
 )
 

backend/infra/impl/storage/minio/minio.go

@@ -23,7 +23,9 @@ import (
 	"io"
 	"log"
 	"math/rand"
+	"net"
 	"net/url"
+	"os"
 	"time"
 
 	"github.com/minio/minio-go/v7"
@@ -31,7 +33,6 @@ import (
 
 	"github.com/coze-dev/coze-studio/backend/infra/contract/imagex"
 	"github.com/coze-dev/coze-studio/backend/infra/contract/storage"
-	"github.com/coze-dev/coze-studio/backend/infra/impl/storage/proxy"
 	"github.com/coze-dev/coze-studio/backend/pkg/ctxcache"
 	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
 	"github.com/coze-dev/coze-studio/backend/types/consts"
@@ -210,9 +211,27 @@ func (m *minioClient) GetObjectUrl(ctx context.Context, objectKey string, opts .
 	}
 
 	// logs.CtxDebugf(ctx, "[GetObjectUrl] origin presignedURL.String = %s", presignedURL.String())
-	ok, proxyURL := proxy.CheckIfNeedReplaceHost(ctx, presignedURL.String())
-	if ok {
-		return proxyURL, nil
+
+	proxyPort := os.Getenv(consts.MinIOProxyEndpoint) // :8889
+	if len(proxyPort) > 0 {
+		currentHost, ok := ctxcache.Get[string](ctx, consts.HostKeyInCtx)
+		if !ok {
+			return presignedURL.String(), nil
+		}
+
+		currentScheme, ok := ctxcache.Get[string](ctx, consts.RequestSchemeKeyInCtx)
+		if !ok {
+			return presignedURL.String(), nil
+		}
+
+		host, _, err := net.SplitHostPort(currentHost)
+		if err != nil {
+			host = currentHost
+		}
+		minioProxyHost := host + proxyPort
+		presignedURL.Host = minioProxyHost
+		presignedURL.Scheme = currentScheme
+		// logs.CtxDebugf(ctx, "[GetObjectUrl] reset presignedURL.String = %s", presignedURL.String())
 	}
 
 	return presignedURL.String(), nil
@@ -246,6 +265,7 @@ func (m *minioClient) GetUploadAuth(ctx context.Context, opt ...imagex.UploadAut
 }
 
 func (m *minioClient) GetResourceURL(ctx context.Context, uri string, opts ...imagex.GetResourceOpt) (*imagex.ResourceURL, error) {
+
 	url, err := m.GetObjectUrl(ctx, uri)
 	if err != nil {
 		return nil, err
@@ -253,12 +273,11 @@ func (m *minioClient) GetResourceURL(ctx context.Context, uri string, opts ...im
 	return &imagex.ResourceURL{
 		URL: url,
 	}, nil
-}
 
+}
 func (m *minioClient) Upload(ctx context.Context, data []byte, opts ...imagex.UploadAuthOpt) (*imagex.UploadResult, error) {
 	return nil, nil
 }
-
 func (m *minioClient) GetUploadAuthWithExpire(ctx context.Context, expire time.Duration, opt ...imagex.UploadAuthOpt) (*imagex.SecurityToken, error) {
 	return nil, nil
 }

backend/infra/impl/storage/proxy/proxy.go

@@ -1,63 +0,0 @@
-/*
- * Copyright 2025 coze-dev 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 proxy
-
-import (
-	"context"
-	"net"
-	"net/url"
-	"os"
-
-	"github.com/coze-dev/coze-studio/backend/pkg/ctxcache"
-	"github.com/coze-dev/coze-studio/backend/pkg/logs"
-	"github.com/coze-dev/coze-studio/backend/types/consts"
-)
-
-func CheckIfNeedReplaceHost(ctx context.Context, originURLStr string) (ok bool, proxyURL string) {
-	// url parse
-	originURL, err := url.Parse(originURLStr)
-	if err != nil {
-		logs.CtxWarnf(ctx, "[CheckIfNeedReplaceHost] url parse failed, err: %v", err)
-		return false, ""
-	}
-
-	proxyPort := os.Getenv(consts.MinIOProxyEndpoint) // :8889
-	if proxyPort == "" {
-		return false, ""
-	}
-
-	currentHost, ok := ctxcache.Get[string](ctx, consts.HostKeyInCtx)
-	if !ok {
-		return false, ""
-	}
-
-	currentScheme, ok := ctxcache.Get[string](ctx, consts.RequestSchemeKeyInCtx)
-	if !ok {
-		return false, ""
-	}
-
-	host, _, err := net.SplitHostPort(currentHost)
-	if err != nil {
-		host = currentHost
-	}
-
-	minioProxyHost := host + proxyPort
-	originURL.Host = minioProxyHost
-	originURL.Scheme = currentScheme
-	logs.CtxDebugf(ctx, "[CheckIfNeedReplaceHost] reset originURL.String = %s", originURL.String())
-	return true, originURL.String()
-}

backend/infra/impl/storage/s3/s3.go

@@ -21,6 +21,9 @@ import (
 	"context"
 	"fmt"
 	"io"
+	"net"
+	"net/url"
+	"os"
 	"time"
 
 	"github.com/aws/aws-sdk-go-v2/aws"
@@ -30,7 +33,6 @@ import (
 
 	"github.com/coze-dev/coze-studio/backend/infra/contract/imagex"
 	"github.com/coze-dev/coze-studio/backend/infra/contract/storage"
-	"github.com/coze-dev/coze-studio/backend/infra/impl/storage/proxy"
 	"github.com/coze-dev/coze-studio/backend/pkg/ctxcache"
 	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
 	"github.com/coze-dev/coze-studio/backend/pkg/logs"
@@ -217,9 +219,34 @@ func (t *s3Client) GetObjectUrl(ctx context.Context, objectKey string, opts ...s
 		return "", fmt.Errorf("get object presigned url failed: %v", err)
 	}
 
-	ok, proxyURL := proxy.CheckIfNeedReplaceHost(ctx, req.URL)
-	if ok {
-		return proxyURL, nil
+	// url parse
+	url, err := url.Parse(req.URL)
+	if err != nil {
+		logs.CtxWarnf(ctx, "[GetObjectUrl] url parse failed, err: %v", err)
+		return req.URL, nil
+	}
+
+	proxyPort := os.Getenv(consts.MinIOProxyEndpoint) // :8889
+	if len(proxyPort) > 0 {
+		currentHost, ok := ctxcache.Get[string](ctx, consts.HostKeyInCtx)
+		if !ok {
+			return req.URL, nil
+		}
+
+		currentScheme, ok := ctxcache.Get[string](ctx, consts.RequestSchemeKeyInCtx)
+		if !ok {
+			return req.URL, nil
+		}
+
+		host, _, err := net.SplitHostPort(currentHost)
+		if err != nil {
+			host = currentHost
+		}
+		minioProxyHost := host + proxyPort
+		url.Host = minioProxyHost
+		url.Scheme = currentScheme
+		logs.CtxInfof(ctx, "[GetObjectUrl] reset ORG.URL = %s  TOS.URL = %s", req.URL, url.String())
+		return url.String(), nil
 	}
 
 	return req.URL, nil
@@ -231,6 +258,7 @@ func (i *s3Client) GetUploadHost(ctx context.Context) string {
 		return ""
 	}
 	return currentHost + consts.ApplyUploadActionURI
+
 }
 
 func (t *s3Client) GetServerID() string {

backend/infra/impl/storage/tos/tos.go

@@ -21,7 +21,10 @@ import (
 	"context"
 	"fmt"
 	"io"
+	"net"
 	"net/http"
+	"net/url"
+	"os"
 	"time"
 
 	"github.com/volcengine/ve-tos-golang-sdk/v2/tos"
@@ -29,7 +32,6 @@ import (
 
 	"github.com/coze-dev/coze-studio/backend/infra/contract/imagex"
 	"github.com/coze-dev/coze-studio/backend/infra/contract/storage"
-	"github.com/coze-dev/coze-studio/backend/infra/impl/storage/proxy"
 	"github.com/coze-dev/coze-studio/backend/pkg/ctxcache"
 	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
 	"github.com/coze-dev/coze-studio/backend/pkg/lang/conv"
@@ -211,9 +213,34 @@ func (t *tosClient) GetObjectUrl(ctx context.Context, objectKey string, opts ...
 		return "", err
 	}
 
-	ok, proxyURL := proxy.CheckIfNeedReplaceHost(ctx, output.SignedUrl)
-	if ok {
-		return proxyURL, nil
+	// url parse
+	url, err := url.Parse(output.SignedUrl)
+	if err != nil {
+		logs.CtxWarnf(ctx, "[GetObjectUrl] url parse failed, err: %v", err)
+		return output.SignedUrl, nil
+	}
+
+	proxyPort := os.Getenv(consts.MinIOProxyEndpoint) // :8889
+	if len(proxyPort) > 0 {
+		currentHost, ok := ctxcache.Get[string](ctx, consts.HostKeyInCtx)
+		if !ok {
+			return output.SignedUrl, nil
+		}
+
+		currentScheme, ok := ctxcache.Get[string](ctx, consts.RequestSchemeKeyInCtx)
+		if !ok {
+			return output.SignedUrl, nil
+		}
+
+		host, _, err := net.SplitHostPort(currentHost)
+		if err != nil {
+			host = currentHost
+		}
+		minioProxyHost := host + proxyPort
+		url.Host = minioProxyHost
+		url.Scheme = currentScheme
+		// logs.CtxDebugf(ctx, "[GetObjectUrl] reset \n ORG.URL = %s \n TOS.URL = %s", output.SignedUrl, url.String())
+		return url.String(), nil
 	}
 
 	return output.SignedUrl, nil

backend/main.go

@@ -74,10 +74,9 @@ func startHttpServer() {
 		server.WithMaxRequestBodySize(int(maxSize)),
 	}
 
-	useSSL := getEnv(consts.UseSSL, "0")
+	useSSL := getEnv("USE_SSL", "0")
 	if useSSL == "1" {
-		cert, err := tls.LoadX509KeyPair(getEnv(consts.SSLCertFile, ""),
-			getEnv(consts.SSLKeyFile, ""))
+		cert, err := tls.LoadX509KeyPair("cert.pem", "key.pem")
 		if err != nil {
 			fmt.Println(err.Error())
 		}
@@ -194,12 +193,10 @@ func asyncStartMinioProxyServer(ctx context.Context) {
 			originDirector(req)
 			req.Host = req.URL.Host
 		}
-		useSSL := getEnv(consts.UseSSL, "0")
+		useSSL := getEnv("USE_SSL", "0")
 		if useSSL == "1" {
 			logs.Infof("Minio proxy server is listening on %s with SSL", minioProxyEndpoint)
-			err := http.ListenAndServeTLS(minioProxyEndpoint,
-				getEnv(consts.SSLCertFile, ""),
-				getEnv(consts.SSLKeyFile, ""), proxy)
+			err := http.ListenAndServeTLS(minioProxyEndpoint, "cert.pem", "key.pem", proxy)
 			if err != nil {
 				log.Fatal(err)
 			}

backend/types/consts/consts.go

@@ -81,10 +81,6 @@ const (
 	CodeRunnerNodeModulesDir = "CODE_RUNNER_NODE_MODULES_DIR"
 	CodeRunnerTimeoutSeconds = "CODE_RUNNER_TIMEOUT_SECONDS"
 	CodeRunnerMemoryLimitMB  = "CODE_RUNNER_MEMORY_LIMIT_MB"
-
-	UseSSL      = "USE_SSL"
-	SSLCertFile = "SSL_CERT_FILE"
-	SSLKeyFile  = "SSL_KEY_FILE"
 )
 
 const (

common/config/subspaces/default/pnpm-lock.yaml

@@ -19030,8 +19030,8 @@ importers:
         specifier: workspace:*
         version: link:../../../arch/i18n
       '@coze/chat-sdk':
-        specifier: 0.1.11-beta.19
-        version: 0.1.11-beta.19(@types/react@18.2.37)(axios@1.10.0)(debug@4.3.3)(lodash-es@4.17.21)(react-dom@18.2.0)(react@18.2.0)
+        specifier: 0.1.11-beta.17
+        version: 0.1.11-beta.17(@types/react@18.2.37)(axios@1.10.0)(debug@4.3.3)(lodash-es@4.17.21)(react-dom@18.2.0)(react@18.2.0)
       react:
         specifier: 18.2.0
         version: 18.2.0
@@ -26106,8 +26106,8 @@ packages:
       - utf-8-validate
     dev: false
 
-  /@coze/chat-sdk@0.1.11-beta.19(@types/react@18.2.37)(axios@1.10.0)(debug@4.3.3)(lodash-es@4.17.21)(react-dom@18.2.0)(react@18.2.0):
-    resolution: {integrity: sha512-DRZ1yuWhYiiOZfbAiD9ifCVA7TiC8Wia4SfkJs5O8kCgbujF2nJrekEWUD6nzt9ivY8oT6Ve/eXfq/jK4CSq6g==}
+  /@coze/chat-sdk@0.1.11-beta.17(@types/react@18.2.37)(axios@1.10.0)(debug@4.3.3)(lodash-es@4.17.21)(react-dom@18.2.0)(react@18.2.0):
+    resolution: {integrity: sha512-nrev9w8IeW9mPqVhl4nT/8Z6fnaja4RlNqXj5e+MPjJugPTOw1brXuHTN2sVKUuFEsc5qse0U531qKJDg34zkA==}
     requiresBuild: true
     peerDependencies:
       axios: ^1.7.1
@@ -26133,7 +26133,6 @@ packages:
       micromark-extension-misc-radio-list-item: 2.1.0
       react: 18.2.0
       react-dom: 18.2.0(react@18.2.0)
-      xss: 1.0.15
       zustand: 4.5.7(@types/react@18.2.37)(immer@10.1.1)(react@18.2.0)
     transitivePeerDependencies:
       - '@types/react'
@@ -35369,7 +35368,7 @@ packages:
     resolution: {integrity: sha512-b3nLFGaGkJ9rzOcuXRfHkZMdjsawuDD0ENL9fzTophtBg8FJHSGbH7daXkEpcwy3v7Xol3pAvsmlYyFhR4pqJw==}
     dependencies:
       '@types/node': 18.18.9
-      '@types/unist': 3.0.3
+      '@types/unist': 2.0.11
       '@types/vfile-message': 2.0.0
     dev: true
 
@@ -38171,7 +38170,7 @@ packages:
       path-case: 3.0.4
       sentence-case: 3.0.4
       snake-case: 3.0.4
-      tslib: 2.8.1
+      tslib: 2.6.3
 
   /character-entities-html4@1.1.4:
     resolution: {integrity: sha512-HRcDxZuZqMx3/a+qrzxdBKBPUpxWEq9xw2OPZ3a/174ihfrQKVsFhqtthBInFy1zZ9GgZyFXOatNujm8M+El3g==}
@@ -49818,7 +49817,7 @@ packages:
     dependencies:
       '@types/react': 18.2.37
       react: 18.2.0
-      tslib: 2.8.1
+      tslib: 2.6.3
     dev: false
 
   /react-virtualized-auto-sizer@1.0.26(react-dom@18.2.0)(react@18.2.0):
@@ -53488,7 +53487,6 @@ packages:
 
   /tslib@2.6.3:
     resolution: {integrity: sha512-xNvxJEOUiWPGhUuUdQgAJPKOOJfGnIyKySOc09XkKsgdUV/3E2zvwZYdejjmRgPCgcym1juLH3226yA7sEFJKQ==}
-    dev: false
 
   /tslib@2.8.1:
     resolution: {integrity: sha512-oJFu94HQb+KVduSUQL7wnpmqnfmLsOA/nAh6b6EH0wCEoK0/mPeXU6c3wKDV83MkOuHPRHtSXKKU99IBazS/2w==}
@@ -55621,7 +55619,7 @@ packages:
       '@types/ws': 8.18.1
       ansi-html-community: 0.0.8
       bonjour-service: 1.3.0
-      chokidar: 3.6.0
+      chokidar: 3.5.3
       colorette: 2.0.19
       compression: 1.8.0
       connect-history-api-fallback: 2.0.0

docker/.env.example

@@ -4,9 +4,6 @@ export LOG_LEVEL="debug"
 export MAX_REQUEST_BODY_SIZE=1073741824
 export SERVER_HOST="localhost${LISTEN_ADDR}"
 export MINIO_PROXY_ENDPOINT=":8889"
-export USE_SSL="0"
-export SSL_CERT_FILE=""
-export SSL_KEY_FILE=""
 
 # MySQL
 export MYSQL_ROOT_PASSWORD=root
@@ -23,7 +20,6 @@ export REDIS_AOF_ENABLED=no
 export REDIS_IO_THREADS=4
 export ALLOW_EMPTY_PASSWORD=yes
 export REDIS_ADDR="localhost:6379"
-export REDIS_PASSWORD=""
 
 # This Upload component used in Agent / workflow File/Image With LLM  , support the component of imagex / storage
 # default: storage, use the settings of storage component
@@ -119,7 +115,6 @@ export OLLAMA_EMBEDDING_DIMS=""
 
 # http embedding
 export HTTP_EMBEDDING_ADDR="http://127.0.0.1:6543"
-export HTTP_EMBEDDING_DIMS=1024
 
 # Settings for OCR
 # If you want to use the OCR-related functions in the knowledge base feature，You need to set up the OCR configuration.

docker/docker-compose.yml

@@ -230,7 +230,7 @@ services:
           cp /opt/bitnami/elasticsearch/analysis-smartcn.zip /tmp/analysis-smartcn.zip 
 
           elasticsearch-plugin install file:///tmp/analysis-smartcn.zip
-          if [[ "$$?" != "0" ]]; then
+          if [[ "$?" != "0" ]]; then
             echo 'Plugin installation failed, exiting operation';
             rm -rf /opt/bitnami/elasticsearch/plugins/analysis-smartcn
             exit 1;
@@ -481,7 +481,7 @@ services:
       - -c
       - |
         set -ex
-        for i in $$(seq 1 60); do
+        for i in $(seq 1 60); do
           DB_HOST="$${MYSQL_HOST}"
           if [ "$${MYSQL_HOST}" = "localhost" ] || [ "$${MYSQL_HOST}" = "127.0.0.1" ]; then
             DB_HOST="mysql"

frontend/packages/studio/open-platform/open-chat/package.json

@@ -21,7 +21,7 @@
   },
   "dependencies": {
     "@coze-arch/i18n": "workspace:*",
-    "@coze/chat-sdk": "0.1.11-beta.19",
+    "@coze/chat-sdk": "0.1.11-beta.17",
     "react": "~18.2.0"
   },
   "devDependencies": {

helm/charts/opencoze/templates/NOTES.txt

@@ -5,22 +5,18 @@
   http{{ if $.Values.ingress.tls }}s{{ end }}://{{ $host.host }}{{ .path }}
   {{- end }}
 {{- end }}
-{{- else if contains "NodePort" .Values.cozeServer.service.type }}
+{{- else if contains "NodePort" .Values.service.type }}
   export NODE_PORT=$(kubectl get --namespace {{ .Release.Namespace }} -o jsonpath="{.spec.ports[0].nodePort}" services {{ include "opencoze.fullname" . }})
   export NODE_IP=$(kubectl get nodes --namespace {{ .Release.Namespace }} -o jsonpath="{.items[0].status.addresses[0].address}")
   echo http://$NODE_IP:$NODE_PORT
-{{- else if contains "LoadBalancer" .Values.cozeServer.service.type }}
+{{- else if contains "LoadBalancer" .Values.service.type }}
      NOTE: It may take a few minutes for the LoadBalancer IP to be available.
            You can watch its status by running 'kubectl get --namespace {{ .Release.Namespace }} svc -w {{ include "opencoze.fullname" . }}'
   export SERVICE_IP=$(kubectl get svc --namespace {{ .Release.Namespace }} {{ include "opencoze.fullname" . }} --template "{{"{{ range (index .status.loadBalancer.ingress 0) }}{{.}}{{ end }}"}}")
-  {{- range .Values.cozeServer.service.ports }}}
-  {{- if eq .name "http" }}
-  echo http://$SERVICE_IP:{{ .port }}
-  {{- end}}
-  {{- end}}
-{{- else if contains "ClusterIP" .Values.cozeServer.service.type }}
+  echo http://$SERVICE_IP:{{ .Values.service.port }}
+{{- else if contains "ClusterIP" .Values.service.type }}
   export POD_NAME=$(kubectl get pods --namespace {{ .Release.Namespace }} -l "app.kubernetes.io/name={{ include "opencoze.name" . }},app.kubernetes.io/instance={{ .Release.Name }}" -o jsonpath="{.items[0].metadata.name}")
   export CONTAINER_PORT=$(kubectl get pod --namespace {{ .Release.Namespace }} $POD_NAME -o jsonpath="{.spec.containers[0].ports[0].containerPort}")
-  echo "Visit http://127.0.0.1:{{ .Values.service.port}} to use your application"
+  echo "Visit http://127.0.0.1:8080 to use your application"
   kubectl --namespace {{ .Release.Namespace }} port-forward $POD_NAME 8080:$CONTAINER_PORT
 {{- end }}

helm/charts/opencoze/templates/elasticsearch-statefulset.yaml

@@ -81,9 +81,7 @@ spec:
       name: es-data
     spec:
       accessModes: [ "ReadWriteOnce" ]
-    {{- if .Values.elasticsearch.persistence.storageClassName }}
       storageClassName: {{ .Values.elasticsearch.persistence.storageClassName | quote }}
-    {{- end }}
       resources:
         requests:
           storage: {{ .Values.elasticsearch.persistence.size | quote }}

helm/charts/opencoze/templates/etcd-statefulset.yaml

@@ -53,9 +53,7 @@ spec:
         name: etcd-data
       spec:
         accessModes: [ "ReadWriteOnce" ]
-      {{- if .Values.etcd.persistence.storageClassName }}
         storageClassName: {{ .Values.etcd.persistence.storageClassName | quote }}
-      {{- end }}
         resources:
           requests:
             storage: {{ .Values.etcd.persistence.size | quote }}

helm/charts/opencoze/templates/milvus-statefulset.yaml

@@ -25,14 +25,7 @@ spec:
           securityContext:
             runAsUser: 0
           image: "{{ .Values.milvus.image.repository }}:{{ .Values.milvus.image.tag }}"
-          command:
-            - bash
-            - -c
-            - |
-              # Set proper permissions for data directories
-              chown -R root:root /var/lib/milvus
-              chmod g+s /var/lib/milvus
-              exec milvus run standalone
+          command: ["milvus", "run", "standalone"]
           env:
             - name: ETCD_ENDPOINTS
               value: "{{ include "opencoze.fullname" . }}-etcd:2379"
@@ -77,9 +70,7 @@ spec:
         name: milvus-data
       spec:
         accessModes: [ "ReadWriteOnce" ]
-      {{- if .Values.milvus.persistence.storageClassName }}
         storageClassName: {{ .Values.milvus.persistence.storageClassName | quote }}
-      {{- end }}
         resources:
           requests:
             storage: {{ .Values.milvus.persistence.size | quote }}

helm/charts/opencoze/templates/minio-statefulset.yaml

@@ -58,9 +58,7 @@ spec:
         name: minio-data
       spec:
         accessModes: [ "ReadWriteOnce" ]
-      {{- if .Values.minio.persistence.storageClassName }}
         storageClassName: {{ .Values.minio.persistence.storageClassName | quote }}
-      {{- end }}
         resources:
           requests:
             storage: {{ .Values.minio.persistence.size | quote }}

helm/charts/opencoze/templates/mysql-statefulset.yaml

@@ -55,9 +55,7 @@ spec:
         name: mysql-data
       spec:
         accessModes: [ "ReadWriteOnce" ]
-      {{- if .Values.mysql.persistence.storageClassName }}
         storageClassName: {{ .Values.mysql.persistence.storageClassName | quote }}
-      {{- end }}
         resources:
           requests:
             storage: {{ .Values.mysql.persistence.size | quote }}

helm/charts/opencoze/templates/redis-statefulset.yaml

@@ -42,9 +42,7 @@ spec:
         name: redis-data
       spec:
         accessModes: [ "ReadWriteOnce" ]
-      {{- if .Values.redis.persistence.storageClassName }}
         storageClassName: {{ .Values.redis.persistence.storageClassName | quote }}
-      {{- end }}
         resources:
           requests:
             storage: {{ .Values.redis.persistence.size | quote }}

helm/charts/opencoze/templates/rocketmq-broker-configmap.yaml

@@ -1,4 +1,3 @@
-{{- if and (eq (lower (default "rmq" .Values.cozeServer.env.COZE_MQ_TYPE)) "rmq") }}
 apiVersion: v1
 kind: ConfigMap
 metadata:
@@ -14,5 +13,4 @@ data:
     fileReservedTime = 48
     brokerRole = ASYNC_MASTER
     flushDiskType = ASYNC_FLUSH
-    brokerIP1 = __POD_IP__
-{{- end}}
+    brokerIP1 = __POD_IP__

helm/charts/opencoze/templates/rocketmq-broker-service.yaml

@@ -1,4 +1,4 @@
-{{- if and (eq (lower (default "rmq" .Values.cozeServer.env.COZE_MQ_TYPE)) "rmq") .Values.rocketmq.enabled }}
+{{- if .Values.rocketmq.enabled }}
 apiVersion: v1
 kind: Service
 metadata:

helm/charts/opencoze/templates/rocketmq-broker-statefulset.yaml

@@ -1,4 +1,4 @@
-{{- if and (eq (lower (default "rmq" .Values.cozeServer.env.COZE_MQ_TYPE)) "rmq") .Values.rocketmq.enabled }}
+{{- if .Values.rocketmq.enabled }}
 apiVersion: apps/v1
 kind: StatefulSet
 metadata:
@@ -111,9 +111,7 @@ spec:
         name: broker-store
       spec:
         accessModes: [ "ReadWriteOnce" ]
-      {{- if .Values.rocketmq.broker.persistence.store.storageClassName }}
         storageClassName: {{ .Values.rocketmq.broker.persistence.store.storageClassName | quote }}
-      {{- end }}
         resources:
           requests:
             storage: {{ .Values.rocketmq.broker.persistence.store.size | quote }}
@@ -121,9 +119,7 @@ spec:
         name: broker-logs
       spec:
         accessModes: [ "ReadWriteOnce" ]
-      {{- if .Values.rocketmq.broker.persistence.logs.storageClassName }}
         storageClassName: {{ .Values.rocketmq.broker.persistence.logs.storageClassName | quote }}
-      {{- end }}
         resources:
           requests:
             storage: {{ .Values.rocketmq.broker.persistence.logs.size | quote }}

helm/charts/opencoze/templates/rocketmq-namesrv-service.yaml

@@ -1,4 +1,4 @@
-{{- if and (eq (lower (default "rmq" .Values.cozeServer.env.COZE_MQ_TYPE)) "rmq") .Values.rocketmq.enabled }}
+{{- if .Values.rocketmq.enabled }}
 apiVersion: v1
 kind: Service
 metadata:

helm/charts/opencoze/templates/rocketmq-namesrv-statefulset.yaml

@@ -1,4 +1,4 @@
-{{- if and (eq (lower (default "rmq" .Values.cozeServer.env.COZE_MQ_TYPE)) "rmq") .Values.rocketmq.enabled }}
+{{- if .Values.rocketmq.enabled }}
 apiVersion: apps/v1
 kind: StatefulSet
 metadata:
@@ -56,9 +56,7 @@ spec:
         name: namesrv-store
       spec:
         accessModes: [ "ReadWriteOnce" ]
-      {{- if .Values.rocketmq.namesrv.persistence.store.storageClassName }}
         storageClassName: {{ .Values.rocketmq.namesrv.persistence.store.storageClassName | quote }}
-      {{- end }}
         resources:
           requests:
             storage: {{ .Values.rocketmq.namesrv.persistence.store.size | quote }}
@@ -66,9 +64,7 @@ spec:
         name: namesrv-logs
       spec:
         accessModes: [ "ReadWriteOnce" ]
-      {{- if .Values.rocketmq.namesrv.persistence.logs.storageClassName }}
         storageClassName: {{ .Values.rocketmq.namesrv.persistence.logs.storageClassName | quote }}
-      {{- end }}
         resources:
           requests:
             storage: {{ .Values.rocketmq.namesrv.persistence.logs.size | quote }}

helm/charts/opencoze/values-local.yaml

@@ -0,0 +1,45 @@
+mysql:
+  persistence:
+    storageClassName: "hostpath"
+
+redis:
+  persistence:
+    storageClassName: "hostpath"
+
+# -- coze-server configuration
+cozeServer:
+  env:
+    MINIO_ENDPOINT: "localhost:9000"
+
+
+rocketmq:
+  namesrv:
+    persistence:
+      store:
+        storageClassName: "hostpath"
+      logs:
+        storageClassName: "hostpath"
+  broker:
+    persistence:
+      store:
+        storageClassName: "hostpath"
+      logs:
+        storageClassName: "hostpath"
+
+elasticsearch:
+  persistence:
+    storageClassName: "hostpath"
+
+
+minio:
+  persistence:
+    storageClassName: "hostpath"
+
+etcd:
+  persistence:
+    storageClassName: "hostpath"
+
+milvus:
+  persistence:
+    storageClassName: "hostpath"
+

helm/charts/opencoze/values.yaml

@@ -14,7 +14,7 @@ mysql:
   user: coze
   password: coze123
   persistence:
-    storageClassName: ""
+    storageClassName: "opencoze-data"
     size: "50Gi"
   initScripts:
     - files/mysql/init.sql
@@ -31,7 +31,7 @@ redis:
   allowEmptyPassword: "yes"
   password: ""
   persistence:
-    storageClassName: ""
+    storageClassName: "opencoze-data"
     size: "50Gi"
 
 # -- coze-server configuration
@@ -41,9 +41,8 @@ cozeServer:
   replicaCount: 1
 
   image:
-    repository: opencoze/opencoze
-    # -- Keep the mirror up to date
-    pullPolicy: Always
+    repository: opencoze-cn-beijing.cr.volces.com/iac/opencoze
+    pullPolicy: IfNotPresent
     tag: 'latest'
 
   service:
@@ -107,10 +106,10 @@ rocketmq:
       tag: 5.3.2
     persistence:
       store:
-        storageClassName: ""
+        storageClassName: "opencoze-data"
         size: "20Gi"
       logs:
-        storageClassName: ""
+        storageClassName: "opencoze-data"
         size: "20Gi"
     resources:
       limits:
@@ -147,10 +146,10 @@ rocketmq:
       flushDiskType = ASYNC_FLUSH
     persistence:
       store:
-        storageClassName: ""
+        storageClassName: "opencoze-data"
         size: "20Gi"
       logs:
-        storageClassName: ""
+        storageClassName: "opencoze-data"
         size: "20Gi"
     resources:
       limits:
@@ -171,7 +170,7 @@ elasticsearch:
   password: ""
   persistence:
     enabled: true
-    storageClassName: ""
+    storageClassName: "opencoze-data"
     accessModes:
       - ReadWriteOnce
     size: 50Gi
@@ -193,7 +192,7 @@ minio:
     port: 9000
     consolePort: 9001
   persistence:
-    storageClassName: ""
+    storageClassName: "opencoze-data"
     size: "50Gi"
   resources:
     limits:
@@ -209,7 +208,7 @@ etcd:
     repository: bitnami/etcd
     tag: 3.5
   persistence:
-    storageClassName: ""
+    storageClassName: "opencoze-data"
     size: "20Gi"
 
 milvus:
@@ -219,7 +218,7 @@ milvus:
     tag: v2.5.10
   bucketName: milvus
   persistence:
-    storageClassName: ""
+    storageClassName: "opencoze-data"
     size: "20Gi"
 
 kibana: