package main import ( "encoding/json" "io/ioutil" //"log" "os" "time" //"github.com/robfig/cron/v3" "github.com/tidwall/pretty" "gopkg.in/robfig/cron.v3" ) func startCron() *cron.Cron { c := cron.New(cron.WithLocation(time.UTC)) c.AddFunc("58 6,14,22 * * *", cronSetDef) c.AddFunc("00 0 * * *", cronUpdateAngryBirbs) c.AddFunc("02 1,3,5,9,11,13,17,19,21 * * *", cronGetHammerTime) c.AddFunc("12 7,15,23 * * *", cronGetHammerTime) c.AddFunc("13 3,7,11,15,19,23 * * *", cronTribute) c.AddFunc("14 7,15,23 * * *", cronCheckVaultLimit) c.AddFunc("15 7,15,23 * * *", cronSendWarReport) c.AddFunc("@every 1m", cronSaveClients) c.Start() return c } func stopCron(c *cron.Cron) { c.Stop() return } func cronUpdateAngryBirbs() { muxClients.RLock() for _, c := range clients { if c.Active { p := JobPayloadMsgFwd{ ChatID64: cfg.Bot.AngryBirbs, } b, _ := json.Marshal(&p) err := createJobCallback(cacheObjSubType[`job_msg_fwd`], c.TGUserID64, cacheObjSubType[`msg_me_ack`], b, 1*time.Minute) logOnError(err, "cronUpdateAngryBirbs : createJobCallback") clientSendCWMsgDelay(c.TGUserID64, `/me`, 0) } } muxClients.RUnlock() return } func cronSendWarReport() { muxClients.RLock() for _, c := range clients { if c.Active { p := JobPayloadMsgFwd{ ChatID64: cfg.Bot.Reportchat, } b, _ := json.Marshal(&p) err := createJobCallback(cacheObjSubType[`job_msg_fwd`], c.TGUserID64, cacheObjSubType[`msg_report_ack`], b, 1*time.Minute) logOnError(err, "cronSendWarReport : createJobCallback") clientSendCWMsgDelay(c.TGUserID64, `/report`, 0) } } muxClients.RUnlock() return } func cronTribute() { muxClients.RLock() for _, c := range clients { if c.Active { if c.CWClass == `Knight` { clientSendCWMsgDelay(c.TGUserID64, `/tributes`, 0) } } } muxClients.RUnlock() return } func cronSetDef() { muxClients.RLock() for _, c := range clients { if c.Active { p := JobPayloadSetDef{} b, _ := json.Marshal(&p) err := createJobCallback(cacheObjSubType[`job_set_def`], c.TGUserID64, cacheObjSubType[`msg_me_ack`], b, 1*time.Minute) logOnError(err, "cronSetDef : createJobCallback") clientSendCWMsgDelay(c.TGUserID64, `🏅Me`, 0) } } muxClients.RUnlock() return } func cronGetHammerTime() { clt, err := getLockedRandomClient() logOnError(err, "cronGetHammerTime : getLockedRandomClient") if err != nil { return } clt.Mux.Unlock() p := JobPayloadGetHammerTime{} b, _ := json.Marshal(&p) err = createJobCallback(cacheObjSubType[`job_get_hammer_time`], clt.TGUserID64, cacheObjSubType[`msg_time_ack`], b, 1*time.Minute) logOnError(err, "cronGetHammerTime : createJobCallback") clientSendCWMsgDelay(clt.TGUserID64, `/time`, 0) } func cronSaveClients() { var clts []ChirpClient muxClients.RLock() for _, c := range clients { if c.Active { clts = append(clts, *c) } } muxClients.RUnlock() for k, _ := range clts { clts[k].Active = false } b, err := json.Marshal(clts) logOnError(err, "cronSaveClients : Marshal") pb := pretty.Pretty(b) err = ioutil.WriteFile("./clients_new.json", pb, 0644) logOnError(err, "cronSaveClients : WriteFile") err = os.Remove("./clients.json") logOnError(err, "cronSaveClients : Remove") err = os.Rename("./clients_new.json", "./clients.json") logOnError(err, "cronSaveClients : Rename") } func cronCheckVaultLimit() { clt, err := getLockedRandomClient() logOnError(err, "cronGetHammerTime : getLockedRandomClient") if err != nil { return } clt.Mux.Unlock() p := JobPayloadCheckVaultLimit{ Status: 0, } b, _ := json.Marshal(p) t := time.Now().UTC().Add(1 * time.Second) _, err = createJob(cacheObjSubType[`job_check_vault_limit`], objJobPriority, clt.TGUserID64, 0, t, b) }