Continue with test cases

Author: victorsteven

api/controllers/base.go

@@ -0,0 +1,34 @@
+package controllers
+
+import (
+	"fmt"
+	"log"
+	"net/http"
+
+	"github.com/gorilla/mux"
+	"github.com/jinzhu/gorm"
+	_ "github.com/jinzhu/gorm/dialects/mysql"
+)
+
+type Server struct {
+	DB     *gorm.DB
+	Router *mux.Router
+}
+
+func (server *Server) Initialize(Dbdriver, User, Password, Dbname string) {
+	var err error
+
+	DBURL := fmt.Sprintf("%s:%s@tcp(127.0.0.1:3306)/%s?charset=utf8&parseTime=True&loc=Local", User, Password, Dbname)
+	server.DB, err = gorm.Open(Dbdriver, DBURL)
+	if err != nil {
+		log.Fatal("cannot connect to the database", err)
+	}
+
+	server.Router = mux.NewRouter()
+	server.initializeRoutes()
+}
+
+func (server *Server) Run(addr string) {
+	fmt.Println("Listening to port 8080")
+	log.Fatal(http.ListenAndServe(addr, server.Router))
+}

api/controllers/login_controller.go

@@ -9,9 +9,10 @@ import (
 	"github.com/victorsteven/fullstack/api/auth"
 	"github.com/victorsteven/fullstack/api/models"
 	"github.com/victorsteven/fullstack/api/responses"
+	"github.com/victorsteven/fullstack/api/utils/channels"
 )
 
-func Login(w http.ResponseWriter, r *http.Request) {
+func (server *Server) Login(w http.ResponseWriter, r *http.Request) {
 	body, err := ioutil.ReadAll(r.Body)
 	if err != nil {
 		fmt.Println("we cant login")
@@ -33,11 +34,33 @@ func Login(w http.ResponseWriter, r *http.Request) {
 		responses.ERROR(w, http.StatusUnprocessableEntity, err)
 		return
 	}
-	token, err := auth.SignIn(user.Email, user.Password)
+	token, err := server.SignIn(user.Email, user.Password)
 	if err != nil {
 		fmt.Println("we cant login")
 		responses.ERROR(w, http.StatusUnprocessableEntity, err)
 		return
 	}
 	responses.JSON(w, http.StatusOK, token)
 }
+
+func (server *Server) SignIn(email, password string) (string, error) {
+	user := models.User{}
+	var err error
+	done := make(chan bool)
+
+	go func(ch chan<- bool) {
+		defer close(ch)
+
+		err = server.DB.Debug().Model(models.User{}).Where("email = ?", email).Take(&user).Error
+		if err != nil {
+			ch <- false
+			return
+		}
+		ch <- true
+	}(done)
+
+	if channels.OK(done) {
+		return auth.CreateToken(user.ID)
+	}
+	return "", err
+}