TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-22 06:20:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

增加测试用例

Browse Source
This commit is contained in:
GoEdgeLab
2022-12-06 14:53:38 +08:00
parent e4f06d34c3
commit 275d7f1622
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
internal/db/models/message_task_dao_test.go
View File

@@ -1,6 +1,7 @@
package models package models_test
import ( import (
"github.com/TeaOSLab/EdgeAPI/internal/db/models"
_ "github.com/go-sql-driver/mysql" _ "github.com/go-sql-driver/mysql"
_ "github.com/iwind/TeaGo/bootstrap" _ "github.com/iwind/TeaGo/bootstrap"
"github.com/iwind/TeaGo/dbs" "github.com/iwind/TeaGo/dbs"
@@ -11,7 +12,7 @@ func TestMessageTaskDAO_FindSendingMessageTasks(t *testing.T) {
dbs.NotifyReady() dbs.NotifyReady()
var tx *dbs.Tx var tx *dbs.Tx
tasks, err := NewMessageTaskDAO().FindSendingMessageTasks(tx, 100) tasks, err := models.NewMessageTaskDAO().FindSendingMessageTasks(tx, 100)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
@@ -20,3 +21,12 @@ func TestMessageTaskDAO_FindSendingMessageTasks(t *testing.T) {
t.Log("task:", task.Id, "recipient:", task.RecipientId) t.Log("task:", task.Id, "recipient:", task.RecipientId)
} }
} }
func TestMessageTaskDAO_CleanExpiredMessageTasks(t *testing.T) {
var dao = models.NewMessageTaskDAO()
var tx *dbs.Tx
err := dao.CleanExpiredMessageTasks(tx, 30)
if err != nil {
t.Fatal(err)
}
}