http service

1 files changed, 0 insertions, 103 deletions

diff --git a/service/http/service.go b/service/http/service.go
deleted file mode 100644
index c31c4a47..00000000
--- a/service/http/service.go
+++ /dev/null
@@ -1,103 +0,0 @@
-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)
-}