75 lines
2.0 KiB
Go
75 lines
2.0 KiB
Go
|
package spaserver
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"fmt"
|
||
|
|
"net"
|
||
|
|
"net/http"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"code.nochebuena.dev/einherjar/contracts/logging"
|
||
|
|
"code.nochebuena.dev/einherjar/spa-server/health"
|
||
|
|
"code.nochebuena.dev/einherjar/spa-server/spa"
|
||
|
|
)
|
||
|
|
|
||
|
|
const shutdownTimeout = 10 * time.Second
|
||
|
|
|
||
|
|
// Server is a lifecycle-managed HTTP server that serves a single-page application.
|
||
|
|
// Register with [launcher.New] via Append — it implements [lifecycle.Component].
|
||
|
|
type Server struct {
|
||
|
|
logger logging.Logger
|
||
|
|
cfg Config
|
||
|
|
srv *http.Server
|
||
|
|
}
|
||
|
|
|
||
|
|
// NewServer returns a Server configured by cfg.
|
||
|
|
func NewServer(logger logging.Logger, cfg Config) *Server {
|
||
|
|
return &Server{logger: logger, cfg: cfg}
|
||
|
|
}
|
||
|
|
|
||
|
|
// OnInit builds the HTTP mux and configures the underlying http.Server.
|
||
|
|
func (s *Server) OnInit() error {
|
||
|
|
mux := http.NewServeMux()
|
||
|
|
mux.Handle("GET /health", health.NewHandler(s.logger))
|
||
|
|
mux.Handle("/", spa.NewHandler(s.logger, s.cfg.StaticDir))
|
||
|
|
|
||
|
|
s.srv = &http.Server{
|
||
|
|
Addr: fmt.Sprintf(":%d", s.cfg.Port),
|
||
|
|
Handler: mux,
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
// OnStart begins serving HTTP requests in a background goroutine.
|
||
|
|
// The TCP listener binds synchronously so a port conflict surfaces immediately.
|
||
|
|
func (s *Server) OnStart() error {
|
||
|
|
ln, err := newListener(s.srv.Addr)
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
s.logger.Info("spa-server: listening", "addr", s.srv.Addr, "static_dir", s.cfg.StaticDir)
|
||
|
|
go func() {
|
||
|
|
if err := s.srv.Serve(ln); err != nil && err != http.ErrServerClosed {
|
||
|
|
s.logger.Error("spa-server: serve error", err)
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func newListener(addr string) (net.Listener, error) {
|
||
|
|
ln, err := net.Listen("tcp", addr)
|
||
|
|
if err != nil {
|
||
|
|
return nil, fmt.Errorf("spa-server: bind %s: %w", addr, err)
|
||
|
|
}
|
||
|
|
return ln, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
// OnStop performs a graceful shutdown, waiting up to 10 seconds for in-flight
|
||
|
|
// requests to complete before forcefully closing connections.
|
||
|
|
func (s *Server) OnStop() error {
|
||
|
|
s.logger.Info("spa-server: shutting down")
|
||
|
|
ctx, cancel := context.WithTimeout(context.Background(), shutdownTimeout)
|
||
|
|
defer cancel()
|
||
|
|
return s.srv.Shutdown(ctx)
|
||
|
|
}
|