every -loop duration, look for completed tasks with loop set and incomplete them
parent
81c8743de7
commit
b8f0efc01c
|
|
@ -5,6 +5,7 @@ import (
|
||||||
"local/args"
|
"local/args"
|
||||||
"os"
|
"os"
|
||||||
"strings"
|
"strings"
|
||||||
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
|
@ -15,6 +16,7 @@ var (
|
||||||
StorePass string
|
StorePass string
|
||||||
Root string
|
Root string
|
||||||
OAuth string
|
OAuth string
|
||||||
|
Loop time.Duration
|
||||||
)
|
)
|
||||||
|
|
||||||
func init() {
|
func init() {
|
||||||
|
|
@ -34,6 +36,7 @@ func Refresh() {
|
||||||
as.Append(args.STRING, "storepass", "pass of store", "")
|
as.Append(args.STRING, "storepass", "pass of store", "")
|
||||||
as.Append(args.STRING, "oauth", "url for boauthz", "")
|
as.Append(args.STRING, "oauth", "url for boauthz", "")
|
||||||
as.Append(args.STRING, "root", "root of static files", "./public")
|
as.Append(args.STRING, "root", "root of static files", "./public")
|
||||||
|
as.Append(args.DURATION, "loop", "loop duration for refreshing completed tasks", time.Minute)
|
||||||
if err := as.Parse(); err != nil {
|
if err := as.Parse(); err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
|
|
@ -44,5 +47,6 @@ func Refresh() {
|
||||||
StoreUser = as.Get("storeuser").GetString()
|
StoreUser = as.Get("storeuser").GetString()
|
||||||
StorePass = as.Get("storepass").GetString()
|
StorePass = as.Get("storepass").GetString()
|
||||||
Root = as.Get("root").GetString()
|
Root = as.Get("root").GetString()
|
||||||
|
Loop = as.Get("loop").GetDuration()
|
||||||
OAuth = as.Get("oauth").GetString()
|
OAuth = as.Get("oauth").GetString()
|
||||||
}
|
}
|
||||||
|
|
|
||||||
1
main.go
1
main.go
|
|
@ -12,6 +12,7 @@ func main() {
|
||||||
if err := s.Routes(); err != nil {
|
if err := s.Routes(); err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
|
go s.Async()
|
||||||
log.Println("listening on", config.Port)
|
log.Println("listening on", config.Port)
|
||||||
if err := http.ListenAndServe(config.Port, s); err != nil {
|
if err := http.ListenAndServe(config.Port, s); err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
|
|
|
||||||
|
|
@ -3,8 +3,11 @@ package ajax
|
||||||
import (
|
import (
|
||||||
"local/storage"
|
"local/storage"
|
||||||
"local/todo-server/config"
|
"local/todo-server/config"
|
||||||
|
"local/todo-server/server/ajax/task"
|
||||||
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
"net/url"
|
"net/url"
|
||||||
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
type Ajax struct {
|
type Ajax struct {
|
||||||
|
|
@ -82,3 +85,39 @@ func has(params url.Values, k string) bool {
|
||||||
_, ok := params[k]
|
_, ok := params[k]
|
||||||
return ok
|
return ok
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (a *Ajax) Async() {
|
||||||
|
c := time.NewTicker(config.Loop)
|
||||||
|
for range c.C {
|
||||||
|
log.Println("loop tasks")
|
||||||
|
if err := a.loopTasks(); err != nil {
|
||||||
|
log.Println("failed to loop tasks", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *Ajax) loopTasks() error {
|
||||||
|
lists, err := a.storageListLists()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
for _, list := range lists {
|
||||||
|
tasks, err := a.storageListTasks(list.UUID, func(t *task.Task) bool {
|
||||||
|
return t.Complete
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
for _, task := range tasks {
|
||||||
|
if !task.Complete || task.Loop == 0 || time.Since(task.Completed) < task.Loop {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
task.Complete = false
|
||||||
|
task.Completed = time.Time{}
|
||||||
|
if err := a.storageSetTask(list.UUID, task); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue