From 748fd3d085496f986adf793d9cd0a49953bf07cc Mon Sep 17 00:00:00 2001 From: Jason Song <i@wolfogre.com> Date: Fri, 6 Jan 2023 18:06:12 +0800 Subject: [PATCH] chore: add init.go to actions --- .../actions/{actions.go => commit_status.go} | 17 +------------- services/actions/init.go | 22 +++++++++++++++++++ 2 files changed, 23 insertions(+), 16 deletions(-) rename services/actions/{actions.go => commit_status.go} (81%) create mode 100644 services/actions/init.go diff --git a/services/actions/actions.go b/services/actions/commit_status.go similarity index 81% rename from services/actions/actions.go rename to services/actions/commit_status.go index e5d8cc2228..eb9f4964d4 100644 --- a/services/actions/actions.go +++ b/services/actions/commit_status.go @@ -1,4 +1,4 @@ -// Copyright 2022 The Gitea Authors. All rights reserved. +// Copyright 2023 The Gitea Authors. All rights reserved. // SPDX-License-Identifier: MIT package actions @@ -12,24 +12,9 @@ import ( git_model "code.gitea.io/gitea/models/git" user_model "code.gitea.io/gitea/models/user" webhook_model "code.gitea.io/gitea/models/webhook" - "code.gitea.io/gitea/modules/graceful" - "code.gitea.io/gitea/modules/notification" - "code.gitea.io/gitea/modules/queue" - "code.gitea.io/gitea/modules/setting" api "code.gitea.io/gitea/modules/structs" ) -func Init() { - if !setting.Actions.Enabled { - return - } - - jobEmitterQueue = queue.CreateUniqueQueue("actions_ready_job", jobEmitterQueueHandle, new(jobUpdate)) - go graceful.GetManager().RunWithShutdownFns(jobEmitterQueue.Run) - - notification.RegisterNotifier(NewNotifier()) -} - func CreateCommitStatus(ctx context.Context, job *actions_model.ActionRunJob) error { if err := job.LoadAttributes(ctx); err != nil { return fmt.Errorf("load run: %w", err) diff --git a/services/actions/init.go b/services/actions/init.go new file mode 100644 index 0000000000..3fd03eeb6f --- /dev/null +++ b/services/actions/init.go @@ -0,0 +1,22 @@ +// Copyright 2022 The Gitea Authors. All rights reserved. +// SPDX-License-Identifier: MIT + +package actions + +import ( + "code.gitea.io/gitea/modules/graceful" + "code.gitea.io/gitea/modules/notification" + "code.gitea.io/gitea/modules/queue" + "code.gitea.io/gitea/modules/setting" +) + +func Init() { + if !setting.Actions.Enabled { + return + } + + jobEmitterQueue = queue.CreateUniqueQueue("actions_ready_job", jobEmitterQueueHandle, new(jobUpdate)) + go graceful.GetManager().RunWithShutdownFns(jobEmitterQueue.Run) + + notification.RegisterNotifier(NewNotifier()) +}