router.go 1.98 KB
Newer Older
qiuqunfeng's avatar
qiuqunfeng committed
1 2 3 4 5 6 7
package api

import (
	"io"
	"net/http"

	"github.com/gin-gonic/gin"
qiuqunfeng's avatar
qiuqunfeng committed
8
	"github.com/rs/zerolog/log"
qiuqunfeng's avatar
qiuqunfeng committed
9 10 11 12 13
	"gitlab.com/tensorsecurity-rd/waf-console/internal/config"
	"gitlab.com/tensorsecurity-rd/waf-console/internal/utils"
	"gorm.io/gorm"
)

qiuqunfeng's avatar
qiuqunfeng committed
14
func SetRouters(db *gorm.DB, clusterClientManager *utils.ClusterClientManager) *gin.Engine {
qiuqunfeng's avatar
qiuqunfeng committed
15 16 17 18
	var engine *gin.Engine

	if !config.Conf.Debug {
		// 生产模式
qiuqunfeng's avatar
qiuqunfeng committed
19
		log.Info().Msg("release mode")
qiuqunfeng's avatar
qiuqunfeng committed
20 21 22 23 24 25 26 27 28
		engine = ReleaseRouter()
		engine.Use(
		// middleware.RequestCostHandler(),
		// middleware.CustomLogger(),
		// middleware.CustomRecovery(),
		// middleware.CorsHandler(),
		)
	} else {
		// 开发调试模式
qiuqunfeng's avatar
qiuqunfeng committed
29
		log.Info().Msg("debug mode")
qiuqunfeng's avatar
qiuqunfeng committed
30 31 32 33 34 35 36 37 38
		engine = gin.New()
		engine.Use(
			// middleware.RequestCostHandler(),
			gin.Logger(),
			// middleware.CustomRecovery(),
			// middleware.CorsHandler(),
		)
	}
	// set up trusted agents
qiuqunfeng's avatar
config  
qiuqunfeng committed
39
	err := engine.SetTrustedProxies([]string{"127.0.0.1"})
qiuqunfeng's avatar
qiuqunfeng committed
40 41 42 43 44 45 46 47 48 49 50 51 52 53
	if err != nil {
		panic(err)
	}
	// ping
	engine.GET("/ping", func(c *gin.Context) {
		c.AbortWithStatusJSON(http.StatusOK, gin.H{
			"message": "pong!",
		})
	})

	// 设置 API 路由
	// SetIPInforRouter(engine)
	// loadkubeConfig()
	// clientcmd.LoadFromFile("kubeconfig.yaml")
qiuqunfeng's avatar
fix  
qiuqunfeng committed
54 55 56 57 58 59 60 61 62 63
	// client := versioned.NewForConfigOrDie(&rest.Config{
	// 	Host: "https://127.0.0.1:6443",
	// 	TLSClientConfig: rest.TLSClientConfig{
	// 		Insecure: false,
	// 		CAData:   []byte(""),
	// 		CertData: []byte(""),
	// 		KeyData:  []byte(""),
	// 	},
	// 	// BearerToken: "1234567890",
	// })
qiuqunfeng's avatar
qiuqunfeng committed
64
	SetWafRouter(engine, clusterClientManager, db)
qiuqunfeng's avatar
qiuqunfeng committed
65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85

	// 统一处理 404
	engine.NoRoute(func(c *gin.Context) {
		utils.AssembleResponse(c, nil, err)
		// response2.Resp().SetHttpCode(http.StatusNotFound).FailCode(c, errors.NotFound)
	})

	return engine
}

// ReleaseRouter 生产模式使用官方建议设置为 release 模式
func ReleaseRouter() *gin.Engine {
	// 切换到生产模式
	gin.SetMode(gin.ReleaseMode)
	// 禁用 gin 输出接口访问日志
	gin.DefaultWriter = io.Discard

	engine := gin.New()

	return engine
}