🎨 archive fiber api & add svelte poc

_archives/api/main_test.go

@@ -0,0 +1,30 @@
+package api
+
+import (
+	"github.com/stretchr/testify/require"
+	db "github.com/zcubbs/tlz/db/sqlc"
+	"github.com/zcubbs/tlz/internal/util"
+	"github.com/zcubbs/tlz/pkg/random"
+	"os"
+	"testing"
+	"time"
+)
+
+func newTestServer(t *testing.T, store db.Store) *Server {
+	config := util.Config{
+		Auth: util.AuthConfig{
+			TokenSymmetricKey:    random.RandomString(32),
+			AccessTokenDuration:  time.Minute,
+			RefreshTokenDuration: 5 * time.Minute,
+		},
+	}
+
+	server, err := NewServer(store, nil, config)
+	require.NoError(t, err)
+
+	return server
+}
+
+func TestMain(m *testing.M) {
+	os.Exit(m.Run())
+}

_archives/api/server.go

@@ -0,0 +1,111 @@
+package api
+
+import (
+	"embed"
+	"fmt"
+	"github.com/charmbracelet/log"
+	"github.com/gofiber/fiber/v2"
+	"github.com/gofiber/fiber/v2/middleware/cors"
+	"github.com/gofiber/fiber/v2/middleware/filesystem"
+	"github.com/gofiber/fiber/v2/middleware/requestid"
+	db "github.com/zcubbs/tlz/db/sqlc"
+	"github.com/zcubbs/tlz/internal/util"
+	"github.com/zcubbs/tlz/pkg/charmlogfiber"
+	"github.com/zcubbs/tlz/pkg/token"
+	"net/http"
+)
+
+type Server struct {
+	store       db.Store
+	app         *fiber.App
+	tokenMaker  token.Maker
+	cfg         util.Config
+	staticEmbed *embed.FS
+	validate    *XValidator
+}
+
+func NewServer(store db.Store, staticEmbed *embed.FS, cfg util.Config) (*Server, error) {
+	tokenMaker, err := token.NewPasetoMaker(cfg.Auth.TokenSymmetricKey)
+	if err != nil {
+		return nil, fmt.Errorf("cannot create new tokenMaker: %w", err)
+	}
+	s := &Server{
+		store:       store,
+		tokenMaker:  tokenMaker,
+		cfg:         cfg,
+		staticEmbed: staticEmbed,
+	}
+
+	s.ApplyDefaultConfig()
+
+	return s, nil
+}
+
+func (s *Server) Start() error {
+	log.Info("starting HTTP server", "port", s.cfg.HttpServer.Port)
+	return s.app.Listen(fmt.Sprintf(":%d", s.cfg.HttpServer.Port))
+}
+
+func (s *Server) ApplyDefaultConfig() {
+	app := fiber.New(fiber.Config{
+		EnablePrintRoutes:     s.cfg.HttpServer.EnablePrintRoutes,
+		DisableStartupMessage: true,
+	})
+
+	s.app = app
+	s.addValidator()
+	s.applyMiddleware()
+	s.addRoutes()
+	s.embedStatic()
+}
+
+func (s *Server) addRoutes() {
+	users := s.app.Group("/api/users")
+	users.Post("/login", s.loginUser)
+	users.Post("/", s.createUser)
+
+	tokens := s.app.Group("/api/tokens")
+	tokens.Post("/refresh", s.renewAccessToken)
+
+	domains := s.app.Group("/api/domains")
+	domains.Use(AuthMiddleware(s.tokenMaker))
+	domains.Post("/", s.CreateDomain)
+	domains.Get("/", s.GetDomains)
+}
+
+func (s *Server) applyMiddleware() {
+	// Initialize default config
+	s.app.Use(cors.New())
+	s.app.Use(requestid.New())
+	// Logging Request ID
+	s.app.Use(requestid.New())
+	s.app.Use(charmlogfiber.New(log.Default()))
+
+	// Or extend your config for customization
+	s.app.Use(cors.New(cors.Config{
+		AllowOrigins: s.cfg.HttpServer.AllowOrigins,
+		AllowHeaders: s.cfg.HttpServer.AllowHeaders,
+	}))
+}
+
+func (s *Server) embedStatic() {
+	if s.staticEmbed != nil {
+		s.app.Use("/", filesystem.New(filesystem.Config{
+			Root:       http.FS(s.staticEmbed),
+			PathPrefix: "web/dist",
+		}))
+	}
+}
+
+func (s *Server) addValidator() {
+	val := &XValidator{
+		validator: validate,
+	}
+
+	err := val.validator.RegisterValidation("domain-name", validDomainName)
+	if err != nil {
+		log.Fatal("cannot register domain-name validator", "error", err)
+	}
+
+	s.validate = val
+}

