Sync gitlab commit from 2025-11-03 to 2025-11-04

.gitignore

@@ -1,26 +1,46 @@
 # Binaries
 bin
+
 .vscode
+.zed
+.idea
+.trae
+
 .DS_Store
 .envrc
-.idea/
-
+.codesouler
 /gitea
 /pgdata
 minio_data
 local_only
 /jetstream
 .env
-*.sh
+memory
+docker-compose-leida.yml
+run_account_local.sh
+run_callback_local.sh
+run_deploy_runner_local.sh
+run_rproxy_local.sh
+run_server_local.sh
+run_user_local.sh
+run_aigateway_local.sh
+run_server_my_local.sh
+run_payment_local.sh
 cmd/csghub-server/__debug_*
+run_dataviewer_local.sh
+run_notification_local.sh
+local.toml
+loki-config.yml
 
 .data
+/data
 */*/_api_test/
 redis/dump.rdb
-run_server_local.sh
 
 **/loki-data/
 **/tempo-data/
 docs/swagger.json
 docs/swagger.yaml
 docs/docs.go
+pgdata15/
+

aigateway/router/aigateway.go

@@ -3,6 +3,9 @@ package router
 import (
 	"fmt"
 
+	"opencsg.com/csghub-server/builder/instrumentation"
+
+	"github.com/gin-contrib/cors"
 	"github.com/gin-gonic/gin"
 	"opencsg.com/csghub-server/aigateway/handler"
 	"opencsg.com/csghub-server/api/middleware"
@@ -11,36 +14,53 @@ import (
 
 func NewRouter(config *config.Config) (*gin.Engine, error) {
 	r := gin.New()
-	r.Use(gin.Recovery())
-	r.Use(middleware.Log(config))
+	middleware.SetInfraMiddleware(r, config, instrumentation.Aigateway)
+	r.Use(cors.New(cors.Config{
+		AllowCredentials: true,
+		AllowHeaders:     []string{"*"},
+		AllowMethods:     []string{"*"},
+		AllowAllOrigins:  true,
+	}))
 	//to access model,fintune with any kind of tokens in auth header
 	r.Use(middleware.Authenticator(config))
-	mustLogin := middleware.MustLogin()
+	middlewareCollection := middleware.MiddlewareCollection{}
+	middlewareCollection.Auth.NeedLogin = middleware.MustLogin()
+	middlewareCollection.Auth.NeedPhoneVerified = middleware.NeedPhoneVerified(config)
 
 	v1Group := r.Group("/v1")
 
 	openAIhandler, err := handler.NewOpenAIHandlerFromConfig(config)
 	if err != nil {
 		return nil, fmt.Errorf("error creating openai handler :%w", err)
 	}
-	v1Group.GET("/models", mustLogin, openAIhandler.ListModels)
-	v1Group.GET("/models/:model", mustLogin, openAIhandler.GetModel)
-	v1Group.POST("/chat/completions", mustLogin, openAIhandler.Chat)
-	v1Group.POST("/embeddings", mustLogin, openAIhandler.Embedding)
+	v1Group.GET("/models", middlewareCollection.Auth.NeedLogin, openAIhandler.ListModels)
+	v1Group.GET("/models/:model", middlewareCollection.Auth.NeedLogin, openAIhandler.GetModel)
+	v1Group.POST("/chat/completions", middlewareCollection.Auth.NeedLogin, openAIhandler.Chat)
+	v1Group.POST("/embeddings", middlewareCollection.Auth.NeedLogin, openAIhandler.Embedding)
 
 	mcpProxy, err := handler.NewMCPProxyHandler(config)
 	if err != nil {
 		return nil, fmt.Errorf("error creating mcp proxy handler :%w", err)
 	}
-	CreateMCPRoute(v1Group, mcpProxy)
+	createMCPRoute(v1Group, mcpProxy)
+
+	agentProxy, err := handler.NewAgentProxyHandler(config)
+	if err != nil {
+		return nil, fmt.Errorf("error creating agent proxy handler :%w", err)
+	}
+	createAgentRoute(v1Group, agentProxy, middlewareCollection)
 	return r, nil
 }
 
-func CreateMCPRoute(v1Group *gin.RouterGroup, mcpProxy handler.MCPProxyHandler) {
+func createMCPRoute(v1Group *gin.RouterGroup, mcpProxy handler.MCPProxyHandler) {
 	mcpGroup := v1Group.Group("mcp")
 	mcpGroup.GET("/servers", mcpProxy.List)
 
 	// todo: enable mcp server proxy later
-	// mcpGroup.GET("/:servicename/sse", mcpProxy.ProxyToApi("/sse"))
-	// mcpGroup.Any("/:servicename/messages/", mcpProxy.ProxyToApi("/messages/"))
+	mcpGroup.Any("/:servicename/*any", mcpProxy.ProxyToApi(""))
+}
+
+func createAgentRoute(v1Group *gin.RouterGroup, agentProxy handler.AgentProxyHandler, middlewareCollection middleware.MiddlewareCollection) {
+	agentGroup := v1Group.Group("/agent", middlewareCollection.Auth.NeedPhoneVerified)
+	agentGroup.Any("/:type/*any", agentProxy.ProxyToApi("/api/v1%s", "any"))
 }