Method Run

internal/base/cron/cron.go:62–119

()

}

func (s *ScheduledTaskManager) Run() {
	log.Infof("cron job manager start")

	s.questionService.SitemapCron(context.Background())
	c := cron.New()
	_, err := c.AddFunc("0 */1 * * *", func() {
		ctx := context.Background()
		log.Infof("sitemap cron execution")
		s.questionService.SitemapCron(ctx)
	})
	if err != nil {
		log.Error(err)
	}

	_, err = c.AddFunc("0 */1 * * *", func() {
		ctx := context.Background()
		log.Infof("refresh hottest cron execution")
		s.questionService.RefreshHottestCron(ctx)
	})
	if err != nil {
		log.Error(err)
	}

	// Check for expired user suspensions every 10 minutes
	_, err = c.AddFunc("*/10 * * * *", func() {
		ctx := context.Background()
		log.Infof("checking expired user suspensions")
		err := s.userAdminService.CheckAndUnsuspendExpiredUsers(ctx)
		if err != nil {
			log.Errorf("failed to check expired user suspensions: %v", err)
		}
	})
	if err != nil {
		log.Error(err)
	}

	if s.serviceConfig.CleanUpUploads {
		log.Infof("clean up uploads cron enabled")

		conf := s.serviceConfig
		_, err = c.AddFunc(fmt.Sprintf("0 */%d * * *", conf.CleanOrphanUploadsPeriodHours), func() {
			log.Infof("clean orphan upload files cron execution")
			s.fileRecordService.CleanOrphanUploadFiles(context.Background())
		})
		if err != nil {
			log.Error(err)
		}

		_, err = c.AddFunc(fmt.Sprintf("0 0 */%d * *", conf.PurgeDeletedFilesPeriodDays), func() {
			log.Infof("purge deleted files cron execution")
			s.fileRecordService.PurgeDeletedFiles(context.Background())
		})
		if err != nil {
			log.Error(err)
		}
	}
	c.Start()
}