before.go

package pluginflow

import (
	log "github.com/eolinker/goku-api-gateway/goku-log"
	"github.com/eolinker/goku-api-gateway/goku-node/common"
	plugin_manager "github.com/eolinker/goku-api-gateway/goku-node/manager/plugin-manager"
	"reflect"
	"time"
)

//BeforeMatch 执行插件的BeforeMatch函数
func BeforeMatch(ctx *common.Context) bool {
	requestID := ctx.RequestId()
	defer func(ctx *common.Context) {
		log.Debug(requestID, " before plugin default: begin")
		for _, handler := range plugin_manager.GetDefaultPlugins() {
			if handler.PluginObj.BeforeMatch == nil || reflect.ValueOf(handler.PluginObj.BeforeMatch).IsNil() {
				continue
			}
			ctx.SetPlugin(handler.Name)
			log.Debug(requestID, " before plugin :", handler.Name, " start")
			now := time.Now()
			_, err := handler.PluginObj.BeforeMatch.BeforeMatch(ctx)
			log.Debug(requestID, " before plugin :", handler.Name, " Duration:", time.Since(now))
			log.Debug(requestID, " before plugin :", handler.Name, " end")
			if err != nil {
				log.Warn(requestID, " before plugin:", handler.Name, " error:", err.Error())
			}
		}
		log.Debug(requestID, " before plugin default: end")
	}(ctx)
	log.Debug(requestID, " before plugin : begin")
	for _, handler := range plugin_manager.GetBeforPlugins() {

		if handler.PluginObj.BeforeMatch == nil || reflect.ValueOf(handler.PluginObj.BeforeMatch).IsNil() {
			continue
		}

		ctx.SetPlugin(handler.Name)
		log.Debug(requestID, " before plugin :", handler.Name, " start")
		now := time.Now()
		flag, err := handler.PluginObj.BeforeMatch.BeforeMatch(ctx)
		log.Debug(requestID, " before plugin :", handler.Name, " Duration:", time.Since(now))
		log.Debug(requestID, " before plugin :", handler.Name, " end")

		if err != nil {
			log.Warn(requestID, " before plugin:", handler.Name, " error:", err.Error())
		}
		if flag == false {
			if handler.IsStop == true {
				return false
			}
		}
	}
	log.Debug(requestID, " before plugin : end")
	return true
}