engine

package
v0.21.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 30, 2020 License: GPL-3.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

View Source 
const NowPlayingExpire = 60 * time.Minute

Variables

View Source 
var Set = wire.NewSet(
	NewBrowser,
	NewCover,
	NewListGenerator,
	NewPlaylists,
	NewRatings,
	NewScrobbler,
	NewSearch,
	NewNowPlayingRepository,
	NewUsers,
	NewMediaStreamer,
	transcoder.New,
	NewTranscodingCache,
	NewImageCache,
	NewPlayers,
)

Functions

This section is empty.

Types

type Browser 

type Browser interface {
	MediaFolders(ctx context.Context) (model.MediaFolders, error)
	Indexes(ctx context.Context, mediaFolderId string, ifModifiedSince time.Time) (model.ArtistIndexes, time.Time, error)
	Directory(ctx context.Context, id string) (*DirectoryInfo, error)
	Artist(ctx context.Context, id string) (*DirectoryInfo, error)
	Album(ctx context.Context, id string) (*DirectoryInfo, error)
	GetSong(ctx context.Context, id string) (*Entry, error)
	GetGenres(ctx context.Context) (model.Genres, error)
}

func NewBrowser 

func NewBrowser(ds model.DataStore) Browser

type Cover 

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

func NewCover 

func NewCover(ds model.DataStore, cache ImageCache) Cover

type DirectoryInfo 

type DirectoryInfo struct {
	Id         string
	Name       string
	Entries    Entries
	Parent     string
	Starred    time.Time
	PlayCount  int64
	UserRating int
	AlbumCount int
	CoverArt   string
	Artist     string
	ArtistId   string
	SongCount  int
	Duration   int
	Created    time.Time
	Year       int
	Genre      string
}

type Entries 

type Entries []Entry

func FromAlbums 

func FromAlbums(albums model.Albums) Entries

func FromArtists 

func FromArtists(ars model.Artists) Entries

func FromMediaFiles 

func FromMediaFiles(mfs model.MediaFiles) Entries

type Entry 

type Entry struct {
	Id          string
	Title       string
	IsDir       bool
	Parent      string
	Album       string
	Year        int
	Artist      string
	Genre       string
	CoverArt    string
	Starred     time.Time
	Track       int
	Duration    int
	Size        int64
	Suffix      string
	BitRate     int
	ContentType string
	Path        string
	PlayCount   int32
	DiscNumber  int
	Created     time.Time
	AlbumId     string
	ArtistId    string
	Type        string
	UserRating  int
	SongCount   int

	UserName   string
	MinutesAgo int
	PlayerId   int
	PlayerName string
	AlbumCount int

	AbsolutePath string
}

func FromAlbum 

func FromAlbum(al *model.Album) Entry

func FromArtist 

func FromArtist(ar *model.Artist) Entry

func FromMediaFile 

func FromMediaFile(mf *model.MediaFile) Entry

type ImageCache added in v0.14.0 

type ImageCache fscache.Cache

func NewImageCache added in v0.14.0 

func NewImageCache() (ImageCache, error)

type ListFilter added in v0.15.0 

type ListFilter model.QueryOptions

func ByArtist added in v0.15.0 

func ByArtist() ListFilter

func ByFrequent added in v0.15.0 

func ByFrequent() ListFilter

func ByGenre added in v0.15.0 

func ByGenre(genre string) ListFilter

func ByName added in v0.15.0 

func ByName() ListFilter

func ByNewest added in v0.15.0 

func ByNewest() ListFilter

func ByRandom added in v0.15.0 

func ByRandom() ListFilter

func ByRating added in v0.15.0 

func ByRating() ListFilter

func ByRecent added in v0.15.0 

func ByRecent() ListFilter

func ByStarred added in v0.15.0 

func ByStarred() ListFilter

func ByYear added in v0.15.0 

func ByYear(fromYear, toYear int) ListFilter

func SongsByGenre added in v0.15.0 

func SongsByGenre(genre string) ListFilter

func SongsByRandom added in v0.15.0 

