From b41a60a932935b23478c601f16d06d77cd0dd167 Mon Sep 17 00:00:00 2001 From: ZhuoQinghui <1302344380@qq.com> Date: Mon, 17 Feb 2025 11:31:52 +0800 Subject: [PATCH] =?UTF-8?q?=E6=95=B4=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/command.go | 82 --------------- src/config.go | 267 ------------------------------------------------ src/daemon.go | 269 ------------------------------------------------- src/http.go | 145 -------------------------- src/task.go | 86 ---------------- 5 files changed, 849 deletions(-) delete mode 100644 src/command.go delete mode 100644 src/config.go delete mode 100644 src/daemon.go delete mode 100644 src/http.go delete mode 100644 src/task.go diff --git a/src/command.go b/src/command.go deleted file mode 100644 index 6de28b4..0000000 --- a/src/command.go +++ /dev/null @@ -1,82 +0,0 @@ -package src - -//import ( -// "log" -// "net" -// "os" -//) -// -//// InitSocket 初始化 socket 文件 -//func InitSocket() { -// log.Println("Start listen command") -// // 删除旧的 socket 文件 -// if _, err := os.Stat(SocketFile); err == nil { -// os.Remove(SocketFile) -// } -// -// listener, err := net.Listen("unix", SocketFile) -// if err != nil { -// log.Fatalf("Failed to listen on socket: %v", err) -// } -// defer listener.Close() -// -// for { -// log.Println("Waiting for connections...") -// conn, err := listener.Accept() -// if err != nil { -// log.Printf("Failed to accept connection: %v", err) -// continue -// } -// -// go handleConnection(conn) -// } -//} -// -///* -//* -//处理连接 -//*/ -//func handleConnection(conn net.Conn) { -// defer conn.Close() -// -// buf := make([]byte, 1024) -// n, err := conn.Read(buf) -// if err != nil { -// log.Printf("Failed to read command: %v", err) -// return -// } -// -// command := string(buf[:n]) -// log.Printf("Received command: %s", command) -// -// // 在这里处理接收到的命令 -// switch command { -// case "stop": -// onStop() -// default: -// onCommand(command) -// } -//} -// -///* -//* -//收到停止命令 -//*/ -//func onStop() { -// log.Println("Stopping daemon...")// os.Remove(PidFile) -// log.Println("Remove PID File...") -// os.Remove(SocketFile) -// log.Println("Remove Socket File...") -// os.Exit(0) -//} -// -///* -//收到命令 -//*/ -//func onCommand(command string) { -// -//} -// -//func onConfig() { -// -//} diff --git a/src/config.go b/src/config.go deleted file mode 100644 index 72d6a92..0000000 --- a/src/config.go +++ /dev/null @@ -1,267 +0,0 @@ -package src - -//import ( -// "acme-mana/src/crypto" -// "bufio" -// "fmt" -// "github.com/go-acme/lego/v4/log" -// "github.com/go-acme/lego/v4/platform/config/env" -// "gopkg.in/yaml.v3" -// "os" -// "strings" -//) -// -//func ReadConfig() *AppConfig { -// if DnsProviderSupports != nil { -// return nil -// } -// InitConfig() -// file, err := os.ReadFile(GetEnvConf().ConfFile) -// if err != nil { -// log.Fatal(err) -// } -// var conf *AppConfig -// err = yaml.Unmarshal(file, &conf) -// if err != nil { -// log.Fatal(err) -// } -// return conf -//} -// -//func InitConfig() { -// // 判断当前目录下是否存在配置文件 config.yml -// _, err := os.Stat(GetEnvConf().ConfFile) -// -// if os.IsNotExist(err) { -// // 配置文件不存在，则创建一个 -// log.Infof("配置文件不存在，自动创建默认配置文件") -// // 生成默认配置 -// conf := readNewConf() -// // 创建一个默认的配置文件 -// file, err := os.Create(GetEnvConf().ConfFile) -// if err != nil { -// log.Fatal(err) -// } -// data, err := yaml.Marshal(conf) -// if err != nil { -// log.Fatal(err) -// } -// // 写入配置文件 -// _, err = file.Write(data) -// if err != nil { -// log.Fatal(err) -// } -// } -// -//} -// -//func readNewConf() *AppConfig { -// conf := defaultConf() -// log.Println("无配置文件, 生成配置文件") -// -// conf.CertDir = scanConfDefault("请输入证书保存目录; 默认为 cert", "cert") -// isGenMsg := "是否需要自动生成用于数据传输加密的RSA密钥对? \n请输入yes(Y)/no(N) 默认为 yes" -// isGenErrMsg := "请输入yes(Y)/no(N)" -// isGenValues := []string{"yes", "no", "Y", "N"} -// isGenEncrypt := scanConfDefaultCheck(isGenMsg, "yes", isGenValues, isGenErrMsg) -// if isGenEncrypt == "no" || isGenEncrypt == "N" { -// conf.Encrypt.PriKey = scanConf("请输入RSA私钥", "请输入RSA私钥") -// conf.Encrypt.PubKey = scanConf("请输入RSA公钥", "请输入RSA公钥") -// } -// -// msg := fmt.Sprintf("请输入DNS提供商; 当前支持的: %s", strings.Join(DnsProviderSupports, ",")) -// errMsg := fmt.Sprintf("不支持的DNS提供商; 当前支持的: %s", strings.Join(DnsProviderSupports, ",")) -// conf.Use = scanConfDefaultCheck(msg, "", DnsProviderSupports, errMsg) -// switch conf.Use { -// case "alidns": -// fmt.Printf("阿里云DNS配置帮助页: \n%s\n", "https://go-acme.github.io/lego/dns/alidns/index.html") -// fmt.Printf("阿里云令牌获取方式:\n%s\n", "https://usercenter.console.aliyun.com/#/manage/ak") -// fmt.Printf("阿里云SDK客户端项目地址:\n%s\n", "https://github.com/aliyun/alibaba-cloud-sdk-go?tab=readme-ov-file") -// conf.Provider.Ali.RegionID = scanConf("请输入阿里云Region ID", "请输入阿里云Region ID") -// conf.Provider.Ali.APIKey = scanConf("请输入阿里云API Key", "请输入阿里云API Key") -// conf.Provider.Ali.SecretKey = scanConf("请输入阿里云Secret Key", "请输入阿里云Secret Key") -// case "tencentcloud": -// fmt.Printf("腾讯云DNS配置帮助页: \n%s\n", "https://go-acme.github.io/lego/dns/tencentcloud/index.html") -// fmt.Printf("腾讯云令牌获取方式: \n%s\n", "https://console.cloud.tencent.com/cam/capi") -// fmt.Printf("腾讯云SDK客户端项目地址: \n%s\n", "https://github.com/tencentcloud/tencentcloud-sdk-go?tab=readme-ov-file") -// conf.Provider.Tencent.SecretId = scanConf("请输入腾讯云Secret Id", "请输入腾讯云Secret Id") -// conf.Provider.Tencent.SecretKey = scanConf("请输入腾讯云Secret Key", "请输入腾讯云Secret Key") -// case "cloudflare": -// fmt.Printf("Cloudflare DNS配置帮助页: \n%s\n", "https://go-acme.github.io/lego/dns/tencentcloud/index.html") -// fmt.Printf("Cloudflare 令牌获取方式: \n%s\n", "https://blog.cloudflare.com/zh-cn/api-tokens-general-availability/") -// fmt.Printf("Cloudflare SDK客户端项目地址: \n%s\n", "https://github.com/cloudflare/cloudflare-go") -// conf.Provider.CloudFlare.Token = scanConf("请输入CloudFlare DNS API Token", "请输入CloudFlare Token") -// } -// isAddDomainMsg := "是否需要添加证书获取配置?\n您可以在此处通过控制台交互添加;也可以在配置文件创建后,直接修改配置文件.\n请输入yes(Y)/no(N) 默认为 yes" -// isAddDomain := scanConfDefaultCheck(isAddDomainMsg, "yes", isGenValues, isGenErrMsg) -// if isAddDomain == "no" || isAddDomain == "N" { -// fmt.Printf("您可以通过手动修改%s文件, 调整证书获取配置.", GetEnvConf().ConfFile) -// conf.Domains = []Domain{} -// return conf -// } -// conf.Domains = []Domain{} -// for { -// name := scanConf("请输入配置名称", "配置名称不能为空") -// email := scanConf("请输入邮箱", "邮箱不能为空") -// host := scanConf("请输入主机名;支持泛解析;\n支持多个域名,多个域名用,(英文逗号)分割;\n如: example.com,*.example.com\n", "主机名不能为空") -// // 将host通过,分割为数组 -// hosts := strings.Split(host, ",") -// conf.Domains = append(conf.Domains, Domain{ -// Name: name, -// Email: email, -// Host: hosts, -// }) -// isAddNextDomainMsg := "是否需要继续添加证书获取配置?\n请输入yes(Y)/no(N) 默认为 yes" -// isAddNextDomain := scanConfDefaultCheck(isAddNextDomainMsg, "yes", isGenValues, isGenErrMsg) -// if isAddNextDomain == "no" || isAddNextDomain == "N" { -// fmt.Printf("您后续可以通过手动修改%s文件, 调整证书获取配置.", GetEnvConf().ConfFile) -// return conf -// } -// } -//} -// -//// 读取用户输入 -//func scanConf(msg string, errMsg string) string { -// for { -// log.Println(msg) -// reader := bufio.NewReader(os.Stdin) -// name, err := reader.ReadString('\n') -// if err != nil { -// fmt.Println("读取失败;", err) -// continue -// } -// name = strings.Trim(name, "\r\n") -// if name == "" { -// fmt.Println(errMsg) -// continue -// } -// return name -// } -//} -// -//func scanConfDefault(msg string, defaultContent string) string { -// for { -// log.Println(msg) -// reader := bufio.NewReader(os.Stdin) -// name, err := reader.ReadString('\n') -// if err != nil { -// fmt.Println("读取失败;", err) -// continue -// } -// name = strings.Trim(name, "\r\n") -// if name == "" { -// return defaultContent -// } -// return name -// } -//} -// -//func scanConfDefaultCheck(msg string, defaultContent string, values []string, errMsg string) string { -// for { -// content := scanConfDefault(msg, defaultContent) -// // 判断内容是否在values中 -// for _, value := range values { -// if value == content { -// return content -// } -// } -// log.Println(errMsg) -// } -//} -// -//func defaultConf() *AppConfig { -// //priKey, pubKey, err := GenRsa() -// priKey, pubKey, err := crypto.GenRSA() -// if err != nil { -// log.Fatal(err) -// } -// return &AppConfig{ -// Use: "Ali", -// CertDir: "cert", -// Provider: AppProvider{ -// Ali: AliProvider{ -// RegionID: "cn-hangzhou", -// APIKey: "api_key", -// SecretKey: "secret_key", -// }, -// Tencent: TencentProvider{ -// SecretId: "secret_id", -// SecretKey: "secret_key", -// }, -// CloudFlare: CloudFlareProvider{ -// Token: "token", -// }, -// }, -// Domains: []Domain{ -// { -// Name: "example.com", -// Email: "email@example.com", -// Host: []string{"www.example.com"}, -// }, -// }, -// Encrypt: Encrypt{ -// PriKey: priKey, -// PubKey: pubKey, -// }, -// } -//} -// -//type AppConfig struct { -// Use string -// -// CertDir string -// -// Provider AppProvider -// -// Domains []Domain -// -// Encrypt Encrypt -//} -// -//type AppProvider struct { -// Ali AliProvider -// Tencent TencentProvider -// CloudFlare CloudFlareProvider -//} -//type AliProvider struct { -// RegionID string -// APIKey string -// SecretKey string -//} -//type TencentProvider struct { -// SecretId string -// SecretKey string -//} -//type CloudFlareProvider struct { -// Token string -//} -//type Domain struct { -// Name string -// Email string -// Host []string -//} -//type Encrypt struct { -// PriKey string -// PubKey string -//} -// -//func (conf AppConfig) FindDomain(name string) *Domain { -// for _, domain := range conf.Domains { -// if domain.Name == name { -// return &domain -// } -// } -// return nil -//} -// -//const ENV_CONF_FILE = "ACME_MANA_CONF_FILE" -// -//func InitRuntimeConf() *EnvConf { -// return &EnvConf{ -// ConfFile: env.GetOrDefaultString(ENV_CONF_FILE, "config.yml"), -// } -//} -// -//type EnvConf struct { -// ConfFile string -//} diff --git a/src/daemon.go b/src/daemon.go deleted file mode 100644 index b36ec91..0000000 --- a/src/daemon.go +++ /dev/null @@ -1,269 +0,0 @@ -package src - -//import ( -// "encoding/json" -// "log" -// "net" -// "os" -// "os/exec" -// "path" -// "path/filepath" -// "strconv" -// "syscall" -//) -// -//var stdout *os.File -//var stderr *os.File -// -//// Start 启动/* -//func Start() { -// initLog() -// args := os.Args -// if len(args) <= 1 { -// //daemonStart() -// doTask() -// return -// } -// command := args[1] -// switch command { -// case "help": -// showHelp() -// case "block": -// doTask() -// case "start": -// daemonStart() -// case "stop": -// daemonStop() -// case "status": -// daemonStatus() -// case "dump": -// dumpConfig() -// case "domains": -// showDomains() -// case "pubkey": -// showPubkey() -// case "apply": -// applyOnce() -// case "-s": -// daemonCommand() -// default: -// log.Fatalf("Unknown command: %s", command) -// } -//} -// -//// 初始化日志文件 -//func initLog() { -// pwd, err := os.Getwd() -// if err != nil { -// log.Fatalf("Failed to get current working directory: %v", err) -// } -// dir := path.Join(pwd, "log") -// _, err = os.Stat(dir) -// if os.IsNotExist(err) { -// err := os.Mkdir(dir, 0777) -// if err != nil { -// log.Fatalf("Failed to create directory: %v", err) -// } -// } -// outFile, err := os.OpenFile(path.Join(dir, "out.log"), os.O_CREATE|os.O_APPEND|os.O_WRONLY, 0644) -// defer outFile.Close() -// stdout = outFile -// -// errFile, err := os.OpenFile(path.Join(dir, "err.log"), os.O_CREATE|os.O_APPEND|os.O_WRONLY, 0644) -// defer stderr.Close() -// stderr = errFile -//} -// -//func showHelp() { -//} -// -//// 守护进程启动 -//func daemonStart() { -// GetAppConfig() -// isDaemon := os.Getenv("GO_DAEMON") -// log.Println("Run Daemon, DAEMON Is " + isDaemon) -// if isDaemon != "1" { -// // 直接启动 -// if isRunning() { -// log.Println("Daemon is already running.") -// return -// } -// -// workPath, err := os.Executable() -// if err != nil { -// log.Fatalf("Failed to get executable path: %v", err) -// } -// cmd := exec.Cmd{ -// Path: workPath, -// Args: os.Args, -// Dir: filepath.Dir(workPath), -// Env: append(os.Environ(), "GO_DAEMON=1"), -// //Stdin: os.Stdin, -// Stdout: stdout, -// Stderr: stderr, -// //Stdin: os.Stdin, -// //Stdout: os.Stdout, -// //Stderr: os.Stderr, -// SysProcAttr: &syscall.SysProcAttr{}, -// } -// -// log.Println("Starting daemon...") -// err = cmd.Start() -// if err != nil { -// log.Fatalf("Failed to start daemon: %v", err) -// } -// err = os.WriteFile(PidFile, []byte(strconv.Itoa(cmd.Process.Pid)), 0644) -// if err != nil { -// log.Fatalf("Failed to write PID file: %v", err) -// } -// log.Printf("Daemon started with PID: %d", cmd.Process.Pid) -// os.Exit(0) -// -// } else { -// // 子进程 -// doTask() -// } -// -//} -// -//// 守护进程停止 -//func daemonStop() { -// sendCommand("stop") -//} -// -//// 守护进程状态 -//func daemonStatus() { -// if isRunning() { -// log.Println("Daemon is running.") -// } else { -// log.Println("Daemon is not running.") -// } -//} -// -//// 输出配置文件 -//func dumpConfig() { -// //config, err := json.Marshal(GetAppConfig()) -// config, err := json.MarshalIndent(GetAppConfig(), "", " ") -// if err != nil { -// log.Fatalf("Failed to marshal config: %v", err) -// } -// log.Println(string(config)) -//} -// -//// 手动执行一次证书申请 -//func applyOnce() { -// if len(os.Args) < 3 { -// log.Fatalf("Please enter domain name!") -// } -// name := os.Args[2] -// if name == "" { -// log.Fatalf("No domain specified!") -// } -// domain := GetAppConfig().FindDomain(name) -// if domain == nil { -// log.Fatalf("Domain not found: %s", name) -// } -// Apply(*domain) -//} -// -//// 输出域名列表 -//func showDomains() { -// domains := GetAppConfig().Domains -// // 格式化为json并打印 -// config, err := json.MarshalIndent(domains, "", " ") -// if err != nil { -// log.Fatalf("Failed to marshal config: %v", err) -// } -// log.Println(string(config)) -//} -// -//// 输出公钥 -//func showPubkey() { -// key := GetAppConfig().Encrypt.PubKey -// log.Println(key) -//} -// -//// 守护进程接收命令 -//func daemonCommand() { -// log.Println("Sending command...") -// command := os.Args[2] -// sendCommand(command) -// -//} -// -//// 发送命令 -//func sendCommand(command string) { -// conn, err := net.Dial("unix", SocketFile) -// if err != nil { -// log.Fatalf("Failed to connect to daemon: %v", err) -// } -// defer func(conn net.Conn) { -// err := conn.Close() -// if err != nil { -// log.Fatalf("Failed to close connection: %v", err) -// } -// }(conn) -// -// _, err = conn.Write([]byte(command)) -// if err != nil { -// log.Fatalf("Failed to send command: %v", err) -// } -// -// log.Printf("Sending command '%s' to daemon with PID: %d", command, 0) -//} -// -//// 业务进程执行任务 -//func doTask() { -// -// // 监听主进程下发的指令 -// go InitSocket() -// -// // 监听HTTP请求 -// go InitHttpServer("0.0.0.0", 10000) -// -// // 自动执行域名证书更新 -// go AutoRefreshCert() -// -// // 阻止退出 -// select {} -//} -// -//// 是否已启动 -//func isRunning() bool { -// log.Println("Checking if daemon is running...") -// pid, err := readPID() -// if err != nil { -// return false -// } -// -// process, err := os.FindProcess(pid) -// log.Println("Found process:", process) -// if err != nil { -// log.Println("Failed to find process:", err) -// return false -// } -// return true -// //err = process.Signal(syscall.Signal(0)) -// //log.Println("Signal result:", err) -// //return err == nil -//} -// -//// 读取PID文件 -//func readPID() (int, error) { -// log.Println("Reading PID file...") -// data, err := os.ReadFile(PidFile) -// if err != nil { -// log.Println("Failed to read PID file:", err) -// return 0, err -// } -// log.Println("PID file content:", string(data)) -// -// pid, err := strconv.Atoi(string(data)) -// if err != nil { -// log.Println("Failed to parse PID:", err) -// return 0, err -// } -// log.Println("PID:", pid) -// -// return pid, nil -//} diff --git a/src/http.go b/src/http.go deleted file mode 100644 index 44b01de..0000000 --- a/src/http.go +++ /dev/null @@ -1,145 +0,0 @@ -package src - -//import ( -// "acme-mana/src/crypto" -// "encoding/base64" -// "encoding/hex" -// "encoding/json" -// "github.com/gin-gonic/gin" -// "log" -// "os" -// "path" -// "path/filepath" -// "strconv" -//) -// -//func InitHttpServer(host string, port int) { -// -// log.Println("Start http server, Listen " + strconv.Itoa(port)) -// h := gin.Default() -// h.GET("/api/v1/refresh", refreshCert) -// h.GET("/api/v1/cert", getCert) -// h.GET("/api/v1/domain/list", domainList) -// err := h.Run(host + ":" + strconv.Itoa(port)) -// if err != nil { -// return -// } -//} -// -//func domainList(c *gin.Context) { -// token := getToken(c) -// domains := GetAppConfig().Domains -// data, err := json.Marshal(domains) -// if err != nil { -// log.Fatal(err) -// } -// -// encryptData := encryptResult(string(data), token) -// c.JSON(200, gin.H{ -// "code": 200, -// "msg": "success", -// "data": encryptData, -// }) -//} -// -//func getCert(c *gin.Context) { -// name := c.Query("name") -// token := getToken(c) -// -// dir := GetAppConfig().CertDir -// dir = filepath.Join(dir, name) -// _, err := os.Stat(dir) -// if os.IsNotExist(err) { -// c.JSON(200, gin.H{ -// "code": 500, -// "msg": "Name does not exist.", -// }) -// return -// } -// crtFilePath := path.Join(dir, CertFileName) -// crtContent, err := os.ReadFile(crtFilePath) -// if err != nil { -// c.JSON(200, gin.H{ -// "code": 500, -// "msg": "Failed to read crt file.", -// }) -// return -// } -// crt := string(crtContent) -// -// keyFilePath := path.Join(dir, KeyFileName) -// keyContent, err := os.ReadFile(keyFilePath) -// if err != nil { -// c.JSON(200, gin.H{ -// "code": 500, -// "msg": "Failed to read key file.", -// }) -// return -// } -// key := string(keyContent) -// -// certInfoFilePath := path.Join(dir, CertInfoFileName) -// certInfoContent, err := os.ReadFile(certInfoFilePath) -// if err != nil { -// c.JSON(200, gin.H{ -// "code": 500, -// "msg": "Failed to read cert info file.", -// }) -// return -// } -// certInfo := string(certInfoContent) -// -// data, err := json.Marshal(&DomainData{ -// Fullchain: crt, -// Key: key, -// Info: certInfo, -// }) -// if err != nil { -// log.Fatal(err) -// } -// -// encryptData := encryptResult(string(data), token) -// c.JSON(200, gin.H{ -// "code": 200, -// "msg": "Success", -// "data": encryptData, -// }) -//} -// -//func refreshCert(c *gin.Context) { -// name := c.Param("name") -// domain := GetAppConfig().FindDomain(name) -// if domain == nil { -// c.JSON(200, gin.H{ -// "code": 500, -// "msg": "Name does not exist.", -// }) -// return -// } -// Apply(*domain) -// c.JSON(200, gin.H{ -// "code": 200, -// "msg": "Success", -// }) -//} -// -//func getToken(c *gin.Context) (token string) { -// token = c.Query("token") -// token = decryptParam(token) -// return -//} -// -//func decryptParam(param string) string { -// priKey := GetAppConfig().Encrypt.PriKey -// tokenBytes, err := hex.DecodeString(param) -// tokenPlain, err := crypto.DecryptRSABase64(priKey, tokenBytes) -// if err != nil { -// log.Fatal(err) -// } -// return string(tokenPlain) -//} -// -//func encryptResult(content string, token string) string { -// result := crypto.EncryptAES([]byte(token), []byte(content)) -// return base64.StdEncoding.EncodeToString(result) -//} diff --git a/src/task.go b/src/task.go deleted file mode 100644 index b8b9cc3..0000000 --- a/src/task.go +++ /dev/null @@ -1,86 +0,0 @@ -package src - -//import ( -// "encoding/json" -// "log" -// "os" -// "path" -// "time" -//) -// -//var AutoRefreshCertTicker = time.NewTicker(time.Hour) -// -//func AutoRefreshCert() { -// log.Println("Start auto refresh cert") -// defer AutoRefreshCertTicker.Stop() -// for { -// select { -// case <-AutoRefreshCertTicker.C: -// doRefreshCert() -// } -// } -//} -// -//func doRefreshCert() { -// domains := GetAppConfig().Domains -// for _, domain := range domains { -// doRefreshCertOnce(domain) -// } -//} -// -//func doRefreshCertOnce(domain Domain) { -// name := domain.Name -// dir := GetAppConfig().CertDir -// certDir := path.Join(dir, name) -// if !ValidExist(certDir, domain) { -// Apply(domain) -// } -// infoFile := path.Join(certDir, CertInfoFileName) -// certInfo := ParseCertInfo(infoFile, domain) -// log.Println("Checking if the certificate is expired, Domain: {}", name) -// if certInfo.Info.NotAfter.Sub(time.Now()) < 14*24*time.Hour { -// log.Println("Apply for a certificate that is about to expire, domain name:", name) -// Apply(domain) -// } -//} -// -//func ValidExist(certDir string, domain Domain) bool { -// _, err := os.Stat(certDir) -// if os.IsNotExist(err) { -// log.Printf("Applying for a certificate, Domain: %s certificate directory does not exist!", domain.Name) -// return false -// } -// if !ExistFile(certDir, CertFileName) { -// log.Printf("Applying for a certificate, Domain: %s %s does not exist!", domain.Name, CertFileName) -// return false -// } -// if !ExistFile(certDir, KeyFileName) { -// log.Printf("Applying for a certificate, Domain: %s %s does not exist!", domain.Name, KeyFileName) -// return false -// } -// if !ExistFile(certDir, CertInfoFileName) { -// log.Printf("Applying for a certificate, Domain: %s %s does not exist!", domain.Name, CertInfoFileName) -// return false -// } -// return true -//} -// -//func ParseCertInfo(infoFile string, domain Domain) CertInfo { -// infoBytes, err := os.ReadFile(infoFile) -// if err != nil { -// log.Println("Failed to read cert info file, Domain: {}", domain.Name) -// } -// var certInfo CertInfo -// err = json.Unmarshal(infoBytes, &certInfo) -// //if err != nil { -// // log.Println("Failed to parse cert info file, Domain: {}", domain.Name) -// //} -// return certInfo -//} -// -//func ExistFile(dir string, fileName string) bool { -// f := path.Join(dir, fileName) -// _, err := os.Stat(f) -// return !os.IsNotExist(err) -// -//}