stores

type Database struct {
	Host     string `json:"host" mapstructure:"host"`
	User     string `json:"user" mapstructure:"user"`
	Password string `json:"password" mapstructure:"password"`
	DBName   string `json:"dbName" mapstructure:"dbName"`
	Port     int    `json:"port" mapstructure:"port"`

	ConnMaxLifetime int `json:"connMaxLifeTime" mapstructure:"connMaxLifeTime"`
	MaxIdleConns    int `json:"maxIdleConns" mapstructure:"maxIdleConns"`
	MaxOpenConns    int `json:"maxOpenConns" mapstructure:"maxOpenConns"`
}

type EventStore interface {
	Save(event *models.Event) error
	DeleteEvents(uint64) error
	Count() int64
}

type JobStore interface {
	Save(job *models.Job) error
	Update(job *models.Job) error
	GetPendingJobs() ([]*models.Job, error)
	SearchJobs(req *SearchJobs) ([]*models.Job, error)
	DeleteJobs([]string, uint64) error
	Count() int64
}

type MainStore interface {
	GetDB() *gorm.DB
	GetJobStore() JobStore
	GetProcessedBlockStore() ProcessedBlockStore
	GetEventStore() EventStore
}

type ProcessedBlockStore interface {
	Save(chainId string, height int64) error
	GetLatestBlock(chainId string) (int64, error)
}

type SearchJobs struct {
	Status       string
	Limit        int
	MaxCreatedAt int64
	Listeners    []string
}