indexer

Documentation

Index

• Variables
• func OpenAndProcessDefinition(file string) (*domain.IndexerDefinition, error)
• func ParseLine(logger Logger, pattern string, vars []string, tmpVars map[string]string, ...) (bool, error)
• type APIService
  • func NewAPIService(log logger.Logger) APIService
• type Logger
• type Service
  • func NewService(log logger.Logger, config *domain.Config, repo domain.IndexerRepo, ...) Service

Variables

var Definitions embed.FS

var ErrIndexerDefinitionDeprecated = errors.New("DEPRECATED: indexer definition version")

Functions

func OpenAndProcessDefinition

func OpenAndProcessDefinition(file string) (*domain.IndexerDefinition, error)

func ParseLine

func ParseLine(logger Logger, pattern string, vars []string, tmpVars map[string]string, line string, ignore bool) (bool, error)

Types

type APIService

type APIService interface {
	TestConnection(ctx context.Context, req domain.IndexerTestApiRequest) (bool, error)
	GetTorrentByID(ctx context.Context, indexer string, torrentID string) (*domain.TorrentBasic, error)
	AddClient(indexer string, settings map[string]string) error
	RemoveClient(indexer string) error
}

func NewAPIService

func NewAPIService(log logger.Logger) APIService

type Logger

type Logger interface {
	Debug() *zerolog.Event
}

type Service

type Service interface {
	Store(ctx context.Context, indexer domain.Indexer) (*domain.Indexer, error)
	Update(ctx context.Context, indexer domain.Indexer) (*domain.Indexer, error)
	Delete(ctx context.Context, id int) error
	FindByFilterID(ctx context.Context, id int) ([]domain.Indexer, error)
	FindByID(ctx context.Context, id int) (*domain.Indexer, error)
	List(ctx context.Context) ([]domain.Indexer, error)
	GetAll() ([]*domain.IndexerDefinition, error)
	GetTemplates() ([]domain.IndexerDefinition, error)
	LoadIndexerDefinitions() error
	GetIndexersByIRCNetwork(server string) []*domain.IndexerDefinition
	GetTorznabIndexers() []domain.IndexerDefinition
	GetMappedDefinitionByName(name string) (*domain.IndexerDefinition, error)
	Start() error
	TestApi(ctx context.Context, req domain.IndexerTestApiRequest) error
	ToggleEnabled(ctx context.Context, indexerID int, enabled bool) error
}

func NewService

func NewService(log logger.Logger, config *domain.Config, repo domain.IndexerRepo, releaseRepo domain.ReleaseRepo, apiService APIService, scheduler scheduler.Service) Service