1 files changed, 103 insertions, 0 deletions
diff --git a/http/service.go b/http/service.go
new file mode 100644
index 00000000..c31c4a47
--- /dev/null
+++ b/http/service.go
@@ -0,0 +1,103 @@
+package http
+
+import (
+	"net/http"
+	"github.com/spiral/roadrunner/service"
+	"context"
+	"github.com/spiral/roadrunner"
+)
+
+// Name contains default service name.
+const Name = "http"
+
+type Middleware interface {
+	// Handle must return true if request/response pair is handled withing the middleware.
+	Handle(w http.ResponseWriter, r *http.Request) bool
+}
+
+// Service manages rr, http servers.
+type Service struct {
+	cfg        *Config
+	listener   func(event int, ctx interface{})
+	middleware []Middleware
+	rr         *roadrunner.Server
+	srv        *Server
+	http       *http.Server
+}
+
+func (s *Service) Add(m Middleware) {
+	s.middleware = append(s.middleware, m)
+}
+
+// Listen attaches server event watcher.
+func (s *Service) Listen(o func(event int, ctx interface{})) {
+	s.listener = o
+}
+
+// Configure must return configure service and return true if service hasStatus enabled. Must return error in case of
+// misconfiguration. Services must not be used without proper configuration pushed first.
+func (s *Service) Configure(cfg service.Config, c service.Container) (bool, error) {
+	config := &Config{}
+	if err := cfg.Unmarshal(config); err != nil {
+		return false, err
+	}
+
+	if !config.Enable {
+		return false, nil
+	}
+
+	if err := config.Valid(); err != nil {
+		return false, err
+	}
+
+	s.cfg = config
+	return true, nil
+}
+
+// Serve serves the service.
+func (s *Service) Serve() error {
+	rr := roadrunner.NewServer(s.cfg.Workers)
+	if err := rr.Start(); err != nil {
+		return err
+	}
+	defer s.rr.Stop()
+
+	s.rr = rr
+	s.srv = &Server{cfg: s.cfg, rr: s.rr}
+	s.http = &http.Server{Addr: s.cfg.httpAddr()}
+
+	s.rr.Listen(s.listener)
+	s.srv.Listen(s.listener)
+
+	if len(s.middleware) == 0 {
+		s.http.Handler = s.srv
+	} else {
+		s.http.Handler = s
+	}
+
+	if err := s.http.ListenAndServe(); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+// Stop stops the service.
+func (s *Service) Stop() {
+	if s.http == nil {
+		return
+	}
+
+	s.http.Shutdown(context.Background())
+}
+
+// Handle handles connection using set of middleware and rr PSR-7 server.
+func (s *Service) ServeHTTP(w http.ResponseWriter, r *http.Request) {
+	for _, m := range s.middleware {
+		if m.Handle(w, r) {
+			return
+		}
+	}
+
+	s.srv.ServeHTTP(w, r)
+}