add delete and update internal reference

internal/interface/main-handler/internal-reference/handler.go

@@ -32,39 +32,39 @@ func (obj myBase) GetList(w http.ResponseWriter, r *http.Request) {
 }
 
 func (obj myBase) GetDetail(w http.ResponseWriter, r *http.Request) {
-	//id := rw.ValidateInt(w, "id", r.PathValue("id"))
+	id := rw.ValidateInt(w, "id", r.PathValue("id"))
-	//if id <= 0 {
+	if id <= 0 {
-	//	return
+		return
-	//}
+	}
-	//dto := e.ReadDetailDto{}
+	dto := eir.ReadDetailDto{}
-	//dto.Id = uint16(id)
+	dto.Id = uint16(id)
-	//res, err := u.ReadDetail(dto)
+	res, err := uir.ReadDetail(dto)
-	//rw.DataResponse(w, res, err)
+	rw.DataResponse(w, res, err)
 }
 
 func (obj myBase) Update(w http.ResponseWriter, r *http.Request) {
-	//id := rw.ValidateInt(w, "id", r.PathValue("id"))
+	id := rw.ValidateInt(w, "id", r.PathValue("id"))
-	//if id <= 0 {
+	if id <= 0 {
-	//	return
+		return
-	//}
+	}
-	//
+
-	//dto := e.UpdateDto{}
+	dto := eir.UpdateDto{}
-	//if res := rw.ValidateStructByIOR(w, r.Body, &dto); !res {
+	if res := rw.ValidateStructByIOR(w, r.Body, &dto); !res {
-	//	return
+		return
-	//}
+	}
-	//dto.Id = uint16(id)
+	dto.Id = uint16(id)
-	//res, err := u.Update(dto)
+	res, err := uir.Update(dto)
-	//rw.DataResponse(w, res, err)
+	rw.DataResponse(w, res, err)
 }
 
 func (obj myBase) Delete(w http.ResponseWriter, r *http.Request) {
-	//id := rw.ValidateInt(w, "id", r.PathValue("id"))
+	id := rw.ValidateInt(w, "id", r.PathValue("id"))
-	//if id <= 0 {
+	if id <= 0 {
-	//	return
+		return
-	//}
+	}
-	//
+
-	//dto := e.DeleteDto{}
+	dto := eir.DeleteDto{}
-	//dto.Id = uint16(id)
+	dto.Id = uint16(id)
-	//res, err := u.Delete(dto)
+	res, err := uir.Delete(dto)
-	//rw.DataResponse(w, res, err)
+	rw.DataResponse(w, res, err)
 }

internal/use-case/main-use-case/internal-reference/case.go

@@ -43,21 +43,8 @@ func Create(input eir.CreateDto) (*d.Data, error) {
 			return err
 		}
 
-		// Validate Encounter Id
+		// Validate Request
-		_, err := ue.ReadDetail(ee.ReadDetailDto{Id: uint16(*input.Encounter_Id)})
+		if err := validateRequest(input); err != nil {
-		if err != nil {
-			return err
-		}
-
-		// Validate Unit Id
-		_, err = uu.ReadDetail(eu.ReadDetailDto{Id: *input.Unit_Id})
-		if err != nil {
-			return err
-		}
-
-		// Validate Doctor Id
-		_, err = ud.ReadDetail(ed.ReadDetailDto{Id: uint16(*input.Doctor_Id)})
-		if err != nil {
 			return err
 		}
 
@@ -144,3 +131,193 @@ func ReadList(input eir.ReadListDto) (*d.Data, error) {
 		Data: eir.ToResponseList(dataList),
 	}, nil
 }
