Method ServiceHandleSSE

controller/mcp/iml.go:219–239

(ctx *gin.Context)

}

func (i *imlMcpController) ServiceHandleSSE(ctx *gin.Context) {
	apikey := ctx.Request.URL.Query().Get("apikey")
	serviceId := ctx.Param("serviceId")
	if serviceId == "" {
		ctx.AbortWithStatusJSON(403, gin.H{"code": -1, "msg": "invalid service id", "success": "fail"})
		return
	}
	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
	}

	i.handleSSE(ctx, mcp_server.DefaultMCPServer(), SessionInfo{
		Apikey: apikey,
	})
}

func (i *imlMcpController) ServiceHandleMessage(ctx *gin.Context) {
	i.handleMessage(ctx, mcp_server.DefaultMCPServer())