Add lesson02 / video03

Author: joanlopez

02-03-controller-test/cmd/api/bootstrap/boostrap.go

@@ -0,0 +1,34 @@
+package bootstrap
+
+import (
+	"database/sql"
+	"fmt"
+
+	"github.com/CodelyTV/go-hexagonal_http_api-course/02-03-controller-test/internal/platform/server"
+	"github.com/CodelyTV/go-hexagonal_http_api-course/02-03-controller-test/internal/platform/storage/mysql"
+	_ "github.com/go-sql-driver/mysql"
+)
+
+const (
+	host = "localhost"
+	port = 8080
+
+	dbUser = "codely"
+	dbPass = "codely"
+	dbHost = "localhost"
+	dbPort = "3306"
+	dbName = "codely"
+)
+
+func Run() error {
+	mysqlURI := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s", dbUser, dbPass, dbHost, dbPort, dbName)
+	db, err := sql.Open("mysql", mysqlURI)
+	if err != nil {
+		return err
+	}
+
+	courseRepository := mysql.NewCourseRepository(db)
+
+	srv := server.New(host, port, courseRepository)
+	return srv.Run()
+}

02-03-controller-test/cmd/api/main.go

@@ -0,0 +1,13 @@
+package main
+
+import (
+	"log"
+
+	"github.com/CodelyTV/go-hexagonal_http_api-course/02-03-controller-test/cmd/api/bootstrap"
+)
+
+func main() {
+	if err := bootstrap.Run(); err != nil {
+		log.Fatal(err)
+	}
+}

02-03-controller-test/internal/course.go

@@ -0,0 +1,41 @@
+package mooc
+
+import "context"
+
+// CourseRepository defines the expected behaviour from a course storage.
+type CourseRepository interface {
+	Save(ctx context.Context, course Course) error
+}
+
+//go:generate mockery --case=snake --outpkg=storagemocks --output=platform/storage/storagemocks --name=CourseRepository
+
+// Course is the data structure that represents a course.
+type Course struct {
+	id       string
+	name     string
+	duration string
+}
+
+// NewCourse creates a new course.
+func NewCourse(id, name, duration string) Course {
+	return Course{
+		id:       id,
+		name:     name,
+		duration: duration,
+	}
+}
+
+// ID returns the course unique identifier.
+func (c Course) ID() string {
+	return c.id
+}
+
+// Name returns the course name.
+func (c Course) Name() string {
+	return c.name
+}
+
+// Duration returns the course duration.
+func (c Course) Duration() string {
+	return c.duration
+}

02-03-controller-test/internal/platform/server/handler/courses/create.go

@@ -0,0 +1,33 @@
+package courses
+
+import (
+	"net/http"
+
+	mooc "github.com/CodelyTV/go-hexagonal_http_api-course/02-03-controller-test/internal"
+	"github.com/gin-gonic/gin"
+)
+
+type createRequest struct {
+	ID       string `json:"id" binding:"required"`
+	Name     string `json:"name" binding:"required"`
+	Duration string `json:"duration" binding:"required"`
+}
+
+// CreateHandler returns an HTTP handler for courses creation.
+func CreateHandler(courseRepository mooc.CourseRepository) gin.HandlerFunc {
+	return func(ctx *gin.Context) {
+		var req createRequest
+		if err := ctx.BindJSON(&req); err != nil {
+			ctx.JSON(http.StatusBadRequest, err.Error())
+			return
+		}
+
+		course := mooc.NewCourse(req.ID, req.Name, req.Duration)
+		if err := courseRepository.Save(ctx, course); err != nil {
+			ctx.JSON(http.StatusInternalServerError, err.Error())
+			return
+		}
+
+		ctx.Status(http.StatusCreated)
+	}
+}

02-03-controller-test/internal/platform/server/handler/courses/create_test.go

