diff --git a/internal/domain/main-entities/specialist/dto.go b/internal/domain/main-entities/specialist/dto.go
index a67a830f..2d656556 100644
--- a/internal/domain/main-entities/specialist/dto.go
+++ b/internal/domain/main-entities/specialist/dto.go
@@ -8,6 +8,7 @@ import (
 )
 
 type CreateDto struct {
+	Id        *uint   `json:"id"`
 	Code      string  `json:"code" validate:"maxLength=10"`
 	Name      string  `json:"name" validate:"maxLength=50"`
 	Unit_Code *string `json:"unit_code"`
diff --git a/internal/domain/main-entities/subspecialist/dto.go b/internal/domain/main-entities/subspecialist/dto.go
index 6e10b573..72959023 100644
--- a/internal/domain/main-entities/subspecialist/dto.go
+++ b/internal/domain/main-entities/subspecialist/dto.go
@@ -7,6 +7,7 @@ import (
 )
 
 type CreateDto struct {
+	Id              *uint   `json:"id"`
 	Code            string  `json:"code" validate:"maxLength=10"`
 	Name            string  `json:"name" validate:"maxLength=50"`
 	Specialist_Code *string `json:"specialist_code"`
diff --git a/internal/interface/simgos-sync-handler/simgos-sync-handler.go b/internal/interface/simgos-sync-handler/simgos-sync-handler.go
index 590d7b9d..6b63e1d6 100644
--- a/internal/interface/simgos-sync-handler/simgos-sync-handler.go
+++ b/internal/interface/simgos-sync-handler/simgos-sync-handler.go
@@ -19,6 +19,8 @@ import (
 	"simrs-vx/internal/interface/main-handler/home"
 	division "simrs-vx/internal/interface/simgos-sync-handler/division"
 	installation "simrs-vx/internal/interface/simgos-sync-handler/installation"
+	specialist "simrs-vx/internal/interface/simgos-sync-handler/specialist"
+	subspecialist "simrs-vx/internal/interface/simgos-sync-handler/subspecialist"
 	unit "simrs-vx/internal/interface/simgos-sync-handler/unit"
 )
 
@@ -39,6 +41,8 @@ func SetRoutes() http.Handler {
 	hc.SyncCrud(r, prefix+"/v1/installation", installation.O)
 	hc.SyncCrud(r, prefix+"/v1/unit", unit.O)
 	hc.SyncCrud(r, prefix+"/v1/division", division.O)
+	hc.SyncCrud(r, prefix+"/v1/specialist", specialist.O)
+	hc.SyncCrud(r, prefix+"/v1/subspecialist", subspecialist.O)
 
 	return cmw.SetCors(handlerlogger.SetLog(r))
 }
diff --git a/internal/interface/simgos-sync-handler/specialist/handler.go b/internal/interface/simgos-sync-handler/specialist/handler.go
new file mode 100644
index 00000000..79289472
--- /dev/null
+++ b/internal/interface/simgos-sync-handler/specialist/handler.go
@@ -0,0 +1,66 @@
+package specialist
+
+import (
+	"net/http"
+
+	rw "github.com/karincake/risoles"
+	// ua "github.com/karincake/tumpeng/auth/svc"
+
+	e "simrs-vx/internal/domain/main-entities/specialist"
+	esync "simrs-vx/internal/domain/sync-entities/log"
+	u "simrs-vx/internal/use-case/simgos-sync-use-case/specialist"
+)
+
+type myBase struct{}
+
+var O myBase
+
+func (obj myBase) Create(w http.ResponseWriter, r *http.Request) {
+	dto := e.CreateDto{}
+	if res := rw.ValidateStructByIOR(w, r.Body, &dto); !res {
+		return
+	}
+	res, err := u.Create(dto)
+	rw.DataResponse(w, res, err)
+}
+
+func (obj myBase) CreateLog(w http.ResponseWriter, r *http.Request) {
+	dto := esync.SimxLogDto{}
+	if res := rw.ValidateStructByIOR(w, r.Body, &dto); !res {
+		return
+	}
+	res, err := u.CreateSimxLog(dto)
+	rw.DataResponse(w, res, err)
+}
+
+func (obj myBase) Update(w http.ResponseWriter, r *http.Request) {
+	id := rw.ValidateInt(w, "id", r.PathValue("id"))
+	if id <= 0 {
+		return
+	}
+
+	dto := e.UpdateDto{}
+	if res := rw.ValidateStructByIOR(w, r.Body, &dto); !res {
+		return
+	}
+
+	val := uint16(id)
+	dto.Id = &val
+
+	res, err := u.Update(dto)
+	rw.DataResponse(w, res, err)
+}
+
+func (obj myBase) Delete(w http.ResponseWriter, r *http.Request) {
+	id := rw.ValidateInt(w, "id", r.PathValue("id"))
+	if id <= 0 {
+		return
+	}
+
+	dto := e.DeleteDto{}
+	val := uint16(id)
+	dto.Id = &val
+
+	res, err := u.Delete(dto)
+	rw.DataResponse(w, res, err)
+}
diff --git a/internal/interface/simgos-sync-handler/subspecialist/handler.go b/internal/interface/simgos-sync-handler/subspecialist/handler.go
new file mode 100644
index 00000000..fcd03c6b
--- /dev/null
+++ b/internal/interface/simgos-sync-handler/subspecialist/handler.go
@@ -0,0 +1,66 @@
+package subspecialist
+
+import (
+	"net/http"
+
+	rw "github.com/karincake/risoles"
+	// ua "github.com/karincake/tumpeng/auth/svc"
+
+	e "simrs-vx/internal/domain/main-entities/subspecialist"
+	esync "simrs-vx/internal/domain/sync-entities/log"
+	u "simrs-vx/internal/use-case/simgos-sync-use-case/subspecialist"
+)
+
+type myBase struct{}
+
+var O myBase
+
+func (obj myBase) Create(w http.ResponseWriter, r *http.Request) {
+	dto := e.CreateDto{}
+	if res := rw.ValidateStructByIOR(w, r.Body, &dto); !res {
+		return
+	}
+	res, err := u.Create(dto)
+	rw.DataResponse(w, res, err)
+}
+
+func (obj myBase) CreateLog(w http.ResponseWriter, r *http.Request) {
+	dto := esync.SimxLogDto{}
+	if res := rw.ValidateStructByIOR(w, r.Body, &dto); !res {
+		return
+	}
+	res, err := u.CreateSimxLog(dto)
+	rw.DataResponse(w, res, err)
+}
+
+func (obj myBase) Update(w http.ResponseWriter, r *http.Request) {
+	id := rw.ValidateInt(w, "id", r.PathValue("id"))
+	if id <= 0 {
+		return
+	}
+
+	dto := e.UpdateDto{}
+	if res := rw.ValidateStructByIOR(w, r.Body, &dto); !res {
+		return
+	}
+
+	val := uint16(id)
+	dto.Id = &val
+
+	res, err := u.Update(dto)
+	rw.DataResponse(w, res, err)
+}
+
+func (obj myBase) Delete(w http.ResponseWriter, r *http.Request) {
+	id := rw.ValidateInt(w, "id", r.PathValue("id"))
+	if id <= 0 {
+		return
+	}
+
+	dto := e.DeleteDto{}
+	val := uint16(id)
+	dto.Id = &val
+
+	res, err := u.Delete(dto)
+	rw.DataResponse(w, res, err)
+}
diff --git a/internal/use-case/main-use-case/division/case.go b/internal/use-case/main-use-case/division/case.go
index 4be7ce82..8f2e8488 100644
--- a/internal/use-case/main-use-case/division/case.go
+++ b/internal/use-case/main-use-case/division/case.go
@@ -1,18 +1,19 @@
 package division
 
 import (
-	e "simrs-vx/internal/domain/main-entities/division"
-	erc "simrs-vx/internal/domain/references/common"
-	esync "simrs-vx/internal/domain/sync-entities/log"
 	"strconv"
 
 	dg "github.com/karincake/apem/db-gorm-pg"
 	d "github.com/karincake/dodol"
+	"gorm.io/gorm"
 
 	pl "simrs-vx/pkg/logger"
 	pu "simrs-vx/pkg/use-case-helper"
 
-	"gorm.io/gorm"
+	erc "simrs-vx/internal/domain/references/common"
+
+	e "simrs-vx/internal/domain/main-entities/division"
+	esync "simrs-vx/internal/domain/sync-entities/log"
 )
 
 const source = "division"
diff --git a/internal/use-case/main-use-case/specialist/case.go b/internal/use-case/main-use-case/specialist/case.go
index c51a0002..f9f5442b 100644
--- a/internal/use-case/main-use-case/specialist/case.go
+++ b/internal/use-case/main-use-case/specialist/case.go
@@ -1,7 +1,6 @@
 package specialist
 
 import (
-	e "simrs-vx/internal/domain/main-entities/specialist"
 	"strconv"
 
 	dg "github.com/karincake/apem/db-gorm-pg"
@@ -11,6 +10,11 @@ import (
 	pu "simrs-vx/pkg/use-case-helper"
 
 	"gorm.io/gorm"
+
+	erc "simrs-vx/internal/domain/references/common"
+
+	e "simrs-vx/internal/domain/main-entities/specialist"
+	esync "simrs-vx/internal/domain/sync-entities/log"
 )
 
 const source = "specialist"
@@ -25,36 +29,32 @@ func Create(input e.CreateDto) (*d.Data, error) {
 
 	// Start log
 	pl.SetLogInfo(&event, input, "started", "create")
+	mwRunner := newMiddlewareRunner(&event)
 
 	err := dg.I.Transaction(func(tx *gorm.DB) error {
-		mwRunner := newMiddlewareRunner(&event, tx)
-		mwRunner.setMwType(pu.MWTPre)
-		// Run pre-middleware
-		if err := mwRunner.RunCreateMiddleware(createPreMw, &input, &data); err != nil {
-			return err
-		}
-
 		if resData, err := CreateData(input, &event, tx); err != nil {
 			return err
 		} else {
 			data = *resData
+			id := uint(data.Id)
+			input.Id = &id
 		}
 
-		mwRunner.setMwType(pu.MWTPost)
-		// Run post-middleware
-		if err := mwRunner.RunCreateMiddleware(createPostMw, &input, &data); err != nil {
+		mwRunner.setMwType(pu.MWTPre)
+		// Run pre-middleware
+		if err := mwRunner.RunCreateMiddleware(createPreMw, &input); err != nil {
 			return err
 		}
 
-		pl.SetLogInfo(&event, nil, "complete")
-
 		return nil
 	})
 
-	if err != nil {
+	if err = runLogMiddleware(err, input, mwRunner); err != nil {
 		return nil, err
 	}
 
+	pl.SetLogInfo(&event, nil, "complete")
+
 	return &d.Data{
 		Meta: d.II{
 			"source":    source,
@@ -80,7 +80,7 @@ func ReadList(input e.ReadListDto) (*d.Data, error) {
 	pl.SetLogInfo(&event, input, "started", "readList")
 
 	err = dg.I.Transaction(func(tx *gorm.DB) error {
-		mwRunner := newMiddlewareRunner(&event, tx)
+		mwRunner := newMiddlewareRunner(&event)
 		mwRunner.setMwType(pu.MWTPre)
 		// Run pre-middleware
 		if err := mwRunner.RunReadListMiddleware(readListPreMw, &input, data); err != nil {
@@ -131,7 +131,7 @@ func ReadDetail(input e.ReadDetailDto) (*d.Data, error) {
 	pl.SetLogInfo(&event, input, "started", "readDetail")
 
 	err = dg.I.Transaction(func(tx *gorm.DB) error {
-		mwRunner := newMiddlewareRunner(&event, tx)
+		mwRunner := newMiddlewareRunner(&event)
 		mwRunner.setMwType(pu.MWTPre)
 		// Run pre-middleware
 		if err := mwRunner.RunReadDetailMiddleware(readDetailPreMw, &input, data); err != nil {
@@ -177,6 +177,7 @@ func Update(input e.UpdateDto) (*d.Data, error) {
 
 	// Start log
 	pl.SetLogInfo(&event, input, "started", "update")
+	mwRunner := newMiddlewareRunner(&event)
 
 	err = dg.I.Transaction(func(tx *gorm.DB) error {
 		pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
@@ -184,32 +185,26 @@ func Update(input e.UpdateDto) (*d.Data, error) {
 			return err
 		}
 
-		mwRunner := newMiddlewareRunner(&event, tx)
-		mwRunner.setMwType(pu.MWTPre)
-		// Run pre-middleware
-		if err := mwRunner.RunUpdateMiddleware(readDetailPreMw, &rdDto, data); err != nil {
-			return err
-		}
-
+		input.Id = &data.Id
 		if err := UpdateData(input, data, &event, tx); err != nil {
 			return err
 		}
 
-		pl.SetLogInfo(&event, nil, "complete")
-
-		mwRunner.setMwType(pu.MWTPost)
-		// Run post-middleware
-		if err := mwRunner.RunUpdateMiddleware(readDetailPostMw, &rdDto, data); err != nil {
+		mwRunner.setMwType(pu.MWTPre)
+		// Run pre-middleware
+		if err := mwRunner.RunUpdateMiddleware(updatePreMw, &input); err != nil {
 			return err
 		}
 
 		return nil
 	})
 
-	if err != nil {
+	if err = runLogMiddleware(err, input, mwRunner); err != nil {
 		return nil, err
 	}
 
+	pl.SetLogInfo(&event, nil, "complete")
+
 	return &d.Data{
 		Meta: d.IS{
 			"source":    source,
@@ -233,6 +228,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 
 	// Start log
 	pl.SetLogInfo(&event, input, "started", "delete")
+	mwRunner := newMiddlewareRunner(&event)
 
 	err = dg.I.Transaction(func(tx *gorm.DB) error {
 		pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
@@ -240,30 +236,26 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 			return err
 		}
 
-		mwRunner := newMiddlewareRunner(&event, tx)
-		mwRunner.setMwType(pu.MWTPre)
-		// Run pre-middleware
-		if err := mwRunner.RunDeleteMiddleware(readDetailPreMw, &rdDto, data); err != nil {
-			return err
-		}
-
+		input.Id = &data.Id
 		if err := DeleteData(data, &event, tx); err != nil {
 			return err
 		}
 
-		mwRunner.setMwType(pu.MWTPost)
-		// Run post-middleware
-		if err := mwRunner.RunDeleteMiddleware(readDetailPostMw, &rdDto, data); err != nil {
+		mwRunner.setMwType(pu.MWTPre)
+		// Run pre-middleware
+		if err := mwRunner.RunDeleteMiddleware(deletePreMw, &input); err != nil {
 			return err
 		}
 
 		return nil
 	})
 
-	if err != nil {
+	if err = runLogMiddleware(err, input, mwRunner); err != nil {
 		return nil, err
 	}
 
+	pl.SetLogInfo(&event, nil, "complete")
+
 	return &d.Data{
 		Meta: d.IS{
 			"source":    source,
@@ -274,3 +266,32 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 	}, nil
 
 }
+
+func runLogMiddleware(err error, input any, mwRunner *middlewareRunner) error {
+	var errMsg string
+	inputLog := esync.SimxLogDto{
+		Payload: input,
+		Method:  erc.CCCreate,
+	}
+
+	if err != nil {
+		// Run log-middleware
+		errMsg = err.Error()
+		inputLog.ErrMessage = &errMsg
+		inputLog.IsSuccess = false
+
+		// create log failed
+		if errMiddleware := mwRunner.RunCreateLogMiddleware(createSimxLogMw, &inputLog); errMiddleware != nil {
+			return errMiddleware
+		}
+		return err
+	}
+
+	// create log success
+	inputLog.IsSuccess = true
+	if err = mwRunner.RunCreateLogMiddleware(createSimxLogMw, &inputLog); err != nil {
+		return err
+	}
+
+	return nil
+}
diff --git a/internal/use-case/main-use-case/specialist/middleware-runner.go b/internal/use-case/main-use-case/specialist/middleware-runner.go
index 4aa6cdd4..c937d2bc 100644
--- a/internal/use-case/main-use-case/specialist/middleware-runner.go
+++ b/internal/use-case/main-use-case/specialist/middleware-runner.go
@@ -2,6 +2,7 @@ package specialist
 
 import (
 	e "simrs-vx/internal/domain/main-entities/specialist"
+	esync "simrs-vx/internal/domain/sync-entities/log"
 	pl "simrs-vx/pkg/logger"
 	pu "simrs-vx/pkg/use-case-helper"
 
@@ -15,21 +16,36 @@ type middlewareRunner struct {
 }
 
 // NewMiddlewareExecutor creates a new middleware executor
-func newMiddlewareRunner(event *pl.Event, tx *gorm.DB) *middlewareRunner {
+func newMiddlewareRunner(event *pl.Event) *middlewareRunner {
 	return &middlewareRunner{
 		Event: event,
-		Tx:    tx,
 	}
 }
 
 // ExecuteCreateMiddleware executes create middleware
-func (me *middlewareRunner) RunCreateMiddleware(middlewares []createMw, input *e.CreateDto, data *e.Specialist) error {
+func (me *middlewareRunner) RunCreateMiddleware(middlewares []createMw, input *e.CreateDto) error {
 	for _, middleware := range middlewares {
-		logData := pu.GetLogData(input, data)
+		logData := pu.GetLogData(input, nil)
 
 		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
 
-		if err := middleware.Func(input, data, me.Tx); err != nil {
+		if err := middleware.Func(input); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+// ExecuteCreateMiddleware executes createlog middleware
+func (me *middlewareRunner) RunCreateLogMiddleware(middlewares []createLogMw, input *esync.SimxLogDto) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, nil)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input); err != nil {
 			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
 		}
 
@@ -68,13 +84,13 @@ func (me *middlewareRunner) RunReadDetailMiddleware(middlewares []readDetailMw,
 	return nil
 }
 
-func (me *middlewareRunner) RunUpdateMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Specialist) error {
+func (me *middlewareRunner) RunUpdateMiddleware(middlewares []updateMw, input *e.UpdateDto) error {
 	for _, middleware := range middlewares {
-		logData := pu.GetLogData(input, data)
+		logData := pu.GetLogData(input, nil)
 
 		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
 
-		if err := middleware.Func(input, data, me.Tx); err != nil {
+		if err := middleware.Func(input); err != nil {
 			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
 		}
 
@@ -83,13 +99,13 @@ func (me *middlewareRunner) RunUpdateMiddleware(middlewares []readDetailMw, inpu
 	return nil
 }
 
-func (me *middlewareRunner) RunDeleteMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Specialist) error {
+func (me *middlewareRunner) RunDeleteMiddleware(middlewares []deleteMw, input *e.DeleteDto) error {
 	for _, middleware := range middlewares {
-		logData := pu.GetLogData(input, data)
+		logData := pu.GetLogData(input, nil)
 
 		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
 
-		if err := middleware.Func(input, data, me.Tx); err != nil {
+		if err := middleware.Func(input); err != nil {
 			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
 		}
 
diff --git a/internal/use-case/main-use-case/specialist/middleware.go b/internal/use-case/main-use-case/specialist/middleware.go
index 298e51a8..5d119b01 100644
--- a/internal/use-case/main-use-case/specialist/middleware.go
+++ b/internal/use-case/main-use-case/specialist/middleware.go
@@ -1,9 +1,20 @@
 package specialist
 
+import (
+	plugin "simrs-vx/internal/use-case/simgos-sync-plugin/specialist"
+)
+
 // example of middleware
-// func init() {
-// 	createPreMw = append(createPreMw,
-// 		CreateMw{Name: "modif-input", Func: pm.ModifInput},
-// 		CreateMw{Name: "check-data", Func: pm.CheckData},
-// 	)
-// }
+func init() {
+	createPreMw = append(createPreMw,
+		createMw{Name: "create-unit", Func: plugin.Create})
+
+	createSimxLogMw = append(createSimxLogMw,
+		createLogMw{Name: "create-log", Func: plugin.CreateLog})
+
+	updatePreMw = append(updatePreMw,
+		updateMw{Name: "update-unit", Func: plugin.Update})
+
+	deletePreMw = append(deletePreMw,
+		deleteMw{Name: "delete-unit", Func: plugin.Delete})
+}
diff --git a/internal/use-case/main-use-case/specialist/tycovar.go b/internal/use-case/main-use-case/specialist/tycovar.go
index 16fa50b0..d0755799 100644
--- a/internal/use-case/main-use-case/specialist/tycovar.go
+++ b/internal/use-case/main-use-case/specialist/tycovar.go
@@ -12,11 +12,27 @@ import (
 	"gorm.io/gorm"
 
 	e "simrs-vx/internal/domain/main-entities/specialist"
+	elog "simrs-vx/internal/domain/sync-entities/log"
 )
 
 type createMw struct {
 	Name string
-	Func func(input *e.CreateDto, data *e.Specialist, tx *gorm.DB) error
+	Func func(input *e.CreateDto) error
+}
+
+type createLogMw struct {
+	Name string
+	Func func(input *elog.SimxLogDto) error
+}
+
+type updateMw struct {
+	Name string
+	Func func(input *e.UpdateDto) error
+}
+
+type deleteMw struct {
+	Name string
+	Func func(input *e.DeleteDto) error
 }
 
 type readListMw struct {
@@ -29,16 +45,17 @@ type readDetailMw struct {
 	Func func(input *e.ReadDetailDto, data *e.Specialist, tx *gorm.DB) error
 }
 
-type UpdateMw = readDetailMw
-type DeleteMw = readDetailMw
+type UpdateMw = updateMw
+type DeleteMw = deleteMw
 
-var createPreMw []createMw      // preprocess middleware
-var createPostMw []createMw     // postprocess middleware
+var createPreMw []createMw  // preprocess middleware
+var createPostMw []createMw // postprocess middleware
+var createSimxLogMw []createLogMw
 var readListPreMw []readListMw  // ..
 var readListPostMw []readListMw // ..
 var readDetailPreMw []readDetailMw
 var readDetailPostMw []readDetailMw
-var updatePreMw []readDetailMw
+var updatePreMw []updateMw
 var updatePostMw []readDetailMw
-var deletePreMw []readDetailMw
+var deletePreMw []deleteMw
 var deletePostMw []readDetailMw
diff --git a/internal/use-case/main-use-case/subspecialist/case.go b/internal/use-case/main-use-case/subspecialist/case.go
index 51509c47..ca99750d 100644
--- a/internal/use-case/main-use-case/subspecialist/case.go
+++ b/internal/use-case/main-use-case/subspecialist/case.go
@@ -2,6 +2,8 @@ package subspecialist
 
 import (
 	e "simrs-vx/internal/domain/main-entities/subspecialist"
+	erc "simrs-vx/internal/domain/references/common"
+	esync "simrs-vx/internal/domain/sync-entities/log"
 	"strconv"
 
 	dg "github.com/karincake/apem/db-gorm-pg"
@@ -25,36 +27,32 @@ func Create(input e.CreateDto) (*d.Data, error) {
 
 	// Start log
 	pl.SetLogInfo(&event, input, "started", "create")
+	mwRunner := newMiddlewareRunner(&event)
 
 	err := dg.I.Transaction(func(tx *gorm.DB) error {
-		mwRunner := newMiddlewareRunner(&event, tx)
-		mwRunner.setMwType(pu.MWTPre)
-		// Run pre-middleware
-		if err := mwRunner.RunCreateMiddleware(createPreMw, &input, &data); err != nil {
-			return err
-		}
-
 		if resData, err := CreateData(input, &event, tx); err != nil {
 			return err
 		} else {
 			data = *resData
+			id := uint(data.Id)
+			input.Id = &id
 		}
 
-		mwRunner.setMwType(pu.MWTPost)
+		mwRunner.setMwType(pu.MWTPre)
 		// Run post-middleware
-		if err := mwRunner.RunCreateMiddleware(createPostMw, &input, &data); err != nil {
+		if err := mwRunner.RunCreateMiddleware(createPreMw, &input); err != nil {
 			return err
 		}
 
-		pl.SetLogInfo(&event, nil, "complete")
-
 		return nil
 	})
 
-	if err != nil {
+	if err = runLogMiddleware(err, input, mwRunner); err != nil {
 		return nil, err
 	}
 
+	pl.SetLogInfo(&event, nil, "complete")
+
 	return &d.Data{
 		Meta: d.II{
 			"source":    source,
@@ -80,7 +78,7 @@ func ReadList(input e.ReadListDto) (*d.Data, error) {
 	pl.SetLogInfo(&event, input, "started", "readList")
 
 	err = dg.I.Transaction(func(tx *gorm.DB) error {
-		mwRunner := newMiddlewareRunner(&event, tx)
+		mwRunner := newMiddlewareRunner(&event)
 		mwRunner.setMwType(pu.MWTPre)
 		// Run pre-middleware
 		if err := mwRunner.RunReadListMiddleware(readListPreMw, &input, data); err != nil {
@@ -131,7 +129,7 @@ func ReadDetail(input e.ReadDetailDto) (*d.Data, error) {
 	pl.SetLogInfo(&event, input, "started", "readDetail")
 
 	err = dg.I.Transaction(func(tx *gorm.DB) error {
-		mwRunner := newMiddlewareRunner(&event, tx)
+		mwRunner := newMiddlewareRunner(&event)
 		mwRunner.setMwType(pu.MWTPre)
 		// Run pre-middleware
 		if err := mwRunner.RunReadDetailMiddleware(readDetailPreMw, &input, data); err != nil {
@@ -177,6 +175,7 @@ func Update(input e.UpdateDto) (*d.Data, error) {
 
 	// Start log
 	pl.SetLogInfo(&event, input, "started", "update")
+	mwRunner := newMiddlewareRunner(&event)
 
 	err = dg.I.Transaction(func(tx *gorm.DB) error {
 		pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
@@ -184,32 +183,26 @@ func Update(input e.UpdateDto) (*d.Data, error) {
 			return err
 		}
 
-		mwRunner := newMiddlewareRunner(&event, tx)
-		mwRunner.setMwType(pu.MWTPre)
-		// Run pre-middleware
-		if err := mwRunner.RunUpdateMiddleware(readDetailPreMw, &rdDto, data); err != nil {
-			return err
-		}
-
+		input.Id = &data.Id
 		if err := UpdateData(input, data, &event, tx); err != nil {
 			return err
 		}
 
-		pl.SetLogInfo(&event, nil, "complete")
-
-		mwRunner.setMwType(pu.MWTPost)
+		mwRunner.setMwType(pu.MWTPre)
 		// Run post-middleware
-		if err := mwRunner.RunUpdateMiddleware(readDetailPostMw, &rdDto, data); err != nil {
+		if err := mwRunner.RunUpdateMiddleware(updatePreMw, &input); err != nil {
 			return err
 		}
 
 		return nil
 	})
 
-	if err != nil {
+	if err = runLogMiddleware(err, input, mwRunner); err != nil {
 		return nil, err
 	}
 
+	pl.SetLogInfo(&event, nil, "complete")
+
 	return &d.Data{
 		Meta: d.IS{
 			"source":    source,
@@ -233,6 +226,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 
 	// Start log
 	pl.SetLogInfo(&event, input, "started", "delete")
+	mwRunner := newMiddlewareRunner(&event)
 
 	err = dg.I.Transaction(func(tx *gorm.DB) error {
 		pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
@@ -240,30 +234,26 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 			return err
 		}
 
-		mwRunner := newMiddlewareRunner(&event, tx)
-		mwRunner.setMwType(pu.MWTPre)
-		// Run pre-middleware
-		if err := mwRunner.RunDeleteMiddleware(readDetailPreMw, &rdDto, data); err != nil {
-			return err
-		}
-
+		input.Id = &data.Id
 		if err := DeleteData(data, &event, tx); err != nil {
 			return err
 		}
 
-		mwRunner.setMwType(pu.MWTPost)
+		mwRunner.setMwType(pu.MWTPre)
 		// Run post-middleware
-		if err := mwRunner.RunDeleteMiddleware(readDetailPostMw, &rdDto, data); err != nil {
+		if err := mwRunner.RunDeleteMiddleware(deletePreMw, &input); err != nil {
 			return err
 		}
 
 		return nil
 	})
 
-	if err != nil {
+	if err = runLogMiddleware(err, input, mwRunner); err != nil {
 		return nil, err
 	}
 
+	pl.SetLogInfo(&event, nil, "complete")
+
 	return &d.Data{
 		Meta: d.IS{
 			"source":    source,
@@ -274,3 +264,32 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
 	}, nil
 
 }
+
+func runLogMiddleware(err error, input any, mwRunner *middlewareRunner) error {
+	var errMsg string
+	inputLog := esync.SimxLogDto{
+		Payload: input,
+		Method:  erc.CCCreate,
+	}
+
+	if err != nil {
+		// Run log-middleware
+		errMsg = err.Error()
+		inputLog.ErrMessage = &errMsg
+		inputLog.IsSuccess = false
+
+		// create log failed
+		if errMiddleware := mwRunner.RunCreateLogMiddleware(createSimxLogMw, &inputLog); errMiddleware != nil {
+			return errMiddleware
+		}
+		return err
+	}
+
+	// create log success
+	inputLog.IsSuccess = true
+	if err = mwRunner.RunCreateLogMiddleware(createSimxLogMw, &inputLog); err != nil {
+		return err
+	}
+
+	return nil
+}
diff --git a/internal/use-case/main-use-case/subspecialist/middleware-runner.go b/internal/use-case/main-use-case/subspecialist/middleware-runner.go
index c7e5f285..065e5ecc 100644
--- a/internal/use-case/main-use-case/subspecialist/middleware-runner.go
+++ b/internal/use-case/main-use-case/subspecialist/middleware-runner.go
@@ -2,6 +2,7 @@ package subspecialist
 
 import (
 	e "simrs-vx/internal/domain/main-entities/subspecialist"
+	esync "simrs-vx/internal/domain/sync-entities/log"
 	pl "simrs-vx/pkg/logger"
 	pu "simrs-vx/pkg/use-case-helper"
 
@@ -15,21 +16,35 @@ type middlewareRunner struct {
 }
 
 // NewMiddlewareExecutor creates a new middleware executor
-func newMiddlewareRunner(event *pl.Event, tx *gorm.DB) *middlewareRunner {
+func newMiddlewareRunner(event *pl.Event) *middlewareRunner {
 	return &middlewareRunner{
 		Event: event,
-		Tx:    tx,
 	}
 }
 
 // ExecuteCreateMiddleware executes create middleware
-func (me *middlewareRunner) RunCreateMiddleware(middlewares []createMw, input *e.CreateDto, data *e.Subspecialist) error {
+func (me *middlewareRunner) RunCreateMiddleware(middlewares []createMw, input *e.CreateDto) error {
 	for _, middleware := range middlewares {
-		logData := pu.GetLogData(input, data)
+		logData := pu.GetLogData(input, nil)
 
 		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
 
-		if err := middleware.Func(input, data, me.Tx); err != nil {
+		if err := middleware.Func(input); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+func (me *middlewareRunner) RunCreateLogMiddleware(middlewares []createLogMw, input *esync.SimxLogDto) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, nil)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input); err != nil {
 			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
 		}
 
@@ -68,13 +83,13 @@ func (me *middlewareRunner) RunReadDetailMiddleware(middlewares []readDetailMw,
 	return nil
 }
 
-func (me *middlewareRunner) RunUpdateMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Subspecialist) error {
+func (me *middlewareRunner) RunUpdateMiddleware(middlewares []updateMw, input *e.UpdateDto) error {
 	for _, middleware := range middlewares {
-		logData := pu.GetLogData(input, data)
+		logData := pu.GetLogData(input, nil)
 
 		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
 
-		if err := middleware.Func(input, data, me.Tx); err != nil {
+		if err := middleware.Func(input); err != nil {
 			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
 		}
 
@@ -83,13 +98,13 @@ func (me *middlewareRunner) RunUpdateMiddleware(middlewares []readDetailMw, inpu
 	return nil
 }
 
-func (me *middlewareRunner) RunDeleteMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Subspecialist) error {
+func (me *middlewareRunner) RunDeleteMiddleware(middlewares []deleteMw, input *e.DeleteDto) error {
 	for _, middleware := range middlewares {
-		logData := pu.GetLogData(input, data)
+		logData := pu.GetLogData(input, nil)
 
 		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
 
-		if err := middleware.Func(input, data, me.Tx); err != nil {
+		if err := middleware.Func(input); err != nil {
 			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
 		}
 
diff --git a/internal/use-case/main-use-case/subspecialist/tycovar.go b/internal/use-case/main-use-case/subspecialist/tycovar.go
index ed4540b8..cd26e517 100644
--- a/internal/use-case/main-use-case/subspecialist/tycovar.go
+++ b/internal/use-case/main-use-case/subspecialist/tycovar.go
@@ -9,6 +9,8 @@ functionality. The purpose of this is to make the code more maintainable.
 package subspecialist
 
 import (
+	elog "simrs-vx/internal/domain/sync-entities/log"
+
 	"gorm.io/gorm"
 
 	e "simrs-vx/internal/domain/main-entities/subspecialist"
@@ -16,7 +18,22 @@ import (
 
 type createMw struct {
 	Name string
-	Func func(input *e.CreateDto, data *e.Subspecialist, tx *gorm.DB) error
+	Func func(input *e.CreateDto) error
+}
+
+type createLogMw struct {
+	Name string
+	Func func(input *elog.SimxLogDto) error
+}
+
+type updateMw struct {
+	Name string
+	Func func(input *e.UpdateDto) error
+}
+
+type deleteMw struct {
+	Name string
+	Func func(input *e.DeleteDto) error
 }
 
 type readListMw struct {
@@ -29,16 +46,17 @@ type readDetailMw struct {
 	Func func(input *e.ReadDetailDto, data *e.Subspecialist, tx *gorm.DB) error
 }
 
-type UpdateMw = readDetailMw
-type DeleteMw = readDetailMw
+type UpdateMw = updateMw
+type DeleteMw = deleteMw
 
-var createPreMw []createMw      // preprocess middleware
-var createPostMw []createMw     // postprocess middleware
+var createPreMw []createMw  // preprocess middleware
+var createPostMw []createMw // postprocess middleware
+var createSimxLogMw []createLogMw
 var readListPreMw []readListMw  // ..
 var readListPostMw []readListMw // ..
 var readDetailPreMw []readDetailMw
 var readDetailPostMw []readDetailMw
-var updatePreMw []readDetailMw
+var updatePreMw []updateMw
 var updatePostMw []readDetailMw
-var deletePreMw []readDetailMw
+var deletePreMw []deleteMw
 var deletePostMw []readDetailMw
diff --git a/internal/use-case/simgos-sync-plugin/specialist/plugin.go b/internal/use-case/simgos-sync-plugin/specialist/plugin.go
new file mode 100644
index 00000000..892d7a17
--- /dev/null
+++ b/internal/use-case/simgos-sync-plugin/specialist/plugin.go
@@ -0,0 +1,167 @@
+package specialist
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+
+	sync "simrs-vx/internal/infra/sync-cfg"
+
+	e "simrs-vx/internal/domain/main-entities/specialist"
+	elog "simrs-vx/internal/domain/sync-entities/log"
+
+	d "github.com/karincake/dodol"
+)
+
+func Create(input *e.CreateDto) error {
+	endpoint := getPrefixEndpoint()
+
+	jsonData, err := json.Marshal(input)
+	if err != nil {
+		return fmt.Errorf("failed to encode JSON: %w", err)
+	}
+
+	req, err := http.NewRequest("POST", endpoint, bytes.NewReader(jsonData))
+	if err != nil {
+		return err
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return err
+	}
+	defer resp.Body.Close()
+
+	bodyBytes, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != http.StatusOK {
+		errors := d.FieldError{}
+		_ = json.Unmarshal(bodyBytes, &errors)
+
+		return fmt.Errorf(errors.Message)
+	}
+
+	return nil
+}
+
+func CreateLog(input *elog.SimxLogDto) error {
+	prefixEndpoint := getPrefixEndpoint()
+	endpoint := prefixEndpoint + "/log"
+
+	jsonData, err := json.Marshal(input)
+	if err != nil {
+		return fmt.Errorf("failed to encode JSON: %w", err)
+	}
+
+	req, err := http.NewRequest("POST", endpoint, bytes.NewReader(jsonData))
+	if err != nil {
+		return err
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return err
+	}
+	defer resp.Body.Close()
+
+	bodyBytes, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != http.StatusOK {
+		errors := d.FieldError{}
+		_ = json.Unmarshal(bodyBytes, &errors)
+
+		return fmt.Errorf(errors.Message)
+	}
+
+	return nil
+}
+
+func Update(input *e.UpdateDto) error {
+	prefixEndpoint := getPrefixEndpoint()
+	endpoint := fmt.Sprintf("%s/%v", prefixEndpoint, *input.Id)
+
+	jsonData, err := json.Marshal(input)
+	if err != nil {
+		return fmt.Errorf("failed to encode JSON: %w", err)
+	}
+
+	req, err := http.NewRequest("PATCH", endpoint, bytes.NewReader(jsonData))
+	if err != nil {
+		return err
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return err
+	}
+	defer resp.Body.Close()
+
+	bodyBytes, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != http.StatusOK {
+		errors := d.FieldError{}
+		_ = json.Unmarshal(bodyBytes, &errors)
+
+		return fmt.Errorf(errors.Message)
+	}
+
+	return nil
+}
+
+func Delete(input *e.DeleteDto) error {
+	prefixEndpoint := getPrefixEndpoint()
+	endpoint := fmt.Sprintf("%s/%v", prefixEndpoint, *input.Id)
+
+	jsonData, err := json.Marshal(input)
+	if err != nil {
+		return fmt.Errorf("failed to encode JSON: %w", err)
+	}
+
+	req, err := http.NewRequest("DELETE", endpoint, bytes.NewReader(jsonData))
+	if err != nil {
+		return err
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return err
+	}
+	defer resp.Body.Close()
+
+	bodyBytes, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != http.StatusOK {
+		errors := d.FieldError{}
+		_ = json.Unmarshal(bodyBytes, &errors)
+
+		return fmt.Errorf(errors.Message)
+	}
+
+	return nil
+}
+
+func getPrefixEndpoint() string {
+	return fmt.Sprintf("%s%s/v1/specialist", sync.O.Host, sync.O.Prefix)
+}
diff --git a/internal/use-case/simgos-sync-plugin/subspecialist/plugin.go b/internal/use-case/simgos-sync-plugin/subspecialist/plugin.go
new file mode 100644
index 00000000..15d6f650
--- /dev/null
+++ b/internal/use-case/simgos-sync-plugin/subspecialist/plugin.go
@@ -0,0 +1,167 @@
+package subspecialist
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+
+	sync "simrs-vx/internal/infra/sync-cfg"
+
+	e "simrs-vx/internal/domain/main-entities/subspecialist"
+	elog "simrs-vx/internal/domain/sync-entities/log"
+
+	d "github.com/karincake/dodol"
+)
+
+func Create(input *e.CreateDto) error {
+	endpoint := getPrefixEndpoint()
+
+	jsonData, err := json.Marshal(input)
+	if err != nil {
+		return fmt.Errorf("failed to encode JSON: %w", err)
+	}
+
+	req, err := http.NewRequest("POST", endpoint, bytes.NewReader(jsonData))
+	if err != nil {
+		return err
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return err
+	}
+	defer resp.Body.Close()
+
+	bodyBytes, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != http.StatusOK {
+		errors := d.FieldError{}
+		_ = json.Unmarshal(bodyBytes, &errors)
+
+		return fmt.Errorf(errors.Message)
+	}
+
+	return nil
+}
+
+func CreateLog(input *elog.SimxLogDto) error {
+	prefixEndpoint := getPrefixEndpoint()
+	endpoint := prefixEndpoint + "/log"
+
+	jsonData, err := json.Marshal(input)
+	if err != nil {
+		return fmt.Errorf("failed to encode JSON: %w", err)
+	}
+
+	req, err := http.NewRequest("POST", endpoint, bytes.NewReader(jsonData))
+	if err != nil {
+		return err
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return err
+	}
+	defer resp.Body.Close()
+
+	bodyBytes, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != http.StatusOK {
+		errors := d.FieldError{}
+		_ = json.Unmarshal(bodyBytes, &errors)
+
+		return fmt.Errorf(errors.Message)
+	}
+
+	return nil
+}
+
+func Update(input *e.UpdateDto) error {
+	prefixEndpoint := getPrefixEndpoint()
+	endpoint := fmt.Sprintf("%s/%v", prefixEndpoint, *input.Id)
+
+	jsonData, err := json.Marshal(input)
+	if err != nil {
+		return fmt.Errorf("failed to encode JSON: %w", err)
+	}
+
+	req, err := http.NewRequest("PATCH", endpoint, bytes.NewReader(jsonData))
+	if err != nil {
+		return err
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return err
+	}
+	defer resp.Body.Close()
+
+	bodyBytes, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != http.StatusOK {
+		errors := d.FieldError{}
+		_ = json.Unmarshal(bodyBytes, &errors)
+
+		return fmt.Errorf(errors.Message)
+	}
+
+	return nil
+}
+
+func Delete(input *e.DeleteDto) error {
+	prefixEndpoint := getPrefixEndpoint()
+	endpoint := fmt.Sprintf("%s/%v", prefixEndpoint, *input.Id)
+
+	jsonData, err := json.Marshal(input)
+	if err != nil {
+		return fmt.Errorf("failed to encode JSON: %w", err)
+	}
+
+	req, err := http.NewRequest("DELETE", endpoint, bytes.NewReader(jsonData))
+	if err != nil {
+		return err
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return err
+	}
+	defer resp.Body.Close()
+
+	bodyBytes, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != http.StatusOK {
+		errors := d.FieldError{}
+		_ = json.Unmarshal(bodyBytes, &errors)
+
+		return fmt.Errorf(errors.Message)
+	}
+
+	return nil
+}
+
+func getPrefixEndpoint() string {
+	return fmt.Sprintf("%s%s/v1/subspecialist", sync.O.Host, sync.O.Prefix)
+}
diff --git a/internal/use-case/simgos-sync-use-case/specialist/case.go b/internal/use-case/simgos-sync-use-case/specialist/case.go
new file mode 100644
index 00000000..4e6de31d
--- /dev/null
+++ b/internal/use-case/simgos-sync-use-case/specialist/case.go
@@ -0,0 +1,214 @@
+package specialist
+
+import (
+	pl "simrs-vx/pkg/logger"
+
+	dg "github.com/karincake/apem/db-gorm-pg"
+	d "github.com/karincake/dodol"
+	"gorm.io/gorm"
+
+	e "simrs-vx/internal/domain/main-entities/specialist"
+	esimgos "simrs-vx/internal/domain/simgos-entities/specialist"
+	esync "simrs-vx/internal/domain/sync-entities/log"
+)
+
+const source = "specialist"
+
+func Create(input e.CreateDto) (*d.Data, error) {
+	var (
+		txSync   = dg.I.Begin()
+		txSimgos = dg.IS["simrs"].Begin()
+	)
+
+	event := pl.Event{
+		Feature: "Create",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "create")
+
+	// STEP 1: Insert to simgos
+	sgData, err := CreateSimgosData(input, &event, txSimgos)
+	if err != nil {
+		return nil, err
+	}
+
+	// STEP 2: Insert to Link
+	syncLink, err := CreateLinkData(*input.Id, sgData.Id, &event, txSync)
+	if err != nil {
+		txSimgos.Rollback()
+		return nil, err
+	}
+
+	// STEP 3: Commit two trx
+	if err = txSync.Commit().Error; err != nil {
+		txSync.Rollback()
+		txSimgos.Rollback()
+		return nil, err
+	}
+
+	if err = txSimgos.Commit().Error; err != nil {
+		// STEP 4: Rollback Partial
+		go func() {
+			_ = DeleteLinkData(syncLink, &event)
+		}()
+		return nil, err
+	}
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.II{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "created",
+		},
+	}, nil
+}
+
+func CreateSimxLog(input esync.SimxLogDto) (*d.Data, error) {
+	event := pl.Event{
+		Feature: "Create",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "create")
+
+	err := dg.I.Transaction(func(tx *gorm.DB) error {
+		// InsertSimxLog
+		if err := CreateLogData(input, &event, tx); err != nil {
+			return err
+		}
+
+		pl.SetLogInfo(&event, nil, "complete")
+
+		return nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.II{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "created",
+		},
+	}, nil
+}
+
+func Update(input e.UpdateDto) (*d.Data, error) {
+	var (
+		txSimgos = dg.IS["simrs"].Begin()
+		err      error
+	)
+
+	event := pl.Event{
+		Feature: "Update",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "update")
+
+	// STEP 1: Get Installation Link
+	syncLink, err := ReadDetailLinkData(*input.Id, &event)
+	if err != nil {
+		return nil, err
+	}
+
+	// Step 2: Update Simgos
+	err = UpdateSimgosData(input, syncLink, &event, txSimgos)
+	if err != nil {
+		return nil, err
+	}
+
+	// STEP 4: Commit two trx
+	if err = txSimgos.Commit().Error; err != nil {
+		txSimgos.Rollback()
+		return nil, err
+	}
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "updated",
+		},
+	}, nil
+}
+
+func Delete(input e.DeleteDto) (*d.Data, error) {
+	var (
+		txSync   = dg.I.Begin()
+		txSimgos = dg.IS["simrs"].Begin()
+		sgData   *esimgos.MPolihfis
+		err      error
+	)
+
+	event := pl.Event{
+		Feature: "Delete",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "delete")
+
+	// STEP 1: Get Installation Link
+	syncLink, err := ReadDetailLinkData(*input.Id, &event)
+	if err != nil {
+		return nil, err
+	}
+
+	// STEP 2: Get Simgos
+	sgData, err = ReadDetailSimgosData(uint16(syncLink.Simgos_Id), &event)
+	if err != nil {
+		return nil, err
+	}
+
+	// STEP 3: Delete M_Unit Simgos
+	err = HardDeleteSimgosData(sgData, &event, txSimgos)
+	if err != nil {
+		return nil, err
+	}
+
+	// STEP 4: Delete Installation Link
+	err = DeleteLinkData(syncLink, &event, txSync)
+	if err != nil {
+		txSimgos.Rollback()
+		return nil, err
+	}
+
+	// STEP 4: Commit two trx
+	if err = txSync.Commit().Error; err != nil {
+		txSync.Rollback()
+		txSimgos.Rollback()
+		return nil, err
+	}
+
+	if err = txSimgos.Commit().Error; err != nil {
+		// STEP 5: Rollback Partial
+		go func() {
+			_, _ = CreateLinkData(uint(*input.Id), sgData.Id, &event)
+		}()
+		return nil, err
+	}
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "deleted",
+		},
+	}, nil
+
+}
diff --git a/internal/use-case/simgos-sync-use-case/specialist/helper.go b/internal/use-case/simgos-sync-use-case/specialist/helper.go
new file mode 100644
index 00000000..95839354
--- /dev/null
+++ b/internal/use-case/simgos-sync-use-case/specialist/helper.go
@@ -0,0 +1,60 @@
+/*
+DESCRIPTION:
+Any functions that are used internally by the use-case
+*/
+package specialist
+
+import (
+	"encoding/json"
+	erc "simrs-vx/internal/domain/references/common"
+
+	e "simrs-vx/internal/domain/main-entities/specialist"
+	esimgos "simrs-vx/internal/domain/simgos-entities/specialist"
+	esyncLog "simrs-vx/internal/domain/sync-entities/log"
+	esync "simrs-vx/internal/domain/sync-entities/specialist"
+)
+
+func setDataSimgos[T *e.CreateDto | *e.UpdateDto](input T) (data esimgos.MPolihfis) {
+	var inputSrc *e.CreateDto
+	if inputT, ok := any(input).(*e.CreateDto); ok {
+		inputSrc = inputT
+	} else {
+		inputTemp := any(input).(*e.UpdateDto)
+		inputSrc = &inputTemp.CreateDto
+	}
+
+	data.Code = inputSrc.Code
+	data.Poliklinik = inputSrc.Name
+	data.Active = 1
+	data.Status = 1
+
+	return
+}
+
+func setDataSimxLog(input *esyncLog.SimxLogDto) (data esync.SpecialistSimxLog) {
+	// encode to JSON
+	jsonData, _ := json.MarshalIndent(input.Payload, "", "  ")
+	jsonString := string(jsonData)
+
+	var status erc.ProcessStatusCode
+	if input.IsSuccess {
+		status = erc.PSCSuccess
+	} else {
+		status = erc.PSCFailed
+		if input.ErrMessage != nil {
+			data.ErrMessage = input.ErrMessage
+		}
+	}
+
+	data.Value = &jsonString
+	data.Date = &now
+	data.Status = status
+
+	return
+}
+
+func setDataSimxLink(simxId, simgosId uint) (data esync.SpecialistLink) {
+	data.Simx_Id = simxId
+	data.Simgos_Id = simgosId
+	return
+}
diff --git a/internal/use-case/simgos-sync-use-case/specialist/lib.go b/internal/use-case/simgos-sync-use-case/specialist/lib.go
new file mode 100644
index 00000000..c7123f0b
--- /dev/null
+++ b/internal/use-case/simgos-sync-use-case/specialist/lib.go
@@ -0,0 +1,188 @@
+package specialist
+
+import (
+	plh "simrs-vx/pkg/lib-helper"
+	pl "simrs-vx/pkg/logger"
+	pu "simrs-vx/pkg/use-case-helper"
+	"time"
+
+	dg "github.com/karincake/apem/db-gorm-pg"
+	"gorm.io/gorm"
+
+	e "simrs-vx/internal/domain/main-entities/specialist"
+	esimgos "simrs-vx/internal/domain/simgos-entities/specialist"
+	esynclog "simrs-vx/internal/domain/sync-entities/log"
+	esync "simrs-vx/internal/domain/sync-entities/specialist"
+)
+
+var now = time.Now()
+
+func CreateSimgosData(input e.CreateDto, event *pl.Event, dbx ...*gorm.DB) (*esimgos.MPolihfis, error) {
+	pl.SetLogInfo(event, nil, "started", "DBCreate")
+
+	data := setDataSimgos(&input)
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.IS["simrs"]
+	}
+
+	if err := tx.Create(&data).Error; err != nil {
+		return nil, plh.HandleCreateError(input, event, err)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func ReadDetailSimgosData(simgosId uint16, event *pl.Event) (*esimgos.MPolihfis, error) {
+	pl.SetLogInfo(event, simgosId, "started", "DBReadDetail")
+	data := esimgos.MPolihfis{}
+
+	var tx = dg.IS["simrs"]
+
+	if err := tx.
+		Where("\"id\" = ?", simgosId).
+		First(&data).Error; err != nil {
+		if processedErr := pu.HandleReadError(err, event, source, simgosId, data); processedErr != nil {
+			return nil, processedErr
+		}
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func UpdateSimgosData(input e.UpdateDto, dataSimgos *esync.SpecialistLink, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, input, "started", "DBUpdate")
+
+	data := setDataSimgos(&input)
+	data.Id = dataSimgos.Simgos_Id
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.IS["simrs"]
+	}
+
+	if err := tx.Save(&data).Error; err != nil {
+		event.Status = "failed"
+		event.ErrInfo = pl.ErrorInfo{
+			Code:   "data-update-fail",
+			Detail: "Database update failed",
+			Raw:    err,
+		}
+		return pl.SetLogError(event, input)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}
+
+func HardDeleteSimgosData(data *esimgos.MPolihfis, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, data, "started", "DBDelete")
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.IS["simrs"]
+	}
+
+	if err := tx.
+		Delete(&data).Error; err != nil {
+		event.Status = "failed"
+		event.ErrInfo = pl.ErrorInfo{
+			Code:   "data-delete-fail",
+			Detail: "Database delete failed",
+			Raw:    err,
+		}
+		return pl.SetLogError(event, data)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}
+
+func CreateLinkData(simxId, simgosId uint, event *pl.Event, dbx ...*gorm.DB) (*esync.SpecialistLink, error) {
+	pl.SetLogInfo(event, nil, "started", "DBCreate")
+	data := setDataSimxLink(simxId, simgosId)
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.Create(&data).Error; err != nil {
+		return nil, plh.HandleCreateError(data, event, err)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func ReadDetailLinkData(simxId uint16, event *pl.Event) (*esync.SpecialistLink, error) {
+	pl.SetLogInfo(event, simxId, "started", "DBReadDetail")
+	data := esync.SpecialistLink{}
+
+	var tx = dg.I
+
+	if err := tx.
+		Where("\"Simx_Id\" = ?", simxId).
+		First(&data).Error; err != nil {
+		if processedErr := pu.HandleReadError(err, event, source, simxId, data); processedErr != nil {
+			return nil, processedErr
+		}
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func DeleteLinkData(data *esync.SpecialistLink, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, data, "started", "DBDelete")
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.Delete(&data).Error; err != nil {
+		event.Status = "failed"
+		event.ErrInfo = pl.ErrorInfo{
+			Code:   "data-delete-fail",
+			Detail: "Database delete failed",
+			Raw:    err,
+		}
+		return pl.SetLogError(event, data)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}
+
+func CreateLogData(input esynclog.SimxLogDto, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, nil, "started", "DBCreate")
+	data := setDataSimxLog(&input)
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.Create(&data).Error; err != nil {
+		return plh.HandleCreateError(input, event, err)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}
diff --git a/internal/use-case/simgos-sync-use-case/specialist/middleware-runner.go b/internal/use-case/simgos-sync-use-case/specialist/middleware-runner.go
new file mode 100644
index 00000000..938c1f92
--- /dev/null
+++ b/internal/use-case/simgos-sync-use-case/specialist/middleware-runner.go
@@ -0,0 +1,104 @@
+package specialist
+
+import (
+	pl "simrs-vx/pkg/logger"
+	pu "simrs-vx/pkg/use-case-helper"
+
+	"gorm.io/gorm"
+
+	e "simrs-vx/internal/domain/main-entities/specialist"
+)
+
+type middlewareRunner struct {
+	Event  *pl.Event
+	Tx     *gorm.DB
+	MwType pu.MWType
+}
+
+// NewMiddlewareExecutor creates a new middleware executor
+func newMiddlewareRunner(event *pl.Event, tx *gorm.DB) *middlewareRunner {
+	return &middlewareRunner{
+		Event: event,
+		Tx:    tx,
+	}
+}
+
+// ExecuteCreateMiddleware executes create middleware
+func (me *middlewareRunner) RunCreateMiddleware(middlewares []createMw, input *e.CreateDto, data *e.Specialist) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+func (me *middlewareRunner) RunReadListMiddleware(middlewares []readListMw, input *e.ReadListDto, data *e.Specialist) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+func (me *middlewareRunner) RunReadDetailMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Specialist) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+func (me *middlewareRunner) RunUpdateMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Specialist) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+func (me *middlewareRunner) RunDeleteMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Specialist) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+func (me *middlewareRunner) setMwType(mwType pu.MWType) {
+	me.MwType = mwType
+}
diff --git a/internal/use-case/simgos-sync-use-case/specialist/middleware.go b/internal/use-case/simgos-sync-use-case/specialist/middleware.go
new file mode 100644
index 00000000..298e51a8
--- /dev/null
+++ b/internal/use-case/simgos-sync-use-case/specialist/middleware.go
@@ -0,0 +1,9 @@
+package specialist
+
+// example of middleware
+// func init() {
+// 	createPreMw = append(createPreMw,
+// 		CreateMw{Name: "modif-input", Func: pm.ModifInput},
+// 		CreateMw{Name: "check-data", Func: pm.CheckData},
+// 	)
+// }
diff --git a/internal/use-case/simgos-sync-use-case/specialist/tycovar.go b/internal/use-case/simgos-sync-use-case/specialist/tycovar.go
new file mode 100644
index 00000000..16fa50b0
--- /dev/null
+++ b/internal/use-case/simgos-sync-use-case/specialist/tycovar.go
@@ -0,0 +1,44 @@
+/*
+DESCRIPTION:
+A sample, part of the package that contains type, constants, and/or variables.
+
+In this sample it also provides type and variable regarding the needs of the
+middleware to separate from main use-case which has the basic CRUD
+functionality. The purpose of this is to make the code more maintainable.
+*/
+package specialist
+
+import (
+	"gorm.io/gorm"
+
+	e "simrs-vx/internal/domain/main-entities/specialist"
+)
+
+type createMw struct {
+	Name string
+	Func func(input *e.CreateDto, data *e.Specialist, tx *gorm.DB) error
+}
+
+type readListMw struct {
+	Name string
+	Func func(input *e.ReadListDto, data *e.Specialist, tx *gorm.DB) error
+}
+
+type readDetailMw struct {
+	Name string
+	Func func(input *e.ReadDetailDto, data *e.Specialist, tx *gorm.DB) error
+}
+
+type UpdateMw = readDetailMw
+type DeleteMw = readDetailMw
+
+var createPreMw []createMw      // preprocess middleware
+var createPostMw []createMw     // postprocess middleware
+var readListPreMw []readListMw  // ..
+var readListPostMw []readListMw // ..
+var readDetailPreMw []readDetailMw
+var readDetailPostMw []readDetailMw
+var updatePreMw []readDetailMw
+var updatePostMw []readDetailMw
+var deletePreMw []readDetailMw
+var deletePostMw []readDetailMw
diff --git a/internal/use-case/simgos-sync-use-case/subspecialist/case.go b/internal/use-case/simgos-sync-use-case/subspecialist/case.go
new file mode 100644
index 00000000..e16d50bd
--- /dev/null
+++ b/internal/use-case/simgos-sync-use-case/subspecialist/case.go
@@ -0,0 +1,214 @@
+package subspecialist
+
+import (
+	pl "simrs-vx/pkg/logger"
+
+	dg "github.com/karincake/apem/db-gorm-pg"
+	d "github.com/karincake/dodol"
+	"gorm.io/gorm"
+
+	e "simrs-vx/internal/domain/main-entities/subspecialist"
+	//esimgos "simrs-vx/internal/domain/simgos-entities/specialist"
+	esync "simrs-vx/internal/domain/sync-entities/log"
+)
+
+const source = "subspecialist"
+
+func Create(input e.CreateDto) (*d.Data, error) {
+	//var (
+	//	txSync   = dg.I.Begin()
+	//	txSimgos = dg.IS["simrs"].Begin()
+	//)
+
+	event := pl.Event{
+		Feature: "Create",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "create")
+
+	//// STEP 1: Insert to simgos
+	//sgData, err := CreateSimgosData(input, &event, txSimgos)
+	//if err != nil {
+	//	return nil, err
+	//}
+	//
+	//// STEP 2: Insert to Link
+	//syncLink, err := CreateLinkData(*input.Id, sgData.Id, &event, txSync)
+	//if err != nil {
+	//	txSimgos.Rollback()
+	//	return nil, err
+	//}
+	//
+	//// STEP 3: Commit two trx
+	//if err = txSync.Commit().Error; err != nil {
+	//	txSync.Rollback()
+	//	txSimgos.Rollback()
+	//	return nil, err
+	//}
+	//
+	//if err = txSimgos.Commit().Error; err != nil {
+	//	// STEP 4: Rollback Partial
+	//	go func() {
+	//		_ = DeleteLinkData(syncLink, &event)
+	//	}()
+	//	return nil, err
+	//}
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.II{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "created",
+		},
+	}, nil
+}
+
+func CreateSimxLog(input esync.SimxLogDto) (*d.Data, error) {
+	event := pl.Event{
+		Feature: "Create",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "create")
+
+	err := dg.I.Transaction(func(tx *gorm.DB) error {
+		// InsertSimxLog
+		if err := CreateLogData(input, &event, tx); err != nil {
+			return err
+		}
+
+		pl.SetLogInfo(&event, nil, "complete")
+
+		return nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.II{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "created",
+		},
+	}, nil
+}
+
+func Update(input e.UpdateDto) (*d.Data, error) {
+	//var (
+	//	txSimgos = dg.IS["simrs"].Begin()
+	//	err      error
+	//)
+
+	event := pl.Event{
+		Feature: "Update",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "update")
+
+	//// STEP 1: Get Installation Link
+	//syncLink, err := ReadDetailLinkData(*input.Id, &event)
+	//if err != nil {
+	//	return nil, err
+	//}
+	//
+	//// Step 2: Update Simgos
+	//err = UpdateSimgosData(input, syncLink, &event, txSimgos)
+	//if err != nil {
+	//	return nil, err
+	//}
+	//
+	//// STEP 4: Commit two trx
+	//if err = txSimgos.Commit().Error; err != nil {
+	//	txSimgos.Rollback()
+	//	return nil, err
+	//}
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "updated",
+		},
+	}, nil
+}
+
+func Delete(input e.DeleteDto) (*d.Data, error) {
+	//var (
+	//	txSync   = dg.I.Begin()
+	//	txSimgos = dg.IS["simrs"].Begin()
+	//	sgData   *esimgos.MPolihfis
+	//	err      error
+	//)
+
+	event := pl.Event{
+		Feature: "Delete",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "delete")
+
+	//// STEP 1: Get Installation Link
+	//syncLink, err := ReadDetailLinkData(*input.Id, &event)
+	//if err != nil {
+	//	return nil, err
+	//}
+	//
+	//// STEP 2: Get Simgos
+	//sgData, err = ReadDetailSimgosData(uint16(syncLink.Simgos_Id), &event)
+	//if err != nil {
+	//	return nil, err
+	//}
+	//
+	//// STEP 3: Delete M_Unit Simgos
+	//err = HardDeleteSimgosData(sgData, &event, txSimgos)
+	//if err != nil {
+	//	return nil, err
+	//}
+	//
+	//// STEP 4: Delete Installation Link
+	//err = DeleteLinkData(syncLink, &event, txSync)
+	//if err != nil {
+	//	txSimgos.Rollback()
+	//	return nil, err
+	//}
+	//
+	//// STEP 4: Commit two trx
+	//if err = txSync.Commit().Error; err != nil {
+	//	txSync.Rollback()
+	//	txSimgos.Rollback()
+	//	return nil, err
+	//}
+	//
+	//if err = txSimgos.Commit().Error; err != nil {
+	//	// STEP 5: Rollback Partial
+	//	go func() {
+	//		_, _ = CreateLinkData(uint(*input.Id), sgData.Id, &event)
+	//	}()
+	//	return nil, err
+	//}
+
+	pl.SetLogInfo(&event, nil, "complete")
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "deleted",
+		},
+	}, nil
+
+}
diff --git a/internal/use-case/simgos-sync-use-case/subspecialist/helper.go b/internal/use-case/simgos-sync-use-case/subspecialist/helper.go
new file mode 100644
index 00000000..898f161c
--- /dev/null
+++ b/internal/use-case/simgos-sync-use-case/subspecialist/helper.go
@@ -0,0 +1,59 @@
+/*
+DESCRIPTION:
+Any functions that are used internally by the use-case
+*/
+package subspecialist
+
+import (
+	"encoding/json"
+	erc "simrs-vx/internal/domain/references/common"
+	//esimgos "simrs-vx/internal/domain/simgos-entities/specialist"
+	esyncLog "simrs-vx/internal/domain/sync-entities/log"
+	esync "simrs-vx/internal/domain/sync-entities/specialist"
+)
+
+//func setDataSimgos[T *e.CreateDto | *e.UpdateDto](input T) (data esimgos.MPolihfis) {
+//	var inputSrc *e.CreateDto
+//	if inputT, ok := any(input).(*e.CreateDto); ok {
+//		inputSrc = inputT
+//	} else {
+//		inputTemp := any(input).(*e.UpdateDto)
+//		inputSrc = &inputTemp.CreateDto
+//	}
+//
+//	data.Code = inputSrc.Code
+//	data.Poliklinik = inputSrc.Name
+//	data.CodePolirs = *inputSrc.Unit_Code
+//	data.Active = 1
+//	data.Status = 1
+//
+//	return
+//}
+
+func setDataSimxLog(input *esyncLog.SimxLogDto) (data esync.SpecialistSimxLog) {
+	// encode to JSON
+	jsonData, _ := json.MarshalIndent(input.Payload, "", "  ")
+	jsonString := string(jsonData)
+
+	var status erc.ProcessStatusCode
+	if input.IsSuccess {
+		status = erc.PSCSuccess
+	} else {
+		status = erc.PSCFailed
+		if input.ErrMessage != nil {
+			data.ErrMessage = input.ErrMessage
+		}
+	}
+
+	data.Value = &jsonString
+	data.Date = &now
+	data.Status = status
+
+	return
+}
+
+func setDataSimxLink(simxId, simgosId uint) (data esync.SpecialistLink) {
+	data.Simx_Id = simxId
+	data.Simgos_Id = simgosId
+	return
+}
diff --git a/internal/use-case/simgos-sync-use-case/subspecialist/lib.go b/internal/use-case/simgos-sync-use-case/subspecialist/lib.go
new file mode 100644
index 00000000..781e899d
--- /dev/null
+++ b/internal/use-case/simgos-sync-use-case/subspecialist/lib.go
@@ -0,0 +1,187 @@
+package subspecialist
+
+import (
+	plh "simrs-vx/pkg/lib-helper"
+	pl "simrs-vx/pkg/logger"
+	pu "simrs-vx/pkg/use-case-helper"
+	"time"
+
+	dg "github.com/karincake/apem/db-gorm-pg"
+	"gorm.io/gorm"
+
+	//esimgos "simrs-vx/internal/domain/simgos-entities/specialist"
+	esynclog "simrs-vx/internal/domain/sync-entities/log"
+	esync "simrs-vx/internal/domain/sync-entities/specialist"
+)
+
+var now = time.Now()
+
+//func CreateSimgosData(input e.CreateDto, event *pl.Event, dbx ...*gorm.DB) (*esimgos.MPolihfis, error) {
+//	pl.SetLogInfo(event, nil, "started", "DBCreate")
+//
+//	data := setDataSimgos(&input)
+//
+//	var tx *gorm.DB
+//	if len(dbx) > 0 {
+//		tx = dbx[0]
+//	} else {
+//		tx = dg.IS["simrs"]
+//	}
+//
+//	if err := tx.Create(&data).Error; err != nil {
+//		return nil, plh.HandleCreateError(input, event, err)
+//	}
+//
+//	pl.SetLogInfo(event, nil, "complete")
+//	return &data, nil
+//}
+
+//func ReadDetailSimgosData(simgosId uint16, event *pl.Event) (*esimgos.MPolihfis, error) {
+//	pl.SetLogInfo(event, simgosId, "started", "DBReadDetail")
+//	data := esimgos.MPolihfis{}
+//
+//	var tx = dg.IS["simrs"]
+//
+//	if err := tx.
+//		Where("\"kode_unit\" = ?", simgosId).
+//		First(&data).Error; err != nil {
+//		if processedErr := pu.HandleReadError(err, event, source, simgosId, data); processedErr != nil {
+//			return nil, processedErr
+//		}
+//	}
+//
+//	pl.SetLogInfo(event, nil, "complete")
+//	return &data, nil
+//}
+
+//func UpdateSimgosData(input e.UpdateDto, dataSimgos *esync.SpecialistLink, event *pl.Event, dbx ...*gorm.DB) error {
+//	pl.SetLogInfo(event, input, "started", "DBUpdate")
+//
+//	data := setDataSimgos(&input)
+//	data.Id = dataSimgos.Simgos_Id
+//
+//	var tx *gorm.DB
+//	if len(dbx) > 0 {
+//		tx = dbx[0]
+//	} else {
+//		tx = dg.IS["simrs"]
+//	}
+//
+//	if err := tx.Save(&data).Error; err != nil {
+//		event.Status = "failed"
+//		event.ErrInfo = pl.ErrorInfo{
+//			Code:   "data-update-fail",
+//			Detail: "Database update failed",
+//			Raw:    err,
+//		}
+//		return pl.SetLogError(event, input)
+//	}
+//
+//	pl.SetLogInfo(event, nil, "complete")
+//	return nil
+//}
+
+//func HardDeleteSimgosData(data *esimgos.MPolihfis, event *pl.Event, dbx ...*gorm.DB) error {
+//	pl.SetLogInfo(event, data, "started", "DBDelete")
+//
+//	var tx *gorm.DB
+//	if len(dbx) > 0 {
+//		tx = dbx[0]
+//	} else {
+//		tx = dg.IS["simrs"]
+//	}
+//
+//	if err := tx.
+//		Delete(&data).Error; err != nil {
+//		event.Status = "failed"
+//		event.ErrInfo = pl.ErrorInfo{
+//			Code:   "data-delete-fail",
+//			Detail: "Database delete failed",
+//			Raw:    err,
+//		}
+//		return pl.SetLogError(event, data)
+//	}
+//
+//	pl.SetLogInfo(event, nil, "complete")
+//	return nil
+//}
+
+func CreateLinkData(simxId, simgosId uint, event *pl.Event, dbx ...*gorm.DB) (*esync.SpecialistLink, error) {
+	pl.SetLogInfo(event, nil, "started", "DBCreate")
+	data := setDataSimxLink(simxId, simgosId)
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.Create(&data).Error; err != nil {
+		return nil, plh.HandleCreateError(data, event, err)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func ReadDetailLinkData(simxId uint16, event *pl.Event) (*esync.SpecialistLink, error) {
+	pl.SetLogInfo(event, simxId, "started", "DBReadDetail")
+	data := esync.SpecialistLink{}
+
+	var tx = dg.I
+
+	if err := tx.
+		Where("\"Simx_Id\" = ?", simxId).
+		First(&data).Error; err != nil {
+		if processedErr := pu.HandleReadError(err, event, source, simxId, data); processedErr != nil {
+			return nil, processedErr
+		}
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func DeleteLinkData(data *esync.SpecialistLink, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, data, "started", "DBDelete")
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.Delete(&data).Error; err != nil {
+		event.Status = "failed"
+		event.ErrInfo = pl.ErrorInfo{
+			Code:   "data-delete-fail",
+			Detail: "Database delete failed",
+			Raw:    err,
+		}
+		return pl.SetLogError(event, data)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}
+
+func CreateLogData(input esynclog.SimxLogDto, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, nil, "started", "DBCreate")
+	data := setDataSimxLog(&input)
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	if err := tx.Create(&data).Error; err != nil {
+		return plh.HandleCreateError(input, event, err)
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return nil
+}
diff --git a/internal/use-case/simgos-sync-use-case/subspecialist/middleware-runner.go b/internal/use-case/simgos-sync-use-case/subspecialist/middleware-runner.go
new file mode 100644
index 00000000..134041f1
--- /dev/null
+++ b/internal/use-case/simgos-sync-use-case/subspecialist/middleware-runner.go
@@ -0,0 +1,104 @@
+package subspecialist
+
+import (
+	pl "simrs-vx/pkg/logger"
+	pu "simrs-vx/pkg/use-case-helper"
+
+	"gorm.io/gorm"
+
+	e "simrs-vx/internal/domain/main-entities/subspecialist"
+)
+
+type middlewareRunner struct {
+	Event  *pl.Event
+	Tx     *gorm.DB
+	MwType pu.MWType
+}
+
+// NewMiddlewareExecutor creates a new middleware executor
+func newMiddlewareRunner(event *pl.Event, tx *gorm.DB) *middlewareRunner {
+	return &middlewareRunner{
+		Event: event,
+		Tx:    tx,
+	}
+}
+
+// ExecuteCreateMiddleware executes create middleware
+func (me *middlewareRunner) RunCreateMiddleware(middlewares []createMw, input *e.CreateDto, data *e.Subspecialist) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+func (me *middlewareRunner) RunReadListMiddleware(middlewares []readListMw, input *e.ReadListDto, data *e.Subspecialist) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+func (me *middlewareRunner) RunReadDetailMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Subspecialist) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+func (me *middlewareRunner) RunUpdateMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Subspecialist) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+func (me *middlewareRunner) RunDeleteMiddleware(middlewares []readDetailMw, input *e.ReadDetailDto, data *e.Subspecialist) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+func (me *middlewareRunner) setMwType(mwType pu.MWType) {
+	me.MwType = mwType
+}
diff --git a/internal/use-case/simgos-sync-use-case/subspecialist/middleware.go b/internal/use-case/simgos-sync-use-case/subspecialist/middleware.go
new file mode 100644
index 00000000..ad2ba452
--- /dev/null
+++ b/internal/use-case/simgos-sync-use-case/subspecialist/middleware.go
@@ -0,0 +1,9 @@
+package subspecialist
+
+// example of middleware
+// func init() {
+// 	createPreMw = append(createPreMw,
+// 		CreateMw{Name: "modif-input", Func: pm.ModifInput},
+// 		CreateMw{Name: "check-data", Func: pm.CheckData},
+// 	)
+// }
diff --git a/internal/use-case/simgos-sync-use-case/subspecialist/tycovar.go b/internal/use-case/simgos-sync-use-case/subspecialist/tycovar.go
new file mode 100644
index 00000000..ed4540b8
--- /dev/null
+++ b/internal/use-case/simgos-sync-use-case/subspecialist/tycovar.go
@@ -0,0 +1,44 @@
+/*
+DESCRIPTION:
+A sample, part of the package that contains type, constants, and/or variables.
+
+In this sample it also provides type and variable regarding the needs of the
+middleware to separate from main use-case which has the basic CRUD
+functionality. The purpose of this is to make the code more maintainable.
+*/
+package subspecialist
+
+import (
+	"gorm.io/gorm"
+
+	e "simrs-vx/internal/domain/main-entities/subspecialist"
+)
+
+type createMw struct {
+	Name string
+	Func func(input *e.CreateDto, data *e.Subspecialist, tx *gorm.DB) error
+}
+
+type readListMw struct {
+	Name string
+	Func func(input *e.ReadListDto, data *e.Subspecialist, tx *gorm.DB) error
+}
+
+type readDetailMw struct {
+	Name string
+	Func func(input *e.ReadDetailDto, data *e.Subspecialist, tx *gorm.DB) error
+}
+
+type UpdateMw = readDetailMw
+type DeleteMw = readDetailMw
+
+var createPreMw []createMw      // preprocess middleware
+var createPostMw []createMw     // postprocess middleware
+var readListPreMw []readListMw  // ..
+var readListPostMw []readListMw // ..
+var readDetailPreMw []readDetailMw
+var readDetailPostMw []readDetailMw
+var updatePreMw []readDetailMw
+var updatePostMw []readDetailMw
+var deletePreMw []readDetailMw
+var deletePostMw []readDetailMw