fwatcher

type FileAction interface {
	HandleFile(file string) error
}

type FileIdempotent struct {
	gorm.Model
	FileName string `gorm:"size:64"`
	FileKey  string `gorm:"size:64;unique"`
}

type FileIdempotentService struct {
	Logger *zap.Logger
	Key    string
	DB     *gorm.DB
}

type FileWatcherParams struct {
	dig.In
	Ctx        context.Context
	Logger     *zap.Logger
	Action     FileAction
	Idempotent *FileIdempotentService `optional:"true"`
}

type FilelWatcher struct {
	Logger        *zap.Logger
	Action        FileAction
	Recursive     bool
	Path          string
	Interval      time.Duration
	Included      []string
	Excluded      []string
	RetryDelay    time.Duration
	RetryAttempts uint
	Delete        bool
	DoneFolder    string
	ErrorFolder   string
	ShouldRetry   retry.RetryIfFunc
	Idempotent    *FileIdempotentService
}