@@ -0,0 +1,67 @@
+package courses
+
+import (
+	"bytes"
+	"encoding/json"
+	"net/http"
+	"net/http/httptest"
+	"testing"
+
+	"github.com/CodelyTV/go-hexagonal_http_api-course/02-03-controller-test/internal/platform/storage/storagemocks"
+	"github.com/gin-gonic/gin"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/mock"
+	"github.com/stretchr/testify/require"
+)
+
+func TestHandler_Create(t *testing.T) {
+	courseRepository := new(storagemocks.CourseRepository)
+	courseRepository.On("Save", mock.Anything, mock.AnythingOfType("mooc.Course")).Return(nil)
+
+	gin.SetMode(gin.TestMode)
+	r := gin.New()
+	r.POST("/courses", CreateHandler(courseRepository))
+
+	t.Run("given an invalid request it returns 400", func(t *testing.T) {
+		createCourseReq := createRequest{
+			ID:   "8a1c5cdc-ba57-445a-994d-aa412d23723f",
+			Name: "Demo Course",
+		}
+
+		b, err := json.Marshal(createCourseReq)
+		require.NoError(t, err)
+
+		req, err := http.NewRequest(http.MethodPost, "/courses", bytes.NewBuffer(b))
+		require.NoError(t, err)
+
+		rec := httptest.NewRecorder()
+		r.ServeHTTP(rec, req)
+
+		res := rec.Result()
+		defer res.Body.Close()
+
+		assert.Equal(t, http.StatusBadRequest, res.StatusCode)
+	})
+
+	t.Run("given a valid request it returns 201", func(t *testing.T) {
+		createCourseReq := createRequest{
+			ID:       "8a1c5cdc-ba57-445a-994d-aa412d23723f",
+			Name:     "Demo Course",
+			Duration: "10 months",
+		}
+
+		b, err := json.Marshal(createCourseReq)
+		require.NoError(t, err)
+
+		req, err := http.NewRequest(http.MethodPost, "/courses", bytes.NewBuffer(b))
+		require.NoError(t, err)
+
+		rec := httptest.NewRecorder()
+		r.ServeHTTP(rec, req)
+
+		res := rec.Result()
+		defer res.Body.Close()
+
+		assert.Equal(t, http.StatusCreated, res.StatusCode)
+	})
+}

02-03-controller-test/internal/platform/server/handler/health/check.go

@@ -0,0 +1,14 @@
+package health
+
+import (
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+)
+
+// CheckHandler returns an HTTP handler to perform health checks.
+func CheckHandler() gin.HandlerFunc {
+	return func(ctx *gin.Context) {
+		ctx.String(http.StatusOK, "everything is ok!")
+	}
+}

02-03-controller-test/internal/platform/server/server.go

@@ -0,0 +1,41 @@
+package server
+
+import (
+	"fmt"
+	"log"
+
+	mooc "github.com/CodelyTV/go-hexagonal_http_api-course/02-03-controller-test/internal"
+	"github.com/CodelyTV/go-hexagonal_http_api-course/02-03-controller-test/internal/platform/server/handler/courses"
+	"github.com/CodelyTV/go-hexagonal_http_api-course/02-03-controller-test/internal/platform/server/handler/health"
+	"github.com/gin-gonic/gin"
+)
+
+type Server struct {
+	httpAddr string
+	engine   *gin.Engine
+
+	// deps
+	courseRepository mooc.CourseRepository
+}
+
+func New(host string, port uint, courseRepository mooc.CourseRepository) Server {
+	srv := Server{
+		engine:   gin.New(),
+		httpAddr: fmt.Sprintf("%s:%d", host, port),
+
+		courseRepository: courseRepository,
+	}
+
+	srv.registerRoutes()
+	return srv
+}
+
+func (s *Server) Run() error {
+	log.Println("Server running on", s.httpAddr)
+	return s.engine.Run(s.httpAddr)
+}
+
+func (s *Server) registerRoutes() {
+	s.engine.GET("/health", health.CheckHandler())
+	s.engine.POST("/courses", courses.CreateHandler(s.courseRepository))
+}

02-03-controller-test/internal/platform/storage/mysql/course.go

@@ -0,0 +1,11 @@
+package mysql
+
+const (
+	sqlCourseTable = "courses"
+)
+
+type sqlCourse struct {
+	ID       string `db:"id"`
+	Name     string `db:"name"`
+	Duration string `db:"duration"`
+}

02-03-controller-test/internal/platform/storage/mysql/course_repository.go

@@ -0,0 +1,39 @@
+package mysql
+
+import (
+	"context"
+	"database/sql"
+	"fmt"
+
+	mooc "github.com/CodelyTV/go-hexagonal_http_api-course/02-03-controller-test/internal"
+	"github.com/huandu/go-sqlbuilder"
+)
+
+// CourseRepository is a MySQL mooc.CourseRepository implementation.
+type CourseRepository struct {
+	db *sql.DB
+}
+
+// NewCourseRepository initializes a MySQL-based implementation of mooc.CourseRepository.
+func NewCourseRepository(db *sql.DB) *CourseRepository {
+	return &CourseRepository{
+		db: db,
+	}
+}
+
+// Save implements the mooc.CourseRepository interface.
+func (r *CourseRepository) Save(ctx context.Context, course mooc.Course) error {
+	courseSQLStruct := sqlbuilder.NewStruct(new(sqlCourse))
+	query, args := courseSQLStruct.InsertInto(sqlCourseTable, sqlCourse{
+		ID:       course.ID(),
+		Name:     course.Name(),
+		Duration: course.Duration(),
+	}).Build()
+
+	_, err := r.db.ExecContext(ctx, query, args...)
+	if err != nil {
+		return fmt.Errorf("error trying to persist course on database: %v", err)
+	}
+
+	return nil
+}