-feature ✨ add 3 layers of cockroach

Rayato159 · Nov 24, 2023 · be6e61d · be6e61d
1 parent 1c7e5dd
commit be6e61d
Show file tree

Hide file tree

Showing 4 changed files with 35 additions and 4 deletions.
diff --git a/cockroach/handlers/cockroachHttpHandler.go b/cockroach/handlers/cockroachHttpHandler.go
@@ -10,6 +10,12 @@ type cockroachHttpHandler struct {
 	cockroachUsecase usecases.CockroachUsecase
 }
 
+func NewCockroachHttpHandler(cockroachUsecase usecases.CockroachUsecase) CockroachHandler {
+	return &cockroachHttpHandler{
+		cockroachUsecase: cockroachUsecase,
+	}
+}
+
 func (h *cockroachHttpHandler) DetectCockroach(c echo.Context) error {
 	return nil
 }
diff --git a/cockroach/repositories/cockroachFCM.go b/cockroach/repositories/cockroachFCM.go
@@ -7,6 +7,10 @@ import (
 
 type cockroachFCMMessaging struct{}
 
+func NewCockroachFCMMessaging() CockroachMessaging {
+	return &cockroachFCMMessaging{}
+}
+
 func (c *cockroachFCMMessaging) PushNotification(m entities.CockroachPushNotificationDto) error {
 	// ... handle logic to push FCM notification here ...
 	log.Info("Pushing notification to FCM")

diff --git a/cockroach/repositories/cockroachPostgres.go b/cockroach/repositories/cockroachPostgres.go
@@ -9,6 +9,10 @@ type cockroachPostgresRepository struct {
 	db *gorm.DB
 }
 
+func NewCockroachPostgresRepository(db *gorm.DB) CockroachRepository {
+	return &cockroachPostgresRepository{db: db}
+}
+
 func (r *cockroachPostgresRepository) InsertCockroachData(
 	in entities.InsertCockroachDto,
 ) error {

diff --git a/server/echoServer.go b/server/echoServer.go
@@ -2,8 +2,10 @@ package server
 
 import (
 	"fmt"
-	"net/http"
 
+	"github.com/Rayato159/go-clean-arch-v2/cockroach/handlers"
+	cockroachRepositories "github.com/Rayato159/go-clean-arch-v2/cockroach/repositories"
+	cockroachUsecases "github.com/Rayato159/go-clean-arch-v2/cockroach/usecases"
 	"github.com/Rayato159/go-clean-arch-v2/config"
 	"github.com/labstack/echo/v4"
 	"gorm.io/gorm"
@@ -24,10 +26,25 @@ func NewEchoServer(cfg *config.Config, db *gorm.DB) Server {
 }
 
 func (s *echoServer) Start() {
-	s.app.GET("/", func(c echo.Context) error {
-		return c.String(http.StatusOK, "Hello, World!")
-	})
+	s.initializeCockroachHttpHandler()
 
 	serverUrl := fmt.Sprintf(":%d", s.cfg.App.Port)
 	s.app.Logger.Fatal(s.app.Start(serverUrl))
 }
+
+func (s *echoServer) initializeCockroachHttpHandler() {
+	// Initialize all layers
+	cockroachPostgresRepository := cockroachRepositories.NewCockroachPostgresRepository(s.db)
+	cockroachFCMMessaging := cockroachRepositories.NewCockroachFCMMessaging()
+
+	cockroachUsecase := cockroachUsecases.NewCockroachUsecaseImpl(
+		cockroachPostgresRepository,
+		cockroachFCMMessaging,
+	)
+
+	cockroachHttpHandler := handlers.NewCockroachHttpHandler(cockroachUsecase)
+
+	// Routers
+	cockroachRouters := s.app.Group("/cockroach")
+	cockroachRouters.POST("/", cockroachHttpHandler.DetectCockroach)
+}