antifraud

type AntiFraud interface {
	Run(ctx context.Context) error
	DealOpened(deal *sonm.Deal) error
	TrackTask(ctx context.Context, deal *sonm.Deal, taskID string) error
	FinishDeal(ctx context.Context, deal *sonm.Deal, optsFlags flags) error
}

type Config struct {
	TaskQuality            float64             `yaml:"task_quality" required:"true"`
	QualityCheckInterval   time.Duration       `yaml:"quality_check_interval" default:"15s"`
	BlacklistCheckInterval time.Duration       `yaml:"blacklist_check_interval" default:"5m"`
	ConnectionTimeout      time.Duration       `yaml:"connection_timeout" default:"60s"`
	LogProcessorConfig     LogProcessorConfig  `yaml:"log_processor"`
	PoolProcessorConfig    PoolProcessorConfig `yaml:"pool_processor"`
	Whitelist              []common.Address    `yaml:"whitelist"`
}

type LogProcessorConfig struct {
	ProcessorConfig `yaml:",inline"`
	Pattern         string  `yaml:"pattern" required:"true"`
	Field           int     `yaml:"field"`
	Multiplier      float64 `yaml:"multiplier" required:"true"`
	LogDir          string  `yaml:"log_dir"`
}

type Option func(options *processorOpts)

type PoolProcessorConfig struct {
	ProcessorConfig `yaml:",inline"`
	URL             string `yaml:"url"`
}

type Processor interface {
	Run(ctx context.Context) error
	TaskID() string
	TaskQuality() (accurate bool, quality float64)
}

type ProcessorConfig struct {
	Format          string        `yaml:"format" required:"true"`
	TrackInterval   time.Duration `yaml:"track_interval" default:"10s"`
	TaskWarmupDelay time.Duration `yaml:"warmup_delay" required:"true"`
	DecayTime       float64       `yaml:"decay_time" required:"true"`
}

type ProcessorFactory interface {
	LogProcessor(deal *types.Deal, taskID string, opts ...Option) Processor
	PoolProcessor(deal *types.Deal, taskID string, opts ...Option) Processor
}