ai-agent/internal/middleware/chat_middleware.go

package middleware

import (
	"cs-agent/internal/pkg/irisx"
	"cs-agent/internal/services"

	"github.com/kataras/iris/v12"
	"github.com/mlogclub/simple/web"
)

func ExternalUserMiddleware(ctx iris.Context) {
	channel := services.ChannelService.GetEnabledChannel(ctx)
	if channel == nil {
		ctx.StopExecution()
		_ = ctx.JSON(web.JsonErrorMsg("接入渠道异常"))
		return
	}
	result, err := services.CustomerSessionService.VerifyRequest(ctx, channel)
	if err != nil {
		ctx.StopExecution()
		_ = ctx.JSON(web.JsonError(err))
		return
	}
	services.CustomerSessionService.SetRefreshHeaders(ctx, result)
	irisx.SetExternalUser(ctx, result.ExternalUser)
	ctx.Next()
}