func SongsByRandom(genre string, fromYear, toYear int) ListFilter

type ListGenerator 

type ListGenerator interface {
	GetAllStarred(ctx context.Context) (artists Entries, albums Entries, mediaFiles Entries, err error)
	GetNowPlaying(ctx context.Context) (Entries, error)
	GetSongs(ctx context.Context, offset, size int, filter ListFilter) (Entries, error)
	GetAlbums(ctx context.Context, offset, size int, filter ListFilter) (Entries, error)
}

func NewListGenerator 

func NewListGenerator(ds model.DataStore, npRepo NowPlayingRepository) ListGenerator

type MediaStreamer added in v0.6.0 

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

func NewMediaStreamer added in v0.6.0 

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

type NowPlayingInfo 

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

type NowPlayingRepository 

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

	// Removes and returns the element at the end of the queue
	Dequeue(playerId int) (*NowPlayingInfo, error)

	// Returns the element at the head of the queue (last inserted one)
	Head(playerId int) (*NowPlayingInfo, error)

	// Returns the element at the end of the queue (first inserted one)
	Tail(playerId int) (*NowPlayingInfo, error)

	// Size of the queue for the playerId
	Count(playerId int) (int64, 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() NowPlayingRepository

type Players added in v0.10.0 

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 added in v0.10.0 

func NewPlayers(ds model.DataStore) Players

type PlaylistInfo 

type PlaylistInfo struct {
	Id        string
	Name      string
	Entries   Entries
	SongCount int
	Duration  int
	Public    bool
	Owner     string
	Comment   string
	Created   time.Time
	Changed   time.Time
}

type Playlists 

type Playlists interface {
	GetAll(ctx context.Context) (model.Playlists, error)
	Get(ctx context.Context, id string) (*PlaylistInfo, error)
	Create(ctx context.Context, playlistId, name string, ids []string) error
	Delete(ctx context.Context, playlistId string) error
	Update(ctx context.Context, playlistId string, name *string, idsToAdd []string, idxToRemove []int) error
}

func NewPlaylists 

func NewPlaylists(ds model.DataStore) Playlists

type Ratings 

type Ratings interface {
	SetStar(ctx context.Context, star bool, ids ...string) error
	SetRating(ctx context.Context, id string, rating int) error
}

func NewRatings 

func NewRatings(ds model.DataStore) Ratings

type Scrobbler 

type Scrobbler interface {
	Register(ctx context.Context, playerId int, trackId string, playDate time.Time) (*model.MediaFile, error)
	NowPlaying(ctx context.Context, playerId int, playerName, trackId, username string) (*model.MediaFile, error)
}

func NewScrobbler 

func NewScrobbler(ds model.DataStore, npr NowPlayingRepository) Scrobbler
type Search interface {
	SearchArtist(ctx context.Context, q string, offset int, size int) (Entries, error)
	SearchAlbum(ctx context.Context, q string, offset int, size int) (Entries, error)
	SearchSong(ctx context.Context, q string, offset int, size int) (Entries, error)
}

func NewSearch 

func NewSearch(ds model.DataStore) Search

type Stream 

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

func (*Stream) ContentType added in v0.8.4 

func (s *Stream) ContentType() string

func (*Stream) Duration added in v0.8.4 

func (s *Stream) Duration() float32

func (*Stream) EstimatedContentLength added in v0.13.0 

func (s *Stream) EstimatedContentLength() int

func (*Stream) ModTime added in v0.8.4 

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

func (*Stream) Name added in v0.8.4 

func (s *Stream) Name() string

func (*Stream) Seekable added in v0.8.4 

func (s *Stream) Seekable() bool

type TranscodingCache added in v0.14.0 

type TranscodingCache fscache.Cache

func NewTranscodingCache added in v0.8.3 

func NewTranscodingCache() (TranscodingCache, error)

type Users 

type Users interface {
	Authenticate(ctx context.Context, username, password, token, salt, jwt string) (*model.User, error)
}

func NewUsers 

func NewUsers(ds model.DataStore) Users

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.