// Package admin
// @Link  https://gitee.com/linngc/webos.gf
// @Copyright  Copyright (c) 2022 webos CLI
// @Author  linngc
// @License
package admin

import (
	"context"
	"gitee.com/linngc/center.gf/contrib/module/cachebuffer/clientv1"
	cachebuffervo "gitee.com/linngc/center.gf/contrib/module/cachebuffer/model/vo"
	"gitee.com/linngc/center.gf/contrib/plugins/xproxy/toolkit"
	"gitee.com/linngc/center.gf/internal/service/platform/admin"
	service "gitee.com/linngc/center.gf/internal/service/platform/system/basic"
	"github.com/gogf/gf/v2/frame/g"
)

type (
	sAdminConfig struct{}
)

// CacheModuleYaml 初始化[缓存模块]参数配置信息
func (s *sAdminConfig) CacheModuleYaml(ctx context.Context) (err error) {
	//1.从数据库中获取配置数据
	embedFs, err := service.SysParam().QueryToYaml(ctx, "center.cache.embedFs")
	nutsdb, err := service.SysParam().QueryToYaml(ctx, "center.cache.nutsdb")
	minioCos, err := service.SysParam().QueryToYaml(ctx, "center.cache.minioCos")
	qiniuCos, err := service.SysParam().QueryToYaml(ctx, "center.cache.qiniuCos")
	tencentCos, err := service.SysParam().QueryToYaml(ctx, "center.cache.tencentCos")
	//2.将数据解析成yaml对象
	embedFsYaml, err := embedFs.ToYamlString()
	nutsdbYaml, err := nutsdb.ToYamlString()
	minioCosYaml, err := minioCos.ToYamlString()
	qiniuCosYaml, err := qiniuCos.ToYamlString()
	tencentCosYaml, err := tencentCos.ToYamlString()
	//3.打印输出数据日志
	g.Log().Debug(ctx, "数据库加载[本地数据缓存模块]参数配置信息\n", embedFsYaml)
	g.Log().Debug(ctx, "数据库加载[持久化nutsdb存储模块]参数配置信息\n", nutsdbYaml)
	g.Log().Debug(ctx, "数据库加载[minioCos缓存模块]参数配置信息\n", minioCosYaml)
	g.Log().Debug(ctx, "数据库加载[qiniuCos缓存模块]参数配置信息\n", qiniuCosYaml)
	g.Log().Debug(ctx, "数据库加载[tencentCos缓存模块]参数配置信息\n", tencentCosYaml)
	//4.数据赋值
	clientv1.Stat.OnConfig(cachebuffervo.CacheUnmarshal{
		EmbedFs: embedFsYaml, Nutsdb: nutsdbYaml, MinioCos: minioCosYaml, QiniuCos: qiniuCosYaml, TencentCos: tencentCosYaml})

	return
}

// OnConfig 初始化[插件模块参数]配置信息
func (s *sAdminConfig) OnConfig(ctx context.Context) (err error) {
	//1.从数据库中获取配置数据
	alpine, err := service.SysParam().QueryToYaml(ctx, "center.mirrors.alpine")
	maven, err := service.SysParam().QueryToYaml(ctx, "center.proxy.maven")
	golang, err := service.SysParam().QueryToYaml(ctx, "center.proxy.golang")
	npm, err := service.SysParam().QueryToYaml(ctx, "center.proxy.npm")
	//2.将数据解析成yaml对象
	alpineYaml, err := alpine.ToYamlString()
	mavenYaml, err := maven.ToYamlString()
	golangYaml, err := golang.ToYamlString()
	npmYaml, err := npm.ToYamlString()
	//3.打印输出数据日志
	g.Log().Debug(ctx, "数据库加载[alpine]镜像服务模块参数配置信息\n", alpineYaml)
	g.Log().Debug(ctx, "数据库加载[Maven]代理模块参数配置信息\n", mavenYaml)
	g.Log().Debug(ctx, "数据库加载[Golang]代理模块参数配置信息\n", golangYaml)
	g.Log().Debug(ctx, "数据库加载[npm]代理模块参数配置信息\n", npmYaml)
	//4.数据赋值
	//初始化 镜像服务模块 参数配置信息
	//alpinetoolkit.OnConfig(alpineYaml)
	//初始化 代理模块 参数配置信息
	toolkit.MavenOnConfig(mavenYaml)
	toolkit.GolangOnConfig(golangYaml)
	toolkit.NpmOnConfig(npmYaml)
	return
}

func init() {
	admin.RegisterAdminConfig(NewAdminConfig())
}

func NewAdminConfig() *sAdminConfig {
	return &sAdminConfig{}
}