kopia lustrzana https://github.com/reiver/greatape
125 wiersze
3.0 KiB
Go
125 wiersze
3.0 KiB
Go
package server
|
|
|
|
import (
|
|
. "contracts"
|
|
"strings"
|
|
"time"
|
|
"utility/jwt"
|
|
|
|
"github.com/gofiber/fiber/v2"
|
|
"github.com/gofiber/fiber/v2/middleware/cors"
|
|
_ "github.com/gofiber/fiber/v2/middleware/csrf"
|
|
"github.com/gofiber/fiber/v2/middleware/limiter"
|
|
"github.com/gofiber/fiber/v2/middleware/logger"
|
|
"github.com/gofiber/fiber/v2/middleware/recover"
|
|
"github.com/gofiber/helmet/v2"
|
|
"github.com/gofiber/template/html"
|
|
)
|
|
|
|
type httpServer struct {
|
|
framework *fiber.App
|
|
storage IStorage
|
|
logger ILogger
|
|
}
|
|
|
|
func authorization(c *fiber.Ctx) error {
|
|
h := c.Get("Authorization")
|
|
|
|
if h == "" {
|
|
return fiber.ErrUnauthorized
|
|
}
|
|
|
|
// Spliting the header
|
|
chunks := strings.Split(h, " ")
|
|
|
|
// If header signature is not like `Bearer <token>`, then throw
|
|
// This is also required, otherwise chunks[1] will throw out of bound error
|
|
if len(chunks) < 2 {
|
|
return fiber.ErrUnauthorized
|
|
}
|
|
|
|
// Verify the token which is in the chunks
|
|
user, err := jwt.Verify(chunks[1])
|
|
|
|
if err != nil {
|
|
return fiber.ErrUnauthorized
|
|
}
|
|
|
|
c.Locals("USER", user.ID)
|
|
|
|
return c.Next()
|
|
}
|
|
|
|
func New() IServer {
|
|
framework := fiber.New(fiber.Config{
|
|
DisableStartupMessage: true,
|
|
Views: html.New("./views", ".html"),
|
|
})
|
|
|
|
// framework.Get("/u/:name/inbox").Use(authorization)
|
|
// framework.Post("/u/:name/outbox").Use(authorization)
|
|
framework.Group("/api/v1/profile").Use(authorization)
|
|
|
|
framework.Use(
|
|
cors.New(),
|
|
logger.New(logger.Config{
|
|
Next: nil,
|
|
Format: "[${time}] ${status} - ${latency} ${method} ${path} ${body}\n",
|
|
TimeFormat: "15:04:05",
|
|
TimeZone: "Local",
|
|
TimeInterval: 500 * time.Millisecond,
|
|
}),
|
|
recover.New(),
|
|
helmet.New(),
|
|
// csrf.New(),
|
|
limiter.New(limiter.Config{
|
|
Max: 20,
|
|
Expiration: 30 * time.Second,
|
|
LimiterMiddleware: limiter.SlidingWindow{},
|
|
}),
|
|
)
|
|
|
|
return &httpServer{
|
|
framework: framework,
|
|
}
|
|
}
|
|
|
|
func (server *httpServer) SetStorageProvider(storage IStorage) {
|
|
server.storage = storage
|
|
}
|
|
|
|
func (server *httpServer) SetLogger(logger ILogger) {
|
|
server.logger = logger
|
|
}
|
|
|
|
func (server *httpServer) Bind(routes ...IRoute) {
|
|
for _, route := range routes {
|
|
func(route IRoute) {
|
|
switch route.Method() {
|
|
case HttpGet:
|
|
server.framework.Get(route.Path(), func(underlyingContext *fiber.Ctx) error {
|
|
return route.Handler()(newContext(underlyingContext))
|
|
})
|
|
case HttpPost:
|
|
server.framework.Post(route.Path(), func(underlyingContext *fiber.Ctx) error {
|
|
return route.Handler()(newContext(underlyingContext))
|
|
})
|
|
case HttpPut:
|
|
server.framework.Put(route.Path(), func(underlyingContext *fiber.Ctx) error {
|
|
return route.Handler()(newContext(underlyingContext))
|
|
})
|
|
case HttpDelete:
|
|
server.framework.Delete(route.Path(), func(underlyingContext *fiber.Ctx) error {
|
|
return route.Handler()(newContext(underlyingContext))
|
|
})
|
|
default:
|
|
panic("unsupported_method")
|
|
}
|
|
}(route)
|
|
}
|
|
}
|
|
|
|
func (server *httpServer) Listen(address string) {
|
|
server.framework.Listen(address)
|
|
}
|