health check endpoint

mnemosyned/daemon.go

@@ -50,6 +50,7 @@ type Daemon struct {
 	opts          *DaemonOpts
 	monitor       *monitoring
 	rpcOptions    []grpc.ServerOption
+	postgres      *sql.DB
 	storage       storage
 	logger        log.Logger
 	rpcListener   net.Listener
@@ -157,6 +158,9 @@ func (d *Daemon) Run() (err error) {
 			mux.Handle("/debug/pprof/symbol", http.HandlerFunc(pprof.Symbol))
 			mux.Handle("/debug/pprof/trace", http.HandlerFunc(pprof.Trace))
 			mux.Handle("/metrics", prometheus.Handler())
+			mux.Handle("/health", &healthHandler{
+				postgres: d.postgres,
+			})
 			sklog.Error(d.logger, http.Serve(d.debugListener, mux))
 		}()
 	}
@@ -184,13 +188,11 @@ func (d *Daemon) Addr() net.Addr {
 }
 
 func (d *Daemon) initStorage() (err error) {
-	var db *sql.DB
-
 	switch d.opts.Storage {
 	case StorageEngineInMemory:
 		return errors.New("in memory storage is not implemented yet")
 	case StorageEnginePostgres:
-		db, err = initPostgres(
+		d.postgres, err = initPostgres(
 			d.opts.PostgresAddress,
 			d.logger,
 		)
@@ -199,7 +201,7 @@ func (d *Daemon) initStorage() (err error) {
 		}
 		if d.storage, err = initStorage(
 			d.opts.IsTest,
-			newPostgresStorage("session", db, d.monitor, d.opts.SessionTTL),
+			newPostgresStorage("session", d.postgres, d.monitor, d.opts.SessionTTL),
 			d.logger,
 		); err != nil {
 			return

mnemosyned/health.go

@@ -0,0 +1,22 @@
+package mnemosyned
+
+import (
+	"database/sql"
+	"net/http"
+)
+
+type healthHandler struct {
+	postgres *sql.DB
+}
+
+func (hh *healthHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request) {
+	if hh.postgres != nil {
+		if err := hh.postgres.Ping(); err != nil {
+			http.Error(rw, "postgres ping failure", http.StatusServiceUnavailable)
+			return
+		}
+	}
+
+	rw.WriteHeader(http.StatusOK)
+	rw.Write([]byte("1"))
+}

mnemosyned/health_test.go

@@ -0,0 +1,51 @@
+package mnemosyned
+
+import (
+	"io/ioutil"
+	"net/http"
+	"net/http/httptest"
+	"testing"
+)
+
+func TestHealthHandler_ServeHTTP(t *testing.T) {
+	s := &postgresSuite{}
+	s.setup(t)
+
+	var (
+		res *http.Response
+		pay []byte
+		err error
+	)
+	srv := httptest.NewServer(&healthHandler{
+		postgres: s.db,
+	})
+	defer srv.Close()
+
+	if res, err = http.Get(srv.URL); err != nil {
+		t.Fatalf("unexpected error: %s", err.Error())
+	}
+	if res.StatusCode != http.StatusOK {
+		t.Fatalf("wrong status code, expected %d but got %d", http.StatusOK, res.StatusCode)
+	}
+	if pay, err = ioutil.ReadAll(res.Body); err != nil {
+		t.Fatalf("unexpected error: %s", err.Error())
+	}
+	if string(pay) != "1" {
+		t.Errorf("wrong payload, expected %s but got %s", "1", string(pay))
+	}
+
+	s.teardown(t)
+
+	if res, err = http.Get(srv.URL); err != nil {
+		t.Fatalf("unexpected error: %s", err.Error())
+	}
+	if res.StatusCode != http.StatusServiceUnavailable {
+		t.Fatalf("wrong status code, expected %d but got %d", http.StatusServiceUnavailable, res.StatusCode)
+	}
+	if pay, err = ioutil.ReadAll(res.Body); err != nil {
+		t.Fatalf("unexpected error: %s", err.Error())
+	}
+	if string(pay) != "postgres ping failure\n" {
+		t.Errorf("wrong payload, expected '%s' but got '%s'", "postgres ping failure\n", string(pay))
+	}
+}