feat: support run a cron job now

Author: eli-yip

echo.go

@@ -146,6 +146,8 @@ func registerJob(apiGroup *echo.Group, jobHandler *jobController.Controller) {
 	deleteTaskApi.Name = "Delete task route"
 	listTaskApi := jobApi.GET("/task/list", jobHandler.ListTask)
 	listTaskApi.Name = "List task route"
+	runNowApi := jobApi.POST("/run/:job", jobHandler.RunJobByName)
+	runNowApi.Name = "Run job now route"
 }
 
 // /api/v1/archive

internal/controller/job/job.go

@@ -47,6 +47,18 @@ func (h *Controller) StartJob(c echo.Context) (err error) {
 	}
 }
 
+func (h *Controller) RunJobByName(c echo.Context) (err error) {
+	logger := common.ExtractLogger(c)
+
+	jobName := c.Param("job")
+
+	if err := h.cronService.RunJobNow(jobName); err != nil {
+		logger.Error("Failed to run job now", zap.Error(err))
+		return c.JSON(http.StatusBadRequest, &ErrResp{Message: err.Error()})
+	}
+	return c.JSON(http.StatusOK, &Resp{Message: "job started"})
+}
+
 func (h *Controller) GetJobs(c echo.Context) (err error) {
 	logger := common.ExtractLogger(c)
 

pkg/cron/cron.go

@@ -63,6 +63,16 @@ func (c *CronService) RemoveCrawlJob(jobID string) (err error) {
 	return nil
 }
 
+func (c *CronService) RunJobNow(jobName string) (err error) {
+	for _, j := range c.s.Jobs() {
+		if j.Name() == jobName {
+			go func() { _ = j.RunNow() }()
+			return nil
+		}
+	}
+	return fmt.Errorf("job %s not found", jobName)
+}
+
 func GenerateRealCrawlFunc(crawlFunc func(chan CronJobInfo)) func() {
 	return func() {
 		emptyChan := make(chan CronJobInfo, 1)