initial commit

This commit is contained in:
2023-01-31 02:40:19 +01:00
commit 552c004151
23 changed files with 1822 additions and 0 deletions
+52
View File
@@ -0,0 +1,52 @@
package config
import (
"phc/website/sl"
"github.com/joho/godotenv"
)
type Interface interface {
sl.Service
Mode() string
Host() string
}
type Custom struct {
ModeValue string
HostValue string
}
func (c Custom) Mode() string { return c.ModeValue }
func (c Custom) Host() string { return c.HostValue }
func (Custom) Initialize(l *sl.ServiceLocator) error {
return nil
}
type EnvConfig struct {
mode string
host string
}
func (c EnvConfig) Mode() string { return c.mode }
func (c EnvConfig) Host() string { return c.host }
func (c *EnvConfig) Initialize(l *sl.ServiceLocator) error {
m, err := godotenv.Read(".env")
if err != nil {
return err
}
c.mode = "production"
if v, ok := m["MODE"]; ok {
c.mode = v
}
c.host = ":4000"
if v, ok := m["HOST"]; ok {
c.host = v
}
return nil
}
+64
View File
@@ -0,0 +1,64 @@
package database
import (
"fmt"
"phc/website/model"
"phc/website/sl"
)
type Database interface {
sl.Service
CreateUser(user model.User) error
ReadUser(id string) (model.User, error)
ReadUsers() ([]model.User, error)
UpdateUser(id string, user model.User) error
DeleteUser(id string) error
}
type Memory struct {
Users []model.User
}
func (m *Memory) Initialize(l *sl.ServiceLocator) error { return nil }
func (m *Memory) CreateUser(user model.User) error {
m.Users = append(m.Users, user)
return nil
}
func (m *Memory) ReadUser(id string) (model.User, error) {
for _, u := range m.Users {
if u.Id == id {
return u, nil
}
}
return model.User{}, fmt.Errorf(`no user with id "%s"`, id)
}
func (m *Memory) ReadUsers() ([]model.User, error) {
return m.Users, nil
}
func (m *Memory) UpdateUser(id string, user model.User) error {
for i, u := range m.Users {
if u.Id == id {
m.Users[i] = user
return nil
}
}
return fmt.Errorf(`no user with id "%s"`, id)
}
func (m *Memory) DeleteUser(id string) error {
for i, u := range m.Users {
if u.Id == id {
m.Users = append(m.Users[:i], m.Users[i+1:]...)
return nil
}
}
return fmt.Errorf(`no user with id "%s"`, id)
}
+47
View File
@@ -0,0 +1,47 @@
package dev
import (
"log"
"path"
"phc/website/services/server/routes"
"phc/website/sl"
"github.com/gofiber/fiber/v2"
)
type Dev struct {
HtmlRouteBindings map[string]string
}
func (m *Dev) Initialize(l *sl.ServiceLocator) error {
m.HtmlRouteBindings = map[string]string{}
router, err := sl.Use[*routes.Router](l)
if err != nil {
return err
}
router.Get("/api/dev/routes", func(c *fiber.Ctx) error {
return c.JSON(m.HtmlRouteBindings)
})
return nil
}
// UseVitePage this hook will link the provided "mountPoint" to the "frontendHtml" page
func UseVitePage[T any](l *sl.ServiceLocator, mountPoint, frontendHtml string) func(c *fiber.Ctx) error {
log.Printf(`registering vite route %q for %q`, frontendHtml, mountPoint)
dev, err := sl.Use[*Dev](l)
if err != nil {
log.Fatal(err)
}
frontendPath := path.Join("./frontend/", frontendHtml)
dev.HtmlRouteBindings[mountPoint] = frontendPath
return func(c *fiber.Ctx) error {
return c.SendFile(frontendPath)
}
}
@@ -0,0 +1,39 @@
package lista_utenti
import (
"phc/website/services/database"
"phc/website/services/server/dev"
"phc/website/services/server/routes"
"phc/website/sl"
"github.com/gofiber/fiber/v2"
)
type ListaUtenti struct{}
func (s *ListaUtenti) Initialize(l *sl.ServiceLocator) error {
db, err := sl.Use[database.Database](l)
if err != nil {
return err
}
router, err := sl.Use[*routes.Router](l)
if err != nil {
return err
}
router.Get("/utenti",
dev.UseVitePage[ListaUtenti](l, "/utenti", "pages/lista-utenti/index.html"),
)
router.Get("/api/lista-utenti", func(c *fiber.Ctx) error {
users, err := db.ReadUsers()
if err != nil {
return err
}
return c.JSON(users)
})
return nil
}
@@ -0,0 +1,82 @@
package lista_utenti_test
import (
"context"
"fmt"
"io"
"net"
"net/http"
"phc/website/model"
"phc/website/services/database"
"phc/website/services/server/dev"
lista_utenti "phc/website/services/server/lista-utenti"
"phc/website/services/server/routes"
"phc/website/sl"
"testing"
"github.com/gofiber/fiber/v2"
"github.com/valyala/fasthttp"
"github.com/valyala/fasthttp/fasthttputil"
)
func Test1(t *testing.T) {
l := sl.New()
sl.InjectValue[database.Database](l, &database.Memory{
Users: []model.User{
{
Id: "claire",
FullName: "Claire Doe",
Nickname: "claire-doe",
AuthSources: map[string]model.AuthSource{},
},
{
Id: "john",
FullName: "John Smith",
Nickname: "john-smith",
AuthSources: map[string]model.AuthSource{},
},
},
})
sl.Inject(l, &dev.Dev{})
sl.Inject(l, &lista_utenti.ListaUtenti{})
r := fiber.New()
sl.InjectValue(l, routes.NewRouter(r))
req, err := http.NewRequest("GET", "http://localhost:4000/api/lista-utenti", nil)
if err != nil {
t.Error(err)
}
ln := fasthttputil.NewInmemoryListener()
defer ln.Close()
go func() {
err := fasthttp.Serve(ln, r.Handler())
if err != nil {
panic(fmt.Errorf("failed to serve: %v", err))
}
}()
client := http.Client{
Transport: &http.Transport{
DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) {
return ln.Dial()
},
},
}
res, err := client.Do(req)
if err != nil {
t.Error(err)
}
body, err := io.ReadAll(res.Body)
if err != nil {
t.Error(err)
}
t.Log(string(body))
}
+15
View File
@@ -0,0 +1,15 @@
package routes
import (
"phc/website/sl"
"github.com/gofiber/fiber/v2"
)
func NewRouter(r fiber.Router) *Router {
return &Router{r}
}
type Router struct{ fiber.Router }
func (s *Router) Initialize(l *sl.ServiceLocator) error { return nil }
+26
View File
@@ -0,0 +1,26 @@
package server
import (
"phc/website/services/server/dev"
lista_utenti "phc/website/services/server/lista-utenti"
"phc/website/services/server/routes"
"phc/website/sl"
"github.com/gofiber/fiber/v2"
)
type Server struct{ Router *fiber.App }
func (s *Server) Initialize(l *sl.ServiceLocator) error {
s.Router = fiber.New(fiber.Config{})
sl.InjectValue(l, routes.NewRouter(s.Router))
if _, err := sl.Use[*dev.Dev](l); err != nil {
return err
}
if _, err := sl.Use[*lista_utenti.ListaUtenti](l); err != nil {
return err
}
return nil
}