core

Documentation

Index

• Constants
• Variables
• func GetEntityByID(ctx context.Context, ds model.DataStore, id string) (interface{}, error)
• func LastFMNewClient() *lastfm.Client
• func SpotifyNewClient() *spotify.Client
• type Archiver
  • func NewArchiver(ds model.DataStore) Archiver
• type Artwork
  • func NewArtwork(ds model.DataStore, cache ArtworkCache) Artwork
• type ArtworkCache
  • func GetImageCache() ArtworkCache
• type CacheWarmer
  • func NewCacheWarmer(artwork Artwork, artworkCache ArtworkCache) CacheWarmer
• type ExternalInfo
  • func NewExternalInfo(ds model.DataStore, lfm *lastfm.Client, spf *spotify.Client) ExternalInfo
• type MediaStreamer
  • func NewMediaStreamer(ds model.DataStore, ffm transcoder.Transcoder, cache TranscodingCache) MediaStreamer
• type NowPlaying
  • func NewNowPlayingRepository() NowPlaying
• type NowPlayingInfo
• type Players
  • func NewPlayers(ds model.DataStore) Players
• type Stream
  • func (s *Stream) ContentType() string
  • func (s *Stream) Duration() float32
  • func (s *Stream) EstimatedContentLength() int
  • func (s *Stream) ModTime() time.Time
  • func (s *Stream) Name() string
  • func (s *Stream) Seekable() bool
• type TranscodingCache
  • func GetTranscodingCache() TranscodingCache

Constants

const NowPlayingExpire = 60 * time.Minute

const UnavailableArtistID = "-1"

Variables

var Set = wire.NewSet(
	NewArtwork,
	NewMediaStreamer,
	GetTranscodingCache,
	GetImageCache,
	NewArchiver,
	NewNowPlayingRepository,
	NewExternalInfo,
	NewCacheWarmer,
	NewPlayers,
	LastFMNewClient,
	SpotifyNewClient,
	transcoder.New,
)

Functions

func GetEntityByID

func GetEntityByID(ctx context.Context, ds model.DataStore, id string) (interface{}, error)

TODO: Should the type be encoded in the ID?

func LastFMNewClient

func LastFMNewClient() *lastfm.Client

func SpotifyNewClient

func SpotifyNewClient() *spotify.Client

Types

type Archiver

type Archiver interface {
	ZipAlbum(ctx context.Context, id string, w io.Writer) error
	ZipArtist(ctx context.Context, id string, w io.Writer) error
	ZipPlaylist(ctx context.Context, id string, w io.Writer) error
}

func NewArchiver

func NewArchiver(ds model.DataStore) Archiver

type Artwork

type Artwork interface {
	Get(ctx context.Context, id string, size int, out io.Writer) error
}

func NewArtwork

func NewArtwork(ds model.DataStore, cache ArtworkCache) Artwork

type ArtworkCache

type ArtworkCache cache.FileCache

func GetImageCache

func GetImageCache() ArtworkCache

type CacheWarmer

type CacheWarmer interface {
	AddAlbum(ctx context.Context, albumID string)
	Flush(ctx context.Context)
}

func NewCacheWarmer

func NewCacheWarmer(artwork Artwork, artworkCache ArtworkCache) CacheWarmer

type ExternalInfo

type ExternalInfo interface {
	UpdateArtistInfo(ctx context.Context, id string, count int, includeNotPresent bool) (*model.Artist, error)
	SimilarSongs(ctx context.Context, id string, count int) (model.MediaFiles, error)
	TopSongs(ctx context.Context, artist string, count int) (model.MediaFiles, error)
}

func NewExternalInfo

func NewExternalInfo(ds model.DataStore, lfm *lastfm.Client, spf *spotify.Client) ExternalInfo

type MediaStreamer

type MediaStreamer interface {
	NewStream(ctx context.Context, id string, reqFormat string, reqBitRate int) (*Stream, error)
}

func NewMediaStreamer

func NewMediaStreamer(ds model.DataStore, ffm transcoder.Transcoder, cache TranscodingCache) MediaStreamer

type NowPlaying

type NowPlaying interface {
	// Insert at the head of the queue
	Enqueue(*NowPlayingInfo) error

	// Returns all heads from all playerIds
	GetAll() ([]*NowPlayingInfo, error)
}

This repo must have the semantics of a FIFO queue, for each playerId

func NewNowPlayingRepository

func NewNowPlayingRepository() NowPlaying

type NowPlayingInfo

type NowPlayingInfo struct {
	TrackID    string
	Start      time.Time
	Username   string
	PlayerId   int
	PlayerName string
}

type Players

type Players interface {
	Get(ctx context.Context, playerId string) (*model.Player, error)
	Register(ctx context.Context, id, client, typ, ip string) (*model.Player, *model.Transcoding, error)
}

func NewPlayers

func NewPlayers(ds model.DataStore) Players

type Stream

type Stream struct {
	io.ReadCloser
	io.Seeker
	// contains filtered or unexported fields
}

func (*Stream) ContentType

func (s *Stream) ContentType() string

func (*Stream) Duration

func (s *Stream) Duration() float32

func (*Stream) EstimatedContentLength

func (s *Stream) EstimatedContentLength() int

func (*Stream) ModTime

func (s *Stream) ModTime() time.Time

func (*Stream) Name

func (s *Stream) Name() string

func (*Stream) Seekable

func (s *Stream) Seekable() bool

type TranscodingCache

type TranscodingCache cache.FileCache

func GetTranscodingCache

func GetTranscodingCache() TranscodingCache