+
+func ReadDetail(input eir.ReadDetailDto) (*d.Data, error) {
+	var data *eir.InternalReference
+	var err error
+
+	event := pl.Event{
+		Feature: "ReadDetail",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "readDetail")
+
+	err = dg.I.Transaction(func(tx *gorm.DB) error {
+		mwRunner := newMiddlewareRunner(&event, tx)
+		mwRunner.setMwType(pu.MWTPre)
+		// Run pre-middleware
+		if err := mwRunner.RunReadDetailMiddleware(readDetailPreMw, &input, data); err != nil {
+			return err
+		}
+
+		if data, err = ReadDetailData(input, &event, tx); err != nil {
+			return err
+		}
+
+		mwRunner.setMwType(pu.MWTPost)
+		// Run post-middleware
+		if err := mwRunner.RunReadDetailMiddleware(readDetailPostMw, &input, data); err != nil {
+			return err
+		}
+
+		return nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "fetched",
+		},
+		Data: data.ToResponse(),
+	}, nil
+}
+
+func validateRequest(input eir.CreateDto) (err error) {
+
+	// Validate Encounter Id
+	_, err = ue.ReadDetail(ee.ReadDetailDto{Id: uint16(*input.Encounter_Id)})
+	if err != nil {
+		return err
+	}
+
+	// Validate Unit Id
+	_, err = uu.ReadDetail(eu.ReadDetailDto{Id: *input.Unit_Id})
+	if err != nil {
+		return err
+	}
+
+	// Validate Doctor Id
+	_, err = ud.ReadDetail(ed.ReadDetailDto{Id: uint16(*input.Doctor_Id)})
+	if err != nil {
+		return err
+	}
+
+	return
+}
+
+func Update(input eir.UpdateDto) (*d.Data, error) {
+	rdDto := eir.ReadDetailDto{Id: input.Id}
+	var data *eir.InternalReference
+	var err error
+
+	event := pl.Event{
+		Feature: "Update",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "update")
+
+	err = dg.I.Transaction(func(tx *gorm.DB) error {
+		pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
+		if data, err = ReadDetailData(rdDto, &event, tx); err != nil {
+			return err
+		}
+
+		mwRunner := newMiddlewareRunner(&event, tx)
+		mwRunner.setMwType(pu.MWTPre)
+		// Run pre-middleware
+		if err := mwRunner.RunUpdateMiddleware(readDetailPreMw, &rdDto, data); err != nil {
+			return err
+		}
+
+		// Validate Request
+		if err := validateRequest(input.CreateDto); err != nil {
+			return err
+		}
+
+		if err := UpdateData(input, data, &event, tx); err != nil {
+			return err
+		}
+
+		// Get Updated Data
+		if data, err = ReadDetailData(rdDto, &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 {
+			return err
+		}
+
+		return nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "updated",
+		},
+		Data: data.ToResponse(),
+	}, nil
+
+}
+
+func Delete(input eir.DeleteDto) (*d.Data, error) {
+	rdDto := eir.ReadDetailDto{Id: input.Id}
+	var data *eir.InternalReference
+	var err error
+
+	event := pl.Event{
+		Feature: "Delete",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "delete")
+
+	err = dg.I.Transaction(func(tx *gorm.DB) error {
+		pl.SetLogInfo(&event, rdDto, "started", "DBReadDetail")
+		if data, err = ReadDetailData(rdDto, &event, tx); err != nil {
+			return err
+		}
+
+		mwRunner := newMiddlewareRunner(&event, tx)
+		mwRunner.setMwType(pu.MWTPre)
+		// Run pre-middleware
+		if err := mwRunner.RunDeleteMiddleware(readDetailPreMw, &rdDto, data); err != nil {
+			return err
+		}
+
+		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 {
+			return err
+		}
+
+		return nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &d.Data{
+		Meta: d.IS{
+			"source":    source,
+			"structure": "single-data",
+			"status":    "deleted",
+		},
+		Data: data.ToResponse(),
+	}, nil
+
+}

internal/use-case/main-use-case/internal-reference/helper.go

@@ -5,6 +5,7 @@ Any functions that are used internally by the use-case
 package internal_reference
 
 import (
+	"simrs-vx/internal/domain/base-entities/core"
 	ir "simrs-vx/internal/domain/main-entities/internal-reference"
 )
 
@@ -21,3 +22,14 @@ func setData[T *ir.CreateDto | *ir.UpdateDto](input T, data *ir.InternalReferenc
 	data.Unit_Id = inputSrc.Unit_Id
 	data.Doctor_Id = inputSrc.Doctor_Id
 }
+
+func setDataUpdate(src ir.UpdateDto) *ir.InternalReference {
+	return &ir.InternalReference{
+		Main: core.Main{
+			Id: uint(src.Id),
+		},
+		Encounter_Id: src.Encounter_Id,
+		Unit_Id:      src.Unit_Id,
+		Doctor_Id:    src.Doctor_Id,
+	}
+}

internal/use-case/main-use-case/internal-reference/lib.go

@@ -2,19 +2,20 @@ package internal_reference
 
 import (
 	"errors"
-	ir "simrs-vx/internal/domain/main-entities/internal-reference"
+	eir "simrs-vx/internal/domain/main-entities/internal-reference"
 	plh "simrs-vx/pkg/lib-helper"
 	pl "simrs-vx/pkg/logger"
+	pu "simrs-vx/pkg/use-case-helper"
 
 	dg "github.com/karincake/apem/db-gorm-pg"
 	gh "github.com/karincake/getuk"
 	"gorm.io/gorm"
 )
 
-func CreateData(input ir.CreateDto, event *pl.Event, dbx ...*gorm.DB) (*ir.InternalReference, error) {
+func CreateData(input eir.CreateDto, event *pl.Event, dbx ...*gorm.DB) (*eir.InternalReference, error) {
 	pl.SetLogInfo(event, nil, "started", "DBCreate")
 
-	data := ir.InternalReference{}
+	data := eir.InternalReference{}
 	setData(&input, &data)
 
 	var tx *gorm.DB
@@ -32,12 +33,12 @@ func CreateData(input ir.CreateDto, event *pl.Event, dbx ...*gorm.DB) (*ir.Inter
 	return &data, nil
 }
 
-func ReadListData(input ir.ReadListDto, event *pl.Event, dbx ...*gorm.DB) ([]ir.InternalReference, *ir.MetaDto, error) {
+func ReadListData(input eir.ReadListDto, event *pl.Event, dbx ...*gorm.DB) ([]eir.InternalReference, *eir.MetaDto, error) {
 	pl.SetLogInfo(event, input, "started", "DBReadList")
-	data := []ir.InternalReference{}
+	data := []eir.InternalReference{}
 	pagination := gh.Pagination{}
 	count := int64(0)
-	meta := ir.MetaDto{}
+	meta := eir.MetaDto{}
 
 	var tx *gorm.DB
 	if len(dbx) > 0 {
@@ -47,7 +48,7 @@ func ReadListData(input ir.ReadListDto, event *pl.Event, dbx ...*gorm.DB) ([]ir.
 	}
 
 	tx = tx.
-		Model(&ir.InternalReference{}).
+		Model(&eir.InternalReference{}).
 		Scopes(gh.Preload(input.Includes)).
 		Scopes(gh.Filter(input.FilterDto)).
 		Count(&count).
@@ -68,3 +69,78 @@ func ReadListData(input ir.ReadListDto, event *pl.Event, dbx ...*gorm.DB) ([]ir.
 	pl.SetLogInfo(event, nil, "complete")
 	return data, &meta, nil
 }
+
+func ReadDetailData(input eir.ReadDetailDto, event *pl.Event, dbx ...*gorm.DB) (*eir.InternalReference, error) {
+	pl.SetLogInfo(event, input, "started", "DBReadDetail")
+	data := eir.InternalReference{}
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	preload := "encounter,unit,doctor"
+
+	if err := tx.
+		Scopes(gh.Preload(preload)).
+		First(&data, input.Id).
+		Error; err != nil {
+
+		if processedErr := pu.HandleReadError(err, event, source, input.Id, data); processedErr != nil {
+			return nil, processedErr
+		}
+	}
+
+	pl.SetLogInfo(event, nil, "complete")
+	return &data, nil
+}
+
+func UpdateData(input eir.UpdateDto, data *eir.InternalReference, event *pl.Event, dbx ...*gorm.DB) error {
+	pl.SetLogInfo(event, data, "started", "DBUpdate")
+	data = setDataUpdate(input)
+
+	var tx *gorm.DB
+	if len(dbx) > 0 {
+		tx = dbx[0]
+	} else {
+		tx = dg.I
+	}
+
+	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 DeleteData(data *eir.InternalReference, 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
+}