dwelling-upload/pkg/server/http.go

package server

import (
	"context"
	"crypto/subtle"
	"encoding/json"
	"log"
	"net"
	"net/http"
	"time"

	"github.com/julienschmidt/httprouter"
)

type HttpServer struct {
	server *http.Server
	router *httprouter.Router
}

func NewHttpServer() *HttpServer {
	r := httprouter.New()
	return &HttpServer{
		server: &http.Server{
			ReadTimeout:  3 * time.Second,
			WriteTimeout: 3 * time.Second,
			Handler:      r,
		},
		router: r,
	}
}

func (s *HttpServer) GET(path string, handler http.HandlerFunc) {
	s.router.Handler(http.MethodGet, path, handler)
}

func (s *HttpServer) POST(path string, handler http.HandlerFunc) {
	s.router.Handler(http.MethodPost, path, handler)
}

func (s *HttpServer) PATCH(path string, handler http.HandlerFunc) {
	s.router.Handler(http.MethodPatch, path, handler)
}

func (s *HttpServer) PUT(path string, handler http.HandlerFunc) {
	s.router.Handler(http.MethodPut, path, handler)
}

func (s *HttpServer) DELETE(path string, handler http.HandlerFunc) {
	s.router.Handler(http.MethodDelete, path, handler)
}

func (s *HttpServer) ServeStatic(path string, fsys http.FileSystem) {
	s.router.ServeFiles(path, fsys)
}

// GetURLParam wrapper around underlying router for getting URL parameters.
func GetURLParam(r *http.Request, param string) string {
	return httprouter.ParamsFromContext(r.Context()).ByName(param)
}

func (s *HttpServer) Start(network, address string) error {
	listener, err := net.Listen(network, address)
	if err != nil {
		return err
	}

	go func() {
		if err = s.server.Serve(listener); err != nil && err != http.ErrServerClosed {
			log.Fatalln(err)
		}
	}()

	return nil
}

func (s *HttpServer) Stop() error {
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()

	if err := s.server.Shutdown(ctx); err != nil {
		return err
	}

	return nil
}

// AuthWithToken middleware that authenticates user by token (that is effectively just a password)
// supplied in an 'Authentication-Token' HTTP header.
func AuthWithToken(handler http.HandlerFunc, token string) http.HandlerFunc {
	return func(rw http.ResponseWriter, r *http.Request) {
		if subtle.ConstantTimeCompare([]byte(r.Header.Get("Authentication-Token")), []byte(token)) == 1 {
			handler(rw, r)
		} else {
			rw.WriteHeader(http.StatusUnauthorized)
			rw.Header().Add("Content-Type", "application/json")
			response := make(map[string]string)
			response["message"] = "Unauthorized"
			json.NewEncoder(rw).Encode(response)
		}
	}
}