2 files changed, 44 insertions, 12 deletions
diff --git a/http/server.go b/http/server.go
index 178980a7..de414b08 100644
--- a/http/server.go
+++ b/http/server.go
@@ -7,6 +7,29 @@ import (
 	"github.com/pkg/errors"
 )
 
+const (
+	// EventResponse thrown after the request been processed. See Log as payload.
+	EventResponse = iota + 500
+
+	// EventError thrown on any non job error provided by road runner server.
+	EventError
+)
+
+// Log represents singular http response event.
+type Log struct {
+	// Method of the request.
+	Method string
+
+	// Uri requested by the client.
+	Uri string
+
+	// Status is response status.
+	Status int
+
+	// Associated error, if any.
+	Error error
+}
+
 // Server serves http connections to underlying PHP application using PSR-7 protocol. Context will include request headers,
 // parsed files and query, payload will include parsed form dataTree (if any).
 type Server struct {
@@ -15,7 +38,7 @@ type Server struct {
 	rr       *roadrunner.Server
 }
 
-// Listen attaches pool event watcher.
+// AddListener attaches pool event watcher.
 func (s *Server) Listen(l func(event int, ctx interface{})) {
 	s.listener = l
 }
@@ -65,12 +88,18 @@ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
+	s.handleResponse(req, resp)
 	resp.Write(w)
 }
 
-// handleError sends error
+// handleResponse triggers response event.
+func (s *Server) handleResponse(req *Request, resp *Response) {
+	s.throw(EventResponse, &Log{Method: req.Method, Uri: req.Uri, Status: resp.Status})
+}
+
+// handleError sends error.
 func (s *Server) handleError(w http.ResponseWriter, r *http.Request, err error) {
-	s.throw(2332323, err)
+	s.throw(EventError, &Log{Method: r.Method, Uri: uri(r), Status: 500, Error: err})
 
 	w.WriteHeader(500)
 	w.Write([]byte(err.Error()))
diff --git a/http/service.go b/http/service.go
index 81ffb8a2..7835a652 100644
--- a/http/service.go
+++ b/http/service.go
@@ -18,24 +18,21 @@ type Middleware interface {
 
 // Service manages rr, http servers.
 type Service struct {
-	cfg *Config
-
-	// todo: multiple listeners
-	listener func(event int, ctx interface{})
-
+	cfg        *Config
+	listeners  []func(event int, ctx interface{})
 	middleware []Middleware
 	rr         *roadrunner.Server
 	srv        *Server
 	http       *http.Server
 }
 
-func (s *Service) Add(m Middleware) {
+func (s *Service) AddMiddleware(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
+// AddListener attaches server event watcher.
+func (s *Service) AddListener(l func(event int, ctx interface{})) {
+	s.listeners = append(s.listeners, l)
 }
 
 // Configure must return configure svc and return true if svc hasStatus enabled. Must return error in case of
@@ -114,3 +111,9 @@ func (s *Service) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 
 	s.srv.ServeHTTP(w, r)
 }
+
+func (s *Service) listener(event int, ctx interface{}) {
+	for _, l := range s.listeners {
+		l(event, ctx)
+	}
+}