Compare commits
1 Commits
api-shoppi
...
project-st
Author | SHA1 | Date | |
---|---|---|---|
0ec205fe25 |
@ -1,3 +0,0 @@
|
||||
# GoAsWebServer
|
||||
|
||||
Repository d'entrainement au développement de solutions web en Go. Chaque branche est axée sur un sujet différent et ou un test quelconque.
|
@ -1,89 +0,0 @@
|
||||
package api
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"net/http"
|
||||
|
||||
"github.com/google/uuid"
|
||||
"github.com/gorilla/mux"
|
||||
)
|
||||
|
||||
// Item data structure SUB
|
||||
type Item struct {
|
||||
ID uuid.UUID `json:"id"`
|
||||
Name string `json:"name"`
|
||||
}
|
||||
|
||||
// Server data structure MAIN
|
||||
type Server struct {
|
||||
*mux.Router // Merge mux router comportement with Server
|
||||
ShoppingItems []Item
|
||||
}
|
||||
|
||||
// Server Constructor
|
||||
func NewServer() *Server {
|
||||
server := &Server{
|
||||
Router: mux.NewRouter(),
|
||||
ShoppingItems: []Item{},
|
||||
}
|
||||
server.InitRoutes()
|
||||
return server
|
||||
}
|
||||
|
||||
// Init mux router
|
||||
func (server *Server) InitRoutes() {
|
||||
server.HandleFunc("/shopping-items", server.ListShoppingItems()).Methods("GET")
|
||||
server.HandleFunc("/shopping-items", server.CreateShoppingItem()).Methods("POST")
|
||||
server.HandleFunc("/shopping-items/{id}", server.RemoveShoppingItem()).Methods("DELETE")
|
||||
}
|
||||
|
||||
// Handler create item
|
||||
func (server *Server) CreateShoppingItem() http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
var item Item
|
||||
if err := json.NewDecoder(r.Body).Decode(&item); err != nil {
|
||||
http.Error(w, err.Error(), http.StatusBadRequest)
|
||||
return
|
||||
}
|
||||
|
||||
item.ID = uuid.New()
|
||||
server.ShoppingItems = append(server.ShoppingItems, item)
|
||||
|
||||
w.Header().Set("Content-Type", "application/json")
|
||||
if err := json.NewEncoder(w).Encode(item); err != nil {
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Handler retrieve items
|
||||
func (server *Server) ListShoppingItems() http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
w.Header().Set("Content-Type", "application/json")
|
||||
if err := json.NewEncoder(w).Encode(server.ShoppingItems); err != nil {
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Hndler remove item
|
||||
func (server *Server) RemoveShoppingItem() http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
rawID := mux.Vars(r)["id"]
|
||||
|
||||
itemID, err := uuid.Parse(rawID)
|
||||
if err != nil {
|
||||
http.Error(w, err.Error(), http.StatusBadRequest)
|
||||
return
|
||||
}
|
||||
|
||||
for i, item := range server.ShoppingItems {
|
||||
if item.ID == itemID {
|
||||
server.ShoppingItems = append(server.ShoppingItems[:i], server.ShoppingItems[i+1:]...)
|
||||
break
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
1
cmd/server/main.go
Normal file
1
cmd/server/main.go
Normal file
@ -0,0 +1 @@
|
||||
package server
|
2
go.mod
2
go.mod
@ -3,6 +3,6 @@ module endmove/webserverlearning
|
||||
go 1.18
|
||||
|
||||
require (
|
||||
github.com/google/uuid v1.3.0
|
||||
github.com/gorilla/mux v1.8.0
|
||||
github.com/russross/blackfriday/v2 v2.1.0
|
||||
)
|
||||
|
4
go.sum
4
go.sum
@ -1,4 +1,4 @@
|
||||
github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I=
|
||||
github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
|
||||
github.com/gorilla/mux v1.8.0 h1:i40aqfkR1h2SlN9hojwV5ZA91wcXFOvkdNIeFDP5koI=
|
||||
github.com/gorilla/mux v1.8.0/go.mod h1:DVbg23sWSpFRCP0SfiEN6jmj59UnW/n46BH5rLB71So=
|
||||
github.com/russross/blackfriday/v2 v2.1.0 h1:JIOH55/0cWyOuilr9/qlrm0BSXldqnqwMsf35Ld67mk=
|
||||
github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
|
||||
|
20
html/template.go
Normal file
20
html/template.go
Normal file
@ -0,0 +1,20 @@
|
||||
package html
|
||||
|
||||
import (
|
||||
"html/template"
|
||||
"strings"
|
||||
|
||||
"github.com/russross/blackfriday/v2"
|
||||
)
|
||||
|
||||
func Parse(templates ...string) *template.Template {
|
||||
return template.Must(template.New("ALL").Funcs(FuncMap()).ParseFiles(templates...))
|
||||
}
|
||||
|
||||
func FuncMap() template.FuncMap {
|
||||
return template.FuncMap{
|
||||
"lowercase": strings.ToLower,
|
||||
"uppercase": strings.ToUpper,
|
||||
"markdown": blackfriday.Run,
|
||||
}
|
||||
}
|
66
main.go
66
main.go
@ -1,66 +0,0 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"context"
|
||||
"endmove/webserverlearning/api"
|
||||
"flag"
|
||||
"fmt"
|
||||
"net/http"
|
||||
"os"
|
||||
"os/signal"
|
||||
"time"
|
||||
)
|
||||
|
||||
func main() {
|
||||
// define graceful time for webserver shutdown - not required
|
||||
var wait time.Duration
|
||||
|
||||
flag.DurationVar(&wait, "graceful-timeout", time.Second*30, "The time needed to close the connections")
|
||||
flag.Parse() // apply flags <!> one shot function
|
||||
|
||||
// Config webserver
|
||||
webserver := http.Server{
|
||||
Addr: ":8080",
|
||||
// Timeout (stop overloading and attack)
|
||||
WriteTimeout: time.Second * 15,
|
||||
ReadTimeout: time.Second * 15,
|
||||
IdleTimeout: time.Second * 60,
|
||||
// Mux instance
|
||||
Handler: api.NewServer(),
|
||||
}
|
||||
|
||||
// Start webserver in routine
|
||||
go func() {
|
||||
if err := webserver.ListenAndServe(); err != nil {
|
||||
fmt.Println(err.Error())
|
||||
}
|
||||
}()
|
||||
fmt.Println("Server started on : http://localhost:8080")
|
||||
|
||||
// setuping sig to catch ctrl+c and throw a graceful stop
|
||||
sig := make(chan os.Signal, 1)
|
||||
signal.Notify(sig, os.Interrupt)
|
||||
|
||||
// waiting sig
|
||||
<-sig
|
||||
|
||||
// defining graceful timeout
|
||||
ctx, cancel := context.WithTimeout(context.Background(), wait)
|
||||
defer cancel()
|
||||
|
||||
// shut down webserver with countdown
|
||||
webserver.Shutdown(ctx)
|
||||
|
||||
fmt.Println("program has stopped")
|
||||
os.Exit(0)
|
||||
}
|
||||
|
||||
// func main() {
|
||||
// http.HandleFunc("/hello-world", func(w http.ResponseWriter, r *http.Request) {
|
||||
// w.Write([]byte("<h1>Hello World !</h1>"))
|
||||
// })
|
||||
// go http.ListenAndServe(":8080", nil)
|
||||
// fmt.Println("Server listening on port :8080 at http://localhost:8080")
|
||||
// time.Sleep(1 * time.Minute)
|
||||
// fmt.Println("Quit...")
|
||||
// }
|
@ -1,13 +0,0 @@
|
||||
### List shopping items
|
||||
GET http://localhost:8080/shopping-items
|
||||
|
||||
### Create new shopping item
|
||||
POST http://localhost:8080/shopping-items
|
||||
Content-Type: application/json
|
||||
|
||||
{
|
||||
"name": "MDR"
|
||||
}
|
||||
|
||||
### Remove shopping item
|
||||
DELETE http://localhost:8080/shopping-items/uuid
|
1
store/store.go
Normal file
1
store/store.go
Normal file
@ -0,0 +1 @@
|
||||
package store
|
17
web/middleware.go
Normal file
17
web/middleware.go
Normal file
@ -0,0 +1,17 @@
|
||||
package web
|
||||
|
||||
import "net/http"
|
||||
|
||||
func WithAuth(f http.HandlerFunc) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
// TODO check request auth
|
||||
f(w, r)
|
||||
}
|
||||
}
|
||||
|
||||
func WithCompression(f http.HandlerFunc) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
// TODO wrap writter in compressor
|
||||
f(w, r)
|
||||
}
|
||||
}
|
33
web/server.go
Normal file
33
web/server.go
Normal file
@ -0,0 +1,33 @@
|
||||
package web
|
||||
|
||||
import (
|
||||
"net/http"
|
||||
|
||||
"github.com/gorilla/mux"
|
||||
)
|
||||
|
||||
func NewServer() *Server {
|
||||
server := &Server{
|
||||
Router: mux.NewRouter(),
|
||||
}
|
||||
server.HandleFunc("/todos", server.todos).Methods("GET")
|
||||
server.HandleFunc("/todos", WithAuth(server.todoCreate)).Methods("POST")
|
||||
server.HandleFunc("/todos", WithAuth(server.todoDelete)).Methods("DELETE")
|
||||
return server
|
||||
}
|
||||
|
||||
type Server struct {
|
||||
*mux.Router
|
||||
}
|
||||
|
||||
func (server *Server) todos(w http.ResponseWriter, r *http.Request) {
|
||||
// TODO get
|
||||
}
|
||||
|
||||
func (server *Server) todoCreate(w http.ResponseWriter, r *http.Request) {
|
||||
// TODO get
|
||||
}
|
||||
|
||||
func (server *Server) todoDelete(w http.ResponseWriter, r *http.Request) {
|
||||
// TODO get
|
||||
}
|
Loading…
Reference in New Issue
Block a user