package main;


import ("fmt"
        "gopkg.in/mgo.v2"
        "time"
        "gopkg.in/mgo.v2/bson"
         "bufio"
         "os"

        )
const (
    hosts      = "localhost:27017"
    database   = "my_database"
    username   = "dev1"
    password   = "password123"
    collection = "users"
)
type users struct {
        User string   `bson:"user" json:"user"`
        Data string   `bson:"data" json:"data"`
}

func main(){

    fmt.Println("Starting Application!")

    info := &mgo.DialInfo{
        Addrs:    []string{hosts},
        Timeout:  60 * time.Second,
        Database: database,
        Username: username,
        Password: password,
    }

     session, err1 := mgo.DialWithInfo(info)
    if err1 != nil {
        panic(err1)
    }
    defer session.Close()



    col := session.DB(database).C(collection)

    var user users;
    var userArray []users;
    reader := bufio.NewReader(os.Stdin)
    fmt.Print("Enter A userName to save to database: ")
    username, _ := reader.ReadString('\n')
    fmt.Println("Username will be ",username)

    fmt.Print("Enter some random data to save to database: ")
    data, _ := reader.ReadString('\n')

    col.Insert(&users{User:username,Data:data})
    col.Find(bson.M{"user":username}).One(&user);

    fmt.Println(user);


    count, err2 := col.Count()

    if err2 != nil {
        panic(err2)
    }
    fmt.Println(fmt.Sprintf("Messages count: %d", count))


    col.Find(bson.M{}).All(&userArray)
    fmt.Println(userArray);



}