gapi/authorization.go → api/authorization.go

@@ -1,4 +1,4 @@
-package gapi
+package api
 
 import (
 	"context"

gapi/converter.go → api/converter.go

@@ -1,4 +1,4 @@
-package gapi
+package api
 
 import (
 	db "github.com/zcubbs/tlz/db/sqlc"

gapi/error.go → api/error.go

@@ -1,4 +1,4 @@
-package gapi
+package api
 
 import (
 	"google.golang.org/genproto/googleapis/rpc/errdetails"

gapi/logger.go → api/logger.go

@@ -1,4 +1,4 @@
-package gapi
+package api
 
 import (
 	"context"

api/main_test.go

@@ -1,16 +1,21 @@
 package api
 
 import (
+	"context"
+	"fmt"
+	"github.com/google/uuid"
 	"github.com/stretchr/testify/require"
 	db "github.com/zcubbs/tlz/db/sqlc"
 	"github.com/zcubbs/tlz/internal/util"
 	"github.com/zcubbs/tlz/pkg/random"
-	"os"
+	"github.com/zcubbs/tlz/pkg/token"
+	"github.com/zcubbs/tlz/worker"
+	"google.golang.org/grpc/metadata"
 	"testing"
 	"time"
 )
 
-func newTestServer(t *testing.T, store db.Store) *Server {
+func newTestServer(t *testing.T, store db.Store, taskDistributor worker.TaskDistributor) *Server {
 	config := util.Config{
 		Auth: util.AuthConfig{
 			TokenSymmetricKey:    random.RandomString(32),
@@ -19,12 +24,22 @@ func newTestServer(t *testing.T, store db.Store) *Server {
 		},
 	}
 
-	server, err := NewServer(store, nil, config)
+	server, err := NewServer(store, taskDistributor, config)
 	require.NoError(t, err)
 
 	return server
 }
 
-func TestMain(m *testing.M) {
-	os.Exit(m.Run())
+func newContextWithBearerToken(t *testing.T, tokenMaker token.Maker, username string, userId uuid.UUID, duration time.Duration) context.Context {
+	accessToken, _, err := tokenMaker.CreateToken(username, userId, duration)
+	require.NoError(t, err)
+
+	bearerToken := fmt.Sprintf("%s %s", authorizationBearer, accessToken)
+	md := metadata.MD{
+		authorizationHeader: []string{
+			bearerToken,
+		},
+	}
+
+	return metadata.NewIncomingContext(context.Background(), md)
 }

gapi/metadata.go → api/metadata.go

@@ -1,4 +1,4 @@
-package gapi
+package api
 
 import (
 	"context"

gapi/rpc_create_user.go → api/rpc_create_user.go

@@ -1,4 +1,4 @@
-package gapi
+package api
 
 import (
 	"context"

gapi/rpc_create_user_test.go → api/rpc_create_user_test.go

@@ -1,4 +1,4 @@
-package gapi
+package api
 
 import (
 	"context"

gapi/rpc_login_user.go → api/rpc_login_user.go

@@ -1,4 +1,4 @@
-package gapi
+package api
 
 import (
 	"context"

gapi/rpc_ping.go → api/rpc_ping.go

@@ -1,4 +1,4 @@
-package gapi
+package api
 
 import (
 	"context"

gapi/rpc_update_user.go → api/rpc_update_user.go

@@ -1,4 +1,4 @@
-package gapi
+package api
 
 import (
 	"context"

gapi/rpc_verify_user.go → api/rpc_verify_user.go

@@ -1,4 +1,4 @@
-package gapi
+package api
 
 import (
 	"context"