Compare commits
No commits in common. "project-structure" and "api-shopping" have entirely different histories.
project-st
...
api-shoppi
3
README.md
Normal file
3
README.md
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
# 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.
|
89
api/server.go
Normal file
89
api/server.go
Normal file
@ -0,0 +1,89 @@
|
|||||||
|
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 +0,0 @@
|
|||||||
package server
|
|
2
go.mod
2
go.mod
@ -3,6 +3,6 @@ module endmove/webserverlearning
|
|||||||
go 1.18
|
go 1.18
|
||||||
|
|
||||||
require (
|
require (
|
||||||
|
github.com/google/uuid v1.3.0
|
||||||
github.com/gorilla/mux v1.8.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 h1:i40aqfkR1h2SlN9hojwV5ZA91wcXFOvkdNIeFDP5koI=
|
||||||
github.com/gorilla/mux v1.8.0/go.mod h1:DVbg23sWSpFRCP0SfiEN6jmj59UnW/n46BH5rLB71So=
|
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=
|
|
||||||
|
@ -1,20 +0,0 @@
|
|||||||
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
Normal file
66
main.go
Normal file
@ -0,0 +1,66 @@
|
|||||||
|
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...")
|
||||||
|
// }
|
13
shopping.rest
Normal file
13
shopping.rest
Normal file
@ -0,0 +1,13 @@
|
|||||||
|
### 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 +0,0 @@
|
|||||||
package store
|
|
@ -1,17 +0,0 @@
|
|||||||
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)
|
|
||||||
}
|
|
||||||
}
|
|
@ -1,33 +0,0 @@
|
|||||||
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