/* 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 }