dispatch/storage/user_test.go

185 lines
4.7 KiB
Go
Raw Normal View History

package storage_test
2016-01-07 22:59:38 +00:00
import (
"io/ioutil"
"os"
2016-01-17 20:15:29 +00:00
"strconv"
2016-01-07 22:59:38 +00:00
"testing"
"github.com/khlieng/dispatch/storage"
"github.com/khlieng/dispatch/storage/bleve"
"github.com/khlieng/dispatch/storage/boltdb"
2017-04-20 03:32:22 +00:00
"github.com/kjk/betterguid"
2016-03-01 00:51:26 +00:00
"github.com/stretchr/testify/assert"
2016-01-07 22:59:38 +00:00
)
func tempdir() string {
f, _ := ioutil.TempDir("", "")
return f
}
func TestUser(t *testing.T) {
2020-04-20 01:02:15 +00:00
storage.Initialize(tempdir(), "", "")
db, err := boltdb.New(storage.Path.Database())
assert.Nil(t, err)
user, err := storage.NewUser(db)
assert.Nil(t, err)
2016-01-07 22:59:38 +00:00
srv := &storage.Server{
Name: "Freenode",
Host: "irc.freenode.net",
Nick: "test",
2016-01-07 22:59:38 +00:00
}
chan1 := &storage.Channel{
Server: srv.Host,
2016-01-07 22:59:38 +00:00
Name: "#test",
}
chan2 := &storage.Channel{
Server: srv.Host,
2016-01-07 22:59:38 +00:00
Name: "#testing",
}
user.AddServer(srv)
user.AddChannel(chan1)
user.AddChannel(chan2)
2016-01-07 22:59:38 +00:00
users, err := storage.LoadUsers(db)
assert.Nil(t, err)
2016-01-07 22:59:38 +00:00
assert.Len(t, users, 1)
user = users[0]
assert.Equal(t, uint64(1), user.ID)
2016-01-07 22:59:38 +00:00
servers, err := user.GetServers()
2016-01-07 22:59:38 +00:00
assert.Len(t, servers, 1)
assert.Equal(t, srv, servers[0])
channels, err := user.GetChannels()
2016-01-07 22:59:38 +00:00
assert.Len(t, channels, 2)
assert.Equal(t, chan1, channels[0])
assert.Equal(t, chan2, channels[1])
user.SetNick("bob", srv.Host)
servers, err = user.GetServers()
assert.Equal(t, "bob", servers[0].Nick)
2016-01-07 22:59:38 +00:00
user.SetServerName("cake", srv.Host)
servers, err = user.GetServers()
assert.Equal(t, "cake", servers[0].Name)
user.RemoveChannel(srv.Host, chan1.Name)
channels, err = user.GetChannels()
2016-01-07 22:59:38 +00:00
assert.Len(t, channels, 1)
assert.Equal(t, chan2, channels[0])
user.RemoveServer(srv.Host)
servers, err = user.GetServers()
assert.Len(t, servers, 0)
channels, err = user.GetChannels()
assert.Len(t, channels, 0)
2018-10-15 06:56:17 +00:00
settings := user.GetClientSettings()
assert.NotNil(t, settings)
assert.Equal(t, storage.DefaultClientSettings(), settings)
settings.ColoredNicks = !settings.ColoredNicks
err = user.SetClientSettings(settings)
assert.Nil(t, err)
assert.Equal(t, settings, user.GetClientSettings())
assert.NotEqual(t, settings, storage.DefaultClientSettings())
user.Remove()
_, err = os.Stat(storage.Path.User(user.Username))
assert.True(t, os.IsNotExist(err))
users, err = storage.LoadUsers(db)
assert.Nil(t, err)
for i := range users {
assert.NotEqual(t, user.ID, users[i].ID)
}
2016-01-07 22:59:38 +00:00
}
2016-01-17 20:15:29 +00:00
func TestMessages(t *testing.T) {
2020-04-20 01:02:15 +00:00
storage.Initialize(tempdir(), "", "")
2016-01-17 20:15:29 +00:00
db, err := boltdb.New(storage.Path.Database())
2016-01-17 20:15:29 +00:00
assert.Nil(t, err)
user, err := storage.NewUser(db)
assert.Nil(t, err)
os.MkdirAll(storage.Path.User(user.Username), 0700)
search, err := bleve.New(storage.Path.Index(user.Username))
assert.Nil(t, err)
user.SetMessageStore(db)
user.SetMessageSearchProvider(search)
2017-05-02 21:21:25 +00:00
messages, hasMore, err := user.GetMessages("irc.freenode.net", "#go-nuts", 10, "6")
2016-01-17 20:15:29 +00:00
assert.Nil(t, err)
2017-05-02 21:21:25 +00:00
assert.False(t, hasMore)
2016-01-17 20:15:29 +00:00
assert.Len(t, messages, 0)
2017-05-02 21:21:25 +00:00
messages, hasMore, err = user.GetLastMessages("irc.freenode.net", "#go-nuts", 10)
2016-01-17 20:15:29 +00:00
assert.Nil(t, err)
2017-05-02 21:21:25 +00:00
assert.False(t, hasMore)
2016-01-17 20:15:29 +00:00
assert.Len(t, messages, 0)
messages, err = user.SearchMessages("irc.freenode.net", "#go-nuts", "message")
assert.Nil(t, err)
assert.Len(t, messages, 0)
2017-04-20 03:32:22 +00:00
ids := []string{}
2016-01-17 20:15:29 +00:00
for i := 0; i < 5; i++ {
2017-04-20 03:32:22 +00:00
id := betterguid.New()
ids = append(ids, id)
err = user.LogMessage(id, "irc.freenode.net", "nick", "#go-nuts", "message"+strconv.Itoa(i))
2016-01-17 20:15:29 +00:00
assert.Nil(t, err)
}
2017-05-02 21:21:25 +00:00
messages, hasMore, err = user.GetMessages("irc.freenode.net", "#go-nuts", 10, ids[4])
2016-01-17 20:15:29 +00:00
assert.Equal(t, "message0", messages[0].Content)
2017-04-20 03:32:22 +00:00
assert.Equal(t, "message3", messages[3].Content)
2016-01-17 20:15:29 +00:00
assert.Nil(t, err)
2017-05-02 21:21:25 +00:00
assert.False(t, hasMore)
2017-04-20 03:32:22 +00:00
assert.Len(t, messages, 4)
2016-01-17 20:15:29 +00:00
2017-05-02 21:21:25 +00:00
messages, hasMore, err = user.GetMessages("irc.freenode.net", "#go-nuts", 10, betterguid.New())
2016-01-17 22:33:52 +00:00
assert.Equal(t, "message0", messages[0].Content)
assert.Equal(t, "message4", messages[4].Content)
2016-01-17 20:15:29 +00:00
assert.Nil(t, err)
2017-05-02 21:21:25 +00:00
assert.False(t, hasMore)
2016-01-17 20:15:29 +00:00
assert.Len(t, messages, 5)
2017-05-02 21:21:25 +00:00
messages, hasMore, err = user.GetMessages("irc.freenode.net", "#go-nuts", 10, ids[2])
2016-01-17 20:15:29 +00:00
assert.Equal(t, "message0", messages[0].Content)
2017-04-20 03:32:22 +00:00
assert.Equal(t, "message1", messages[1].Content)
2016-01-17 20:15:29 +00:00
assert.Nil(t, err)
2017-05-02 21:21:25 +00:00
assert.False(t, hasMore)
2017-04-20 03:32:22 +00:00
assert.Len(t, messages, 2)
2016-01-17 20:15:29 +00:00
2017-05-02 21:21:25 +00:00
messages, hasMore, err = user.GetLastMessages("irc.freenode.net", "#go-nuts", 10)
2016-01-17 20:15:29 +00:00
assert.Equal(t, "message0", messages[0].Content)
2017-05-02 21:21:25 +00:00
assert.Equal(t, "message4", messages[4].Content)
2016-01-17 20:15:29 +00:00
assert.Nil(t, err)
2017-05-02 21:21:25 +00:00
assert.False(t, hasMore)
2016-01-17 20:15:29 +00:00
assert.Len(t, messages, 5)
2017-05-02 21:21:25 +00:00
messages, hasMore, err = user.GetLastMessages("irc.freenode.net", "#go-nuts", 4)
assert.Equal(t, "message1", messages[0].Content)
assert.Equal(t, "message4", messages[3].Content)
2016-01-17 20:15:29 +00:00
assert.Nil(t, err)
2017-05-02 21:21:25 +00:00
assert.True(t, hasMore)
assert.Len(t, messages, 4)
2016-01-17 20:15:29 +00:00
messages, err = user.SearchMessages("irc.freenode.net", "#go-nuts", "message")
assert.Nil(t, err)
assert.True(t, len(messages) > 0)
2016-01-17 20:15:29 +00:00
db.Close()
2016-01-17 20:15:29 +00:00
}