This commit is contained in:
2023-05-29 15:52:53 +08:00
parent dfe4801421
commit c59d801434
4 changed files with 28 additions and 4 deletions
+1 -1
View File
@@ -99,7 +99,7 @@ func (r *Remind) callbackFn(task *Task) {
r.callback(*task)
}
if !task.GetTimer().IsRunning() {
r.DeleteTask(task.ID)
go r.DeleteTask(task.ID)
}
}
+24
View File
@@ -16,6 +16,30 @@ func exists(path string) bool {
}
return err == nil
}
func TestStarDB(t *testing.T) {
var db stardb.StarDB
err := db.Open("sqlite", "./db.sqlite")
if err != nil {
t.Fatal(err)
}
var r *Remind
r, err = NewRemind(&db, func(task Task) {
fmt.Println("hello world!", time.Now(), task.ID, task.Key, task.TmrInfo, task.Msg, task.Origin)
fmt.Println(task.GetTimer().NextTimer(), task.GetTimer().IsRunning())
fmt.Println(r.ListTasks())
fmt.Println("ok")
time.Sleep(time.Second * 10)
fmt.Println(task.GetTimer().NextTimer())
})
tk, err := r.AddTask("每天下午3点52分20秒提醒我吃饭", "00", []byte{})
if err != nil {
t.Fatal(err)
}
fmt.Println(tk.GetTimer().NextTimer())
fmt.Println(r.ListTasks())
fmt.Println("hello")
time.Sleep(time.Second * 120)
}
func TestOtherDb(t *testing.T) {
var db stardb.StarDB