refactor: clean code

internal/certificate/service.go

@@ -25,11 +25,7 @@ type CertificateService struct {
 	settingsRepo    settingsRepository
 }
 
-func NewCertificateService(
-	acmeAccountRepo acmeAccountRepository,
-	certificateRepo certificateRepository,
-	settingsRepo settingsRepository,
-) *CertificateService {
+func NewCertificateService(acmeAccountRepo acmeAccountRepository, certificateRepo certificateRepository, settingsRepo settingsRepository) *CertificateService {
 	return &CertificateService{
 		acmeAccountRepo: acmeAccountRepo,
 		certificateRepo: certificateRepo,

internal/domain/access.go

@@ -1,6 +1,8 @@
 package domain
 
-import "time"
+import (
+	"time"
+)
 
 const CollectionNameAccess = "access"
 

internal/domain/meta.go

@@ -1,6 +1,8 @@
 package domain
 
-import "time"
+import (
+	"time"
+)
 
 type Meta struct {
 	Id        string    `db:"id"      json:"id"`

internal/scheduler/certificate.go

@@ -1,11 +1,13 @@
 package scheduler
 
-import "context"
+import (
+	"context"
+)
 
 type certificateService interface {
 	InitSchedule(ctx context.Context) error
 }
 
-func InitCertificateScheduler(service certificateService) error {
+func initCertificateScheduler(service certificateService) error {
 	return service.InitSchedule(context.Background())
 }

internal/scheduler/scheduler.go

@@ -19,11 +19,11 @@ func Setup() {
 	workflowSvc := workflow.NewWorkflowService(workflowRepo, workflowRunRepo, settingsRepo)
 	certificateSvc := certificate.NewCertificateService(acmeAccountRepo, certificateRepo, settingsRepo)
 
-	if err := InitWorkflowScheduler(workflowSvc); err != nil {
+	if err := initWorkflowScheduler(workflowSvc); err != nil {
 		app.GetLogger().Error("failed to init workflow scheduler", slog.Any("error", err))
 	}
 
-	if err := InitCertificateScheduler(certificateSvc); err != nil {
+	if err := initCertificateScheduler(certificateSvc); err != nil {
 		app.GetLogger().Error("failed to init certificate scheduler", slog.Any("error", err))
 	}
 }

internal/scheduler/workflow.go

@@ -1,11 +1,13 @@
 package scheduler
 
-import "context"
+import (
+	"context"
+)
 
 type workflowService interface {
 	InitSchedule(ctx context.Context) error
 }
 
-func InitWorkflowScheduler(service workflowService) error {
+func initWorkflowScheduler(service workflowService) error {
 	return service.InitSchedule(context.Background())
 }

internal/workflow/engine/errors.go

@@ -1,6 +1,8 @@
 package engine
 
-import "fmt"
+import (
+	"fmt"
+)
 
 var (
 	// 表示工作流引擎执行被中断，可能已结束

internal/workflow/service_inst.go

@@ -13,7 +13,11 @@ var (
 
 func thisSvcInst() *WorkflowService {
 	thisSvcOnce.Do(func() {
-		thisSvc = NewWorkflowService(repository.NewWorkflowRepository(), repository.NewWorkflowRunRepository(), repository.NewSettingsRepository())
+		thisSvc = NewWorkflowService(
+			repository.NewWorkflowRepository(),
+			repository.NewWorkflowRunRepository(),
+			repository.NewSettingsRepository(),
+		)
 	})
 	return thisSvc
 }

pkg/sdk3rd/baiducloud/cert/model.go

@@ -1,6 +1,8 @@
 package cert
 
-import "github.com/baidubce/bce-sdk-go/services/cert"
+import (
+	"github.com/baidubce/bce-sdk-go/services/cert"
+)
 
 type CreateCertArgs struct {
 	cert.CreateCertArgs

pkg/sdk3rd/conoha/vps/v3/endpoint.go

@@ -1,6 +1,8 @@
 package v3
 
-import "fmt"
+import (
+	"fmt"
+)
 
 const region = "c3j1"
 

pkg/sdk3rd/ksyun/cdn/types.go

@@ -1,6 +1,8 @@
 package cdn
 
-import "fmt"
+import (
+	"fmt"
+)
 
 type sdkResponse interface {
 	GetAPIError() error

pkg/sdk3rd/ksyun/kcm/types.go

@@ -1,6 +1,8 @@
 package kcm
 
-import "fmt"
+import (
+	"fmt"
+)
 
 type sdkResponse interface {
 	GetAPIError() error