Skip to content

Commit ab918a3

Browse files
committed
feat(subscr): cron
1 parent 2018c8b commit ab918a3

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

cli/cmd/root.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,13 +2,14 @@ package cmd
22

33
import (
44
"fmt"
5-
"github.com/semaphoreui/semaphore/api/helpers"
6-
"github.com/semaphoreui/semaphore/services/server"
75
"net/http"
86
"net/url"
97
"os"
108
"strings"
119

10+
"github.com/semaphoreui/semaphore/api/helpers"
11+
"github.com/semaphoreui/semaphore/services/server"
12+
1213
"github.com/gorilla/handlers"
1314
"github.com/semaphoreui/semaphore/api"
1415
"github.com/semaphoreui/semaphore/api/sockets"
@@ -86,7 +87,7 @@ func runService() {
8687
accessKeyService := server.NewAccessKeyService(store, encryptionService, store)
8788
secretStorageService := server.NewSecretStorageService(store, accessKeyService)
8889
environmentService := server.NewEnvironmentService(store, encryptionService)
89-
subscriptionService := proServer.NewSubscriptionService()
90+
subscriptionService := proServer.NewSubscriptionService(store, store)
9091

9192
taskPool := tasks.CreateTaskPool(
9293
store,
@@ -117,6 +118,7 @@ func runService() {
117118
fmt.Printf("Interface %v\n", util.Config.Interface)
118119
fmt.Printf("Port %v\n", util.Config.Port)
119120

121+
subscriptionService.StartValidationCron()
120122
go sockets.StartWS()
121123
go schedulePool.Run()
122124
go taskPool.Run()

0 commit comments

Comments
 (0)