package gateway

const (
	ProfessionOutput      = "output"
	ProfessionCertificate = "certificate"
	ProfessionRouter      = "router"
	ProfessionApplication = "app"
	ProfessionStrategy    = "strategy"
	ProfessionService     = "service"
	ProfessionAIProvider  = "ai-provider"
	ProfessionAIResource  = "ai-resource"
)

func RegisterDynamicResourceDriver(key string, worker Worker) {
	dynamicResourceMap[key] = worker
}

func GetDynamicResourceDriver(key string) (Worker, bool) {
	v, ok := dynamicResourceMap[key]
	return v, ok
}

var dynamicResourceMap = map[string]Worker{
	"service": {
		Profession: ProfessionService,
		Driver:     "http",
	},
	"file-access-log": {
		Profession: ProfessionOutput,
		Driver:     "file",
	},
	"http-access-log": {
		Profession: ProfessionOutput,
		Driver:     "http_output",
	},
	"nsqd-access-log": {
		Profession: ProfessionOutput,
		Driver:     "nsqd",
	},
	"syslog-access-log": {
		Profession: ProfessionOutput,
		Driver:     "syslog_output",
	},
	"kafka-access-log": {
		Profession: ProfessionOutput,
		Driver:     "kafka_output",
	},
	"influxdbv2": {
		Profession: ProfessionOutput,
		Driver:     "influxdbv2",
	},
	"redis": {
		Profession: ProfessionOutput,
		Driver:     "redis",
	},
	// 证书
	"certificate": {
		Profession: ProfessionCertificate,
		Driver:     "server",
	},
	"loki": {
		Profession: ProfessionOutput,
		Driver:     "loki",
	},
	"ai-provider": {
		Profession: ProfessionAIResource,
		Driver:     "ai-provider",
	},
	"ai-key": {
		Profession: ProfessionAIResource,
		Driver:     "ai-key",
	},
}

type Worker struct {
	Profession string
	Driver     string
}