package benefactorkindboxvalidator import ( "context" "fmt" "time" "git.gocasts.ir/ebhomengo/niki/entity" refertimeparam "git.gocasts.ir/ebhomengo/niki/param/admin/refer_time" addressparam "git.gocasts.ir/ebhomengo/niki/param/benefactor/address" param "git.gocasts.ir/ebhomengo/niki/param/benefactor/benefactore" errmsg "git.gocasts.ir/ebhomengo/niki/pkg/err_msg" validation "github.com/go-ozzo/ozzo-validation/v4" ) type Repository interface { BenefactorKindBoxExist(ctx context.Context, benefactorID uint, kindBoxID uint) (bool, error) GetKindBox(ctx context.Context, kindBoxID uint) (entity.KindBox, error) } type BenefactorSvc interface { BenefactorExistByID(ctx context.Context, request param.BenefactorExistByIDRequest) (param.BenefactorExistByIDResponse, error) } type AddressSvc interface { AddressExistByID(ctx context.Context, request addressparam.GetAddressByIDRequest) (addressparam.GetAddressByIDResponse, error) } type ReferTimeSvc interface { GetReferTimeByID(ctx context.Context, req refertimeparam.GetReferTimeRequest) (refertimeparam.GetReferTimeResponse, error) } type Validator struct { repo Repository benefactorSvc BenefactorSvc addressSvc AddressSvc referTimeSvc ReferTimeSvc } func New(repo Repository, benefactorSvc BenefactorSvc, addressSvc AddressSvc, referTimeSvc ReferTimeSvc) Validator { return Validator{repo: repo, benefactorSvc: benefactorSvc, addressSvc: addressSvc, referTimeSvc: referTimeSvc} } func (v Validator) doesBenefactorExist(value interface{}) error { benefactorID, ok := value.(uint) if !ok { return fmt.Errorf(errmsg.ErrorMsgSomethingWentWrong) } _, err := v.benefactorSvc.BenefactorExistByID(context.Background(), param.BenefactorExistByIDRequest{ID: benefactorID}) if err != nil { return fmt.Errorf(errmsg.ErrorMsgNotFound) } return nil } func (v Validator) doesBenefactorKindBoxExist(benefactorID uint) validation.RuleFunc { return func(value interface{}) error { kbID, ok := value.(uint) if !ok { return fmt.Errorf(errmsg.ErrorMsgSomethingWentWrong) } exist, err := v.repo.BenefactorKindBoxExist(context.Background(), benefactorID, kbID) if err != nil { return fmt.Errorf(errmsg.ErrorMsgSomethingWentWrong) } if !exist { return fmt.Errorf(errmsg.ErrorMsgNotFound) } return nil } } func (v Validator) doesAddressExist(benefactorID uint) validation.RuleFunc { return func(value interface{}) error { addressID, ok := value.(uint) if !ok { return fmt.Errorf(errmsg.ErrorMsgSomethingWentWrong) } address, err := v.addressSvc.AddressExistByID(context.Background(), addressparam.GetAddressByIDRequest{ID: addressID}) if err != nil { return fmt.Errorf(errmsg.ErrorMsgSomethingWentWrong) } if address.Address == nil { return fmt.Errorf(errmsg.ErrorMsgNotFound) } if address.Address.BenefactorID != benefactorID { return fmt.Errorf(errmsg.ErrorMsgNotFound) } return nil } } func (v Validator) isDateValid(value interface{}) error { date, ok := value.(time.Time) if !ok { return fmt.Errorf(errmsg.ErrorMsgSomethingWentWrong) } if date.Before(time.Now()) { return fmt.Errorf(errmsg.ErrorMsgInvalidInput) } return nil } func (v Validator) isReferTimeIDValid(value interface{}) error { referTimeID, ok := value.(uint) if !ok { return fmt.Errorf(errmsg.ErrorMsgSomethingWentWrong) } resp, gErr := v.referTimeSvc.GetReferTimeByID(context.Background(), refertimeparam.GetReferTimeRequest{ ReferTimeID: referTimeID, }) if gErr != nil { return fmt.Errorf(errmsg.ErrorMsgReferTimeNotFound) } if resp.ReferTime.Status != entity.ReferTimeActiveStatus { return fmt.Errorf(errmsg.ErrorMsgReferTimeIsNotActive) } return nil } func (v Validator) doesKindBoxHaveDeliveredStatus(value interface{}) error { kindBoxID, ok := value.(uint) if !ok { return fmt.Errorf(errmsg.ErrorMsgSomethingWentWrong) } kindBox, err := v.repo.GetKindBox(context.Background(), kindBoxID) if err != nil { return fmt.Errorf(errmsg.ErrorMsgSomethingWentWrong) } if kindBox.Status != entity.KindBoxDeliveredStatus { return fmt.Errorf(errmsg.ErrorMsgInvalidStatus) } return nil }