server.go 939 B

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. package server
  2. import (
  3. "context"
  4. "fmt"
  5. "log/slog"
  6. "net"
  7. "net/http"
  8. "github.com/sst/opencode/pkg/app"
  9. )
  10. type Server struct {
  11. app *app.App
  12. mux *http.ServeMux
  13. http *http.Server
  14. log *slog.Logger
  15. }
  16. func New(app *app.App) (*Server, error) {
  17. result := &Server{
  18. app: app,
  19. mux: http.NewServeMux(),
  20. log: slog.With("service", "server"),
  21. }
  22. result.mux.HandleFunc("/rpc", func(w http.ResponseWriter, r *http.Request) {
  23. })
  24. listener, err := net.Listen("tcp", ":0")
  25. if err != nil {
  26. return nil, err
  27. }
  28. port := listener.Addr().(*net.TCPAddr).Port
  29. listener.Close()
  30. result.log.Info("listening on port", "port", port)
  31. result.http = &http.Server{
  32. Addr: fmt.Sprintf(":%d", port),
  33. Handler: result.mux,
  34. }
  35. return result, nil
  36. }
  37. func (s *Server) Start(ctx context.Context) error {
  38. s.log.Info("starting server")
  39. go func() {
  40. <-ctx.Done()
  41. s.http.Shutdown(context.Background())
  42. }()
  43. return s.http.ListenAndServe()
  44. }