adapters

Documentation

Index

• func NewCachedTracker(tracker usecases.Tracker, cache Cache) (usecases.Tracker, error)
• type AnilistMapper
  • func (mapper *AnilistMapper) Close() error
  • func (mapper *AnilistMapper) MapID(ctx context.Context, anilistId string) (string, error)
  • func (mapper *AnilistMapper) MapIDs(ctx context.Context, anilistIds []string) ([]string, error)
  • func (mapper *AnilistMapper) Refresh(ctx context.Context) error
• type AnilistStore
• type Cache
• type Getter
• type JSONLocalPath
  • func (source JSONLocalPath[F]) Fetch(ctx context.Context) ([]Metadata, error)
• type JSONSourceURL
  • func (source JSONSourceURL[F]) Fetch(ctx context.Context, client Getter) ([]Metadata, error)
• type Metadata
• type MetadataSource
• type Store

Functions

func NewCachedTracker

func NewCachedTracker(tracker usecases.Tracker, cache Cache) (usecases.Tracker, error)

Types

type AnilistMapper

type AnilistMapper struct {
	Source MetadataSource[Metadata]
	Store  AnilistStore
}

func (*AnilistMapper) Close

func (mapper *AnilistMapper) Close() error

func (*AnilistMapper) MapID

func (mapper *AnilistMapper) MapID(ctx context.Context, anilistId string) (string, error)

func (*AnilistMapper) MapIDs

func (mapper *AnilistMapper) MapIDs(ctx context.Context, anilistIds []string) ([]string, error)

func (*AnilistMapper) Refresh

func (mapper *AnilistMapper) Refresh(ctx context.Context) error

type AnilistStore

type AnilistStore interface {
	Store

	MappingByAnilistID(ctx context.Context, anilistId string) (*entities.Media, error)
	MappingByAnilistIDBulk(ctx context.Context, anilistIds []string) ([]*entities.Media, error)
}

type Cache

type Cache interface {
	io.Closer

	GetString(ctx context.Context, key string) (string, error)
	SetString(ctx context.Context, key, value string) error
}

type Getter

type Getter interface {
	Get(string) (*http.Response, error)
}

type JSONLocalPath

type JSONLocalPath[F Metadata] string

func (JSONLocalPath[F]) Fetch

func (source JSONLocalPath[F]) Fetch(ctx context.Context) ([]Metadata, error)

type JSONSourceURL

type JSONSourceURL[F Metadata] string

func (JSONSourceURL[F]) Fetch

func (source JSONSourceURL[F]) Fetch(ctx context.Context, client Getter) ([]Metadata, error)

type Metadata

type Metadata interface {
	GetAnilistID() string
	GetTvdbID() string
}

type MetadataSource

type MetadataSource[T Metadata] interface {
	Fetch(ctx context.Context, client Getter) ([]T, error)
}

type Store

type Store interface {
	io.Closer

	PutMedia(ctx context.Context, media *entities.Media) error
	PutMediaBulk(ctx context.Context, medias []*entities.Media) error
}