Add user storage test

commands/clear.go

@@ -1,6 +1,9 @@
 package commands
 
 import (
+	"log"
+	"os"
+
 	"github.com/khlieng/dispatch/Godeps/_workspace/src/github.com/spf13/cobra"
 
 	"github.com/khlieng/dispatch/storage"
@@ -8,8 +11,20 @@ import (
 
 var clearCmd = &cobra.Command{
 	Use:   "clear",
-	Short: "Clear all application data",
+	Short: "Clear database and message logs",
 	Run: func(cmd *cobra.Command, args []string) {
-		storage.Clear()
+		err := os.Remove(storage.Path.Database())
+		if err == nil || os.IsNotExist(err) {
+			log.Println("Database cleared")
+		} else {
+			log.Println(err)
+		}
+
+		err = os.RemoveAll(storage.Path.Logs())
+		if err == nil {
+			log.Println("Logs cleared")
+		} else {
+			log.Println(err)
+		}
 	},
 }

commands/dispatch.go

@@ -27,29 +27,26 @@ const logo = `
 var rootCmd = &cobra.Command{
 	Use:   "dispatch",
 	Short: "Web-based IRC client in Go.",
-	Run: func(cmd *cobra.Command, args []string) {
-		storage.Initialize()
-		server.Run()
-	},
-
 	PersistentPreRun: func(cmd *cobra.Command, args []string) {
 		if cmd.Use == "dispatch" {
 			fmt.Println(logo)
 		}
 
-		storage.SetDirectory(viper.GetString("dir"))
+		storage.Initialize(viper.GetString("dir"))
 
-		err := os.MkdirAll(storage.Path.Logs(), 0700)
-		if err != nil {
-			log.Fatal(err)
-		}
-
-		initConfig()
+		initConfig(storage.Path.Config())
 
 		viper.SetConfigName("config")
 		viper.AddConfigPath(storage.Path.Root())
 		viper.ReadInConfig()
 	},
+
+	Run: func(cmd *cobra.Command, args []string) {
+		log.Println("Storing data at", storage.Path.Root())
+
+		storage.Open()
+		server.Run()
+	},
 }
 
 func Execute() {
@@ -67,9 +64,7 @@ func init() {
 	viper.BindPFlag("dir", rootCmd.PersistentFlags().Lookup("dir"))
 }
 
-func initConfig() {
-	configPath := storage.Path.Config()
-
+func initConfig(configPath string) {
 	if _, err := os.Stat(configPath); os.IsNotExist(err) {
 		config, err := assets.Asset("config.default.toml")
 		if err != nil {

server/irc_handler_test.go

@@ -20,9 +20,8 @@ func TestMain(m *testing.M) {
 		log.Fatal(err)
 	}
 
-	storage.SetDirectory(tempdir)
-	os.MkdirAll(storage.Path.Logs(), 0700)
-	storage.Initialize()
+	storage.Initialize(tempdir)
+	storage.Open()
 	user = storage.NewUser("uuid")
 	channelStore = storage.NewChannelStore()
 

storage/directory.go

@@ -6,12 +6,6 @@ import (
 	"github.com/khlieng/dispatch/Godeps/_workspace/src/github.com/mitchellh/go-homedir"
 )
 
-var Path directory
-
-func SetDirectory(dir string) {
-	Path = directory(dir)
-}
-
 func DefaultDirectory() string {
 	home, _ := homedir.Dir()
 	return filepath.Join(home, ".dispatch")

storage/storage.go

@@ -8,6 +8,8 @@ import (
 )
 
 var (
+	Path directory
+
 	db *bolt.DB
 
 	bucketUsers    = []byte("Users")
@@ -16,9 +18,16 @@ var (
 	bucketMessages = []byte("Messages")
 )
 
-func Initialize() {
-	log.Println("Storing data at", Path.Root())
+func Initialize(dir string) {
+	Path = directory(dir)
 
+	err := os.MkdirAll(Path.Logs(), 0700)
+	if err != nil {
+		log.Fatal(err)
+	}
+}
+
+func Open() {
 	var err error
 	db, err = bolt.Open(Path.Database(), 0600, nil)
 	if err != nil {
@@ -37,8 +46,3 @@ func Initialize() {
 func Close() {
 	db.Close()
 }
-
-func Clear() {
-	os.RemoveAll(Path.Logs())
-	os.Remove(Path.Database())
-}

storage/user_test.go

@@ -0,0 +1,65 @@
+package storage
+
+import (
+	"io/ioutil"
+	"testing"
+
+	"github.com/khlieng/dispatch/Godeps/_workspace/src/github.com/stretchr/testify/assert"
+)
+
+func tempdir() string {
+	f, _ := ioutil.TempDir("", "")
+	return f
+}
+
+func TestUser(t *testing.T) {
+	Initialize(tempdir())
+	Open()
+
+	srv := Server{
+		Name:    "Freenode",
+		Address: "irc.freenode.net",
+		Nick:    "test",
+	}
+	chan1 := Channel{
+		Server: srv.Address,
+		Name:   "#test",
+	}
+	chan2 := Channel{
+		Server: srv.Address,
+		Name:   "#testing",
+	}
+
+	user := NewUser("unique")
+	user.AddServer(srv)
+	user.AddChannel(chan1)
+	user.AddChannel(chan2)
+	user.Close()
+
+	users := LoadUsers()
+	assert.Len(t, users, 1)
+
+	user = users[0]
+	assert.Equal(t, "unique", user.UUID)
+
+	servers := user.GetServers()
+	assert.Len(t, servers, 1)
+	assert.Equal(t, srv, servers[0])
+
+	channels := user.GetChannels()
+	assert.Len(t, channels, 2)
+	assert.Equal(t, chan1, channels[0])
+	assert.Equal(t, chan2, channels[1])
+
+	user.SetNick("bob", srv.Address)
+	assert.Equal(t, "bob", user.GetServers()[0].Nick)
+
+	user.RemoveChannel(srv.Address, chan1.Name)
+	channels = user.GetChannels()
+	assert.Len(t, channels, 1)
+	assert.Equal(t, chan2, channels[0])
+
+	user.RemoveServer(srv.Address)
+	assert.Len(t, user.GetServers(), 0)
+	assert.Len(t, user.GetChannels(), 0)
+}