Mikkel Georgsen
1764c7b06a
- TestHandler: POST /api/test/cable, GET /api/test/events, GET /api/test/recent - POST /api/test/cable: DisallowUnknownFields (T-05-03), creates NetBox cable, auto-prints with 1s rate limit (T-05-05), prepends to 20-item ring buffer - GET /api/test/events: SSE, 30s keepalive, exits on context cancel (T-05-04) - GET /api/test/recent: thread-safe ring buffer, returns [] when empty - AttachStream() wires StreamingTesterDriver channel to SSE broadcaster - Router: three /api/test/* routes added to NewRouter signature - main.go: constructs TestHandler, wires USB Manager event loop stub - All handler tests pass race-clean (7 test cases)
69 lines
2.2 KiB
Go
69 lines
2.2 KiB
Go
package api
|
|
|
|
import (
|
|
"io/fs"
|
|
"net/http"
|
|
|
|
"github.com/go-chi/chi/v5"
|
|
"github.com/go-chi/chi/v5/middleware"
|
|
|
|
"git.georgsen.dk/hwlab/internal/api/handlers"
|
|
)
|
|
|
|
// spaHandler serves static files and falls back to index.html for unknown paths,
|
|
// enabling client-side routing in the React SPA.
|
|
type spaHandler struct {
|
|
staticFS fs.FS
|
|
}
|
|
|
|
func (h spaHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|
// Try to open the requested path in the embedded FS.
|
|
f, err := h.staticFS.Open(r.URL.Path)
|
|
if err != nil {
|
|
// File not found — serve index.html so the SPA router handles it.
|
|
r2 := r.Clone(r.Context())
|
|
r2.URL.Path = "/"
|
|
http.FileServer(http.FS(h.staticFS)).ServeHTTP(w, r2)
|
|
return
|
|
}
|
|
f.Close()
|
|
http.FileServer(http.FS(h.staticFS)).ServeHTTP(w, r)
|
|
}
|
|
|
|
// NewRouter creates the chi router. staticFiles is the fs.FS rooted at web/dist,
|
|
// passed from main.go where the go:embed directive lives.
|
|
// intakeHandler handles POST /api/intake (multipart photo upload).
|
|
// inventoryHandler handles GET /api/inventory and GET /api/inventory/{id}.
|
|
// labelHandler handles POST /api/labels/:deviceID/print.
|
|
// usbEventsHandler handles GET /api/usb/events (SSE stream).
|
|
// testHandler handles POST /api/test/cable, GET /api/test/events, GET /api/test/recent.
|
|
func NewRouter(
|
|
staticFiles fs.FS,
|
|
intakeHandler http.Handler,
|
|
inventoryHandler *handlers.InventoryHandler,
|
|
labelHandler *handlers.LabelHandler,
|
|
usbEventsHandler *handlers.USBEventsHandler,
|
|
testHandler *handlers.TestHandler,
|
|
) http.Handler {
|
|
r := chi.NewRouter()
|
|
r.Use(middleware.Logger)
|
|
r.Use(middleware.Recoverer)
|
|
r.Use(middleware.RealIP)
|
|
|
|
r.Route("/api", func(r chi.Router) {
|
|
r.Get("/health", handlers.Health)
|
|
r.Post("/intake", intakeHandler.ServeHTTP)
|
|
r.Get("/inventory", inventoryHandler.ListInventory)
|
|
r.Get("/inventory/{id}", inventoryHandler.GetInventoryItem)
|
|
r.Post("/labels/{deviceID}/print", labelHandler.PrintLabel)
|
|
r.Get("/usb/events", usbEventsHandler.ServeEvents)
|
|
r.Post("/test/cable", testHandler.SubmitCableTest)
|
|
r.Get("/test/events", testHandler.StreamEvents)
|
|
r.Get("/test/recent", testHandler.RecentTests)
|
|
})
|
|
|
|
// SPA fallback — serve static files; unknown paths fall back to index.html.
|
|
r.Handle("/*", spaHandler{staticFS: staticFiles})
|
|
|
|
return r
|
|
}
|