Feature/impl deep health check

internal/infrastructure/dependency/dependency.go

@@ -19,6 +19,7 @@ import (
 )
 
 type Dependency struct {
+	DatabaseCli *database.Client
 
 	// public
 	PublicAuthenticationInteractor usecase.PublicAuthenticationInteractor
@@ -39,7 +40,7 @@ func (d *Dependency) Inject(
 	ctx context.Context,
 	e *environment.Environment,
 ) {
-	_ = database.NewClient(e.DBHost, e.DBUser, e.DBPassword, e.DBDatabase)
+	d.DatabaseCli = database.NewClient(e.DBHost, e.DBUser, e.DBPassword, e.DBDatabase)
 
 	firebaseCli := firebase.NewClient(e.GCPProjectID)
 

internal/infrastructure/grpc/internal/handler/public/handler.go

@@ -1,21 +1,25 @@
 package public
 
 import (
+	"github.com/abyssparanoia/rapid-go/internal/infrastructure/database"
 	public_apiv1 "github.com/abyssparanoia/rapid-go/internal/infrastructure/grpc/pb/rapid/public_api/v1"
 	"github.com/abyssparanoia/rapid-go/internal/usecase"
 )
 
 type PublicHandler struct {
+	databaseCli *database.Client
 	public_apiv1.UnimplementedPublicV1ServiceServer
 	authenticationInteractor usecase.PublicAuthenticationInteractor
 	tenantInteractor         usecase.PublicTenantInteractor
 }
 
 func NewPublicHandler(
+	databaseCli *database.Client,
 	authenticationInteractor usecase.PublicAuthenticationInteractor,
 	tenantInteractor usecase.PublicTenantInteractor,
 ) public_apiv1.PublicV1ServiceServer {
 	return &PublicHandler{
+		databaseCli:              databaseCli,
 		authenticationInteractor: authenticationInteractor,
 		tenantInteractor:         tenantInteractor,
 	}

internal/infrastructure/grpc/internal/handler/public/health_check.go

@@ -0,0 +1,22 @@
+package public
+
+import (
+	"context"
+
+	public_apiv1 "github.com/abyssparanoia/rapid-go/internal/infrastructure/grpc/pb/rapid/public_api/v1"
+	"github.com/abyssparanoia/rapid-go/internal/pkg/logger"
+	"go.uber.org/zap"
+)
+
+func (h *PublicHandler) PublicDeepHealthCheck(ctx context.Context, req *public_apiv1.PublicDeepHealthCheckRequest) (*public_apiv1.PublicDeepHealthCheckResponse, error) {
+
+	databaseStatus := "up"
+	if err := h.databaseCli.DB.Ping(); err != nil {
+		logger.L(ctx).Error("failed to  h.databaseCli.DB.Ping", zap.Error(err))
+		databaseStatus = "down"
+	}
+
+	return &public_apiv1.PublicDeepHealthCheckResponse{
+		DatabaseStatus: databaseStatus,
+	}, nil
+}