Method ServiceHandleStreamHTTP

controller/mcp/iml.go:245–266

(ctx *gin.Context)

}

func (i *imlMcpController) ServiceHandleStreamHTTP(ctx *gin.Context) {
	apikey := ctx.Request.Header.Get("Authorization")
	serviceId := ctx.Request.Header.Get("X-Service-Id")
	if serviceId == "" {
		ctx.AbortWithStatusJSON(403, gin.H{"code": -1, "msg": "invalid service id", "success": "fail"})
		return
	}
	apikey = strings.TrimPrefix(apikey, "Bearer ")
	ok, err := i.authorizationModule.CheckAPIKeyAuthorizationByService(ctx, serviceId, apikey)
	if err != nil {
		ctx.AbortWithStatusJSON(403, gin.H{"code": -1, "msg": err.Error(), "success": "fail"})
		return
	}
	if !ok {
		ctx.AbortWithStatusJSON(403, gin.H{"code": -1, "msg": "invalid apikey", "success": "fail"})
		return
	}
	cfg := i.settingModule.Get(ctx)
	req := ctx.Request.WithContext(utils.SetGatewayInvoke(ctx.Request.Context(), cfg.InvokeAddress))
	req = req.WithContext(utils.SetLabel(req.Context(), "apikey", apikey))
	mcp_server.DefaultMCPServer().ServeHTTP(ctx.Writer, req)
}

func (i *imlMcpController) handleMessage(ctx *gin.Context, server http.Handler) {
	sessionId := ctx.Request.URL.Query().Get("sessionId")