diff --git a/backend/internal/httpapi/server.go b/backend/internal/httpapi/server.go index 7dd1f64..90cc284 100644 --- a/backend/internal/httpapi/server.go +++ b/backend/internal/httpapi/server.go @@ -66,6 +66,7 @@ type Dependencies struct { // DeployCertificateTask 执行已有任务,不得重复创建任务或尝试记录。 DeployCertificateTask func(context.Context, string) (certificate.IssueResult, deployment.Report, error) RestoreCertificateVersion func(context.Context, string, string) (certificate.IssueResult, error) + RestoreCertificateVersionTask func(context.Context, string, string) (certificate.IssueResult, error) ValidateCertificate func(context.Context, string) (certificate.IssueResult, certificate.ValidationResult, error) // ValidateCertificateTask 直接校验当前证书,不重复创建任务。 ValidateCertificateTask func(context.Context, string) (certificate.IssueResult, certificate.ValidationResult, error) @@ -107,6 +108,7 @@ type Server struct { deployCertificate func(context.Context, string) (certificate.IssueResult, deployment.Report, error) deployCertificateTask func(context.Context, string) (certificate.IssueResult, deployment.Report, error) restoreVersion func(context.Context, string, string) (certificate.IssueResult, error) + restoreVersionTask func(context.Context, string, string) (certificate.IssueResult, error) validateCertificateWorkflow func(context.Context, string) (certificate.IssueResult, certificate.ValidationResult, error) validateCertificateTask func(context.Context, string) (certificate.IssueResult, certificate.ValidationResult, error) @@ -177,6 +179,7 @@ func New(deps Dependencies) *Server { deployCertificate: deps.DeployCertificate, deployCertificateTask: deps.DeployCertificateTask, restoreVersion: deps.RestoreCertificateVersion, + restoreVersionTask: deps.RestoreCertificateVersionTask, validateCertificateWorkflow: deps.ValidateCertificate, validateCertificateTask: deps.ValidateCertificateTask, runRenewal: deps.RunRenewal, diff --git a/backend/internal/httpapi/task_api.go b/backend/internal/httpapi/task_api.go index f0e00cc..c868b58 100644 --- a/backend/internal/httpapi/task_api.go +++ b/backend/internal/httpapi/task_api.go @@ -38,7 +38,10 @@ func (s *Server) submitPreparedDomainTask(c *gin.Context, taskType string, prepa prepared.cleanup() } }() - if (taskType == "certificate_issue" && s.issueCertificate == nil) || (taskType == "certificate_deploy" && s.deployCertificateTask == nil) || (taskType == "certificate_validate" && s.validateCertificateTask == nil) { + if (taskType == "certificate_issue" && s.issueCertificate == nil) || + (taskType == "certificate_deploy" && s.deployCertificateTask == nil) || + (taskType == "certificate_validate" && s.validateCertificateTask == nil) || + (taskType == "certificate_restore" && s.restoreVersionTask == nil) { s.writeError(c, http.StatusNotImplemented, "证书申请接口尚未配置", errors.New("证书申请工作流未配置")) return }