feat: optimize schedule

contracts/route/route.go

@@ -23,8 +23,10 @@ type Route interface {
 	RunTLSWithCert(host, certFile, keyFile string) error
 	// ServeHTTP serves HTTP requests.
 	ServeHTTP(writer http.ResponseWriter, request *http.Request)
-	// Shutdown gracefully shuts down the serve.
+	// DEPRECATED use Stop instead.
 	Shutdown(ctx ...context.Context) error
+	// Stop gracefully stop the serve.
+	Stop(ctx ...context.Context) error
 }
 
 type Router interface {

contracts/schedule/schedule.go

@@ -1,5 +1,9 @@
 package schedule
 
+import (
+	"context"
+)
+
 type Schedule interface {
 	// Call add a new callback event to the schedule.
 	Call(callback func()) Event
@@ -9,4 +13,6 @@ type Schedule interface {
 	Register(events []Event)
 	// Run schedules.
 	Run()
+	// Stop schedules.
+	Stop(ctx ...context.Context) error
 }

schedule/application.go

@@ -1,6 +1,7 @@
 package schedule
 
 import (
+	"context"
 	"time"
 
 	"github.com/robfig/cron/v3"
@@ -24,8 +25,11 @@ func NewApplication(artisan console.Artisan, cache cache.Cache, log log.Log, deb
 	return &Application{
 		artisan: artisan,
 		cache:   cache,
-		log:     log,
-		debug:   debug,
+		cron: cron.New(cron.WithParser(cron.NewParser(
+			cron.SecondOptional|cron.Minute|cron.Hour|cron.Dom|cron.Month|cron.Dow|cron.Descriptor,
+		)), cron.WithLogger(NewLogger(log, debug))),
+		log:   log,
+		debug: debug,
 	}
 }
 
@@ -38,17 +42,30 @@ func (app *Application) Command(command string) schedule.Event {
 }
 
 func (app *Application) Register(events []schedule.Event) {
-	if app.cron == nil {
-		app.cron = cron.New(cron.WithLogger(NewLogger(app.log, app.debug)))
-	}
-
 	app.addEvents(events)
 }
 
 func (app *Application) Run() {
 	app.cron.Run()
 }
 
+func (app *Application) Stop(ctx ...context.Context) error {
+	if len(ctx) == 0 {
+		ctx = append(ctx, context.Background())
+	}
+
+	cronCtx := app.cron.Stop()
+
+	for {
+		select {
+		case <-cronCtx.Done():
+			return nil
+		case <-ctx[0].Done():
+			return ctx[0].Err()
+		}
+	}
+}
+
 func (app *Application) addEvents(events []schedule.Event) {
 	for _, event := range events {
 		chain := cron.NewChain(cron.Recover(NewLogger(app.log, app.debug)))