Test with MYSQL in travis

.travis.yml

@@ -2,13 +2,17 @@ language: go
 
 go_import_path: project-root
 
+services:
+  - mysql
+
 go:
   - "1.8"
   - "1.9"
   - "1.10"
   - "tip"
 
 before_install:
+  - mysql -e 'CREATE DATABASE webapitest;'
   - export GOPATH=$HOME/gopath/src/project-root
   - export PATH=$HOME/gopath/src/project-root/bin:$PATH
   - cd $GOPATH/src/app/webapi

migration/tables-only.sql

@@ -0,0 +1,41 @@
+SET NAMES utf8 COLLATE 'utf8_unicode_ci';
+SET foreign_key_checks = 1;
+SET time_zone = '+00:00';
+SET sql_mode = 'NO_AUTO_VALUE_ON_ZERO';
+SET CHARACTER SET utf8;
+
+CREATE TABLE IF NOT EXISTS user_status (
+    id TINYINT(1) UNSIGNED NOT NULL AUTO_INCREMENT,
+
+    status VARCHAR(25) NOT NULL,
+
+    created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+    deleted TINYINT(1) UNSIGNED NOT NULL DEFAULT 0,
+
+    PRIMARY KEY (id)
+);
+
+CREATE TABLE IF NOT EXISTS user (
+    id VARCHAR(36) NOT NULL,
+
+    first_name VARCHAR(50) NOT NULL,
+    last_name VARCHAR(50) NOT NULL,
+    email VARCHAR(100) NOT NULL,
+    password CHAR(60) NOT NULL,
+
+    status_id TINYINT(1) UNSIGNED NOT NULL DEFAULT 1,
+
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+    deleted_at TIMESTAMP DEFAULT 0,
+
+    UNIQUE KEY (email),
+    CONSTRAINT `f_user_status` FOREIGN KEY (`status_id`) REFERENCES `user_status` (`id`) ON DELETE CASCADE ON UPDATE CASCADE,
+
+    PRIMARY KEY (id)
+);
+
+INSERT INTO `user_status` (`id`, `status`, `created_at`, `updated_at`, `deleted`) VALUES
+(1, 'active',   CURRENT_TIMESTAMP,  CURRENT_TIMESTAMP,  0),
+(2, 'inactive', CURRENT_TIMESTAMP,  CURRENT_TIMESTAMP,  0);

src/app/webapi/component/core_mock.go

@@ -1,16 +1,40 @@
 package component
 
 import (
+	"log"
+
 	"app/webapi/internal/bind"
 	"app/webapi/internal/response"
 	"app/webapi/internal/testutil"
+	"app/webapi/pkg/database"
 	"app/webapi/pkg/query"
 )
 
+// TestDatabase returns a test database.
+func TestDatabase(dbSpecificDB bool) *database.DBW {
+	dbc := new(database.Connection)
+	dbc.Hostname = "127.0.0.1"
+	dbc.Port = 3306
+	dbc.Username = "root"
+	dbc.Password = ""
+	dbc.Database = "webapitest"
+	dbc.Parameter = "parseTime=true&allowNativePasswords=true"
+
+	connection, err := dbc.Connect(dbSpecificDB)
+	if err != nil {
+		log.Println("DB Error:", err)
+	}
+
+	dbw := database.New(connection)
+
+	return dbw
+}
+
 // NewCoreMock returns all mocked dependencies.
 func NewCoreMock() (Core, *CoreMock) {
 	ml := new(testutil.MockLogger)
-	md := new(testutil.MockDatabase)
+	//md := new(testutil.MockDatabase)
+	md := TestDatabase(true)
 	mq := query.New(md)
 	mt := new(testutil.MockToken)
 	resp := response.New()
@@ -31,7 +55,7 @@ func NewCoreMock() (Core, *CoreMock) {
 // CoreMock contains all the mocked dependencies.
 type CoreMock struct {
 	Log     *testutil.MockLogger
-	DB      *testutil.MockDatabase
+	DB      IDatabase
 	Q       IQuery
 	Bind    IBind
 	Reponse IResponse

src/app/webapi/component/interface.go

@@ -19,11 +19,11 @@ type IDatabase interface {
 	Error(err error) error
 	AffectedRows(result sql.Result) int
 
-	PaginatedResults(results interface{}, fn func() (results interface{}, total int, err error)) (total int, err error)
+	/*PaginatedResults(results interface{}, fn func() (results interface{}, total int, err error)) (total int, err error)
 	RecordExistsInt(fn func() (exists bool, ID int64, err error)) (exists bool, ID int64, err error)
 	RecordExistsString(fn func() (exists bool, ID string, err error)) (exists bool, ID string, err error)
 	AddRecordInt(fn func() (ID int64, err error)) (ID int64, err error)
-	AddRecordString(fn func() (ID string, err error)) (ID string, err error)
+	AddRecordString(fn func() (ID string, err error)) (ID string, err error)*/
 }
 
 // IQuery provides default queries.

src/app/webapi/component/user/create.go

@@ -0,0 +1,66 @@
+package user
+
+import (
+	"errors"
+	"net/http"
+
+	"app/webapi/store"
+)
+
+// Create .
+// swagger:route POST /v1/user user UserCreate
+//
+// Create a user.
+//
+// Security:
+//   token:
+//
+// Responses:
+//   201: CreatedResponse
+//   400: BadRequestResponse
+//   401: UnauthorizedResponse
+//   500: InternalServerErrorResponse
+func (p *Endpoint) Create(w http.ResponseWriter, r *http.Request) (int, error) {
+	// swagger:parameters UserCreate
+	type request struct {
+		// in: formData
+		// Required: true
+		FirstName string `json:"first_name" validate:"required"`
+		// in: formData
+		// Required: true
+		LastName string `json:"last_name" validate:"required"`
+		// in: formData
+		// Required: true
+		Email string `json:"email" validate:"required,email"`
+		// in: formData
+		// Required: true
+		Password string `json:"password" validate:"required"`
+	}
+
+	// Request validation.
+	req := new(request)
+	if err := p.Bind.FormUnmarshal(req, r); err != nil {
+		return http.StatusBadRequest, err
+	} else if err = p.Bind.Validate(req); err != nil {
+		return http.StatusBadRequest, err
+	}
+
+	// Create the store.
+	u := store.NewUser(p.DB, p.Q)
+
+	// Check for existing user.
+	exists, _, err := u.ExistsByField(u, "email", req.Email)
+	if err != nil {
+		return http.StatusInternalServerError, err
+	} else if exists {
+		return http.StatusBadRequest, errors.New("user already exists")
+	}
+
+	// Create the user in the database.
+	ID, err := u.Create(req.FirstName, req.LastName, req.Email, req.Password)
+	if err != nil {
+		return http.StatusInternalServerError, err
+	}
+
+	return p.Response.Created(w, ID)
+}