Transport layer

Author: Onur Menal

cmd/server/main.go

@@ -6,6 +6,7 @@ import (
 
 	"github.com/onurmenal/go-rest-api/internal/comment"
 	"github.com/onurmenal/go-rest-api/internal/db"
+	transportHttp "github.com/onurmenal/go-rest-api/internal/transport/http"
 )
 
 func Run() error {
@@ -28,13 +29,10 @@ func Run() error {
 
 	cmtService := comment.NewService(db)
 
-	fmt.Println(cmtService.PostComment(context.Background(), comment.Comment{
-		Slug:   "testslug",
-		Body:   "testbody",
-		Author: "onur menal",
-	}))
-
-	fmt.Println("Successfully connected and pinged database")
+	httpHandler := transportHttp.NewHandler(cmtService)
+	if err := httpHandler.Serve(); err != nil {
+		return err
+	}
 
 	return nil
 }

deployment/docker-compose.yml docker-compose.yml

@@ -5,6 +5,7 @@ go 1.16
 require (
 	github.com/golang-migrate/migrate/v4 v4.15.2 // indirect
 	github.com/google/go-github/v35 v35.2.0 // indirect
+	github.com/gorilla/mux v1.8.0 // indirect
 	github.com/jmoiron/sqlx v1.3.5 // indirect
 	github.com/lib/pq v1.10.6 // indirect
 	github.com/satori/go.uuid v1.2.0 // indirect

go.mod

@@ -587,6 +587,8 @@ github.com/gorilla/handlers v1.4.2/go.mod h1:Qkdc/uu4tH4g6mTK6auzZ766c4CA0Ng8+o/
 github.com/gorilla/mux v1.7.2/go.mod h1:1lud6UwP+6orDFRuTfBEV8e9/aOM/c4fVVCaMa2zaAs=
 github.com/gorilla/mux v1.7.3/go.mod h1:1lud6UwP+6orDFRuTfBEV8e9/aOM/c4fVVCaMa2zaAs=
 github.com/gorilla/mux v1.7.4/go.mod h1:DVbg23sWSpFRCP0SfiEN6jmj59UnW/n46BH5rLB71So=
+github.com/gorilla/mux v1.8.0 h1:i40aqfkR1h2SlN9hojwV5ZA91wcXFOvkdNIeFDP5koI=
+github.com/gorilla/mux v1.8.0/go.mod h1:DVbg23sWSpFRCP0SfiEN6jmj59UnW/n46BH5rLB71So=
 github.com/gorilla/websocket v0.0.0-20170926233335-4201258b820c/go.mod h1:E7qHFY5m1UJ88s3WnNqhKjPHQ0heANvMoAMk2YaljkQ=
 github.com/gorilla/websocket v1.4.0/go.mod h1:E7qHFY5m1UJ88s3WnNqhKjPHQ0heANvMoAMk2YaljkQ=
 github.com/gorilla/websocket v1.4.2/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=

go.sum

@@ -0,0 +1,62 @@
+package http
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"net/http"
+	"os"
+	"os/signal"
+	"time"
+
+	"github.com/gorilla/mux"
+)
+
+type CommentService interface{}
+
+type Handler struct {
+	Router  *mux.Router
+	Service CommentService
+	Server  *http.Server
+}
+
+func NewHandler(service CommentService) *Handler {
+	h := &Handler{
+		Service: service,
+	}
+	h.Router = mux.NewRouter()
+	h.mapRoutes()
+
+	h.Server = &http.Server{
+		Addr:    "0.0.0.0:8080",
+		Handler: h.Router,
+	}
+
+	return h
+}
+
+func (h *Handler) mapRoutes() {
+	h.Router.HandleFunc("/hello", func(w http.ResponseWriter, r *http.Request) {
+		fmt.Fprintf(w, "Hello World")
+	})
+}
+
+func (h *Handler) Serve() error {
+	go func() {
+		if err := h.Server.ListenAndServe(); err != nil {
+			log.Println(err.Error())
+		}
+	}()
+
+	c := make(chan os.Signal, 1)
+	signal.Notify(c, os.Interrupt)
+	<-c
+
+	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
+	defer cancel()
+	h.Server.Shutdown(ctx)
+
+	log.Println("shutting down")
+
+	return nil
+}