Change syncer.SyncInterval to second-level.

object/syncer_cron.go

@@ -14,27 +14,27 @@
 
 package object
 
-import "github.com/mileusna/crontab"
+import "github.com/robfig/cron/v3"
 
-var cronMap map[string]*crontab.Crontab
+var cronMap map[string]*cron.Cron
 
 func init() {
-	cronMap = map[string]*crontab.Crontab{}
+	cronMap = map[string]*cron.Cron{}
 }
 
-func getCrontab(name string) *crontab.Crontab {
-	ctab, ok := cronMap[name]
+func getCronMap(name string) *cron.Cron {
+	m, ok := cronMap[name]
 	if !ok {
-		ctab = crontab.New()
-		cronMap[name] = ctab
+		m = cron.New()
+		cronMap[name] = m
 	}
-	return ctab
+	return m
 }
 
-func clearCrontab(name string) {
-	ctab, ok := cronMap[name]
+func clearCron(name string) {
+	cron, ok := cronMap[name]
 	if ok {
-		ctab.Clear()
+		cron.Stop()
 		delete(cronMap, name)
 	}
 }

object/syncer_user.go

@@ -166,14 +166,14 @@ func RunSyncUsersJob() {
 
 		syncer.syncUsers()
 
-		// run at every minute
-		//schedule := fmt.Sprintf("* * * * %d", syncer.SyncInterval)
-		schedule := "* * * * *"
-		ctab := getCrontab(syncer.Name)
-		err := ctab.AddJob(schedule, syncer.syncUsers)
+		schedule := fmt.Sprintf("@every %ds", syncer.SyncInterval)
+		cron := getCronMap(syncer.Name)
+		_, err := cron.AddFunc(schedule, syncer.syncUsers)
 		if err != nil {
 			panic(err)
 		}
+
+		cron.Start()
 	}
 
 	time.Sleep(time.Duration(1<<63 - 1))