simrsx-be/internal/use-case/_use-case-template/crud/case.go

/*
DESCRIPTION:
Any functions that are available to be used externally.
*/
package crud

import (
	"strconv"

	dg "github.com/karincake/apem/db-gorm-pg"
	lo "github.com/karincake/apem/logero"
	d "github.com/karincake/dodol"
	"gorm.io/gorm"

	e "simrs-vx/internal/domain/_template/single"
)

const source = "crud"

func Create(input e.Createdto) (*d.Data, error) {
	data := e.Single{}

	setData(&data, &input)
	err := dg.I.Transaction(func(tx *gorm.DB) error {
		lo.I.
		for i := range createPreMw {
			if err := createPreMw[i](&input, &data, tx); err != nil {
				return nil
			}
		}
		slog.
		if result, err := CreateData(&data, tx).Error; err != nil {
			return nil
		}

		for i := range createPostMw {
			if err := createPostMw[i](&input, &data, tx); err != nil {
				return nil
			}
		}

		return nil
	})

	return &d.Data{
		Meta: d.II{
			"source": source,
			"type":   "list",
			"status": "created",
		},
		Data: result,
	}, nil
}

func ReadList(input e.ReadListDto) (*d.Data, error) {
	err := dg.I.Transaction(func(tx *gorm.DB) error {
		for i := range readListPreMw {
			if err := readListPreMw[i](&input, &data, tx); err != nil {
				return nil
			}
		}

		data, meta, err := ReadListData(input, tx)
		if err != nil {
			return nil, err
		}

		for i := range readListPostMw {
			if err := readListPostMw[i](&input, &data, tx); err != nil {
				return nil
			}
		}

		return nil
	})

	return &d.Data{
		Meta: d.IS{
			"source":            source,
			"structure":         "list-data",
			"status":            "fetched",
			"page_number":       strconv.Itoa(meta.PageNumber),
			"page_size":         strconv.Itoa(meta.PageSize),
			"record_totalCount": strconv.Itoa(meta.Count),
		},
		Data: data,
	}, nil
}

func ReadDetail(input e.ReadDetailDto) (*d.Data, error) {
	err := dg.I.Transaction(func(tx *gorm.DB) error {
		for i := range readDetailPreMw {
			if err := readDetailPreMw[i](&input, &data, tx); err != nil {
				return nil
			}
		}
		data, err := ReadDetailData(input, tx)
		if err != nil {
			return nil, err
		}
		for i := range readDetailPostMw {
			if err := readDetailPostMw[i](&input, &data, tx); err != nil {
				return nil
			}
		}
		return nil
	})
	return &d.Data{
		Meta: d.IS{
			"source":    source,
			"structure": "single-data",
			"status":    "fetched",
		},
		Data: data,
	}, nil
}

func Update(input e.Updatedto) (*d.Data, error) {
	err := dg.I.Transaction(func(tx *gorm.DB) error {
		data, err := ReadDetailData(input, tx)
		if err != nil {
			return nil
		}

		setData(&data, &input)
		for i := range updatePreMw {
			if err := updatePreMw[i](&input, &data, tx); err != nil {
				return nil
			}
		}
		if err := UpdateData(*data, tx); err != nil {
			return nil
		}
		for i := range updatePostMw {
			if err := updatePostMw[i](&input, &data, tx); err != nil {
				return nil
			}
		}
		return nil
	})
	return &d.Data{
		Meta: d.IS{
			"source":    source,
			"structure": "single-data",
			"status":    "updated",
		},
		Data: data,
	}, nil

}

func Delete(input e.Deletedto) (*d.Data, error) {
	err := dg.I.Transaction(func(tx *gorm.DB) error {
		data, err := ReadDetailData(input, tx)
		if err != nil {
			return nil
		}
		for i := range deletePreMw {
			if err := deletePreMw[i](&input, &data, tx); err != nil {
				return nil
			}
		}
		if err := DeleteData(data, tx); err != nil {
			return nil
		}
		for i := range deletePostMw {
			if err := deletePostMw[i](&input, &data, tx); err != nil {
				return nil
			}
		}
	})
	return &d.Data{
		Meta: d.IS{
			"source":    source,
			"structure": "single-data",
			"status":    "deleted",
		},
		Data: data,
	}, nil

}