add enabled sync

internal/use-case/main-use-case/installation/middleware-runner.go

@@ -6,6 +6,8 @@ import (
 
 	"gorm.io/gorm"
 
+	sync "simrs-vx/internal/infra/sync-cfg"
+
 	e "simrs-vx/internal/domain/main-entities/installation"
 	esync "simrs-vx/internal/domain/sync-entities/log"
 )
@@ -14,17 +16,23 @@ type middlewareRunner struct {
 	Event  *pl.Event
 	Tx     *gorm.DB
 	MwType pu.MWType
+	SyncOn bool
 }
 
 // NewMiddlewareExecutor creates a new middleware executor
 func newMiddlewareRunner(event *pl.Event) *middlewareRunner {
 	return &middlewareRunner{
-		Event: event,
+		Event:  event,
+		SyncOn: sync.O.Enable,
 	}
 }
 
 // ExecuteCreateMiddleware executes create middleware
 func (me *middlewareRunner) RunCreateMiddleware(middlewares []createMw, input *e.CreateDto) error {
+	if !me.SyncOn {
+		return nil
+	}
+
 	for _, middleware := range middlewares {
 		logData := pu.GetLogData(input, nil)
 
@@ -41,6 +49,10 @@ func (me *middlewareRunner) RunCreateMiddleware(middlewares []createMw, input *e
 
 // ExecuteCreateMiddleware executes create middleware
 func (me *middlewareRunner) RunCreateLogMiddleware(middlewares []createLogMw, input *esync.SimxLogDto) error {
+	if !me.SyncOn {
+		return nil
+	}
+
 	for _, middleware := range middlewares {
 		logData := pu.GetLogData(input, nil)
 
@@ -56,6 +68,10 @@ func (me *middlewareRunner) RunCreateLogMiddleware(middlewares []createLogMw, in
 }
 
 func (me *middlewareRunner) RunReadListMiddleware(middlewares []readListMw, input *e.ReadListDto, data *e.Installation) error {
+	if !me.SyncOn {
+		return nil
+	}
+
 	for _, middleware := range middlewares {
 		logData := pu.GetLogData(input, data)
 
@@ -71,6 +87,10 @@ func (me *middlewareRunner) RunReadListMiddleware(middlewares []readListMw, inpu
 }
 
 func (me *middlewareRunner) RunReadDetailMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Installation) error {
+	if !me.SyncOn {
+		return nil
+	}
+
 	for _, middleware := range middlewares {
 		logData := pu.GetLogData(input, data)
 
@@ -86,6 +106,10 @@ func (me *middlewareRunner) RunReadDetailMiddleware(middlewares []readDetailMw,
 }
 
 func (me *middlewareRunner) RunUpdateMiddleware(middlewares []UpdateMw, input *e.UpdateDto) error {
+	if !me.SyncOn {
+		return nil
+	}
+
 	for _, middleware := range middlewares {
 		logData := pu.GetLogData(input, nil)
 
@@ -101,6 +125,10 @@ func (me *middlewareRunner) RunUpdateMiddleware(middlewares []UpdateMw, input *e
 }
 
 func (me *middlewareRunner) RunDeleteMiddleware(middlewares []DeleteMw, input *e.DeleteDto) error {
+	if !me.SyncOn {
+		return nil
+	}
+
 	for _, middleware := range middlewares {
 		logData := pu.GetLogData(input, nil)