forked from GoBelieveIO/im_service
-
Notifications
You must be signed in to change notification settings - Fork 0
/
storage_test.go
76 lines (61 loc) · 2.2 KB
/
storage_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
package main
import "testing"
import "log"
var storage = NewStorage("/tmp")
var appid int64 = 0
var device_id int64 = 0
var master *Master
func init() {
master = NewMaster()
master.Start()
}
func Test_Storage(t *testing.T) {
im := &IMMessage{sender:1, receiver:2, content:"test"}
msg := &Message{cmd:MSG_IM, body:im}
msgid := storage.SaveMessage(msg)
msg2 := storage.LoadMessage(msgid)
if msg2 != nil {
log.Println("msg2 cmd:", msg2.cmd)
} else {
log.Println("can't load msg:", msgid)
}
}
func Test_Offline(t *testing.T) {
im := &IMMessage{sender:1, receiver:2, content:"test"}
msg := &Message{cmd:MSG_IM, body:im}
for i := 0; i < 100; i++ {
msgid := storage.SavePeerMessage(appid, im.receiver, device_id, msg)
log.Println("enqueue msgid:", msgid)
}
log.Println("----------------------------")
offs := storage.LoadOfflineMessage(appid, im.receiver, device_id)
for _, emsg := range(offs) {
log.Println("dequeue msgid:", emsg.msgid)
storage.DequeueOffline(emsg.msgid, appid, im.receiver, device_id)
}
}
func Test_Dequeue(t *testing.T) {
im := &IMMessage{sender:1, receiver:2, content:"test"}
msg := &Message{cmd:MSG_IM, body:im}
msgid := storage.SavePeerMessage(appid, im.receiver, device_id, msg)
log.Println("enqueue msgid:", msgid)
storage.DequeueOffline(msgid, appid, im.receiver, device_id)
log.Println("dequeue msgid:", msgid)
}
func Test_LoadLatest(t *testing.T) {
im := &IMMessage{sender:1, receiver:2, content:"test"}
msg := &Message{cmd:MSG_IM, body:im}
msgid := storage.SavePeerMessage(appid, im.receiver, device_id, msg)
storage.DequeueOffline(msgid, appid, im.receiver, device_id)
im = &IMMessage{sender:1, receiver:2, content:"test2"}
msg = &Message{cmd:MSG_IM, body:im}
msgid = storage.SavePeerMessage(appid, im.receiver, device_id, msg)
storage.DequeueOffline(msgid, appid, im.receiver, device_id)
messages := storage.LoadLatestMessages(appid, im.receiver, 2)
latest := messages[0]
im2 := latest.msg.body.(*IMMessage)
log.Println("sender:", im2.sender, " receiver:", im2.receiver, " content:", string(im2.content))
latest = messages[1]
im2 = latest.msg.body.(*IMMessage)
log.Println("sender:", im2.sender, " receiver:", im2.receiver, " content:", string(im2.content))
}