server

Documentation

Overview

Package server implements the moggio protocol.

Index

• Variables
• func Dir(useLocal bool, name string) http.FileSystem
• func FS(useLocal bool) http.FileSystem
• func FSByte(useLocal bool, name string) ([]byte, error)
• func FSMustByte(useLocal bool, name string) []byte
• func FSMustString(useLocal bool, name string) string
• func FSString(useLocal bool, name string) (string, error)
• func Index(w http.ResponseWriter, r *http.Request)
• func JSON(h func(io.Reader, url.Values, httprouter.Params) (interface{}, error)) httprouter.Handle
• func ListenAndServe(stateFile, addr, central string, devMode bool) error
• type Playlist
• type PlaylistChange
• type PlaylistInfo
• type ProtocolData
• type Seek
  • func NewSeek(canSeek bool, sr time.Duration, f func(int) ([]float32, error)) *Seek
  • func (s *Seek) Pos() time.Duration
  • func (s *Seek) Read(n int) (b []float32, err error)
  • func (s *Seek) Seek(offset time.Duration) error
• type Server
  • func New(stateFile, central string) (*Server, error)
  • func (srv *Server) Cmd(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)
  • func (srv *Server) Data(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)
  • func (srv *Server) GetMux(devMode bool) *http.ServeMux
  • func (srv *Server) ListenAndServe(addr string, devMode bool) error
  • func (srv *Server) OAuth(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
  • func (srv *Server) PlaylistChange(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)
  • func (srv *Server) ProtocolAdd(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)
  • func (srv *Server) ProtocolRefresh(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)
  • func (srv *Server) ProtocolRemove(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)
  • func (srv *Server) QueueChange(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)
  • func (srv *Server) TokenRegister(w http.ResponseWriter, r *http.Request, p httprouter.Params)
  • func (srv *Server) WebSocket(ws *websocket.Conn)
• type SongID
  • func (s SongID) ID() codec.ID
  • func (s SongID) Key() string
  • func (s SongID) MarshalJSON() ([]byte, error)
  • func (s SongID) Protocol() string
  • func (s SongID) Triple() (protocol, key string, id codec.ID)
• type State
  • func (s State) String() string
• type Status

Variables

var MoggioVersion string

Functions

func Dir

func Dir(useLocal bool, name string) http.FileSystem

Dir returns a http.Filesystem for the embedded assets on a given prefix dir. If useLocal is true, the filesystem's contents are instead used.

func FS

func FS(useLocal bool) http.FileSystem

FS returns a http.Filesystem for the embedded assets. If useLocal is true, the filesystem's contents are instead used.

func FSByte

func FSByte(useLocal bool, name string) ([]byte, error)

FSByte returns the named file from the embedded assets. If useLocal is true, the filesystem's contents are instead used.

func FSMustByte

func FSMustByte(useLocal bool, name string) []byte

FSMustByte is the same as FSByte, but panics if name is not present.

func FSMustString

func FSMustString(useLocal bool, name string) string

FSMustString is the string version of FSMustByte.

func FSString

func FSString(useLocal bool, name string) (string, error)

FSString is the string version of FSByte.

func Index

func Index(w http.ResponseWriter, r *http.Request)

func JSON

func JSON(h func(io.Reader, url.Values, httprouter.Params) (interface{}, error)) httprouter.Handle

func ListenAndServe

func ListenAndServe(stateFile, addr, central string, devMode bool) error

Types

type Playlist

type Playlist []SongID

type PlaylistChange

type PlaylistChange [][]string

type PlaylistInfo

type PlaylistInfo []listItem

type ProtocolData

type ProtocolData struct {
	Protocol string
	Key      string
}

type Seek

type Seek struct {
	// contains filtered or unexported fields
}

func NewSeek

func NewSeek(canSeek bool, sr time.Duration, f func(int) ([]float32, error)) *Seek

func (*Seek) Pos

func (s *Seek) Pos() time.Duration

func (*Seek) Read

func (s *Seek) Read(n int) (b []float32, err error)

func (*Seek) Seek

func (s *Seek) Seek(offset time.Duration) error

Seek sets the offset for the next Read to offset, relative to the origin of the file.

type Server

type Server struct {
	Queue     Playlist
	Playlists map[string]Playlist

	Username string
	Token    string

	Repeat      bool
	Random      bool
	Protocols   map[string]map[string]protocol.Instance
	MinDuration time.Duration

	// Current song data.
	PlaylistIndex int
	// contains filtered or unexported fields
}

func New

func New(stateFile, central string) (*Server, error)

func (*Server) Cmd

func (srv *Server) Cmd(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)

func (*Server) Data

func (srv *Server) Data(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)

func (*Server) GetMux

func (srv *Server) GetMux(devMode bool) *http.ServeMux

func (*Server) ListenAndServe

func (srv *Server) ListenAndServe(addr string, devMode bool) error

ListenAndServe listens on the TCP network address addr and then calls Serve to handle requests on incoming connections.

func (*Server) OAuth

func (srv *Server) OAuth(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

func (*Server) PlaylistChange

func (srv *Server) PlaylistChange(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)

func (*Server) ProtocolAdd

func (srv *Server) ProtocolAdd(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)

func (*Server) ProtocolRefresh

func (srv *Server) ProtocolRefresh(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)

func (*Server) ProtocolRemove

func (srv *Server) ProtocolRemove(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)

func (*Server) QueueChange

func (srv *Server) QueueChange(body io.Reader, form url.Values, ps httprouter.Params) (interface{}, error)

func (*Server) TokenRegister

func (srv *Server) TokenRegister(w http.ResponseWriter, r *http.Request, p httprouter.Params)

func (*Server) WebSocket

func (srv *Server) WebSocket(ws *websocket.Conn)

type SongID

type SongID codec.ID

func (SongID) ID

func (s SongID) ID() codec.ID

func (SongID) Key

func (s SongID) Key() string

func (SongID) MarshalJSON

func (s SongID) MarshalJSON() ([]byte, error)

func (SongID) Protocol

func (s SongID) Protocol() string

func (SongID) Triple

func (s SongID) Triple() (protocol, key string, id codec.ID)

type State

type State int

func (State) String

func (s State) String() string

type Status

type Status struct {
	// Playback state
	State State
	// Song ID.
	Song     SongID
	SongInfo codec.SongInfo
	// Elapsed time of current song.
	Elapsed time.Duration
	// Duration of current song.
	Time       time.Duration
	Random     bool
	Repeat     bool
	Username   string
	Hostname   string
	CentralURL string
}